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

   static int newConnection( const MAKRti::DtString& connName,
      unsigned int connID, const 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,
      unsigned int connID, const DtInetAddrAndPort& connAddr );

   virtual int newConnection( const MAKRti::DtString& connName,
      unsigned int connID, const DtInetAddrAndPort& connAddr );
   
   virtual void processLostUpstreamConnection();

protected:

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

#endif