forwarderFaultManager.h

Go to the documentation of this file.

/*********************************************************************
** Copyright (c) 2005 MaK Technologies, Inc.
** All rights reserved.
*********************************************************************/
/*********************************************************************
** $RCSfile: forwarderFaultManager.h,v $ $Revision: 1.4 $ $State: Exp $
*********************************************************************/

#ifndef DtForwarderFaultManager_H_
#define DtForwarderFaultManager_H_

#include "rtiMsConfig.h"
#include <vector>
#include <map>
#include <vlutil/vlTime.h>

class DtConnectionMgr;
class DtJoinMsg;
class DtForwarderConnectionLostMsg;
class DtForwarderPingMsg;


class DT_DLL_EXEC DtForwarderFaultManager
{
private:
   DtForwarderFaultManager();
public:

   DtForwarderFaultManager( DtConnectionMgr* connectMgr,
      MAKRti::DtTime heartbeatPeriod );

   virtual ~DtForwarderFaultManager();

   virtual void tick();

public:

   static void processJoin(const DtJoinMsg& msg, void* usr);

   static void processConnectionLost(const DtForwarderConnectionLostMsg& msg, void* usr);

   static void processPing(const DtForwarderPingMsg& msg, void* usr);

protected:

   typedef std::vector< unsigned long > DtConnIdList;
   typedef std::map< unsigned long, DtConnIdList > DtForwarderIdToConnIdsMap;

protected:

   virtual void processJoin(const DtJoinMsg& msg);
   
   virtual void processConnectionLost(const DtForwarderConnectionLostMsg& msg);

   virtual void processPing(const DtForwarderPingMsg& msg);

   virtual void pingAllForwarders() const;

   virtual void pingForwarder( unsigned long forwarderId ) const;

   virtual void resignForwarder( unsigned long forwarderId ) const;
      
   virtual void disconnectFederates( const DtConnIdList& federates ) const;
   
protected:

   DtForwarderIdToConnIdsMap myForwarderToFederatesMap;
   DtConnectionMgr*          myConnectMgr;
   MAKRti::DtClock           myClock;
   MAKRti::DtTime            myHeartbeatPeriod;
   MAKRti::DtTime            myLastHeartbeat;
};

#endif