FederateProxyManager Class Reference

Collaboration diagram for FederateProxyManager:

Public Member Functions
	FederateProxyManager (const std::string serverAddress, int serverPort)
	~FederateProxyManager ()
bool	tick ()
void	listProxies ()
void	killProxy (unsigned long long sessionId)

Protected Member Functions
void	socketAdded (DtTcpMsgSocket *sock)
void	socketRemoved (DtTcpMsgSocket *sock)
void	checkTimeout ()
void	removeProxy (FederateProxy *proxy)
void	disconnectProxy (FederateProxy *proxy)
void	removeProxyFromTimeout (FederateProxy *proxy)
void	processAddedConnections ()
int	processAddedConnection (DtTcpMsgSocket *sock)
bool	processNewSession (DtTcpMsgSocket *sock, unsigned long protocolVersion)
bool	processReconnect (DtTcpMsgSocket *sock, unsigned long sessionId, unsigned long lastReceived, unsigned long oldestSent)

Static Protected Member Functions
static void	socketAdded (DtTcpMsgSocket *sock, void *usr)
static void	socketRemoved (DtTcpMsgSocket *sock, void *usr)

Protected Attributes
DtTcpMsgSocketMgr *	mySocketMgr
	Pointer to the socket manager object owned by this instance. More...
std::shared_ptr < DtMsgHeaderReader >	myHeaderReader
std::map< DtTcpMsgSocket *, FederateProxy * >	mySocketToProxyMap
std::map< FederateProxy *, DtTcpMsgSocket * >	myProxyToSocketMap
std::map< unsigned long long, FederateProxy * >	mySessionIdToProxyMap
std::map< unsigned long long, FederateProxy * >	mySessionIdToDisconnectedMap
std::map< MAKRti::DtTime, FederateProxy * >	myTimeoutToDisconnectedMap
std::list< DtTcpMsgSocket * >	myAddedSockets
unsigned long	myNextId
MAKRti::DtClock	myClock

Constructor & Destructor Documentation

FederateProxyManager::FederateProxyManager	(	const std::string	serverAddress,
		int	serverPort
	)

FederateProxyManager::~FederateProxyManager

(

)

Member Function Documentation

void FederateProxyManager::checkTimeout ( )

protected

void FederateProxyManager::disconnectProxy ( FederateProxy *  proxy )

protected

void FederateProxyManager::killProxy

(

unsigned long long

sessionId

)

void FederateProxyManager::listProxies

(

)

int FederateProxyManager::processAddedConnection ( DtTcpMsgSocket *  sock )

protected

void FederateProxyManager::processAddedConnections ( )

protected

bool FederateProxyManager::processNewSession ( DtTcpMsgSocket *  sock, unsigned long  protocolVersion  )

protected

bool FederateProxyManager::processReconnect ( DtTcpMsgSocket *  sock, unsigned long  sessionId, unsigned long  lastReceived, unsigned long  oldestSent  )

protected

void FederateProxyManager::removeProxy ( FederateProxy *  proxy )

protected

void FederateProxyManager::removeProxyFromTimeout ( FederateProxy *  proxy )

protected

void FederateProxyManager::socketAdded ( DtTcpMsgSocket *  sock )

protected

static void FederateProxyManager::socketAdded ( DtTcpMsgSocket *  sock, void *  usr  )

staticprotected

void FederateProxyManager::socketRemoved ( DtTcpMsgSocket *  sock )

protected

static void FederateProxyManager::socketRemoved ( DtTcpMsgSocket *  sock, void *  usr  )

staticprotected

bool FederateProxyManager::tick

(

)

Member Data Documentation

std::list<DtTcpMsgSocket*> FederateProxyManager::myAddedSockets

protected

MAKRti::DtClock FederateProxyManager::myClock

protected

std::shared_ptr<DtMsgHeaderReader> FederateProxyManager::myHeaderReader

protected

unsigned long FederateProxyManager::myNextId

protected

std::map<FederateProxy*, DtTcpMsgSocket*> FederateProxyManager::myProxyToSocketMap

protected

std::map<unsigned long long, FederateProxy*> FederateProxyManager::mySessionIdToDisconnectedMap

protected

std::map<unsigned long long, FederateProxy*> FederateProxyManager::mySessionIdToProxyMap

protected

DtTcpMsgSocketMgr* FederateProxyManager::mySocketMgr

protected

Pointer to the socket manager object owned by this instance.

std::map<DtTcpMsgSocket*, FederateProxy*> FederateProxyManager::mySocketToProxyMap

protected

std::map<MAKRti::DtTime, FederateProxy*> FederateProxyManager::myTimeoutToDisconnectedMap

protected

---

The documentation for this class was generated from the following file:

• FederateProxyManager.h