rtiShmQNetMgr.h

Go to the documentation of this file.

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

#ifndef DtRtiShmQNetMgr_H_
#define DtRtiShmQNetMgr_H_


#include "rtiMsConfig.h"
#include "asyConMgr.h"
#include <vlutil/vlThread.h>
#include "RIDparams.h"
#include "multicastDiscoveryMgr.h"

#include <vlutil/vlSelectParamW.h>
#include <vlutil/vlHashlist.h>

#include <vector>

class DtRtiMsg;
class DtMessageFilter;
class DtSmConnectionMgr;

class DT_DLL_LRC DtRtiShmQNetMgr : public DtAsyncConnectionMgr
{
protected:
   
   DtRtiShmQNetMgr( DtRIDParameters * params );

public:

   virtual ~DtRtiShmQNetMgr();

   virtual int init(DtRIDParameters* params);

   virtual void setSmConnMgr( DtSmConnectionMgr *smConnMgr );

   virtual void enrollSmFederate( DtFederateHandle federateHandle, int fedExHandle );
   virtual void dropSmFederate( DtFederateHandle federateHandle, int fedExHandle );

protected:

   DtRtiShmQNetMgr( const DtRtiShmQNetMgr& orig );
   DtRtiShmQNetMgr& operator=( const DtRtiShmQNetMgr& orig );

   virtual bool processConnection( DtRtiConnection* conn, MAKRti::DtTransportType trans );
   virtual DtNetReadStatus  processMsg( const DtRtiMsg& msg );

   virtual void applyOutboundMsgFilters( DtRtiMsg *msg );
   virtual DtNetReadStatus filterReliableLoopbacks( const DtRtiMsg& msg );



   virtual bool performMulticastDiscovery();

public:
 
   static DtConnectionMgr* create(DtRIDParameters* p);

protected:

   MAKRti::DtInetAddr          myHostIpAddr;
   unsigned int        myPort;
   DtSmConnectionMgr * mySmConnMgr;

   bool myCloseAllConnectionsRequested;

   typedef std::multimap< DtFederateHandle, int >  DtFedHandleToFedExHandleMap;
   DtFedHandleToFedExHandleMap  myFedHandleToFedExMap;

   typedef std::map< int, DtBitMask* > DtRouteMaskFilterByFedexHandle;
   typedef std::map< MAKRti::DtString, DtBitMask* > DtRouteMaskFilterByFedexName;

   DtRouteMaskFilterByFedexHandle myFedexHandleFilterList;
   DtRouteMaskFilterByFedexName   myFedexFilterList;

};

#endif