Main Page | Namespace List | Class Hierarchy | Class List | Directories | File List | Namespace Members | Class Members | File Members

XrdClientInputBuffer Class Reference

#include <XrdClientInputBuffer.hh>

Collaboration diagram for XrdClientInputBuffer:

Collaboration graph
[legend]
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 (   ) 
 

XrdClientInputBuffer::~XrdClientInputBuffer (   ) 
 


Member Function Documentation

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

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

bool XrdClientInputBuffer::IsMexEmpty (   )  [inline]
 

bool XrdClientInputBuffer::IsSemEmpty (   )  [inline]
 

int XrdClientInputBuffer::MexSize (   )  [inline]
 

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

int XrdClientInputBuffer::PutMsg (  XrdClientMessage *  msg  ) 
 

int XrdClientInputBuffer::SemSize (   )  [inline]
 

int XrdClientInputBuffer::WipeStreamid (  int  streamid  ) 
 


Member Data Documentation

int XrdClientInputBuffer::fMsgIter [private]
 

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

XrdSysRecMutex XrdClientInputBuffer::fMutex [private]
 

XrdOucHash<XrdSysSemWait> XrdClientInputBuffer::fSyncobjRepo [private]
 


The documentation for this class was generated from the following files:
Generated on Sun Nov 6 13:41:55 2011 for xrootd by  doxygen 1.3.9.1