forwarderPingProcessor.h

Go to the documentation of this file.

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

#ifndef DtForwarderPingProcessor_H_
#define DtForwarderPingProcessor_H_

#include "forwarderNode.h"
#include "forwarderPingMsg.h"
#include "routeMap.h"
#include "rtiMsConfig.h"

#include <vlutil/vlUtil.h>
#include <map>
#include <set>

class DtForwarderPingFilter;
class DtRtiExecDisconnectFilter;

class DT_DLL_FORWARDER DtForwarderPingProcessor
{
public:
   typedef bool (DtForwarderPingProcessor::* PingMsgHandlerMemberCb)(
      const DtInetAddrAndPort& src, const DtForwarderPingMsg& msg  );
   typedef bool (DtForwarderPingProcessor::* DestinationProcessingMemberCb)(
      const DtInetAddrAndPort& src, DtForwarderPort::DtAddressPortList& destinations );

   DtForwarderPingProcessor( DtBoost::shared_ptr<DtForwarderNode> parent );
   
   virtual ~DtForwarderPingProcessor();

   virtual bool gotMsgToLanPort( const DtInetAddrAndPort& src,
      const DtForwarderPingMsg& msg );

   virtual bool gotMsgToOutPort( const DtInetAddrAndPort& src,
      const DtForwarderPingMsg& msg );

   virtual bool processPingMsgDestinations ( const DtInetAddrAndPort& src,
      DtForwarderPort::DtAddressPortList& destinations );

   virtual bool ignorePingMsgToLan ( const DtInetAddrAndPort& src,
      DtForwarderPort::DtAddressPortList& destinations );

public:

   static int lostConnection( const MAKRti::DtString& connName, const MAKRti::DtString& hostName, 
      unsigned int connID, const std::pair<DtInetAddrAndPort, DtInetAddrAndPort>& connAddr, void* usr);

protected:

   virtual int lostConnection( const MAKRti::DtString& connName, const MAKRti::DtString& hostName,
      unsigned int connID, const std::pair<DtInetAddrAndPort, DtInetAddrAndPort>& connAddr);
   
   virtual void sendResponseMsg( unsigned long target,
      DtForwarderPingMsg::DtPingStatus status, 
      const DtInetAddrAndPort* addr = 0 );

   virtual bool processInToOutMsg( const DtInetAddrAndPort& src,
      const DtForwarderPingMsg& msg );
   
   virtual bool processLanToOutMsg( const DtInetAddrAndPort& src,
      const DtForwarderPingMsg& msg );

   
protected:

   class PendingRequest
   {
   public:
      PendingRequest() :
         currentStatus(DtForwarderPingMsg::PingResponseNotFound),
         destinationId(0),
         sourceAddress(),
         pendingOutResponses() {}

      PendingRequest(const DtInetAddrAndPort& src, unsigned int destId,
         const DtRouteMap::DtAddressPortList& expectedOutResponses) :
         currentStatus(DtForwarderPingMsg::PingResponseNotFound),
         destinationId(destId),
         sourceAddress(src),
         pendingOutResponses(expectedOutResponses) {}
   private:

   public:
      PendingRequest(const PendingRequest & orig)
      {
         *this = orig;
      }
      PendingRequest& operator=(const PendingRequest& orig)
      {
         if (this != &orig)
         {
            currentStatus = orig.currentStatus;
            destinationId = orig.destinationId;
            sourceAddress = orig.sourceAddress;
            pendingOutResponses = orig.pendingOutResponses;
         }
         return *this;
      }

   public:
      DtForwarderPingMsg::DtPingStatus currentStatus;
      unsigned int                     destinationId;
      DtInetAddrAndPort                sourceAddress;
      DtRouteMap::DtAddressPortList    pendingOutResponses;
   };

   typedef std::map< unsigned long, PendingRequest > DtDestToRequestMap;
   
protected:

   DtBoost::shared_ptr<DtForwarderNode>       myParent;
   DtForwarderPingFilter* myMsgToLanFilter;
   DtForwarderPingFilter* myMsgToOutFilter;

   DtDestToRequestMap   myPendingRequests;
   
};

#endif