DtFedExec Class Reference

Collaboration diagram for DtFedExec:

List of all members.

Public Member Functions
virtual	~DtFedExec ()
	Destructor.
virtual DtConnectionMgr *	connectMgr ()
	Returns the connection mgr.
virtual DtLogicalTimeFactory *	fedTimeFactory ()
	Returns the time factory.
virtual const DtString &	fedExName () const
	Returns the name of the this federation execution.
virtual int	fedExHandle () const
	Returns the handle of this federation execution.
virtual const DtString &	fedFileName () const
	Returns the name of the FED file that was associated with the federation execution at creation time.
virtual const std::vector < DtString > &	fomModules () const
	Returns the fomModules names associated w/ the fedex.
virtual bool	fullyCreated () const
	Return boolean: Federation execution creation is complete.
virtual void	setFullyCreated (bool val)
	Set completion status.
virtual unsigned long	creatorID () const
	Set the ID for who created this federation execution.
virtual void	createDistributor (const unsigned long initiatingFedID, const DtString &momModuleName, const std::vector< DtString > &fomModules)
	Create Fed File Distributor for federation.
virtual int	numFederates () const
	Returns the total number of federates joined to this federation.
virtual DtFederate *	getFederate (DtFederateHandle handle)
	Returns the DtFederate object representing the joined federate with the indicated handle.
virtual DtFederateHandle	federateHandleOfConnection (unsigned long connId) const
	Return the connection's federate handle if joined to this federation; otherwise, 0.
virtual void	disconnectFederate (DtFederate *fed)
	Mark federate as attempting to reconnect.
virtual bool	removeFederateConnection (unsigned long id)
	Removes the federate with the given connection ID.
virtual bool	restoreFederateConnection (DtFederateHandle handle, unsigned long newConnId, unsigned long &oldConnId)
	Restore a joined federate on a new connection ID TODO: let this work for connected, not necessarily joined federates Pass back old connection ID Return bool: federate restored.
virtual void	reconnectFederateSucceeded (DtFederate *fed)
	Federate successfully reconnected.
virtual void	reconnectFederateFailed (DtFederate *fed)
	Federate failed to reconnect.
virtual bool	resignFederate (DtFederateHandle handle, DtResignAction action, DtResignReason reason)
	Resign the given federate from the federation.
virtual void	resetClockForHeartBeat ()
	This should only be called when the rtiExec has reconnected.
virtual bool	tick ()
	Tick the federation execution.
virtual void	printFederates ()
	Print the list of federates for each federation execution.
virtual void	addFederateJoinedCallback (DtFederateCbFn fn, void *usr)
	Register callback to be invoked whenever a federate joins a federation.
virtual void	removeFederateJoinedCallback (DtFederateCbFn fn, void *usr)
	Remove callback to be invoked whenever a federate joins a federation.
virtual void	addFederateResignedCallback (DtFederateCbFn fn, void *usr)
	Register callback to be invoked whenever a federate resigns a federation.
virtual void	removeFederateResignedCallback (DtFederateCbFn fn, void *usr)
	Remove callback to be invoked whenever a federate resigns a federation.
virtual void	addSyncPtRegisteredCallback (DtSyncPointCbFn fn, void *usr)
	Register a callback to be invoked whenever a new sync point has been registered.
virtual void	removeSyncPtRegisteredCallback (DtSyncPointCbFn fn, void *usr)
	Unregister a callback to be invoked whenever a new sync point has been registered.
virtual void	addSyncPtAchievedCallback (DtSyncPointAchievedCbFn fn, void *usr)
	Register a callback to be invoked whenever a federate has achieved a sync point.
virtual void	removeSyncPtAchievedCallback (DtSyncPointAchievedCbFn fn, void *usr)
	Unregister a callback to be invoked whenever a federate has achieved a sync point.
virtual void	addFederationSynchronizedCallback (DtSyncPointCbFn fn, void *usr)
	Register a callback to be invoked whenever all federates has achieved a sync point.
virtual void	removeFederationSynchronizedCallback (DtSyncPointCbFn fn, void *usr)
	Unregister a callback to be invoked whenever all federates has achieved a sync point.
virtual void	addFederateDisconnectedCallback (DtFederateCbFn fn, void *usr)
	Register callbacks for federate disconnected.
virtual void	removeFederateDisconnectedCallback (DtFederateCbFn fn, void *usr)
	Unregister callbacks for federate disconnected.
virtual void	addFederateReconnectSucceededCallback (DtFederateCbFn fn, void *usr)
virtual void	removeFederateReconnectSucceededCallback (DtFederateCbFn fn, void *usr)
virtual void	addFederateReconnectFailedCallback (DtFederateCbFn fn, void *usr)
virtual void	removeFederateReconnectFailedCallback (DtFederateCbFn fn, void *usr)
void	multFileReceivedCb (const DtFomModuleDistributionMsg &msg)
	File received callback... generates a distributor postCommand.
void	multFileRequestedCb (const DtFomModuleRequestMsg &msg)
	File requested callback... generates a distributor postCommand.
void	pushFomModuleToJoinedFederates (DtFederate *newFederate, DtString fileName, unsigned int fileSize, const char *fileBuffer)
	Push a FOM Module to all joined federates except the one specified.
void	pushFomModuleToSingleFederate (DtFederateHandle recipient, DtString fileName, unsigned int fileSize, const char *fileBuffer)
	Push a FOM Module to the given federate.
virtual void	processRequestedModulesArrived (const DtRequestedModulesArrivedEvent &e)
	Process arrival of requested FOM Modules.
virtual void	processFedFileRequestMsg (const DtFedFileRequestMsgEvent &e)
	Process FED file requests.
virtual void	processFileTransfer (const DtFedExTakeFileEvent &e)
	Process file transfers.
virtual DtFederateHandleInfoMap const &	federates () const
	Returns the list of federates for this fed exec.
virtual void	disableNetworkTesting ()
	Disable network testing at federate.
virtual void	enableNetworkTesting ()
	Enable network testing at federate.
virtual void	changeLatencyTestMode (DtFederateHandle handle, bool runTest, bool continuous, bool haltContinuous, bool observing, unsigned int interactionPeriod, unsigned int numInteractions, unsigned int payloadBytes)
	Changes the latency test mode for the specified federate.
virtual bool	transferRidParams (DtFederateHandle handle, const DtString &ridString)
	Transfer RID parameters over network.
Static Public Member Functions
static void	multFileReceivedCb (const DtFomModuleDistributionMsg &msg, void *usr)
	File received callback... generates a distributor postCommand.
static void	multFileRequestedCb (const DtFomModuleRequestMsg &msg, void *usr)
	File requested callback... generates a distributor postCommand.
static DtFedExec *	create (DtConnectionMgr *connMgr, const std::vector< unsigned int > &crcs, DtString const &fedExName, std::string const &timeImplName, MAKRti::DtFomType fedType, DtString const &momModuleName, const std::vector< DtString > &fomModules, int fedExHandle, DtRIDParameters *params, unsigned int momModuleCrc)
	Creates an instance of a DtFedExec;.
static void	setCreatorFunction (DtFedExecCreator creator)
	Call this function to set an alternate creator function With this function, users can replace this DtFedExec with their own derived class.
static void	init (DtRtiAssistantExecClient *assistant)
Static RTI message callbacks
Static methods to install in connection manager to process message callbacks
static void	processJoinMsg (const DtJoinMsg &msg, void *usr)
static void	processJoinConfirm (const DtJoinConfirmMsg &msg, void *usr)
static void	processAlive (const DtAliveMsg &msg, void *usr)
static void	processResign (const DtResignMsg &msg, void *usr)
static void	processSyncPoint (const DtSyncPointMsg &msg, void *usr)
static void	processSyncPointQuery (const DtSyncPointQueryMsg &msg, void *usr)
static void	processSaveRequest (const DtSaveRequestMsg &msg, void *usr)
static void	processInitiatedSave (const DtInitiatedSaveMsg &msg, void *usr)
static void	processSaveComplete (const DtSaveCompleteMsg &msg, void *usr)
static void	processSaveBegun (const DtSaveBegunMsg &msg, void *usr)
static void	processAbortSave (const DtAbortSaveMsg &msg, void *usr)
static void	processRestoreRequest (const DtRestoreRequestMsg &msg, void *usr)
static void	processRestoreBegun (const DtRestoreBegunMsg &msg, void *usr)
static void	processRestoreComplete (const DtRestoreCompleteMsg &msg, void *usr)
static void	processAbortRestore (const DtAbortRestoreMsg &msg, void *usr)
static void	processOwnership (const DtOwnershipMsg &msg, void *usr)
static void	processReserveName (DtReserveNameMsg const &msg, void *usr)
static void	processReserveMultiName (DtReserveMultiNameMsg const &msg, void *usr)
static void	processReleaseMultiName (DtReleaseMultiNameMsg const &msg, void *usr)
static void	processQuerySaveStatus (DtQuerySaveStatusMsg const &msg, void *usr)
static void	processQueryRestoreStatus (DtQueryRestoreStatusMsg const &msg, void *usr)
Protected Types
typedef std::set< std::string >	DtFedExReservedNameSet
typedef std::map < DtFederateHandle, DtFedExReservedNameSet >	DtFedExFederateReservedNameMap
Protected Member Functions
	DtFedExec (DtConnectionMgr *connMgr, const std::vector< unsigned int > &crcs, DtString const &fedExName, std::string const &timeImplName, MAKRti::DtFomType fedType, const DtString &momModuleName, const std::vector< DtString > &modules, int fedExHandle, DtRIDParameters *params, unsigned int momModuleCrc)
	Constructor.
virtual const std::map < unsigned long, const std::vector< DtString > * > &	joinFomModules () const
	Returns the joinfomModules names associated w/ the fedex.
virtual const std::vector < DtString > &	joinFomModulesForConnection (unsigned long connID) const
virtual const std::vector < DtString > &	createFomModules () const
	Returns the joinfomModules names associated w/ the fedex.
virtual void	processRegisterSyncPoint (const DtSyncPointMsg &msg)
	Process sync point registration.
virtual void	processAchievedSyncPoint (const DtSyncPointMsg &msg)
	Process sync point achieved.
virtual void	createSyncPoint (const DtSyncPointMsg &msg)
	Create a sync point.
virtual void	processSyncPtAchievedCallbacks (DtSyncPt *point, DtFederate *federate)
	Process the callbacks registered for federates achieving sync points.
virtual void	processFederationSynchronizedCallbacks (DtSyncPt *point)
	Process the callbacks registered for federates achieving sync points.
virtual bool	synchronized (DtSyncPt *point, DtFederateHandleSet &unsuccessfulSet) const
	Return true if we've reached synchronization for this point, false otherwise.
virtual void	sendSyncPointReport (const DtSyncPointQueryMsg &msg)
	Send MOM report synchronization point interaction.
virtual void	sendSyncPointStatusReport (const DtSyncPointQueryMsg &msg)
	Send MOM report synchronization point status interaction.
virtual DtFederate *	addFederate (const char *federateType, const char *fedHostName, DtFederateHandle handle, unsigned long connHandle, MAKRti::DtInetAddr host, DtHlaVersionId hlaVersion, MAKRti::DtInetAddr webServerHost, int webServerPort, const char *federateName=0)
	Add a federate to the federation.
virtual DtFederate *	createFederate (const char *federateType, const char *federateName, const char *fedHostname, DtFederateHandle handle, unsigned long connHandle, MAKRti::DtInetAddr host, DtHlaVersionId hlaVersion, MAKRti::DtInetAddr webServerHost, int webServerPort)
	Create a new federate.
virtual bool	isMember (DtFederateHandle handle) const
	Returns true if the given federate is a member of this federation.
virtual bool	deleteFederate (DtFederateHandle handle)
	Removes the indicated federate from the federation execution, and deletes the corresponding DtFederate object.
virtual bool	processCreateReady ()
	Federation Execution Processing.
virtual void	processJoin (unsigned long connID, const DtFedJoinInfo *fedInfo)
	Process a join.
virtual void	processJoinReady ()
	Perform processing when a join is ready.
virtual void	destroyDistributor ()
	Destroy Fed File Distributor for federation.
virtual DtAsyncFileDistributorRunnable *	distributor () const
	Return a pointer to the distributor.
virtual unsigned int	numberFederatesAllowed (unsigned int numPartners) const
	Given the number of partners allowed by a joining federate, determines the number of federates allowed in the federation.
virtual void	resetControl ()
	Reset control.
virtual bool	tickDistributor ()
	Tick the distributor.
virtual bool	processEvents ()
	Process events from asynchronous thread.
DtFedReader *	getReader (DtFomType theFomType)
DtFedReader *	getReader (DtFomType theFomType, DtFomClassMgr *target)
void	populateWithUnknownFoms (std::vector< DtString > &mods, std::vector< DtString > &requestedMods)
bool	isFomAvailable (const DtString &fomName)
bool	doesCrcMatchKnownFomModuleCrc (const DtString &fomName, unsigned int myTakenFomCrc)
virtual bool	fedFileReady (const MAKRti::DtString &fileName) const
	Return boolean: File has been received and is ready to process.
virtual bool	fedFilesReady (const std::vector< MAKRti::DtString > *fileNames) const
	Return boolean: Files have been received and is ready to process.
virtual bool	addJoinFomModuleForConnection (unsigned long connId, const std::vector< MAKRti::DtString > &modulesFromJoinRequest)
	Add the given FOM Module request to the given connection's list.
virtual void	removeJoinFomModuleForConnection (unsigned long connID)
	Remove the given FOM Module request to the given connection's list.
virtual void	tickSaveRestore ()
	Tick actions.
virtual void	tickJoin ()
	Periodically send a join response to prod unconfirmed federate joins This polling mechanism compensates for dropped messages.
virtual void	tickFederates ()
	Check if the interval since the last heartbeat for any federate has exceeded the timeout.
virtual void	retireSyncPoint (const char *name)
	DtTIME.
virtual void	announceAllSyncPoints (DtFederateHandle hand)
	Called when new federates join to announce to them all of the currently existing synch points that involve them.
virtual void	checkTimedSave ()
	Initiate save if conditions for timed save have been meet.
virtual void	initiateSave (const char *label)
	Initiates the save of the federation, including the fedex.
virtual bool	save (const char *label)
	saves the fedex Return boolean: save was successful?
virtual int	verifyRestore (const char *label)
	verifies the restore label
virtual bool	restore (const char *label)
	restores the fedex Return boolean: save was successful?
virtual void	endSave (DtSaveFinishedResult result)
	finish the save
virtual void	endRestore (DtEndRestoreResult restoreResult)
	finish the restore
virtual DtString &	getSaveFileName (const char *label, MAKRti::DtString &fileName, bool extendName=true)
	Create a restore file name from the label and return in supplied parameter.
virtual DtString &	getRestoreFileName (const char *label, MAKRti::DtString &fileName)
	Create a restore file name from the label and return in supplied parameter.
virtual int	getNextFreeFedHandle ()
	Used internally to get the next available Federate Id within this federation.
	DtFedExec ()
	Default Ctor disabled.
	DtFedExec (const DtFedExec &orig)
	Copy and assignment operators are disabled.
DtFedExec &	operator= (DtFedExec const &orig)
RTI message callbacks
Actual methods used to process message callbacks
virtual void	processJoinMsg (const DtJoinMsg &msg)
virtual bool	handleJoinFailureCases (const DtJoinMsg &msg)
virtual void	requestFedFileUpload (const DtJoinMsg &msg)
virtual void	processJoinConfirm (const DtJoinConfirmMsg &msg)
virtual void	processAlive (const DtAliveMsg &msg)
virtual void	processResign (const DtResignMsg &msg)
virtual void	processSyncPoint (const DtSyncPointMsg &msg)
virtual void	processSyncPointQuery (const DtSyncPointQueryMsg &msg)
virtual void	processSaveRequest (const DtSaveRequestMsg &msg)
virtual void	processInitiatedSave (const DtInitiatedSaveMsg &msg)
virtual void	processSaveComplete (const DtSaveCompleteMsg &msg)
virtual void	processSaveBegun (const DtSaveBegunMsg &msg)
virtual void	processAbortSave (const DtAbortSaveMsg &msg)
virtual void	processRestoreRequest (const DtRestoreRequestMsg &msg)
virtual void	processRestoreBegun (const DtRestoreBegunMsg &msg)
virtual void	processRestoreComplete (const DtRestoreCompleteMsg &msg)
virtual void	processAbortRestore (const DtAbortRestoreMsg &msg)
virtual void	processOwnership (const DtOwnershipMsg &msg)
virtual void	processReserveName (DtReserveNameMsg const &msg)
virtual void	processReserveMultiName (DtReserveMultiNameMsg const &msg)
virtual void	processReleaseMultiName (DtReleaseMultiNameMsg const &msg)
virtual void	processQuerySaveStatus (DtQuerySaveStatusMsg const &msg)
virtual void	processQueryRestoreStatus (DtQueryRestoreStatusMsg const &msg)
Send RTI messages
Send an RTI message of the appropriate kind with the given parameters.
virtual void	sendSyncPointMsg (DtSyncMsgType kind, int id, DtSyncPointStatus status, const char *name, RTINAMESPACE::VariableLengthData const *theTag=NULL, const DtFederateHandleSet *set=NULL, const DtFederateHandleSet *unsuccessfulSet=NULL)
virtual void	sendResignMsg (const char *name, DtFederateHandle fedHandle, DtResignAction action, DtResignReason reason, const DtTimeInfo *timeInfo)
virtual void	sendEnableDisableNetworkTestingMsg (const char *name, bool enabled)
virtual void	sendTransferRidParamsMsg (const char *name, DtFederateHandle fedHandle, const DtString &paramString)
virtual void	sendJoinResponseMsg (unsigned long destinationIDValue, unsigned short requestID, unsigned int crcOfFedFile, DtFederateHandle handle, const char *federateName, int fedExHandle, const char *fedExName, const DtString &momModule, const std::vector< MAKRti::DtString > &modules, unsigned long flags, bool allowNetworkTesting, bool enableNetworkTesting, DtHlaVersionId hlaVers, DtJoinResponseMsg::errorCodes errorValue=DtJoinResponseMsg::DT_NO_ERROR, const DtString &errorString=DtString::nullString())
virtual void	sendSaveInitiateMsg (const char *labelVal)
virtual void	sendSaveInitiateConstrainedMsg (const char *labelVal)
virtual void	sendSaveResponse (DtFederateHandle fedHandle, unsigned long requestID, const char *labelVal, DtSaveResponseFlag response)
virtual void	sendDesignatedFederate (DtFederateHandle fedHandle)
virtual void	sendNameReservedMsg (DtFederateHandle requestingFederate, char const *objectName, bool result)
virtual void	sendMultiNameReservedMsg (DtFederateHandle requestingFederate, std::set< std::wstring > const &objectNames, bool result)
virtual void	sendRestoreStatus (DtFederateHandle requestingFederate, RTINAMESPACE::FederateRestoreStatusVector const &restoreStatusList)
virtual void	sendSaveStatus (DtFederateHandle requestingFederate, RTINAMESPACE::FederateHandleSaveStatusPairVector const &saveStatusList)
Protected Attributes
DtConnectionMgr *	myConnectionMgr
unsigned int	myCrcOfFedFile
int	myFreeFedHandle
bool *	myFedHandlesInUse
DtString	myFedExName
DtFederateHandleInfoMap	myFederates
DtFederateNameInfoMap	myFederatesByName
std::map< MAKRti::DtString, DtFederateHandle >	myFederateHdlsByName
int	myNumFederates
DtSyncHashlist	mySyncList
DtString	myMomModule
unsigned int	myMomModuleCrc
std::vector< unsigned int >	myCreationFedFilesCRCs
MAKRti::DtFomType	myFedType
std::vector< DtString >	myFomModules
std::map< DtString, unsigned int >	myFomModulesNameToCrcMap
std::set< DtString >	myFomModulesSet
std::vector< DtString >	myCreateFomModules
std::map< unsigned long, const std::vector< DtString > * >	myJoinFomModules
DtFomClassMgr *	myFom
int	myFedExHandle
DtFederateHandle	myDesignatedFederate
float	myFederateTimeoutInterval
std::set< unsigned long >	myConnectionsProcessJoined
std::map< DtFederateHandle, DtFedJoinInfo * >	myJoiningFederates
	List of joining federates for which a join confirm is expected.
std::map< unsigned long, DtFedJoinInfo * >	myJoiningFederatesByID
int	myNumberResponseAttempts
	Response interval from params is divided by this number.
float	myResponseInterval
	to obtain response retransmission interval
bool	mySave
bool	myRestore
std::set< DtFederateHandle >	myFederateSaveList
DtFederateHandleStdSet	myInitiatedSaveFederates
DtString	mySaveLabel
DtFederateHandle	mySavingFederate
DtFederateHandleInfoMap	myFedRestoreList
std::map< DtFederateHandle, unsigned long >	myRestoreConnectIdMap
std::map< DtFederateHandle, MAKRti::DtInetAddr >	myRestoreHostAddrMap
DtString	mySavePath
bool	mySavePending
bool	mySaveBegun
std::map< DtString, DtFileInformation * >	myTakenFiles
	until requester takes them.
bool	myAwaitingCreateUpload
unsigned long	myCreatorConnId
std::set< unsigned long >	myAwaitingJoinUpload
bool	myFullyCreated
int	myTimeout
int	myDefaultWait
DtList	myJoinCallbacks
DtList	myResignCallbacks
DtList	myDisconnectCallbacks
DtList	myReconnectSucceededCallbacks
DtList	myReconnectFailedCallbacks
DtList	myFedSynchronizedCallbacks
DtList	mySpAchievedCallbacks
DtList	mySpRegisterCallbacks
DtFedExReservedNameSet	myReservedNames
DtFedExFederateReservedNameMap	myFederateReservedNames
vrlmod::DtThreadedObject *	myDistributorThread
	DtTIME.
DtAsyncFileDistributorRunnable *	myDistributor
bool	myDistributeFedFile
bool	myCrcCheckFedFile
unsigned long	myInitiatorID
int	myStrictNameReservation
bool	myAllowNetworkTesting
	Whether network testing is enabled or completely disabled by the RID.
bool	myNetworkTestingEnabled
	Whether network testing has been toggled on/off by the assistant.
DtClock	myClock
unsigned int	myNumberFederatesAllowed
DtFedReader13 *	myFedReader13
DtFedReader1516 *	myFedReader1516
DtFedReader1516e *	myFedReader1516e
Static Protected Attributes
static const std::vector < DtString >	theEmptyStringSet = std::vector<DtString>()
static DtFedExecCreator	theCreator = NULL
Private Attributes
bool	myFullFedFileDistribution
Static Private Attributes
static const DtString	nullStr = ""

---

Member Typedef Documentation

typedef std::map< DtFederateHandle, DtFedExReservedNameSet > DtFedExec::DtFedExFederateReservedNameMap [protected]

typedef std::set<std::string> DtFedExec::DtFedExReservedNameSet [protected]

---

Constructor & Destructor Documentation

DtFedExec::DtFedExec	(	DtConnectionMgr *	connMgr,
		const std::vector< unsigned int > &	crcs,
		DtString const &	fedExName,
		std::string const &	timeImplName,
		MAKRti::DtFomType	fedType,
		const DtString &	momModuleName,
		const std::vector< DtString > &	modules,
		int	fedExHandle,
		DtRIDParameters *	params,
		unsigned int	momModuleCrc
	)		[protected]

Constructor.

References DtAbortRestoreMsg::addCallback(), DtQueryRestoreStatusMsg::addCallback(), DtQuerySaveStatusMsg::addCallback(), DtSaveTimeAdvanceMsg::addCallback(), DtInitiatedSaveMsg::addCallback(), DtSaveBegunMsg::addCallback(), DtAbortSaveMsg::addCallback(), DtAliveMsg::addCallback(), DtRestoreRequestMsg::addCallback(), DtRestoreCompleteMsg::addCallback(), DtSaveRequestMsg::addCallback(), DtSaveCompleteMsg::addCallback(), DtReserveMultiNameMsg::addCallback(), DtReleaseMultiNameMsg::addCallback(), DtRestoreBegunMsg::addCallback(), DtJoinConfirmMsg::addCallback(), DtSyncPointQueryMsg::addCallback(), DtResignMsg::addCallback(), DtJoinMsg::addCallback(), DtOwnershipMsg::addCallback(), DtSyncPointMsg::addCallback(), connectMgr(), DtRIDParameters::dataDistMgmt, DtToWString(), DtRIDParameters::enableFederateHeartbeat, fedExHandle(), DtRIDParameters::fullFedFileDistribution, DtRtiMtdDestinationList::getMaxDestinations(), myDefaultWait, myFederateTimeoutInterval, myFedExHandle, myFedHandlesInUse, myFomModules, myFomModulesNameToCrcMap, myFomModulesSet, myFreeFedHandle, myFullFedFileDistribution, myMomModule, myNumberResponseAttempts, myNumFederates, myResponseInterval, myRestore, mySave, mySavePath, myTimeout, NULL, processAbortRestore(), processAbortSave(), processAlive(), processInitiatedSave(), processJoinConfirm(), processJoinMsg(), processOwnership(), processQueryRestoreStatus(), processQuerySaveStatus(), processReleaseMultiName(), processReserveMultiName(), processReserveName(), processResign(), processRestoreBegun(), processRestoreComplete(), processRestoreRequest(), processSaveBegun(), processSaveComplete(), processSaveRequest(), processSyncPoint(), processSyncPointQuery(), DtRIDParameters::responseInterval, DtRIDParameters::saveRestoreDirectoryPath(), and DtInteractionMsg::setChannelIncluded().

DtFedExec::~DtFedExec

(

)

[virtual]

Destructor.

References connectMgr(), destroyDistributor(), DtSyncHashlist::empty(), myFederateHdlsByName, myFederates, myFederatesByName, myFedHandlesInUse, myFedReader13, myFedReader1516, myFedReader1516e, myJoinFomModules, myJoiningFederates, myJoiningFederatesByID, mySyncList, NULL, processAbortRestore(), processAbortSave(), processAlive(), processInitiatedSave(), processJoinConfirm(), processJoinMsg(), processOwnership(), processQueryRestoreStatus(), processQuerySaveStatus(), processReleaseMultiName(), processReserveMultiName(), processReserveName(), processResign(), processRestoreBegun(), processRestoreComplete(), processRestoreRequest(), processSaveBegun(), processSaveComplete(), processSaveRequest(), processSyncPoint(), processSyncPointQuery(), DtAbortRestoreMsg::removeCallback(), DtQuerySaveStatusMsg::removeCallback(), DtQueryRestoreStatusMsg::removeCallback(), DtInitiatedSaveMsg::removeCallback(), DtSaveTimeAdvanceMsg::removeCallback(), DtSaveBegunMsg::removeCallback(), DtAbortSaveMsg::removeCallback(), DtAliveMsg::removeCallback(), DtRestoreRequestMsg::removeCallback(), DtRestoreCompleteMsg::removeCallback(), DtSaveRequestMsg::removeCallback(), DtSaveCompleteMsg::removeCallback(), DtReleaseMultiNameMsg::removeCallback(), DtReserveMultiNameMsg::removeCallback(), DtRestoreBegunMsg::removeCallback(), DtJoinConfirmMsg::removeCallback(), DtSyncPointQueryMsg::removeCallback(), DtResignMsg::removeCallback(), DtJoinMsg::removeCallback(), DtOwnershipMsg::removeCallback(), and DtSyncPointMsg::removeCallback().

DtFedExec::DtFedExec

(

)

[protected]

Default Ctor disabled.

Referenced by create().

DtFedExec::DtFedExec

(

const DtFedExec &

orig

)

[protected]

Copy and assignment operators are disabled.

---

Member Function Documentation

DtFederate * DtFedExec::addFederate	(	const char *	federateType,
		const char *	fedHostName,
		DtFederateHandle	handle,
		unsigned long	connHandle,
		MAKRti::DtInetAddr	host,
		DtHlaVersionId	hlaVersion,
		MAKRti::DtInetAddr	webServerHost,
		int	webServerPort,
		const char *	federateName = 0
	)		[protected, virtual]

Add a federate to the federation.

References createFederate(), DtNoRestoreInProgress, DtNoSaveInProgress, DtFederate::getHandle(), DtFederate::getName(), FedCallbackInfo::myData, myFederateHdlsByName, myFederates, myFederatesByName, FedCallbackInfo::myFn, myJoinCallbacks, myNumFederates, DtFederate::setRestoreStatus(), and DtFederate::setSaveStatus().

Referenced by processJoinConfirm(), and restore().

void DtFedExec::addFederateDisconnectedCallback	(	DtFederateCbFn	fn,
		void *	usr
	)		[virtual]

Register callbacks for federate disconnected.

References myDisconnectCallbacks.

Referenced by DtRtiexecObserverMgr::federationCreatedCallback().

void DtFedExec::addFederateJoinedCallback	(	DtFederateCbFn	fn,
		void *	usr
	)		[virtual]

Register callback to be invoked whenever a federate joins a federation.

References myJoinCallbacks.

Referenced by DtRtiexecObserverMgr::federationCreatedCallback().

void DtFedExec::addFederateReconnectFailedCallback	(	DtFederateCbFn	fn,
		void *	usr
	)		[virtual]

References myReconnectFailedCallbacks.

Referenced by DtRtiexecObserverMgr::federationCreatedCallback().

void DtFedExec::addFederateReconnectSucceededCallback	(	DtFederateCbFn	fn,
		void *	usr
	)		[virtual]

References myReconnectSucceededCallbacks.

Referenced by DtRtiexecObserverMgr::federationCreatedCallback().

void DtFedExec::addFederateResignedCallback	(	DtFederateCbFn	fn,
		void *	usr
	)		[virtual]

Register callback to be invoked whenever a federate resigns a federation.

References myResignCallbacks.

Referenced by DtRtiexecObserverMgr::federationCreatedCallback().

void DtFedExec::addFederationSynchronizedCallback	(	DtSyncPointCbFn	fn,
		void *	usr
	)		[virtual]

Register a callback to be invoked whenever all federates has achieved a sync point.

References myFedSynchronizedCallbacks.

Referenced by DtRtiexecObserverMgr::federationCreatedCallback().

bool DtFedExec::addJoinFomModuleForConnection	(	unsigned long	connId,
		const std::vector< MAKRti::DtString > &	modulesFromJoinRequest
	)		[protected, virtual]

Add the given FOM Module request to the given connection's list.

References connectMgr(), fomModuleMerging, myFomModulesSet, and myJoinFomModules.

Referenced by requestFedFileUpload().

void DtFedExec::addSyncPtAchievedCallback	(	DtSyncPointAchievedCbFn	fn,
		void *	usr
	)		[virtual]

Register a callback to be invoked whenever a federate has achieved a sync point.

References mySpAchievedCallbacks.

Referenced by DtRtiexecObserverMgr::federationCreatedCallback().

void DtFedExec::addSyncPtRegisteredCallback	(	DtSyncPointCbFn	fn,
		void *	usr
	)		[virtual]

Register a callback to be invoked whenever a new sync point has been registered.

References mySpRegisterCallbacks.

Referenced by DtRtiexecObserverMgr::federationCreatedCallback().

void DtFedExec::announceAllSyncPoints

(

DtFederateHandle

hand

)

[protected, virtual]

Called when new federates join to announce to them all of the currently existing synch points that involve them.

References DtAnnouncePt, DtSyncStatusSucceeded, DtSyncPt::federates(), DtFederateHandleSet::isMember(), DtSyncHashlist::list(), mySyncList, DtSyncPt::name(), NULL, sendSyncPointMsg(), and DtSyncPt::tag().

Referenced by processJoinConfirm().

void DtFedExec::changeLatencyTestMode	(	DtFederateHandle	handle,
		bool	runTest,
		bool	continuous,
		bool	haltContinuous,
		bool	observing,
		unsigned int	interactionPeriod,
		unsigned int	numInteractions,
		unsigned int	payloadBytes
	)		[virtual]

Changes the latency test mode for the specified federate.

References connectMgr(), DtConnectionMgr::create(), DtChangeLatencyTestModeMsgKind, myFedExHandle, DtConnectionMgr::sendAndDelete(), DtChangeLatencyTestModeMsg::setContinuousUpdate(), DtRtiMsg::setFedEx(), DtChangeLatencyTestModeMsg::setInitiator(), DtChangeLatencyTestModeMsg::setInteractionPeriod(), DtChangeLatencyTestModeMsg::setNumInteractions(), DtChangeLatencyTestModeMsg::setObservingResults(), DtChangeLatencyTestModeMsg::setPayloadBytes(), DtChangeLatencyTestModeMsg::setRunTest(), and DtChangeLatencyTestModeMsg::setShouldHaltContinuous().

Referenced by DtLatencyTestModeCmd::operator()().

void DtFedExec::checkTimedSave

(

)

[protected, virtual]

Initiate save if conditions for timed save have been meet.

References initiateSave(), mySaveLabel, and mySavePending.

DtConnectionMgr * DtFedExec::connectMgr

(

)

[inline, virtual]

Returns the connection mgr.

References myConnectionMgr.

Referenced by addJoinFomModuleForConnection(), changeLatencyTestMode(), DtFedexTakeFileCmd::createNamesOnlyTakeFileEvent(), DtFedExec(), endRestore(), endSave(), processCreateReady(), processJoin(), processJoinMsg(), processOwnership(), processResign(), processRestoreBegun(), processRestoreRequest(), pushFomModuleToSingleFederate(), removeFederateConnection(), requestFedFileUpload(), restoreFederateConnection(), sendDesignatedFederate(), sendEnableDisableNetworkTestingMsg(), sendJoinResponseMsg(), sendMultiNameReservedMsg(), sendNameReservedMsg(), sendResignMsg(), sendRestoreStatus(), sendSaveInitiateConstrainedMsg(), sendSaveInitiateMsg(), sendSaveResponse(), sendSaveStatus(), sendSyncPointMsg(), sendSyncPointReport(), sendSyncPointStatusReport(), sendTransferRidParamsMsg(), tickFederates(), and ~DtFedExec().

DtFedExec * DtFedExec::create	(	DtConnectionMgr *	connMgr,
		const std::vector< unsigned int > &	crcs,
		DtString const &	fedExName,
		std::string const &	timeImplName,
		MAKRti::DtFomType	fedType,
		DtString const &	momModuleName,
		const std::vector< DtString > &	fomModules,
		int	fedExHandle,
		DtRIDParameters *	params,
		unsigned int	momModuleCrc
	)		[static]

Creates an instance of a DtFedExec;.

References DtFedExec(), fedExHandle(), fedExName(), fomModules(), and theCreator.

Referenced by createFederate(), and setCreatorFunction().

void DtFedExec::createDistributor	(	const unsigned long	initiatingFedID,
		const DtString &	momModuleName,
		const std::vector< DtString > &	fomModules
	)		[virtual]

Create Fed File Distributor for federation.

References DtFomModuleRequestMsg::addCallback(), DtFomModuleDistributionMsg::addCallback(), multFileReceivedCb(), multFileRequestedCb(), myAwaitingCreateUpload, myConnectionMgr, myCreateFomModules, myCreatorConnId, myDistributor, myDistributorThread, myFedExHandle, myFullFedFileDistribution, myInitiatorID, myMomModule, populateWithUnknownFoms(), DtAsyncFileDistributorRunnable::postCommand(), DtAsyncFileDistributorRunnable::registerFedFileRequestsEvent(), DtAsyncFileDistributorRunnable::registerPushFedFileToFederatesEvent(), DtAsyncFileDistributorRunnable::registerRequestedModulesArrivedEvent(), DtAsyncFileDistributorRunnable::registerTakeFileEvent(), DtFileDistributor::setFedexHandle(), DtFileDistributor::setFedHandle(), and vrlmod::DtThreadedObject::start().

Referenced by DtRtiExec::processCreate().

DtFederate * DtFedExec::createFederate	(	const char *	federateType,
		const char *	federateName,
		const char *	fedHostname,
		DtFederateHandle	handle,
		unsigned long	connHandle,
		MAKRti::DtInetAddr	host,
		DtHlaVersionId	hlaVersion,
		MAKRti::DtInetAddr	webServerHost,
		int	webServerPort
	)		[protected, virtual]

Create a new federate.

Override this function when overriding DtFederate.

References create(), and mySyncList.

Referenced by addFederate().

const std::vector< DtString > & DtFedExec::createFomModules

(

)

const [protected, virtual]

Returns the joinfomModules names associated w/ the fedex.

References myCreateFomModules.

void DtFedExec::createSyncPoint

(

const DtSyncPointMsg &

msg

)

[protected, virtual]

Create a sync point.

References DtFederate::addFederateSyncPt(), DtSyncHashlist::addSyncPoint(), DtSyncPointMsg::federates(), DtFederate::getHandle(), DtFederateHandleSet::isMember(), SpCallbackInfo::myData, myFederates, SpCallbackInfo::myFn, mySpRegisterCallbacks, mySyncList, DtSyncPointMsg::syncPointName(), and DtSyncPointMsg::tag().

Referenced by processRegisterSyncPoint().

unsigned long DtFedExec::creatorID

(

)

const [virtual]

Set the ID for who created this federation execution.

References myCreatorConnId.

Referenced by DtRtiExec::removeDroppedFederateConnections().

bool DtFedExec::deleteFederate

(

DtFederateHandle

handle

)

[protected, virtual]

Removes the indicated federate from the federation execution, and deletes the corresponding DtFederate object.

References DtRtiMtdDestinationList::destinationIndex(), DtFederate::getConnectionHandle(), getFederate(), DtFederate::getName(), FedCallbackInfo::myData, myDesignatedFederate, myFederateHdlsByName, myFederateReservedNames, myFederates, myFederatesByName, myFedHandlesInUse, FedCallbackInfo::myFn, myJoinFomModules, myNumFederates, myReservedNames, myResignCallbacks, myStrictNameReservation, resetControl(), and DtRtiMsg::smartForwardingEnabled().

Referenced by processResign().

void DtFedExec::destroyDistributor

(

)

[protected, virtual]

Destroy Fed File Distributor for federation.

References multFileReceivedCb(), multFileRequestedCb(), myConnectionMgr, myDistributeFedFile, myDistributor, myDistributorThread, DtFomModuleRequestMsg::removeCallback(), DtFomModuleDistributionMsg::removeCallback(), and vrlmod::DtThreadedObject::stop().

Referenced by ~DtFedExec().

void DtFedExec::disableNetworkTesting

(

)

[virtual]

Disable network testing at federate.

References myFedExName, myNetworkTestingEnabled, and sendEnableDisableNetworkTestingMsg().

Referenced by DtEnableDisableNetworkTestingCmd::operator()().

void DtFedExec::disconnectFederate

(

DtFederate *

fed

)

[virtual]

Mark federate as attempting to reconnect.

References FedCallbackInfo::myData, myDisconnectCallbacks, and FedCallbackInfo::myFn.

Referenced by DtRtiExec::processDisconnect().

DtAsyncFileDistributorRunnable * DtFedExec::distributor

(

)

const [protected, virtual]

Return a pointer to the distributor.

References myDistributor.

bool DtFedExec::doesCrcMatchKnownFomModuleCrc	(	const DtString &	fomName,
		unsigned int	myTakenFomCrc
	)		[protected]

References myFomModulesNameToCrcMap, and myMomModuleCrc.

Referenced by isFomAvailable().

void DtFedExec::enableNetworkTesting

(

)

[virtual]

Enable network testing at federate.

References myFedExName, myNetworkTestingEnabled, and sendEnableDisableNetworkTestingMsg().

Referenced by DtEnableDisableNetworkTestingCmd::operator()(), and sendJoinResponseMsg().

void DtFedExec::endRestore

(

DtEndRestoreResult

restoreResult

)

[protected, virtual]

finish the restore

References connectMgr(), DtConnectionMgr::create(), DtNoRestoreInProgress, DtRestoreEndMsgKind, DtRestoreResultSucess, DtRestoreResultUnableToRestore, myClock, myFederates, myFederateSaveList, myFederateTimeoutInterval, myFedExHandle, myFedRestoreList, myRestore, myRestoreConnectIdMap, myRestoreHostAddrMap, mySaveLabel, myTimeout, restore(), DtConnectionMgr::sendAndDelete(), DtRestoreEndMsg::set(), DtFederate::setFederateHeartbeat(), DtRtiMsg::setFedEx(), and DtFederate::setRestoreStatus().

Referenced by processAbortRestore(), processResign(), processRestoreBegun(), processRestoreComplete(), and tickSaveRestore().

void DtFedExec::endSave

(

DtSaveFinishedResult

result

)

[protected, virtual]

finish the save

References connectMgr(), DtConnectionMgr::create(), DtNoSaveInProgress, DtSaveFinishedMsgKind, DtSaveFinishedRtiUnableToSave, DtSaveFinishedSuccess, myClock, myFederates, myFederateSaveList, myFederateTimeoutInterval, myFedExHandle, myInitiatedSaveFederates, mySave, mySaveBegun, mySaveLabel, mySavePending, myTimeout, save(), DtConnectionMgr::sendAndDelete(), DtSaveFinishedMsg::set(), DtFederate::setFederateHeartbeat(), DtRtiMsg::setFedEx(), and DtFederate::setSaveStatus().

Referenced by processAbortSave(), processResign(), processSaveComplete(), and tickSaveRestore().

DtFederateHandle DtFedExec::federateHandleOfConnection

(

unsigned long

connId

)

const [virtual]

Return the connection's federate handle if joined to this federation; otherwise, 0.

References DtFederate::getConnectionHandle(), DtFederate::getHandle(), myFederates, and myJoiningFederatesByID.

Referenced by DtRtiExec::processDisconnect().

DtFederateHandleInfoMap const & DtFedExec::federates

(

)

const [inline, virtual]

Returns the list of federates for this fed exec.

References myFederates.

Referenced by DtRtiexecObserverForWebService::processSyncPtRegisteredEvent(), DtRtiexecObserverForAssistant::processSyncPtRegisteredEvent(), DtRtiexecObserverForWebService::processTimeStateEvent(), and DtRtiexecObserverForAssistant::processTimeStateEvent().

int DtFedExec::fedExHandle

(

)

const [virtual]

Returns the handle of this federation execution.

References myFedExHandle.

Referenced by create(), DtRtiExec::destroyFederationByName(), DtFedExec(), handleJoinFailureCases(), DtDestroyFederationCmd::operator()(), DtRtiExec::processCreate(), DtRtiexecObserverForWebService::processFederateJoinedEvent(), DtRtiexecObserverForWebService::processFederateResignedEvent(), DtRtiexecObserverForWebService::processFederationSynchronizedEvent(), DtRtiexecObserverForWebService::processFedExCreatedEvent(), DtRtiexecObserverForAssistant::processFedExCreatedEvent(), DtRtiexecObserverForWebService::processFedExDestroyedEvent(), DtRtiexecObserverForAssistant::processFedExDestroyedEvent(), processJoin(), processJoinMsg(), processOwnership(), DtRtiExec::processQueueFull(), processRestoreBegun(), processRestoreRequest(), DtRtiexecObserverForWebService::processSyncPtAchievedEvent(), DtRtiexecObserverForWebService::processSyncPtRegisteredEvent(), restoreFederateConnection(), sendDesignatedFederate(), sendMultiNameReservedMsg(), sendNameReservedMsg(), sendRestoreStatus(), sendSaveInitiateConstrainedMsg(), sendSaveInitiateMsg(), sendSaveResponse(), sendSaveStatus(), sendSyncPointStatusReport(), and tickJoin().

const DtString & DtFedExec::fedExName

(

)

const [inline, virtual]

Returns the name of the this federation execution.

References myFedExName.

Referenced by create(), DtRtiExec::deleteFederate(), processCreateReady(), DtRtiExec::processDisconnect(), DtRtiexecObserverForAssistant::processFederateDisconnectedEvent(), DtRtiexecObserverForAssistant::processFederateJoinedEvent(), DtRtiexecObserverForAssistant::processFederateReconnectFailedEvent(), DtRtiexecObserverForAssistant::processFederateReconnectSucceededEvent(), DtRtiexecObserverForAssistant::processFederateResignedEvent(), DtRtiexecObserverForAssistant::processFederationSynchronizedEvent(), DtRtiexecObserverForWebService::processFedExCreatedEvent(), DtRtiexecObserverForAssistant::processFedExCreatedEvent(), DtRtiexecObserverForAssistant::processFedExDestroyedEvent(), processJoin(), processJoinConfirm(), processResign(), DtRtiexecObserverForAssistant::processSyncPtAchievedEvent(), DtRtiexecObserverForAssistant::processSyncPtRegisteredEvent(), DtRtiExec::removeDroppedFederateConnections(), removeFederateConnection(), restoreFederateConnection(), DtRtiExec::tick(), tickFederates(), and tickJoin().

const DtString & DtFedExec::fedFileName

(

)

const [virtual]

Returns the name of the FED file that was associated with the federation execution at creation time.

References myFomModules, and nullStr.

Referenced by DtRtiexecObserverForWebService::processFedExCreatedEvent(), and DtRtiexecObserverForAssistant::processFedExCreatedEvent().

bool DtFedExec::fedFileReady

(

const MAKRti::DtString &

fileName

)

const [protected, virtual]

Return boolean: File has been received and is ready to process.

References myTakenFiles.

Referenced by fedFilesReady(), and processCreateReady().

bool DtFedExec::fedFilesReady

(

const std::vector< MAKRti::DtString > *

fileNames

)

const [protected, virtual]

Return boolean: Files have been received and is ready to process.

References fedFileReady().

Referenced by processCreateReady(), and processJoinReady().

DtLogicalTimeFactory * DtFedExec::fedTimeFactory

(

)

[virtual]

Returns the time factory.

References NULL.

Referenced by DtRtiExec::processCreate().

const std::vector< DtString > & DtFedExec::fomModules

(

)

const [virtual]

Returns the fomModules names associated w/ the fedex.

References myFomModules.

Referenced by create(), DtRtiexecObserverForAssistant::processFederateJoinedEvent(), DtRtiexecObserverForAssistant::processFedExCreatedEvent(), processJoin(), processJoinMsg(), and tickJoin().

bool DtFedExec::fullyCreated

(

)

const [virtual]

Return boolean: Federation execution creation is complete.

References myFullyCreated.

Referenced by handleJoinFailureCases(), and DtRtiExec::removeDroppedFederateConnections().

DtFederate * DtFedExec::getFederate

(

DtFederateHandle

handle

)

[virtual]

Returns the DtFederate object representing the joined federate with the indicated handle.

References myFederates.

Referenced by DtRtiExec::deleteFederate(), deleteFederate(), DtDeleteFederateCmd::operator()(), DtChangeRidParamCmd::operator()(), DtLatencyTestModeCmd::operator()(), processAchievedSyncPoint(), processAlive(), DtRtiExec::processDisconnect(), processInitiatedSave(), DtRtiExec::processReconnect(), processRegisterSyncPoint(), processResign(), processRestoreComplete(), processRestoreRequest(), processSaveBegun(), processSaveComplete(), resignFederate(), and transferRidParams().

int DtFedExec::getNextFreeFedHandle

(

)

[protected, virtual]

Used internally to get the next available Federate Id within this federation.

References DtRtiMtdDestinationList::destinationIndex(), DtRtiMtdDestinationList::getMaxDestinations(), myFedHandlesInUse, myFreeFedHandle, and DtRtiMsg::smartForwardingEnabled().

Referenced by processJoinMsg().

DtFedReader * DtFedExec::getReader

(

DtFomType

theFomType

)

[protected]

References myFedReader13, myFedReader1516, myFedReader1516e, and NULL.

Referenced by getReader(), processCreateReady(), and processJoin().

DtFedReader * DtFedExec::getReader	(	DtFomType	theFomType,
		DtFomClassMgr *	target
	)		[protected]

References getReader().

DtString & DtFedExec::getRestoreFileName	(	const char *	label,
		MAKRti::DtString &	fileName
	)		[protected, virtual]

Create a restore file name from the label and return in supplied parameter.

Returns a reference to the supplied parameter

References getSaveFileName().

Referenced by restore(), and verifyRestore().

DtString & DtFedExec::getSaveFileName	(	const char *	label,
		MAKRti::DtString &	fileName,
		bool	extendName = true
	)		[protected, virtual]

Create a restore file name from the label and return in supplied parameter.

Returns a reference to the supplied parameter

References myFedExName, and mySavePath.

Referenced by getRestoreFileName(), and save().

bool DtFedExec::handleJoinFailureCases

(

const DtJoinMsg &

msg

)

[protected, virtual]

References DtJoinResponseMsg::DT_FEDEX_DOES_NOT_EXIST, DtJoinResponseMsg::DT_NAME_IN_USE, DtJoinResponseMsg::DT_PARTNER_TAKEN, DtJoinResponseMsg::DT_RESTORE_IN_PROGRESS, DtJoinResponseMsg::DT_SAVE_IN_PROGRESS, DtJoinResponseMsg::DT_TYPE_CONFLICT, DtJoinMsg::federateName(), fedExHandle(), DtJoinMsg::fullFedExName(), fullyCreated(), DtJoinMsg::hlaVersion(), myAllowNetworkTesting, myFederates, myFederatesByName, myFedExName, myJoiningFederates, myNetworkTestingEnabled, myNumberFederatesAllowed, myRestore, mySave, DtJoinMsg::needPartner(), numberFederatesAllowed(), DtJoinMsg::requestID(), sendJoinResponseMsg(), DtJoinMsg::sourceID(), and theEmptyStringSet.

Referenced by processJoinMsg().

void DtFedExec::init

(

DtRtiAssistantExecClient *

assistant

)

[static]

References DtRtiAssistantClient::getNewLicenseServerFromAssistant(), lm, DtAssistantPopupHelper::popupAssistantMessage(), r1, and DtRtiAssistantExecClient::updateLicenseServer().

Referenced by DtRtiexecObserverForAssistant::initialize().

void DtFedExec::initiateSave

(

const char *

label

)

[protected, virtual]

Initiates the save of the federation, including the fedex.

References DtInstructedToSave, myDefaultWait, myFederates, myFederateSaveList, myInitiatedSaveFederates, mySave, mySaveLabel, mySavePending, myTimeout, NULL, sendSaveInitiateConstrainedMsg(), sendSaveInitiateMsg(), and DtFederate::setSaveStatus().

Referenced by checkTimedSave(), and processSaveRequest().

bool DtFedExec::isFomAvailable

(

const DtString &

fomName

)

[protected]

References DtLibRTIUtil::crcOfBuff(), doesCrcMatchKnownFomModuleCrc(), DtReadFile(), myCrcCheckFedFile, myTakenFiles, and DtLibRTIUtil::openFedFile().

Referenced by populateWithUnknownFoms().

bool DtFedExec::isMember

(

DtFederateHandle

handle

)

const [protected, virtual]

Returns true if the given federate is a member of this federation.

References myFederates.

Referenced by processAbortRestore(), processAbortSave(), processInitiatedSave(), processOwnership(), processReserveMultiName(), processReserveName(), processRestoreBegun(), processRestoreComplete(), processRestoreRequest(), processSaveBegun(), processSaveComplete(), processSaveRequest(), processSyncPoint(), and processSyncPointQuery().

const std::map< unsigned long, const std::vector< DtString > * > & DtFedExec::joinFomModules

(

)

const [protected, virtual]

Returns the joinfomModules names associated w/ the fedex.

References myJoinFomModules.

const std::vector< DtString > & DtFedExec::joinFomModulesForConnection

(

unsigned long

connID

)

const [protected, virtual]

References myJoinFomModules, and theEmptyStringSet.

Referenced by processJoin(), processJoinConfirm(), processJoinMsg(), and processJoinReady().

void DtFedExec::multFileReceivedCb

(

const DtFomModuleDistributionMsg &

msg

)

File received callback... generates a distributor postCommand.

References DtFomModuleDistributionMsg::destination(), DtFomModuleDistributionMsg::fullFedExName(), myDistributor, myFedExName, DtAsyncFileDistributorRunnable::postCommand(), and DtFomModuleDistributionMsg::sourceID().

Referenced by createDistributor(), destroyDistributor(), multFileReceivedCb(), and DtFileReceivedEvent::processResults().

void DtFedExec::multFileReceivedCb	(	const DtFomModuleDistributionMsg &	msg,
		void *	usr
	)		[static]

File received callback... generates a distributor postCommand.

References multFileReceivedCb().

void DtFedExec::multFileRequestedCb

(

const DtFomModuleRequestMsg &

msg

)

File requested callback... generates a distributor postCommand.

References DtFomModuleRequestMsg::destinationID(), DtRtiMsg::fedExHandle(), myDistributor, myFedExHandle, DtAsyncFileDistributorRunnable::postCommand(), and DtFomModuleRequestMsg::sourceID().

Referenced by createDistributor(), destroyDistributor(), and multFileRequestedCb().

void DtFedExec::multFileRequestedCb	(	const DtFomModuleRequestMsg &	msg,
		void *	usr
	)		[static]

File requested callback... generates a distributor postCommand.

References multFileRequestedCb().

unsigned int DtFedExec::numberFederatesAllowed

(

unsigned int

numPartners

)

const [protected, virtual]

Given the number of partners allowed by a joining federate, determines the number of federates allowed in the federation.

The value 0 indicates no limit in both the input and return values. Returns: 0 if no partner limit; otherwise, the number of partners allowed in the federation.

References myNumberFederatesAllowed.

Referenced by handleJoinFailureCases().

int DtFedExec::numFederates

(

)

const [inline, virtual]

Returns the total number of federates joined to this federation.

References myNumFederates.

Referenced by DtRtiExec::destroyFederationByName().

DtFedExec& DtFedExec::operator=

(

DtFedExec const &

orig

)

[protected]

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

References isFomAvailable().

Referenced by createDistributor(), and requestFedFileUpload().

void DtFedExec::printFederates

(

)

[virtual]

Print the list of federates for each federation execution.

References DtFederate::getFederateHost(), DtFederate::getHandle(), DtFederate::getName(), DtFederate::getType(), DtFederate::isNamed(), and myFederates.

void DtFedExec::processAbortRestore	(	const DtAbortRestoreMsg &	msg,
		void *	usr
	)		[static]

Referenced by DtFedExec(), and ~DtFedExec().

void DtFedExec::processAbortRestore

(

const DtAbortRestoreMsg &

msg

)

[protected, virtual]

References DtRestoreResultAborted, endRestore(), DtRtiMsg::federateHandle(), DtRtiMsg::isForExec(), isMember(), myFedExHandle, myFedExName, and myRestore.

void DtFedExec::processAbortSave	(	const DtAbortSaveMsg &	msg,
		void *	usr
	)		[static]

Referenced by DtFedExec(), and ~DtFedExec().

void DtFedExec::processAbortSave

(

const DtAbortSaveMsg &

msg

)

[protected, virtual]

References DtSaveFinishedAborted, endSave(), DtRtiMsg::federateHandle(), DtRtiMsg::isForExec(), isMember(), myFedExHandle, myFedExName, and mySave.

void DtFedExec::processAchievedSyncPoint

(

const DtSyncPointMsg &

msg

)

[protected, virtual]

Process sync point achieved.

References DtAchieved, DtSynchronized, DtSyncStatusSucceeded, DtSyncPointMsg::federateId(), DtSyncPt::federates(), getFederate(), DtSyncHashlist::lookupSyncPoint(), mySyncList, DtSyncPt::name(), NULL, processSyncPtAchievedCallbacks(), retireSyncPoint(), sendSyncPointMsg(), DtFederate::setFederateSyncPtAchieved(), DtSyncPointMsg::syncMsgKind(), and DtSyncPointMsg::syncPointName().

Referenced by processSyncPoint().

void DtFedExec::processAlive	(	const DtAliveMsg &	msg,
		void *	usr
	)		[static]

Referenced by DtFedExec(), and ~DtFedExec().

void DtFedExec::processAlive

(

const DtAliveMsg &

msg

)

[protected, virtual]

References DtRtiMsg::federateHandle(), getFederate(), myClock, and DtFederate::setFederateHeartbeat().

bool DtFedExec::processCreateReady

(

)

[protected, virtual]

Federation Execution Processing.

Perform processing when create is ready

References DtScopedNotifyLevelChange::changeNotifyLevel(), connectMgr(), DtConnectionMgr::create(), DtFomClassMgr::create(), DtCreateResponseMsgKind, DtCRExecCouldNotOpenFed, DtCRExecCreated, DtMergeFomStatusSuccess, DtRIDParameters::dumpFed, dumpFed, extend13and1516interop, fedExName(), fedFileReady(), fedFilesReady(), getReader(), myAwaitingCreateUpload, myCreateFomModules, myCreatorConnId, myFom, myFullyCreated, myInitiatorID, myMomModule, myTakenFiles, DtConnectionMgr::params(), DtScopedNotifyLevelChange::restoreNotifyLevel(), DtConnectionMgr::sendAndDelete(), DtCreateResponseMsg::set(), and DtFomClassMgr::setExtend13and1516interop().

Referenced by tickDistributor().

bool DtFedExec::processEvents

(

)

[protected, virtual]

Process events from asynchronous thread.

References DtAsyncFileDistributorRunnable::getNextEvent(), myClock, myDistributor, and DtDistributorThreadEvent::processResults().

Referenced by tickDistributor().

void DtFedExec::processFederationSynchronizedCallbacks

(

DtSyncPt *

point

)

[protected, virtual]

Process the callbacks registered for federates achieving sync points.

References SpCallbackInfo::myData, myFedSynchronizedCallbacks, and SpCallbackInfo::myFn.

Referenced by retireSyncPoint().

void DtFedExec::processFedFileRequestMsg

(

const DtFedFileRequestMsgEvent &

e

)

[virtual]

Process FED file requests.

References DtMessageFactory< T_Message, T_MessageKind, T_NetworkHeader >::create(), DtFomModuleRequestMsgKind, DtConnectionMgr::msgFactory(), myConnectionMgr, myFedExHandle, myFedExName, DtFedFileRequestMsgEvent::myFileNames, DtFedFileRequestMsgEvent::myInitiatingID, DtConnectionMgr::sendAndDelete(), DtFomModuleRequestMsg::set(), DtRtiMsg::setFederateHandle(), and DtRtiMsg::setFedEx().

Referenced by DtFedFileRequestMsgEvent::processResults().

void DtFedExec::processFileTransfer

(

const DtFedExTakeFileEvent &

e

)

[virtual]

Process file transfers.

References DtFedExTakeFileEvent::myFileNames, and myTakenFiles.

Referenced by DtFedExTakeFileEvent::processResults().

void DtFedExec::processInitiatedSave	(	const DtInitiatedSaveMsg &	msg,
		void *	usr
	)		[static]

Referenced by DtFedExec(), and ~DtFedExec().

void DtFedExec::processInitiatedSave

(

const DtInitiatedSaveMsg &

msg

)

[protected, virtual]

References DtInstructedToSave, DtRtiMsg::federateHandle(), getFederate(), DtFederate::getHandle(), DtRtiMsg::isForExec(), isMember(), myFederates, myFedExHandle, myFedExName, myInitiatedSaveFederates, mySave, mySaveLabel, DtSortedListItem::next(), NULL, sendSaveInitiateMsg(), and DtFederate::setSaveStatus().

void DtFedExec::processJoin	(	unsigned long	connID,
		const DtFedJoinInfo *	fedInfo
	)		[protected, virtual]

Process a join.

References DtScopedNotifyLevelChange::changeNotifyLevel(), DtFomClassMgr::clone(), DtConnectionMgr::connectionId(), connectMgr(), DtFomClassMgr::create(), DtJoinResponseMsg::DT_FED_FILE_MERGE_PROBLEM, DtJoinResponseMsg::DT_FED_FILE_NOT_READY, DtJoinResponseMsg::DT_NO_ERROR, DtMergeFomStatusSuccess, dumpFed, extend13and1516interop, fedExHandle(), fedExName(), DtRIDParameters::fomModuleMerging, fomModules(), getReader(), joinFomModulesForConnection(), myAllowNetworkTesting, myConnectionMgr, myConnectionsProcessJoined, myCreationFedFilesCRCs, myDistributor, DtFedJoinInfo::myFederateName, DtFedJoinInfo::myFedExName, DtFedJoinInfo::myFedId, DtFileInformation::myFilePointer, DtFedJoinInfo::myFlags, myFom, DtFedJoinInfo::myHandle, DtFedJoinInfo::myHlaVersion, myJoiningFederates, myJoiningFederatesByID, myMomModule, myNetworkTestingEnabled, DtFedJoinInfo::myRequestID, myTakenFiles, DtConnectionMgr::params(), DtAsyncFileDistributorRunnable::postCommand(), removeJoinFomModuleForConnection(), resetControl(), sendJoinResponseMsg(), and DtFomClassMgr::setExtend13and1516interop().

Referenced by processJoinReady().

void DtFedExec::processJoinConfirm	(	const DtJoinConfirmMsg &	msg,
		void *	usr
	)		[static]

Referenced by DtFedExec(), and ~DtFedExec().

void DtFedExec::processJoinConfirm

(

const DtJoinConfirmMsg &

msg

)

[protected, virtual]

References addFederate(), announceAllSyncPoints(), DtRtiMtdDestinationList::destinationIndex(), DtJoinConfirmMsg::DtCouldNotCreateTimeFactory, DtJoinConfirmMsg::DtCrcMismatch, DtJoinConfirmMsg::DtFomError, DtJoinConfirmMsg::DtNoError, DtJoinConfirmMsg::DtTimedOut, DtJoinConfirmMsg::errorCode(), DtRtiMsg::federateHandle(), fedExName(), DtRIDParameters::fomModuleMerging, DtFederate::getDescription(), DtFederate::getHandle(), DtRtiMsg::isForExec(), joinFomModulesForConnection(), myClock, myConnectionMgr, myConnectionsProcessJoined, myDesignatedFederate, DtFedJoinInfo::myFederateHostName, DtFedJoinInfo::myFederateName, myFederateTimeoutInterval, DtFedJoinInfo::myFederateType, myFedExHandle, myFedExName, myFedHandlesInUse, DtFedJoinInfo::myFedId, DtFedJoinInfo::myHandle, DtFedJoinInfo::myHlaVersion, DtFedJoinInfo::myIpAddr, myJoiningFederates, myJoiningFederatesByID, mySaveLabel, mySavePending, DtFedJoinInfo::myWebServerAddr, DtFedJoinInfo::myWebServerPort, DtConnectionMgr::params(), resetControl(), sendDesignatedFederate(), DtFederate::setFederateHeartbeat(), DtRtiMsg::smartForwardingEnabled(), and DtJoinConfirmMsg::sourceID().

void DtFedExec::processJoinMsg	(	const DtJoinMsg &	msg,
		void *	usr
	)		[static]

Referenced by DtFedExec(), and ~DtFedExec().

void DtFedExec::processJoinMsg

(

const DtJoinMsg &

msg

)

[protected, virtual]

References connectMgr(), DtJoinResponseMsg::DT_CRC_FAILURE, DtJoinResponseMsg::DT_FAILED_TO_GET_LICENSE, DtJoinResponseMsg::DT_FED_FILE_MERGE_PROBLEM, DtJoinResponseMsg::DT_MAX_FEDERATES_JOINED, DtJoinResponseMsg::DT_RTIEXEC_LICENSING_PARAM_MISMATCH, DtJoinResponseMsg::DT_UNKNOWN_ERROR, DtGENERATE_KEY, DtJoinMsg::federateHostName(), DtJoinMsg::federateName(), DtJoinMsg::federateType(), fedExHandle(), DtRtiMsg::fedExHandle(), DtRtiMsg::fedExName(), DtJoinMsg::flags(), DtRIDParameters::fomModuleMerging, fomModuleMerging, fomModules(), DtJoinMsg::fullFedExName(), DtJoinMsg::getCRCsOfFedFiles(), DtJoinMsg::getFomModuleNames(), getNextFreeFedHandle(), handleJoinFailureCases(), DtJoinMsg::hlaVersion(), DtJoinMsg::ipAddress(), joinFomModulesForConnection(), lm, myAllowNetworkTesting, DtFedJoinInfo::myAttempts, myClock, myConnectionMgr, myCrcCheckFedFile, myCreationFedFilesCRCs, DtFedJoinInfo::myFederateHostName, DtFedJoinInfo::myFederateName, DtFedJoinInfo::myFedExName, DtFedJoinInfo::myFedId, myFomModules, myFomModulesNameToCrcMap, myFomModulesSet, DtFedJoinInfo::myHandle, DtFedJoinInfo::myHlaVersion, myJoinFomModules, myJoiningFederates, myJoiningFederatesByID, myMomModule, myNetworkTestingEnabled, DtFedJoinInfo::myNextSendTime, myNumberFederatesAllowed, DtFedJoinInfo::myRequestID, myResponseInterval, DtJoinMsg::needPartner(), DtConnectionMgr::params(), DtAssistantPopupHelper::popupAssistantMessage(), r1, removeJoinFomModuleForConnection(), requestFedFileUpload(), DtJoinMsg::requestID(), sendJoinResponseMsg(), DtJoinMsg::sourceID(), true, DtJoinMsg::webServerAddress(), and DtJoinMsg::webServerPort().

void DtFedExec::processJoinReady

(

)

[protected, virtual]

Perform processing when a join is ready.

References fedFilesReady(), joinFomModulesForConnection(), myAwaitingJoinUpload, myClock, myConnectionMgr, myConnectionsProcessJoined, myJoiningFederatesByID, DtConnectionMgr::params(), processJoin(), removeJoinFomModuleForConnection(), and DtRIDParameters::responseInterval.

Referenced by tickDistributor().

void DtFedExec::processOwnership	(	const DtOwnershipMsg &	msg,
		void *	usr
	)		[static]

Referenced by DtFedExec(), and ~DtFedExec().

void DtFedExec::processOwnership

(

const DtOwnershipMsg &

msg

)

[protected, virtual]

References connectMgr(), DtGiveToLRC, DtRtiMsg::federateHandle(), fedExHandle(), DtRtiMsg::isForExec(), isMember(), myFederates, myFedExHandle, myFedExName, DtOwnershipMsg::ownerMsgKind(), DtOwnershipMsg::recipientFederate(), DtConnectionMgr::send(), and DtOwnershipMsg::setRecipientFederate().

void DtFedExec::processQueryRestoreStatus	(	DtQueryRestoreStatusMsg const &	msg,
		void *	usr
	)		[static]

Referenced by DtFedExec(), and ~DtFedExec().

void DtFedExec::processQueryRestoreStatus

(

DtQueryRestoreStatusMsg const &

msg

)

[protected, virtual]

References DtFederateRestoreRequestPending, DtNoRestoreInProgress, DtPreparedToRestore, DtRestoring, DtWaitingForFederationToRestore, DtWaitingForRestoreToBegin, rti1516::FEDERATE_PREPARED_TO_RESTORE, rti1516::FEDERATE_RESTORE_REQUEST_PENDING, rti1516::FEDERATE_RESTORING, rti1516::FEDERATE_WAITING_FOR_FEDERATION_TO_RESTORE, rti1516::FEDERATE_WAITING_FOR_RESTORE_TO_BEGIN, DtRtiMsg::federateHandle(), DtFederate::getHandle(), myFederates, rti1516::NO_RESTORE_IN_PROGRESS, DtFederate::restoreStatus(), and sendRestoreStatus().

void DtFedExec::processQuerySaveStatus	(	DtQuerySaveStatusMsg const &	msg,
		void *	usr
	)		[static]

Referenced by DtFedExec(), and ~DtFedExec().

void DtFedExec::processQuerySaveStatus

(

DtQuerySaveStatusMsg const &

msg

)

[protected, virtual]

References DtInstructedToSave, DtNoSaveInProgress, DtSaving, DtWaitingForFederationToSave, rti1516::FEDERATE_INSTRUCTED_TO_SAVE, rti1516::FEDERATE_SAVING, rti1516::FEDERATE_WAITING_FOR_FEDERATION_TO_SAVE, DtRtiMsg::federateHandle(), DtFederate::getHandle(), myFederates, rti1516::NO_SAVE_IN_PROGRESS, DtFederate::saveStatus(), and sendSaveStatus().

void DtFedExec::processRegisterSyncPoint

(

const DtSyncPointMsg &

msg

)

[protected, virtual]

Process sync point registration.

References createSyncPoint(), DtAnnouncePt, DtSyncPointRegFailed, DtSyncPointRegSucceeded, DtSyncStatusFailLabelNotUnique, DtSyncStatusFailMemberNotJoined, DtSyncStatusSucceeded, DtSyncPointMsg::federateId(), DtSyncPointMsg::federates(), getFederate(), DtFederateHandleSet::getHandle(), DtSyncHashlist::lookupSyncPoint(), mySyncList, NULL, DtSyncPointMsg::numFederates(), sendSyncPointMsg(), DtFederateHandleSet::size(), DtSyncPointMsg::syncPointName(), and DtSyncPointMsg::tag().

Referenced by processSyncPoint().

void DtFedExec::processReleaseMultiName	(	DtReleaseMultiNameMsg const &	msg,
		void *	usr
	)		[static]

Referenced by DtFedExec(), and ~DtFedExec().

void DtFedExec::processReleaseMultiName

(

DtReleaseMultiNameMsg const &

msg

)

[protected, virtual]

References DtToString(), DtRtiMsg::federateHandle(), DtReleaseMultiNameMsg::getObjectNames(), myFederateReservedNames, and myReservedNames.

void DtFedExec::processRequestedModulesArrived

(

const DtRequestedModulesArrivedEvent &

e

)

[virtual]

Process arrival of requested FOM Modules.

References DtFedexTakeFileCmd::createNamesOnlyTakeFileEvent(), myDistributor, DtRequestedModulesArrivedEvent::myFileNames, and DtAsyncFileDistributorRunnable::postCommand().

Referenced by DtRequestedModulesArrivedEvent::processResults().

void DtFedExec::processReserveMultiName	(	DtReserveMultiNameMsg const &	msg,
		void *	usr
	)		[static]

Referenced by DtFedExec(), and ~DtFedExec().

void DtFedExec::processReserveMultiName

(

DtReserveMultiNameMsg const &

msg

)

[protected, virtual]

References DtToString(), DtRtiMsg::federateHandle(), DtReserveMultiNameMsg::getObjectNames(), DtRtiMsg::isForExec(), isMember(), myFederateReservedNames, myFedExHandle, myFedExName, myReservedNames, sendMultiNameReservedMsg(), and true.

void DtFedExec::processReserveName	(	DtReserveNameMsg const &	msg,
		void *	usr
	)		[static]

Referenced by DtFedExec(), and ~DtFedExec().

void DtFedExec::processReserveName

(

DtReserveNameMsg const &

msg

)

[protected, virtual]

References isMember(), myFederateReservedNames, myFedExHandle, myFedExName, myReservedNames, and sendNameReservedMsg().

void DtFedExec::processResign	(	const DtResignMsg &	msg,
		void *	usr
	)		[static]

Referenced by DtFedExec(), and ~DtFedExec().

void DtFedExec::processResign

(

const DtResignMsg &

msg

)

[protected, virtual]

References connectMgr(), deleteFederate(), DtRtiMtdDestinationList::destinationIndex(), DtRestoreResultFederateResigned, DtSaveFinishedFederateResigned, DtSynchronized, DtSyncStatusSucceeded, endRestore(), endSave(), DtRtiMsg::federateHandle(), DtSyncPt::federates(), DtRtiMsg::fedExHandle(), fedExName(), DtFederate::getDescription(), getFederate(), DtRtiMsg::isForExec(), DtSyncHashlist::list(), lm, DtSyncHashlist::lookupSyncPoint(), myConnectionsProcessJoined, myFederateSaveList, myFedExHandle, myFedExName, myFedHandlesInUse, DtFedJoinInfo::myFedId, myJoiningFederates, myJoiningFederatesByID, myRestore, mySave, mySavePending, mySyncList, DtSyncPt::name(), processSyncPtAchievedCallbacks(), r1, resetControl(), retireSyncPoint(), sendSyncPointMsg(), DtFederate::setFederateSyncPtAchieved(), DtRtiMsg::smartForwardingEnabled(), and DtFederate::syncPtList().

void DtFedExec::processRestoreBegun	(	const DtRestoreBegunMsg &	msg,
		void *	usr
	)		[static]

Referenced by DtFedExec(), and ~DtFedExec().

void DtFedExec::processRestoreBegun

(

const DtRestoreBegunMsg &

msg

)

[protected, virtual]

References connectMgr(), DtPreparedToRestore, DtResponseFail, DtResponseSuccess, DtRestoreResultFederateFailure, DtRestoring, endRestore(), DtRtiMsg::federateHandle(), fedExHandle(), DtFederate::getConnectionHandle(), DtFederate::getFederateHost(), DtFederate::getHandle(), DtFederate::getType(), DtRtiMsg::isForExec(), isMember(), myDefaultWait, myFederates, myFederateSaveList, myFedExHandle, myFedExName, myFedRestoreList, myRestore, myRestoreConnectIdMap, myRestoreHostAddrMap, myTimeout, NULL, DtRestoreBegunMsg::responseFlag(), DtConnectionMgr::send(), DtRtiMsg::setFedEx(), and DtFederate::setRestoreStatus().

void DtFedExec::processRestoreComplete	(	const DtRestoreCompleteMsg &	msg,
		void *	usr
	)		[static]

Referenced by DtFedExec(), and ~DtFedExec().

void DtFedExec::processRestoreComplete

(

const DtRestoreCompleteMsg &

msg

)

[protected, virtual]

References DtRestoreResultFederateFailure, DtRestoreResultSucess, DtWaitingForFederationToRestore, endRestore(), DtRtiMsg::federateHandle(), getFederate(), DtRtiMsg::isForExec(), isMember(), myFederateSaveList, myFedExHandle, myFedExName, myRestore, DtFederate::setRestoreStatus(), and DtSaveCompleteMsg::successIndicator().

void DtFedExec::processRestoreRequest	(	const DtRestoreRequestMsg &	msg,
		void *	usr
	)		[static]

Referenced by DtFedExec(), and ~DtFedExec().

void DtFedExec::processRestoreRequest

(

const DtRestoreRequestMsg &

msg

)

[protected, virtual]

References connectMgr(), DtRestoreReplyMsg::DT_RESTORE_IN_PROCESS, DtRestoreReplyMsg::DT_RESTORE_NO_LABEL, DtRestoreReplyMsg::DT_RESTORE_OK, DtRestoreReplyMsg::DT_RESTORE_WRONG_CONFIG, DtWaitingForRestoreToBegin, DtRtiMsg::federateHandle(), fedExHandle(), getFederate(), DtRtiMsg::isForExec(), isMember(), DtSaveMsg::label(), myDefaultWait, myFederates, myFederateSaveList, myFedExHandle, myFedExName, myRestore, mySaveLabel, myTimeout, NULL, DtConnectionMgr::send(), DtRestoreReplyMsg::setDestinationID(), DtRtiMsg::setFedEx(), DtFederate::setRestoreStatus(), and verifyRestore().

void DtFedExec::processSaveBegun	(	const DtSaveBegunMsg &	msg,
		void *	usr
	)		[static]

Referenced by DtFedExec(), and ~DtFedExec().

void DtFedExec::processSaveBegun

(

const DtSaveBegunMsg &

msg

)

[protected, virtual]

References DtSaving, DtRtiMsg::federateHandle(), getFederate(), DtRtiMsg::isForExec(), isMember(), myFedExHandle, myFedExName, mySave, mySaveBegun, and DtFederate::setSaveStatus().

void DtFedExec::processSaveComplete	(	const DtSaveCompleteMsg &	msg,
		void *	usr
	)		[static]

Referenced by DtFedExec(), and ~DtFedExec().

void DtFedExec::processSaveComplete

(

const DtSaveCompleteMsg &

msg

)

[protected, virtual]

References DtSaveFinishedFederateFailure, DtSaveFinishedSuccess, DtWaitingForFederationToSave, endSave(), DtRtiMsg::federateHandle(), getFederate(), DtRtiMsg::isForExec(), isMember(), myFederateSaveList, myFedExHandle, myFedExName, mySave, DtFederate::setSaveStatus(), and DtSaveCompleteMsg::successIndicator().

void DtFedExec::processSaveRequest	(	const DtSaveRequestMsg &	msg,
		void *	usr
	)		[static]

Referenced by DtFedExec(), and ~DtFedExec().

void DtFedExec::processSaveRequest

(

const DtSaveRequestMsg &

msg

)

[protected, virtual]

References DtSRSaveAccepted, DtSRSaveInProgress, DtRtiMsg::federateHandle(), initiateSave(), DtRtiMsg::isForExec(), isMember(), DtSaveMsg::label(), myFedExHandle, myFedExName, mySaveBegun, mySavePending, mySavingFederate, DtSaveMsg::requestID(), and sendSaveResponse().

void DtFedExec::processSyncPoint	(	const DtSyncPointMsg &	msg,
		void *	usr
	)		[static]

Referenced by DtFedExec(), and ~DtFedExec().

void DtFedExec::processSyncPoint

(

const DtSyncPointMsg &

msg

)

[protected, virtual]

References DtAchieved, DtAchievedUnsuccessfully, DtAnnouncePt, DtRegister, DtSynchronized, DtSyncPointRegFailed, DtSyncPointRegSucceeded, DtRtiMsg::federateHandle(), DtRtiMsg::isForExec(), isMember(), myFedExHandle, myFedExName, processAchievedSyncPoint(), processRegisterSyncPoint(), DtSyncPointMsg::syncMsgKind(), and DtSyncPointMsg::syncPointName().

void DtFedExec::processSyncPointQuery	(	const DtSyncPointQueryMsg &	msg,
		void *	usr
	)		[static]

Referenced by DtFedExec(), and ~DtFedExec().

void DtFedExec::processSyncPointQuery

(

const DtSyncPointQueryMsg &

msg

)

[protected, virtual]

References DtSyncPointQueryPoints, DtSyncPointQueryStatus, DtRtiMsg::federateHandle(), DtRtiMsg::isForExec(), isMember(), myFedExHandle, myFedExName, DtSyncPointQueryMsg::queryKind(), sendSyncPointReport(), and sendSyncPointStatusReport().

void DtFedExec::processSyncPtAchievedCallbacks	(	DtSyncPt *	point,
		DtFederate *	federate
	)		[protected, virtual]

Process the callbacks registered for federates achieving sync points.

References SpACallbackInfo::myData, SpACallbackInfo::myFn, and mySpAchievedCallbacks.

Referenced by processAchievedSyncPoint(), and processResign().

void DtFedExec::pushFomModuleToJoinedFederates	(	DtFederate *	newFederate,
		DtString	fileName,
		unsigned int	fileSize,
		const char *	fileBuffer
	)

Push a FOM Module to all joined federates except the one specified.

References myDistributor, myFederates, and DtAsyncFileDistributorRunnable::postCommand().

Referenced by DtPushFedFileToFederatesEvent::processResults().

void DtFedExec::pushFomModuleToSingleFederate	(	DtFederateHandle	recipient,
		DtString	fileName,
		unsigned int	fileSize,
		const char *	fileBuffer
	)

Push a FOM Module to the given federate.

References connectMgr(), myDistributor, and DtFileDistributor::pushFedFile().

Referenced by DtPushFedFileToSingleFederateEvent::processResults().

void DtFedExec::reconnectFederateFailed

(

DtFederate *

fed

)

[virtual]

Federate failed to reconnect.

References FedCallbackInfo::myData, FedCallbackInfo::myFn, and myReconnectFailedCallbacks.

Referenced by DtRtiExec::processReconnect(), and removeFederateConnection().

void DtFedExec::reconnectFederateSucceeded

(

DtFederate *

fed

)

[virtual]

Federate successfully reconnected.

References FedCallbackInfo::myData, FedCallbackInfo::myFn, and myReconnectSucceededCallbacks.

Referenced by DtRtiExec::processReconnect().

bool DtFedExec::removeFederateConnection

(

unsigned long

id

)

[virtual]

Removes the federate with the given connection ID.

References connectMgr(), DtRtiMtdDestinationList::destinationIndex(), DtLostConnectionResign, fedExName(), DtFederate::getDescription(), DtFederate::getHandle(), myAwaitingJoinUpload, myConnectionsProcessJoined, myFederates, myFedHandlesInUse, DtFedJoinInfo::myFedId, DtFedJoinInfo::myHandle, myJoiningFederates, myJoiningFederatesByID, reconnectFederateFailed(), removeJoinFomModuleForConnection(), resetControl(), resignFederate(), and DtRtiMsg::smartForwardingEnabled().

Referenced by DtRtiExec::removeDroppedFederateConnections().

void DtFedExec::removeFederateDisconnectedCallback	(	DtFederateCbFn	fn,
		void *	usr
	)		[virtual]

Unregister callbacks for federate disconnected.

References FedCallbackInfo::myData, myDisconnectCallbacks, and FedCallbackInfo::myFn.

Referenced by DtRtiexecObserverMgr::federationDestroyedCallback().

void DtFedExec::removeFederateJoinedCallback	(	DtFederateCbFn	fn,
		void *	usr
	)		[virtual]

Remove callback to be invoked whenever a federate joins a federation.

References FedCallbackInfo::myData, FedCallbackInfo::myFn, myJoinCallbacks, and NULL.

Referenced by DtRtiexecObserverMgr::federationDestroyedCallback().

void DtFedExec::removeFederateReconnectFailedCallback	(	DtFederateCbFn	fn,
		void *	usr
	)		[virtual]

References FedCallbackInfo::myData, FedCallbackInfo::myFn, and myReconnectFailedCallbacks.

Referenced by DtRtiexecObserverMgr::federationDestroyedCallback().

void DtFedExec::removeFederateReconnectSucceededCallback	(	DtFederateCbFn	fn,
		void *	usr
	)		[virtual]

References FedCallbackInfo::myData, FedCallbackInfo::myFn, and myReconnectSucceededCallbacks.

Referenced by DtRtiexecObserverMgr::federationDestroyedCallback().

void DtFedExec::removeFederateResignedCallback	(	DtFederateCbFn	fn,
		void *	usr
	)		[virtual]

Remove callback to be invoked whenever a federate resigns a federation.

References FedCallbackInfo::myData, FedCallbackInfo::myFn, myResignCallbacks, and NULL.

Referenced by DtRtiexecObserverMgr::federationDestroyedCallback().

void DtFedExec::removeFederationSynchronizedCallback	(	DtSyncPointCbFn	fn,
		void *	usr
	)		[virtual]

Unregister a callback to be invoked whenever all federates has achieved a sync point.

References SpCallbackInfo::myData, myFedSynchronizedCallbacks, SpCallbackInfo::myFn, and NULL.

Referenced by DtRtiexecObserverMgr::federationDestroyedCallback().

void DtFedExec::removeJoinFomModuleForConnection

(

unsigned long

connID

)

[protected, virtual]

Remove the given FOM Module request to the given connection's list.

References myFomModules, myFomModulesSet, and myJoinFomModules.

Referenced by processJoin(), processJoinMsg(), processJoinReady(), and removeFederateConnection().

void DtFedExec::removeSyncPtAchievedCallback	(	DtSyncPointAchievedCbFn	fn,
		void *	usr
	)		[virtual]

Unregister a callback to be invoked whenever a federate has achieved a sync point.

References SpACallbackInfo::myData, SpACallbackInfo::myFn, mySpAchievedCallbacks, and NULL.

Referenced by DtRtiexecObserverMgr::federationDestroyedCallback().

void DtFedExec::removeSyncPtRegisteredCallback	(	DtSyncPointCbFn	fn,
		void *	usr
	)		[virtual]

Unregister a callback to be invoked whenever a new sync point has been registered.

References SpCallbackInfo::myData, SpCallbackInfo::myFn, mySpRegisterCallbacks, and NULL.

Referenced by DtRtiexecObserverMgr::federationDestroyedCallback().

void DtFedExec::requestFedFileUpload

(

const DtJoinMsg &

msg

)

[protected, virtual]

References addJoinFomModuleForConnection(), connectMgr(), fomModuleMerging, DtJoinMsg::getFomModuleNames(), myAwaitingJoinUpload, myDistributor, myFullFedFileDistribution, populateWithUnknownFoms(), DtAsyncFileDistributorRunnable::postCommand(), and DtJoinMsg::sourceID().

Referenced by processJoinMsg().

void DtFedExec::resetClockForHeartBeat

(

)

[virtual]

This should only be called when the rtiExec has reconnected.

This will prevent a healthy federate from being disconnected because the rtiExec was disconnected and it did not receive the heartbeat. This comes at the cost of not detecting an unhealthy federate for the period between that federates last heartbeat and the time that this was called.

References myClock, myFederates, myFederateTimeoutInterval, and DtFederate::setFederateHeartbeat().

void DtFedExec::resetControl

(

)

[protected, virtual]

Reset control.

References myFederates, myJoiningFederates, and myNumberFederatesAllowed.

Referenced by deleteFederate(), processJoin(), processJoinConfirm(), processResign(), removeFederateConnection(), and tickJoin().

bool DtFedExec::resignFederate	(	DtFederateHandle	handle,
		DtResignAction	action,
		DtResignReason	reason
	)		[virtual]

Resign the given federate from the federation.

References getFederate(), myFedExName, NULL, and sendResignMsg().

Referenced by DtRtiExec::deleteFederate(), DtDeleteFederateCmd::operator()(), DtRtiExec::processQueueFull(), removeFederateConnection(), and tickFederates().

bool DtFedExec::restore

(

const char *

label

)

[protected, virtual]

restores the fedex Return boolean: save was successful?

References addFederate(), DtFederate::addFederateSyncPt(), DtSyncHashlist::addSyncPoint(), DtRtiMtdDestinationList::destinationIndex(), DtHlaVersionUnknown, DtSyncHashlist::empty(), DtRtiMtdDestinationList::getMaxDestinations(), getRestoreFileName(), myDesignatedFederate, myFederateHdlsByName, myFederateReservedNames, myFederates, myFederatesByName, myFedHandlesInUse, myFreeFedHandle, myInitiatedSaveFederates, myJoiningFederates, myJoiningFederatesByID, myNumFederates, myReservedNames, myRestoreConnectIdMap, myRestoreHostAddrMap, mySave, mySavePending, mySyncList, DtSyncPt::name(), restoreFederateSyncPoint(), restoreFederationSyncPoint(), and DtRtiMsg::smartForwardingEnabled().

Referenced by endRestore().

bool DtFedExec::restoreFederateConnection	(	DtFederateHandle	handle,
		unsigned long	newConnId,
		unsigned long &	oldConnId
	)		[virtual]

Restore a joined federate on a new connection ID TODO: let this work for connected, not necessarily joined federates Pass back old connection ID Return bool: federate restored.

References connectMgr(), DtReconnectMsg::DtReconnectAccepted, fedExHandle(), fedExName(), DtFederate::getConnectionHandle(), DtFederate::getDescription(), DtFederate::getHandle(), myFederates, DtConnectionMgr::send(), DtFederate::setConnectionHandle(), and DtRtiMsg::setFedEx().

Referenced by DtRtiExec::processReconnect().

void DtFedExec::retireSyncPoint

(

const char *

name

)

[protected, virtual]

DtTIME.

Remove the sync point - usually called after the point has been reached by all, and the federation is synchronized.

References myFederates, mySyncList, processFederationSynchronizedCallbacks(), DtSyncHashlist::remove(), and DtFederate::removeFederateSyncPt().

Referenced by processAchievedSyncPoint(), and processResign().

bool DtFedExec::save

(

const char *

label

)

[protected, virtual]

saves the fedex Return boolean: save was successful?

References DtFederate::getConnectionHandle(), DtFederate::getHandle(), getSaveFileName(), DtFederate::getType(), DtSyncHashlist::list(), myDesignatedFederate, myFederateReservedNames, myFederates, myFedExName, myFomModules, myFreeFedHandle, myNumFederates, myReservedNames, mySyncList, NULL, saveFederateSyncPoint(), saveFederationSyncPoint(), and DtFederate::syncPtList().

Referenced by endSave().

void DtFedExec::sendDesignatedFederate

(

DtFederateHandle

fedHandle

)

[protected, virtual]

References connectMgr(), DtConnectionMgr::create(), DtDesignatedFederateMsgKind, fedExHandle(), DtConnectionMgr::sendAndDelete(), DtDesignatedFederateMsg::set(), and DtRtiMsg::setFedEx().

Referenced by processJoinConfirm().

void DtFedExec::sendEnableDisableNetworkTestingMsg	(	const char *	name,
		bool	enabled
	)		[protected, virtual]

References connectMgr(), DtConnectionMgr::create(), DtEnableDisableNetworkTestingMsgKind, myFedExHandle, DtConnectionMgr::sendAndDelete(), DtEnableDisableNetworkTestingMsg::set(), and DtRtiMsg::setFedEx().

Referenced by disableNetworkTesting(), and enableNetworkTesting().

void DtFedExec::sendJoinResponseMsg	(	unsigned long	destinationIDValue,
		unsigned short	requestID,
		unsigned int	crcOfFedFile,
		DtFederateHandle	handle,
		const char *	federateName,
		int	fedExHandle,
		const char *	fedExName,
		const DtString &	momModule,
		const std::vector< MAKRti::DtString > &	modules,
		unsigned long	flags,
		bool	allowNetworkTesting,
		bool	enableNetworkTesting,
		DtHlaVersionId	hlaVers,
		DtJoinResponseMsg::errorCodes	errorValue = DtJoinResponseMsg::DT_NO_ERROR,
		const DtString &	errorString = DtString::nullString()
	)		[protected, virtual]

References connectMgr(), DtConnectionMgr::create(), DtHlaEvolved, DtJoinResponseMsgKind, enableNetworkTesting(), myFederateHdlsByName, DtConnectionMgr::sendAndDelete(), DtJoinResponseMsg::set(), and DtRtiMsg::setFedEx().

Referenced by handleJoinFailureCases(), processJoin(), processJoinMsg(), and tickJoin().

void DtFedExec::sendMultiNameReservedMsg	(	DtFederateHandle	requestingFederate,
		std::set< std::wstring > const &	objectNames,
		bool	result
	)		[protected, virtual]

References connectMgr(), DtConnectionMgr::create(), DtMultiNameReservedMsgKind, fedExHandle(), DtConnectionMgr::sendAndDelete(), DtMultiNameReservedMsg::set(), and DtRtiMsg::setFedEx().

Referenced by processReserveMultiName().

void DtFedExec::sendNameReservedMsg	(	DtFederateHandle	requestingFederate,
		char const *	objectName,
		bool	result
	)		[protected, virtual]

References connectMgr(), DtConnectionMgr::create(), DtNameReservedMsgKind, fedExHandle(), DtConnectionMgr::sendAndDelete(), and DtRtiMsg::setFedEx().

Referenced by processReserveName().

void DtFedExec::sendResignMsg	(	const char *	name,
		DtFederateHandle	fedHandle,
		DtResignAction	action,
		DtResignReason	reason,
		const DtTimeInfo *	timeInfo
	)		[protected, virtual]

References connectMgr(), DtConnectionMgr::create(), DtResignMsgKind, myFedExHandle, DtConnectionMgr::sendAndDelete(), DtResignMsg::set(), DtRtiMsg::setFedEx(), and DtResignMsg::setTimeStamp().

Referenced by resignFederate().

void DtFedExec::sendRestoreStatus	(	DtFederateHandle	requestingFederate,
		RTINAMESPACE::FederateRestoreStatusVector const &	restoreStatusList
	)		[protected, virtual]

References connectMgr(), DtConnectionMgr::create(), DtRestoreStatusMsgKind, fedExHandle(), DtConnectionMgr::sendAndDelete(), and DtRtiMsg::setFedEx().

Referenced by processQueryRestoreStatus().

void DtFedExec::sendSaveInitiateConstrainedMsg

(

const char *

labelVal

)

[protected, virtual]

References connectMgr(), DtConnectionMgr::create(), DtSaveInitiateConstrainedMsgKind, fedExHandle(), DtConnectionMgr::sendAndDelete(), DtSaveMsg::set(), and DtRtiMsg::setFedEx().

Referenced by initiateSave().

void DtFedExec::sendSaveInitiateMsg

(

const char *

labelVal

)

[protected, virtual]

References connectMgr(), DtConnectionMgr::create(), DtSaveInitiateMsgKind, fedExHandle(), DtConnectionMgr::sendAndDelete(), DtSaveMsg::set(), and DtRtiMsg::setFedEx().

Referenced by initiateSave(), and processInitiatedSave().

void DtFedExec::sendSaveResponse	(	DtFederateHandle	fedHandle,
		unsigned long	requestID,
		const char *	labelVal,
		DtSaveResponseFlag	response
	)		[protected, virtual]

References connectMgr(), DtConnectionMgr::create(), DtSaveResponseMsgKind, fedExHandle(), DtConnectionMgr::sendAndDelete(), DtSaveResponseMsg::set(), and DtRtiMsg::setFedEx().

Referenced by processSaveRequest().

void DtFedExec::sendSaveStatus	(	DtFederateHandle	requestingFederate,
		RTINAMESPACE::FederateHandleSaveStatusPairVector const &	saveStatusList
	)		[protected, virtual]

References connectMgr(), DtConnectionMgr::create(), DtSaveStatusMsgKind, fedExHandle(), DtConnectionMgr::sendAndDelete(), and DtRtiMsg::setFedEx().

Referenced by processQuerySaveStatus().

void DtFedExec::sendSyncPointMsg	(	DtSyncMsgType	kind,
		int	id,
		DtSyncPointStatus	status,
		const char *	name,
		RTINAMESPACE::VariableLengthData const *	theTag = NULL,
		const DtFederateHandleSet *	set = NULL,
		const DtFederateHandleSet *	unsuccessfulSet = NULL
	)		[protected, virtual]

References connectMgr(), DtConnectionMgr::create(), DtSyncPointMsgKind, myFedExHandle, DtConnectionMgr::sendAndDelete(), DtSyncPointMsg::set(), and DtRtiMsg::setFedEx().

Referenced by announceAllSyncPoints(), processAchievedSyncPoint(), processRegisterSyncPoint(), and processResign().

void DtFedExec::sendSyncPointReport

(

const DtSyncPointQueryMsg &

msg

)

[protected, virtual]

Send MOM report synchronization point interaction.

References DtSyncPointQueryMsg::classHandle(), connectMgr(), DtConnectionMgr::create(), DtDefaultRegionSetHandle, DtInteractionRoMsgKind, DtToWString(), DtSyncHashlist::list(), myFedExHandle, mySyncList, DtSyncPt::name(), DtBitMask::reset(), DtConnectionMgr::sendStampedAnonymousAndDelete(), DtInteractionRoMsg::set(), DtRtiMtdDestinationList::set(), DtRtiMsg::setFedEx(), and DtSyncPointQueryMsg::syncPointHandle().

Referenced by processSyncPointQuery().

void DtFedExec::sendSyncPointStatusReport

(

const DtSyncPointQueryMsg &

msg

)

[protected, virtual]

Send MOM report synchronization point status interaction.

References DtSyncPointQueryMsg::classHandle(), connectMgr(), DtConnectionMgr::create(), DtDefaultRegionSetHandle, DtInteractionRoMsgKind, DtToWString(), DtSyncPt::federates(), DtFederate::federateSyncPtAchieved(), fedExHandle(), DtFederate::getHandle(), DtFederateHandleSet::isMember(), DtSyncHashlist::list(), myFederates, mySyncList, DtSyncPt::name(), DtBitMask::reset(), DtConnectionMgr::sendAndDelete(), DtInteractionRoMsg::set(), DtRtiMtdDestinationList::set(), DtRtiMsg::setFederateHandle(), DtRtiMsg::setFedEx(), DtSyncPointQueryMsg::syncPointFederateHandle(), and DtSyncPointQueryMsg::syncPointHandle().

Referenced by processSyncPointQuery().

void DtFedExec::sendTransferRidParamsMsg	(	const char *	name,
		DtFederateHandle	fedHandle,
		const DtString &	paramString
	)		[protected, virtual]

References connectMgr(), DtConnectionMgr::create(), DtTransferRidParamsMsgKind, DtConnectionMgr::sendAndDelete(), DtTransferRidParamsMsg::setDestinationID(), and DtTransferRidParamsMsg::writeRidTestBlock().

Referenced by transferRidParams().

void DtFedExec::setCreatorFunction

(

DtFedExecCreator

creator

)

[static]

Call this function to set an alternate creator function With this function, users can replace this DtFedExec with their own derived class.

References create(), DtBindCreator(), and theCreator.

void DtFedExec::setFullyCreated

(

bool

val

)

[virtual]

Set completion status.

References myFullyCreated.

Referenced by DtRtiExec::processCreate().

bool DtFedExec::synchronized	(	DtSyncPt *	point,
		DtFederateHandleSet &	unsuccessfulSet
	)		const [protected, virtual]

Return true if we've reached synchronization for this point, false otherwise.

Also return the list of federates who achieved the sync point unsuccessfully.

References DtFederateHandleSet::add(), DtSyncPt::federates(), DtFederate::federateSyncPtAchieved(), DtFederate::federateSyncPtAchievedSuccessfully(), DtFederate::getHandle(), DtFederateHandleSet::isMember(), myFederates, and DtSyncPt::name().

bool DtFedExec::tick

(

)

[virtual]

Tick the federation execution.

References myDistributeFedFile, tickDistributor(), tickFederates(), tickJoin(), and tickSaveRestore().

Referenced by DtRtiExec::tick().

bool DtFedExec::tickDistributor

(

)

[protected, virtual]

Tick the distributor.

References myDistributor, processCreateReady(), processEvents(), and processJoinReady().

Referenced by tick().

void DtFedExec::tickFederates

(

)

[protected, virtual]

Check if the interval since the last heartbeat for any federate has exceeded the timeout.

If so, resign the federate.

References connectMgr(), DtNotHeartbeatedResign, DtFederate::federateHeartbeat(), DtRIDParameters::federateReconnectPause, fedExName(), DtFederate::getDescription(), DtFederate::getHandle(), myClock, myFederates, myFederateTimeoutInterval, myResponseInterval, myRestore, mySave, DtConnectionMgr::params(), and resignFederate().

Referenced by tick().

void DtFedExec::tickJoin

(

)

[protected, virtual]

Periodically send a join response to prod unconfirmed federate joins This polling mechanism compensates for dropped messages.

References DtRtiMtdDestinationList::destinationIndex(), fedExHandle(), fedExName(), fomModules(), myAllowNetworkTesting, DtFedJoinInfo::myAttempts, myClock, myConnectionsProcessJoined, myCreationFedFilesCRCs, DtFedJoinInfo::myFederateName, DtFedJoinInfo::myFedExName, myFedHandlesInUse, DtFedJoinInfo::myFedId, DtFedJoinInfo::myFlags, DtFedJoinInfo::myHandle, DtFedJoinInfo::myHlaVersion, myJoiningFederates, myJoiningFederatesByID, myMomModule, myNetworkTestingEnabled, DtFedJoinInfo::myNextSendTime, DtFedJoinInfo::myRequestID, myResponseInterval, resetControl(), sendJoinResponseMsg(), and DtRtiMsg::smartForwardingEnabled().

Referenced by tick().

void DtFedExec::tickSaveRestore

(

)

[protected, virtual]

Tick actions.

Check if a save/restore has timed out. If so, terminate it.

References DtRestoreResultFailureDetected, DtSaveFinishedFailureDetected, endRestore(), endSave(), myFederateSaveList, myRestore, mySave, myTimeout, and NULL.

Referenced by tick().

bool DtFedExec::transferRidParams	(	DtFederateHandle	handle,
		const DtString &	ridString
	)		[virtual]

Transfer RID parameters over network.

References getFederate(), myFedExName, NULL, and sendTransferRidParamsMsg().

Referenced by DtChangeRidParamCmd::operator()().

int DtFedExec::verifyRestore

(

const char *

label

)

[protected, virtual]

verifies the restore label

References DtHlaVersionUnknown, getRestoreFileName(), DtFederate::getType(), myFederates, myFedRestoreList, myNumFederates, and mySyncList.

Referenced by processRestoreRequest().

---

Member Data Documentation

bool DtFedExec::myAllowNetworkTesting [protected]

Whether network testing is enabled or completely disabled by the RID.

Referenced by handleJoinFailureCases(), processJoin(), processJoinMsg(), and tickJoin().

bool DtFedExec::myAwaitingCreateUpload [protected]

Referenced by createDistributor(), and processCreateReady().

std::set< unsigned long> DtFedExec::myAwaitingJoinUpload [protected]

Referenced by processJoinReady(), removeFederateConnection(), and requestFedFileUpload().

DtClock DtFedExec::myClock [protected]

Referenced by endRestore(), endSave(), processAlive(), processEvents(), processJoinConfirm(), processJoinMsg(), processJoinReady(), resetClockForHeartBeat(), tickFederates(), and tickJoin().

DtConnectionMgr* DtFedExec::myConnectionMgr [protected]

Referenced by connectMgr(), createDistributor(), destroyDistributor(), processFedFileRequestMsg(), processJoin(), processJoinConfirm(), processJoinMsg(), and processJoinReady().

std::set< unsigned long > DtFedExec::myConnectionsProcessJoined [protected]

Referenced by processJoin(), processJoinConfirm(), processJoinReady(), processResign(), removeFederateConnection(), and tickJoin().

bool DtFedExec::myCrcCheckFedFile [protected]

Referenced by isFomAvailable(), and processJoinMsg().

unsigned int DtFedExec::myCrcOfFedFile [protected]

std::vector<DtString> DtFedExec::myCreateFomModules [protected]

Referenced by createDistributor(), createFomModules(), and processCreateReady().

std::vector<unsigned int> DtFedExec::myCreationFedFilesCRCs [protected]

Referenced by processJoin(), processJoinMsg(), and tickJoin().

unsigned long DtFedExec::myCreatorConnId [protected]

Referenced by createDistributor(), creatorID(), and processCreateReady().

int DtFedExec::myDefaultWait [protected]

Referenced by DtFedExec(), initiateSave(), processRestoreBegun(), and processRestoreRequest().

DtFederateHandle DtFedExec::myDesignatedFederate [protected]

Referenced by deleteFederate(), processJoinConfirm(), restore(), and save().

DtList DtFedExec::myDisconnectCallbacks [protected]

Referenced by addFederateDisconnectedCallback(), disconnectFederate(), and removeFederateDisconnectedCallback().

bool DtFedExec::myDistributeFedFile [protected]

Referenced by destroyDistributor(), and tick().

DtAsyncFileDistributorRunnable* DtFedExec::myDistributor [protected]

Referenced by createDistributor(), destroyDistributor(), distributor(), multFileReceivedCb(), multFileRequestedCb(), processEvents(), processJoin(), processRequestedModulesArrived(), pushFomModuleToJoinedFederates(), pushFomModuleToSingleFederate(), requestFedFileUpload(), and tickDistributor().

vrlmod::DtThreadedObject* DtFedExec::myDistributorThread [protected]

DtTIME.

Referenced by createDistributor(), and destroyDistributor().

std::map< MAKRti::DtString, DtFederateHandle > DtFedExec::myFederateHdlsByName [protected]

Referenced by addFederate(), deleteFederate(), restore(), sendJoinResponseMsg(), and ~DtFedExec().

DtFedExFederateReservedNameMap DtFedExec::myFederateReservedNames [protected]

Referenced by deleteFederate(), processReleaseMultiName(), processReserveMultiName(), processReserveName(), restore(), and save().

DtFederateHandleInfoMap DtFedExec::myFederates [protected]

Referenced by addFederate(), createSyncPoint(), deleteFederate(), endRestore(), endSave(), federateHandleOfConnection(), federates(), getFederate(), handleJoinFailureCases(), initiateSave(), isMember(), printFederates(), processInitiatedSave(), processOwnership(), processQueryRestoreStatus(), processQuerySaveStatus(), processRestoreBegun(), processRestoreRequest(), pushFomModuleToJoinedFederates(), removeFederateConnection(), resetClockForHeartBeat(), resetControl(), restore(), restoreFederateConnection(), retireSyncPoint(), save(), sendSyncPointStatusReport(), synchronized(), tickFederates(), verifyRestore(), and ~DtFedExec().

std::set<DtFederateHandle> DtFedExec::myFederateSaveList [protected]

Referenced by endRestore(), endSave(), initiateSave(), processResign(), processRestoreBegun(), processRestoreComplete(), processRestoreRequest(), processSaveComplete(), and tickSaveRestore().

DtFederateNameInfoMap DtFedExec::myFederatesByName [protected]

Referenced by addFederate(), deleteFederate(), handleJoinFailureCases(), restore(), and ~DtFedExec().

float DtFedExec::myFederateTimeoutInterval [protected]

Referenced by DtFedExec(), endRestore(), endSave(), processJoinConfirm(), resetClockForHeartBeat(), and tickFederates().

int DtFedExec::myFedExHandle [protected]

Referenced by changeLatencyTestMode(), createDistributor(), DtFedExec(), endRestore(), endSave(), fedExHandle(), multFileRequestedCb(), processAbortRestore(), processAbortSave(), processFedFileRequestMsg(), processInitiatedSave(), processJoinConfirm(), processOwnership(), processReserveMultiName(), processReserveName(), processResign(), processRestoreBegun(), processRestoreComplete(), processRestoreRequest(), processSaveBegun(), processSaveComplete(), processSaveRequest(), processSyncPoint(), processSyncPointQuery(), sendEnableDisableNetworkTestingMsg(), sendResignMsg(), sendSyncPointMsg(), and sendSyncPointReport().

DtString DtFedExec::myFedExName [protected]

Referenced by disableNetworkTesting(), enableNetworkTesting(), fedExName(), getSaveFileName(), handleJoinFailureCases(), multFileReceivedCb(), processAbortRestore(), processAbortSave(), processFedFileRequestMsg(), processInitiatedSave(), processJoinConfirm(), processOwnership(), processReserveMultiName(), processReserveName(), processResign(), processRestoreBegun(), processRestoreComplete(), processRestoreRequest(), processSaveBegun(), processSaveComplete(), processSaveRequest(), processSyncPoint(), processSyncPointQuery(), resignFederate(), save(), and transferRidParams().

bool* DtFedExec::myFedHandlesInUse [protected]

Referenced by deleteFederate(), DtFedExec(), getNextFreeFedHandle(), processJoinConfirm(), processResign(), removeFederateConnection(), restore(), tickJoin(), and ~DtFedExec().

DtFedReader13* DtFedExec::myFedReader13 [protected]

Referenced by getReader(), and ~DtFedExec().

DtFedReader1516* DtFedExec::myFedReader1516 [protected]

Referenced by getReader(), and ~DtFedExec().

DtFedReader1516e* DtFedExec::myFedReader1516e [protected]

Referenced by getReader(), and ~DtFedExec().

DtFederateHandleInfoMap DtFedExec::myFedRestoreList [protected]

Referenced by endRestore(), processRestoreBegun(), and verifyRestore().

DtList DtFedExec::myFedSynchronizedCallbacks [protected]

Referenced by addFederationSynchronizedCallback(), processFederationSynchronizedCallbacks(), and removeFederationSynchronizedCallback().

MAKRti::DtFomType DtFedExec::myFedType [protected]

DtFomClassMgr* DtFedExec::myFom [protected]

Referenced by processCreateReady(), and processJoin().

std::vector<DtString> DtFedExec::myFomModules [protected]

Referenced by DtFedExec(), fedFileName(), fomModules(), processJoinMsg(), removeJoinFomModuleForConnection(), and save().

std::map<DtString, unsigned int> DtFedExec::myFomModulesNameToCrcMap [protected]

Referenced by doesCrcMatchKnownFomModuleCrc(), DtFedExec(), and processJoinMsg().

std::set<DtString> DtFedExec::myFomModulesSet [protected]

Referenced by addJoinFomModuleForConnection(), DtFedExec(), processJoinMsg(), and removeJoinFomModuleForConnection().

int DtFedExec::myFreeFedHandle [protected]

Referenced by DtFedExec(), getNextFreeFedHandle(), restore(), and save().

bool DtFedExec::myFullFedFileDistribution [private]

Referenced by createDistributor(), DtFedExec(), and requestFedFileUpload().

bool DtFedExec::myFullyCreated [protected]

Referenced by fullyCreated(), processCreateReady(), and setFullyCreated().

DtFederateHandleStdSet DtFedExec::myInitiatedSaveFederates [protected]

Referenced by endSave(), initiateSave(), processInitiatedSave(), and restore().

unsigned long DtFedExec::myInitiatorID [protected]

Referenced by createDistributor(), and processCreateReady().

DtList DtFedExec::myJoinCallbacks [protected]

Referenced by addFederate(), addFederateJoinedCallback(), and removeFederateJoinedCallback().

std::map<unsigned long, const std::vector<DtString>* > DtFedExec::myJoinFomModules [protected]

Referenced by addJoinFomModuleForConnection(), deleteFederate(), joinFomModules(), joinFomModulesForConnection(), processJoinMsg(), removeJoinFomModuleForConnection(), and ~DtFedExec().

std::map<DtFederateHandle, DtFedJoinInfo*> DtFedExec::myJoiningFederates [protected]

List of joining federates for which a join confirm is expected.

Referenced by handleJoinFailureCases(), processJoin(), processJoinConfirm(), processJoinMsg(), processResign(), removeFederateConnection(), resetControl(), restore(), tickJoin(), and ~DtFedExec().

std::map<unsigned long, DtFedJoinInfo*> DtFedExec::myJoiningFederatesByID [protected]

Referenced by federateHandleOfConnection(), processJoin(), processJoinConfirm(), processJoinMsg(), processJoinReady(), processResign(), removeFederateConnection(), restore(), tickJoin(), and ~DtFedExec().

DtString DtFedExec::myMomModule [protected]

Referenced by createDistributor(), DtFedExec(), processCreateReady(), processJoin(), processJoinMsg(), and tickJoin().

unsigned int DtFedExec::myMomModuleCrc [protected]

Referenced by doesCrcMatchKnownFomModuleCrc().

bool DtFedExec::myNetworkTestingEnabled [protected]

Whether network testing has been toggled on/off by the assistant.

Referenced by disableNetworkTesting(), enableNetworkTesting(), handleJoinFailureCases(), processJoin(), processJoinMsg(), and tickJoin().

unsigned int DtFedExec::myNumberFederatesAllowed [protected]

Referenced by handleJoinFailureCases(), numberFederatesAllowed(), processJoinMsg(), and resetControl().

int DtFedExec::myNumberResponseAttempts [protected]

Response interval from params is divided by this number.

Referenced by DtFedExec().

int DtFedExec::myNumFederates [protected]

Referenced by addFederate(), deleteFederate(), DtFedExec(), numFederates(), restore(), save(), and verifyRestore().

DtList DtFedExec::myReconnectFailedCallbacks [protected]

Referenced by addFederateReconnectFailedCallback(), reconnectFederateFailed(), and removeFederateReconnectFailedCallback().

DtList DtFedExec::myReconnectSucceededCallbacks [protected]

Referenced by addFederateReconnectSucceededCallback(), reconnectFederateSucceeded(), and removeFederateReconnectSucceededCallback().

DtFedExReservedNameSet DtFedExec::myReservedNames [protected]

Referenced by deleteFederate(), processReleaseMultiName(), processReserveMultiName(), processReserveName(), restore(), and save().

DtList DtFedExec::myResignCallbacks [protected]

Referenced by addFederateResignedCallback(), deleteFederate(), and removeFederateResignedCallback().

float DtFedExec::myResponseInterval [protected]

to obtain response retransmission interval

Referenced by DtFedExec(), processJoinMsg(), tickFederates(), and tickJoin().

bool DtFedExec::myRestore [protected]

Referenced by DtFedExec(), endRestore(), handleJoinFailureCases(), processAbortRestore(), processResign(), processRestoreBegun(), processRestoreComplete(), processRestoreRequest(), tickFederates(), and tickSaveRestore().

std::map<DtFederateHandle, unsigned long> DtFedExec::myRestoreConnectIdMap [protected]

Referenced by endRestore(), processRestoreBegun(), and restore().

std::map<DtFederateHandle, MAKRti::DtInetAddr> DtFedExec::myRestoreHostAddrMap [protected]

Referenced by endRestore(), processRestoreBegun(), and restore().

bool DtFedExec::mySave [protected]

Referenced by DtFedExec(), endSave(), handleJoinFailureCases(), initiateSave(), processAbortSave(), processInitiatedSave(), processResign(), processSaveBegun(), processSaveComplete(), restore(), tickFederates(), and tickSaveRestore().

bool DtFedExec::mySaveBegun [protected]

Referenced by endSave(), processSaveBegun(), and processSaveRequest().

DtString DtFedExec::mySaveLabel [protected]

Referenced by checkTimedSave(), endRestore(), endSave(), initiateSave(), processInitiatedSave(), processJoinConfirm(), and processRestoreRequest().

DtString DtFedExec::mySavePath [protected]

Referenced by DtFedExec(), and getSaveFileName().

bool DtFedExec::mySavePending [protected]

Referenced by checkTimedSave(), endSave(), initiateSave(), processJoinConfirm(), processResign(), processSaveRequest(), and restore().

DtFederateHandle DtFedExec::mySavingFederate [protected]

Referenced by processSaveRequest().

DtList DtFedExec::mySpAchievedCallbacks [protected]

Referenced by addSyncPtAchievedCallback(), processSyncPtAchievedCallbacks(), and removeSyncPtAchievedCallback().

DtList DtFedExec::mySpRegisterCallbacks [protected]

Referenced by addSyncPtRegisteredCallback(), createSyncPoint(), and removeSyncPtRegisteredCallback().

int DtFedExec::myStrictNameReservation [protected]

Referenced by deleteFederate().

DtSyncHashlist DtFedExec::mySyncList [protected]

Referenced by announceAllSyncPoints(), createFederate(), createSyncPoint(), processAchievedSyncPoint(), processRegisterSyncPoint(), processResign(), restore(), retireSyncPoint(), save(), sendSyncPointReport(), sendSyncPointStatusReport(), verifyRestore(), and ~DtFedExec().

std::map<DtString, DtFileInformation*> DtFedExec::myTakenFiles [protected]

until requester takes them.

Referenced by fedFileReady(), isFomAvailable(), processCreateReady(), processFileTransfer(), and processJoin().

int DtFedExec::myTimeout [protected]

Referenced by DtFedExec(), endRestore(), endSave(), initiateSave(), processRestoreBegun(), processRestoreRequest(), and tickSaveRestore().

const DtString DtFedExec::nullStr = "" [static, private]

Referenced by fedFileName().

DtFedExecCreator DtFedExec::theCreator = NULL [static, protected]

Referenced by create(), and setCreatorFunction().

const std::vector< DtString > DtFedExec::theEmptyStringSet = std::vector<DtString>() [static, protected]

Referenced by handleJoinFailureCases(), and joinFomModulesForConnection().

---

The documentation for this class was generated from the following files:

• fedex.h
• fedex.cxx