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, 
      unsigned int connID, const DtInetAddrAndPort& connAddr, void* usr );

protected:

   virtual int lostConnection( const MAKRti::DtString& connName, 
      unsigned int connID, const 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 ) {}
         
      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 //! DtForwarderPingProcessor_H_