lanForwarderPort.h

Go to the documentation of this file.

/*******************************************************************************
 ** Copyright (c) 2006 MaK Technologies, Inc.
 ** All rights reserved.
 *******************************************************************************/
/*******************************************************************************
 ** $RCSfile: lanForwarderPort.h,v $ $Revision: 1.7 $ $State: Exp $
 *******************************************************************************/

#ifndef DtLanForwarderPort_H_
#define DtLanForwarderPort_H_

#include "forwarderPort.h"
#include "rtiMsConfig.h"
#include <map>
#include <vector>

class DtRIDParameters;
class DtRouteMap;
class DtExtendedRtiMsgForwarder;
class DtFederateTrackingFilter;

class DT_DLL_FORWARDER DtLanForwarderPort : public DtForwarderPort
{
protected:

   DtLanForwarderPort( const DtRIDParameters* params,
      DtBoost::shared_ptr<DtRouteMap> routes,
      const MAKRti::DtInetAddr& host,
      int forwarderPort,
      const MAKRti::DtInetEndpoint& forwardertoConnectTo );

public:
   
   virtual ~DtLanForwarderPort();
   
   virtual bool isReady() const;

   virtual DtAddressMsgPair getNextMsg();

   virtual void sendByTransport( const DtForwarderMsg& msg ) const;

   virtual void sendToAllReliable( const DtForwarderMsg& msg ) const;

   virtual void sendToListReliable( const DtForwarderMsg& msg,
      const DtAddressPortList& destinations ) const;

   virtual inline bool flush();

   virtual void setForwarderId(unsigned long id);

   virtual void selectParams( MAKRti::DtSelectParamWithWrite& selectParams );

   virtual void updateRoutes();
   
   virtual int checkConnectionStatus( const DtInetAddrAndPort* target = 0 );

   virtual void clearNeededConnections();

   virtual unsigned int abortPendingConnections();

   unsigned int pendingConnectionsAborted();

   virtual DtAddressPortList connections() const;

   virtual void listenToMulticastGroup( const MAKRti::DtInetAddr& mcastAddr );
   virtual void dropMulticastGroup( const MAKRti::DtInetAddr& mcastAddr );
   
   virtual bool updateFederateConnectionId( unsigned long orig, 
                                            unsigned long final );

   virtual const DtFederateTrackingFilter* fedTrackingFilter() const;

   virtual bool populateConnectionInformation(
      unsigned int& numForwarderClientConns,
      unsigned int& numForwarderExecConns,
      std::vector<MAKRti::DtString>& clientConnectionHostNames,
      std::vector<MAKRti::DtInetAddr>& clientConnectionAddrs) const;

public:
   
   static DtForwarderPort* create( const DtRIDParameters* params,
      const DtBoost::shared_ptr<DtRouteMap> routes,
      const MAKRti::DtInetAddr& host,
      int forwarderPort,
      const MAKRti::DtInetEndpoint& forwardertoConnectTo );
   
   static void setCreatorFunction( DtForwarderPortCreatorFcn creator );
   
protected:   

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

   
protected:

   const DtRIDParameters*      myParams;
   DtExtendedRtiMsgForwarder*  myForwarder;
   bool                        myIsReady;

protected:

   static DtForwarderPortCreatorFcn theCreator;
   
};

#endif