rtiAssistantForwarderClient.h

Go to the documentation of this file.

/*********************************************************************
 ** Copyright (c) 2013 MaK Technologies, Inc.
 ** All rights reserved.
 *********************************************************************/

#ifndef rtiAssistantForwarderClient_H_
#define rtiAssistantForwarderClient_H_


#include "rtiVersion.h"
#include "rtiAssistantClient.h"
#include "assistantConnectionInfo.h"


struct DtNameAndConnStatus
{
   MAKRti::DtString name;
   bool isConnected;
};
typedef std::map<DtInetAddrAndPort, DtNameAndConnStatus> DtNeededFwConnMap;

class DT_DLL_ASSISTANT DtRtiAssistantForwarderClient : public DtRtiAssistantClient
{
public:

   DtRtiAssistantForwarderClient( DtAssistantComponentType type,
                                  int port = DtASSISTANT_DEFAULT_PORT );

   virtual ~DtRtiAssistantForwarderClient();

   virtual void updateForwarderInfo(
      const MAKRti::DtInetAddr& tcpAddr,  int tcpPort, const DtInetAddr& tcpNetworkIfAddr,
      const MAKRti::DtInetAddr& udpAddr, int udpPort, const DtInetAddr& udpNetworkIfAddr,
      bool fullCompliance,
      const MAKRti::DtInetAddr& additionalForwarder, int forwarderPort,
      bool useRoutesFile);

   virtual void updateLogFile( const MAKRti::DtFilename& file );

   virtual void updateExecConfirmed( bool confirmed, bool fullyCompliant );

   virtual void sendClientInfo(bool isReconnect = false) override;

   virtual void sendFullForwarderInfo(unsigned int numForwarderToForwarderConns,
      const std::vector<MAKRti::DtString>& forwarderIdentifiers,
      const std::vector<MAKRti::DtString>& forwarderConnectionNames,
      const std::vector<MAKRti::DtString>& forwarderConnectionHostNames,
      const std::vector< std::pair< MAKRti::DtInetAddr, MAKRti::DtInetAddr > >& forwarderConnectionAddrs,
      const std::vector<int>& forwarderConnectionPorts,
      unsigned int numForwarderExecConns,
      unsigned int numForwarderClientConns,
      const std::vector<MAKRti::DtString>& clientConnectionNames,
      const std::vector<MAKRti::DtString>& clientConnectionTypeNames,
      const std::vector<DtString>& clientConnectionProcessNames,
      const std::vector<DtString>& clientConnectionPIDs,
      const std::vector<DtString>& clientConnectionCommandArgs,
      const std::vector<MAKRti::DtString>& clientConnectionHostNames,
      const std::vector<MAKRti::DtInetAddr>& clientConnectionAddrs,
      const std::vector<MAKRti::DtString>& clientConnectionFederationNames,
      const std::vector<int>& clientFederateHandles,
      const std::vector<unsigned>& clientConnIds,
      const std::vector<int>& clientConnectionQueueStatus,
      const std::vector<DtHlaVersionId>& clientHlaVersions,
      const std::vector<DtAssistantMsgFederateStatus>& clientConnectionFederateStatus );

   virtual void sendWaitingForForwarders(bool isWaiting, const DtNeededFwConnMap& neededFws);

protected:

   MAKRti::DtString myHostName;

   MAKRti::DtInetAddr myTcpAddress;

   int myTcpPort;

   MAKRti::DtInetAddr myTcpIfAddress;

   MAKRti::DtInetAddr myUdpAddress;

   int myUdpPort;

   MAKRti::DtInetAddr myUdpIfAddress;

   bool myFullCompliance;

   MAKRti::DtInetAddr myAdditionalForwarder;

   int myForwarderPort;

   bool myUseRoutesFile;

   bool myExecConfirmed;

   MAKRti::DtFilename myLogFile;

   DtClock myClock;

};


#endif