![]() |
MAK RTIspy API Documentation for HLA Evolved
|
Instances of the DtTcpForwarder__vl__ class manage TCP connections for variants of Forwarder (servers) which accept TCP connections. More...
Inheritance diagram for DtTcpForwarder__vl__:
Collaboration diagram for DtTcpForwarder__vl__:Public Member Functions | |
| DtTcpForwarder__vl__ (int port, const DtInetAddr &networkInterface=DtInetAddr::inaddrAny()) | |
| Constructor. | |
| DtTcpForwarder__vl__ () | |
| Constructor which will NOT open up a socket manager. | |
| virtual | ~DtTcpForwarder__vl__ () |
| Destructor. | |
| virtual void | sendToAll (caddr_t packet, size_t size) |
| Send a packet to all open TCP connections. | |
| virtual void | readAndForward (DtTime maxTimeOverAll, DtTime maxTimePerSocket) |
| Retrieve all messages from each TCP connection and forward each to all other TCP connections. | |
| virtual void | readAndForward (DtTcpMsgSocket *sock, DtTime stopTime) |
| Retrieve all messages from a single TCP connection and forward each to all other TCP connections, stopping when the clock reaches the specified stop time. | |
| virtual DtTcpMsgSocketMgr * | socketMgr () |
| Return a pointer to the socket manager object owned by this instance. | |
Protected Attributes | |
| DtTcpMsgSocketMgr * | mySocketMgr |
| Pointer to the socket manager object owned by this instance. | |
| DtClock | myClock |
| Clock object used to meter processing time . | |
| DtTcpMsgSocket * | myBeginSock |
| The socket to begin processing next time we readAndForwarder. | |
Private Member Functions | |
| DtTcpForwarder__vl__ (const DtTcpForwarder__vl__ &) | |
| Copy CTOR Not Implemented – Copy Not Allowed! | |
| DtTcpForwarder__vl__ & | operator= (const DtTcpForwarder__vl__ &) |
| Assignment Operator Not Implemented – Assignment Not Allowed! | |
Instances of the DtTcpForwarder__vl__ class manage TCP connections for variants of Forwarder (servers) which accept TCP connections.
| DtTcpForwarder__vl__::DtTcpForwarder__vl__ | ( | int | port, |
| const DtInetAddr & | networkInterface = DtInetAddr::inaddrAny() |
||
| ) |
Constructor.
Accepts port number and interface on which to listen for incoming client connections.
| DtTcpForwarder__vl__::DtTcpForwarder__vl__ | ( | ) |
Constructor which will NOT open up a socket manager.
Instead, construction of the socket manager is left to a derived class.
|
virtual |
Destructor.
References mySocketMgr.
|
private |
Copy CTOR Not Implemented – Copy Not Allowed!
|
private |
Assignment Operator Not Implemented – Assignment Not Allowed!
|
virtual |
Retrieve all messages from each TCP connection and forward each to all other TCP connections.
The amount of time spent processing each individual connection is limited by maxTimePerSocket and the total amount of time spent processing all connections is limited by maxTimeOverAll.
References DtTcpMsgSocket::isConnected(), myBeginSock, myClock, mySocketMgr, DtTcpMsgSocketMgr::removeAndDelete(), DtTcpMsgSocketMgr::socketIter(), and DtTcpMsgSocketMgr::socketSet().
|
virtual |
Retrieve all messages from a single TCP connection and forward each to all other TCP connections, stopping when the clock reaches the specified stop time.
References DtTcpMsgSocket::flush(), myClock, DtTcpMsgSocket::recvMessage(), and sendToAll().
|
virtual |
Send a packet to all open TCP connections.
Reimplemented in DtFilteredTcpForwarder.
References DtTcpMsgSocket::isConnected(), mySocketMgr, DtTcpMsgSocket::sendMessage(), and DtTcpMsgSocketMgr::socketSet().
Referenced by readAndForward().
|
virtual |
Return a pointer to the socket manager object owned by this instance.
References mySocketMgr.
Referenced by DtRtiMsgForwarder::closeAllConnectionsIfRequested(), DtRtiMsgForwarder::init(), and DtRtiMsgForwarder::requestKillSingleConnection().
|
protected |
The socket to begin processing next time we readAndForwarder.
Referenced by DtFilteredTcpForwarder::DtFilteredTcpForwarder(), readAndForward(), and DtFilteredTcpForwarder::readAndForward().
|
protected |
Clock object used to meter processing time .
Referenced by readAndForward(), and DtFilteredTcpForwarder::readAndForward().
|
protected |
Pointer to the socket manager object owned by this instance.
Referenced by DtFilteredTcpForwarder::DtFilteredTcpForwarder(), DtFilteredTcpForwarder::filter(), readAndForward(), DtFilteredTcpForwarder::readAndForward(), sendToAll(), DtFilteredTcpForwarder::sendToAll(), DtFilteredTcpForwarder::sendToList(), DtFilteredTcpForwarder::setEnableCompression(), DtFilteredTcpForwarder::setEnablePacketBundling(), socketMgr(), DtFilteredTcpForwarder::updateQueuedSockets(), and ~DtTcpForwarder__vl__().