Public Types | |
enum | HandlerConfigurationFlags { InsecureConnection = 0x00000000, SecureConnection = 0x00000001, NoMaskingRequirements = 0x00000000, RequireMaskedInput = 0x00000010, RequireUnmaskedInput = 0x00000020, DoNotRequireMaskedInput = 0x00000040, RequireMaskedOutput = 0x00000100, AccumulateCompleteMessage = 0x00001000, DispatchTextAsBinary = 0x00000000, DispatchTextAsStrings = 0x00010000, DoNotValidateText = 0x00000000, ValidateText = 0x00100000, AlreadyConnected = 0x01000000, ServerMaskingRequirements = RequireMaskedInput, ClientMaskingRequirements = RequireMaskedOutput | RequireUnmaskedInput, ConnectionSecurityMask = 0x00000001, InputMaskingPolicyMask = 0x00000070, OutputMaskingPolicyMask = 0x00000100, MaskingPolicyMask = InputMaskingPolicyMask | OutputMaskingPolicyMask, AccumulationPolicyMask = 0x00001000, DispatchTextPolicyMask = 0x00010000, TextValidationPolicyMask = 0x00100000, InitialConnectionStateMask = 0x01000000, ValidFlagsMask } |
Public Member Functions | |
CProtocolHandler (IWebSocketServer &server, JetByteTools::Socket::IStreamSocket &socket, JetByteTools::IO::IAllocateBuffers &allocator, DWORD flags=InsecureConnection|ServerMaskingRequirements) | |
CProtocolHandler (JetByteTools::Core::IProvideRandomNumbers &randomNumberProvider, IWebSocketServer &server, JetByteTools::Socket::IStreamSocket &socket, JetByteTools::IO::IAllocateBuffers &allocator, DWORD flags=InsecureConnection|ServerMaskingRequirements) | |
CProtocolHandler (const CProtocolHandler &rhs) | |
CProtocolHandler & | operator= (const CProtocolHandler &rhs) |
void | AddRef () |
void | Release () |
void | Connect (const std::string &host, const std::string &url) |
void | Connect (const std::string &host, const std::string &url, const std::string &subProtocols) |
void | Connect (const std::string &host, const std::string &url, const std::string &subProtocols, const std::string &version) |
void | AcceptHandshake () |
void | OnConnectionEstablished (const std::string &uri, JetByteTools::IO::IBuffer::SequenceNumber nextSequenceNumber) override |
void | OnDataReceived (JetByteTools::IO::CSmartBuffer &buffer) override |
void | OnConnectionClosed () override |
~CProtocolHandler () override |
CProtocolHandler | ( | IWebSocketServer & | server, | |
JetByteTools::Socket::IStreamSocket & | socket, | |||
JetByteTools::IO::IAllocateBuffers & | allocator, | |||
DWORD | flags = InsecureConnection | ServerMaskingRequirements | |||
) |
CProtocolHandler | ( | JetByteTools::Core::IProvideRandomNumbers & | randomNumberProvider, | |
IWebSocketServer & | server, | |||
JetByteTools::Socket::IStreamSocket & | socket, | |||
JetByteTools::IO::IAllocateBuffers & | allocator, | |||
DWORD | flags = InsecureConnection | ServerMaskingRequirements | |||
) |
CProtocolHandler | ( | const CProtocolHandler & | rhs | ) |
~CProtocolHandler | ( | ) | [override] |
CProtocolHandler& operator= | ( | const CProtocolHandler & | rhs | ) |
void AddRef | ( | ) |
void Release | ( | ) |
void Connect | ( | const std::string & | host, | |
const std::string & | url | |||
) |
void Connect | ( | const std::string & | host, | |
const std::string & | url, | |||
const std::string & | subProtocols | |||
) |
void Connect | ( | const std::string & | host, | |
const std::string & | url, | |||
const std::string & | subProtocols, | |||
const std::string & | version | |||
) |
void AcceptHandshake | ( | ) |
void OnConnectionEstablished | ( | const std::string & | uri, | |
JetByteTools::IO::IBuffer::SequenceNumber | nextSequenceNumber | |||
) | [override, virtual] |
Implements IConnectableProtocolHandler.
void OnDataReceived | ( | JetByteTools::IO::CSmartBuffer & | buffer | ) | [override, virtual] |
Implements IProtocolHandler.
void OnConnectionClosed | ( | ) | [override, virtual] |
Implements IProtocolHandler.