Instances of DtRtiExecFederateMgr process federation-level messages (such as create, destroy, join, resign, and sync points) for HLA applications that are using the rtiexec. More...

Inheritance diagram for DtRtiExecFederateMgr:

Collaboration diagram for DtRtiExecFederateMgr:

List of all members.

Public Member Functions
	DtRtiExecFederateMgr (DtRIDParameters params, DtRtiAmbassadorBaseImplementor ambImplPtr, DtConnectionMgr *connMgr, DtBoost::shared_ptr< DtRtiAssistantLrcClient > assistantClient)
	Constructor.
virtual	~DtRtiExecFederateMgr ()
	Destructor.
std::map< DtString, DtSynchronousFileDistributor * >	distributors ()
	Access to the file distributor.
std::map< DtString, DtSynchronousFileDistributor * >	distributors () const
DtSynchronousFileDistributor *	joinDistributor ()
DtSynchronousFileDistributor *	joinDistributor () const
virtual void	init ()
	Virtual initialization within create.
CreateDestoryJoinResignServices
Handle the create/destroy and join/resign services
virtual void	createFederationExecution (const char executionName, const char timeImplName, const char *fed)
	Process the create federation execution service.
virtual void	destroyFederationExecution (const char *executionName)
	Process the destroy federation execution service.
virtual RTI::FederateHandle	joinFederationExecution (const char yourName, const char executionName, RTI::FederateAmbassador *federateAmbassadorReference, unsigned long flags)
	Process the join federation execution service.
virtual void	resignFederationExecution (RTI::ResignAction theAction)
	Process the resign federation execution service.
SynchronizationPointServices
Handle the synchronization point services
virtual void	registerFederationSynchronizationPoint (char const label, char const theTag)
	Process the register synchronization point service.
virtual void	registerFederationSynchronizationPoint (char const label, char const theTag, DtFederateHandleSet const &syncSet)
	Process the register synchronization point service.
virtual void	synchronizationPointAchieved (char const *label, bool successfully=true)
	Process the synchronization point achieved service.
SaveRestoreServices
Process the save and restore services
virtual void	requestFederationSave (char const label, RTI::FedTime const time=NULL)
	Process the request federation save service.
virtual void	federateSaveBegun ()
	Process the federate save begun service.
virtual void	federateSaveComplete ()
	Process the federate save complete service.
virtual void	federateSaveNotComplete ()
	Process the federate save complete service.
virtual void	requestFederationRestore (const char *label)
	Process the request federation restore service.
virtual void	federateRestoreComplete ()
	Process the federate restore complete service.
virtual void	federateRestoreNotComplete ()
	Process the federate restore complete service.
Static Public Member Functions
static DtFederateMgr *	create (DtRIDParameters params, DtRtiAmbassadorBaseImplementor ambImplPtr, DtConnectionMgr *connMgr, DtBoost::shared_ptr< DtRtiAssistantLrcClient > assistantClient)
	Creates an instance of this derived class;.
MessageCallbacks
Register these methods for callbacks. Pass this manager as the user data
static void	processSyncPointMsg (const DtSyncPointMsg &msg, void *usr)
	sync point message callback
static void	processDesignatedFederateMsg (const DtDesignatedFederateMsg &msg, void *usr)
	designated federate message callback
static void	processFomModuleFileRequestMsg (const DtFomModuleRequestMsg &msg, void *usr)
	Fom Module file distribution message callback.
static void	processCreateResponseMsg (const DtCreateResponseMsg &msg, void *usr)
	Create response message callback.
static void	processJoinResponseMsg (const DtJoinResponseMsg &msg, void *usr)
	Join response message callback.
static void	processDestroyResponseMsg (const DtDestroyResponseMsg &msg, void *usr)
	Destroy response message callback.
Protected Member Functions
virtual void	initRidTester ()
	Initialize the RidTester.
virtual void	initializeDistributor (const char *executionName)
	This function will create the distributor if necessary and initialize it.
virtual void	waitForJoinResponse (const char *executionName, std::vector< MAKRti::DtString > &joinModules)
	This function will wait for the join response or fail and throw.
void	checkJoinResponse ()
	Check the join response and throw appropriate exception on error.
virtual void	initializeTimeFactory ()
	Initialize the time factory.
virtual void	initializeFOM (const char *executionName)
	Initialize the FOM.
virtual void	postJoinInit (const char yourName, const char executionName, const char federateName, RTI::FederateAmbassador federateAmbassadorReference)
	Uses the given information to initialize federate data.
virtual void	handleFailedJoin (unsigned long sourceID, DtJoinConfirmMsg::errorCodes code)
	Handle the join failure before throwing an exception.
virtual void	setDesignatedFederate (bool isDesignated)
	Set/Get designated status of this federate's LRC.
virtual bool	isDesignatedFederate ()
void	appendFomModule (std::vector< MAKRti::DtString > &target, MAKRti::DtString const &source)
	Append the source FED file name into the target list, stripping the path name as it is appended into the target.
void	appendFomModules (std::vector< MAKRti::DtString > &target, std::vector< MAKRti::DtString > const &source)
	Append the source FED file names into the target list, stripping the path names as they are appended into the target.
virtual bool	findFedFileNameFromMapping (const MAKRti::DtString execName, const std::vector< MAKRti::DtString > &orig, std::vector< MAKRti::DtString > &namesToUse) const
	Find the full FED file path from the stripped name.
void	testReadFomModules (const DtRIDParameters::DtStringList &, MAKRti::DtString executionName, bool isMim=false)
	Attempt to read modules.
virtual void	mergeFomModules (const std::vector< MAKRti::DtString > *fomModules)
	Merge the given FOM Modules into the current FOM.
virtual void	testSaveProgress ()
	Check for save/restore in progress exceptions.
virtual void	applyRidParameters ()
	Apply RID parameters.
virtual void	posttick ()
	Processing after a tick.
DtFedReader *	getReader (DtFomType theFomType)
void	populateWithUnknownFoms (std::vector< DtString > &mods, std::vector< DtString > &requestedMods)
bool	isFomAvailable (const DtString &fomName)
void	getCrcsOfFoms (std::vector< unsigned int > &moduleCrcs, const std::vector< MAKRti::DtString > &creationFomModuleNames)
MAKRti::DtFilename &	getStandardMimPath ()
MessageHandling
Process federation management messages Registered callback call these methods
virtual void	processSyncPointMsg (const DtSyncPointMsg &msg)
	Process a sync point message.
virtual void	processDesignatedFederateMsg (const DtDesignatedFederateMsg &msg)
	Process designated federate message.
virtual void	processFomModuleFileRequestMsg (const DtFomModuleRequestMsg &msg)
	Process Fom Module file distribution message.
virtual void	processCreateResponseMsg (const DtCreateResponseMsg &msg)
	Process create response message.
virtual void	processJoinResponseMsg (const DtJoinResponseMsg &msg)
	Process join response message.
virtual void	processDestroyResponseMsg (const DtDestroyResponseMsg &msg)
	Process destroy response message.
virtual void	processSaveInitiate (const DtSaveInitiateMsg &msg)
	Process the save initiate message.
virtual void	processSaveInitiate (const char *label)
	Process the save initiate.
virtual void	requestImmediateSave (const char *label)
	Process the immediate save message.
virtual void	processSaveResponse (const DtSaveResponseMsg &msg)
	Process the save response message.
virtual void	processSaveFinished (const DtSaveFinishedMsg &msg)
	Process the save finished message.
virtual void	processRestoreReply (const DtRestoreReplyMsg &msg)
	Process the restore reply message.
virtual void	processRestoreEnd (const DtRestoreEndMsg &msg)
	Process the restore end message.
virtual void	processRestoreInitiate (const DtRestoreInitiateMsg &msg)
	Process the restore initiate message.
virtual void	processRestore (const DtRestoreMsg &msg)
	Process the restore message.
SendMessages
Send messages of different types
virtual void	sendCreateMsg (MAKRti::DtString const &fedExNameVal, MAKRti::DtString const &timeImplName, const std::vector< unsigned int > &moduleCrcs, MAKRti::DtFomType fedType, MAKRti::DtString const &momModuleName, const std::vector< MAKRti::DtString > &fomModules, unsigned int momModuleCrc)
	Send create federation message.
virtual void	sendDestroyMsg (const char *name)
	Send destroy federation message.
virtual void	sendJoinMsg (unsigned long sourceID, unsigned short requestID, const char fedType, const char fedExName, const char *fedName, const std::vector< MAKRti::DtString > &fomModules, const unsigned long flags, const std::vector< unsigned int > &joinModulesCrcs)
	Send join federation message.
virtual void	sendJoinConfirmMsg (unsigned long sourceID, DtJoinConfirmMsg::errorCodes errorCode)
	Send join federation confirm message.
virtual void	sendSyncPointMsg (DtSyncMsgType kind, DtFederateHandle &id, char const name, char const tag=NULL, DtFederateHandleSet const *set=NULL)
	Send synchronization point message.
virtual void	sendSaveRequestMsg (unsigned long requestID, const char *label)
	Send save federation request message.
virtual void	sendSaveBegunMsg ()
	Send save federate begun message.
virtual void	sendSaveCompleteMsg (const char *label, bool success)
	Send federate complete message.
virtual void	sendRestoreRequestMsg (const char *label)
	Send restore federation request message.
virtual void	sendRestoreBegunMsg (const char *label, DtResponseFlag response)
	Send restore federate begun message.
virtual void	sendRestoreCompleteMsg (const char *label, bool success)
	Send restore federate complete message.
SaveRestoreHelpers
Helper methods to process save and restore
virtual void	initiateSave ()
	Perform the actual save possibly after waiting to enter time advancing state.
virtual void	initiateTimedSave (RTI::FedTime const &saveTime)
	Perform the actual save possibly after waiting to enter time advancing state.
virtual bool	saveLRC (DtRtiSaveFile &saveFile)
	Save the LRC state information.
virtual bool	save (DtRtiSaveFile &file)
	Save the federation manager state information to the given file.
virtual void	prepareToRestoreLRC ()
	Prepare the state information of the LRC for a restore (may include a back up save in case restore fails).
virtual bool	restoreLRC (DtRtiSaveFile &saveFile)
	Restore the LRC state information Return bool: restore successful?
virtual void	prepareToRestore ()
	Prepare the state information to be restored (i.e., clear out existing data).
virtual bool	restore (DtRtiSaveFile &file)
	Restore the federation manager state information from the given file.
Protected Attributes
std::map< DtString, DtSynchronousFileDistributor * >	myDistributors
	federate Fed File Distributors.
DtSynchronousFileDistributor *	myJoinDistributor
	The Fed File Distributor of the joined federation execution.
DtCreateResponseFlag	myCreateResponse
	Status of create federation.
MAKRti::DtString	myCreateResponseErrorString
	Error String of create federation.
DtDestroyResponseFlag	myDestroyResponse
	Status of destroy federation.
DtJoinResponseMsg *	myJoinResponse
	Copy of join response.
DtJoinConfirmMsg::errorCodes	myJoinConfirmResponse
	Status of join confirm.
MAKRti::DtString	myDestroyExecutionName
	Name of federation to destroy.
bool	myFedFileRequest
	Status of fed file request.
std::vector< MAKRti::DtString >	myFomModuleRequests
	Queue of modules requested.
unsigned short	myJoinRequestID
	Join request ID.
unsigned long	mySaveRequestID
	Save request ID.
DtSaveResponseFlag	mySaveResponse
	Save response status.
MAKRti::DtHashList	mySyncPoints
	MAKRti::DtHashList of DtStringHashKeys representing synch point names that have been announced to us.
std::string *	myFailedSyncPointLabel
	Failed sync point request.
DtFederateHandle	myOldFedHandle
	during a restore the fedhandle changes.
bool	myIsDesignatedFederate
	This federate LRC is designated for handling some federation wide tasks (e.g., MOM Federation attribute ownership)
vrlmod::DtThreadedObject *	myDistributorThread
	Should we use local or distributed fed file?
bool	myAsynchronousDistributor
std::map< MAKRti::DtString, DtFileInformation * >	myTakenFiles
	until requester takes them.
DtFedReader13 *	myFedReader13
DtFedReader1516 *	myFedReader1516
DtFedReader1516e *	myFedReader1516e
MAKRti::DtFilename	myStandardMimPath
bool	myFullFedFileDistribution
Private Member Functions
	DtRtiExecFederateMgr (DtFederateMgr const &)
	Copy Constructor not implemented -- Copy Not Allowed!
DtRtiExecFederateMgr &	operator= (DtRtiExecFederateMgr const &)
	Assignment not implemented -- Assignment Not Allowed!

Detailed Description

Instances of DtRtiExecFederateMgr process federation-level messages (such as create, destroy, join, resign, and sync points) for HLA applications that are using the rtiexec.

It also manages the manager objects responsible for handling general communication, objects, interactions, the FOM, MOM, and data distribution mmg. Override this class if you want to change how federation-level messages get processed. To inspect federation data, users can obtain a pointer to an instance of this class through the RTI's DtRtiAmbassadorImplementor pointer.

Constructor & Destructor Documentation

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

Constructor.

References DtRIDParameters::fullFedFileDistribution, and myFullFedFileDistribution.

Referenced by create().

DtRtiExecFederateMgr::~DtRtiExecFederateMgr ( ) [virtual]

Destructor.

References DtFederateMgr::connectMgr(), myDistributors, myFedReader13, myFedReader1516, myFedReader1516e, myJoinResponse, mySyncPoints, myTakenFiles, DtFederateMgr::params(), processDesignatedFederateMsg(), processFomModuleFileRequestMsg(), processJoinResponseMsg(), processSyncPointMsg(), DtDesignatedFederateMsg::removeCallback(), DtReportFederationsMsg::removeCallback(), DtFomModuleRequestMsg::removeCallback(), DtSyncPointMsg::removeCallback(), and DtJoinResponseMsg::removeCallback().

DtRtiExecFederateMgr::DtRtiExecFederateMgr ( DtFederateMgr const & ) [private]

Copy Constructor not implemented -- Copy Not Allowed!

Member Function Documentation

void DtRtiExecFederateMgr::appendFomModule	(	std::vector< MAKRti::DtString > &	target,
		MAKRti::DtString const &	source
	)		`[protected]`

Append the source FED file name into the target list, stripping the path name as it is appended into the target.

void DtRtiExecFederateMgr::appendFomModules	(	std::vector< MAKRti::DtString > &	target,
		std::vector< MAKRti::DtString > const &	source
	)		`[protected]`

Append the source FED file names into the target list, stripping the path names as they are appended into the target.

void DtRtiExecFederateMgr::applyRidParameters ( ) [protected, virtual]

Apply RID parameters.

Reimplemented from DtFederateMgr.

References DtFederateMgr::connectMgr(), DtConnectionMgr::enableSmartForwarding(), initRidTester(), DtFederateMgr::myParams, and DtRIDParameters::ridConsistencyChecking().

void DtRtiExecFederateMgr::checkJoinResponse ( ) [protected]

Check the join response and throw appropriate exception on error.

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

Creates an instance of this derived class;.

Reimplemented from DtFederateMgr.

References DtRtiExecFederateMgr().

Referenced by DtRtiAmbassadorBaseImplementor::completeConnection(), and mergeFomModules().

void DtRtiExecFederateMgr::createFederationExecution	(	const char *	executionName,
		const char *	timeImplName,
		const char *	fed
	)		`[virtual]`

Process the create federation execution service.

Implements DtFederateMgr.

References DtCreateResponseMsg::addCallback(), DtCRExecAlreadyExists, DtCRExecCouldNotCreateTimeFactory, DtCRExecCouldNotOpenFed, DtCRExecCreated, DtCRWaiting, DtToWString(), fedFileName(), fomModuleMerging, DtAssistantPopupHelper::popupAssistantMessage(), and DtCreateResponseMsg::removeCallback().

void DtRtiExecFederateMgr::destroyFederationExecution ( const char * executionName ) [virtual]

std::map< DtString, DtSynchronousFileDistributor * > DtRtiExecFederateMgr::distributors ( )

Access to the file distributor.

References myDistributors.

Referenced by initializeFOM(), and waitForJoinResponse().

std::map< DtString, DtSynchronousFileDistributor * > DtRtiExecFederateMgr::distributors ( ) const

References myDistributors.

void DtRtiExecFederateMgr::federateRestoreComplete ( ) [virtual]

Process the federate restore complete service.

Implements DtFederateMgr.

References DtFederateMgr::myRestoreLabel, and sendRestoreCompleteMsg().

void DtRtiExecFederateMgr::federateRestoreNotComplete ( ) [virtual]

Process the federate restore complete service.

Implements DtFederateMgr.

References DtFederateMgr::myRestoreLabel, and sendRestoreCompleteMsg().

Referenced by processRestoreInitiate().

void DtRtiExecFederateMgr::federateSaveBegun ( ) [virtual]

Process the federate save begun service.

Implements DtFederateMgr.

References DtFederateMgr::mySaveBegun, and sendSaveBegunMsg().

void DtRtiExecFederateMgr::federateSaveComplete ( ) [virtual]

Process the federate save complete service.

Implements DtFederateMgr.

References DtFederateMgr::federateHandle(), DtRtiSaveFile::fileName(), DtFederateMgr::getSaveFileName(), DtFederateMgr::myLastSaveLabel, DtFederateMgr::mySaveBegun, DtFederateMgr::mySaveLabel, saveLRC(), and sendSaveCompleteMsg().

void DtRtiExecFederateMgr::federateSaveNotComplete ( ) [virtual]

Process the federate save complete service.

Implements DtFederateMgr.

References DtFederateMgr::connectMgr(), DtFederateMgr::mySaveInitiated, DtFederateMgr::mySaveLabel, sendSaveCompleteMsg(), and DtConnectionMgr::setSaveInProgress().

Referenced by initiateSave().

bool DtRtiExecFederateMgr::findFedFileNameFromMapping	(	const MAKRti::DtString	execName,
		const std::vector< MAKRti::DtString > &	orig,
		std::vector< MAKRti::DtString > &	namesToUse
	)		const `[protected, virtual]`

Find the full FED file path from the stripped name.

References DtFederateMgr::myFedFileNames.

Referenced by initializeFOM(), and waitForJoinResponse().

void DtRtiExecFederateMgr::getCrcsOfFoms	(	std::vector< unsigned int > &	moduleCrcs,
		const std::vector< MAKRti::DtString > &	creationFomModuleNames
	)		`[protected]`

References DtFederateMgr::myParsedFoms.

DtFedReader * DtRtiExecFederateMgr::getReader ( DtFomType theFomType ) [protected]

Reimplemented from DtFederateMgr.

References DtFederateMgr::myFedReader, myFedReader13, myFedReader1516, myFedReader1516e, and NULL.

Referenced by mergeFomModules(), and testReadFomModules().

MAKRti::DtFilename & DtRtiExecFederateMgr::getStandardMimPath ( ) [protected]

References DtRtiLibPath(), and myStandardMimPath.

Referenced by isFomAvailable(), and mergeFomModules().

void DtRtiExecFederateMgr::handleFailedJoin	(	unsigned long	sourceID,
		DtJoinConfirmMsg::errorCodes	code
	)		`[protected, virtual]`

Handle the join failure before throwing an exception.

References DtFederateMgr::connectMgr(), DtFederateMgr::myFedExHandle, DtFederateMgr::myFedHandle, processJoinResponseMsg(), DtJoinResponseMsg::removeCallback(), and sendJoinConfirmMsg().

Referenced by checkJoinResponse(), initializeFOM(), initializeTimeFactory(), and waitForJoinResponse().

void DtRtiExecFederateMgr::init ( ) [virtual]

Virtual initialization within create.

Reimplemented from DtFederateMgr.

References DtReportFederationsMsg::addCallback(), DtFomModuleRequestMsg::addCallback(), DtFederateMgr::connectMgr(), DtFederateMgr::params(), and processFomModuleFileRequestMsg().

void DtRtiExecFederateMgr::initializeDistributor ( const char * executionName ) [protected, virtual]

This function will create the distributor if necessary and initialize it.

References DtFederateMgr::myConnectMgr, myDistributors, myFedFileRequest, and DtFederateMgr::params().

void DtRtiExecFederateMgr::initializeFOM ( const char * executionName ) [protected, virtual]

void DtRtiExecFederateMgr::initializeTimeFactory ( ) [protected, virtual]

Initialize the time factory.

References DtFederateMgr::connectMgr(), DtJoinConfirmMsg::DtCouldNotCreateTimeFactory, DtToWString(), handleFailedJoin(), rti1516::LogicalTimeFactoryFactory::makeLogicalTimeFactory(), rti1516e::LogicalTimeFactoryFactory::makeLogicalTimeFactory(), DtFederateMgr::myHlaTimeFactory, myJoinResponse, DtFederateMgr::myLogicalTimeFactory, DtAssistantPopupHelper::popupAssistantMessage(), DtFederateMgr::setCurrentTimeImplName(), DtFederateMgr::timeFactory(), DtJoinResponseMsg::timeImplName(), and DtFederateMgr::timeImplName().

void DtRtiExecFederateMgr::initiateSave ( ) [protected, virtual]

Perform the actual save possibly after waiting to enter time advancing state.

Reimplemented from DtFederateMgr.

References DtFederateMgr::connectMgr(), DtConnectionMgr::fedAmb(), federateSaveNotComplete(), RTI::FederateAmbassador::initiateFederateSave(), DtFederateMgr::mySaveInitiated, DtFederateMgr::mySaveLabel, and DtConnectionMgr::setSaveInProgress().

Referenced by initiateTimedSave(), and processSaveInitiate().

void DtRtiExecFederateMgr::initiateTimedSave ( RTI::FedTime const & saveTime ) [protected, virtual]

Perform the actual save possibly after waiting to enter time advancing state.

Provide time of save.

Reimplemented from DtFederateMgr.

References initiateSave().

void DtRtiExecFederateMgr::initRidTester ( ) [protected, virtual]

Initialize the RidTester.

References DtConnectionMgr::connectionId(), DtFederateMgr::connectMgr(), DtFederateMgr::myClock, DtFederateMgr::myConnectMgr, DtFederateMgr::myParams, DtRidFileTester::receivedResponse(), DtRIDParameters::responseInterval, DtRidFileTester::sendRequestForTesting(), DtConnectionMgr::tick(), DtFederateMgr::tick(), and DtConnectionMgr::yield().

Referenced by applyRidParameters().

bool DtRtiExecFederateMgr::isDesignatedFederate ( ) [protected, virtual]

References myIsDesignatedFederate.

bool DtRtiExecFederateMgr::isFomAvailable ( const DtString & fomName ) [protected]

References DtReadFile(), getStandardMimPath(), myTakenFiles, and DtLibRTIUtil::openFedFile().

Referenced by populateWithUnknownFoms().

DtSynchronousFileDistributor * DtRtiExecFederateMgr::joinDistributor ( )

References myJoinDistributor.

Referenced by mergeFomModules(), and posttick().

DtSynchronousFileDistributor * DtRtiExecFederateMgr::joinDistributor ( ) const

References myJoinDistributor.

RTI::FederateHandle DtRtiExecFederateMgr::joinFederationExecution	(	const char *	yourName,
		const char *	executionName,
		RTI::FederateAmbassador *	federateAmbassadorReference,
		unsigned long	flags
	)		`[virtual]`

Process the join federation execution service.

Implements DtFederateMgr.

References DtJoinResponseMsg::addCallback(), DtGENERATE_KEY, DtJoinConfirmMsg::DtNoError, fedFileName(), and DtAssistantPopupHelper::popupAssistantMessage().

void DtRtiExecFederateMgr::mergeFomModules ( const std::vector< MAKRti::DtString > * fomModules ) [protected, virtual]

Merge the given FOM Modules into the current FOM.

Referenced by initializeFOM().

DtRtiExecFederateMgr& DtRtiExecFederateMgr::operator= ( DtRtiExecFederateMgr const & ) [private]

Assignment not implemented -- Assignment Not Allowed!

void DtRtiExecFederateMgr::populateWithUnknownFoms	(	std::vector< DtString > &	mods,
		std::vector< DtString > &	requestedMods
	)		`[protected]`

References isFomAvailable().

Referenced by initializeFOM().

void DtRtiExecFederateMgr::postJoinInit	(	const char *	yourName,
		const char *	executionName,
		const char *	federateName,
		RTI::FederateAmbassador *	federateAmbassadorReference
	)		`[protected, virtual]`

Uses the given information to initialize federate data.

DtFomClassMgr needs to be initialized before this function is called.

Reimplemented from DtFederateMgr.

References DtDesignatedFederateMsg::addCallback(), DtSyncPointMsg::addCallback(), DtJoinConfirmMsg::DtNoError, and DtFederateMgr::postJoinInit().

void DtRtiExecFederateMgr::posttick ( ) [protected, virtual]

Processing after a tick.

Reimplemented from DtFederateMgr.

References DtFederateMgr::connectMgr(), DtConnectionMgr::fedAmb(), DtRIDParameters::fomModuleMerging, DtRIDParameters::fullFedFileDistribution, DtSynchronousFileDistributor::getPushedFomModules(), joinDistributor(), myFailedSyncPointLabel, DtFederateMgr::params(), DtSynchronousFileDistributor::pullInProgress(), DtSynchronousFileDistributor::pushedFomModules(), rti1516::SYNCHRONIZATION_POINT_LABEL_NOT_UNIQUE, rti1516e::SYNCHRONIZATION_POINT_LABEL_NOT_UNIQUE, and RTI::FederateAmbassador::synchronizationPointRegistrationFailed().

void DtRtiExecFederateMgr::prepareToRestore ( ) [protected, virtual]

Prepare the state information to be restored (i.e., clear out existing data).

Referenced by prepareToRestoreLRC().

void DtRtiExecFederateMgr::prepareToRestoreLRC ( ) [protected, virtual]

Prepare the state information of the LRC for a restore (may include a back up save in case restore fails).

References DtFederateMgr::myFom, DtFederateMgr::myInterMgr, DtFederateMgr::myMomMgr, DtFederateMgr::myObjMgr, DtInteractionMgr::prepareToRestore(), DtFomClassMgr::prepareToRestore(), prepareToRestore(), and DtObjectMgr::prepareToRestore().

Referenced by processRestoreInitiate().

void DtRtiExecFederateMgr::processCreateResponseMsg ( const DtCreateResponseMsg & msg ) [protected, virtual]

Process create response message.

References DtConnectionMgr::connectionId(), DtFederateMgr::connectMgr(), DtCreateResponseMsg::destinationID(), DtCreateResponseMsg::errorString(), myCreateResponse, myCreateResponseErrorString, and DtCreateResponseMsg::responseFlag().

void DtRtiExecFederateMgr::processCreateResponseMsg	(	const DtCreateResponseMsg &	msg,
		void *	usr
	)		`[static]`

Create response message callback.

void DtRtiExecFederateMgr::processDesignatedFederateMsg ( const DtDesignatedFederateMsg & msg ) [protected, virtual]

Process designated federate message.

References DtFederateMgr::connectMgr(), DtDesignatedFederateMsg::designatedFederate(), DtConnectionMgr::fedHandle(), DtFederateMgr::myMomMgr, and setDesignatedFederate().

Referenced by ~DtRtiExecFederateMgr().

void DtRtiExecFederateMgr::processDesignatedFederateMsg	(	const DtDesignatedFederateMsg &	msg,
		void *	usr
	)		`[static]`

designated federate message callback

void DtRtiExecFederateMgr::processDestroyResponseMsg ( const DtDestroyResponseMsg & msg ) [protected, virtual]

Process destroy response message.

References DtDestroyResponseMsg::fullFedExName(), myDestroyExecutionName, myDestroyResponse, and DtDestroyResponseMsg::responseFlag().

Referenced by destroyFederationExecution().

void DtRtiExecFederateMgr::processDestroyResponseMsg	(	const DtDestroyResponseMsg &	msg,
		void *	usr
	)		`[static]`

Destroy response message callback.

void DtRtiExecFederateMgr::processFomModuleFileRequestMsg ( const DtFomModuleRequestMsg & msg ) [protected, virtual]

Process Fom Module file distribution message.

References DtConnectionMgr::connectionId(), DtFederateMgr::connectMgr(), DtFomModuleRequestMsg::destinationID(), DtFomModuleRequestMsg::getFomModuleNames(), myFedFileRequest, myFomModuleRequests, and DtFederateMgr::params().

Referenced by init(), and ~DtRtiExecFederateMgr().

void DtRtiExecFederateMgr::processFomModuleFileRequestMsg	(	const DtFomModuleRequestMsg &	msg,
		void *	usr
	)		`[static]`

Fom Module file distribution message callback.

void DtRtiExecFederateMgr::processJoinResponseMsg ( const DtJoinResponseMsg & msg ) [protected, virtual]

void DtRtiExecFederateMgr::processJoinResponseMsg	(	const DtJoinResponseMsg &	msg,
		void *	usr
	)		`[static]`

Join response message callback.

void DtRtiExecFederateMgr::processRestore ( const DtRestoreMsg & msg ) [protected, virtual]

Process the restore message.

Reimplemented from DtFederateMgr.

References DtFederateMgr::connectMgr(), DtResponseFail, DtResponseSuccess, enableSaveRestoreWhenUsingRtiexec, DtConnectionMgr::fedAmb(), RTI::FederateAmbassador::federationRestoreBegun(), DtSaveMsg::label(), DtFederateMgr::myRestoreBegun, DtFederateMgr::myRestoreLabel, DtFederateMgr::params(), sendRestoreBegunMsg(), DtConnectionMgr::setRestoreInProgress(), and useRtiExec.

void DtRtiExecFederateMgr::processRestoreEnd ( const DtRestoreEndMsg & msg ) [protected, virtual]

Process the restore end message.

Reimplemented from DtFederateMgr.

References DtFederateMgr::connectMgr(), DtRestoreResultAborted, DtRestoreResultFailureDetected, DtRestoreResultFederateFailure, DtRestoreResultFederateResigned, DtRestoreResultSucess, DtRestoreResultUnableToRestore, DtConnectionMgr::emptyPendingMsgList(), enableSaveRestoreWhenUsingRtiexec, DtRestoreEndMsg::endResult(), DtConnectionMgr::fedAmb(), rti1516::FEDERATE_REPORTED_FAILURE_DURING_RESTORE, rti1516::FEDERATE_RESIGNED_DURING_RESTORE, RTI::FederateAmbassador::federationNotRestored(), RTI::FederateAmbassador::federationRestored(), DtFederateMgr::myFedHandle, myOldFedHandle, DtFederateMgr::myRestoreBegun, DtFederateMgr::myRestoreInitiated, DtFederateMgr::myRestoreRequested, DtFederateMgr::params(), rti1516e::RESTORE_ABORTED, rti1516::RTI_DETECTED_FAILURE_DURING_RESTORE, rti1516::RTI_UNABLE_TO_RESTORE, DtConnectionMgr::setFederateHandle(), DtConnectionMgr::setRestoreInProgress(), and useRtiExec.

void DtRtiExecFederateMgr::processRestoreInitiate ( const DtRestoreInitiateMsg & msg ) [protected, virtual]

Process the restore initiate message.

Reimplemented from DtFederateMgr.

References DtFederateMgr::connectMgr(), DtToWString(), enableSaveRestoreWhenUsingRtiexec, DtConnectionMgr::fedAmb(), DtFederateMgr::federateHandle(), federateRestoreNotComplete(), DtFederateMgr::getRestoreFileName(), RTI::FederateAmbassador::initiateFederateRestore(), DtFederateMgr::myFedHandle, DtFederateMgr::myRestoreInitiated, DtFederateMgr::myRestoreLabel, DtRestoreInitiateMsg::newHandle(), DtRestoreInitiateMsg::oldHandle(), DtFederateMgr::params(), prepareToRestoreLRC(), restoreLRC(), and useRtiExec.

void DtRtiExecFederateMgr::processRestoreReply ( const DtRestoreReplyMsg & msg ) [protected, virtual]

Process the restore reply message.

Reimplemented from DtFederateMgr.

References DtFederateMgr::connectMgr(), DtRestoreReplyMsg::destinationID(), DtRestoreReplyMsg::DT_RESTORE_IN_PROCESS, DtRestoreReplyMsg::DT_RESTORE_NO_LABEL, DtRestoreReplyMsg::DT_RESTORE_OK, DtRestoreReplyMsg::DT_RESTORE_WRONG_CONFIG, DtToWString(), enableSaveRestoreWhenUsingRtiexec, DtConnectionMgr::fedAmb(), DtRestoreReplyMsg::label(), DtFederateMgr::myFedHandle, DtFederateMgr::params(), DtRestoreReplyMsg::reply(), RTI::FederateAmbassador::requestFederationRestoreFailed(), RTI::FederateAmbassador::requestFederationRestoreSucceeded(), and useRtiExec.

void DtRtiExecFederateMgr::processSaveFinished ( const DtSaveFinishedMsg & msg ) [protected, virtual]

Process the save finished message.

Reimplemented from DtFederateMgr.

References DtFederateMgr::connectMgr(), DtSaveFinishedAborted, DtSaveFinishedFailureDetected, DtSaveFinishedFederateFailure, DtSaveFinishedFederateResigned, DtSaveFinishedInvalidSaveTime, DtSaveFinishedRtiUnableToSave, DtSaveFinishedSuccess, enableSaveRestoreWhenUsingRtiexec, DtConnectionMgr::fedAmb(), rti1516::FEDERATE_REPORTED_FAILURE_DURING_SAVE, rti1516::FEDERATE_RESIGNED_DURING_SAVE, RTI::FederateAmbassador::federationNotSaved(), RTI::FederateAmbassador::federationSaved(), DtSaveFinishedMsg::finishedResult(), DtFederateMgr::mySaveBegun, DtFederateMgr::mySaveInitiated, DtFederateMgr::params(), rti1516::RTI_DETECTED_FAILURE_DURING_SAVE, rti1516::RTI_UNABLE_TO_SAVE, rti1516e::SAVE_ABORTED, rti1516::SAVE_TIME_CANNOT_BE_HONORED, DtConnectionMgr::setSaveInProgress(), and useRtiExec.

void DtRtiExecFederateMgr::processSaveInitiate ( const DtSaveInitiateMsg & msg ) [protected, virtual]

Process the save initiate message.

Reimplemented from DtFederateMgr.

References DtSaveMsg::label().

void DtRtiExecFederateMgr::processSaveInitiate ( const char * label ) [protected, virtual]

Process the save initiate.

References enableSaveRestoreWhenUsingRtiexec, initiateSave(), DtFederateMgr::mySaveLabel, DtFederateMgr::params(), and useRtiExec.

void DtRtiExecFederateMgr::processSaveResponse ( const DtSaveResponseMsg & msg ) [protected, virtual]

Process the save response message.

Reimplemented from DtFederateMgr.

References DtFederateMgr::connectMgr(), DtConnectionMgr::fedHandle(), mySaveRequestID, mySaveResponse, DtSaveResponseMsg::requestID(), DtSaveResponseMsg::requestingFederate(), and DtSaveResponseMsg::responseFlag().

void DtRtiExecFederateMgr::processSyncPointMsg ( const DtSyncPointMsg & msg ) [protected, virtual]

Process a sync point message.

References RTI::FederateAmbassador::announceSynchronizationPoint(), DtFederateMgr::connectMgr(), DtAchieved, DtAnnouncePt, DtRegister, DtSynchronized, DtSyncPointRegFailed, DtSyncPointRegSucceeded, DtSyncStatusFailLabelNotUnique, DtSyncStatusFailMemberNotJoined, DtSyncStatusFailResignDuringSync, DtSyncStatusFailRtiInternal, DtSyncStatusFailTimeNotHonored, DtToWString(), DtConnectionMgr::fedAmb(), rti1516::FEDERATE_RESIGNED_DURING_SYNCHRONIZATION, DtSyncPointMsg::federateId(), DtSyncPointMsg::federates(), RTI::FederateAmbassador::federationSynchronized(), DtSyncPointMsg::getFederates(), DtSyncPointMsg::getUnsuccessfulFederates(), DtRtiMsg::isForExec(), DtFederateMgr::myFedExHandle, DtFederateMgr::myFedExName, DtFederateMgr::myFedHandle, mySyncPoints, rti1516::RTI_DETECTED_FAILURE_DURING_SYNCHRONIZATION, rti1516::SYNCHRONIZATION_POINT_LABEL_NOT_UNIQUE, rti1516::SYNCHRONIZATION_SET_MEMBER_NOT_JOINED, rti1516::SYNCHRONIZATION_TIME_CANNOT_BE_HONORED, RTI::FederateAmbassador::synchronizationPointRegistrationFailed(), RTI::FederateAmbassador::synchronizationPointRegistrationSucceeded(), DtSyncPointMsg::syncMsgKind(), DtSyncPointMsg::syncPointName(), DtSyncPointMsg::syncPointStatus(), DtSyncPointMsg::tag(), and DtRtiMsg::theDefaultTag.

Referenced by ~DtRtiExecFederateMgr().

void DtRtiExecFederateMgr::processSyncPointMsg	(	const DtSyncPointMsg &	msg,
		void *	usr
	)		`[static]`

sync point message callback

void DtRtiExecFederateMgr::registerFederationSynchronizationPoint	(	char const *	label,
		char const *	theTag
	)		`[virtual]`

Process the register synchronization point service.

Implements DtFederateMgr.

References DtRegister, myFailedSyncPointLabel, DtFederateMgr::myFedHandle, mySyncPoints, and sendSyncPointMsg().

void DtRtiExecFederateMgr::registerFederationSynchronizationPoint	(	char const *	label,
		char const *	theTag,
		DtFederateHandleSet const &	syncSet
	)		`[virtual]`

Process the register synchronization point service.

Implements DtFederateMgr.

References DtRegister, myFailedSyncPointLabel, DtFederateMgr::myFedHandle, mySyncPoints, and sendSyncPointMsg().

void DtRtiExecFederateMgr::requestFederationRestore ( const char * label ) [virtual]

Process the request federation restore service.

Implements DtFederateMgr.

References DtFederateMgr::myRestoreLabel, DtFederateMgr::myRestoreRequested, and sendRestoreRequestMsg().

void DtRtiExecFederateMgr::requestFederationSave	(	char const *	label,
		RTI::FedTime const *	time = `NULL`
	)		`[virtual]`

Process the request federation save service.

Implements DtFederateMgr.

References DtFederateMgr::mySaveLabel, and requestImmediateSave().

void DtRtiExecFederateMgr::requestImmediateSave ( const char * label ) [protected, virtual]

Process the immediate save message.

References DtSaveResponseMsg::addCallback(), DtFederateMgr::connectMgr(), DtSRSaveAccepted, DtSRSaveInProgress, DtSRSaveWaiting, DtToWString(), DtConnectionMgr::enterServiceCall(), DtConnectionMgr::exitServiceCall(), DtFederateMgr::myClock, mySaveRequestID, mySaveResponse, DtFederateMgr::params(), DtFederateMgr::processSaveResponse(), DtSaveResponseMsg::removeCallback(), DtRIDParameters::responseInterval, sendSaveRequestMsg(), DtConnectionMgr::tick(), and DtConnectionMgr::yield().

Referenced by requestFederationSave().

void DtRtiExecFederateMgr::resignFederationExecution ( RTI::ResignAction theAction ) [virtual]

Process the resign federation execution service.

Reimplemented from DtFederateMgr.

References DtSRSaveWaiting, NULL, DtDesignatedFederateMsg::removeCallback(), DtSyncPointMsg::removeCallback(), DtJoinResponseMsg::removeCallback(), and DtFederateMgr::resignFederationExecution().

bool DtRtiExecFederateMgr::restore ( DtRtiSaveFile & file ) [protected, virtual]

Restore the federation manager state information from the given file.

Reimplemented from DtFederateMgr.

References DtConnectionMgr::addPendingMsg(), DtFederateMgr::connectMgr(), DtMessageFactory< T_Message, T_MessageKind, T_NetworkHeader >::create(), DtRtiSaveBestEffortMsgType, DtRtiSaveFedMgrType, DtRtiSaveReliableMsgType, DtConnectionMgr::emptyPendingMsgList(), DtFedMgrPacket::fedHandle, DtFedMgrPacket::header, DtConnectionMgr::msgFactory(), DtFederateMgr::myConnectMgr, DtFederateMgr::myFedExHandle, DtFederateMgr::myFedHandle, myOldFedHandle, mySyncPoints, DtFedMgrPacket::numMsgs, DtFedMgrPacket::numSyncPts, DtSaveDataHeader::packetType, DtRtiSaveFile::readNextPacket(), DtRtiMsg::setFedEx(), and DtRtiMsg::setTransportType().

Referenced by restoreLRC().

bool DtRtiExecFederateMgr::restoreLRC ( DtRtiSaveFile & saveFile ) [protected, virtual]

Restore the LRC state information Return bool: restore successful?

References DtRtiSaveFile::isOk(), DtFederateMgr::myFom, DtFederateMgr::myInterMgr, DtFederateMgr::myMomMgr, DtFederateMgr::myObjMgr, DtInteractionMgr::restore(), DtFomClassMgr::restore(), restore(), and DtObjectMgr::restore().

Referenced by processRestoreInitiate().

bool DtRtiExecFederateMgr::save ( DtRtiSaveFile & file ) [protected, virtual]

Save the federation manager state information to the given file.

Reimplemented from DtFederateMgr.

References DtConnectionMgr::addPendingMsg(), DtFederateMgr::connectMgr(), DtRtiSaveBestEffortMsgType, DtRtiSaveFedMgrType, DtRtiSaveReliableMsgType, DtFedMgrPacket::fedHandle, DtFedMgrPacket::header, DtFederateMgr::myFedHandle, mySyncPoints, DtConnectionMgr::nextPendingMsg(), DtFedMgrPacket::numMsgs, DtFedMgrPacket::numSyncPts, DtSaveDataHeader::packetSize, DtSaveDataHeader::packetType, DtFederateMgr::params(), DtConnectionMgr::pendingMsgCount(), DtRIDParameters::saveTransientMessages, saveTransientMessages, DtRtiMsg::transportType(), and DtRtiSaveFile::writePacket().

Referenced by saveLRC().

bool DtRtiExecFederateMgr::saveLRC ( DtRtiSaveFile & saveFile ) [protected, virtual]

Save the LRC state information.

Return bool: save successful?

References DtRtiSaveFile::isOk(), DtFederateMgr::myFom, DtFederateMgr::myInterMgr, DtFederateMgr::myMomMgr, DtFederateMgr::myObjMgr, DtInteractionMgr::save(), DtFomClassMgr::save(), save(), and DtObjectMgr::save().

Referenced by federateSaveComplete().

void DtRtiExecFederateMgr::sendCreateMsg	(	MAKRti::DtString const &	fedExNameVal,
		MAKRti::DtString const &	timeImplName,
		const std::vector< unsigned int > &	moduleCrcs,
		MAKRti::DtFomType	fedType,
		MAKRti::DtString const &	momModuleName,
		const std::vector< MAKRti::DtString > &	fomModules,
		unsigned int	momModuleCrc
	)		`[protected, virtual]`

Send create federation message.

References DtFederateMgr::connectMgr(), DtConnectionMgr::create(), DtCreateMsgKind, DtConnectionMgr::sendAndDelete(), and DtCreateMsg::set().

void DtRtiExecFederateMgr::sendDestroyMsg ( const char * name ) [protected, virtual]

Send destroy federation message.

References DtFederateMgr::connectMgr(), DtConnectionMgr::create(), DtDestroyMsgKind, DtConnectionMgr::sendAndDelete(), and DtDestroyMsg::set().

Referenced by destroyFederationExecution().

void DtRtiExecFederateMgr::sendJoinConfirmMsg	(	unsigned long	sourceID,
		DtJoinConfirmMsg::errorCodes	errorCode
	)		`[protected, virtual]`

Send join federation confirm message.

References DtFederateMgr::connectMgr(), DtConnectionMgr::create(), DtJoinConfirmMsgKind, DtConnectionMgr::sendStampedAndDelete(), and DtJoinConfirmMsg::set().

Referenced by handleFailedJoin().

void DtRtiExecFederateMgr::sendJoinMsg	(	unsigned long	sourceID,
		unsigned short	requestID,
		const char *	fedType,
		const char *	fedExName,
		const char *	fedName,
		const std::vector< MAKRti::DtString > &	fomModules,
		const unsigned long	flags,
		const std::vector< unsigned int > &	joinModulesCrcs
	)		`[protected, virtual]`

Send join federation message.

References DtFederateMgr::connectMgr(), DtConnectionMgr::create(), DtDefaultInterfaceAddr(), DtGetLocalHostName(), DtHlaVersion(), DtJoinMsgKind, DtUseFedObservers, DtFederateMgr::myConnectedToWebServer, DtRIDParameters::networkInterfaceAddr(), DtFederateMgr::params(), DtConnectionMgr::sendAndDelete(), DtJoinMsg::set(), DtJoinMsg::setIpAddress(), DtJoinMsg::setWebServerAddress(), DtJoinMsg::setWebServerPort(), and webserviceAddrString.

void DtRtiExecFederateMgr::sendRestoreBegunMsg	(	const char *	label,
		DtResponseFlag	response
	)		`[protected, virtual]`

Send restore federate begun message.

References DtFederateMgr::connectMgr(), DtConnectionMgr::create(), DtRestoreBegunMsgKind, DtFederateMgr::federateHandle(), DtConnectionMgr::sendStampedAndDelete(), and DtRestoreBegunMsg::set().

Referenced by processRestore().

void DtRtiExecFederateMgr::sendRestoreCompleteMsg	(	const char *	label,
		bool	success
	)		`[protected, virtual]`

Send restore federate complete message.

References DtFederateMgr::connectMgr(), DtConnectionMgr::create(), DtRestoreCompleteMsgKind, DtConnectionMgr::sendStampedAndDelete(), and DtSaveCompleteMsg::set().

Referenced by federateRestoreComplete(), and federateRestoreNotComplete().

void DtRtiExecFederateMgr::sendRestoreRequestMsg ( const char * label ) [protected, virtual]

Send restore federation request message.

References DtFederateMgr::connectMgr(), DtConnectionMgr::create(), DtRestoreRequestMsgKind, DtConnectionMgr::sendStampedAndDelete(), and DtSaveMsg::set().

Referenced by requestFederationRestore().

void DtRtiExecFederateMgr::sendSaveBegunMsg ( ) [protected, virtual]

Send save federate begun message.

References DtFederateMgr::connectMgr(), DtConnectionMgr::create(), DtSaveBegunMsgKind, and DtConnectionMgr::sendStampedAndDelete().

Referenced by federateSaveBegun().

void DtRtiExecFederateMgr::sendSaveCompleteMsg	(	const char *	label,
		bool	success
	)		`[protected, virtual]`

Send federate complete message.

References DtFederateMgr::connectMgr(), DtConnectionMgr::create(), DtSaveCompleteMsgKind, DtConnectionMgr::sendStampedAndDelete(), and DtSaveCompleteMsg::set().

Referenced by federateSaveComplete(), and federateSaveNotComplete().

void DtRtiExecFederateMgr::sendSaveRequestMsg	(	unsigned long	requestID,
		const char *	label
	)		`[protected, virtual]`

Send save federation request message.

References DtFederateMgr::connectMgr(), DtConnectionMgr::create(), DtSaveRequestMsgKind, DtConnectionMgr::sendStampedAndDelete(), and DtSaveRequestMsg::set().

Referenced by requestImmediateSave().

void DtRtiExecFederateMgr::sendSyncPointMsg	(	DtSyncMsgType	kind,
		DtFederateHandle &	id,
		char const *	name,
		char const *	tag = `NULL`,
		DtFederateHandleSet const *	set = `NULL`
	)		`[protected, virtual]`

Send synchronization point message.

References DtFederateMgr::connectMgr(), DtConnectionMgr::create(), DtSyncPointMsgKind, DtSyncStatusSucceeded, DtConnectionMgr::sendStampedAndDelete(), and DtSyncPointMsg::set().

Referenced by registerFederationSynchronizationPoint(), and synchronizationPointAchieved().

void DtRtiExecFederateMgr::setDesignatedFederate ( bool isDesignated ) [protected, virtual]

Set/Get designated status of this federate's LRC.

References myIsDesignatedFederate.

Referenced by processDesignatedFederateMsg().

void DtRtiExecFederateMgr::synchronizationPointAchieved	(	char const *	label,
		bool	successfully = `true`
	)		`[virtual]`

Process the synchronization point achieved service.

Implements DtFederateMgr.

References DtAchieved, DtAchievedUnsuccessfully, DtFederateMgr::myFedHandle, mySyncPoints, and sendSyncPointMsg().

void DtRtiExecFederateMgr::testReadFomModules	(	const DtRIDParameters::DtStringList &	modulesNames,
		MAKRti::DtString	executionName,
		bool	isMim = `false`
	)		`[protected]`