forwarderNodeInfoProcessor.h

Go to the documentation of this file.

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

#ifndef DtForwarderNodeInfoProcessor_H_
#define DtForwarderNodeInfoProcessor_H_

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

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

class DT_DLL_FORWARDER DtForwarderNodeInfoFilter;
class DtForwarderNodeInfoMsg;

class DT_DLL_FORWARDER DtForwarderNodeInfoProcessor
{
public:
   typedef bool (DtForwarderNodeInfoProcessor::* forwarderNodeInfoMsgHandlerMemberCb)(
      const DtForwarderPort::DtAddressMsgPair& msg  );

   DtForwarderNodeInfoProcessor( std::shared_ptr<DtForwarderNode> parent );
   
   virtual ~DtForwarderNodeInfoProcessor();
   
   virtual bool processForwarderNodeMsg( const DtForwarderPort::DtAddressMsgPair& msg );

public:

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

   virtual int lostConnection( const MAKRti::DtString& connName, const MAKRti::DtString& hostName,
      unsigned int connID, const std::pair<DtInetAddrAndPort, DtInetAddrAndPort>& addr);
   

protected:

   std::shared_ptr<DtForwarderNode>            myParent;
   DtForwarderNodeInfoFilter*                      myInitializationMsgsFilter;
   
   
   MAKRti::DtString                                myNodeName;
   MAKRti::DtString                                myHostName;
   unsigned long                                   myConnId;
   DtInetAddrAndPort                               myIp;

};

#endif