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