forwarderNodeInfoMsg.h

Go to the documentation of this file.

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

#ifndef DtForwarderNodeInfoMsg_H_
#define DtForwarderNodeInfoMsg_H_


#include <vlutil/vlString.h>
#include <vlutil/vlUtil.h>

#include "rtiMsg.h"
#include "netForwarderNodeInfoMsg.h"
#include <averagedLatencyTestReport.h>
#include <map>

class DtForwarderNodeInfoMsg;
class DtConnectionMgr;

struct DT_DLL_LRC DtForwarderNodeInfo
{
   DtForwarderNodeInfo();
   DtForwarderNodeInfo(const DtForwarderNodeInfo& orig)
   {
      myForwarderName = orig.myForwarderName;
      myHostName = orig.myHostName;
      myDestination = orig.myDestination;
      myNodeId = orig.myNodeId;
      myHasExec = orig.myHasExec;
      
      std::set<MAKRti::DtInetAddr>::const_iterator iter = orig.myExternalIPAddrs.begin();
      std::set<MAKRti::DtInetAddr>::const_iterator theEnd = orig.myExternalIPAddrs.end();
      for ( ; iter != theEnd; ++iter )
      {
         myExternalIPAddrs.insert(*iter);
      }
   }

   MAKRti::DtString myForwarderName;
   MAKRti::DtString myHostName;
   DtInetAddrAndPort myDestination;
   std::set<MAKRti::DtInetAddr> myExternalIPAddrs;
   unsigned long myNodeId;
   bool myHasExec;

   bool operator<(const DtForwarderNodeInfo& other) const
   {
      return myDestination < other.myDestination;
   }
   bool operator==(const DtForwarderNodeInfo& other) const
   {
      bool retVal = true;

      retVal = myNodeId == other.myNodeId
         && myDestination == other.myDestination
         && myForwarderName == other.myForwarderName
         && myHostName == other.myHostName
         && myHasExec == other.myHasExec
         && myExternalIPAddrs.size() == other.myExternalIPAddrs.size();
      std::set<MAKRti::DtInetAddr>::const_iterator iter = other.myExternalIPAddrs.begin();
      std::set<MAKRti::DtInetAddr>::const_iterator myIter = myExternalIPAddrs.begin();
      std::set<MAKRti::DtInetAddr>::const_iterator theEnd = other.myExternalIPAddrs.end();
      for ( ; retVal && iter != theEnd; ++iter, ++myIter )
      {
         retVal &= (myIter == iter );
      }
      return retVal;
   }
   
   void print() const;
};

      
typedef void (*DtForwarderNodeInfoCb)(const DtForwarderNodeInfoMsg& report, void* usr);


class DT_DLL_LRC DtForwarderNodeInfoMsg : public DtRtiMsg
{
public:
   

   DtForwarderNodeInfoMsg(DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

   DtForwarderNodeInfoMsg(const DtNetForwarderNodeInfoMsg* netRepMsg,
      DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

   virtual ~DtForwarderNodeInfoMsg();

   virtual DtRtiMsg* clone(bool copy = true) const;

   virtual void printData(DtLogicalTimeFactory* logicalTimeFactory) const;


   virtual void setInetAddr(const MAKRti::DtInetAddr& addr);
   virtual MAKRti::DtInetAddr getInetAddr() const;

   virtual void setNodeId( unsigned long nodeId);
   virtual unsigned long getNodeId() const;

   virtual void setPort( int nodeId);
   virtual int getPort() const;

   virtual void setForwarderName( const MAKRti::DtString& name);   
   virtual MAKRti::DtString forwarderName() const;   

   virtual void setForwarderHostName( const MAKRti::DtString& name );
   virtual MAKRti::DtString forwarderHostName() const;

   virtual void setKnownForwarderNodes(const std::set<DtForwarderNodeInfo>& nodes);
   virtual void knownForwarderNodes(std::set<DtForwarderNodeInfo>& nodesToPopulate) const;

   virtual void setNodeIdForRecipientToUse( unsigned long nodeId );
   virtual unsigned long nodeIdForRecipientToUse() const;

   virtual void setHasExec(bool hasExecValue);
   virtual bool hasExec() const;
   
public:

   static DtRtiMsg* create(const DtNetMsgHeader* initial,
      DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

   static DtRtiMsg* create(DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

   static void addCallback(DtConnectionMgr* conn,
      DtForwarderNodeInfoCb cb, void* usr);
   static void removeCallback(DtConnectionMgr* conn,
      DtForwarderNodeInfoCb cb, void* usr);


   static const DtString& shutDownStatement();

   static const DtString& readyStatement();

protected:

   virtual DtNetForwarderNodeInfoMsg* netForwarderNodeInfoMsg();
   virtual const DtNetForwarderNodeInfoMsg* netForwarderNodeInfoMsg() const;

   virtual DtRtiMsgKind internalDtRtiMsgKind();

   virtual int minSize() const;

   virtual const char* forwarderNamePtr() const;
   virtual char* forwarderNamePtr();
   virtual void setForwarderNameSize( unsigned int size );
   virtual unsigned int forwarderNameSize() const;
   
   virtual const char* forwarderHostNamePtr() const;
   virtual char* forwarderHostNamePtr();
   virtual void setForwarderHostNameSize( unsigned int size );
   virtual unsigned int forwarderHostNameSize() const;

   virtual void setAddressFamily(MAKRti::DtInetUtils::DtInetAddrFamily num );
   virtual MAKRti::DtInetUtils::DtInetAddrFamily addressFamily() const;

   virtual void setNumKnownForwarder(unsigned long num);
   virtual unsigned long numKnownForwarders() const;

   virtual const DtNetU128* knownFwAddrsPtr() const;
   virtual DtNetU128* knownFwAddrsPtr();

   virtual const DtNetU32* knownFwNodeIdsPtr() const;
   virtual DtNetU32* knownFwNodeIdsPtr();

   virtual const DtNetU16* knownFwNodePortsPtr() const;
   virtual DtNetU16* knownFwNodePortsPtr();

   virtual const char* knownFwNamesPtr() const;
   virtual char* knownFwNamesPtr();
   virtual void setKnownFwNamesSize(unsigned long size);
   virtual unsigned long knownFwNamesSize() const;

   virtual const char* knownFwHostNamesPtr() const;
   virtual char* knownFwHostNamesPtr();
   virtual void setKnownFwHostNamesSize(unsigned long size);
   virtual unsigned long knownFwHostNamesSize() const;

protected:

   static const DtString theShutDownStatement;

   static const DtString theReadyStatement;

};

#endif