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

CWriteOnlyFilterData Class Reference

Inheritance diagram for CWriteOnlyFilterData:
Collaboration diagram for CWriteOnlyFilterData:

List of all members.

Public Types

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

Public Member Functions

 CWriteOnlyFilterData (CFilterDataBase::ICallback &callback, JetByteTools::IO::IAllocateBuffers &allocator, IFilterableStreamSocket &socket, bool wantWriteCompletions=false)
 CWriteOnlyFilterData (const CWriteOnlyFilterData &rhs)
CWriteOnlyFilterDataoperator= (const CWriteOnlyFilterData &rhs)
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

enum  CustomProcessorCommands { FirstCustomCommandCode = NextCommandCode }
typedef
JetByteTools::Core::CActivatableObject::QueuedCommands 
QueuedCommands
typedef
JetByteTools::Core::TReferenceCountedSmartPointer
< CFilterDataBase
CSmartFilterDataBase

Protected Member Functions

virtual ~CWriteOnlyFilterData ()
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


Member Typedef Documentation

CSmartFilterDataBase [protected, inherited]


Member Enumeration Documentation

enum CustomProcessorCommands [protected, inherited]

Enumerator:
FirstCustomCommandCode 


Constructor & Destructor Documentation

CWriteOnlyFilterData ( CFilterDataBase::ICallback callback,
JetByteTools::IO::IAllocateBuffers allocator,
IFilterableStreamSocket socket,
bool  wantWriteCompletions = false 
)

virtual ~CWriteOnlyFilterData (  )  [protected, virtual]


Member Function Documentation

CWriteOnlyFilterData& operator= ( const CWriteOnlyFilterData rhs  ) 

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

Reimplemented from CFilterDataBase.

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

Reimplemented from CFilterDataBase.

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:44 2021 for The Server Framework - v7.4 by doxygen 1.5.3