XrdClientInputBuffer Class Reference

#include <XrdClientInputBuffer.hh>

Collaboration diagram for XrdClientInputBuffer:

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()

XrdClientInputBuffer::~XrdClientInputBuffer

(

)

Member Function Documentation

GetMsg()

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

GetSyncObjOrMakeOne()

XrdSysSemWait * XrdClientInputBuffer::GetSyncObjOrMakeOne ( int  streamid )

private

IsMexEmpty()

bool XrdClientInputBuffer::IsMexEmpty ( )

inline

References MexSize().

IsSemEmpty()

bool XrdClientInputBuffer::IsSemEmpty ( )

inline

References SemSize().

MexSize()

int XrdClientInputBuffer::MexSize ( )

inline

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

Referenced by IsMexEmpty().

MsgForStreamidCnt()

int XrdClientInputBuffer::MsgForStreamidCnt ( int  streamid )

private

PutMsg()

int XrdClientInputBuffer::PutMsg

(

XrdClientMessage *

msg

)

SemSize()

int XrdClientInputBuffer::SemSize ( )

inline

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

Referenced by IsSemEmpty().

WipeStreamid()

int XrdClientInputBuffer::WipeStreamid

(

int

streamid

)

Referenced by XrdClientPhyConnection::WipeStreamid().

Member Data Documentation

fMsgIter

int XrdClientInputBuffer::fMsgIter

private

fMsgQue

XrdClientVector<XrdClientMessage*> XrdClientInputBuffer::fMsgQue

private

Referenced by MexSize().

fMutex

XrdSysRecMutex XrdClientInputBuffer::fMutex

private

Referenced by MexSize(), and SemSize().

fSyncobjRepo

XrdOucHash<XrdSysSemWait> XrdClientInputBuffer::fSyncobjRepo

private

Referenced by SemSize().

---

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

• XrdClientInputBuffer.hh