smartForwardingProcessor.h

Go to the documentation of this file.

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

#ifndef DtSmartForwardingProcessor_H_
#define DtSmartForwardingProcessor_H_

#include "federateJoinResignFilter.h"
#include "updateInterDestinationFilter.h"
#include "rtiMsConfig.h"
#include <bitMask.h>
#include <map>

class DT_DLL_FORWARDER DtSmartForwardingProcessor
{
private:
   DtSmartForwardingProcessor();

   DtSmartForwardingProcessor(const DtSmartForwardingProcessor &);

   DtSmartForwardingProcessor& operator=(const DtSmartForwardingProcessor& orig);


public:
   DtSmartForwardingProcessor( std::shared_ptr<DtForwarderNode> parent );

   virtual ~DtSmartForwardingProcessor();
   
   bool federateJoined( const DtInetAddrAndPort& src, const DtNetJoinConfirmMsg* msg  );

   bool federateResigned( const DtInetAddrAndPort& src, const DtNetResignMsg* msg  );
   
   bool processJoinResignDestinations( const DtInetAddrAndPort& src,
      DtForwarderPort::DtAddressPortList& destinations );
   
   bool filterUpdateInterDestinations( const DtInetAddrAndPort& src,
      caddr_t msg, DtForwarderPort::DtAddressPortList& destinations );

public:

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

protected:

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

protected:
   typedef std::map< unsigned long, DtInetAddrAndPort > DtIdToAddrMap;
   typedef std::map< DtInetAddrAndPort, DtBitMask >     DtAddrToIdMaskMap;
   std::shared_ptr<DtForwarderNode>  myParent;
   DtIdToAddrMap     myFedIdToAddressMap;
   DtAddrToIdMaskMap myAddressToFedIdsMap;
   DtFederateJoinResignFilter<DtSmartForwardingProcessor>* myJoinResignFilter;
   DtUpdateInterDestinationFilter<DtSmartForwardingProcessor>* myUpdateInterFilter;
   
};

#endif