The C++ framework for developing highly scalable, high performance servers on Windows platforms.

CWebSocket Class Reference

Inheritance diagram for CWebSocket:
Collaboration diagram for CWebSocket:

List of all members.

Public Types

typedef
BaseInterface::DataLength 
DataLength
typedef
JetByteTools::Core::IIndexedOpaqueUserData::UserDataIndex 
UserDataIndex

Public Member Functions

 CWebSocket (JetByteTools::Core::IReentrantLockableObject &lock, JetByteTools::Core::IProvideRandomNumbers &randomNumberProvider, JetByteTools::Socket::IStreamSocket &socket, JetByteTools::IO::IAllocateBuffers &allocator, IWebSocketInputHandler &inputHandler)
 CWebSocket (const CWebSocket &rhs)
CWebSocketoperator= (const CWebSocket &rhs)
void EnableMasking ()
void SendPong (const BYTE *pData, BYTE dataLength)
void StartMessage (MessageType type, __int64 messageSize, JetByteTools::IO::CSmartBuffer &buffer) override
void StartFragmentedMessage (MessageType type, __int64 fragmentSize, JetByteTools::IO::CSmartBuffer &buffer) override
void StartNewFragment (__int64 fragmentSize, JetByteTools::IO::CSmartBuffer &buffer, bool finalFragment) override
bool TryStartMessage (MessageType type, __int64 messageSize, JetByteTools::IO::CSmartBuffer &buffer) override
bool TryStartFragmentedMessage (MessageType type, __int64 fragmentSize, JetByteTools::IO::CSmartBuffer &buffer) override
bool TryStartNewFragment (__int64 fragmentSize, JetByteTools::IO::CSmartBuffer &buffer, bool finalFragment) override
void SendMessageData (JetByteTools::IO::CSmartBuffer &buffer) override
bool TrySendMessageData (JetByteTools::IO::CSmartBuffer &buffer) override
bool TryWriteText (JetByteTools::IO::CSmartBuffer &buffer) override
bool TryWriteText (const TCHAR *pData, DataLength dataLength) override
bool TryWriteText (const BYTE *pUTF8Data, DataLength dataLength) override
void WriteBinary (JetByteTools::IO::CSmartBuffer &buffer) override
void WriteBinary (const BYTE *pData, DataLength dataLength) override
bool TryWriteBinary (JetByteTools::IO::CSmartBuffer &buffer) override
bool TryWriteBinary (const BYTE *pData, DataLength dataLength) override
bool Close () override
bool Close (WORD statusCode) override
bool Close (WORD statusCode, const JetByteTools::Core::_tstring &reason) override
bool Ping (const BYTE *pData, BYTE dataLength) override
bool Pong (const BYTE *pData, BYTE dataLength) override
const std::string & GetIdentifierA () const override
JetByteTools::Core::_tstring GetIdentifier () const override
void OnConnectionClosed (bool shutdown)
bool InternalRead (JetByteTools::IO::CSmartBuffer &buffer)
bool InternalRead (JetByteTools::IO::IBuffer *pBuffer=nullptr)
bool TryWriteRaw (JetByteTools::IO::CSmartBuffer &buffer)
bool TryWriteRaw (const BYTE *pData, DataLength dataLength)
bool TryWriteRaw (const char *pData, DataLength dataLength)
bool TryRead () override
bool TryRead (JetByteTools::IO::CSmartBuffer &buffer) override
bool TryRead (JetByteTools::IO::IBuffer *pBuffer) override
void Read () override
void Read (JetByteTools::IO::CSmartBuffer &buffer) override
void Read (JetByteTools::IO::IBuffer *pBuffer) override
void WriteText (JetByteTools::IO::CSmartBuffer &buffer) override
void WriteText (const JetByteTools::Core::_tstring &text) override
void WriteText (const TCHAR *pData, DataLength dataLength) override
void WriteText (const BYTE *pUTF8Data, DataLength dataLength) override
bool TryWriteText (const JetByteTools::Core::_tstring &text) override
virtual bool TryWriteText (const TCHAR *pData, DataLength dataLength)=0
virtual bool TryWriteText (const BYTE *pUTF8Data, DataLength dataLength)=0
bool AbortConnection () override
JetByteTools::Socket::CAddress GetLocalAddress () const override
JetByteTools::Socket::CAddress GetRemoteAddress () const override
void AddRef () override
void Release () override
void * GetUserPointer (UserDataIndex index) const override
void SetUserPointer (UserDataIndex index, void *pData) override
ULONG_PTR GetUserData (UserDataIndex index) const override
void SetUserData (UserDataIndex index, ULONG_PTR data) override
JetByteTools::IO::CSmartBuffer Allocate () override
JetByteTools::IO::CSmartBuffer Allocate (JetByteTools::IO::IAllocateBuffer &allocator) override
JetByteTools::IO::CSmartBuffer AllocateCustomSizedBuffer (JetByteTools::IO::IBuffer::BufferSize bufferSize) override
JetByteTools::IO::CSmartBuffer AllocateCustomSizedBuffer (JetByteTools::IO::IAllocateBuffer &allocator, JetByteTools::IO::IBuffer::BufferSize bufferSize) override
void AddBufferToPool (JetByteTools::IO::IBuffer &buffer) override

Protected Types

typedef AutoCloser
< BaseInterface
CAutoCloser

Protected Member Functions

bool IsClosed ()
void ReduceCloseCounter ()
bool ShouldClose ()
void SendClose (JetByteTools::IO::CCustomPoolSmartBuffer &buffer)

Protected Attributes

JetByteTools::Socket::IStreamSocketm_socket
JetByteTools::IO::IAllocateBuffersm_allocator
JetByteTools::Core::IReentrantLockableObjectm_lock

Friends

class AutoWriteCountManager

Classes

class  AutoWriteCountManager


Member Typedef Documentation

typedef BaseInterface::DataLength DataLength [inherited]

typedef AutoCloser<BaseInterface> CAutoCloser [protected, inherited]


Constructor & Destructor Documentation

CWebSocket ( const CWebSocket rhs  ) 


Member Function Documentation

CWebSocket& operator= ( const CWebSocket rhs  ) 

void EnableMasking (  ) 

void SendPong ( const BYTE pData,
BYTE  dataLength 
)

void StartMessage ( MessageType  type,
__int64  messageSize,
JetByteTools::IO::CSmartBuffer buffer 
) [override]

void StartFragmentedMessage ( MessageType  type,
__int64  fragmentSize,
JetByteTools::IO::CSmartBuffer buffer 
) [override]

void StartNewFragment ( __int64  fragmentSize,
JetByteTools::IO::CSmartBuffer buffer,
bool  finalFragment 
) [override]

bool TryStartMessage ( MessageType  type,
__int64  messageSize,
JetByteTools::IO::CSmartBuffer buffer 
) [override]

bool TryStartFragmentedMessage ( MessageType  type,
__int64  fragmentSize,
JetByteTools::IO::CSmartBuffer buffer 
) [override]

bool TryStartNewFragment ( __int64  fragmentSize,
JetByteTools::IO::CSmartBuffer buffer,
bool  finalFragment 
) [override]

void SendMessageData ( JetByteTools::IO::CSmartBuffer buffer  )  [override]

bool TrySendMessageData ( JetByteTools::IO::CSmartBuffer buffer  )  [override]

bool TryWriteText ( JetByteTools::IO::CSmartBuffer buffer  )  [override, virtual]

Implements TWebSocketBase.

bool TryWriteText ( const TCHAR pData,
DataLength  dataLength 
) [override]

bool TryWriteText ( const BYTE pUTF8Data,
DataLength  dataLength 
) [override]

void WriteBinary ( JetByteTools::IO::CSmartBuffer buffer  )  [override]

void WriteBinary ( const BYTE pData,
DataLength  dataLength 
) [override]

bool TryWriteBinary ( JetByteTools::IO::CSmartBuffer buffer  )  [override]

bool TryWriteBinary ( const BYTE pData,
DataLength  dataLength 
) [override]

bool Close (  )  [override]

bool Close ( WORD  statusCode  )  [override]

bool Close ( WORD  statusCode,
const JetByteTools::Core::_tstring reason 
) [override]

bool Ping ( const BYTE pData,
BYTE  dataLength 
) [override]

bool Pong ( const BYTE pData,
BYTE  dataLength 
) [override]

const std::string& GetIdentifierA (  )  const [inline, override, inherited]

JetByteTools::Core::_tstring GetIdentifier (  )  const [inline, override, inherited]

void OnConnectionClosed ( bool  shutdown  )  [inline, inherited]

bool InternalRead ( JetByteTools::IO::CSmartBuffer buffer  )  [inline, inherited]

bool InternalRead ( JetByteTools::IO::IBuffer *  pBuffer = nullptr  )  [inline, inherited]

bool TryWriteRaw ( JetByteTools::IO::CSmartBuffer buffer  )  [inline, inherited]

bool TryWriteRaw ( const BYTE pData,
DataLength  dataLength 
) [inline, inherited]

bool TryWriteRaw ( const char *  pData,
DataLength  dataLength 
) [inline, inherited]

bool TryRead (  )  [inline, override, inherited]

bool TryRead ( JetByteTools::IO::CSmartBuffer buffer  )  [inline, override, inherited]

bool TryRead ( JetByteTools::IO::IBuffer *  pBuffer  )  [inline, override, inherited]

void Read (  )  [inline, override, inherited]

void Read ( JetByteTools::IO::CSmartBuffer buffer  )  [inline, override, inherited]

void Read ( JetByteTools::IO::IBuffer *  pBuffer  )  [inline, override, inherited]

void WriteText ( JetByteTools::IO::CSmartBuffer buffer  )  [inline, override, inherited]

void WriteText ( const JetByteTools::Core::_tstring text  )  [inline, override, inherited]

void WriteText ( const TCHAR pData,
DataLength  dataLength 
) [inline, override, inherited]

void WriteText ( const BYTE pUTF8Data,
DataLength  dataLength 
) [inline, override, inherited]

bool TryWriteText ( const JetByteTools::Core::_tstring text  )  [inline, override, inherited]

virtual bool TryWriteText ( const TCHAR pData,
DataLength  dataLength 
) [pure virtual, inherited]

virtual bool TryWriteText ( const BYTE pUTF8Data,
DataLength  dataLength 
) [pure virtual, inherited]

bool AbortConnection (  )  [inline, override, inherited]

JetByteTools::Socket::CAddress GetLocalAddress (  )  const [inline, override, inherited]

JetByteTools::Socket::CAddress GetRemoteAddress (  )  const [inline, override, inherited]

void AddRef (  )  [inline, override, inherited]

void Release (  )  [inline, override, inherited]

void * GetUserPointer ( UserDataIndex  index  )  const [inline, override, inherited]

void SetUserPointer ( UserDataIndex  index,
void *  pData 
) [inline, override, inherited]

ULONG_PTR GetUserData ( UserDataIndex  index  )  const [inline, override, inherited]

void SetUserData ( UserDataIndex  index,
ULONG_PTR  data 
) [inline, override, inherited]

JetByteTools::IO::CSmartBuffer Allocate (  )  [inline, override, inherited]

JetByteTools::IO::CSmartBuffer Allocate ( JetByteTools::IO::IAllocateBuffer allocator  )  [inline, override, inherited]

JetByteTools::IO::CSmartBuffer AllocateCustomSizedBuffer ( JetByteTools::IO::IBuffer::BufferSize  bufferSize  )  [inline, override, inherited]

JetByteTools::IO::CSmartBuffer AllocateCustomSizedBuffer ( JetByteTools::IO::IAllocateBuffer allocator,
JetByteTools::IO::IBuffer::BufferSize  bufferSize 
) [inline, override, inherited]

void AddBufferToPool ( JetByteTools::IO::IBuffer &  buffer  )  [inline, override, inherited]

bool IsClosed (  )  [inline, protected, inherited]

void ReduceCloseCounter (  )  [inline, protected, inherited]

bool ShouldClose (  )  [inline, protected, inherited]

void SendClose ( JetByteTools::IO::CCustomPoolSmartBuffer buffer  )  [inline, protected, inherited]


Friends And Related Function Documentation

friend class AutoWriteCountManager [friend]


Member Data Documentation


Generated on Sun Sep 12 19:11:29 2021 for The Server Framework - v7.4 by doxygen 1.5.3