#include <XrdCpMthrQueue.hh>
Public Member Functions | |
XrdCpMthrQueue () | |
~XrdCpMthrQueue () | |
int | PutBuffer (void *buf, long long offs, int len) |
int | GetBuffer (void **buf, long long &offs, int &len) |
int | GetLength () |
void | Clear () |
Private Attributes | |
long | fTotSize |
XrdClientVector< XrdCpMessage * > | fMsgQue |
int | fMsgIter |
int | fWrWait |
XrdSysRecMutex | fMutex |
XrdSysSemWait | fReadSem |
XrdSysSemaphore | fWriteSem |
XrdCpMthrQueue::XrdCpMthrQueue | ( | ) |
XrdCpMthrQueue::~XrdCpMthrQueue | ( | ) | [inline] |
void XrdCpMthrQueue::Clear | ( | ) |
int XrdCpMthrQueue::GetBuffer | ( | void ** | buf, | |
long long & | offs, | |||
int & | len | |||
) |
int XrdCpMthrQueue::GetLength | ( | ) | [inline] |
References fMsgQue, and XrdClientVector< T >::GetSize().
int XrdCpMthrQueue::PutBuffer | ( | void * | buf, | |
long long | offs, | |||
int | len | |||
) |
int XrdCpMthrQueue::fMsgIter [private] |
XrdClientVector<XrdCpMessage*> XrdCpMthrQueue::fMsgQue [private] |
Referenced by GetLength().
XrdSysRecMutex XrdCpMthrQueue::fMutex [private] |
XrdSysSemWait XrdCpMthrQueue::fReadSem [private] |
long XrdCpMthrQueue::fTotSize [private] |
XrdSysSemaphore XrdCpMthrQueue::fWriteSem [private] |
int XrdCpMthrQueue::fWrWait [private] |