Sorted list for queueing messages in time stamped order. More...

Inheritance diagram for DtRtiMsgQueue:

Collaboration diagram for DtRtiMsgQueue:

Public Member Functions
	DtRtiMsgQueue (DtLogicalTimeFactory *fedTimeFactory)
virtual	~DtRtiMsgQueue ()
virtual bool	timeRegulating ()
	Set/Get status of time regulation/constraint.
virtual void	setTimeRegulating (bool isTimeRegulating)
virtual bool	timeConstrained ()
virtual void	setTimeConstrained (bool isTimeConstrained)
virtual bool	asynchronous ()
virtual void	setAsynchronous (bool isAsynchronous)
virtual bool	timeAvailable ()
virtual void	setTimeAvailable (bool isTimeAvailable)
virtual bool	timeAdvancing ()
virtual void	setTimeAdvancing (bool isTimeAdvancing)
virtual const RTI::FedTime &	timestamp ()
	Set/Get current federate time.
virtual void	setTimestamp (const RTI::FedTime &federateTime)
virtual const RTI::FedTime &	lookahead ()
	Set/Get current federate lookahead.
virtual void	setLookahead (const RTI::FedTime &lookaheadValue)
virtual const RTI::FedTime &	galt ()
	Set/Get greatest allowed logical time When in the time advancing state messages with timestamps less than this value (and greater than logical time) are passed through without being queued.
virtual void	setGalt (const RTI::FedTime &federateTime)
virtual bool	queueMsg (DtRtiMsg const &msg)
	A clone of the message is added to queue if the queue is time constrained, message is timestamp order, and message timestamp is greater than queue timestamp.
virtual DtRtiMsg *	removeMsg (const DtMessageRetractionHandle &retractHandle)
	Return and remove the message with the supplied retraction handle.
virtual bool	deleteMsg (const DtMessageRetractionHandle &retractHandle)
	Remove and delete the message with the supplied retraction handle Return boolean: message was in queue and deleted?
virtual void	deleteMsgs (DtFederateHandle federateHandle)
	Remove and delete the messages with the supplied federate handle.
virtual void	deleteAll ()
	Remove and delete all the messages.
virtual DtRtiMsg *	nextMsg (const RTI::FedTime &timestamp)
	Return and remove the next message with a lower timestamp.
virtual DtRtiMsg *	nextTsoMsg (const RTI::FedTime &timestamp)
	Return and remove the next TSO message with a lower timestamp.
virtual DtRtiMsg *	removeNextTsoMsg ()
	Remove the next TSO message.
virtual DtRtiMsg *	peekNextTsoMsg ()
	Return but do not remove the next TSO message.
unsigned int	roQueueLength () const
Protected Member Functions
virtual DtSortedListItem *	newItem (void *data)
	Create a new DtMessageItem envelope for the data to be inserted into the list.
	DtRtiMsgQueue (const DtRtiMsgQueue &orig)
DtRtiMsgQueue &	operator= (DtRtiMsgQueue const &orig)
virtual DtSortedListItem *	add (void *data)
	Only internal methods should use this non typed add.
Protected Attributes
MAKRti::DtList	myRoList
bool	myTimeConstrainedEnabled
bool	myTimeRegulatingEnabled
bool	myAsynchronous
bool	myTimeAvailable
bool	myTimeAdvancing
DtLogicalTimeFactory *	myLogicalTimeFactory
std::auto_ptr< RTI::FedTime >	myTime
std::auto_ptr< RTI::FedTime >	myLookahead
std::auto_ptr< RTI::FedTime >	myGalt

Detailed Description

Sorted list for queueing messages in time stamped order.

Constructor & Destructor Documentation

DtRtiMsgQueue::DtRtiMsgQueue ( DtLogicalTimeFactory * fedTimeFactory )

References DtLogicalTimeFactory::makeInitial(), DtLogicalTimeFactory::makeZero(), myGalt, myLogicalTimeFactory, myLookahead, and myTime.

DtRtiMsgQueue::~DtRtiMsgQueue ( ) [virtual]

References deleteAll().

DtRtiMsgQueue::DtRtiMsgQueue ( const DtRtiMsgQueue & orig ) [protected]

Member Function Documentation

DtSortedListItem * DtRtiMsgQueue::add ( void * data ) [protected, virtual]

Only internal methods should use this non typed add.

Reimplemented from DtSortedList.

Referenced by queueMsg().

bool DtRtiMsgQueue::asynchronous ( ) [inline, virtual]

References myAsynchronous.

Referenced by queueMsg().

void DtRtiMsgQueue::deleteAll ( ) [virtual]

Remove and delete all the messages.

References DtSortedList::first(), myRoList, and NULL.

Referenced by ~DtRtiMsgQueue().

bool DtRtiMsgQueue::deleteMsg ( const DtMessageRetractionHandle & retractHandle ) [virtual]

Remove and delete the message with the supplied retraction handle Return boolean: message was in queue and deleted?

References removeMsg().

void DtRtiMsgQueue::deleteMsgs ( DtFederateHandle federateHandle ) [virtual]

Remove and delete the messages with the supplied federate handle.

References DtSortedListItem::data(), DtRtiMsg::federateHandle(), DtSortedList::first(), DtSortedListItem::next(), and NULL.

const RTI::FedTime & DtRtiMsgQueue::galt ( ) [inline, virtual]

Set/Get greatest allowed logical time When in the time advancing state messages with timestamps less than this value (and greater than logical time) are passed through without being queued.

Time available includes equal values.

Referenced by queueMsg().

const RTI::FedTime & DtRtiMsgQueue::lookahead ( ) [inline, virtual]

Set/Get current federate lookahead.

DtSortedListItem * DtRtiMsgQueue::newItem ( void * data ) [protected, virtual]

Create a new DtMessageItem envelope for the data to be inserted into the list.

Reimplemented from DtSortedList.

References myLogicalTimeFactory.

DtRtiMsg * DtRtiMsgQueue::nextMsg ( const RTI::FedTime & timestamp ) [virtual]

Return and remove the next message with a lower timestamp.

References NULL.

DtRtiMsg * DtRtiMsgQueue::nextTsoMsg ( const RTI::FedTime & timestamp ) [virtual]

Return and remove the next TSO message with a lower timestamp.

References DtSortedListItem::data(), NULL, and DtRtiMsg::time().

DtRtiMsgQueue & DtRtiMsgQueue::operator= ( DtRtiMsgQueue const & orig ) [protected]

DtRtiMsg * DtRtiMsgQueue::peekNextTsoMsg ( ) [virtual]

Return but do not remove the next TSO message.

References DtSortedListItem::data(), DtSortedList::first(), and NULL.

bool DtRtiMsgQueue::queueMsg ( DtRtiMsg const & msg ) [virtual]

A clone of the message is added to queue if the queue is time constrained, message is timestamp order, and message timestamp is greater than queue timestamp.

Return boolean: message was added to queue?

References add(), asynchronous(), DtRtiMsg::cloneWithTransport(), galt(), DtRtiMsg::isConstrained(), myLogicalTimeFactory, myRoList, myTime, DtRtiMsg::orderType(), printableString(), DtRtiMsg::time(), timeAdvancing(), timeAvailable(), and timeConstrained().