multicastSubscriptionProcessor.h

Go to the documentation of this file.

/*******************************************************************************
** Copyright (c) 2006 MaK Technologies, Inc.
** All rights reserved.
*******************************************************************************/
/*******************************************************************************
** $RCSfile: multicastSubscriptionProcessor.h,v $ $Revision: 1.4 $ $State: Exp $
*******************************************************************************/
#ifndef DtMulticastSubscriptionProcessor_H_
#define DtMulticastSubscriptionProcessor_H_

#include "multicastListenDropFilter.h"
#include "rtiMsConfig.h"
#include <map>


class DT_DLL_FORWARDER DtMulticastSubscriptionProcessor
{
private:
   DtMulticastSubscriptionProcessor();

public:
   DtMulticastSubscriptionProcessor( DtBoost::shared_ptr<DtForwarderNode> parent );

   virtual ~DtMulticastSubscriptionProcessor();
   
   bool listenToMulticastGroup( const DtInetAddrAndPort& src, const DtNetMulticastConfigureMsg* msg  );
   
   bool dropMulticastGroup( const DtInetAddrAndPort& src, const DtNetMulticastConfigureMsg* msg  );

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

public:

   static void setMaxFederates( unsigned int maxFederates );
   unsigned int maxFederates() const;

#if (0)

   static void lostConnection( const MAKRti::DtInetAddr& addr, void* usr );
#endif 

protected:
#if (0)

   virtual void lostConnection( const MAKRti::DtInetAddr& addr );
#endif

   virtual bool forceDropMulticastGroup( const MAKRti::DtInetAddr& addr  );

   unsigned long federateIndex( unsigned long federateHandle ) const;

protected:
   DtBoost::shared_ptr<DtForwarderNode>  myParent;

   static unsigned int theMaxFederates;

   typedef std::map< unsigned long, MAKRti::DtInetAddr > DtIdToAddrMap;
   DtIdToAddrMap     myFedIdToAddressMap;

   typedef std::map< MAKRti::DtInetAddr, DtBitMask > DtAddrToIdMaskMap;
   DtAddrToIdMaskMap myAddressToFedIdsMap;

   DtMulticastListenDropFilter<DtMulticastSubscriptionProcessor>* myListenDropFilter;

   unsigned long myLastMulticastDropFedHdl;
   MAKRti::DtInetAddr myLastMulticastDropAddr;


};

#endif