XrdClientInputBuffer Class Reference

#include <XrdClientInputBuffer.hh>

Collaboration diagram for XrdClientInputBuffer:

[legend]

List of all members.

Public Member Functions
	XrdClientInputBuffer ()
	~XrdClientInputBuffer ()
bool	IsMexEmpty ()
bool	IsSemEmpty ()
int	MexSize ()
int	PutMsg (XrdClientMessage *msg)
int	SemSize ()
int	WipeStreamid (int streamid)
XrdClientMessage *	GetMsg (int streamid, int secstimeout)
Private Member Functions
XrdSysSemWait *	GetSyncObjOrMakeOne (int streamid)
int	MsgForStreamidCnt (int streamid)
Private Attributes
XrdClientVector < XrdClientMessage * >	fMsgQue
int	fMsgIter
XrdSysRecMutex	fMutex
XrdOucHash< XrdSysSemWait >	fSyncobjRepo

---

Constructor & Destructor Documentation

XrdClientInputBuffer::XrdClientInputBuffer

(

)

XrdClientInputBuffer::~XrdClientInputBuffer

(

)

---

Member Function Documentation

XrdClientMessage* XrdClientInputBuffer::GetMsg	(	int	streamid,
		int	secstimeout
	)

XrdSysSemWait* XrdClientInputBuffer::GetSyncObjOrMakeOne

(

int

streamid

)

[private]

bool XrdClientInputBuffer::IsMexEmpty

(

)

[inline]

References MexSize().

bool XrdClientInputBuffer::IsSemEmpty

(

)

[inline]

References SemSize().

int XrdClientInputBuffer::MexSize

(

)

[inline]

References fMsgQue, fMutex, and XrdClientVector< T >::GetSize().

Referenced by IsMexEmpty().

int XrdClientInputBuffer::MsgForStreamidCnt

(

int

streamid

)

[private]

int XrdClientInputBuffer::PutMsg

(

XrdClientMessage *

msg

)

int XrdClientInputBuffer::SemSize

(

)

[inline]

References fMutex, fSyncobjRepo, and XrdOucHash< T >::Num().

Referenced by IsSemEmpty().

int XrdClientInputBuffer::WipeStreamid

(

int

streamid

)

Referenced by XrdClientPhyConnection::WipeStreamid().

---

Member Data Documentation

int XrdClientInputBuffer::fMsgIter [private]

XrdClientVector<XrdClientMessage*> XrdClientInputBuffer::fMsgQue [private]

Referenced by MexSize().

XrdSysRecMutex XrdClientInputBuffer::fMutex [private]

Referenced by MexSize(), and SemSize().

XrdOucHash<XrdSysSemWait> XrdClientInputBuffer::fSyncobjRepo [private]

Referenced by SemSize().

---

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

• XrdClientInputBuffer.hh