Distributes fomModule files from initiating federate to RtiExec and then from RtiExec to all joining federates. More...

Inheritance diagram for DtAsyncFileDistributorRunnable:

Collaboration diagram for DtAsyncFileDistributorRunnable:

Public Member Functions
	DtAsyncFileDistributorRunnable (DtFedExec *parent)
	Fedex Constructor.
virtual	~DtAsyncFileDistributorRunnable ()
	Destructor.
virtual std::auto_ptr < DtDistributorThreadEvent >	getNextEvent ()
virtual void	postCommand (std::auto_ptr< DtFedExecDistribFunctor > cmd)
virtual void	setOnExitHandler (const DtDistributorThreadEvent &fn)
virtual void	registerUploadFedFileToExecEvent (const DtDistribFunctor &fn)
virtual void	registerFedFileRequestsEvent (const DtDistribFunctor &fn)
virtual void	registerRequestedModulesArrivedEvent (const DtDistribFunctor &fn)
virtual void	registerTakeFileEvent (const DtDistribFunctor &fn)
virtual void	registerPushFedFileToFederatesEvent (const DtDistribFunctor &fn)
virtual void	registerPushFedFileToSingleFederateEvent (const DtDistribFunctor &fn)
virtual void	run ()
	Thread Functions.
virtual void	requestFedFileUploadToExec (const unsigned long initiatingFedID, const std::vector< DtString > *modules)
virtual bool	sendFedFile (const std::vector< DtString > &modules, DtFederateHandle recipient)
virtual void	fedFileUploaded (const DtString fileUploaded)
	Called when Fom Module received successfully.
void	processTakeFileCmd (std::map< DtString, DtFileInformation * >)
void	processPushFedFileToAllFederates (DtString name, int size, const char *buff, unsigned long destination)
void	processFileRequested (const DtFomModuleRequestMsg &cmd)
void	processFileReceived (const DtFomModuleDistributionMsg &cmd)
bool	requestsPending () const
	Are there outstanding requests to be handled?
Public Member Functions inherited from DtFileDistributor
virtual bool	sendFedFile (const std::vector< MAKRti::DtString > &modules)
	Override sendFedFile upload fed files passed in.
virtual bool	pushFedFile (DtConnectionMgr connMgr, const MAKRti::DtString &fileName, const unsigned int fileSize, const char fileBuffer, const DtFederateHandle destination=0)
	pushFedFile
virtual void	fedFileUploaded (const MAKRti::DtString fileUploaded)
	Called when Fom Module received successfully.
virtual bool	fileReceived (const DtFomModuleDistributionMsg &msg, bool &areAllHere)
virtual bool	fileRequested (const DtFomModuleRequestMsg &msg)
virtual void	removeFile (const MAKRti::DtString fileName)
	Remove all knowledge of this file from myFiles.
virtual void	removeFiles (const std::vector< MAKRti::DtString > &modules)
	Remove all knowledge of these file from myFiles.
virtual bool	fedFileReady (const MAKRti::DtString &fileName) const
	Does the distributor have a valid copy of this fom Module.
virtual bool	fedFilesReady (const std::vector< MAKRti::DtString > *fileNames) const
	Does the distributor have a valid copy of all of these fom Modules.
const FILE *	fedFilePtr (MAKRti::DtString fileName) const
	Get the fed file pointer.
const char *	fedFileBuff (MAKRti::DtString fileName) const
	Get the fed file buffer.
DtFileInformation *	takeFedFile (MAKRti::DtString fileName)
	Take ownership of the file.
unsigned int	fileSize (MAKRti::DtString fileName) const
FILE *	getTmpFile ()
void	setFedHandle (unsigned int newHandle)
	Set the Fed Handle of the distributor.
void	setFedexHandle (unsigned int newHandle)

Static Public Member Functions
static DtAsyncFileDistributorRunnable *	create (DtFedExec *parent)
Static Public Member Functions inherited from DtFileDistributor
static void	setCreatorFunction (DtFileDistributorCreator fn)

Protected Types
typedef std::list < DtDistributorThreadEvent * >	DtDistributorThreadEventList
typedef std::pair < DtDistributorThreadEvent *, bool >	DtMsgFunctorIsMomMsgPair
Protected Types inherited from DtFileDistributor
typedef std::list< DtRtiMsg * >	rtiMsgList

Protected Member Functions
void	signalFrontEnd () const
bool	executeCommand ()
void	processInternalCommands ()
void	changeCallbackEvents (const DtDistribFunctorChangeRequest &fn)
void	clearEventList (rtiMsgList &theEventList)
Protected Member Functions inherited from DtFileDistributor
	DtFileDistributor (const int fedExHandle, const int federateHandle, const MAKRti::DtString &fedExName)
	Constructor.
virtual	~DtFileDistributor ()
	Destructor.

Protected Attributes
bool	myStopped
std::auto_ptr < DtFedExecDistribFunctor >	mySignal
std::auto_ptr < DtDistributorThreadEvent >	myOnExitEvent
DtThreadSafeQueue < DtDistributorThreadEvent >	myPendingCommands
DtThreadSafeQueue < DtDistributorThreadEvent >	myEventQueue
DtThreadSafeQueue < DtDistributorThreadEvent >	myInternalCmdQueue
DtDistributorThreadEventList	myRequestedModuleArrivedEvents
	Registered event functors.
DtDistributorThreadEventList	myTakeFileEvents
DtDistributorThreadEventList	myFedFileRequestedEvents
DtDistributorThreadEventList	myFedFileReceivedEvents
DtDistributorThreadEventList	myPushFedFileToAllFederatesEvents
DtDistributorThreadEventList	myPushFedFileToSingleFederateEvents
DtDistributorThreadEventList	myUploadRequestEvents
Protected Attributes inherited from DtFileDistributor
std::map< MAKRti::DtString, DtFileInformation * >	myFiles
	Map between files that have been uploaded to me and their 'file names'.
std::set< std::pair < DtFederateHandle, MAKRti::DtString > >	myPendingRequests
MAKRti::DtString	myFedExName
int	myFedExHandle
int	myFederateHandle
std::map< MAKRti::DtString, FILE * >	myOpenFileHandles

Private Member Functions
	DtAsyncFileDistributorRunnable ()
	DtAsyncFileDistributorRunnable (const DtAsyncFileDistributorRunnable &orig)
DtAsyncFileDistributorRunnable &	operator= (const DtAsyncFileDistributorRunnable &orig)

Private Attributes
DtFedExec *	myFedEx

Additional Inherited Members
Static Protected Attributes inherited from DtFileDistributor
static DtFileDistributorCreator	theCreator = 0

Detailed Description

Distributes fomModule files from initiating federate to RtiExec and then from RtiExec to all joining federates.

Member Typedef Documentation

typedef std::list<DtDistributorThreadEvent*> DtAsyncFileDistributorRunnable::DtDistributorThreadEventList

protected

typedef std::pair< DtDistributorThreadEvent*, bool> DtAsyncFileDistributorRunnable::DtMsgFunctorIsMomMsgPair

protected

Constructor & Destructor Documentation

DtAsyncFileDistributorRunnable::DtAsyncFileDistributorRunnable ( DtFedExec * parent )

Fedex Constructor.

DtAsyncFileDistributorRunnable::~DtAsyncFileDistributorRunnable ( )

virtual

Destructor.

References myStopped.

DtAsyncFileDistributorRunnable::DtAsyncFileDistributorRunnable ( )

private

Referenced by create().

DtAsyncFileDistributorRunnable::DtAsyncFileDistributorRunnable ( const DtAsyncFileDistributorRunnable & orig )

private

Member Function Documentation

void DtAsyncFileDistributorRunnable::changeCallbackEvents ( const DtDistribFunctorChangeRequest & fn )

protected

Referenced by processInternalCommands().

void DtAsyncFileDistributorRunnable::clearEventList ( rtiMsgList & theEventList )

protected

DtAsyncFileDistributorRunnable * DtAsyncFileDistributorRunnable::create ( DtFedExec * parent )

static

References DtAsyncFileDistributorRunnable().

bool DtAsyncFileDistributorRunnable::executeCommand ( )

protected

References myEventQueue, myPendingCommands, DtThreadSafeQueue< T >::pop(), DtThreadSafeQueue< T >::push_back(), and signalFrontEnd().

Referenced by run().

void DtAsyncFileDistributorRunnable::fedFileUploaded ( const DtString fileUploaded )

virtual

Called when Fom Module received successfully.

References myEventQueue, myRequestedModuleArrivedEvents, and DtThreadSafeQueue< T >::push_back().

Referenced by processFileReceived().

std::auto_ptr< DtDistributorThreadEvent > DtAsyncFileDistributorRunnable::getNextEvent ( )

virtual

References myEventQueue, and DtThreadSafeQueue< T >::pop().

Referenced by DtFedExec::processEvents().

DtAsyncFileDistributorRunnable& DtAsyncFileDistributorRunnable::operator= ( const DtAsyncFileDistributorRunnable & orig )

private

void DtAsyncFileDistributorRunnable::postCommand ( std::auto_ptr< DtFedExecDistribFunctor > cmd )

virtual

References myPendingCommands, and DtThreadSafeQueue< T >::push_back().

Referenced by DtFedExec::createDistributor(), DtFedExec::multFileReceivedCb(), DtFedExec::multFileRequestedCb(), DtFedExec::processJoin(), DtFedExec::processRequestedModulesArrived(), DtFedExec::pushFomModuleToJoinedFederates(), and DtFedExec::requestFedFileUpload().

void DtAsyncFileDistributorRunnable::processFileReceived ( const DtFomModuleDistributionMsg & cmd )

References fedFileUploaded(), DtFileDistributor::fileReceived(), DtFomModuleDistributionMsg::fomModuleName(), myFedFileReceivedEvents, and DtFileDistributor::myFiles.

void DtAsyncFileDistributorRunnable::processFileRequested ( const DtFomModuleRequestMsg & cmd )

References DtFileDistributor::fileRequested(), DtFomModuleRequestMsg::getFomModuleNames(), sendFedFile(), and DtFomModuleRequestMsg::sourceID().

void DtAsyncFileDistributorRunnable::processInternalCommands ( )

protected

References changeCallbackEvents(), myInternalCmdQueue, and DtThreadSafeQueue< T >::pop().

Referenced by run().

void DtAsyncFileDistributorRunnable::processPushFedFileToAllFederates	(	DtString	name,
		int	size,
		const char *	buff,
		unsigned long	destination
	)

References myPushFedFileToAllFederatesEvents.

void DtAsyncFileDistributorRunnable::processTakeFileCmd ( std::map< DtString, DtFileInformation * > files )

References myEventQueue, myTakeFileEvents, DtThreadSafeQueue< T >::push_back(), and DtFileDistributor::takeFedFile().

void DtAsyncFileDistributorRunnable::registerFedFileRequestsEvent ( const DtDistribFunctor & fn )

virtual

References DtDistribFunctorChangeRequest::FedFileRequested, myInternalCmdQueue, and DtThreadSafeQueue< T >::push_back().

Referenced by DtFedExec::createDistributor().

void DtAsyncFileDistributorRunnable::registerPushFedFileToFederatesEvent ( const DtDistribFunctor & fn )

virtual

References myInternalCmdQueue, DtThreadSafeQueue< T >::push_back(), and DtDistribFunctorChangeRequest::PushFedFileToAllFederates.

Referenced by DtFedExec::createDistributor().

void DtAsyncFileDistributorRunnable::registerPushFedFileToSingleFederateEvent ( const DtDistribFunctor & fn )

virtual

References myInternalCmdQueue, DtThreadSafeQueue< T >::push_back(), and DtDistribFunctorChangeRequest::PushFedFileToSingleFederate.

void DtAsyncFileDistributorRunnable::registerRequestedModulesArrivedEvent ( const DtDistribFunctor & fn )

virtual

References myInternalCmdQueue, DtThreadSafeQueue< T >::push_back(), and DtDistribFunctorChangeRequest::RequestedModuleArrived.

Referenced by DtFedExec::createDistributor().

void DtAsyncFileDistributorRunnable::registerTakeFileEvent ( const DtDistribFunctor & fn )

virtual

References myInternalCmdQueue, DtThreadSafeQueue< T >::push_back(), and DtDistribFunctorChangeRequest::TakeFile.

Referenced by DtFedExec::createDistributor().

void DtAsyncFileDistributorRunnable::registerUploadFedFileToExecEvent ( const DtDistribFunctor & fn )

virtual

References myInternalCmdQueue, DtThreadSafeQueue< T >::push_back(), and DtDistribFunctorChangeRequest::UploadToExec.

void DtAsyncFileDistributorRunnable::requestFedFileUploadToExec	(	const unsigned long	initiatingFedID,
		const std::vector< DtString > *	modules
	)

virtual

References myEventQueue, myFedFileRequestedEvents, and DtThreadSafeQueue< T >::push_back().

Referenced by DtGetFileFromDistributorCmd::operator()().

bool DtAsyncFileDistributorRunnable::requestsPending ( ) const

Are there outstanding requests to be handled?

Reimplemented from DtFileDistributor.

References DtFileDistributor::myPendingRequests.

void DtAsyncFileDistributorRunnable::run ( )

virtual

Thread Functions.

References RTI::Exception::_name, RTI::Exception::_reason, DtInitialException(), DtToString(), executeCommand(), myEventQueue, myOnExitEvent, myStopped, DtAssistantPopupHelper::popupAssistantMessage(), processInternalCommands(), DtThreadSafeQueue< T >::push_back(), rti1516::Exception::what(), and rti1516e::Exception::what().

bool DtAsyncFileDistributorRunnable::sendFedFile	(	const std::vector< DtString > &	modules,
		DtFederateHandle	recipient
	)

virtual

References myEventQueue, DtFileDistributor::myFiles, myPushFedFileToAllFederatesEvents, DtThreadSafeQueue< T >::push_back(), and DtFileDistributor::sendFedFile().

Referenced by processFileRequested().

void DtAsyncFileDistributorRunnable::setOnExitHandler ( const DtDistributorThreadEvent & fn )

virtual

References DtDistribFunctorChangeRequest::BackendExited, myInternalCmdQueue, and DtThreadSafeQueue< T >::push_back().

void DtAsyncFileDistributorRunnable::signalFrontEnd ( ) const

protected

References mySignal.

Referenced by executeCommand().

Member Data Documentation

DtThreadSafeQueue<DtDistributorThreadEvent> DtAsyncFileDistributorRunnable::myEventQueue

protected

Referenced by executeCommand(), fedFileUploaded(), getNextEvent(), processTakeFileCmd(), requestFedFileUploadToExec(), run(), and sendFedFile().

DtFedExec* DtAsyncFileDistributorRunnable::myFedEx

private

DtDistributorThreadEventList DtAsyncFileDistributorRunnable::myFedFileReceivedEvents

protected

Referenced by changeCallbackEvents(), and processFileReceived().

DtDistributorThreadEventList DtAsyncFileDistributorRunnable::myFedFileRequestedEvents

protected

Referenced by changeCallbackEvents(), and requestFedFileUploadToExec().

DtThreadSafeQueue<DtDistributorThreadEvent> DtAsyncFileDistributorRunnable::myInternalCmdQueue

protected

Referenced by processInternalCommands(), registerFedFileRequestsEvent(), registerPushFedFileToFederatesEvent(), registerPushFedFileToSingleFederateEvent(), registerRequestedModulesArrivedEvent(), registerTakeFileEvent(), registerUploadFedFileToExecEvent(), and setOnExitHandler().

std::auto_ptr<DtDistributorThreadEvent> DtAsyncFileDistributorRunnable::myOnExitEvent

protected

Referenced by changeCallbackEvents(), and run().

DtThreadSafeQueue<DtDistributorThreadEvent> DtAsyncFileDistributorRunnable::myPendingCommands

protected

Referenced by executeCommand(), and postCommand().

DtDistributorThreadEventList DtAsyncFileDistributorRunnable::myPushFedFileToAllFederatesEvents

protected

Referenced by changeCallbackEvents(), processPushFedFileToAllFederates(), and sendFedFile().

DtDistributorThreadEventList DtAsyncFileDistributorRunnable::myPushFedFileToSingleFederateEvents

protected

Referenced by changeCallbackEvents().

DtDistributorThreadEventList DtAsyncFileDistributorRunnable::myRequestedModuleArrivedEvents

protected

Registered event functors.

Referenced by changeCallbackEvents(), and fedFileUploaded().

std::auto_ptr<DtFedExecDistribFunctor> DtAsyncFileDistributorRunnable::mySignal

protected

Referenced by signalFrontEnd().

bool DtAsyncFileDistributorRunnable::myStopped

protected

Referenced by run(), and ~DtAsyncFileDistributorRunnable().

DtDistributorThreadEventList DtAsyncFileDistributorRunnable::myTakeFileEvents

protected

Referenced by changeCallbackEvents(), and processTakeFileCmd().

DtDistributorThreadEventList DtAsyncFileDistributorRunnable::myUploadRequestEvents

protected

Referenced by changeCallbackEvents().

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

Public Member Functions

Static Public Member Functions

Protected Types

Protected Member Functions

Protected Attributes

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Member Typedef Documentation

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation