DtShmMsgQueueWriter Class Reference

Inheritance diagram for DtShmMsgQueueWriter:

Collaboration diagram for DtShmMsgQueueWriter:

List of all members.

Public Member Functions
	DtShmMsgQueueWriter (DtShmMsgQueue *q, int size, int sem, int firstSem, bool wait, bool pleaseInit, bool dropOldest=true)
virtual	~DtShmMsgQueueWriter ()
virtual int	Write (char *buf, size_t size)
virtual int	Writev (char **buflist, size_t *sizelist, int n)
void	setInternal (int mode)
void	setGoAway (int mode)
int	newDropped ()
int	oldDropped ()
int	msgsSent ()
Public Attributes
DtShmMsgQueueManager	qManager
bool	resourceWait
int	queueBack
Private Member Functions
int	enqueuev (char **buflist, size_t *sizelist, int n, int totalSize)
void	copyv (char **buflist, size_t *sizelist, int n, int endSize)
int	findSpace (int start, int request, int *available)
void	moveFront (void)
int	verifyQueue (void)
	This looks for anything out of the ordinary and calls abort() when something is wrong.
Private Attributes
int	newLost
int	oldLost
int	notLost

---

Constructor & Destructor Documentation

DtShmMsgQueueWriter::DtShmMsgQueueWriter	(	DtShmMsgQueue *	q,
		int	size,
		int	sem,
		int	firstSem,
		bool	wait,
		bool	pleaseInit,
		bool	dropOldest = true
	)

virtual DtShmMsgQueueWriter::~DtShmMsgQueueWriter

(

)

[inline, virtual]

---

Member Function Documentation

void DtShmMsgQueueWriter::copyv	(	char **	buflist,
		size_t *	sizelist,
		int	n,
		int	endSize
	)		[private]

int DtShmMsgQueueWriter::enqueuev	(	char **	buflist,
		size_t *	sizelist,
		int	n,
		int	totalSize
	)		[private]

int DtShmMsgQueueWriter::findSpace	(	int	start,
		int	request,
		int *	available
	)		[private]

void DtShmMsgQueueWriter::moveFront

(

void

)

[private]

int DtShmMsgQueueWriter::msgsSent

(

)

[inline]

int DtShmMsgQueueWriter::newDropped

(

)

[inline]

int DtShmMsgQueueWriter::oldDropped

(

)

[inline]

void DtShmMsgQueueWriter::setGoAway

(

int

mode

)

[inline]

void DtShmMsgQueueWriter::setInternal

(

int

mode

)

[inline]

int DtShmMsgQueueWriter::verifyQueue

(

void

)

[private]

This looks for anything out of the ordinary and calls abort() when something is wrong.

virtual int DtShmMsgQueueWriter::Write	(	char *	buf,
		size_t	size
	)		[virtual]

Implements DtClientServerWriter.

virtual int DtShmMsgQueueWriter::Writev	(	char **	buflist,
		size_t *	sizelist,
		int	n
	)		[virtual]

Implements DtClientServerWriter.

---

Member Data Documentation

int DtShmMsgQueueWriter::newLost [private]

int DtShmMsgQueueWriter::notLost [private]

int DtShmMsgQueueWriter::oldLost [private]

DtShmMsgQueueManager DtShmMsgQueueWriter::qManager

int DtShmMsgQueueWriter::queueBack

bool DtShmMsgQueueWriter::resourceWait

---

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

• vlShmWriter.h