#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] |
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().
Member Data Documentation
int XrdClientInputBuffer::fMsgIter [private] |
XrdSysRecMutex XrdClientInputBuffer::fMutex [private] |
The documentation for this class was generated from the following files:
