Go to the documentation of this file.
51 #define CPMTQ_BUFFSIZE 50000000
72 int GetBuffer(
void **buf,
long long &offs,
int &len);
Definition: XrdCpMthrQueue.hh:53
~XrdCpMthrQueue()
Definition: XrdCpMthrQueue.hh:69
Definition: XrdSysSemWait.hh:34
int GetSize() const
Definition: XrdClientVector.hh:142
XrdSysSemaphore fWriteSem
Definition: XrdCpMthrQueue.hh:64
XrdSysSemWait fReadSem
Definition: XrdCpMthrQueue.hh:62
Definition: XrdCpMthrQueue.hh:43
long fTotSize
Definition: XrdCpMthrQueue.hh:55
Definition: XrdSysPthread.hh:404
Definition: XrdSysPthread.hh:240
XrdClientVector< XrdCpMessage * > fMsgQue
Definition: XrdCpMthrQueue.hh:56
XrdSysRecMutex fMutex
Definition: XrdCpMthrQueue.hh:60
int PutBuffer(void *buf, long long offs, int len)
int len
Definition: XrdCpMthrQueue.hh:46
void * buf
Definition: XrdCpMthrQueue.hh:44
int GetBuffer(void **buf, long long &offs, int &len)
int fWrWait
Definition: XrdCpMthrQueue.hh:58
long long offs
Definition: XrdCpMthrQueue.hh:45
int GetLength()
Definition: XrdCpMthrQueue.hh:73
int fMsgIter
Definition: XrdCpMthrQueue.hh:57