Instances of DtInteractionMgr manage the sending and receiving of interactions. More...

Collaboration diagram for DtInteractionMgr:

Public Types
typedef DtInteractionMgr (	DtInteractionMgrCreator )(DtFederateMgr *fedMgr)
	Creator function.

Public Member Functions
virtual	~DtInteractionMgr ()
	Destructor.
virtual void	postJoinInit ()
	Post join processing. All managers shall have been created and initialized.
virtual bool	isPostJoined () const
	Return bool: Was the post join initialization perfomerd?
virtual void	publish (DtInteractionClassHandle theInteraction)
	Process publish service call.
virtual void	unpublish (DtInteractionClassHandle theInteraction)
	Process unpublish service call.
virtual void	subscribe (DtInteractionClassHandle theClass, bool active)
	Process subscribe service call.
virtual void	unsubscribe (DtInteractionClassHandle theClass)
	Process unsubscribe service call.
virtual unsigned long	send (DtInteractionClassHandle theInteraction, const DtPhvps &params, RTI::FedTime const theTime, const char theTag, DtHandle channel, bool anonymous=false)
	Process send interaction service call.
MAKRti::DtTransportType	getTransport (DtInteractionClassHandle theClass)
	Get the transport for the given class.
virtual void	setTransport (DtInteractionClassHandle theClass, MAKRti::DtTransportType theType)
	Set the transport for the given class.
virtual void	setOrder (DtInteractionClassHandle theClass, MAKRti::DtOrderType theType)
	Set the order for the given class.
virtual int	acceptInteraction (const DtInteractionMsg &msg)
	DDM.
virtual int	subscribed (DtInteractionClassHandle handle)
	Returns 1 if subscribed to the class, 0 otherwise Assumes handle is defined.
virtual int	published (DtInteractionClassHandle handle)
	Returns 1 if published the class, 0 otherwise Assumes handle is defined.
virtual int	subscribed (DtInteractionClassInfo *classDesc)
	Returns 1 if subscribed to the class, 0 otherwise Assumes handle is defined.
virtual int	evaluateSubscription (DtRtiMsg const &msg)
	Determine if message is interaction and if so, is it subscribed e.g., would be delivered if processed Returns -1 if not an interaction, 0 if no delivery expected, 1 if delivery expected.
virtual void	sendSubscribeMsg (DtInteractionClassHandle theInter, bool isPassive, DtFederateHandle fedHandle)
	Send subscribe interaction message.
virtual void	sendSubscribeMsg (DtInteractionClassHandle theInter, bool isPassive, DtBitMask *sendMask=0)
virtual void	sendPublishMsg (DtInteractionClassHandle theInter)
	Send publish interaction message.
virtual void	sendUnsubscribeMsg (DtInteractionClassHandle theInter, bool forSmartForwarding=false)
	Send unsubscribe interaction message.
virtual void	sendUnpublishMsg (DtInteractionClassHandle theInter)
	Send unpublish interaction message.
virtual void	sendInteractionMsg (DtInteractionClassHandle theClass, const DtPhvps &theParams, MAKRti::DtTransportType transportType, MAKRti::DtOrderType orderType, RTI::FedTime const theTime, const char theTag, unsigned long serialNumber, DtHandle channel, bool anonymous=false)
	Send interaction message.
virtual void	addPendingStartInters (DtInteractionClassHandle theClass)
	Add a turnOn/OffInteractions call that should be made in the next tick call.
virtual void	addPendingStopInters (DtInteractionClassHandle theClass)
virtual void	sendPendingStartInters ()
	Send pending turnOn/OffInteractions.
virtual void	sendPendingStopInters ()
virtual void	sendPendingSubscription ()
	Send/add pending subscription class retransmissions that will get sent during next tick.
virtual void	addPendingSubscription (DtObjectClassHandle theClass, bool isPassive, DtFederateHandle fedHandle=0)
virtual void	sendPendingUnsubscription ()
	Send/add pending unsubscription class retransmissions that will get sent during next tick.
virtual void	addPendingUnsubscription (DtObjectClassHandle theClass, bool forSmartForwarding)
virtual void	preTick ()
	Called before processing messages in RTI ambassador tick / evoke callbacks.
virtual void	postTick ()
	Called after processing messages in RTI ambassador tick / evoke callbacks.
virtual void	processResign (const DtResignMsg &msg)
	Process resign message.
virtual DtInteractionClassInfo *	firstSubscribedClass (DtInteractionClassInfo *classDesc)
	Returns most specific superclass of class, to which we are subscribed.
void	enableRelevanceAdvisorySwitch ()
	Enable/Disable interactionRelevanceAdvisorySwitch 1516 throws exception if call is redundant.
void	disableRelevanceAdvisorySwitch ()
void	setRelevanceAdvisorySwitch (bool enableSwitch)
	Set/Get value of interactionRelevanceAdvisorySwitch.
bool	relevanceAdvisorySwitch ()
virtual MAKRti::DtInetAddr	localAddrMap (DtInteractionClassHandle theClass, DtHandle theChannel)
	Map the class and channel to a multicast address.
virtual bool	save (DtRtiSaveFile &file)
	Save the state information to the given file.
virtual void	prepareToRestore ()
	Prepare the state information to be restored (i.e., clear out existing data).
virtual bool	restore (DtRtiSaveFile &file)
	Restore the state information from the given file.
DtFederateMgr *	federateMgr ()
	Access the federate manager.
DtFederateMgr *	federateMgr () const
DtConnectionMgr *	connectMgr ()
	Access the connection manager.
DtConnectionMgr *	connectMgr () const
DtRIDParameters *	params ()
	Access the RID parameters.
DtRIDParameters *	params () const
DtFomClassMgr *	fom ()
	Access the fom manager.
DtFomClassMgr *	fom () const

Static Public Member Functions
static DtInteractionMgr *	create (DtFederateMgr *fedMgrPtr)
	A Interaction Manager instance is created and its pointer is returned.
static void	setCreatorFunction (DtInteractionMgrCreator fn)
	Register a creator function.
static void	setInternalCreatorFunction (DtInteractionMgrCreator fn)
	Register alternate internal creators.

Protected Types
typedef std::map < DtObjectClassHandle, DtBitMask * >	DtObjectClassMaskMap

Protected Member Functions
	DtInteractionMgr (DtFederateMgr *fedMgr)
	Constructor.
void	fastIncrementSentTally (DtInteractionClassHandle classHandle, MAKRti::DtTransportType transport)
void	fastIncrementReceivedTally (DtInteractionClassHandle classHandle, MAKRti::DtTransportType transport)
virtual void	processInteraction (const DtInteractionMsg &msg)
	Message callbacks called from registered callbacks.
virtual void	processPub (const DtPubInterMsg &msg)
virtual void	processUnpub (const DtUnpubInterMsg &msg)
virtual void	processSub (const DtSubInterMsg &msg)
virtual void	processUnsub (const DtUnsubInterMsg &msg)
virtual void	addClassMulticast (DtInteractionClassInfo *classDesc)
	Recursively add and remove the DM multicast address of this class and all its subclasses.
virtual void	removeClassMulticast (DtInteractionClassInfo *classDesc)
virtual void	destroyInteractionLists ()
	DDM.

Static Protected Member Functions
static void	processInteraction (const DtInteractionMsg &msg, void *usr)
	Message callback methods to register with connection manager The class instance is expected for user data.
static void	processPub (const DtPubInterMsg &msg, void *usr)
static void	processUnpub (const DtUnpubInterMsg &msg, void *usr)
static void	processSub (const DtSubInterMsg &msg, void *usr)
static void	processUnsub (const DtUnsubInterMsg &msg, void *usr)

Protected Attributes
DtFederateMgr *	myFederateMgr
	Access to the federate manager.
bool	myIsJoined
	Manager has performed join processing.
MAKRti::DtList	myPendingStartIntersList
	Pending start/stop interactions.
MAKRti::DtList	myPendingStopIntersList
std::set< DtRtiMsgKind >	myConstrainedInteractionKinds
bool	myRelevanceSwitch
	Indicates whether relevance advisory is enabled.
std::set< DtObjectClassHandle >	myRetransmitSubClass
	Set of class subscriptions to retransmit.
DtObjectClassMaskMap	myRetransmitSubClassMask
std::set< DtObjectClassHandle >	myRetransmitPassiveSubClass
std::set< DtObjectClassHandle >	myRetransmitUnsubClass
	Set of class unsubscriptions to retransmit.
std::set< DtObjectClassHandle >	myRetransmitUnsubClassForSmartForwarding

Static Protected Attributes
static DtInteractionMgrCreator	theCreator = 0
	The plugin creator.
static DtInteractionMgrCreator	theInternalCreator = 0
	The internal creator.

Private Member Functions
	DtInteractionMgr (DtInteractionMgr const &other)
	Copy constructor not implemented – Copy not allowed!
DtInteractionMgr &	operator= (DtInteractionMgr const &other)
	Assignment operator not implemented – Assignment not allowed!

Detailed Description

Instances of DtInteractionMgr manage the sending and receiving of interactions.

This class also handles subscription and publication information.

Member Typedef Documentation

typedef DtInteractionMgr*(* DtInteractionMgr::DtInteractionMgrCreator)(DtFederateMgr *fedMgr)

Creator function.

typedef std::map< DtObjectClassHandle,DtBitMask*> DtInteractionMgr::DtObjectClassMaskMap

protected

Constructor & Destructor Documentation

DtInteractionMgr::DtInteractionMgr ( DtFederateMgr * fedMgr )

protected

DtInteractionMgr::~DtInteractionMgr ( )

virtual

Destructor.

References connectMgr(), destroyInteractionLists(), processInteraction(), processPub(), processSub(), processUnpub(), processUnsub(), DtPubInterMsg::removeCallback(), DtUnpubInterMsg::removeCallback(), DtSubInterMsg::removeCallback(), DtUnsubInterMsg::removeCallback(), and DtInteractionRoMsg::removeCallback().

DtInteractionMgr::DtInteractionMgr ( DtInteractionMgr const & other )

private

Copy constructor not implemented – Copy not allowed!

Member Function Documentation

int DtInteractionMgr::acceptInteraction ( const DtInteractionMsg & msg )

virtual

DDM.

Return true if the interaction should be processed

References connectMgr(), DtRtiMsg::federateHandle(), and DtConnectionMgr::fedHandle().

Referenced by processInteraction().

void DtInteractionMgr::addClassMulticast ( DtInteractionClassInfo * classDesc )

protectedvirtual

Recursively add and remove the DM multicast address of this class and all its subclasses.

References connectMgr(), DtInteractionClassInfo::destinationAddress(), DtInteractionClassInfo::destinationDevice(), DtConnectionMgr::listenToMulticastGroup(), and DtInteractionClassInfo::subclasses().

Referenced by removeClassMulticast(), and subscribe().

void DtInteractionMgr::addPendingStartInters ( DtInteractionClassHandle theClass )

virtual

Add a turnOn/OffInteractions call that should be made in the next tick call.

If relevanceAdvisorySwitch is false, it's a no-op.

References myPendingStartIntersList, and relevanceAdvisorySwitch().

Referenced by DtInteractionClassInfo::publish(), and DtInteractionClassInfo::updateRelevance().

void DtInteractionMgr::addPendingStopInters ( DtInteractionClassHandle theClass )

virtual

References myPendingStopIntersList, and relevanceAdvisorySwitch().

Referenced by DtInteractionClassInfo::updateRelevance().

void DtInteractionMgr::addPendingSubscription	(	DtObjectClassHandle	theClass,
		bool	isPassive,
		DtFederateHandle	fedHandle = `0`
	)

virtual

References DtRtiMtdDestinationList::getMaxDestinations(), internalMsgSmartForwardingWhenUsingRtiexec, myRetransmitPassiveSubClass, myRetransmitSubClass, myRetransmitSubClassMask, myRetransmitUnsubClass, myRetransmitUnsubClassForSmartForwarding, params(), DtBitMask::reset(), DtBitMask::setBit(), and useRtiExec.

Referenced by processPub().

void DtInteractionMgr::addPendingUnsubscription	(	DtObjectClassHandle	theClass,
		bool	forSmartForwarding
	)

virtual

References myRetransmitPassiveSubClass, myRetransmitSubClass, myRetransmitUnsubClass, and myRetransmitUnsubClassForSmartForwarding.

Referenced by processPub().

DtConnectionMgr * DtInteractionMgr::connectMgr ( )

Access the connection manager.

References DtFederateMgr::connectMgr(), and federateMgr().

Referenced by acceptInteraction(), addClassMulticast(), DtInteractionMgr(), processInteraction(), processPub(), processResign(), processSub(), processUnpub(), processUnsub(), removeClassMulticast(), send(), sendInteractionMsg(), sendPendingStartInters(), sendPendingStopInters(), sendPendingSubscription(), sendPendingUnsubscription(), sendPublishMsg(), sendSubscribeMsg(), sendUnpublishMsg(), sendUnsubscribeMsg(), and ~DtInteractionMgr().

DtConnectionMgr * DtInteractionMgr::connectMgr ( ) const

References DtFederateMgr::connectMgr(), and federateMgr().

DtInteractionMgr * DtInteractionMgr::create ( DtFederateMgr * fedMgrPtr )

static

A Interaction Manager instance is created and its pointer is returned.

A registered creator is used if present; otherwise, an internal class is instantiated.

References DtInteractionMgr(), theCreator, and theInternalCreator.

Referenced by setCreatorFunction(), and setInternalCreatorFunction().

void DtInteractionMgr::destroyInteractionLists ( )

protectedvirtual

DDM.

Destroy processing lists

Referenced by ~DtInteractionMgr().

void DtInteractionMgr::disableRelevanceAdvisorySwitch ( )

References relevanceAdvisorySwitch(), and setRelevanceAdvisorySwitch().

void DtInteractionMgr::enableRelevanceAdvisorySwitch ( )

Enable/Disable interactionRelevanceAdvisorySwitch 1516 throws exception if call is redundant.

References relevanceAdvisorySwitch(), and setRelevanceAdvisorySwitch().

int DtInteractionMgr::evaluateSubscription ( DtRtiMsg const & msg )

virtual

Determine if message is interaction and if so, is it subscribed e.g., would be delivered if processed Returns -1 if not an interaction, 0 if no delivery expected, 1 if delivery expected.

References firstSubscribedClass(), fom(), DtInteractionMsg::handle(), DtFomClassMgr::interactionByHandle(), DtRtiMsg::msgKind(), and myConstrainedInteractionKinds.

Referenced by DtRtiMsgQueue::evaluateSubscription().

void DtInteractionMgr::fastIncrementReceivedTally	(	DtInteractionClassHandle	classHandle,
		MAKRti::DtTransportType	transport
	)

protected

References params().

Referenced by processInteraction().

void DtInteractionMgr::fastIncrementSentTally	(	DtInteractionClassHandle	classHandle,
		MAKRti::DtTransportType	transport
	)

protected

References params().

Referenced by sendInteractionMsg().

DtFederateMgr * DtInteractionMgr::federateMgr ( )

Access the federate manager.

References myFederateMgr.

Referenced by connectMgr(), fom(), params(), and processInteraction().

DtFederateMgr * DtInteractionMgr::federateMgr ( ) const

References myFederateMgr.

DtInteractionClassInfo * DtInteractionMgr::firstSubscribedClass ( DtInteractionClassInfo * classDesc )

virtual

Returns most specific superclass of class, to which we are subscribed.

References DtInteractionClassInfo::baseClass(), NULL, and subscribed().

Referenced by evaluateSubscription(), and processInteraction().

DtFomClassMgr * DtInteractionMgr::fom ( )

Access the fom manager.

References federateMgr(), and DtFederateMgr::fom().

Referenced by DtInteractionMgr(), evaluateSubscription(), getTransport(), localAddrMap(), processInteraction(), processPub(), processResign(), processSub(), processUnsub(), publish(), published(), send(), sendInteractionMsg(), setOrder(), setTransport(), subscribe(), subscribed(), unpublish(), and unsubscribe().

DtFomClassMgr * DtInteractionMgr::fom ( ) const

References federateMgr(), and DtFederateMgr::fom().

MAKRti::DtTransportType DtInteractionMgr::getTransport ( DtInteractionClassHandle theClass )

Get the transport for the given class.

References fom(), DtFomClassMgr::interactionByHandle(), NULL, DtInteractionClassInfo::published(), and DtInteractionClassInfo::transport().

bool DtInteractionMgr::isPostJoined ( ) const

virtual

Return bool: Was the post join initialization perfomerd?

References myIsJoined.

MAKRti::DtInetAddr DtInteractionMgr::localAddrMap	(	DtInteractionClassHandle	theClass,
		DtHandle	theChannel
	)

virtual

Map the class and channel to a multicast address.

References DtInteractionClassInfo::destinationAddress(), fom(), and DtFomClassMgr::interactionByHandle().

Referenced by sendInteractionMsg().

DtInteractionMgr& DtInteractionMgr::operator= ( DtInteractionMgr const & other )

private

Assignment operator not implemented – Assignment not allowed!

DtRIDParameters * DtInteractionMgr::params ( )

Access the RID parameters.

References federateMgr(), and DtFederateMgr::params().

Referenced by addPendingSubscription(), DtInteractionMgr(), fastIncrementReceivedTally(), fastIncrementSentTally(), processPub(), DtInteractionClassInfo::publish(), send(), and sendInteractionMsg().

DtRIDParameters * DtInteractionMgr::params ( ) const

References federateMgr(), and DtFederateMgr::params().

void DtInteractionMgr::postJoinInit ( )

virtual

Post join processing. All managers shall have been created and initialized.

References myIsJoined.

void DtInteractionMgr::postTick ( )

virtual

Called after processing messages in RTI ambassador tick / evoke callbacks.

References sendPendingStartInters(), sendPendingStopInters(), sendPendingSubscription(), and sendPendingUnsubscription().

Referenced by DtFederateMgr::posttick().

void DtInteractionMgr::prepareToRestore ( )

virtual

Prepare the state information to be restored (i.e., clear out existing data).

Referenced by DtRtiExecFederateMgr::prepareToRestoreLRC().

void DtInteractionMgr::preTick ( )

virtual

Called before processing messages in RTI ambassador tick / evoke callbacks.

Referenced by DtFederateMgr::pretick().

void DtInteractionMgr::processInteraction ( const DtInteractionMsg & msg )

protectedvirtual

Message callbacks called from registered callbacks.

References acceptInteraction(), DtInteractionMsg::channel(), connectMgr(), DtInteractionClassInfo::dimensions(), DtOrderType, fastIncrementReceivedTally(), DtConnectionMgr::fedAmb(), DtRtiMsg::federateHandle(), federateMgr(), DtFederateMgr::fedExHandle(), firstSubscribedClass(), fom(), DtInteractionMsg::getParams(), DtInteractionMsg::handle(), DtInteractionClassInfo::handle(), rti1516e::SupplementalReceiveInfo::hasProducingFederate, rti1516e::SupplementalReceiveInfo::hasSentRegions, DtRtiMsg::hasTime(), DtFomClassMgr::interactionByHandle(), NULL, DtInteractionMsg::numParams(), DtRtiMsg::orderType(), rti1516e::SupplementalReceiveInfo::producingFederate, rti1516::RECEIVE, rti1516e::RECEIVE, RTI::FederateAmbassador::receiveInteraction(), rti1516e::SupplementalReceiveInfo::sentRegions, DtRtiMsg::serialNumber(), subscribed(), DtInteractionClassInfo::subscribedWithRegion(), DtInteractionMsg::tag(), DtRtiMsg::time(), and DtRtiMsg::transportType().

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

void DtInteractionMgr::processInteraction	(	const DtInteractionMsg &	msg,
		void *	usr
	)

staticprotected

Message callback methods to register with connection manager The class instance is expected for user data.

void DtInteractionMgr::processPub ( const DtPubInterMsg & msg )

protectedvirtual

void DtInteractionMgr::processPub	(	const DtPubInterMsg &	msg,
		void *	usr
	)

staticprotected

void DtInteractionMgr::processResign ( const DtResignMsg & msg )

virtual

Process resign message.

References connectMgr(), DtRtiMsg::federateHandle(), DtConnectionMgr::fedHandle(), fom(), DtFomClassMgr::interactionByHandle(), DtFomClassMgr::numInteractions(), and DtInteractionClassInfo::remoteUnsubscribe().

Referenced by DtFederateMgr::processResign().

void DtInteractionMgr::processSub ( const DtSubInterMsg & msg )

protectedvirtual

References connectMgr(), DtRtiMsg::federateHandle(), DtConnectionMgr::fedHandle(), fom(), DtSubInterMsg::handle(), DtFomClassMgr::interactionByHandle(), DtSubInterMsg::isPassive(), DtInteractionClassInfo::remotePassiveSubscribe(), DtInteractionClassInfo::remoteSubscribe(), and DtInteractionClassInfo::remoteUnsubscribe().

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

void DtInteractionMgr::processSub	(	const DtSubInterMsg &	msg,
		void *	usr
	)

staticprotected

void DtInteractionMgr::processUnpub ( const DtUnpubInterMsg & msg )

protectedvirtual

References connectMgr(), DtRtiMsg::federateHandle(), and DtConnectionMgr::fedHandle().

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

void DtInteractionMgr::processUnpub	(	const DtUnpubInterMsg &	msg,
		void *	usr
	)

staticprotected

void DtInteractionMgr::processUnsub ( const DtUnsubInterMsg & msg )

protectedvirtual

References connectMgr(), DtRtiMsg::federateHandle(), DtConnectionMgr::fedHandle(), fom(), DtUnsubInterMsg::handle(), DtFomClassMgr::interactionByHandle(), DtUnsubInterMsg::isForSmartForwarding(), and DtInteractionClassInfo::remoteUnsubscribe().

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

void DtInteractionMgr::processUnsub	(	const DtUnsubInterMsg &	msg,
		void *	usr
	)

staticprotected

void DtInteractionMgr::publish ( DtInteractionClassHandle theInteraction )

virtual

Process publish service call.

References fom(), DtFomClassMgr::interactionByHandle(), DtInteractionClassInfo::publish(), and sendPublishMsg().

Referenced by DtTestManager::postJoinInit().

int DtInteractionMgr::published ( DtInteractionClassHandle handle )

virtual

Returns 1 if published the class, 0 otherwise Assumes handle is defined.

References fom(), DtFomClassMgr::interactionByHandle(), and DtInteractionClassInfo::published().

bool DtInteractionMgr::relevanceAdvisorySwitch ( )

References myRelevanceSwitch.

Referenced by addPendingStartInters(), addPendingStopInters(), disableRelevanceAdvisorySwitch(), and enableRelevanceAdvisorySwitch().

void DtInteractionMgr::removeClassMulticast ( DtInteractionClassInfo * classDesc )

protectedvirtual

References addClassMulticast(), connectMgr(), DtInteractionClassInfo::destinationAddress(), DtConnectionMgr::dropMulticastGroup(), and DtInteractionClassInfo::subclasses().

Referenced by unsubscribe().

bool DtInteractionMgr::restore ( DtRtiSaveFile & file )

virtual

Restore the state information from the given file.

References DtRtiSaveIntMgrType, DtInteractionMgrPacket::header, myRelevanceSwitch, DtSaveDataHeader::packetType, DtRtiSaveFile::readNextPacket(), and DtInteractionMgrPacket::relevanceSwitch.

Referenced by DtRtiExecFederateMgr::restoreLRC().

bool DtInteractionMgr::save ( DtRtiSaveFile & file )

virtual

Save the state information to the given file.

References DtRtiSaveIntMgrType, DtInteractionMgrPacket::header, myRelevanceSwitch, DtSaveDataHeader::packetSize, DtSaveDataHeader::packetType, DtInteractionMgrPacket::relevanceSwitch, and DtRtiSaveFile::writePacket().

Referenced by DtRtiExecFederateMgr::saveLRC().

unsigned long DtInteractionMgr::send	(	DtInteractionClassHandle	theInteraction,
		const DtPhvps &	params,
		RTI::FedTime const *	theTime,
		const char *	theTag,
		DtHandle	channel,
		bool	anonymous = `false`
	)

virtual

Process send interaction service call.

References connectMgr(), DtRIDParameters::DtFomTransportTypeUseBestEffort, DtRIDParameters::DtFomTransportTypeUseReliable, DtOrderType, DtRIDParameters::errorChecking, fom(), DtFomClassMgr::interactionByHandle(), DtInteractionClassInfo::order(), DtInteractionClassInfo::paramByHandle(), params(), DtInteractionClassInfo::published(), sendInteractionMsg(), and DtInteractionClassInfo::transport().

Referenced by DtTestManager::sendInteraction().

void DtInteractionMgr::sendInteractionMsg	(	DtInteractionClassHandle	theClass,
		const DtPhvps &	theParams,
		MAKRti::DtTransportType	transportType,
		MAKRti::DtOrderType	orderType,
		RTI::FedTime const *	theTime,
		const char *	theTag,
		unsigned long	serialNumber,
		DtHandle	channel,
		bool	anonymous = `false`
	)

virtual

void DtInteractionMgr::sendPendingStartInters ( )

virtual

Send pending turnOn/OffInteractions.

References connectMgr(), DtConnectionMgr::fedAmb(), myFederateMgr, myPendingStartIntersList, NULL, DtFederateMgr::restoreBegun(), and RTI::FederateAmbassador::turnInteractionsOn().

Referenced by postTick().

void DtInteractionMgr::sendPendingStopInters ( )

virtual

References connectMgr(), DtConnectionMgr::fedAmb(), myFederateMgr, myPendingStopIntersList, NULL, DtFederateMgr::restoreBegun(), and RTI::FederateAmbassador::turnInteractionsOff().

Referenced by postTick().

void DtInteractionMgr::sendPendingSubscription ( )

virtual

Send/add pending subscription class retransmissions that will get sent during next tick.

References connectMgr(), myRetransmitPassiveSubClass, myRetransmitSubClass, myRetransmitSubClassMask, and sendSubscribeMsg().

Referenced by postTick().

void DtInteractionMgr::sendPendingUnsubscription ( )

virtual

Send/add pending unsubscription class retransmissions that will get sent during next tick.

References connectMgr(), myRetransmitUnsubClass, myRetransmitUnsubClassForSmartForwarding, and sendUnsubscribeMsg().

Referenced by postTick().

void DtInteractionMgr::sendPublishMsg ( DtInteractionClassHandle theInter )

virtual

Send publish interaction message.

References connectMgr(), DtConnectionMgr::create(), DtPubInterMsgKind, DtConnectionMgr::sendStampedAndDelete(), and DtPubInterMsg::set().

Referenced by publish().

void DtInteractionMgr::sendSubscribeMsg	(	DtInteractionClassHandle	theInter,
		bool	isPassive,
		DtFederateHandle	fedHandle
	)

virtual

Send subscribe interaction message.

References connectMgr(), DtConnectionMgr::create(), DtSubInterMsgKind, DtConnectionMgr::sendDirectedStampedAndDelete(), and DtSubInterMsg::set().

Referenced by processPub(), sendPendingSubscription(), and subscribe().

void DtInteractionMgr::sendSubscribeMsg	(	DtInteractionClassHandle	theInter,
		bool	isPassive,
		DtBitMask *	sendMask = `0`
	)

virtual

References connectMgr(), DtConnectionMgr::create(), DtSubInterMsgKind, DtBitMask::reset(), DtConnectionMgr::sendDirectedStampedAndDelete(), and DtSubInterMsg::set().

void DtInteractionMgr::sendUnpublishMsg ( DtInteractionClassHandle theInter )

virtual

Send unpublish interaction message.

References connectMgr(), DtConnectionMgr::create(), DtUnpubInterMsgKind, DtConnectionMgr::sendStampedAndDelete(), and DtUnpubInterMsg::set().

Referenced by unpublish().

void DtInteractionMgr::sendUnsubscribeMsg	(	DtInteractionClassHandle	theInter,
		bool	forSmartForwarding = `false`
	)

virtual

Send unsubscribe interaction message.

References connectMgr(), DtConnectionMgr::create(), DtUnsubInterMsgKind, DtConnectionMgr::sendStampedAndDelete(), and DtUnsubInterMsg::set().

Referenced by processPub(), sendPendingUnsubscription(), and unsubscribe().

void DtInteractionMgr::setCreatorFunction ( DtInteractionMgrCreator fn )

static

Register a creator function.

When set, it will be used to create the Interaction Manager.

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

void DtInteractionMgr::setInternalCreatorFunction ( DtInteractionMgrCreator fn )

static

Register alternate internal creators.

The RTI proper uses this function to choose from various internal implementations. This function should not be used by plugins as the assignment may be overridden internally. Use the setCreatorFunction.

References create(), and theInternalCreator.