#include <XrdClientInputBuffer.hh>
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 |
XrdClientInputBuffer::XrdClientInputBuffer | ( | ) |
XrdClientInputBuffer::~XrdClientInputBuffer | ( | ) |
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().
int XrdClientInputBuffer::fMsgIter [private] |
Referenced by MexSize().
XrdSysRecMutex XrdClientInputBuffer::fMutex [private] |
Referenced by SemSize().