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

CStreamSocketConnectionManager Member List

This is the complete list of members for CStreamSocketConnectionManager, including all inherited members.

AbortAllConnections()TConnectionManagerBase [inline]
AbortAllConnections(ConnectionClosureReason reason)TConnectionManagerBase [inline, protected]
AcceptEx(SOCKET listenSocket, SOCKET acceptSocket, PVOID pOutputBuffer, DWORD receiveDataLength, DWORD localAddressLength, DWORD remoteAddressLength, LPDWORD bytesReceived, LPOVERLAPPED pOverlapped) const CUsesMSWinSockExtensions [protected]
AllocateBuffer() overrideTConnectionManagerBase [inline, protected]
AllocateBuffer(JetByteTools::IO::IPoolBuffers &pool) overrideTConnectionManagerBase [inline, protected]
AllocateCustomSizedBuffer(JetByteTools::IO::IBuffer::BufferSize bufferSize) overrideTConnectionManagerBase [inline, protected]
AllocateSocket(SOCKET theSocket)TStreamSocketConnectionManager< CFilteringStreamSocketConnectionManagerBase > [protected]
AssociateDevice(SOCKET s, JetByteTools::IO::IHandler &handler) const TConnectionManagerBase [inline, protected]
AsyncConnect(const IFullAddress &address, const void *pUserData=nullptr, SocketBufferSize recvBufferSize=DefaultSocketBufferSize, SocketBufferSize sendBufferSize=DefaultSocketBufferSize)TStreamSocketConnectionManager< CFilteringStreamSocketConnectionManagerBase > [virtual]
AsyncConnect(const IFullAddress &address, const void *pUserData, const void *pFilterData, SocketBufferSize recvBufferSize, SocketBufferSize sendBufferSize)TStreamSocketConnectionManager< CFilteringStreamSocketConnectionManagerBase > [protected]
AsyncConnectAvailable(const IAddressType &addressType) const overrideTStreamSocketConnectionManager< CFilteringStreamSocketConnectionManagerBase >
AsyncConnectNoThrow(const IFullAddress &address, const void *pUserData=nullptr, SocketBufferSize recvBufferSize=DefaultSocketBufferSize, SocketBufferSize sendBufferSize=DefaultSocketBufferSize)TStreamSocketConnectionManager< CFilteringStreamSocketConnectionManagerBase > [virtual]
AsyncConnectNoThrow(const IFullAddress &address, const void *pUserData, const void *pFilterData, SocketBufferSize recvBufferSize, SocketBufferSize sendBufferSize)TStreamSocketConnectionManager< CFilteringStreamSocketConnectionManagerBase > [protected]
BeginShutdown()TConnectionManagerBase [inline, virtual]
CanDisconnectSocketForReuse(SOCKET s) const CUsesMSWinSockExtensions [protected]
CDispatchRestrictor()CDispatchRestrictor [protected]
CDispatchRestrictor(const CDispatchRestrictor &rhs)CDispatchRestrictor [protected]
CheckCanConnectNow()TConnectionManagerBase [inline, protected]
Connect(const IFullAddress &address, const void *pUserData=nullptr, SocketBufferSize recvBufferSize=DefaultSocketBufferSize, SocketBufferSize sendBufferSize=DefaultSocketBufferSize)TStreamSocketConnectionManager< CFilteringStreamSocketConnectionManagerBase > [virtual]
Connect(const IFullAddress &address, const void *pUserData, const void *pFilterData, SocketBufferSize recvBufferSize, SocketBufferSize sendBufferSize)TStreamSocketConnectionManager< CFilteringStreamSocketConnectionManagerBase > [protected]
ConnectAsyncIfAvailable(const IFullAddress &address, const void *pUserData=nullptr, SocketBufferSize recvBufferSize=DefaultSocketBufferSize, SocketBufferSize sendBufferSize=DefaultSocketBufferSize)TStreamSocketConnectionManager< CFilteringStreamSocketConnectionManagerBase > [virtual]
ConnectAsyncIfAvailable(const IFullAddress &address, const void *pUserData, const void *pFilterData, SocketBufferSize recvBufferSize, SocketBufferSize sendBufferSize)TStreamSocketConnectionManager< CFilteringStreamSocketConnectionManagerBase > [protected]
ConnectAsyncIfAvailableNoThrow(const IFullAddress &address, const void *pUserData=nullptr, SocketBufferSize recvBufferSize=DefaultSocketBufferSize, SocketBufferSize sendBufferSize=DefaultSocketBufferSize)TStreamSocketConnectionManager< CFilteringStreamSocketConnectionManagerBase > [virtual]
ConnectAsyncIfAvailableNoThrow(const IFullAddress &address, const void *pUserData, const void *pFilterData, SocketBufferSize recvBufferSize, SocketBufferSize sendBufferSize)TStreamSocketConnectionManager< CFilteringStreamSocketConnectionManagerBase > [protected]
ConnectEx(SOCKET s, const struct sockaddr FAR *name, int namelen, PVOID lpSendBuffer, DWORD dwSendDataLength, LPDWORD lpdwBytesSent, LPOVERLAPPED lpOverlapped) const CUsesMSWinSockExtensions [protected]
ConnectionEstablished(IStreamSocketEx &socket, const IAddress &address)TStreamSocketConnectionManager< CFilteringStreamSocketConnectionManagerBase > [protected]
ConnectNoThrow(const IFullAddress &address, const void *pUserData=nullptr, SocketBufferSize recvBufferSize=DefaultSocketBufferSize, SocketBufferSize sendBufferSize=DefaultSocketBufferSize)TStreamSocketConnectionManager< CFilteringStreamSocketConnectionManagerBase > [virtual]
ConnectNoThrow(const IFullAddress &address, const void *pUserData, const void *pFilterData, SocketBufferSize recvBufferSize, SocketBufferSize sendBufferSize)TStreamSocketConnectionManager< CFilteringStreamSocketConnectionManagerBase > [protected]
CreateSocket(const IAddressType &addressType, SocketBufferSize recvBufferSize, SocketBufferSize sendBufferSize) const TStreamSocketConnectionManager< CFilteringStreamSocketConnectionManagerBase > [protected]
CSecureConnectShim(JetByteTools::Socket::ICreateFilteredStreamSocketConnections &connectionCreator)CSecureConnectShim [explicit]
CSecureConnectShim(const CSecureConnectShim &rhs)CSecureConnectShim
CStreamSocketConnectionManager(const CContext &sslContext, bool verifyPeer, IStreamSocketConnectionManagerCallback &callback, JetByteTools::IO::IIOPool &pool, JetByteTools::Socket::IAllocateSequencedStreamSockets &socketAllocator, JetByteTools::IO::IAllocateBuffers &bufferAllocator)CStreamSocketConnectionManager
CStreamSocketConnectionManager(bool sslActive, const CContext &sslContext, bool verifyPeer, IStreamSocketConnectionManagerCallback &callback, JetByteTools::IO::IIOPool &pool, JetByteTools::Socket::IAllocateSequencedStreamSockets &socketAllocator, JetByteTools::IO::IAllocateBuffers &bufferAllocator)CStreamSocketConnectionManager
CStreamSocketConnectionManager(IStreamSocketConnectionManagerCallback &callback, JetByteTools::IO::IIOPool &pool, JetByteTools::Socket::IAllocateSequencedStreamSockets &socketAllocator, JetByteTools::IO::IAllocateBuffers &bufferAllocator)CStreamSocketConnectionManager
CStreamSocketConnectionManager(const CStreamSocketConnectionManager &rhs)CStreamSocketConnectionManager
CUsesMSWinSockExtensions()CUsesMSWinSockExtensions [protected]
CUsesMSWinSockExtensions(const CUsesMSWinSockExtensions &rhs)CUsesMSWinSockExtensions [protected]
CUsesWinsock()CUsesWinsock [protected]
CUsesWinsock(const CUsesWinsock &rhs)CUsesWinsock [protected]
DecrementActiveConnections()TConnectionManagerBase [inline, protected]
DisableDispatchForThisSocket(const void *pSocket)CDispatchRestrictor [protected, static]
DisconnectEx(SOCKET s, LPOVERLAPPED pOverlapped, DWORD flags) const CUsesMSWinSockExtensions [protected]
DisconnectSocketForReuse(SOCKET s) const CUsesMSWinSockExtensions [protected]
EnableDispatchForThisSocket(const void *pSocket)CDispatchRestrictor [protected, static]
EnableDispatchOnThisThread(bool enable)CDispatchRestrictor [protected]
EnsureCanConnectNow()TConnectionManagerBase [inline, protected]
ExecuteWrite(IStreamSocketEx &socket, JetByteTools::IO::CSmartBuffer &buffer) overrideTStreamSocketConnectionManager< CFilteringStreamSocketConnectionManagerBase > [protected]
ForceShutdown()TConnectionManagerBase [inline, virtual]
GetAcceptExSockaddrs(PVOID pOutputBuffer, DWORD receiveDataLength, DWORD localAddressLength, DWORD remoteAddressLength, LPSOCKADDR *pLocalSockaddr, LPINT pLocalSockaddrLength, LPSOCKADDR *pRemoteSockaddr, LPINT pRemoteSockaddrLength) const CUsesMSWinSockExtensions [protected]
HandleOperation(IStreamSocketEx &socket, JetByteTools::IO::CSmartBuffer &buffer, DWORD ioSize, DWORD lastError) overrideTStreamSocketConnectionManager< CFilteringStreamSocketConnectionManagerBase > [protected]
IncrementActiveConnections()TConnectionManagerBase [inline, protected]
IssueRead(IStreamSocketEx &socket, JetByteTools::IO::CSmartBuffer &buffer) overrideTStreamSocketConnectionManager< CFilteringStreamSocketConnectionManagerBase > [protected, virtual]
IssueReadOOBIfRequired(IStreamSocketEx &socket)TStreamSocketConnectionManager< CFilteringStreamSocketConnectionManagerBase > [protected]
IssueReadOOBIfRequired(IStreamSocketEx &socket, JetByteTools::IO::CSmartBuffer &buffer)TStreamSocketConnectionManager< CFilteringStreamSocketConnectionManagerBase > [protected]
IssueWrite(IStreamSocketEx &socket, JetByteTools::IO::CSmartBuffer &buffer) overrideTStreamSocketConnectionManager< CFilteringStreamSocketConnectionManagerBase > [protected, virtual]
JoinIOPoolLogicalThreadGroup() const TStreamSocketConnectionManager< CFilteringStreamSocketConnectionManagerBase > [protected]
LoadAcceptEx(SOCKET s) const CUsesMSWinSockExtensions [protected]
LoadConnectEx(SOCKET s) const CUsesMSWinSockExtensions [protected]
LoadDisconnectEx(SOCKET s) const CUsesMSWinSockExtensions [protected]
LoadGetAcceptExSockaddrs(SOCKET s) const CUsesMSWinSockExtensions [protected]
LoadTransmitFile(SOCKET s) const CUsesMSWinSockExtensions [protected]
LoadWSARecvMsg(SOCKET s) const CUsesMSWinSockExtensions [protected]
m_activeConnectionsTConnectionManagerBase [protected]
m_canEnableSkipCompletionPortOnSuccessTConnectionManagerBase [protected]
m_connectionLimiterTConnectionManagerBase [protected]
m_noActiveConnectionsEventTConnectionManagerBase [protected]
m_poolTConnectionManagerBase [protected]
m_socketAllocatorTConnectionManagerBase [protected]
OnClientClose(IStreamSocketEx &socket) overrideTStreamSocketConnectionManager< CFilteringStreamSocketConnectionManagerBase > [protected]
OnConnectionAborted(IStreamSocketEx &socket, ConnectionClosureReason reason, bool wasUserSocket) overrideTStreamSocketConnectionManager< CFilteringStreamSocketConnectionManagerBase > [protected]
OnConnectionClosed(IStreamSocketEx &socket, ConnectionClosureReason reason) overrideTStreamSocketConnectionManager< CFilteringStreamSocketConnectionManagerBase > [protected]
OnConnectionReset(IStreamSocketEx &socket, DWORD lastError) overrideTStreamSocketConnectionManager< CFilteringStreamSocketConnectionManagerBase > [protected]
OnConnectionShutdown(IStreamSocketEx &socket, ShutdownHow how) overrideTStreamSocketConnectionManager< CFilteringStreamSocketConnectionManagerBase > [protected]
operator=(const CStreamSocketConnectionManager &rhs)CStreamSocketConnectionManager
JetByteTools::Socket::TStreamSocketConnectionManager< CFilteringStreamSocketConnectionManagerBase >::operator=(const TStreamSocketConnectionManager &rhs)TStreamSocketConnectionManager< CFilteringStreamSocketConnectionManagerBase >
JetByteTools::Socket::TConnectionManagerBase::operator=(const TConnectionManagerBase &rhs)TConnectionManagerBase
JetByteTools::Socket::CUsesMSWinSockExtensions::operator=(const CUsesMSWinSockExtensions &rhs)CUsesMSWinSockExtensions
JetByteTools::Socket::CUsesWinsock::operator=(const CUsesWinsock &rhs)CUsesWinsock
JetByteTools::Socket::CDispatchRestrictor::operator=(const CDispatchRestrictor &rhs)CDispatchRestrictor
JetByteTools::OpenSSL::CSecureConnectShim::operator=(const CSecureConnectShim &rhs)CSecureConnectShim
PostIoOperationOnHandler(JetByteTools::IO::IHandler &handler, JetByteTools::IO::CSmartBuffer &buffer, DWORD operation, bool forceDispatchToPool=false)TStreamSocketConnectionManager< CFilteringStreamSocketConnectionManagerBase > [protected]
ReleaseSocket(IPoolableSocket &socket, bool wasUserSocket) overrideTConnectionManagerBase [inline, protected, virtual]
RequestCancelIO(IStreamSocketEx &socket) overrideTStreamSocketConnectionManager< CFilteringStreamSocketConnectionManagerBase > [protected]
RequestRead(IStreamSocketEx &socket, JetByteTools::IO::CSmartBuffer &buffer) overrideTStreamSocketConnectionManager< CFilteringStreamSocketConnectionManagerBase > [protected]
RequestWrite(IStreamSocketEx &socket, JetByteTools::IO::CSmartBuffer &buffer) overrideTStreamSocketConnectionManager< CFilteringStreamSocketConnectionManagerBase > [protected]
RequestWrite(IStreamSocketEx &socket, JetByteTools::IO::IIterateableBufferChain &buffers) overrideTStreamSocketConnectionManager< CFilteringStreamSocketConnectionManagerBase > [protected]
SecureAsyncConnect(const JetByteTools::Socket::IFullAddress &address, const void *pUserData, JetByteTools::Socket::SocketBufferSize recvBufferSize=JetByteTools::Socket::DefaultSocketBufferSize, JetByteTools::Socket::SocketBufferSize sendBufferSize=JetByteTools::Socket::DefaultSocketBufferSize)CSecureConnectShim
SecureAsyncConnectNoThrow(const JetByteTools::Socket::IFullAddress &address, const void *pUserData, JetByteTools::Socket::SocketBufferSize recvBufferSize=JetByteTools::Socket::DefaultSocketBufferSize, JetByteTools::Socket::SocketBufferSize sendBufferSize=JetByteTools::Socket::DefaultSocketBufferSize)CSecureConnectShim
SecureConnect(const JetByteTools::Socket::IFullAddress &address, const void *pUserData, JetByteTools::Socket::SocketBufferSize recvBufferSize=JetByteTools::Socket::DefaultSocketBufferSize, JetByteTools::Socket::SocketBufferSize sendBufferSize=JetByteTools::Socket::DefaultSocketBufferSize)CSecureConnectShim
SecureConnectAsyncIfAvailable(const JetByteTools::Socket::IFullAddress &address, const void *pUserData, JetByteTools::Socket::SocketBufferSize recvBufferSize=JetByteTools::Socket::DefaultSocketBufferSize, JetByteTools::Socket::SocketBufferSize sendBufferSize=JetByteTools::Socket::DefaultSocketBufferSize)CSecureConnectShim
SecureConnectAsyncIfAvailableNoThrow(const JetByteTools::Socket::IFullAddress &address, const void *pUserData, JetByteTools::Socket::SocketBufferSize recvBufferSize=JetByteTools::Socket::DefaultSocketBufferSize, JetByteTools::Socket::SocketBufferSize sendBufferSize=JetByteTools::Socket::DefaultSocketBufferSize)CSecureConnectShim
SecureConnectNoThrow(const JetByteTools::Socket::IFullAddress &address, const void *pUserData, JetByteTools::Socket::SocketBufferSize recvBufferSize=JetByteTools::Socket::DefaultSocketBufferSize, JetByteTools::Socket::SocketBufferSize sendBufferSize=JetByteTools::Socket::DefaultSocketBufferSize)CSecureConnectShim
SetBufferSize(SOCKET s, SocketBufferSize bufferSize, int optionName) const TConnectionManagerBase [inline, protected]
ShouldDispatchForThisSocket(const void *pSocket)CDispatchRestrictor [protected, static]
ShouldDispatchOnThisThread()CDispatchRestrictor [protected, static]
ShutdownComplete()TConnectionManagerBase [inline, protected, virtual]
ShutdownIsInProgress() const TConnectionManagerBase [inline, protected]
Start()TConnectionManagerBase [inline, protected, virtual]
TConnectionManagerBase(const TConnectionManagerBase &rhs)TConnectionManagerBase
TConnectionManagerBase(Callback &callback, JetByteTools::IO::IIOPool &pool, Manager &manager, SocketAllocator &socketAllocator, JetByteTools::IO::IAllocateBuffers &bufferAllocator, ILimitConnections &connectionLimiter)TConnectionManagerBase [inline, protected]
TransmitFile(SOCKET s, HANDLE fileToTransmit, DWORD numberOfBytesToWrite, DWORD numberOfBytesPerSend, LPOVERLAPPED lOverlapped, LPTRANSMIT_FILE_BUFFERS lTransmitBuffers, DWORD flags) const CUsesMSWinSockExtensions [protected]
TStreamSocketConnectionManager(IStreamSocketConnectionManagerCallback &callback, JetByteTools::IO::IIOPool &pool, IAllocateStreamSockets &socketAllocator, JetByteTools::IO::IAllocateBuffers &bufferAllocator, ZeroByteReadConfiguration zeroByteReadConfiguration=NoZeroByteRead, ILimitConnections &connectionLimiter=CConnectionLimiter::NoLimitLimiter, OutOfBandDataReadConfiguration outOfBandDataReadConfiguration=NoOutOfBandData)TStreamSocketConnectionManager< CFilteringStreamSocketConnectionManagerBase >
TStreamSocketConnectionManager(const IFullAddress &outboundAddress, IStreamSocketConnectionManagerCallback &callback, JetByteTools::IO::IIOPool &pool, IAllocateStreamSockets &socketAllocator, JetByteTools::IO::IAllocateBuffers &bufferAllocator, ZeroByteReadConfiguration zeroByteReadConfiguration=NoZeroByteRead, ILimitConnections &connectionLimiter=CConnectionLimiter::NoLimitLimiter, OutOfBandDataReadConfiguration outOfBandDataReadConfiguration=NoOutOfBandData)TStreamSocketConnectionManager< CFilteringStreamSocketConnectionManagerBase >
TStreamSocketConnectionManager(const TStreamSocketConnectionManager &rhs)TStreamSocketConnectionManager< CFilteringStreamSocketConnectionManagerBase >
WaitForShutdownToComplete()TConnectionManagerBase [inline, virtual]
WaitForShutdownToComplete(Milliseconds timeout)TConnectionManagerBase [inline, virtual]
WSARecvMsg(SOCKET s, LPWSAMSG lpMsg, LPDWORD lpdwNumberOfBytesRecvd, LPWSAOVERLAPPED lpOverlapped, LPWSAOVERLAPPED_COMPLETION_ROUTINE lpCompletionRoutine) const CUsesMSWinSockExtensions [protected]
~CDispatchRestrictor()CDispatchRestrictor [protected, virtual]
~CSecureConnectShim()CSecureConnectShim [virtual]
~CUsesMSWinSockExtensions()CUsesMSWinSockExtensions [protected, virtual]
~CUsesWinsock()CUsesWinsock [protected, virtual]
~TConnectionManagerBase()TConnectionManagerBase [inline]
~TStreamSocketConnectionManager()TStreamSocketConnectionManager< CFilteringStreamSocketConnectionManagerBase > [virtual]


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