xrootd: XrdClientInputBuffer Class Reference

#include <XrdClientInputBuffer.hh>

Collaboration diagram for XrdClientInputBuffer:

Collaboration graph

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

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

XrdClientInputBuffer::~XrdClientInputBuffer ( )

References XrdOucHash< T >::Apply(), XrdClientVector< T >::Clear(), DeleteHashItem(), fMsgIter, fMsgQue, fMutex, fSyncobjRepo, and XrdClientVector< T >::GetSize().

Member Function Documentation

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

References XrdClientVector< T >::Erase(), fMsgIter, fMsgQue, fMutex, XrdClientVector< T >::GetSize(), GetSyncObjOrMakeOne(), and XrdSysSemWait::Wait().

Referenced by XrdClientPhyConnection::ReadMessage().

XrdSysSemWait * XrdClientInputBuffer::GetSyncObjOrMakeOne ( int streamid ) [private]

References XrdOucHash< T >::Find(), fMutex, fSyncobjRepo, XrdOucHash< T >::Rep(), and snprintf.

Referenced by GetMsg(), and PutMsg().

bool XrdClientInputBuffer::IsMexEmpty ( ) [inline]

bool XrdClientInputBuffer::IsSemEmpty ( ) [inline]

int XrdClientInputBuffer::MexSize ( ) [inline]

Referenced by PutMsg().

int XrdClientInputBuffer::MsgForStreamidCnt ( int streamid ) [private]

References fMsgIter, fMsgQue, XrdClientVector< T >::GetSize(), and XrdClientMessage::MatchStreamid().

int XrdClientInputBuffer::PutMsg ( XrdClientMessage * msg )

References fMsgQue, fMutex, GetSyncObjOrMakeOne(), XrdClientMessage::HeaderSID(), MexSize(), XrdSysSemWait::Post(), and XrdClientVector< T >::Push_back().

Referenced by XrdClientPhyConnection::BuildMessage().

int XrdClientInputBuffer::SemSize ( ) [inline]

int XrdClientInputBuffer::WipeStreamid ( int streamid )

References XrdClientVector< T >::Erase(), fMsgIter, fMsgQue, fMutex, XrdClientVector< T >::GetSize(), and XrdClientMessage::MatchStreamid().

Referenced by XrdClientPhyConnection::WipeStreamid().

Member Data Documentation

int XrdClientInputBuffer::fMsgIter [private]

Referenced by GetMsg(), MsgForStreamidCnt(), WipeStreamid(), and ~XrdClientInputBuffer().

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

Referenced by GetMsg(), MsgForStreamidCnt(), PutMsg(), WipeStreamid(), XrdClientInputBuffer(), and ~XrdClientInputBuffer().

XrdSysRecMutex XrdClientInputBuffer::fMutex [private]

Referenced by GetMsg(), GetSyncObjOrMakeOne(), PutMsg(), WipeStreamid(), and ~XrdClientInputBuffer().

XrdOucHash<XrdSysSemWait> XrdClientInputBuffer::fSyncobjRepo [private]

Referenced by GetSyncObjOrMakeOne(), and ~XrdClientInputBuffer().

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