MsgQueue Class Reference

Inheritance diagram for MsgQueue:

Public Member Functions
virtual	~MsgQueue ()
void	pushMsg (Msg *msg)
unsigned long	msgQSize () const
SerializedMsg *	headMsg () const
void	consumeHeadMsg ()
void	clearMsgQueue ()
void	messageMayHaveProgressed (const SerializedMsg *msg)
void	setFds (int rFd, int wFd)
virtual bool	acceptSharedBuffers () const
virtual void	log (const std::string &log) const

Protected Member Functions
int	getRFd () const
int	getWFd () const
void	traceMsg (const std::string &log, XMLEle *root)
virtual void	close ()=0
virtual void	closeWritePart ()
virtual void	onMessage (XMLEle *root, std::list< int > &sharedBuffers)=0
	MsgQueue (bool useSharedBuffer)
Protected Member Functions inherited from Collectable
HeartBeat	heartBeat () const

Static Protected Member Functions
static void	crackBLOB (const char *enableBLOB, BLOBHandling *bp)

Protected Attributes
bool	useSharedBuffer

Detailed Description

Definition at line 515 of file indiserver.cpp.

Constructor & Destructor Documentation

MsgQueue()

MsgQueue::MsgQueue ( bool  useSharedBuffer )

protected

Definition at line 3613 of file indiserver.cpp.

~MsgQueue()

MsgQueue::~MsgQueue ( )

virtual

Definition at line 3622 of file indiserver.cpp.

Member Function Documentation

acceptSharedBuffers()

virtual bool MsgQueue::acceptSharedBuffers ( ) const

inlinevirtual

Reimplemented in DvrInfo.

Definition at line 590 of file indiserver.cpp.

clearMsgQueue()

void MsgQueue::clearMsgQueue

(

)

Definition at line 3773 of file indiserver.cpp.

close()

virtual void MsgQueue::close ( )

protectedpure virtual

Implemented in DvrInfo, and ClInfo.

closeWritePart()

void MsgQueue::closeWritePart ( )

protectedvirtual

Reimplemented in DvrInfo.

Definition at line 3642 of file indiserver.cpp.

consumeHeadMsg()

void MsgQueue::consumeHeadMsg

(

)

Definition at line 3719 of file indiserver.cpp.

crackBLOB()

void MsgQueue::crackBLOB ( const char *  enableBLOB, BLOBHandling *  bp  )

staticprotected

Definition at line 2516 of file indiserver.cpp.

getRFd()

int MsgQueue::getRFd ( ) const

inlineprotected

Definition at line 545 of file indiserver.cpp.

getWFd()

int MsgQueue::getWFd ( ) const

inlineprotected

Definition at line 549 of file indiserver.cpp.

headMsg()

SerializedMsg * MsgQueue::headMsg

(

)

const

Definition at line 3713 of file indiserver.cpp.

log()

void MsgQueue::log ( const std::string &  log ) const

virtual

Reimplemented in DvrInfo, and ClInfo.

Definition at line 2476 of file indiserver.cpp.

messageMayHaveProgressed()

void MsgQueue::messageMayHaveProgressed

(

const SerializedMsg *

msg

)

Definition at line 3765 of file indiserver.cpp.

msgQSize()

unsigned long MsgQueue::msgQSize

(

)

const

Definition at line 3789 of file indiserver.cpp.

onMessage()

virtual void MsgQueue::onMessage ( XMLEle *  root, std::list< int > &  sharedBuffers  )

protectedpure virtual

Implemented in DvrInfo, and ClInfo.

pushMsg()

void MsgQueue::pushMsg

(

Msg *

msg

)

Definition at line 3729 of file indiserver.cpp.

setFds()

void MsgQueue::setFds	(	int	rFd,
		int	wFd
	)

Definition at line 3677 of file indiserver.cpp.

traceMsg()

void MsgQueue::traceMsg ( const std::string &  log, XMLEle *  root  )

protected

Definition at line 2549 of file indiserver.cpp.

Member Data Documentation

useSharedBuffer

bool MsgQueue::useSharedBuffer

protected

Definition at line 544 of file indiserver.cpp.

---

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

• indiserver.cpp