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,
      std::shared_ptr<DtRtiAssistantLrcClient> assistantClient);

   virtual ~DtSimpleFederateMgr();

private:
   
   DtSimpleFederateMgr(DtFederateMgr const& );

   DtSimpleFederateMgr& operator= (DtSimpleFederateMgr const& );

public:



   virtual void createFederationExecution(
      const char* executionName, const char* timeImplName,
#if defined(DtIFSPEC13) || defined(DtIFSPEC1516)
      const char* fed);
#else
      const std::vector<DtString>& fomModules,
      const char* mimModule);
#endif

   virtual void destroyFederationExecution (
      const char* executionName);

#if !defined(DtIFSPEC13) && !defined(DtIFSPEC1516)
   virtual void listFederationExecutions() const;

   virtual void listFederationMembers(DtString const& federationName) const;
#endif

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

   virtual void resignFederationExecution(RTI_API::ResignAction theAction);



   virtual void registerFederationSynchronizationPoint(char const * label, DtRtiApiTagConstRef theTag);

   virtual void registerFederationSynchronizationPoint(char const * label, DtRtiApiTagConstRef theTag,
      DtFederateHandleSet const & syncSet);

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

   virtual void testSaveProgress() const;



   virtual void requestFederationSave(char const * label, DtRtiApiTime const * time = NULL);
#if !defined(DtIFSPEC13)
   virtual void queryFederationSaveStatus();
   virtual void queryFederationRestoreStatus();
#if !defined(DtIFSPEC1516)
   virtual void abortFederationSave();
   virtual void abortFederationRestore();
#endif
#endif
   virtual void federateSaveBegun ();
   virtual void federateSaveComplete ();
   virtual void federateSaveNotComplete ();
   virtual void requestFederationRestore ( const char *label);
   virtual void federateRestoreComplete ();
   virtual void federateRestoreNotComplete ();

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

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

protected:

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

};

#endif