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 void	sendSubscribeMsg (DtInteractionClassHandle theInter, bool isPassive)
	Send subscribe interaction message.
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)
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 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
bool	myRelevanceSwitch
	Indicates whether relevance advisory is enabled.
std::set< DtObjectClassHandle >	myRetransmitSubClass
	Set of class subscriptions to retransmit.
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.

Constructor & Destructor Documentation

DtInteractionMgr::DtInteractionMgr ( DtFederateMgr * fedMgr ) [protected]

Constructor.

References DtPubInterMsg::addCallback(), DtUnpubInterMsg::addCallback(), DtSubInterMsg::addCallback(), DtUnsubInterMsg::addCallback(), DtInteractionRoMsg::addCallback(), connectMgr(), dataDistMgmt, fom(), myFederateMgr, myRelevanceSwitch, params(), processInteraction(), processPub(), processSub(), processUnpub(), processUnsub(), and DtInteractionMsg::setChannelIncluded().

Referenced by create().

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 ) [protected, virtual]

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
	)		`[virtual]`

References myRetransmitPassiveSubClass, myRetransmitSubClass, myRetransmitUnsubClass, and myRetransmitUnsubClassForSmartForwarding.

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 ( ) [protected, virtual]

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

void DtInteractionMgr::fastIncrementReceivedTally	(	DtInteractionClassHandle	classHandle,
		MAKRti::DtTransportType	transport
	)		`[protected]`

References momServiceAvailable, and params().

Referenced by processInteraction().

void DtInteractionMgr::fastIncrementSentTally	(	DtInteractionClassHandle	classHandle,
		MAKRti::DtTransportType	transport
	)		`[protected]`

References momServiceAvailable, and params().

Referenced by sendInteractionMsg().

DtFederateMgr * DtInteractionMgr::federateMgr ( )

Access the federate manager.

References myFederateMgr.

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

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(), DtInteractionClassInfo::handle(), NULL, and subscribed().

Referenced by processInteraction().

DtFomClassMgr * DtInteractionMgr::fom ( )

Access the fom manager.

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

Referenced by DtInteractionMgr(), 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 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 ) [protected, virtual]

Message callbacks called from registered callbacks.

References acceptInteraction(), DtInteractionMsg::channel(), connectMgr(), DtInteractionClassInfo::dimensions(), fastIncrementReceivedTally(), DtConnectionMgr::fedAmb(), DtRtiMsg::federateHandle(), 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(), DtInteractionMsg::tag(), DtRtiMsg::time(), and DtRtiMsg::transportType().

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

void DtInteractionMgr::processInteraction	(	const DtInteractionMsg &	msg,
		void *	usr
	)		`[static, protected]`

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

void DtInteractionMgr::processPub	(	const DtPubInterMsg &	msg,
		void *	usr
	)		`[static, protected]`

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 ) [protected, virtual]

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
	)		`[static, protected]`

void DtInteractionMgr::processUnpub ( const DtUnpubInterMsg & msg ) [protected, virtual]

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

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

void DtInteractionMgr::processUnpub	(	const DtUnpubInterMsg &	msg,
		void *	usr
	)		`[static, protected]`

void DtInteractionMgr::processUnsub ( const DtUnsubInterMsg & msg ) [protected, virtual]

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
	)		`[static, protected]`

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 ) [protected, virtual]

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, 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(), myPendingStartIntersList, NULL, and RTI::FederateAmbassador::turnInteractionsOn().

Referenced by postTick().

void DtInteractionMgr::sendPendingStopInters ( ) [virtual]

References connectMgr(), DtConnectionMgr::fedAmb(), myPendingStopIntersList, NULL, 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, 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
	)		`[virtual]`

Send subscribe interaction message.

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

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

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.