Reimplemented from CActivatableObject::Callback.
Reimplemented from CActivatableObject::Callback.
typedef JetByteTools::Core::CActivatableObject::QueuedCommands QueuedCommands [protected] |
Reimplemented from CActivatableObject::Callback.
CSmartFilterDataBase [protected] |
enum CustomProcessorCommands [protected] |
CFilterDataBase | ( | ICallback & | callback, | |
JetByteTools::IO::IAllocateBuffers & | allocator, | |||
IFilterableStreamSocket & | socket, | |||
bool | wantWriteCompletions = false | |||
) |
CFilterDataBase | ( | const CFilterDataBase & | rhs | ) |
virtual ~CFilterDataBase | ( | ) | [protected, virtual] |
CFilterDataBase& operator= | ( | const CFilterDataBase & | rhs | ) |
bool OnRead | ( | JetByteTools::IO::CSmartBuffer & | buffer | ) | [override, virtual] |
void OnReadCompleted | ( | JetByteTools::IO::CSmartBuffer & | buffer | ) | [override, virtual] |
void OnWrite | ( | JetByteTools::IO::CSmartBuffer & | buffer | ) | [override, virtual] |
void OnWrite | ( | JetByteTools::IO::IIterateableBufferChain & | buffers | ) | [override, virtual] |
Implements IFilterData.
void OnWriteCompleted | ( | JetByteTools::IO::CSmartBuffer & | buffer | ) | [override, virtual] |
void OnWriteCompletionError | ( | JetByteTools::IO::CSmartBuffer & | buffer, | |
DWORD | lastError | |||
) | [override, virtual] |
void OnOutboundConnectionFailed | ( | ) | [override, virtual] |
Implements IFilterData.
void OnClientClose | ( | ) | [override, virtual] |
Implements IFilterData.
void OnConnectionReset | ( | DWORD | lastError | ) | [override, virtual] |
Implements IFilterData.
void OnConnectionClosed | ( | ) | [override, virtual] |
Implements IFilterData.
void OnConnectionShutdown | ( | ShutdownHow | how | ) | [override, virtual] |
Implements IFilterData.
void OnAllConnectionsAborted | ( | ConnectionClosureReason | reason, | |
bool | wasUserSocket | |||
) | [override, virtual] |
Implements IFilterData.
void OnSocketReleased | ( | ) | [override, virtual] |
Implements IFilterData.
bool ClientClosed | ( | ) | const [protected] |
bool ReadIsPending | ( | ) | const [protected] |
void IssueReadIfRequired | ( | ) | [protected] |
bool IssueReadIfPossible | ( | JetByteTools::IO::CSmartBuffer & | buffer | ) | [protected] |
void ApplicationReadCompleted | ( | ) | [protected] |
void PendingWriteCompleted | ( | bool | completeSocketWrite = true |
) | [protected] |
void PendingWritesCompleted | ( | size_t | numPendingWritesCompleted, | |
bool | completeSocketWrite = true | |||
) | [protected] |
bool TryWriteData | ( | JetByteTools::IO::CSmartBuffer & | buffer, | |
bool | weInitiatedWrite = false | |||
) | [protected] |
void WriteData | ( | JetByteTools::IO::CSmartBuffer & | buffer, | |
bool | weInitiatedWrite = false | |||
) | [protected] |
bool WriteData | ( | JetByteTools::IO::CSmartBuffer & | buffer, | |
const BYTE * | pData, | |||
DWORD | dataSize, | |||
bool | weInitiatedWrite = false | |||
) | [protected] |
void WriteCompleted | ( | ) | [protected] |
void WriteCompleted | ( | JetByteTools::IO::CSmartBuffer & | buffer, | |
bool | completeSocketWrite, | |||
bool | writeSideClosed | |||
) | [protected] |
void WriteCompletionError | ( | JetByteTools::IO::CSmartBuffer & | buffer, | |
DWORD | lastError | |||
) | [protected] |
void OnDataAvailable | ( | JetByteTools::IO::CSmartBuffer & | buffer | ) | [protected] |
CSmartBuffer Allocate | ( | ) | [override, protected, virtual] |
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] |
virtual CSmartBuffer AllocateCustomSizedBuffer | ( | IBuffer::BufferSize | bufferSize | ) | [pure virtual, inherited] |
Implemented in CBufferHandleAllocator, CCustomPoolBufferAllocator, IAllocateBuffers, IManageBufferLifeCycle, IPoolBuffers, and CNullBufferPool.
friend CSmartFilterDataBase [protected] |
JetByteTools::Core::CActivatableObject m_processor [protected] |
JetByteTools::IO::CBufferChain m_writeRequestBuffers [protected] |
JetByteTools::IO::CBufferChain m_writeCompleteBuffers [protected] |
JetByteTools::IO::IAllocateBuffers& m_allocator [protected] |
JetByteTools::Socket::IFilterableStreamSocket& m_socket [protected] |