simpFedMgr.h

Go to the documentation of this file.

/*********************************************************************
** Copyright (c) 1998 MaK Technologies, Inc.
** All rights reserved.
*********************************************************************/
/*********************************************************************
** $RCSfile: simpFedMgr.h,v $ $Revision: 1.26 $ $State: Exp $
*********************************************************************/

#ifndef simpFedMgr_H_
#define simpFedMgr_H_


#include "rtiMsConfig.h"
#include "fedMgr.h"
#include <vlutil/vlString.h>
#include <map>

class DT_DLL_LRC DtSimpleFederateMgr : public DtFederateMgr
{
public:

   DtSimpleFederateMgr(DtRIDParameters* params,
      DtRtiAmbassadorBaseImplementor* ambImplPtr,
      DtConnectionMgr* connMgr,
      DtBoost::shared_ptr<DtRtiAssistantLrcClient> assistantClient);

   virtual ~DtSimpleFederateMgr();

private:
   
   DtSimpleFederateMgr(DtFederateMgr const& );

   DtSimpleFederateMgr& operator= (DtSimpleFederateMgr const& );

public:



   virtual void createFederationExecution(
      const char* executionName, const char* timeImplName,
#ifdef DtIFSPEC1516E
      const std::vector<DtString>& fomModules,
      const char* mimModule);
#else
      const char* fed);
#endif

   virtual void destroyFederationExecution (
      const char* executionName);

#ifdef DtIFSPEC1516E

   virtual void listFederationExecutions();
#endif

#ifdef DtIFSPEC1516
   virtual rti1516::FederateHandle joinFederationExecution (
      const char* federateType,   
      const char* executionName, 
      rti1516::FederateAmbassador* federateAmbassadorReference, 
      unsigned long flags);
#elif defined(DtIFSPEC1516E)
   virtual rti1516e::FederateHandle joinFederationExecution (
      const char* federateName,   
      const char* federateType,   
      const char* executionName,
      const std::vector<DtString>& fomModules,
      unsigned long flags);
#else
   virtual RTI::FederateHandle joinFederationExecution (
      const char* federateType,   
      const char* executionName, 
      RTI::FederateAmbassador* federateAmbassadorReference, 
      unsigned long flags);
#endif

#ifdef DtIFSPEC1516
   virtual void resignFederationExecution(
      rti1516::ResignAction theAction);
#elif defined(DtIFSPEC1516E)
   virtual void resignFederationExecution(
       rti1516e::ResignAction theAction);
#else
   virtual void resignFederationExecution(
      RTI::ResignAction theAction);
#endif




#ifdef DtIFSPEC1516
   virtual void registerFederationSynchronizationPoint(
      char const * label,
      rti1516::VariableLengthData const & theTag);
#elif defined(DtIFSPEC1516E)
   virtual void registerFederationSynchronizationPoint(
       char const * label,
       rti1516e::VariableLengthData const & theTag);
#else
   virtual void registerFederationSynchronizationPoint(
      char const * label,
      char const * theTag);
#endif

#ifdef DtIFSPEC1516
   virtual void registerFederationSynchronizationPoint(
      char const * label,
      rti1516::VariableLengthData const & theTag,
      DtFederateHandleSet const & syncSet);
#elif defined(DtIFSPEC1516E)
   virtual void registerFederationSynchronizationPoint(
       char const * label,
       rti1516e::VariableLengthData const & theTag,
       DtFederateHandleSet const & syncSet);
#else
   virtual void registerFederationSynchronizationPoint(
      char const * label,
      char const * theTag,
      DtFederateHandleSet const & syncSet);
#endif

   virtual void synchronizationPointAchieved(
      const char* label, bool successfully=true);

   virtual void testSaveProgress();



#ifdef DtIFSPEC1516

   virtual void requestFederationSave (char const * label,
      rti1516::LogicalTime const * time=NULL);
   virtual void queryFederationSaveStatus();
   virtual void queryFederationRestoreStatus();
#elif defined(DtIFSPEC1516E)

   virtual void requestFederationSave (char const * label,
       rti1516e::LogicalTime const * time=NULL);
   virtual void queryFederationSaveStatus();
   virtual void queryFederationRestoreStatus();
   virtual void abortFederationSave();
   virtual void abortFederationRestore();
#else

   virtual void requestFederationSave (char const * label,
      RTI::FedTime const * time=NULL);
#endif

   virtual void federateSaveBegun ();
   virtual void federateSaveComplete ();
   virtual void federateSaveNotComplete ();
   virtual void requestFederationRestore ( const char *label);
   virtual void federateRestoreComplete ();
   virtual void federateRestoreNotComplete ();

   // Allow merging in lightweight connections
   virtual void mergeFomModules( std::vector<MAKRti::DtString>* fomModules );

   virtual void addNonDuplicateFoms(std::vector<MAKRti::DtString>& fomModules, const std::vector<MAKRti::DtString>& fomModulesToAdd);
public:

   static DtFederateMgr* create(DtRIDParameters* params,
      DtRtiAmbassadorBaseImplementor* ambImplPtr,
      DtConnectionMgr* connMgr,
      DtBoost::shared_ptr<DtRtiAssistantLrcClient> assistantClient);

protected:

   std::map< DtString, std::vector< DtString > > myFederationsToCreateFomModulesMap;

};

#endif