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

CAsyncConnector Class Reference

Inheritance diagram for CAsyncConnector:
Collaboration diagram for CAsyncConnector:

List of all members.

Public Types

typedef
JetByteTools::Core::CActivatableObject::CommandCode 
CommandCode
typedef
JetByteTools::Core::CActivatableObject::IProcessQueuedCommand 
IProcessQueuedCommand

Public Member Functions

 CAsyncConnector (const CContext &context, ICallback &callback, JetByteTools::IO::IAllocateBuffers &allocator, JetByteTools::Socket::IFilterableStreamSocket &socket)
 CAsyncConnector (const CAsyncConnector &rhs)
virtual ~CAsyncConnector ()
CAsyncConnectoroperator= (const CAsyncConnector &rhs)
JetByteTools::Core::_tstring GetTargetName () const
bool RequirePeerVerification () const
void StartHandshake ()
void Renegotiate (ClientAuthenticationRequirements requirements)
void AllowRenegotiation (bool allow)
void Shutdown ()
void SendAlert (DWORD alertType, DWORD alertNumber)
void SessionControl (DWORD sessionFlags)
bool OnRead (JetByteTools::IO::CSmartBuffer &buffer) override
void OnReadCompleted (JetByteTools::IO::CSmartBuffer &buffer) override
void OnWrite (JetByteTools::IO::CSmartBuffer &buffer) override
void OnWrite (JetByteTools::IO::IIterateableBufferChain &buffers) override
void OnWriteCompleted (JetByteTools::IO::CSmartBuffer &buffer) override
void OnWriteCompletionError (JetByteTools::IO::CSmartBuffer &buffer, DWORD lastError) override
void OnOutboundConnectionFailed () override
void OnClientClose () override
void OnConnectionReset (DWORD lastError) override
void OnConnectionClosed () override
void OnConnectionShutdown (ShutdownHow how) override
void OnAllConnectionsAborted (ConnectionClosureReason reason, bool wasUserSocket) override
void OnSocketReleased () override
virtual CSmartBuffer AllocateCustomSizedBuffer (IBuffer::BufferSize bufferSize)=0

Protected Types

typedef
JetByteTools::Core::CActivatableObject::QueuedCommands 
QueuedCommands
typedef
JetByteTools::Core::TReferenceCountedSmartPointer
< CFilterDataBase > 
CSmartFilterDataBase

Protected Member Functions

bool ClientClosed () const
bool ReadIsPending () const
void IssueReadIfRequired ()
bool IssueReadIfPossible (JetByteTools::IO::CSmartBuffer &buffer)
void ApplicationReadCompleted ()
void PendingWriteCompleted (bool completeSocketWrite=true)
void PendingWritesCompleted (size_t numPendingWritesCompleted, bool completeSocketWrite=true)
bool TryWriteData (JetByteTools::IO::CSmartBuffer &buffer, bool weInitiatedWrite=false)
void WriteData (JetByteTools::IO::CSmartBuffer &buffer, bool weInitiatedWrite=false)
bool WriteData (JetByteTools::IO::CSmartBuffer &buffer, const BYTE *pData, DWORD dataSize, bool weInitiatedWrite=false)
void WriteCompleted ()
void WriteCompleted (JetByteTools::IO::CSmartBuffer &buffer, bool completeSocketWrite, bool writeSideClosed)
void WriteCompletionError (JetByteTools::IO::CSmartBuffer &buffer, DWORD lastError)
void OnDataAvailable (JetByteTools::IO::CSmartBuffer &buffer)
JetByteTools::IO::CSmartBuffer Allocate () override
 Allocate an instance of IBuffer, remember to call Release() on it when you're done with it.
JetByteTools::IO::CSmartBuffer AllocateCustomSizedBuffer (JetByteTools::IO::IBuffer::BufferSize bufferSize) override

Protected Attributes

friend CSmartFilterDataBase
JetByteTools::Core::CActivatableObject m_processor
JetByteTools::IO::CBufferChainStoresNulls m_readRequestBuffers
JetByteTools::IO::CSequencedBufferCollection m_readCompleteBuffers
JetByteTools::IO::CBufferChain m_writeRequestBuffers
JetByteTools::IO::CBufferChain m_writeCompleteBuffers
JetByteTools::IO::IAllocateBuffersm_allocator
JetByteTools::Socket::IFilterableStreamSocketm_socket

Classes

class  DecryptedData
class  ICallback


Member Typedef Documentation

CSmartFilterDataBase [protected, inherited]


Constructor & Destructor Documentation

CAsyncConnector ( const CAsyncConnector rhs  ) 

~CAsyncConnector (  )  [virtual]


Member Function Documentation

CAsyncConnector& operator= ( const CAsyncConnector rhs  ) 

_tstring GetTargetName (  )  const

bool RequirePeerVerification (  )  const

void StartHandshake (  ) 

void Renegotiate ( ClientAuthenticationRequirements  requirements  ) 

void AllowRenegotiation ( bool  allow  ) 

void Shutdown (  ) 

void SendAlert ( DWORD  alertType,
DWORD  alertNumber 
)

void SessionControl ( DWORD  sessionFlags  ) 

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

Implements IFilterData.

Reimplemented in CWriteOnlyFilterData.

void OnReadCompleted ( JetByteTools::IO::CSmartBuffer buffer  )  [override, virtual, inherited]

Implements IFilterData.

Reimplemented in CWriteOnlyFilterData.

void OnWrite ( JetByteTools::IO::CSmartBuffer buffer  )  [override, virtual, inherited]

Implements IFilterData.

Reimplemented in CReadOnlyFilterData.

void OnWrite ( JetByteTools::IO::IIterateableBufferChain buffers  )  [override, virtual, inherited]

Implements IFilterData.

void OnWriteCompleted ( JetByteTools::IO::CSmartBuffer buffer  )  [override, virtual, inherited]

Implements IFilterData.

Reimplemented in CReadOnlyFilterData.

void OnWriteCompletionError ( JetByteTools::IO::CSmartBuffer buffer,
DWORD  lastError 
) [override, virtual, inherited]

Implements IFilterData.

Reimplemented in CReadOnlyFilterData.

void OnOutboundConnectionFailed (  )  [override, virtual, inherited]

Implements IFilterData.

void OnClientClose (  )  [override, virtual, inherited]

Implements IFilterData.

void OnConnectionReset ( DWORD  lastError  )  [override, virtual, inherited]

Implements IFilterData.

void OnConnectionClosed (  )  [override, virtual, inherited]

Implements IFilterData.

void OnConnectionShutdown ( ShutdownHow  how  )  [override, virtual, inherited]

Implements IFilterData.

void OnAllConnectionsAborted ( ConnectionClosureReason  reason,
bool  wasUserSocket 
) [override, virtual, inherited]

Implements IFilterData.

void OnSocketReleased (  )  [override, virtual, inherited]

Implements IFilterData.

bool ClientClosed (  )  const [protected, inherited]

bool ReadIsPending (  )  const [protected, inherited]

void IssueReadIfRequired (  )  [protected, inherited]

bool IssueReadIfPossible ( JetByteTools::IO::CSmartBuffer buffer  )  [protected, inherited]

void ApplicationReadCompleted (  )  [protected, inherited]

void PendingWriteCompleted ( bool  completeSocketWrite = true  )  [protected, inherited]

void PendingWritesCompleted ( size_t  numPendingWritesCompleted,
bool  completeSocketWrite = true 
) [protected, inherited]

bool TryWriteData ( JetByteTools::IO::CSmartBuffer buffer,
bool  weInitiatedWrite = false 
) [protected, inherited]

void WriteData ( JetByteTools::IO::CSmartBuffer buffer,
bool  weInitiatedWrite = false 
) [protected, inherited]

bool WriteData ( JetByteTools::IO::CSmartBuffer buffer,
const BYTE pData,
DWORD  dataSize,
bool  weInitiatedWrite = false 
) [protected, inherited]

void WriteCompleted (  )  [protected, inherited]

void WriteCompleted ( JetByteTools::IO::CSmartBuffer buffer,
bool  completeSocketWrite,
bool  writeSideClosed 
) [protected, inherited]

void WriteCompletionError ( JetByteTools::IO::CSmartBuffer buffer,
DWORD  lastError 
) [protected, inherited]

void OnDataAvailable ( JetByteTools::IO::CSmartBuffer buffer  )  [protected, inherited]

CSmartBuffer Allocate (  )  [override, protected, virtual, inherited]

Allocate an instance of IBuffer, remember to call Release() on it when you're done with it.

Implements IAllocateBuffer.

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

virtual CSmartBuffer AllocateCustomSizedBuffer ( IBuffer::BufferSize  bufferSize  )  [pure virtual, inherited]


Member Data Documentation

friend CSmartFilterDataBase [protected, inherited]


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