networkMapProcessor.h

Go to the documentation of this file.

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

#ifndef DtNetworkMapProcessor_H_
#define DtNetworkMapProcessor_H_

#include "forwarderNode.h"
#include "routeMap.h"
#include "rtiMsConfig.h"
#include <networkMapReqMsg.h>
#include <networkMapRspMsg.h>
#include <spyXmlDocument.h>
#include <netMapForwarderXmlBlock.h>

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

class DT_DLL_FORWARDER DtNetworkMapFilter;

class DT_DLL_FORWARDER DtNetworkMapProcessor
{
public:
   typedef bool (DtNetworkMapProcessor::* NetworkMapMsgReqHandlerMemberCb)(
      const DtInetAddrAndPort& src, const DtNetworkMapReqMsg& msg  );
   typedef bool (DtNetworkMapProcessor::* NetworkMapMsgRspHandlerMemberCb)(
      const DtInetAddrAndPort& src, const DtNetworkMapRspMsg& msg  );
   typedef bool (DtNetworkMapProcessor::* DestinationProcessingMemberCb)(
      const DtInetAddrAndPort& src, DtForwarderPort::DtAddressPortList& destinations );

   typedef void (*NetworkMapRequestCompletedCb)( DtNetworkMapRspMsg& msg, void* usr );
   typedef std::list< std::pair< NetworkMapRequestCompletedCb, void* > > RequestCompleteCallbackList;

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

   virtual bool gotNetworkMapRequest( const DtInetAddrAndPort& src,
      const DtNetworkMapReqMsg& msg  );

   virtual bool gotNetworkMapResponse( const DtInetAddrAndPort& src,
      const DtNetworkMapRspMsg& msg  );

   virtual void addRequestCompletedCb( NetworkMapRequestCompletedCb fn, void* usr );
   virtual void removeRequestCompletedCb( NetworkMapRequestCompletedCb fn, void* usr );

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

public:

   static int lostConnection( const MAKRti::DtString& connName,
      unsigned int connID, const DtInetAddrAndPort& addr, void* usr );

protected:

   struct PendingRequest
   {
      PendingRequest( bool isLocal, unsigned long requestor,
         unsigned long srcId, const DtInetAddrAndPort& srcAddr,
         const MAKRti::DtString& localName, unsigned long localId,
         const DtInetAddrAndPort& localIp,
         const DtRouteMap::DtAddressPortList& expectedOutResponses,
         const DtNetMapForwarderXmlBlock::SiblingList& siblings );

      bool requestComplete() const;
      void removePendingDestination( const DtInetAddrAndPort& addr );
      void setLanResponseRecieved();

      bool                      myIsLocalRequest;
      unsigned long             myRequestorId;
      unsigned long             mySourceId;
      DtInetAddrAndPort         mySourceAddress;
      DtRouteMap::DtAddressPortList myPendingOutResponses;
      bool                      myLanResponsePending;      

      DtSpyXmlDocument            myXmlResponse;
      DtNetMapForwarderXmlBlockSP myXmlNetworkMap;
   };

   typedef DtBoost::shared_ptr<PendingRequest> PendingRequestSP;
   typedef std::map< unsigned long, PendingRequestSP > RequestorToRequestsMap;
   
protected:

   virtual int lostConnection( const MAKRti::DtString& connName,
      unsigned int connID, const DtInetAddrAndPort& addr );
   
   virtual void sendResponseMsg( PendingRequestSP request );

   virtual void sendRequestMsg( PendingRequestSP request );

   virtual bool processInToOutRspMsg( const DtInetAddrAndPort& src,
      const DtNetworkMapRspMsg& msg );
   
   virtual bool processLanToOutRspMsg( const DtInetAddrAndPort& src,
      const DtNetworkMapRspMsg& msg );
   
   

protected:

   DtBoost::shared_ptr<DtForwarderNode>            myParent;
   DtNetworkMapFilter*         myMsgToOutFilter;
   
   MAKRti::DtString            myNodeName;
   unsigned long               myConnId;
   DtInetAddrAndPort           myIp;

   DtNetMapForwarderXmlBlock::SiblingList mySiblingForwarders;

   RequestCompleteCallbackList myCompletedRequestCallbacks;

   RequestorToRequestsMap      myPendingRequests;


};

#endif //! DtNetworkMapProcessor_H_