vlShmSubscribableMessageQueue__rti__.h File Reference

Go to the source code of this file.

Classes
class	DtSmSubscribableMessageQueue__rti__
	Implements a generic shared memory message queue for multiple subscribers. More...
struct	DtSmSubscribableMessageQueue__rti__::DtBucketHeader
	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	DtSmSubscribableMessageQueue__rti__::DtQueueHeader
	DtQueueHeader exists at the front of the message queue and contains useful information about the state of the queue. More...

Macros
#define	DtSm_QUEUE_STATE_UNINITIALIZED   0x0
	!WIN32
#define	DtSm_QUEUE_STATE_INITIALIZED   0xFAD2FADE
#define	DtSm_QUEUE_STATE_SHUTDOWN   0xDEADBEEF
#define	DtSM_INVALID_SUBSCRIBER_ID   UINT_MAX
#define	DtSMQ_FETCH_DEFAULT   0x00
	The following constants are intended as bit-masks to be combined with other values (some as-yet-unspecified) which may be defined in sub-classes.
#define	DtSMQ_SKIP_MINE   0x40
#define	DtSMQ_FETCH_ALL   0x80
#define	DtSmSubMsgQ_theMaxSubscribers   255
	TO DO – DAA workaround for MSVC6 bug ID #241569 A bug in MSVC++6 prevents initializing a static const member within a class declaration.

Macro Definition Documentation

#define DtSM_INVALID_SUBSCRIBER_ID   UINT_MAX

Referenced by DtSmSubscribableMessageQueue__rti__::assignSubscriberId(), DtSmSubscribableMessageQueue__rti__::subscribe(), DtSmSubscribableMessageQueue__rti__::unsubscribe(), DtRtiSubscribableMessageQueue::unsubscribeSelf(), DtRtiSubscribableMessageQueue::~DtRtiSubscribableMessageQueue(), and DtSmSubscribableMessageQueue__rti__::~DtSmSubscribableMessageQueue__rti__().

#define DtSm_QUEUE_STATE_INITIALIZED   0xFAD2FADE

Referenced by DtSmSubscribableMessageQueue__rti__::resetQueue(), and DtSmSubscribableMessageQueue__rti__::subscribe().

#define DtSm_QUEUE_STATE_SHUTDOWN   0xDEADBEEF

Referenced by DtSmSocket__rti__::isOpen(), and DtSmSubscribableMessageQueue__rti__::sm_shutdown().

#define DtSm_QUEUE_STATE_UNINITIALIZED   0x0

!WIN32

#define DtSMQ_FETCH_ALL   0x80

Referenced by DtRtiSmSocket::initializeSmQueue(), DtRtiSubscribableMessageQueue::isEmpty(), DtSmSubscribableMessageQueue__rti__::unsubscribe(), and DtRtiSubscribableMessageQueue::unsubscribe().

#define DtSMQ_FETCH_DEFAULT   0x00

The following constants are intended as bit-masks to be combined with other values (some as-yet-unspecified) which may be defined in sub-classes.

Referenced by DtRtiSubscribableMessageQueue::isEmpty().

#define DtSMQ_SKIP_MINE   0x40

Referenced by DtRtiSmSocket::initializeSmQueue(), DtSmConnectionMgr::initQMgr(), and DtRtiSubscribableMessageQueue::isEmpty().

#define DtSmSubMsgQ_theMaxSubscribers   255

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