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