smSubscribableMessageQueue.h File Reference

This file declares DtRtiSubscribableMessageQueue. More...

Go to the source code of this file.

Classes
class	DtRtiSubscribableMessageQueue
	Implements a message queue for multiple subscribers. More...
struct	DtRtiSubscribableMessageQueue::DtRtiBucketHeader
	DtBucketHeader is a structure found at the front of each message to keep track of the number of bytes used, fragmented message indications, the subscriber that enqueued the message, and the sender's sequence number. More...
struct	DtRtiSubscribableMessageQueue::DtRtiQueueHeader
	DtQueueHeader exists at the front of the message queue and contains useful information about the state of the queue. More...
class	DtRtiSubscribableMessageQueue::DtStalledSubscriber
	DtStalledSubscriber keeps track of which queue subscribers have not read a bucket as well as information about the message in the unread bucket for later comparison. More...

Macros
#define	DtSMQ_PRIO_0   0x00
	Flags controlling behavior of RTI subscribable message queue read routine.
#define	DtSMQ_PRIO_1   0x01
#define	DtSMQ_PRIO_2   0x02
#define	DtSMQ_PRIO_3   0x03
#define	DtSMQ_PRIO_4   0x04
#define	DtSMQ_PRIO_5   0x05
#define	DtSMQ_PRIO_6   0x06
#define	DtSMQ_PRIO_7   0x07
#define	DtSMQ_PRIO_MASK   0x07
#define	DtSMQ_MSG_RELIABLE   0x10
#define	DtSMQ_MSG_BESTEFFORT   0x20
#define	DtSMQ_SKIP_RELIABLE   0x10
#define	DtSMQ_SKIP_BESTEFFORT   0x20
#define	DtRtiSubMsgQ_theMaxSubscribers   16384
	TO DO – DAA workaround for MSVC6 bug ID #241569 A bug in MSVC++6 prevents initializing a static const member within a class declaration.

Enumerations
enum	DtSmqEnqueueMode { DtSmqEnqueueBestEffortMode = 0, DtSmqEnqueueReliableMode = 1, DtSmqEnqueueInvalidMode }

Detailed Description

This file declares DtRtiSubscribableMessageQueue.

Macro Definition Documentation

#define DtRtiSubMsgQ_theMaxSubscribers   16384

TO DO – DAA workaround for MSVC6 bug ID #241569 A bug in MSVC++6 prevents initializing a static const member within a class declaration.

It must be initialized outside the class. The bug is fixed in MSVC7, so when support for MSVC6 is dropped we can do away with this kludgy workaround

Referenced by DtRtiSubscribableMessageQueue::DtRtiSubscribableMessageQueue().

#define DtSMQ_MSG_BESTEFFORT   0x20

Referenced by DtSmRtiConnection::flush(), DtRtiSubscribableMessageQueue::getRcvMsgTransportInfo(), DtSmRtiConnection::send(), and DtRtiSubscribableMessageQueue::sendMessage().

#define DtSMQ_MSG_RELIABLE   0x10

Referenced by DtSmRtiConnection::flush(), DtSmRtiConnection::getMessageNetInfo(), DtRtiSubscribableMessageQueue::getRcvMsgTransportInfo(), DtSmRtiConnection::send(), and DtRtiSubscribableMessageQueue::sendMessage().

#define DtSMQ_PRIO_0   0x00

Flags controlling behavior of RTI subscribable message queue read routine.

#define DtSMQ_PRIO_1   0x01

#define DtSMQ_PRIO_2   0x02

#define DtSMQ_PRIO_3   0x03

#define DtSMQ_PRIO_4   0x04

#define DtSMQ_PRIO_5   0x05

#define DtSMQ_PRIO_6   0x06

#define DtSMQ_PRIO_7   0x07

#define DtSMQ_PRIO_MASK   0x07

Referenced by DtSmRtiConnection::getMessageNetInfo(), DtRtiSubscribableMessageQueue::isEmpty(), DtSmRtiConnection::send(), and DtRtiSubscribableMessageQueue::sendMessage().

#define DtSMQ_SKIP_BESTEFFORT   0x20

Referenced by DtRtiSubscribableMessageQueue::isEmpty().

#define DtSMQ_SKIP_RELIABLE   0x10

Referenced by DtRtiSubscribableMessageQueue::isEmpty().

Enumeration Type Documentation

enum DtSmqEnqueueMode

Enumerator:

DtSmqEnqueueBestEffortMode
DtSmqEnqueueReliableMode
DtSmqEnqueueInvalidMode	This must always be the last item.