MAK RTIspy API Documentation for HLA 1.3
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Groups Pages
fedMgr.h
Go to the documentation of this file.
1 /*******************************************************************************
2 ** Copyright (c) 1998 MaK Technologies, Inc.
3 ** All rights reserved.
4 *******************************************************************************/
5 /*******************************************************************************
6 ** $RCSfile: fedMgr.h,v $ $Revision: 1.96 $ $State: Exp $
7 *******************************************************************************/
8 
9 #ifndef fedMgr_H_
10 #define fedMgr_H_
11 
14 
15 #include <mtl/fedReader.h>
16 #include <vlutil/vlPrint.h>
17 #include <vlutil/vlTime.h>
18 #include <vlutil/vlString.h>
19 #include <vlutil/vlList.h>
20 #include <vlutil/vlSmartPointers.h>
21 #include <list>
22 #include "resignMsg.h"
23 #include "resignDirectiveMsg.h"
24 #include "RIDparams.h"
25 #include <mtl/fomSorter.h>
26 
27 #if defined(DtIFSPEC1516) || defined(DtIFSPEC1516E)
28 #include "RTI/RTIambassador.h"
29 #include "RTI/LogicalTimeFactory.h"
30 #include "RTI/Enums.h"
31 #else
32 #ifdef DtIFSPEC13DLC
33 #include "RTI13.h"
34 #define RTI rti13
35 #else
36 #include "RTI.hh"
37 #endif
38 #endif
39 
40 class DtRtiSaveFile;
41 class DtFomClassMgr;
42 class DtRIDParameters;
43 class DtObjectMgr;
44 class DtInteractionMgr;
45 class DtTimeMgr;
46 class DtDataDistMgr;
47 class DtMomMgr;
48 class DtFederateHandleSet;
49 class DtLogicalTimeFactory;
50 class DtResignMsg;
51 class DtSaveInitiateMsg;
52 class DtSaveResponseMsg;
53 class DtSaveFinishedMsg;
54 class DtRestoreReplyMsg;
55 class DtRestoreInitiateMsg;
56 class DtRestoreEndMsg;
57 class DtRestoreMsg;
58 class DtFederateMgr;
59 class DtFedAmbWrapper;
60 class DtRtiAssistantLrcClient;
61 class DtAssistantExitMsg;
62 class DtAssistantLogEnableMsg;
63 class DtRtiAmbassadorBaseImplementor;
64 class DtTestManager;
65 class DtTestMgrFedAmbWrapper;
66 class DtEnableDisableNetworkTestingMsg;
67 class DtLatencyReportMsg;
68 class DtTestMgrStatusMsg;
69 class DtAssistantFederateSignalTickIntervalMsg;
70 class DtAssistantRidParamsMsg;
71 
83 
84 class DT_DLL_LRC DtFederateMgr
85 {
86 public:
88  typedef DtFederateMgr* (*DtFederateMgrCreator)(
89  DtRIDParameters* ridParams,
90  DtRtiAmbassadorBaseImplementor* ambImplPtr,
91  DtConnectionMgr* connMgr,
92  DtBoost::shared_ptr<DtRtiAssistantLrcClient> assistantClient);
93 
94  // Callback for PostTick
95  typedef void (*DtFedMgrPostTickCallbackFcn) (void*);
96  typedef std::pair<DtFedMgrPostTickCallbackFcn, void*> DtFedMgrPostTickCallbackInfo;
97  typedef std::map< MAKRti::DtString, DtFedMgrPostTickCallbackInfo > DtPostTickCallbackMap;
98  typedef std::map< MAKRti::DtString, DtFomClassMgr* > DtParsedFomsMap;
99  typedef std::map< DtString, int > DtFomToComplexMap;
100  typedef std::map< DtString, DtString > DtFomNameToFileNameMap;
101  typedef std::map< DtString, DtString > DtFileNameToFomNameMap;
102  typedef std::multimap< int, DtString > DtComplexToFomsMMap;
103 
104 protected:
105 
107  DtFederateMgr(
108  DtRIDParameters* params,
109  DtRtiAmbassadorBaseImplementor* ambImplPtr,
110  DtConnectionMgr* connMgr,
111  DtBoost::shared_ptr<DtRtiAssistantLrcClient> assistantClient);
112 
113 public:
114 
116  virtual ~DtFederateMgr();
117 
118 private:
119 
121  DtFederateMgr(DtFederateMgr const& );
122 
124  DtFederateMgr& operator= (DtFederateMgr const& );
125 
126 public:
127 
129  virtual void createFederationExecution(
130  const char* executionName, const char* timeImplName,
131 #ifdef DtIFSPEC1516E
132  const std::vector<DtString>& fomModules,
133  const char* mimModule) = 0;
134 #else
135  const char* fed) = 0;
136 #endif
137 
139  virtual void destroyFederationExecution (
140  const char* executionName) = 0;
141 
142 #ifdef DtIFSPEC1516E
143 
144  virtual void listFederationExecutions() = 0;
145 #endif
146 
148 #ifdef DtIFSPEC1516
149  virtual rti1516::FederateHandle joinFederationExecution(
150  const char* federateType,
151  const char* federationExecutionName,
152  rti1516::FederateAmbassador* federateAmbassador,
153  unsigned long flags) = 0;
154 #elif defined(DtIFSPEC1516E)
155  virtual rti1516e::FederateHandle joinFederationExecution(
156  const char* federateName,
157  const char* federateType,
158  const char* federationExecutionName,
159  const std::vector<DtString>& fomModules,
160  unsigned long flags) = 0;
161 #else
162  virtual RTI::FederateHandle joinFederationExecution (
163  const char* yourName,
164  const char* executionName,
165  RTI::FederateAmbassador* federateAmbassadorReference,
166  unsigned long flags) = 0;
167 #endif
168 
170 #ifdef DtIFSPEC1516
171  virtual void resignFederationExecution(
172  rti1516::ResignAction theAction);
173 #elif defined(DtIFSPEC1516E)
174  virtual void resignFederationExecution(
175  rti1516e::ResignAction theAction);
176 #else
177  virtual void resignFederationExecution(
178  RTI::ResignAction theAction);
179 #endif
180 
183  virtual bool automaticReserveObjectName(const char *);
184 
186 #ifdef DtIFSPEC1516
187  virtual void registerFederationSynchronizationPoint(
188  const char* label,
189  rti1516::VariableLengthData const & theTag) = 0;
190 #elif defined(DtIFSPEC1516E)
191  virtual void registerFederationSynchronizationPoint(
192  const char* label,
193  rti1516e::VariableLengthData const & theTag) = 0;
194 #else
195  virtual void registerFederationSynchronizationPoint(
196  const char* label,
197  const char* theTag) = 0;
198 #endif
199 
201  virtual void waitForResignResponse(bool serviceCall = true);
202 
204  virtual void waitForReserveNameResponse(bool serviceCall = true);
205 
207 #ifdef DtIFSPEC1516
208  virtual void registerFederationSynchronizationPoint(
209  const char* label,
210  rti1516::VariableLengthData const & theTag,
211  DtFederateHandleSet const& syncSet) = 0;
212 #elif defined(DtIFSPEC1516E)
213  virtual void registerFederationSynchronizationPoint(
214  const char* label,
215  rti1516e::VariableLengthData const & theTag,
216  DtFederateHandleSet const& syncSet) = 0;
217 #else
218  virtual void registerFederationSynchronizationPoint(
219  const char* label,
220  const char* theTag,
221  DtFederateHandleSet const& syncSet) = 0;
222 #endif
223 
225  virtual void synchronizationPointAchieved(const char* label, bool successfully=true) = 0;
226 
230  virtual MAKRti::DtString fedFileName(MAKRti::DtString execName);
231 
235  virtual MAKRti::DtString timeImplName(MAKRti::DtString execName);
236 
238  virtual void init();
239 
241 
242 #ifdef DtIFSPEC1516
243  virtual void setTopLevelAmbassador(rti1516::RTIambassador* ambPtr);
244 #elif defined(DtIFSPEC1516E)
245  virtual void setTopLevelAmbassador(rti1516e::RTIambassador* ambPtr,
246  rti1516e::FederateAmbassador* federateAmbassador);
247 #else
248  virtual void setTopLevelAmbassador(RTI::RTIambassador* ambPtr);
249 #endif
250 
251 
253  virtual bool tick();
254  virtual void pretick();
255  virtual void posttick();
256 
257  virtual void postTickCallbacks();
258 
259  virtual void addPostTickCallback(const MAKRti::DtString& label, const DtFedMgrPostTickCallbackInfo& cb);
260  virtual void removePostTickCallback(const MAKRti::DtString& label);
261 
262 #ifdef DtIFSPEC1516
263 
264  virtual void requestFederationSave ( const char *label,
265  const rti1516::LogicalTime* time=NULL) =0;
266 
268  virtual void queryFederationSaveStatus()=0;
269 
271  virtual void queryFederationRestoreStatus()=0;
272 #elif defined(DtIFSPEC1516E)
273 
274  virtual void requestFederationSave ( const char *label,
275  const rti1516e::LogicalTime* time=NULL) =0;
276 
278  virtual void queryFederationSaveStatus()=0;
279 
281  virtual void queryFederationRestoreStatus()=0;
282 
284  virtual void abortFederationSave () =0;
285 
287  virtual void abortFederationRestore () =0;
288 #else
289 
290  virtual void requestFederationSave ( const char *label,
291  const RTI::FedTime* time=NULL) =0;
292 #endif
293 
295  virtual void federateSaveBegun () =0;
296 
298  virtual void federateSaveComplete () =0;
299 
301  virtual void federateSaveNotComplete () =0;
302 
304  virtual void requestFederationRestore ( const char *label) =0;
305 
307  virtual void federateRestoreComplete () =0;
308 
310  virtual void federateRestoreNotComplete () =0;
311 
313  virtual char* getTransportationName(MAKRti::DtTransportType transport);
314 
316  virtual char* getOrderName(MAKRti::DtOrderType order);
317 
319  virtual MAKRti::DtTransportType getTransportationHandle(MAKRti::DtString transport);
320 
322  virtual MAKRti::DtOrderType getOrderHandle(MAKRti::DtString order);
323 
325  virtual DtFederateHandle federateHandle() const;
326 
328  virtual MAKRti::DtString const & fedType() const;
329 
331  virtual MAKRti::DtString const & fedName() const;
332 
334  virtual MAKRti::DtString const & fedExName() const;
335 
337  virtual unsigned long fedExHandle() const;
338 
340  virtual bool isJoined() const;
341 
343 
344 #ifdef DtIFSPEC1516
345  rti1516::RTIambassador* rtiAmb();
346  rti1516::RTIambassador* rtiAmb() const;
347 #elif defined(DtIFSPEC1516E)
348  rti1516e::RTIambassador* rtiAmb();
349  rti1516e::RTIambassador* rtiAmb() const;
350 #else
351  RTI::RTIambassador* rtiAmb();
352  RTI::RTIambassador* rtiAmb() const;
353 #endif
354 
355 
357 
358 #ifdef DtIFSPEC1516
359  virtual rti1516::FederateAmbassador * federateAmbassador() const;
360 #elif defined(DtIFSPEC1516E)
361  virtual rti1516e::FederateAmbassador * federateAmbassador() const;
362 #else
363  virtual RTI::FederateAmbassador * federateAmbassador() const;
364 #endif
365 
366 
368  virtual DtConnectionMgr* connectMgr();
369  virtual DtConnectionMgr* connectMgr() const;
370 
372  virtual DtRIDParameters* params();
373  virtual DtRIDParameters* params() const;
374 
376  virtual DtFomClassMgr* fom();
377  virtual DtFomClassMgr* fom() const;
378 
380  virtual DtInteractionMgr* interMgr();
381  virtual DtInteractionMgr* interMgr() const;
382 
384  virtual DtTestManager* testMgr();
385  virtual DtTestManager* testMgr() const;
386 
388  virtual DtObjectMgr* objMgr();
389  virtual DtObjectMgr* objMgr() const;
390 
391 #ifdef DtTIME
392 
393  virtual DtTimeMgr* timeMgr();
394  virtual DtTimeMgr* timeMgr() const;
395 #endif
396 
398  virtual DtLogicalTimeFactory* timeFactory();
399  virtual DtLogicalTimeFactory* timeFactory() const;
400 
401 #ifdef DtMOM
402 
403  virtual DtMomMgr* momMgr();
404  virtual DtMomMgr* momMgr() const;
405 #endif
406 
407 #ifdef DDM
408 
409  virtual DtDataDistMgr* ddmMgr();
410  virtual DtDataDistMgr* ddmMgr() const;
411 #endif
412 
414  virtual DtRtiAssistantLrcClient* assistantClient();
415  virtual DtRtiAssistantLrcClient* assistantClient() const;
416 
418  virtual bool isJoinedFederate(DtFederateHandle federateHandleValue) const;
419 
421  virtual bool forcedToResign() const;
422 
424  virtual void setMomResign();
425 
427  virtual void resetMomResign();
428 
430  virtual bool saveInitiated() const;
431 
433  virtual bool saveBegun() const;
434 
436  virtual bool restoreRequested() const;
437 
439  virtual bool restoreInitiated() const;
440 
442  virtual bool restoreBegun() const;
443 
445  virtual const MAKRti::DtString& restoreLabel() const;
446 
448  virtual const MAKRti::DtString& lastRestoreLabel() const;
449 
451  const MAKRti::DtString& currentFedFileName() const;
452  void setCurrentFedFileName( const MAKRti::DtString& );
453 
455  const MAKRti::DtString& mimName() const;
456  void setMimName( const MAKRti::DtString& );
457 
458 #ifdef DtIFSPEC1516E
459 
460  void addFomModule( const MAKRti::DtString& name, char* buffer );
461 
463  const std::vector<std::wstring>& fomModuleNames() const;
464 
466  void addJoinFomModuleNames(const std::vector<MAKRti::DtString>& moduleNames);
467  const std::vector<std::wstring>& joinFomModuleNames() const;
468 
471  const char* fomModuleData(MAKRti::DtU32 moduleIndicator) const;
472 
475  const char* joinFomModuleData(MAKRti::DtU32 moduleIndicator) const;
476 
478  const char* mimData() const;
479 #endif
480 
482  const MAKRti::DtString& currentTimeImplName() const;
483  void setCurrentTimeImplName( const MAKRti::DtString& );
484 
486  virtual const MAKRti::DtString& saveLabel() const;
487  virtual void setSaveLabel(const MAKRti::DtString& value);
488 
490  virtual const MAKRti::DtString& lastSaveLabel() const;
491  virtual void setLastSaveLabel(const MAKRti::DtString& value);
492 
493 
495  virtual void testSaveProgress() = 0;
496 
499  virtual void initiateSave();
500 
503 #ifdef DtIFSPEC1516
504  virtual void initiateTimedSave(rti1516::LogicalTime const& saveTime);
505 #elif defined(DtIFSPEC1516E)
506  virtual void initiateTimedSave(rti1516e::LogicalTime const& saveTime);
507 #else
508  virtual void initiateTimedSave(RTI::FedTime const& saveTime);
509 #endif
510 
512  virtual bool save( DtRtiSaveFile& file ){ return true;};
513 
515  virtual bool restore( DtRtiSaveFile& file ){ return true;};
516 
522  virtual MAKRti::DtString& getSaveFileName(const char* label,
523  DtFederateHandle fedHandle, MAKRti::DtString& fileName,
524  bool extendName=true);
525 
531  virtual MAKRti::DtString& getRestoreFileName(const char* label,
532  DtFederateHandle fedHandle, MAKRti::DtString& fileName);
533 
535  virtual unsigned long tickCount() const;
536 
538  virtual bool isTicking() const;
539 
541  virtual void reportLatencyTestResults( const DtLatencyReportMsg& msg );
542 
544  virtual void reportLatencyTestStatus( const DtTestMgrStatusMsg& msg );
545 
546  unsigned long flags() const;
547 
548  DtResignAction automaticResignDirective() const;
549 
550 #ifdef DtIFSPEC1516E
551  virtual rti1516e::ResignAction getAutomaticResignDirective() const;
552 
555  virtual void setAutomaticResignDirective( const rti1516e::ResignAction action );
556 #endif
557 
559  virtual const MAKRti::DtString& getFederateNameFromHandle( DtFederateHandle handle );
560  virtual DtFederateHandle getFederateHandleFromName( const MAKRti::DtString& name );
561 
562 public:
563 
570  static DtFederateMgr* create(
571  DtRIDParameters* params,
572  DtRtiAmbassadorBaseImplementor* ambImplPtr,
573  DtConnectionMgr* connMgr,
574  DtBoost::shared_ptr<DtRtiAssistantLrcClient> assistantClient);
575 
578  static void setCreatorFunction(DtFederateMgrCreator fn);
579 
584  static void setInternalCreatorFunction(DtFederateMgrCreator fn);
585 
586 protected:
587 
591 
592 
594  virtual void processResign(const DtResignMsg& msg);
595 
597  virtual void processEnableDisableNetworkTesting( const DtEnableDisableNetworkTestingMsg& msg );
598 
600  virtual void processSaveInitiate(const DtSaveInitiateMsg& msg);
601 
603  virtual void processSaveResponse(const DtSaveResponseMsg& msg);
604 
606  virtual void processSaveFinished(const DtSaveFinishedMsg& msg);
607 
609  virtual void processRestoreReply(const DtRestoreReplyMsg& msg);
610 
612  virtual void processRestoreInitiate(const DtRestoreInitiateMsg& msg);
613 
615  virtual void processRestoreEnd(const DtRestoreEndMsg& msg);
616 
618  virtual void processRestore(const DtRestoreMsg& msg);
620 
624 
625 
626  virtual void processAssistantResign(const DtAssistantExitMsg& msg);
627 
629  virtual void processAssistantEnableLogging(const DtAssistantLogEnableMsg& msg);
630 
632  virtual void processSignalTickInterval( const DtAssistantFederateSignalTickIntervalMsg& msg );
633 
635  virtual void processRidParamRequest( const DtAssistantRidParamsMsg& msg );
637 
638 #ifdef DtIFSPEC1516E
639 
640  virtual void processResignDirective( const DtResignDirectiveMsg& msg );
641 #endif
642 
644  virtual void sendAlive();
645 
647  virtual void sendResignMsg(const char* fedExName,
648  DtFederateHandle fedHandle, DtResignAction action);
649 
651  void sendTickedMsg();
652 
654  virtual void applyRidParameters();
655 
660  virtual MAKRti::DtFilename fedFileNameToUse(MAKRti::DtString fileName, MAKRti::DtString executionName );
661 
662  //Add comments to each later
663  virtual int mapFomDepComplexity(DtString fomFileName);
664 
665  virtual void mapFomNameToFileName(std::vector<DtString>* fomFileNames);
666 
667  virtual void sortFomFileNames(std::vector<DtString>* fomFileNames);
668 
670  virtual void testReadFedFile(MAKRti::DtString fileName, MAKRti::DtString executionName);
671 
674  virtual void readFedFile(MAKRti::DtString fileName, MAKRti::DtString executionName);
675 
678  virtual void readFedFilePtr( const FILE* fp,
679  const MAKRti::DtString& fileName,
680  const MAKRti::DtString& executionName );
681 
684  virtual void addFedExNameMapping(const MAKRti::DtString& execName,
685  const MAKRti::DtString& timeImplName, const MAKRti::DtString& fed);
686 
687  virtual void addFomModuleNameMapping( const MAKRti::DtString executionName,
688  const std::vector<MAKRti::DtString>& modules);
689 
690  virtual void addFomModuleNameMapping( const MAKRti::DtString executionName,
691  const MAKRti::DtString& modules );
692 
694 #ifdef DtIFSPEC1516
695  virtual DtResignAction testResign(rti1516::ResignAction theAction);
696 #elif defined(DtIFSPEC1516E)
697  virtual DtResignAction testResign(rti1516e::ResignAction theAction);
698 #else
699  virtual DtResignAction testResign(RTI::ResignAction theAction);
700 #endif
701 
704  virtual void postJoinInit(
705  const char* federateType,
706  const char* executionName,
707  const char* federateName
708 #ifdef DtIFSPEC1516
709  , rti1516::FederateAmbassador* federateAmbassadorReference);
710 #elif defined(DtIFSPEC1516E)
711  );
712 #else
713  , RTI::FederateAmbassador* federateAmbassadorReference);
714 #endif
715 
716  virtual void postJoinConfirmInit();
717 
718 protected:
719 
723 
724 
726  static void processResign(const DtResignMsg& msg, void* usr);
727 
729  static void processEnableDisableNetworkTesting(const DtEnableDisableNetworkTestingMsg& msg, void* usr );
730 
732  static void processSaveInitiate(const DtSaveInitiateMsg& msg, void* usr);
733 
735  static void processSaveResponse(const DtSaveResponseMsg& msg, void* usr);
736 
738  static void processSaveFinished(const DtSaveFinishedMsg& msg, void* usr);
739 
741  static void processRestoreReply(const DtRestoreReplyMsg& msg, void* usr);
742 
744  static void processRestore(const DtRestoreMsg& msg, void* usr);
745 
747  static void processRestoreInitiate(const DtRestoreInitiateMsg& msg,
748  void* usr);
749 
751  static void processRestoreEnd(const DtRestoreEndMsg& msg, void* usr);
753 
754 
758 
759 
760  static void processAssistantResign(const DtAssistantExitMsg& msg, void* usr);
761 
763  static void processAssistantEnableLogging(const DtAssistantLogEnableMsg& msg, void* usr);
764 
766  static void processSignalTickInterval( const DtAssistantFederateSignalTickIntervalMsg& msg, void* usr );
767 
769  static void processRidParamRequest( const DtAssistantRidParamsMsg& msg, void* usr );
771 
772 #ifdef DtIFSPEC1516E
773 
774  static void processResignDirective( const DtResignDirectiveMsg& msg, void* usr );
775 #endif
776 
779 
780 
782  virtual void createObjectMgr();
783 
785  virtual void createInteractionMgr();
786 
788  virtual void createDdmMgr();
789 
791  virtual void createTimeMgr();
792 
794  virtual void createMomMgr();
795 
797  virtual void createTestMgr();
798 
800 
801 #ifdef DtIFSPEC1516
802  virtual MAKRti::DtResignAction convertResignAction(rti1516::ResignAction) const;
803  virtual rti1516::ResignAction convertResignAction(MAKRti::DtResignAction) const;
804 #elif defined(DtIFSPEC1516E)
805  virtual MAKRti::DtResignAction convertResignAction(rti1516e::ResignAction) const;
806  virtual rti1516e::ResignAction convertResignAction(MAKRti::DtResignAction) const;
807 #else
808  virtual MAKRti::DtResignAction convertResignAction(RTI::ResignAction) const;
809  virtual RTI::ResignAction convertResignAction(MAKRti::DtResignAction) const;
810 #endif
811 
812 public:
813 
814  //In order to correctly stop evokeCallback we need to know what has reached a
815  //federate Ambassador. So we are puttling this boolean here in order to do that
816  //Accessors should be made once we know this works.
817  bool myFedCallbackReached;
818 
819 protected:
820 
821  DtFedReader * getReader( DtFomType theFomType, DtFomClassMgr* target);
822  DtFedReader * getReader( DtFomType theFomType );
823  void addToParsedFomMap( DtFedReader * myFedReader, const MAKRti::DtString & fileNameToUse, DtFomClassMgr* fedTarget, unsigned long theCrc = 0);
824 
826 #ifdef DtIFSPEC1516
827  rti1516::RTIambassador* myRtiAmb;
828 #elif defined(DtIFSPEC1516E)
829  rti1516e::RTIambassador* myRtiAmb;
830 #else
831  RTI::RTIambassador* myRtiAmb;
832 #endif
833 
835  DtRtiAmbassadorBaseImplementor* myAmbImpl;
836 
839 
840 
842  DtConnectionMgr* myConnectMgr;
843 
845  DtFomClassMgr* myFom;
846 
848  DtInteractionMgr* myInterMgr;
849 
851  DtObjectMgr* myObjMgr;
852 
854  DtMomMgr* myMomMgr;
855 
856 #ifdef DDM
857 
858  DtDataDistMgr* myDdmMgr;
859 #endif
860 #ifdef DtTIME
861 
862  DtTimeMgr* myTimeMgr;
863 #endif
864 
865 
867  MAKRti::DtTime myResponseInterval;
868 
870  MAKRti::DtString myFedExName;
871 
873  unsigned long myFedExHandle;
874 
876  MAKRti::DtString myFedType;
877 
880  MAKRti::DtString myFedName;
881 
883  DtFederateHandle myFedHandle;
884 
886  MAKRti::DtString myCurrentFedFileName;
887 
889  MAKRti::DtString myMimName;
890 
892  MAKRti::DtString myCurrentTimeImplName;
893 
894 #ifdef DtIFSPEC1516E
895 
896  std::vector<std::wstring> myFomModulesNames;
897  std::vector<std::wstring> myJoinFomModulesNames;
898  std::vector<char*> myFomModuleData;
899  unsigned myMimIndex;
900 #endif
901 
903  MAKRti::DtTime myLastHeartbeat;
904 
907  DtLogicalTimeFactory* myLogicalTimeFactory;
908 #if defined(DtIFSPEC1516) || defined(DtIFSPEC1516E)
909 #else
910  RTI::FedTimeFactory myHlaTimeFactory;
911 #endif
912 
914  DtFedAmbWrapper* myPrinter;
915 
917  DtFedAmbWrapper* myFedAmbCatch;
918 
919 
921  DtRIDParameters* myParams;
922 
924  DtFedReader * myFedReader;
925  DtFedReader * myFedReader13;
926  DtFedReader * myFedReader1516;
927  DtFedReader * myFedReader1516e;
928 
932  MAKRti::DtList myMappingList;
933 
934  std::map<MAKRti::DtString, std::set<MAKRti::DtString> > myFedFileNames;
935 
937  DtParsedFomsMap myParsedFoms;
938 
939  // make this FOM dependency, not DtString
940  DtComplexToFomsMMap myComplexToFomsMMap;
941  typedef std::pair<int, DtString> DtMMapPair;
942 
943  DtFomToComplexMap myFomToComplexMap;
944  typedef std::pair<DtString, int> DtFomCompPair;
945 
946  DtFomNameToFileNameMap myFomToFileMap;
947  typedef std::pair<DtString, DtString> DtFomFilePair;
948 
949  DtFileNameToFomNameMap myFileToFomMap;
950  typedef std::pair<DtString, DtString> DtFileFomPair;
951 
953  DtBoost::shared_ptr<DtRtiAssistantLrcClient> myAssistantClient;
954 
957 
958 
960  bool mySaveInitiated;
962  bool mySaveBegun;
964  bool myRestoreRequested;
966  bool myRestoreInitiated;
968  bool myRestoreBegun;
970  MAKRti::DtString mySaveLabel;
972  MAKRti::DtString myLastSaveLabel;
974  MAKRti::DtString myRestoreLabel;
976  MAKRti::DtString myLastRestoreLabel;
978 
980  bool myIgnoreForcedResign;
981 
983  bool myForcedToResign;
984 
986  bool myMomResign;
987 
989  bool myMomSaveEvokeCallbacks;
990 
992  bool myResignInProgress;
993 
995  MAKRti::DtClock myClock;
996 
998  unsigned long myTickCount;
999 
1001  bool myIsTicking;
1002 
1004  bool myEnableFederateHeartbeat;
1005 
1006  unsigned long myFlags;
1007 
1008  DtTestManager* myTestMgr;
1009  bool myNetworkTestEnabled;
1010 
1012  float mySignalTickInterval;
1013 
1015  DtTime myLastTickTime;
1016 
1017  DtPostTickCallbackMap myPostTickCallbacks;
1018 
1019  MAKRti::DtFilename myStandardMimPath;
1020 
1021  // our list of Federate Names to Handles and vise-versa
1022  std::map< MAKRti::DtString, DtFederateHandle > myFederateNameToHandle;
1023  std::map< DtFederateHandle, MAKRti::DtString > myFederateHandleToName;
1024 
1026  MAKRti::DtResignAction myResignAction;
1027 
1028  DtFomSorter myFomSorter;
1029 
1030 protected:
1032  static DtFederateMgrCreator theCreator;
1033 
1035  static DtFederateMgrCreator theInternalCreator;
1036 };
1037 
1038 #endif
1039 
1040 
1041 
Document ID: Generated on Mon Jul 9 10:30:41 EDT 2018 from SVN revision 190224
Copyright © 2005-2018 VT MÄK Inc. All Rights Reserved (www.mak.com)