forwarderInfo.h

Go to the documentation of this file.

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


#ifndef DtForwarderInfo_H_
#define DtForwarderInfo_H_

#include <rtiMsConfig.h>
#include <map>
#include <vlutil/vlString.h>
#include <vlutil/vlInetAddr.h>
#include <rtiVersion.h>
#include <assistantForwarderStateMsg.h>
#include <vlutil/vlSmartPointers.h>

class DT_DLL_ASSISTANTAPP DtAssistantNetworkCompInfo
{
public:

   DtAssistantNetworkCompInfo();
   DtAssistantNetworkCompInfo(const MAKRti::DtString& name);
   DtAssistantNetworkCompInfo(const DtAssistantNetworkCompInfo& orig);

   virtual ~DtAssistantNetworkCompInfo();

   virtual DtAssistantNetworkCompInfo& operator=(const DtAssistantNetworkCompInfo& other);
   virtual bool operator==(const DtAssistantNetworkCompInfo& other) const;
   virtual bool operator!=(const DtAssistantNetworkCompInfo& other) const;


   MAKRti::DtString name() const { return myName; }
   void setName(const MAKRti::DtString& n) { myName = n; }

   MAKRti::DtInetAddr address() const { return myAddress; }
   void setAddress(const MAKRti::DtInetAddr& a) { myAddress = a; }
   
   MAKRti::DtInetAddr privateAddress() const { return myPrivateAddress; }
   void setPrivateAddress(const MAKRti::DtInetAddr& a) { myPrivateAddress = a; }

   MAKRti::DtString hostName() const { return myHostName; }
   void setHostName(const MAKRti::DtString& n) { myHostName = n; }

   int port() const { return myPort; }
   void setPort(int p) { myPort = p; }

   MAKRti::DtString hostPort() const {return myHostName + ":" + MAKRti::DtString(myPort);}

   MAKRti::DtString processName() const { return myProcessName; }
   void setProcessName(const MAKRti::DtString& n) { myProcessName = n; }

   MAKRti::DtString typeName() const { return myTypeName; }
   void setTypeName(const MAKRti::DtString& n) { myTypeName = n; }

   MAKRti::DtString commandArgs() const { return myCommandArgs; }
   void setCommandArgs(const MAKRti::DtString& a) { myCommandArgs = a; }

   MAKRti::DtString pid() const { return myPid; }
   void setPid(const MAKRti::DtString& p) { myPid = p; }

   MAKRti::DtString federationName() const { return myFederationName; }
   void setFederationName(const MAKRti::DtString& h) { myFederationName = h; }

   int federateHandle() const { return myFederateHandle; }
   void setFederateHandle(int h) { myFederateHandle = h; }

   unsigned connectionId() const { return myConnId; }
   void setConnectionId(unsigned i) { myConnId = i; }

   int queueStatus() const { return myQueueStatus; }
   void setQueueStatus(int q) { myQueueStatus = q; }

   DtHlaVersionId hlaVersion() const { return myHlaVersion; }
   void setHlaVersion(DtHlaVersionId v) { myHlaVersion = v; }

   DtAssistantMsgFederateStatus federateStatus() const { return myFederateStatus; }
   void setFederateStatus(DtAssistantMsgFederateStatus v) { myFederateStatus = v; }



   bool isValid() const { return !myAddress.isAnyAddr(); }

   bool isDropped() const;

protected:

   MAKRti::DtString myName;
   MAKRti::DtInetAddr myAddress;
   MAKRti::DtInetAddr myPrivateAddress;
   MAKRti::DtString myHostName;
   MAKRti::DtString myProcessName;
   MAKRti::DtString myTypeName;
   MAKRti::DtString myCommandArgs;
   MAKRti::DtString myPid;
   MAKRti::DtString myFederationName;
   int myPort;
   int myFederateHandle;
   unsigned myConnId;
   int myQueueStatus;
   DtHlaVersionId myHlaVersion;
   DtAssistantMsgFederateStatus myFederateStatus;
};

typedef std::list<DtAssistantNetworkCompInfo> DtAssistantNetworkCompInfoList;

class DT_DLL_ASSISTANTAPP DtAssistantForwarderInfo
{

public:

   DtAssistantForwarderInfo(bool isLocal);

   ~DtAssistantForwarderInfo();

   DtAssistantForwarderInfo & operator = ( const DtAssistantForwarderInfo & rhs );
   bool operator!=( const DtAssistantForwarderInfo & other ) const;
   bool operator==( const DtAssistantForwarderInfo & other ) const;

   void updateFromStateMsg(const DtAssistantForwarderStateMsg& msg);

   const DtAssistantMsg* lastStateMsg() const { return myLastStateMessage.get(); }


   typedef std::pair<MAKRti::DtString, int> DtFedexNameFedHdlPair;
   typedef std::map<DtFedexNameFedHdlPair, DtAssistantNetworkCompInfo> DtCompByFederationAndHandleMap;
   // TODO figure out why this typedef for Forwarders uses DtAssistantNetworkCompInfo instead of DtAssistantForwarderInfo
   typedef std::map<DtInetAddrAndPort, DtAssistantNetworkCompInfo> DtPeerForwarderByAddrMap;


   MAKRti::DtInetAddr address() const { return myAddr; }
   int port() const { return myPort; }
   MAKRti::DtString name() const;
   MAKRti::DtString hostName() const;
   const DtPeerForwarderByAddrMap* peerForwarders() const { return &myPeerForwarders; }
   const DtAssistantNetworkCompInfo* rtiexecInfo() const { return &myRtiexec; }
   const DtAssistantNetworkCompInfo* federateInfo(
      const MAKRti::DtString& federation, int handle) const;
   const DtCompByFederationAndHandleMap* federates() const { return &myFederateConns; }
   const DtAssistantNetworkCompInfoList* unclassifiedConns() const { return &myUnclassifiedConns; }
   const DtAssistantNetworkCompInfo* unclassifiedConnInfo(
      unsigned connId ) const;
   bool isDropped();

protected:

   MAKRti::DtInetAddr myAddr;

   int myPort;

   MAKRti::DtString myName;

   MAKRti::DtString myHostName;

   DtPeerForwarderByAddrMap myPeerForwarders;

   DtAssistantNetworkCompInfo myRtiexec;

   DtCompByFederationAndHandleMap myFederateConns;

   std::list<DtAssistantNetworkCompInfo> myUnclassifiedConns;

   bool myIsLocal;

   std::shared_ptr<DtAssistantMsg> myLastStateMessage;
};


#endif