Toshi::T2NamedPipeServerThread Class Reference

#include <T2NamedPipeServer_Win.h>

Inheritance diagram for Toshi::T2NamedPipeServerThread:

Public Member Functions
	T2NamedPipeServerThread (T2NamedPipeServer *a_pServer)
virtual void	Main () override
Public Member Functions inherited from TThread
virtual	~TThread ()
TBOOL	Create (size_t a_iStackSize, PRIORITY a_ePriority, TUINT8 a_eFlags)
TBOOL	Destroy ()
Public Member Functions inherited from T2GenericDList::Node
constexpr	Node ()
	~Node ()
TBOOL	IsLinked () const
void	InsertBefore (Node *pInsertBefore)
void	InsertAfter (Node *pInsertAfter)
void	Remove ()
Node *	Next () const
Node *	Prev () const

Additional Inherited Members
Public Types inherited from TThread
enum	PRIORITY_ : PRIORITY {   THREAD_MODE_BACKGROUND_BEGIN = 0x00010000 , THREAD_MODE_BACKGROUND_END = 0x00020000 , THREAD_PRIORITY_ABOVE_NORMAL = 1 , THREAD_PRIORITY_BELOW_NORMAL = -1 ,   THREAD_PRIORITY_HIGHEST = 2 , THREAD_PRIORITY_IDLE = -15 , THREAD_PRIORITY_LOWEST = -2 , THREAD_PRIORITY_NORMAL = 0 ,   THREAD_PRIORITY_TIME_CRITICAL = 15 }
typedef TINT	PRIORITY
Static Public Member Functions inherited from TThread
static TBOOL	GetPriority (void *a_hThreadHnd, PRIORITY &a_ePriority)
static TBOOL	SetPriority (void *a_hThreadHnd, PRIORITY a_ePriority)
static void	Exit (TThread *a_pThread)
Public Attributes inherited from TThread
void *	m_hThreadHnd
unsigned long	m_iThreadID
Protected Attributes inherited from T2GenericDList::Node
friend	T2GenericDList

Detailed Description

Definition at line 11 of file T2NamedPipeServer_Win.h.

Constructor & Destructor Documentation

T2NamedPipeServerThread()

Toshi::T2NamedPipeServerThread::T2NamedPipeServerThread

(

T2NamedPipeServer *

a_pServer

)

Definition at line 14 of file T2NamedPipeServer_Win.cpp.

    : m_pServer( a_pServer )
{
}

Member Function Documentation

Main()

void Toshi::T2NamedPipeServerThread::Main ( )

overridevirtual

Implements TThread.

Definition at line 19 of file T2NamedPipeServer_Win.cpp.

{
    while ( TTRUE )
    {
        TBOOL bHasClient = TTRUE;
 
        if ( ConnectNamedPipe( m_pServer->m_hPipe, NULL ) == FALSE )
        {
            auto iErr = GetLastError();
 
            if ( iErr == ERROR_NO_DATA )
            {
                DisconnectNamedPipe( m_pServer->m_hPipe );
                TTRACE( "A client has disconnected from the '%s' named pipe\n", m_pServer->m_szName );
                m_pServer->m_bHasClient = TFALSE;
                bHasClient              = TFALSE;
            }
            else if ( iErr != ERROR_PIPE_CONNECTED )
            {
                TASSERT( TFALSE, "Failed ConnectNamedPipe" );
                bHasClient = TFALSE;
            }
        }
 
        if ( bHasClient )
        {
            if ( m_pServer->m_bHasClient == TFALSE )
            {
                TTRACE( "A client has connected to the '%s' named pipe\n", m_pServer->m_szName );
                m_pServer->m_bHasClient = TTRUE;
            }
 
            if ( m_pServer->m_fnUpdateStream )
            {
                m_pServer->m_fnUpdateStream( m_pServer->m_pMemory, m_pServer->m_uiMemorySize, m_pServer->m_pUserData );
            }
 
            if ( m_pServer->m_pMemory && m_pServer->m_uiMemorySize > 0 )
            {
                WriteFile(
                    m_pServer->m_hPipe,
                    m_pServer->m_pMemory,
                    m_pServer->m_uiMemorySize,
                    NULL,
                    NULL
                );
            }
        }
 
        ThreadSleep( m_pServer->m_uiSendInterval );
    }
}

---

The documentation for this class was generated from the following files:

• D:/_dev/OpenBarnyard/Source/Toshi/Source/Platform/Windows/T2NamedPipeServer_Win.h
• D:/_dev/OpenBarnyard/Source/Toshi/Source/Platform/Windows/T2NamedPipeServer_Win.cpp