FederateProxyManager.h

Go to the documentation of this file.

/*********************************************************************
** Copyright (c) 2025 MAK Technologies
** All rights reserved.
*********************************************************************/

#pragma once

#include <rtiutil/rtiMsConfig.h>

#include <vlutil/vlSmartPointers.h>
#include <vlutil/vlTime.h>

#include <map>
#include <list>

class FederateProxy;
class DtMsgHeaderReader;
class DtTcpMsgSocketMgr;
class DtTcpMsgSocket;

namespace rti1516_2025
{
   class RTIambassadorFactory;
};

class DT_DLL_FEDPRO_SERVER FederateProxyManager
{
public:
   FederateProxyManager(const std::string serverAddress, int serverPort);
   ~FederateProxyManager();

   bool tick();

   void listProxies();

   void killProxy(unsigned long long sessionId);

protected:

   void socketAdded(DtTcpMsgSocket* sock);
   void socketRemoved(DtTcpMsgSocket* sock);
   void checkTimeout();

   void removeProxy(FederateProxy* proxy);
   void disconnectProxy(FederateProxy* proxy);
   void removeProxyFromTimeout(FederateProxy* proxy);


   void processAddedConnections();
   // Returns result of processing socket
   //    < 0: socket should be removed from list and discarded
   //    = 0: no action
   //    > 0: socket should be removed from list (given to federate proxy)
   int processAddedConnection(DtTcpMsgSocket* sock);

   bool processNewSession(DtTcpMsgSocket* sock, unsigned long protocolVersion);
   bool processReconnect(DtTcpMsgSocket* sock, unsigned long sessionId, unsigned long lastReceived, unsigned long oldestSent);

protected:

   static void socketAdded(DtTcpMsgSocket* sock, void* usr);
   static void socketRemoved(DtTcpMsgSocket* sock, void* usr);

protected:

   DtTcpMsgSocketMgr* mySocketMgr;
   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;

};