forwarderFaultProcessor.h

Go to the documentation of this file.

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

#ifndef DtForwarderFaultProcessor_H_
#define DtForwarderFaultProcessor_H_

#include "rtiExecConnectionFilter.h"
#include "rtiMsConfig.h"

class DtForwarderNode;


class DT_DLL_FORWARDER DtForwarderFaultProcessor
{
private:
   DtForwarderFaultProcessor();
   
public:
   
   DtForwarderFaultProcessor( DtForwarderNode* parent );

   virtual ~DtForwarderFaultProcessor();

public:

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

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

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

   virtual bool isLocalGroupMember( const DtInetAddrAndPort& addr );
   virtual DtInetAddrAndPort locateGroupPortal( const DtInetAddrAndPort& addr );

   virtual DtInetAddrAndPort localNodeAddress();

   virtual DtInetAddrAndPort rootForwarder();

   virtual DtInetAddrAndPort nextHopTowardRootForwarder();

protected:

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

   virtual int newConnection( const MAKRti::DtString& connName, const MAKRti::DtString& hostName,
      unsigned int connID, const std::pair<DtInetAddrAndPort, DtInetAddrAndPort>& connAddr);
   
   virtual void processLostUpstreamConnection();

protected:

   DtForwarderNode* myParent;
   DtRtiExecConnectionFilter<DtForwarderFaultProcessor> myRtiExecMonitor;
   
};

#endif