federationStateInfo.h

Go to the documentation of this file.

/*********************************************************************
** Copyright (c) 2008 MaK Technologies, Inc.
** All rights reserved.
*********************************************************************/
/*******************************************************************************
** $RCSfile: federationStateInfo.h,v $ $Revision: 1.8 $ $State: Exp $
*******************************************************************************/

#ifndef federationStateInfo_H_
#define federationStateInfo_H_


#include "rtiVersion.h"
#include <vlutil/vlString.h>
#include <vlutil/vlInetAddr.h>
#include <map>
#include <set>

struct DtFederationInfo
{
public:
   DtFederationInfo( MAKRti::DtString name = MAKRti::DtString::nullString(), int handle = -1,
      MAKRti::DtString file = MAKRti::DtString::nullString(), bool testEn = true,
      MAKRti::DtInetAddr webIp = MAKRti::DtInetAddr(), int webPort = -1 ) :
      federationName( name ),
      federationHandle( handle ),
      fedFileName( file ),
      testEnabled( testEn )
      {}

      MAKRti::DtString federationName;
      int      federationHandle;
      MAKRti::DtString fedFileName;
      bool     testEnabled;
};

class DT_DLL_ASSISTANT DtFederateTimeStateInfo
{
public:
   DtFederateTimeStateInfo( unsigned long connId = 0, MAKRti::DtString fedType = "",
      MAKRti::DtString fedName = "", int handle = -1, MAKRti::DtString fedHostName = "", 
      MAKRti::DtInetAddr host = MAKRti::DtInetAddr(), DtHlaVersionId hlaVer = DtHla1516,
      MAKRti::DtInetAddr webServerHost = MAKRti::DtInetAddr(),
      int webServerPort = 0, bool testEn = false, bool testInProg = false, 
      bool contTest = false, unsigned numInitTests = 0, 
      unsigned numTestReps = 0 ) :
      connId( connId ),
      federateType( fedType ),
      federateName( fedName ),
      federateHandle( handle ),
      federateHostName( fedHostName ),
      federateHost( host ),
      hlaVersion( hlaVer ),
      federateWebServerHost( webServerHost ),
      federateWebServerPort( webServerPort ),
      testEnabled( testEn ),
      testInProgress( testInProg ),
      continuousTest( contTest ),
      numInitiatedTests( numInitTests ),
      numTestReports( numTestReps ),
      isRegulating( false ),
      isConstrained( false ),
      isReconnecting( false ),
      isDisconnected( false ) {}

   bool operator==(const DtFederateTimeStateInfo& rhs) const
   {
      return ( connId == rhs.connId && federateType == rhs.federateType &&
         federateName == rhs.federateName &&
         federateHostName == rhs.federateHostName && 
         federateHandle == rhs.federateHandle && 
         federateHost == rhs.federateHost && 
         hlaVersion == rhs.hlaVersion &&
         federateWebServerHost == rhs.federateWebServerHost && 
         federateWebServerPort == rhs.federateWebServerPort && 
         testEnabled == rhs.testEnabled &&
         testInProgress == rhs.testInProgress &&
         continuousTest == rhs.continuousTest &&
         numInitiatedTests == rhs.numInitiatedTests &&
         numTestReports == rhs.numTestReports &&
         isReconnecting == rhs.isReconnecting && 
         isDisconnected == rhs.isDisconnected && 
         isRegulating == rhs.isRegulating && 
         isConstrained == rhs.isConstrained && lbtsString == rhs.lbtsString &&
         lookAheadString == rhs.lookAheadString && timeString == rhs.timeString );
   }
   bool operator!=(const DtFederateTimeStateInfo& rhs) const
   {
      return !(*this == rhs);
   }

      unsigned long connId;
      MAKRti::DtString   federateType;
      MAKRti::DtString   federateName;
      MAKRti::DtString   federateHostName;
      int        federateHandle;
      MAKRti::DtInetAddr federateHost;
      DtHlaVersionId hlaVersion;
      MAKRti::DtInetAddr federateWebServerHost;
      int        federateWebServerPort;

      bool     testEnabled;
      bool     testInProgress;
      bool     continuousTest;
      unsigned numInitiatedTests;
      unsigned numTestReports;

      bool isReconnecting;
      bool isDisconnected;

      bool isRegulating;
      bool isConstrained;

      MAKRti::DtString lbtsString;
      MAKRti::DtString lookAheadString;
      MAKRti::DtString timeString;

      bool heartbeated;
};

// Related typedefs
typedef std::map< int, DtFederateTimeStateInfo > DtFederateStateByHandleMap;
typedef std::pair< std::set< int >, std::set< int > > DtPendingAchievedPair;
typedef std::map< MAKRti::DtString, DtPendingAchievedPair > DtSyncPtToAchievedFederatesMap;
struct DtFederationStateInfo
{
   DtFederationInfo federationInfo;
   DtFederateStateByHandleMap federates;
   DtSyncPtToAchievedFederatesMap syncPts;
   std::map< int, int > localFederates; // handles and component IDs
   bool heartbeated;
};
typedef std::map< MAKRti::DtString, DtFederationStateInfo > DtFederationStateByNameMap;
typedef std::map< int, MAKRti::DtString > DtFederationNameByHandleMap;


#endif