| abortPendingConnections() | DtPeerToPeerTcpSockMgr | |
| addSocket(DtTcpMsgSocket *sock) | DtTcpMsgSocketMgr | virtual |
| addSocketAdditionCallback(DtTcpSocketAdditionCallback cb, void *usr) | DtTcpMsgSocketMgr | virtual |
| addSocketEstablishedCallback(DtSocketEstablishedCallback cb, void *usr) | DtPeerToPeerTcpSockMgr | virtual |
| addSocketRemovalCallback(DtTcpSocketRemovalCallback cb, void *usr) | DtTcpMsgSocketMgr | virtual |
| checkIfReconnecting(const DtInetTcpSocket *newSock) | DtTcpMsgSocketMgr | |
| connectToPeer(const MAKRti::DtInetAddr &addr, DtInetDevice *hostIf=0) | DtPeerToPeerTcpSockMgr | virtual |
| connectToPeer(const MAKRti::DtInetAddr &addr, int port, DtInetDevice *hostIf=0) | DtPeerToPeerTcpSockMgr | virtual |
| disableBundling() | DtTcpMsgSocketMgr | virtual |
| disableCompression() | DtTcpMsgSocketMgr | virtual |
| DtPeerToPeerTcpSockMgr(int port, DtBoost::shared_ptr< DtMsgHeaderReader > hdrRdr, size_t recvBufferSize, int maxForwarderQueue, int reconnectTries=0, float reconnectDelay=0.0f) | DtPeerToPeerTcpSockMgr | |
| DtPeerToPeerTcpSockMgr(const DtPeerToPeerTcpSockMgr &orig) | DtPeerToPeerTcpSockMgr | private |
| DtTcpMsgSocketMgr(DtBoost::shared_ptr< DtMsgHeaderReader > hdrReader, size_t recvBufferSize=20000, int maxQueuedMsgs=-1) | DtTcpMsgSocketMgr | |
| enableBundling(size_t maxBundleSize) | DtTcpMsgSocketMgr | virtual |
| enableCompression(DtU8 compressionLevel) | DtTcpMsgSocketMgr | virtual |
| getLastError() const | DtTcpMsgSocketMgr | inline |
| isListening() const | DtTcpMsgSocketMgr | inline |
| lockProcessConnections() | DtPeerToPeerTcpSockMgr | inline |
| maxMsgSize() const | DtTcpMsgSocketMgr | virtual |
| myAdditionCallbacks | DtTcpMsgSocketMgr | protected |
| myClock | DtPeerToPeerTcpSockMgr | protected |
| myCompressionLevel | DtTcpMsgSocketMgr | protected |
| myEstablishedCallbacks | DtPeerToPeerTcpSockMgr | protected |
| myHeaderReader | DtTcpMsgSocketMgr | protected |
| myLastError | DtTcpMsgSocketMgr | protected |
| myMaxBundleSize | DtTcpMsgSocketMgr | protected |
| myMaxQueuedMessages | DtTcpMsgSocketMgr | protected |
| myPendingConnections | DtPeerToPeerTcpSockMgr | protected |
| myPendingConnectionsAborted | DtPeerToPeerTcpSockMgr | protected |
| myPort | DtPeerToPeerTcpSockMgr | protected |
| myProcessingConnections | DtPeerToPeerTcpSockMgr | protected |
| myReconnectDelay | DtPeerToPeerTcpSockMgr | protected |
| myReconnectTries | DtPeerToPeerTcpSockMgr | protected |
| myRecvBufferSize | DtTcpMsgSocketMgr | protected |
| myRemovalCallbacks | DtTcpMsgSocketMgr | protected |
| mySocketMgr | DtTcpMsgSocketMgr | protected |
| mySockets | DtTcpMsgSocketMgr | protected |
| mySockRecvBufferSize | DtTcpMsgSocketMgr | protected |
| mySockSendBufferSize | DtTcpMsgSocketMgr | protected |
| myTcpNoDelay | DtTcpMsgSocketMgr | protected |
| openServerSocket(DtU16 localPort, DtInetDevice *hostIf=NULL, DtInetUtils::DtInetAddrFamily family=DtInetUtils::DtInetAddrFamily_IPv4, DtU32 flags=(DtDefaultSockOpts|DtSockOptNonBlocking)) | DtTcpMsgSocketMgr | virtual |
| operator=(const DtPeerToPeerTcpSockMgr &orig) | DtPeerToPeerTcpSockMgr | private |
| pendingConnectionsAborted() | DtPeerToPeerTcpSockMgr | |
| processConnections() | DtPeerToPeerTcpSockMgr | virtual |
| processNewConnections() | DtTcpMsgSocketMgr | |
| removeAndDelete(DtTcpMsgSocket *sock) | DtTcpMsgSocketMgr | virtual |
| removeAndDeletePeerConnection(DtTcpMsgSocket *sock, bool abort=true) | DtPeerToPeerTcpSockMgr | virtual |
| removeSocketAdditionCallback(DtTcpSocketAdditionCallback cb, void *usr) | DtTcpMsgSocketMgr | virtual |
| removeSocketEstablishedCallback(DtSocketEstablishedCallback cb, void *usr) | DtPeerToPeerTcpSockMgr | virtual |
| removeSocketRemovalCallback(DtTcpSocketRemovalCallback cb, void *usr) | DtTcpMsgSocketMgr | virtual |
| repairPeerSocket(DtTcpMsgSocket *oldSock) | DtPeerToPeerTcpSockMgr | virtual |
| serverSocketState() const | DtTcpMsgSocketMgr | virtual |
| setRecvBufferSize(DtU32 size) | DtTcpMsgSocketMgr | virtual |
| setSendBufferSize(DtU32 size) | DtTcpMsgSocketMgr | virtual |
| setTcpNoDelay(bool enable) | DtTcpMsgSocketMgr | virtual |
| socketAdded(DtInetSocket *sock, void *usr) | DtTcpMsgSocketMgr | static |
| socketAdded(DtInetSocket *sock) | DtTcpMsgSocketMgr | |
| socketIter(DtTcpMsgSocket *sock) | DtTcpMsgSocketMgr | inline |
| socketRemoved(DtInetSocket *sock, void *usr) | DtTcpMsgSocketMgr | static |
| socketRemoved(DtInetSocket *sock) | DtTcpMsgSocketMgr | |
| socketSet() | DtTcpMsgSocketMgr | inline |
| unlockProcessConnections() | DtPeerToPeerTcpSockMgr | inline |
| ~DtPeerToPeerTcpSockMgr() | DtPeerToPeerTcpSockMgr | virtual |
| ~DtTcpMsgSocketMgr() | DtTcpMsgSocketMgr | virtual |
