typedef TAsyncSocket<IPoolableStreamSocket, IStreamSocketConnectionManager, IStreamSocketCallback> Base |
CStreamSocket | ( | JetByteTools::Core::IIndexedOpaqueUserData::UserDataIndex | numberOfUserDataSlots, | |
PerSocketBufferPoolingLimit | maxPooledBuffers, | |||
ConsecutiveSocketOperations | maxConsecutiveOperations | |||
) |
Create a socket with the specified number of user data slots.
CStreamSocket | ( | const CStreamSocket & | rhs | ) |
~CStreamSocket | ( | ) | [protected] |
CStreamSocket& operator= | ( | const CStreamSocket & | rhs | ) |
void SetNagle | ( | bool | nagle | ) | const [override] |
void SetKeepAlive | ( | Milliseconds | time, | |
Milliseconds | interval | |||
) | const [override] |
void DisableKeepAlive | ( | ) | const [override] |
CStreamSocket::DataLength GetReceiveBufferSize | ( | ) | const [override] |
CStreamSocket::DataLength SetReceiveBufferSize | ( | DataLength | requestedSize | ) | [override] |
CStreamSocket::DataLength SetSendBufferSize | ( | DataLength | requestedSize | ) | [override] |
CStreamSocket::DataLength GetSendBufferSize | ( | ) | const [override] |
void OnAttach | ( | ) | [override, protected, virtual] |
void CancelIOIfNecessary | ( | ) | [override, protected, virtual] |
Reimplemented from TAsyncSocket.
const std::string & GetIdentifierA | ( | ) | const [inline, protected, virtual, inherited] |
JetByteTools::Core::_tstring GetIdentifier | ( | ) | const [inline, protected, virtual, inherited] |
bool IsLockedByThisThread | ( | ) | const [inline, override, protected, inherited] |
JetByteTools::IO::IBuffer::SequenceNumber GetNextOperationSequenceNumber | ( | ) | [inline, override, protected, inherited] |
JetByteTools::IO::CSmartBuffer Allocate | ( | ) | [inline, override, protected, inherited] |
JetByteTools::IO::CSmartBuffer Allocate | ( | JetByteTools::IO::IAllocateBuffer & | allocator | ) | [inline, override, protected, inherited] |
JetByteTools::IO::CSmartBuffer AllocateCustomSizedBuffer | ( | JetByteTools::IO::IBuffer::BufferSize | bufferSize | ) | [inline, override, protected, inherited] |
JetByteTools::IO::CSmartBuffer AllocateCustomSizedBuffer | ( | JetByteTools::IO::IAllocateBuffer & | allocator, | |
JetByteTools::IO::IBuffer::BufferSize | bufferSize | |||
) | [inline, override, protected, inherited] |
void AddBufferToPool | ( | JetByteTools::IO::IBuffer & | buffer | ) | [inline, override, protected, inherited] |
bool CloseSocket | ( | ) | [inline, protected, virtual, inherited] |
void Read | ( | ) | [inline, protected, virtual, inherited] |
void Read | ( | JetByteTools::IO::CSmartBuffer & | buffer | ) | [inline, protected, virtual, inherited] |
void Read | ( | JetByteTools::IO::IBuffer * | pBuffer | ) | [inline, protected, virtual, inherited] |
void Write | ( | const char * | pData, | |
JetByteTools::IO::IStream::DataLength | dataLength | |||
) | [inline, protected, virtual, inherited] |
void Write | ( | const BYTE * | pData, | |
JetByteTools::IO::IStream::DataLength | dataLength | |||
) | [inline, protected, virtual, inherited] |
void Write | ( | JetByteTools::IO::CSmartBuffer & | buffer | ) | [inline, protected, virtual, inherited] |
void Write | ( | JetByteTools::IO::IIterateableBufferChain & | buffers | ) | [inline, protected, virtual, inherited] |
bool TryRead | ( | ) | [inline, protected, virtual, inherited] |
bool TryRead | ( | JetByteTools::IO::CSmartBuffer & | buffer | ) | [inline, protected, virtual, inherited] |
bool TryRead | ( | JetByteTools::IO::IBuffer * | pBuffer | ) | [inline, protected, virtual, inherited] |
bool TryWrite | ( | const char * | pData, | |
JetByteTools::IO::IStream::DataLength | dataLength | |||
) | [inline, protected, virtual, inherited] |
bool TryWrite | ( | const BYTE * | pData, | |
JetByteTools::IO::IStream::DataLength | dataLength | |||
) | [inline, protected, virtual, inherited] |
bool TryWrite | ( | JetByteTools::IO::CSmartBuffer & | buffer | ) | [inline, protected, virtual, inherited] |
bool TryWrite | ( | JetByteTools::IO::IIterateableBufferChain & | buffers | ) | [inline, protected, virtual, inherited] |
void Shutdown | ( | ) | [inline, protected, virtual, inherited] |
void Shutdown | ( | ShutdownHow | how | ) | [inline, protected, virtual, inherited] |
Reimplemented in CDatagramSocket.
bool AbortConnection | ( | ) | [inline, protected, virtual, inherited] |
CAddress GetLocalAddress | ( | ) | const [inline, protected, virtual, inherited] |
CAddress GetRemoteAddress | ( | ) | const [inline, protected, virtual, inherited] |
Reimplemented in CDatagramServerSocket.
void AddRef | ( | ) | [inline, protected, virtual, inherited] |
void Release | ( | ) | [inline, protected, virtual, inherited] |
bool WeOwnOnlyReference | ( | ) | const [inline, protected, virtual, inherited] |
void Attach | ( | IPoolableSocketManager & | manager, | |
ISocketCallback & | callback, | |||
SOCKET | socket | |||
) | [inline, protected, virtual, inherited] |
bool AbortConnectionIfManagedBy | ( | const IPoolableSocketManager & | manager, | |
ConnectionClosureReason | reason | |||
) | [inline, protected, virtual, inherited] |
void DumpIfManagedBy | ( | const IPoolableSocketManager & | manager | ) | const [inline, protected, virtual, inherited] |
bool AddRefIfPossible | ( | ) | [inline, protected, virtual, inherited] |
DWORD GetError | ( | const OVERLAPPED & | overlapped | ) | [inline, protected, virtual, inherited] |
Implement IHandler.
void HandleOperation | ( | JetByteTools::IO::IBuffer * | pBuffer, | |
DWORD | ioSize, | |||
DWORD | lastError | |||
) | [inline, protected, virtual, inherited] |
void * GetUserPointer | ( | JetByteTools::Core::IIndexedOpaqueUserData::UserDataIndex | index | ) | const [inline, protected, virtual, inherited] |
void SetUserPointer | ( | JetByteTools::Core::IIndexedOpaqueUserData::UserDataIndex | index, | |
void * | pData | |||
) | [inline, protected, virtual, inherited] |
ULONG_PTR GetUserData | ( | JetByteTools::Core::IIndexedOpaqueUserData::UserDataIndex | index | ) | const [inline, protected, virtual, inherited] |
void SetUserData | ( | JetByteTools::Core::IIndexedOpaqueUserData::UserDataIndex | index, | |
ULONG_PTR | data | |||
) | [inline, protected, virtual, inherited] |
void WriteCompleted | ( | ) | [inline, protected, virtual, inherited] |
JetByteTools::Core::IReentrantLockableObject & GetLock | ( | ) | const [inline, protected, virtual, inherited] |
void Accepted | ( | ) | [inline, protected, virtual, inherited] |
void AboutToConnect | ( | ) | [inline, protected, virtual, inherited] |
void Connected | ( | ) | [inline, protected, virtual, inherited] |
ConnectionDirection GetConnectionDirection | ( | ) | const [inline, protected, virtual, inherited] |
SOCKET GetSocket | ( | ) | const [inline, protected, virtual, inherited] |
bool CanWrite | ( | size_t | numBuffers = 1 |
) | [inline, protected, virtual, inherited] |
bool CanIssueFilteredWrite | ( | ) | [inline, protected, virtual, inherited] |
bool WritePending | ( | ) | [inline, protected, virtual, inherited] |
void ForceWritePending | ( | ) | [inline, protected, virtual, inherited] |
JetByteTools::IO::CSmartBuffer GetNextOperation | ( | JetByteTools::IO::CSmartBuffer & | buffer | ) | [inline, protected, virtual, inherited] |
bool ProcessAndGetNextOperation | ( | JetByteTools::IO::CSmartBuffer & | buffer | ) | [inline, protected, virtual, inherited] |
void AllowOperationProcessingTransfer | ( | ) | [inline, protected, virtual, inherited] |
virtual void OnDetach | ( | ) | [inline, protected, virtual, inherited] |
Reimplemented in CSequencedStreamSocket.
void IncrementReferenceCountFromZero | ( | ) | [inline, protected, inherited] |
bool OnFinalRelease | ( | ) | [inline, protected, virtual, inherited] |
bool IsValid | ( | ) | const [inline, protected, inherited] |
Manager* m_pManager [protected, inherited] |
Callback* m_pCallback [protected, inherited] |
JetByteTools::Core::CAtomicLong m_outstandingWrites [protected, inherited] |
JetByteTools::Core::CAtomicBool m_writeShutdown [protected, inherited] |
JetByteTools::Core::CAtomicBool m_readShutdown [protected, inherited] |
ConnectionDirection m_direction [protected, inherited] |
JetByteTools::Core::CReentrantLockableObjectTracksLockingThread m_lock [mutable, protected, inherited] |