DtFedExec Class Reference

Collaboration diagram for DtFedExec:

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 *federateName, DtFederateHandle handle, unsigned long connHandle, int astntCompId, const char *fedHostName, MAKRti::DtInetAddr host, DtHlaVersionId hlaVersion)
	Add a federate to the federation.
virtual DtFederate *	createFederate (const char *federateType, const char *federateName, DtFederateHandle handle, unsigned long connHandle, int astntCompId, const char *fedHostname, MAKRti::DtInetAddr host, DtHlaVersionId hlaVersion)
	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	initializeRestore (const char *label)
	Initializes the restore label Returns status: 0 : OK, -1 : failed to open save label, -2 : failed to configure.
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 >	myPendingSaveFederates
DtFederateHandleStdSet	myInitiatedSaveFederates
DtString	mySaveLabel
DtFederateHandle	mySavingFederate
std::set< DtFederateHandle >	myPendingRestoreFederates
DtFederateHandleInfoMap	myRestoreFederatesByOld
DtFederateHandleInfoMap	myRestoreFederatesByNew
DtString	mySavePath
bool	mySavePending
bool	mySaveBegun
std::map< DtString, DtFileInformation * >	myTakenFiles
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(), DtQuerySaveStatusMsg::addCallback(), DtQueryRestoreStatusMsg::addCallback(), DtSaveTimeAdvanceMsg::addCallback(), DtInitiatedSaveMsg::addCallback(), DtSaveBegunMsg::addCallback(), DtAbortSaveMsg::addCallback(), DtAliveMsg::addCallback(), DtRestoreRequestMsg::addCallback(), DtRestoreCompleteMsg::addCallback(), DtSaveRequestMsg::addCallback(), DtSaveCompleteMsg::addCallback(), DtReleaseMultiNameMsg::addCallback(), DtReserveMultiNameMsg::addCallback(), DtRestoreBegunMsg::addCallback(), DtJoinConfirmMsg::addCallback(), DtSyncPointQueryMsg::addCallback(), DtResignMsg::addCallback(), DtJoinMsg::addCallback(), DtOwnershipMsg::addCallback(), DtSyncPointMsg::addCallback(), connectMgr(), DtToWString(), fedExHandle(), 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 *  federateName, DtFederateHandle  handle, unsigned long  connHandle, int  astntCompId, const char *  fedHostName, MAKRti::DtInetAddr  host, DtHlaVersionId  hlaVersion  )

protectedvirtual

Add a federate to the federation.

References createFederate(), 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  )

protectedvirtual

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 )

protectedvirtual

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 ( )

protectedvirtual

Initiate save if conditions for timed save have been meet.

References initiateSave(), mySaveLabel, and mySavePending.

DtConnectionMgr * DtFedExec::connectMgr ( )

inlinevirtual

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, DtFederateHandle  handle, unsigned long  connHandle, int  astntCompId, const char *  fedHostname, MAKRti::DtInetAddr  host, DtHlaVersionId  hlaVersion  )

protectedvirtual

Create a new federate.

Override this function when overriding DtFederate.

References create(), and mySyncList.

Referenced by addFederate().

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

protectedvirtual

Returns the joinfomModules names associated w/ the fedex.

References myCreateFomModules.

void DtFedExec::createSyncPoint ( const DtSyncPointMsg &  msg )

protectedvirtual

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 )

protectedvirtual

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 ( )

protectedvirtual

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

protectedvirtual

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 )

protectedvirtual

finish the restore

References connectMgr(), DtConnectionMgr::create(), DtRestoreEndMsgKind, DtRestoreResultSucess, DtRestoreResultUnableToRestore, myClock, myFederates, myFederateTimeoutInterval, myFedExHandle, myPendingRestoreFederates, myRestore, myRestoreFederatesByNew, myRestoreFederatesByOld, 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 )

protectedvirtual

finish the save

References connectMgr(), DtConnectionMgr::create(), DtNoSaveInProgress, DtSaveFinishedMsgKind, DtSaveFinishedRtiUnableToSave, DtSaveFinishedSuccess, myClock, myFederates, myFederateTimeoutInterval, myFedExHandle, myInitiatedSaveFederates, myPendingSaveFederates, 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

inlinevirtual

Returns the list of federates for this fed exec.

References myFederates.

Referenced by DtRtiexecObserverForAssistant::processSyncPtRegisteredEvent(), 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(), DtRtiexecObserverForAssistant::processFedExCreatedEvent(), DtRtiexecObserverForAssistant::processFedExDestroyedEvent(), processJoin(), processJoinMsg(), processOwnership(), DtRtiExec::processQueueFull(), processRestoreBegun(), processRestoreRequest(), restoreFederateConnection(), sendDesignatedFederate(), sendMultiNameReservedMsg(), sendNameReservedMsg(), sendRestoreStatus(), sendSaveInitiateConstrainedMsg(), sendSaveInitiateMsg(), sendSaveResponse(), sendSaveStatus(), sendSyncPointStatusReport(), and tickJoin().

const DtString & DtFedExec::fedExName ( ) const

inlinevirtual

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(), 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 DtRtiexecObserverForAssistant::processFedExCreatedEvent().

bool DtFedExec::fedFileReady ( const MAKRti::DtString &  fileName ) const

protectedvirtual

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

protectedvirtual

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(), processRestoreBegun(), processRestoreComplete(), processRestoreRequest(), processSaveBegun(), processSaveComplete(), resignFederate(), and transferRidParams().

int DtFedExec::getNextFreeFedHandle ( )

protectedvirtual

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  )

protectedvirtual

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

Returns a reference to the supplied parameter

References getSaveFileName().

Referenced by initializeRestore(), and restore().

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

protectedvirtual

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 )

protectedvirtual

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().

int DtFedExec::initializeRestore ( const char *  label )

protectedvirtual

Initializes the restore label Returns status: 0 : OK, -1 : failed to open save label, -2 : failed to configure.

References DtFederate::assistantCompId(), DtFederate::getConnectionHandle(), DtFederate::getFederateHost(), DtFederate::getFederateHostName(), DtFederate::getHandle(), getRestoreFileName(), DtFederate::getType(), DtFederate::hlaVersion(), myFederates, myNumFederates, myRestoreFederatesByNew, myRestoreFederatesByOld, and mySyncList.

Referenced by processRestoreRequest().

void DtFedExec::initiateSave ( const char *  label )

protectedvirtual

Initiates the save of the federation, including the fedex.

References DtInstructedToSave, myDefaultWait, myFederates, myInitiatedSaveFederates, myPendingSaveFederates, 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

protectedvirtual

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

protectedvirtual

Returns the joinfomModules names associated w/ the fedex.

References myJoinFomModules.

const std::vector< DtString > & DtFedExec::joinFomModulesForConnection ( unsigned long  connID ) const

protectedvirtual

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

protectedvirtual

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

inlinevirtual

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 )

protectedvirtual

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 )

protectedvirtual

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

void DtFedExec::processAchievedSyncPoint ( const DtSyncPointMsg &  msg )

protectedvirtual

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 )

protectedvirtual

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

bool DtFedExec::processCreateReady ( )

protectedvirtual

Federation Execution Processing.

Perform processing when create is ready

References addTestToFom(), DtScopedNotifyLevelChange::changeNotifyLevel(), connectMgr(), DtConnectionMgr::create(), DtFomClassMgr::create(), DtCreateResponseMsgKind, DtCRExecCouldNotOpenFed, DtCRExecCreated, DtMergeFomStatusSuccess, extend13and1516interop, false, 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 ( )

protectedvirtual

Process events from asynchronous thread.

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

Referenced by tickDistributor().

void DtFedExec::processFederationSynchronizedCallbacks ( DtSyncPt *  point )

protectedvirtual

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 )

protectedvirtual

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  )

protectedvirtual

Process a join.

References DtInteractionClassInfo::baseClass(), DtObjectClassInfo::baseClass(), DtScopedNotifyLevelChange::changeNotifyLevel(), DtFomClassMgr::clone(), DtConnectionMgr::connectionId(), connectMgr(), DtConnectionMgr::create(), DtFomClassMgr::create(), DtJoinResponseMsg::DT_FED_FILE_MERGE_PROBLEM, DtJoinResponseMsg::DT_FED_FILE_NOT_READY, DtJoinResponseMsg::DT_NO_ERROR, DtMergeFomStatusSuccess, DtNewFomClassesMsgKind, extend13and1516interop, false, fedExHandle(), fedExName(), DtRIDParameters::fomModuleMerging, fomModules(), getReader(), DtInteractionClassInfo::handle(), DtObjectClassInfo::handle(), 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, DtFomClassMgr::numClasses(), DtFomClassMgr::numInteractions(), DtConnectionMgr::params(), DtAsyncFileDistributorRunnable::postCommand(), removeJoinFomModuleForConnection(), resetControl(), DtConnectionMgr::sendAndDelete(), 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 )

protectedvirtual

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(), DtFedJoinInfo::myAstntCompId, 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, 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 )

protectedvirtual

References DtJoinMsg::assistantCompId(), 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(), DtRtiMsg::fedExHandle(), 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::myAstntCompId, 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(), and true.

void DtFedExec::processJoinReady ( )

protectedvirtual

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 )

protectedvirtual

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 )

protectedvirtual

References 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, myRestoreFederatesByOld, 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 )

protectedvirtual

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 )

protectedvirtual

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 )

protectedvirtual

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 )

protectedvirtual

References DtToString(), false, 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 )

protectedvirtual

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 )

protectedvirtual

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, myFedExHandle, myFedExName, myFedHandlesInUse, DtFedJoinInfo::myFedId, myJoiningFederates, myJoiningFederatesByID, myPendingRestoreFederates, myPendingSaveFederates, 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 )

protectedvirtual

References connectMgr(), DtResponseFail, DtResponseSuccess, DtRestoreResultFederateFailure, endRestore(), DtRtiMsg::federateHandle(), fedExHandle(), getFederate(), DtFederate::getHandle(), DtRtiMsg::isForExec(), isMember(), myDefaultWait, myFedExHandle, myFedExName, myPendingRestoreFederates, myRestore, myRestoreFederatesByOld, 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 )

protectedvirtual

References DtRestoreResultFederateFailure, DtRestoreResultSucess, endRestore(), DtRtiMsg::federateHandle(), getFederate(), DtRtiMsg::isForExec(), isMember(), myFedExHandle, myFedExName, myPendingRestoreFederates, 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 )

protectedvirtual

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

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

static

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

void DtFedExec::processSaveBegun ( const DtSaveBegunMsg &  msg )

protectedvirtual

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 )

protectedvirtual

References DtSaveFinishedFederateFailure, DtSaveFinishedSuccess, DtWaitingForFederationToSave, endSave(), DtRtiMsg::federateHandle(), getFederate(), DtRtiMsg::isForExec(), isMember(), myFedExHandle, myFedExName, myPendingSaveFederates, 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 )

protectedvirtual

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 )

protectedvirtual

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 )

protectedvirtual

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

void DtFedExec::processSyncPtAchievedCallbacks ( DtSyncPt *  point, DtFederate *  federate  )

protectedvirtual

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 )

protectedvirtual

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 )

protectedvirtual

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 ( )

protectedvirtual

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 )

protectedvirtual

restores the fedex Return boolean: save was successful?

References addFederate(), DtSyncHashlist::addSyncPoint(), DtFederate::assistantCompId(), DtRtiMtdDestinationList::destinationIndex(), DtHlaVersionUnknown, DtSyncHashlist::empty(), DtFederate::getConnectionHandle(), DtFederate::getFederateHost(), DtFederate::getFederateHostName(), DtRtiMtdDestinationList::getMaxDestinations(), DtFederate::getName(), getRestoreFileName(), DtFederate::getType(), DtFederate::hlaVersion(), myDesignatedFederate, myFederateHdlsByName, myFederateReservedNames, myFederates, myFederatesByName, myFedHandlesInUse, myFreeFedHandle, myInitiatedSaveFederates, myJoiningFederates, myJoiningFederatesByID, myNumFederates, myReservedNames, myRestoreFederatesByNew, myRestoreFederatesByOld, 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 )

protectedvirtual

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 )

protectedvirtual

saves the fedex Return boolean: save was successful?

References DtFederate::getConnectionHandle(), DtFederate::getHandle(), DtFederate::getName(), 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 )

protectedvirtual

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

Referenced by processJoinConfirm().

void DtFedExec::sendEnableDisableNetworkTestingMsg ( const char *  name, bool  enabled  )

protectedvirtual

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()  )

protectedvirtual

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  )

protectedvirtual

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  )

protectedvirtual

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  )

protectedvirtual

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  )

protectedvirtual

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

Referenced by processQueryRestoreStatus().

void DtFedExec::sendSaveInitiateConstrainedMsg ( const char *  labelVal )

protectedvirtual

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

Referenced by initiateSave().

void DtFedExec::sendSaveInitiateMsg ( const char *  labelVal )

protectedvirtual

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  )

protectedvirtual

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  )

protectedvirtual

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  )

protectedvirtual

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 )

protectedvirtual

Send MOM report synchronization point interaction.

References DtSyncPointQueryMsg::classHandle(), connectMgr(), DtConnectionMgr::create(), DtDefaultRegionSetHandle, DtInteractionRoMsgKind, DtToWString(), DtSyncHashlist::list(), maxNumFederates, 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 )

protectedvirtual

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(), maxNumFederates, 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  )

protectedvirtual

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

protectedvirtual

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 ( )

protectedvirtual

Tick the distributor.

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

Referenced by tick().

void DtFedExec::tickFederates ( )

protectedvirtual

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 ( )

protectedvirtual

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 ( )

protectedvirtual

Tick actions.

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

References DtRestoreResultFailureDetected, DtSaveFinishedFailureDetected, endRestore(), endSave(), 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()().

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(), initializeRestore(), initiateSave(), isMember(), printFederates(), processInitiatedSave(), processOwnership(), processQueryRestoreStatus(), processQuerySaveStatus(), processRestoreRequest(), pushFomModuleToJoinedFederates(), removeFederateConnection(), resetClockForHeartBeat(), resetControl(), restore(), restoreFederateConnection(), retireSyncPoint(), save(), sendSyncPointStatusReport(), synchronized(), tickFederates(), and ~DtFedExec().

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().

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(), initializeRestore(), numFederates(), restore(), and save().

std::set<DtFederateHandle> DtFedExec::myPendingRestoreFederates

protected

Referenced by endRestore(), processResign(), processRestoreBegun(), processRestoreComplete(), and processRestoreRequest().

std::set<DtFederateHandle> DtFedExec::myPendingSaveFederates

protected

Referenced by endSave(), initiateSave(), processResign(), and processSaveComplete().

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().

DtFederateHandleInfoMap DtFedExec::myRestoreFederatesByNew

protected

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

DtFederateHandleInfoMap DtFedExec::myRestoreFederatesByOld

protected

Referenced by endRestore(), initializeRestore(), processQueryRestoreStatus(), 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(), initializeRestore(), processAchievedSyncPoint(), processRegisterSyncPoint(), processResign(), restore(), retireSyncPoint(), save(), sendSyncPointReport(), sendSyncPointStatusReport(), and ~DtFedExec().

std::map<DtString, DtFileInformation*> DtFedExec::myTakenFiles

protected

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 = ""

staticprivate

Referenced by fedFileName().

DtFedExecCreator DtFedExec::theCreator = NULL

staticprotected

Referenced by create(), and setCreatorFunction().

const std::vector< DtString > DtFedExec::theEmptyStringSet = std::vector<DtString>()

staticprotected

Referenced by handleJoinFailureCases(), and joinFomModulesForConnection().

---

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

• fedex.h
• fedex.cxx