DtSmRtiConnection Class Reference

Inheritance diagram for DtSmRtiConnection:

Collaboration diagram for DtSmRtiConnection:

Public Member Functions
	DtSmRtiConnection (DtRtiSmSocket *socket)
	Constructors. More...
virtual	~DtSmRtiConnection ()
	Destructor. More...
virtual int	send (const DtRtiMsg &msg, const MAKRti::DtInetAddr &addr=MAKRti::DtInetAddr::inaddrAny())
	Override DtConnection send method and assert if invoked. More...
virtual int	send (const DtRtiMsg &msg, MAKRti::DtTransportType transport, const MAKRti::DtInetAddr &addr=MAKRti::DtInetAddr::inaddrAny(), unsigned int priority=0)
	Send a message. Non-blocking. More...
virtual bool	flush ()
	Send buffered messages. More...
virtual int	getMessageNetInfo (MAKRti::DtInetAddr *addr, MAKRti::DtTransportType *trans, DtU32 *priority=NULL)
	This method returns the size of the next available message in the shared memory queue along with additional information (e.g. More...
virtual bool	isReliable ()
	Return true if the queue is in reliable delivery mode. More...
virtual int	waitForMessages (MAKRti::DtTime waitTime=0.0)
	Wait (block) for the specified time until a message can be read. More...
virtual int	waitUntilFull (MAKRti::DtTime waitTime=0.0)
	Wait (block) for the specified time until the shared memory is full. More...
virtual bool	sm_shutdown (bool ruthless=false)
	Attempt to shutdown the queue. More...
virtual int	subscriberCount () const
	Return count of subscribers connected to the shared memory queue. More...
Public Member Functions inherited from DtRtiConnection
	DtRtiConnection (DtMsgSocket *skt)
	Constructor. More...
virtual	~DtRtiConnection ()
	Destructor. More...
virtual void	setMsgFactory (DtRtiMsgFactory *fact)
	Set/Get the Message Factory used by this object. More...
virtual DtRtiMsgFactory *	rtiMsgFactory ()
virtual DtRtiMsg *	netRead (DtNetReadStatus *retCode=NULL)
	Note: netRead() creates a new DtRtiMsg using the message factory Caller is responsible for deleting it when through. More...
virtual int	isOk ()
	Return true if the status of the connection is OK. More...
virtual void	setCheckVersion (bool enableCheckVersion)
	Set/get whether to check message version. More...
virtual bool	checkVersion () const
virtual void	disableCheckSize ()
	Disable message size check. More...
virtual void	enableCheckSize ()
	Enable message size check. More...
virtual void	setFedExName (const MAKRti::DtString &newFedExName)
	Set/Get federation execution name. NULL means "all". More...
virtual const MAKRti::DtString &	fedExName () const
virtual void	setFedExHandle (int handle)
	Set/Get federation execution handle. 0 means "all". More...
virtual int	fedExHandle () const
virtual void	setFederateHandle (DtFederationHandle handle)
	Set/Get federate handle. More...
virtual DtFederationHandle	federateHandle () const
virtual void	setConnId (unsigned long connId)
	Set/Get the connection ID assigned to the connection. More...
virtual unsigned long	connId () const
virtual DtMsgSocket *	socket ()
	Returns our socket. More...

Protected Types
typedef std::list< DtRtiMsg * >	DtOutboundPendingList
	for reliable connections only More...

Protected Attributes
DtRtiSmSocket *	mySmSocket
DtOutboundPendingList	myObPendingMessages
Protected Attributes inherited from DtRtiConnection
MAKRti::DtString	myFedExName
int	myFedExHandle
DtFederationHandle	myFedHandle
DtMsgSocket *	mySocket
DtRtiMsgFactory *	myMsgFact
unsigned long	myReceivedMsgCount
bool	myCheckSize
bool	myCheckVersion
unsigned int	myWaitEventIndex
unsigned long	myConnId
	Win32 only. More...

Additional Inherited Members
Protected Member Functions inherited from DtRtiConnection
void	init (DtMsgSocket *s)

Member Typedef Documentation

typedef std::list< DtRtiMsg* > DtSmRtiConnection::DtOutboundPendingList

protected

for reliable connections only

Constructor & Destructor Documentation

DtSmRtiConnection::DtSmRtiConnection

(

DtRtiSmSocket *

socket

)

Constructors.

virtual DtSmRtiConnection::~DtSmRtiConnection ( )

virtual

Destructor.

Member Function Documentation

virtual bool DtSmRtiConnection::flush ( )

virtual

Send buffered messages.

Returns indication of whether the flush is complete or incomplete.

Reimplemented from DtRtiConnection.

virtual int DtSmRtiConnection::getMessageNetInfo ( MAKRti::DtInetAddr *  addr, MAKRti::DtTransportType *  trans, DtU32 *  priority = NULL  )

virtual

This method returns the size of the next available message in the shared memory queue along with additional information (e.g.

destination address, transport method, and priority) needed by a forwarder or shared memory queue manager net I/O handler to pass messages to a network.

virtual bool DtSmRtiConnection::isReliable ( )

virtual

Return true if the queue is in reliable delivery mode.

virtual int DtSmRtiConnection::send ( const DtRtiMsg &  msg, const MAKRti::DtInetAddr &  addr = MAKRti::DtInetAddr::inaddrAny()  )

virtual

Override DtConnection send method and assert if invoked.

Shared memory connections require the additional transport parameter at a minimum so the shared memory queue manager can forward message via the appropriate net I/O socket

Reimplemented from DtRtiConnection.

virtual int DtSmRtiConnection::send ( const DtRtiMsg &  msg, MAKRti::DtTransportType  transport, const MAKRti::DtInetAddr &  addr = MAKRti::DtInetAddr::inaddrAny(), unsigned int  priority = 0  )

virtual

Send a message. Non-blocking.

virtual bool DtSmRtiConnection::sm_shutdown ( bool  ruthless = false )

virtual

Attempt to shutdown the queue.

This should only be invoked by the queue manager before destroying the shared memory pool.

virtual int DtSmRtiConnection::subscriberCount ( ) const

virtual

Return count of subscribers connected to the shared memory queue.

virtual int DtSmRtiConnection::waitForMessages ( MAKRti::DtTime  waitTime = 0.0 )

virtual

Wait (block) for the specified time until a message can be read.

Return status: 0 if messages are ready, > 0 if wait expired, or < 0 if error

virtual int DtSmRtiConnection::waitUntilFull ( MAKRti::DtTime  waitTime = 0.0 )

virtual

Wait (block) for the specified time until the shared memory is full.

Return status: 0 if full, > 0 if wait expired, or < 0 if error

Member Data Documentation

DtOutboundPendingList DtSmRtiConnection::myObPendingMessages

protected

DtRtiSmSocket* DtSmRtiConnection::mySmSocket

protected

---

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

• smConnection.h