xrootd
Public Member Functions | Private Member Functions | Private Attributes | List of all members
XrdClientInputBuffer Class Reference

#include <XrdClientInputBuffer.hh>

Collaboration diagram for XrdClientInputBuffer:
Collaboration graph
[legend]

Public Member Functions

 XrdClientInputBuffer ()
 
 ~XrdClientInputBuffer ()
 
bool IsMexEmpty ()
 
bool IsSemEmpty ()
 
int MexSize ()
 
int PutMsg (XrdClientMessage *msg)
 
int SemSize ()
 
int WipeStreamid (int streamid)
 
XrdClientMessageGetMsg (int streamid, int secstimeout)
 

Private Member Functions

XrdSysSemWaitGetSyncObjOrMakeOne (int streamid)
 
int MsgForStreamidCnt (int streamid)
 

Private Attributes

XrdClientVector< XrdClientMessage * > fMsgQue
 
int fMsgIter
 
XrdSysRecMutex fMutex
 
XrdOucHash< XrdSysSemWaitfSyncobjRepo
 

Constructor & Destructor Documentation

◆ XrdClientInputBuffer()

XrdClientInputBuffer::XrdClientInputBuffer ( )

◆ ~XrdClientInputBuffer()

XrdClientInputBuffer::~XrdClientInputBuffer ( )

Member Function Documentation

◆ GetMsg()

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

◆ GetSyncObjOrMakeOne()

XrdSysSemWait* XrdClientInputBuffer::GetSyncObjOrMakeOne ( int  streamid)
private

◆ IsMexEmpty()

bool XrdClientInputBuffer::IsMexEmpty ( )
inline

◆ IsSemEmpty()

bool XrdClientInputBuffer::IsSemEmpty ( )
inline

◆ MexSize()

int XrdClientInputBuffer::MexSize ( )
inline

◆ MsgForStreamidCnt()

int XrdClientInputBuffer::MsgForStreamidCnt ( int  streamid)
private

◆ PutMsg()

int XrdClientInputBuffer::PutMsg ( XrdClientMessage msg)

◆ SemSize()

int XrdClientInputBuffer::SemSize ( )
inline

◆ WipeStreamid()

int XrdClientInputBuffer::WipeStreamid ( int  streamid)

Member Data Documentation

◆ fMsgIter

int XrdClientInputBuffer::fMsgIter
private

◆ fMsgQue

XrdClientVector<XrdClientMessage*> XrdClientInputBuffer::fMsgQue
private

◆ fMutex

XrdSysRecMutex XrdClientInputBuffer::fMutex
private

◆ fSyncobjRepo

XrdOucHash<XrdSysSemWait> XrdClientInputBuffer::fSyncobjRepo
private

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