network
Class CMessageSocket

CSocketBase
   |
   +--CStreamSocket, IMessagePipeEnd
         |
         +--CMessageSocket

Direct Known Subclasses:

CNetSession

class CMessageSocket

extends CStreamSocket, IMessagePipeEnd

Implements a Message Pipe over an Async IO stream socket. All methods that this class exposes are thread safe and may be called from any thread.

m_InQ

private CLockedMessageDeque m_InQ;

m_IsWriting

private bool m_IsWriting;

m_OutQ

private CLockedMessageDeque m_OutQ;

m_pRdBuffer

private u8* m_pRdBuffer;

m_pWrBuffer

private u8* m_pWrBuffer;

m_RdBufferSize

private uint m_RdBufferSize;

m_ReadingData

private bool m_ReadingData;

m_WrBufferSize

private uint m_WrBufferSize;

CMessageSocket

public CMessageSocket();

CMessageSocket

public CMessageSocket( CSocketInternal* pInt );

~CMessageSocket

public virtual ~CMessageSocket();

BeginConnect

public PS_RESULT BeginConnect( const char* address, int port );

See CStreamSocket::BeginConnect.

ConnectComplete

protected virtual void ConnectComplete( PS_RESULT );

OnClose

protected void OnClose( PS_RESULT errorCode );

OnMessage

protected virtual void OnMessage( CNetMessage* pMsg );

Push

public virtual void Push( CNetMessage* );

ReadComplete

protected virtual void ReadComplete( PS_RESULT );

StartReadHeader

private void StartReadHeader();

StartReadMessage

private void StartReadMessage();

StartWriteNextMessage

private void StartWriteNextMessage();

TryPop

public virtual CNetMessage* TryPop();

WriteComplete

protected virtual void WriteComplete( PS_RESULT );