xrootd
|
#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 | ( | ) |
References DeleteHashItem().
XrdClientMessage * XrdClientInputBuffer::GetMsg | ( | int | streamid, |
int | secstimeout | ||
) |
References XrdSysSemWait::Wait().
Referenced by XrdClientPhyConnection::ReadMessage().
XrdSysSemWait * XrdClientInputBuffer::GetSyncObjOrMakeOne | ( | int | streamid | ) | [private] |
References snprintf.
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().
int XrdClientInputBuffer::fMsgIter [private] |
XrdSysRecMutex XrdClientInputBuffer::fMutex [private] |