MAK RTIspy API Documentation for HLA Evolved
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Groups Pages
execFedMgr.h
Go to the documentation of this file.
1 /*********************************************************************
2 ** Copyright (c) 1998 MaK Technologies, Inc.
3 ** All rights reserved.
4 *********************************************************************/
5 /*********************************************************************
6 ** $RCSfile: execFedMgr.h,v $ $Revision: 1.58 $ $State: Exp $
7 *********************************************************************/
8 
9 #ifndef execFedMgr_H_
10 #define execFedMgr_H_
11 
14 
15 
16 #include "rtiMsConfig.h"
17 #include "fedMgr.h"
18 #include "syncPointMsg.h"
19 #include "resBegMsg.h"
20 #include "creRespMsg.h"
21 #include "desRespMsg.h"
22 #include "joinRespMsg.h"
23 #include "joinConfMsg.h"
24 #include "savRespMsg.h"
25 #include "fomModuleRequestMsg.h"
26 #include "synchronousFileDistributor.h"
27 #include "ridFileTester.h"
28 #include "fileDistributor.h"
29 #include "newFomClassesMsg.h"
30 #include "resignRespMsg.h"
31 #include <vector>
32 #include <set>
33 
34 #include "mtl/fedReader13.h"
35 #include "mtl/fedReader1516.h"
36 #include "mtl/fedReader1516e.h"
37 
38 class DtSyncPointMsg;
39 class DtDesignatedFederateMsg;
40 class DtSaveStatusMsg;
41 class DtRestoreStatusMsg;
42 class DtSaveFinishedMsg;
43 class DtSaveInitiateMsg;
44 class DtRestoreReplyMsg;
45 class DtRestoreEndMsg;
46 class DtRestoreInitiateMsg;
47 class DtRestoreMsg;
48 class DtReportFederationsMsg;
49 class DtNameReservedMsg;
50 
51 namespace vrlmod
52 {
53  class DtThreadedObject;
54 }
55 
66 class DT_DLL_LRC DtRtiExecFederateMgr : public DtFederateMgr
67 {
68 public:
69 
71  DtRtiExecFederateMgr(DtRIDParameters* params,
72  DtRtiAmbassadorBaseImplementor* ambImplPtr,
73  DtConnectionMgr* connMgr,
74  DtBoost::shared_ptr<DtRtiAssistantLrcClient> assistantClient);
75 
77  virtual ~DtRtiExecFederateMgr();
78 
79 private:
80 
82  DtRtiExecFederateMgr(DtFederateMgr const& );
83 
85  DtRtiExecFederateMgr& operator= (DtRtiExecFederateMgr const& );
86 
87 public:
88 
91 
92 
94  virtual void createFederationExecution(
95  const char* executionName, const char* timeImplName,
96 #ifdef DtIFSPEC1516E
97  const std::vector<DtString>& fomModules,
98  const char* mimModule);
99 #else
100  const char* fed);
101 #endif
102 
104  virtual void destroyFederationExecution(
105  const char* executionName);
106 
107 #ifdef DtIFSPEC1516E
108  virtual void listFederationExecutions();
110 #endif
111 
113 #ifdef DtIFSPEC1516
114  virtual rti1516::FederateHandle joinFederationExecution (
115  const char* yourName,
116  const char* executionName,
117  rti1516::FederateAmbassador* federateAmbassadorReference,
118  unsigned long flags);
119 #elif defined(DtIFSPEC1516E)
120  virtual rti1516e::FederateHandle joinFederationExecution (
121  const char* federateName,
122  const char* yourName,
123  const char* executionName,
124  const std::vector<DtString>& fomModules,
125  unsigned long flags);
126 #else
127 
128  virtual RTI::FederateHandle joinFederationExecution (
129  const char* yourName,
130  const char* executionName,
131  RTI::FederateAmbassador* federateAmbassadorReference,
132  unsigned long flags);
133 #endif
134 
135 
137 #ifdef DtIFSPEC1516
138  virtual void resignFederationExecution(
139  rti1516::ResignAction theAction);
140 #elif defined(DtIFSPEC1516E)
141  virtual void resignFederationExecution(
142  rti1516e::ResignAction theAction);
143 #else
144  virtual void resignFederationExecution(
145  RTI::ResignAction theAction);
146 #endif
147 
148 
151 
152 
154 #ifdef DtIFSPEC1516
155  virtual void registerFederationSynchronizationPoint(
156  char const * label,
157  rti1516::VariableLengthData const & theTag);
158 #elif defined(DtIFSPEC1516E)
159  virtual void registerFederationSynchronizationPoint(
160  char const * label,
161  rti1516e::VariableLengthData const & theTag);
162 #else
163  virtual void registerFederationSynchronizationPoint(
164  char const * label,
165  char const * theTag);
166 #endif
167 
169 #ifdef DtIFSPEC1516
170  virtual void registerFederationSynchronizationPoint(
171  char const * label,
172  rti1516::VariableLengthData const & theTag,
173  DtFederateHandleSet const & syncSet);
174 #elif defined(DtIFSPEC1516E)
175  virtual void registerFederationSynchronizationPoint(
176  char const * label,
177  rti1516e::VariableLengthData const & theTag,
178  DtFederateHandleSet const & syncSet);
179 #else
180  virtual void registerFederationSynchronizationPoint(
181  char const * label,
182  char const * theTag,
183  DtFederateHandleSet const & syncSet);
184 #endif
185 
186 
188  virtual void synchronizationPointAchieved(char const * label, bool successfully=true);
190 
193 
194 
195 #ifdef DtIFSPEC1516
196  virtual void requestFederationSave (char const * label,
198  rti1516::LogicalTime const * time=NULL);
199 
201  virtual void queryFederationSaveStatus();
202 
204  virtual void queryFederationRestoreStatus();
205 #elif defined(DtIFSPEC1516E)
206  virtual void requestFederationSave (char const * label,
208  rti1516e::LogicalTime const * time=NULL);
209 
211  virtual void queryFederationSaveStatus();
212 
214  virtual void queryFederationRestoreStatus();
215 
217  virtual void abortFederationSave();
218 
220  virtual void abortFederationRestore();
221 #else
222 
224  virtual void requestFederationSave (char const * label,
225  RTI::FedTime const * time=NULL);
226 #endif
227 
229  virtual void federateSaveBegun ();
230 
232  virtual void federateSaveComplete ();
233 
235  virtual void federateSaveNotComplete ();
236 
238  virtual void requestFederationRestore ( const char *label);
239 
241  virtual void federateRestoreComplete ();
242 
244  virtual void federateRestoreNotComplete ();
246 
249  DtSynchronousFileDistributor* distributor(const char* executionName);
250 
252 
253  DtSynchronousFileDistributor* joinDistributor();
254  DtSynchronousFileDistributor* joinDistributor() const;
256 
258  virtual void init();
259 
260 protected:
261 
263  virtual void initRidTester();
264 
266  virtual void waitForCreateResponse( const char* executionName );
267 
269  virtual void waitForJoinResponse( const char* executionName,
270  std::vector<MAKRti::DtString> &joinModules );
271 
273  virtual void waitForResignResponse(bool serviceCall = true);
274 
276  virtual void waitForReserveNameResponse(bool serviceCall = true);
277 
279  void handleFailedJoinResponse(bool timedOutDueToCreation);
280 
282  virtual void initializeTimeFactory();
283 
285  virtual void initializeFOM( const char* executionName );
286 
287 
290  virtual void postJoinInit(
291  const char* yourName,
292  const char* executionName,
293  const char* federateName
294 #ifdef DtIFSPEC1516
295  , rti1516::FederateAmbassador* federateAmbassadorReference);
296 #elif defined(DtIFSPEC1516E)
297  );
298 #else
299  , RTI::FederateAmbassador* federateAmbassadorReference);
300 #endif
301 
304  virtual void postJoinConfirmInit();
305 
307  virtual void handleFailedJoin(unsigned long sourceID,
308  DtJoinConfirmMsg::errorCodes code);
309 
311  virtual void setDesignatedFederate(bool isDesignated);
312  virtual bool isDesignatedFederate();
313 
316  void appendFomModule(std::vector<MAKRti::DtString>& target,
317  MAKRti::DtString const& source);
318 
321  void appendFomModules(std::vector<MAKRti::DtString>& target,
322  std::vector<MAKRti::DtString> const& source);
323 
325  virtual bool findFedFileNameFromMapping( const MAKRti::DtString execName,
326  const std::vector<MAKRti::DtString>& orig,
327  std::vector<MAKRti::DtString>& namesToUse) const;
328 
330  void testReadFomModules(const DtRIDParameters::DtStringList&,
331  MAKRti::DtString executionName, bool isMim = false);
332 
334  virtual void mergeFomModules(const std::vector<MAKRti::DtString>* fomModules);
335 
339 
340 
342  virtual void processSyncPointMsg(const DtSyncPointMsg& msg);
343 
345  virtual void processDesignatedFederateMsg(const DtDesignatedFederateMsg& msg);
346 
348  virtual void processFomModuleFileRequestMsg(const DtFomModuleRequestMsg& msg);
349 
351  virtual void processCreateResponseMsg(const DtCreateResponseMsg& msg);
352 
353 #ifdef DtIFSPEC1516E
354  virtual void processReportFederationsMsg(const DtReportFederationsMsg& msg);
356 #endif
357 
359  virtual void processJoinResponseMsg(const DtJoinResponseMsg& msg);
360 
362  virtual void processDestroyResponseMsg(const DtDestroyResponseMsg& msg);
363 
365  virtual void processSaveInitiate(const DtSaveInitiateMsg& msg);
366 
368  virtual void processSaveInitiate(const char* label);
369 
371  virtual void requestImmediateSave(const char *label);
372 
374  virtual void processSaveResponse(const DtSaveResponseMsg& msg);
375 
377  virtual void processSaveFinished(const DtSaveFinishedMsg& msg);
378 
380  virtual void processRestoreReply(const DtRestoreReplyMsg& msg);
381 
383  virtual void processRestoreEnd(const DtRestoreEndMsg& msg);
384 
386  virtual void processRestoreInitiate(const DtRestoreInitiateMsg& msg);
387 
389  virtual void processRestore(const DtRestoreMsg& msg);
390 
391 #if defined(DtIFSPEC1516) || defined(DtIFSPEC1516E)
392  virtual void processSaveStatusMsg(const DtSaveStatusMsg& msg);
394 
396  virtual void processRestoreStatusMsg(const DtRestoreStatusMsg& msg);
397 #endif
398 
401  virtual void processNewFomClassesMsg(const DtNewFomClassesMsg& msg);
402 
404  virtual void processResignResponseMsg(const DtResignRespMsg& msg);
405 
407  virtual void processRegisterNameMsg(const DtNameReservedMsg& msg);
408 
410 
412  virtual void testSaveProgress();
413 
415  virtual void applyRidParameters();
416 
421  virtual void processNewFomClasses(const DtNewFomClassesMsg& msg);
422 
423 
426 
427 
429  virtual void sendCreateMsg(MAKRti::DtString const & fedExNameVal,
430  MAKRti::DtString const & timeImplName, const std::vector<unsigned int> & moduleCrcs,
431  MAKRti::DtFomType fedType, MAKRti::DtString const &momModuleName,
432  const std::vector<MAKRti::DtString>& fomModules, unsigned int momModuleCrc);
433 
435  virtual void sendDestroyMsg(const char* name);
436 
438  virtual void sendJoinMsg(
439  unsigned long sourceID, unsigned short requestID, const char* fedType,
440  const char* fedExName, const char* fedName,
441  const std::vector<MAKRti::DtString>& fomModules,
442  const unsigned long flags, const std::vector<unsigned int>& joinModulesCrcs);
443 
445  virtual void sendJoinConfirmMsg(
446  unsigned long sourceID, DtJoinConfirmMsg::errorCodes errorCode);
447 
448 #ifdef DtIFSPEC1516
449  virtual void sendSyncPointMsg(DtSyncMsgType kind, DtFederateHandle& id,
451  char const * name,
452  rti1516::VariableLengthData const* tag = NULL,
453  DtFederateHandleSet const * set = NULL);
454 #ifdef DtTIME
455 
457  virtual void sendSaveRequestTsoMsg(char const * label,
458  rti1516::LogicalTime const * time);
459 #endif
460 #elif defined(DtIFSPEC1516E)
461  virtual void sendSyncPointMsg(DtSyncMsgType kind, DtFederateHandle& id,
463  char const * name,
464  rti1516e::VariableLengthData const* tag = NULL,
465  DtFederateHandleSet const * set = NULL);
466 #ifdef DtTIME
467 
469  virtual void sendSaveRequestTsoMsg(char const * label,
470  rti1516e::LogicalTime const * time);
471 #endif
472 #else
473  virtual void sendSyncPointMsg(DtSyncMsgType kind, DtFederateHandle& id,
475  char const * name,
476  char const * tag = NULL,
477  DtFederateHandleSet const * set = NULL);
478 #ifdef DtTIME
479  virtual void sendSaveRequestTsoMsg(char const * label,
481  RTI::FedTime const * time);
482 #endif
483 #endif
484 
486  virtual void sendSaveRequestMsg(unsigned long requestID, const char *label);
487 
489  virtual void sendSaveBegunMsg();
490 
492  virtual void sendSaveCompleteMsg(const char *label, bool success);
493 
495  virtual void sendRestoreRequestMsg(const char *label);
496 
498  virtual void sendRestoreBegunMsg(const char *label, DtResponseFlag response);
499 
501  virtual void sendRestoreCompleteMsg(const char *label, bool success);
503 
506 
507 
510  virtual void initiateSave();
511 
514 #ifdef DtIFSPEC1516
515  virtual void initiateTimedSave(rti1516::LogicalTime const& saveTime);
516 #elif defined(DtIFSPEC1516E)
517  virtual void initiateTimedSave(rti1516e::LogicalTime const& saveTime);
518 #else
519  virtual void initiateTimedSave(RTI::FedTime const& saveTime);
520 #endif
521 
524  virtual bool saveLRC(DtRtiSaveFile& saveFile);
525 
527  virtual bool save(DtRtiSaveFile& file);
528 
531  virtual void prepareToRestoreLRC();
532 
535  virtual bool restoreLRC(DtRtiSaveFile& saveFile);
536 
538  virtual void prepareToRestore();
539 
541  virtual bool restore( DtRtiSaveFile& file );
543 
545  virtual void posttick();
546 
547 public:
548 
551 
552 
554  static void processSyncPointMsg(const DtSyncPointMsg& msg, void* usr);
555 
557  static void processDesignatedFederateMsg(const DtDesignatedFederateMsg& msg, void* usr);
558 
560  static void processFomModuleFileRequestMsg( const DtFomModuleRequestMsg& msg, void* usr);
561 
563  static void processCreateResponseMsg(const DtCreateResponseMsg& msg, void* usr);
564 
565 #ifdef DtIFSPEC1516E
566  static void processReportFederationsMsg(const DtReportFederationsMsg& msg, void* usr);
568 #endif
569 
571  static void processJoinResponseMsg(const DtJoinResponseMsg& msg, void* usr);
572 
574  static void processDestroyResponseMsg(const DtDestroyResponseMsg& msg, void* usr);
575 
576 #if defined(DtIFSPEC1516) || defined(DtIFSPEC1516E)
577  static void processSaveStatusMsg(const DtSaveStatusMsg& msg, void* usr);
579 
581  static void processRestoreStatusMsg(const DtRestoreStatusMsg& msg, void* usr);
582 #endif
583 
586  static void processNewFomClassesMsg(const DtNewFomClassesMsg& msg, void* usr);
587 
589  static void processResignResponseMsg(const DtResignRespMsg& msg, void* usr);
590 
592  static void processRegisterNameMsg(const DtNameReservedMsg& msg, void* usr);
593 
595 
596 
598  static DtFederateMgr* create(DtRIDParameters* params,
599  DtRtiAmbassadorBaseImplementor* ambImplPtr,
600  DtConnectionMgr* connMgr,
601  DtBoost::shared_ptr<DtRtiAssistantLrcClient> assistantClient);
602 
603 protected:
604 
606  std::map<DtString, DtSynchronousFileDistributor*> myDistributors;
607 
609  DtSynchronousFileDistributor* myJoinDistributor;
610 
612  DtCreateResponseFlag myCreateResponse;
613 
615  DtResignResponse myResignResponse;
616 
618  bool myResignResponseNotReceived;
619 
622  unsigned myRegisterNameResponse;
623 
625  MAKRti:: DtString myCreateResponseErrorString;
626 
628  DtDestroyResponseFlag myDestroyResponse;
629 
631  DtJoinResponseMsg* myJoinResponse;
632 
634  DtJoinConfirmMsg::errorCodes myJoinConfirmResponse;
635 
637  MAKRti::DtString myDestroyExecutionName;
638 
640  std::map<DtString, bool> myFedFileRequests;
641 
643  std::vector<MAKRti::DtString> myFomModuleRequests;
644 
646  unsigned short myJoinRequestID;
647 
649  unsigned long mySaveRequestID;
650 
652  DtSaveResponseFlag mySaveResponse;
653 
658  std::set<DtString> mySyncPoints;
659 
661 #if defined(DtIFSPEC1516) || defined(DtIFSPEC1516E)
662  std::wstring* myFailedSyncPointLabel;
663 #else
664  std::string* myFailedSyncPointLabel;
665 #endif
666 
670  DtFederateHandle myOldFedHandle;
671 
674  bool myIsDesignatedFederate;
675 
676 
678  vrlmod::DtThreadedObject* myDistributorThread;
679  bool myAsynchronousDistributor;
680 
683  std::map<MAKRti::DtString, DtFileInformation*> myTakenFiles;
684 
686  std::list<DtNewFomClassesMsg*> myNewFomClassMsgs;
687 
688  void populateWithUnknownFoms(std::vector<DtString> & mods, std::vector<DtString> & requestedMods);
689  bool isFomAvailable(const DtString & fomName);
690  void getCrcsOfFoms( std::vector<unsigned int> & moduleCrcs, const std::vector<MAKRti::DtString> & creationFomModuleNames );
691  bool myFullFedFileDistribution;
692  MAKRti::DtString myHostname;
693 
694 };
695 
696 #endif
697 
698 
699 
DtRtiExecFederateMgr::mySaveRequestID
unsigned long mySaveRequestID
Save request ID.
Definition: execFedMgr.h:649
DtFederateMgr::initiateTimedSave
virtual void initiateTimedSave(RTI::FedTime const &saveTime)
Save is initiated possibly after waiting to enter time advancing state.
DtRtiAmbassadorBaseImplementor
This class is a base for the protocol specific DtRtiAmbassadorImplementor class.
Definition: ambImpBase.h:49
DtSaveFinishedMsg
Definition: savFinMsg.h:32
DtRtiExecFederateMgr::myOldFedHandle
DtFederateHandle myOldFedHandle
during a restore the fedhandle changes.
Definition: execFedMgr.h:670
DtFederateMgr::createFederationExecution
virtual void createFederationExecution(const char *executionName, const char *timeImplName, const char *fed)=0
Process the create federation execution service.
DtRtiExecFederateMgr::myResignResponse
DtResignResponse myResignResponse
Status of resign federation.
Definition: execFedMgr.h:615
DtNewFomClassesMsg
Definition: newFomClassesMsg.h:18
DtJoinResponseMsg
Definition: joinRespMsg.h:27
DtSaveResponseMsg
Definition: savRespMsg.h:29
DtRtiExecFederateMgr::myNewFomClassMsgs
std::list< DtNewFomClassesMsg * > myNewFomClassMsgs
Queue of FOM class messages to be processed after we join.
Definition: execFedMgr.h:686
DtDestroyResponseFlag
DtDestroyResponseFlag
Definition: desRespMsg.h:23
DtFederateMgr::requestFederationSave
virtual void requestFederationSave(const char *label, const RTI::FedTime *time=NULL)=0
Process the requested federation save service.
DtFederateMgr::restore
virtual bool restore(DtRtiSaveFile &file)
Perform the actual restore.
Definition: fedMgr.h:520
DtFederateMgr::processRestoreEnd
virtual void processRestoreEnd(const DtRestoreEndMsg &msg)
Process restore end message.
DtFederateMgr::synchronizationPointAchieved
virtual void synchronizationPointAchieved(const char *label, bool successfully=true)=0
Process the synchronization point achieved service.
DtRIDParameters
This class manages the RTI&#39;s start-up configuration using both MTL variables and functions.
Definition: RIDparams.h:87
DtFederateMgr::requestFederationRestore
virtual void requestFederationRestore(const char *label)=0
Process the request federation restore service.
DtRtiExecFederateMgr::mySaveResponse
DtSaveResponseFlag mySaveResponse
Save response status.
Definition: execFedMgr.h:652
rti1516e::LogicalTime
Definition: LogicalTime.h:35
DtRtiExecFederateMgr::myRegisterNameResponse
unsigned myRegisterNameResponse
Status of registerName 0 = no response, 1 = success, 2 = failure.
Definition: execFedMgr.h:622
DtNameReservedMsg
Definition: nameReservedMsg.h:25
DtRtiExecFederateMgr::myIsDesignatedFederate
bool myIsDesignatedFederate
This federate LRC is designated for handling some federation wide tasks (e.g., MOM Federation attribu...
Definition: execFedMgr.h:674
DtFederateMgr::processSaveFinished
virtual void processSaveFinished(const DtSaveFinishedMsg &msg)
Process save finished message.
DtFederateMgr::joinFederationExecution
virtual RTI::FederateHandle joinFederationExecution(const char *yourName, const char *executionName, RTI::FederateAmbassador *federateAmbassadorReference, unsigned long flags)=0
Process the join federation execution service.
DtRtiExecFederateMgr::myFailedSyncPointLabel
std::string * myFailedSyncPointLabel
Failed sync point request.
Definition: execFedMgr.h:664
DtSaveResponseFlag
DtSaveResponseFlag
Definition: savRespMsg.h:22
DtRtiExecFederateMgr::myDistributorThread
vrlmod::DtThreadedObject * myDistributorThread
Should we use local or distributed fed file?
Definition: execFedMgr.h:678
DtFederateMgr::waitForResignResponse
virtual void waitForResignResponse(bool serviceCall=true)
Wait for Resign Response.
DtFederateMgr::init
virtual void init()
Virtual initialization within create.
DtFederateHandleSet
Definition: fedHandleSet.h:102
DtFederateMgr::processRestore
virtual void processRestore(const DtRestoreMsg &msg)
Process restore message.
DtRtiExecFederateMgr::myFullFedFileDistribution
bool myFullFedFileDistribution
Definition: execFedMgr.h:691
DtFederateMgr::federateSaveNotComplete
virtual void federateSaveNotComplete()=0
Process the federate save not complete service.
DtFederateMgr::federateSaveComplete
virtual void federateSaveComplete()=0
Process the federate save complete service.
DtRtiExecFederateMgr::myCreateResponseErrorString
MAKRti::DtString myCreateResponseErrorString
Error String of create federation.
Definition: execFedMgr.h:625
DtRtiExecFederateMgr::myAsynchronousDistributor
bool myAsynchronousDistributor
Definition: execFedMgr.h:679
DtFederateMgr::create
static DtFederateMgr * create(DtRIDParameters *params, DtRtiAmbassadorBaseImplementor *ambImplPtr, DtConnectionMgr *connMgr, DtBoost::shared_ptr< DtRtiAssistantLrcClient > assistantClient)
A Federate Manager instance is created, initialized, and its pointer is returned. ...
DtFomModuleRequestMsg
Sent by Federates to request fed file from RtiExec.
Definition: fomModuleRequestMsg.h:28
DtRtiExecFederateMgr::myTakenFiles
std::map< MAKRti::DtString, DtFileInformation * > myTakenFiles
When files are received from distributor, store them here until requester takes them.
Definition: execFedMgr.h:683
DtResignRespMsg
Definition: resignRespMsg.h:20
rti1516e::VariableLengthData
Definition: VariableLengthData.h:34
DtFederateMgr::testSaveProgress
virtual void testSaveProgress()=0
Perform exception tests on save/restore state.
DtRtiExecFederateMgr
Instances of DtRtiExecFederateMgr process federation-level messages (such as create, destroy, join, resign, and sync points) for HLA applications that are using the rtiexec.
Definition: execFedMgr.h:66
rti1516e::ResignAction
ResignAction
Definition: Enums.h:33
DtFederateMgr
Instances of DtFederateMgr process federation-level messages (such as create, destroy, join, resign, and sync points) and manages the objects responsible for handling general communication, objects, interactions, the FOM, MOM, and data distribution mmg.
Definition: fedMgr.h:88
DtRtiExecFederateMgr::myDistributors
std::map< DtString, DtSynchronousFileDistributor * > myDistributors
federate Fed File Distributors.
Definition: execFedMgr.h:606
DtFederateMgr::federateSaveBegun
virtual void federateSaveBegun()=0
Process the federate save begun service.
DtCreateResponseMsg
Definition: creRespMsg.h:35
DtConnectionMgr
Instances of DtConnectionMgr manage the communication objects that the RTI will use to either communi...
Definition: connectMgr.h:60
DtFederateHandle
DtHandle DtFederateHandle
Definition: internalTypes.h:29
DtSyncPointMsg
Definition: syncPointMsg.h:46
DtRestoreEndMsg
Definition: resEndMsg.h:31
DtRtiExecFederateMgr::myJoinDistributor
DtSynchronousFileDistributor * myJoinDistributor
The Fed File Distributor of the joined federation execution.
Definition: execFedMgr.h:609
DtFederateMgr::processRestoreReply
virtual void processRestoreReply(const DtRestoreReplyMsg &msg)
Process restore reply message.
DtCreateResponseFlag
DtCreateResponseFlag
Definition: creRespMsg.h:23
DtSynchronousFileDistributor
Distributes fomModule files from initiating federate to RtiExec and then from RtiExec to all joining ...
Definition: synchronousFileDistributor.h:27
DtFederateMgr::processSaveResponse
virtual void processSaveResponse(const DtSaveResponseMsg &msg)
Process save resonse message.
DtReportFederationsMsg
Definition: reportFederationsMsg.h:26
DtRestoreMsg
Definition: restoreMsg.h:23
DtFederateMgr::federateRestoreComplete
virtual void federateRestoreComplete()=0
Process the federate restore complete service.
DtFederateMgr::processSaveInitiate
virtual void processSaveInitiate(const DtSaveInitiateMsg &msg)
Process save initiate message.
DtFederateMgr::resignFederationExecution
virtual void resignFederationExecution(RTI::ResignAction theAction)
Process the resign federation execution service.
DtRtiExecFederateMgr::mySyncPoints
std::set< DtString > mySyncPoints
MAKRti::DtHashList of DtStringHashKeys representing synch point names that have been announced to us...
Definition: execFedMgr.h:658
DtFederateMgr::operator=
DtFederateMgr & operator=(DtFederateMgr const &)
Assignment not implemented – Assignment Not Allowed!
DtRestoreReplyMsg
Definition: resRepMsg.h:24
DtFederateMgr::waitForReserveNameResponse
virtual void waitForReserveNameResponse(bool serviceCall=true)
Wait for Resign Response.
DtRtiExecFederateMgr::myHostname
MAKRti::DtString myHostname
Definition: execFedMgr.h:692
DtDestroyResponseMsg
Definition: desRespMsg.h:31
DtRtiExecFederateMgr::myDestroyResponse
DtDestroyResponseFlag myDestroyResponse
Status of destroy federation.
Definition: execFedMgr.h:628
DtRtiExecFederateMgr::myResignResponseNotReceived
bool myResignResponseNotReceived
Status of resign federation received.
Definition: execFedMgr.h:618
DtFederateMgr::save
virtual bool save(DtRtiSaveFile &file)
Perform the actual save.
Definition: fedMgr.h:517
DT_DLL_LRC
#define DT_DLL_LRC
Definition: rtiMsConfig.h:126
DtFederateMgr::destroyFederationExecution
virtual void destroyFederationExecution(const char *executionName)=0
Process the destroy federation execution service.
DtRtiExecFederateMgr::myJoinConfirmResponse
DtJoinConfirmMsg::errorCodes myJoinConfirmResponse
Status of join confirm.
Definition: execFedMgr.h:634
DtRtiSaveFile
Definition: saveFile.h:21
DtFederateMgr::postJoinInit
virtual void postJoinInit(const char *federateType, const char *executionName, const char *federateName, RTI::FederateAmbassador *federateAmbassadorReference)
Uses the given information to initialize federate data.
DtRtiExecFederateMgr::myCreateResponse
DtCreateResponseFlag myCreateResponse
Status of create federation.
Definition: execFedMgr.h:612
DtRtiExecFederateMgr::myJoinResponse
DtJoinResponseMsg * myJoinResponse
Copy of join response.
Definition: execFedMgr.h:631
DtRtiExecFederateMgr::myJoinRequestID
unsigned short myJoinRequestID
Join request ID.
Definition: execFedMgr.h:646
DtFederateMgr::applyRidParameters
virtual void applyRidParameters()
Apply RID parameters.
DtFederateMgr::federateRestoreNotComplete
virtual void federateRestoreNotComplete()=0
Process the federate restore not complete service.
DtJoinConfirmMsg::errorCodes
errorCodes
error codes for the errorValue flag
Definition: joinConfMsg.h:29
DtFederateMgr::initiateSave
virtual void initiateSave()
Perform the actual save possibly after waiting to enter time advancing state.
DtSyncMsgType
DtSyncMsgType
Definition: syncPointMsg.h:25
DtFederateMgr::registerFederationSynchronizationPoint
virtual void registerFederationSynchronizationPoint(const char *label, const char *theTag)=0
Process the register federation synchronization point service.
DtRtiExecFederateMgr::myDestroyExecutionName
MAKRti::DtString myDestroyExecutionName
Name of federation to destroy.
Definition: execFedMgr.h:637
DtRtiExecFederateMgr::myFomModuleRequests
std::vector< MAKRti::DtString > myFomModuleRequests
Queue of modules requested.
Definition: execFedMgr.h:643
DtSaveInitiateMsg
Definition: savInitMsg.h:23
DtRestoreInitiateMsg
Definition: resInitMsg.h:22
DtFederateMgr::posttick
virtual void posttick()
DtRtiExecFederateMgr::myFedFileRequests
std::map< DtString, bool > myFedFileRequests
Status of fed file request.
Definition: execFedMgr.h:640
DtDesignatedFederateMsg
Definition: desgFedMsg.h:22
DtFederateMgr::processRestoreInitiate
virtual void processRestoreInitiate(const DtRestoreInitiateMsg &msg)
Process restore initiate message.
DtFederateMgr::postJoinConfirmInit
virtual void postJoinConfirmInit()
DtRIDParameters::DtStringList
std::vector< MAKRti::DtString > DtStringList
Definition: RIDparams.h:92
fedMgr.h
This file contains the declaration of the base federation manager.
DtResignResponse
DtResignResponse
Definition: resignRespMsg.h:12
DtResponseFlag
DtResponseFlag
Definition: resBegMsg.h:22
vrlmod::DtThreadedObject
Definition: vlThreadedObject.h:45
Document ID: Generated on Thu May 11 15:55:32 EDT 2023 from SVN revision 254743
Copyright © 2005-2020 MAK Technologies Inc. All Rights Reserved (www.mak.com)