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

(

)

References DeleteHashItem().

Member Function Documentation

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

References XrdSysSemWait::Wait().

Referenced by XrdClientPhyConnection::ReadMessage().

XrdSysSemWait * XrdClientInputBuffer::GetSyncObjOrMakeOne ( int  streamid )

private

bool XrdClientInputBuffer::IsMexEmpty ( )

inline

bool XrdClientInputBuffer::IsSemEmpty ( )

inline

int XrdClientInputBuffer::MexSize ( )

inline

int XrdClientInputBuffer::MsgForStreamidCnt ( int  streamid )

private

References XrdClientMessage::MatchStreamid().

int XrdClientInputBuffer::PutMsg

(

XrdClientMessage *

msg

)

References XrdClientMessage::HeaderSID(), and XrdSysSemWait::Post().

Referenced by XrdClientPhyConnection::BuildMessage().

int XrdClientInputBuffer::SemSize ( )

inline

int XrdClientInputBuffer::WipeStreamid

(

int

streamid

)

References XrdClientMessage::MatchStreamid().

Referenced by XrdClientPhyConnection::WipeStreamid().

Member Data Documentation

int XrdClientInputBuffer::fMsgIter

private

XrdClientVector<XrdClientMessage*> XrdClientInputBuffer::fMsgQue

private

XrdSysRecMutex XrdClientInputBuffer::fMutex

private

XrdOucHash<XrdSysSemWait> XrdClientInputBuffer::fSyncobjRepo

private

---

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

• XrdClientInputBuffer.hh
• XrdClientInputBuffer.cc