DtAsyncFileDistributorRunnable Class Reference

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 * >	myTempFileHandles

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

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.

virtual DtAsyncFileDistributorRunnable::~DtAsyncFileDistributorRunnable ( )

virtual

Destructor.

DtAsyncFileDistributorRunnable::DtAsyncFileDistributorRunnable ( )

private

DtAsyncFileDistributorRunnable::DtAsyncFileDistributorRunnable ( const DtAsyncFileDistributorRunnable &  orig )

private

Member Function Documentation

void DtAsyncFileDistributorRunnable::changeCallbackEvents ( const DtDistribFunctorChangeRequest &  fn )

protected

void DtAsyncFileDistributorRunnable::clearEventList ( rtiMsgList &  theEventList )

protected

static DtAsyncFileDistributorRunnable* DtAsyncFileDistributorRunnable::create ( DtFedExec *  parent )

static

bool DtAsyncFileDistributorRunnable::executeCommand ( )

protected

virtual void DtAsyncFileDistributorRunnable::fedFileUploaded ( const DtString  fileUploaded )

virtual

Called when Fom Module received successfully.

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

virtual

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

private

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

virtual

void DtAsyncFileDistributorRunnable::processFileReceived

(

const DtFomModuleDistributionMsg &

cmd

)

void DtAsyncFileDistributorRunnable::processFileRequested

(

const DtFomModuleRequestMsg &

cmd

)

void DtAsyncFileDistributorRunnable::processInternalCommands ( )

protected

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

void DtAsyncFileDistributorRunnable::processTakeFileCmd

(

std::map< DtString, DtFileInformation * >

)

virtual void DtAsyncFileDistributorRunnable::registerFedFileRequestsEvent ( const DtDistribFunctor &  fn )

virtual

virtual void DtAsyncFileDistributorRunnable::registerPushFedFileToFederatesEvent ( const DtDistribFunctor &  fn )

virtual

virtual void DtAsyncFileDistributorRunnable::registerPushFedFileToSingleFederateEvent ( const DtDistribFunctor &  fn )

virtual

virtual void DtAsyncFileDistributorRunnable::registerRequestedModulesArrivedEvent ( const DtDistribFunctor &  fn )

virtual

virtual void DtAsyncFileDistributorRunnable::registerTakeFileEvent ( const DtDistribFunctor &  fn )

virtual

virtual void DtAsyncFileDistributorRunnable::registerUploadFedFileToExecEvent ( const DtDistribFunctor &  fn )

virtual

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

virtual

bool DtAsyncFileDistributorRunnable::requestsPending

(

)

const

Are there outstanding requests to be handled?

Reimplemented from DtFileDistributor.

virtual void DtAsyncFileDistributorRunnable::run ( )

virtual

Thread Functions.

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

virtual

virtual void DtAsyncFileDistributorRunnable::setOnExitHandler ( const DtDistributorThreadEvent &  fn )

virtual

void DtAsyncFileDistributorRunnable::signalFrontEnd ( ) const

protected

Member Data Documentation

DtThreadSafeQueue<DtDistributorThreadEvent> DtAsyncFileDistributorRunnable::myEventQueue

protected

DtFedExec* DtAsyncFileDistributorRunnable::myFedEx

private

DtDistributorThreadEventList DtAsyncFileDistributorRunnable::myFedFileReceivedEvents

protected

DtDistributorThreadEventList DtAsyncFileDistributorRunnable::myFedFileRequestedEvents

protected

DtThreadSafeQueue<DtDistributorThreadEvent> DtAsyncFileDistributorRunnable::myInternalCmdQueue

protected

std::auto_ptr<DtDistributorThreadEvent> DtAsyncFileDistributorRunnable::myOnExitEvent

protected

DtThreadSafeQueue<DtDistributorThreadEvent> DtAsyncFileDistributorRunnable::myPendingCommands

protected

DtDistributorThreadEventList DtAsyncFileDistributorRunnable::myPushFedFileToAllFederatesEvents

protected

DtDistributorThreadEventList DtAsyncFileDistributorRunnable::myPushFedFileToSingleFederateEvents

protected

DtDistributorThreadEventList DtAsyncFileDistributorRunnable::myRequestedModuleArrivedEvents

protected

Registered event functors.

std::auto_ptr<DtFedExecDistribFunctor> DtAsyncFileDistributorRunnable::mySignal

protected

bool DtAsyncFileDistributorRunnable::myStopped

protected

DtDistributorThreadEventList DtAsyncFileDistributorRunnable::myTakeFileEvents

protected

DtDistributorThreadEventList DtAsyncFileDistributorRunnable::myUploadRequestEvents

protected

---

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

• asynchronousFileDistributor.h