#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 |
| XrdSysRecMutex | fMutex |
| XrdSysSemWait | fReadSem |
| XrdSysCondVar | fWriteCnd |
Constructor & Destructor Documentation
| XrdCpMthrQueue::XrdCpMthrQueue | ( | ) |
References fMsgQue, XrdClientVector::Clear(), and fTotSize.
| XrdCpMthrQueue::~XrdCpMthrQueue | ( | ) |
Member Function Documentation
| void XrdCpMthrQueue::Clear | ( | ) |
References GetBuffer(), and fTotSize.
| int XrdCpMthrQueue::GetBuffer | ( | void ** | buf, |
| long long & | offs, | ||
| int & | len | ||
| ) |
References fReadSem, XrdSysSemWait::Wait(), fMutex, fMsgQue, XrdClientVector::GetSize(), XrdClientVector::Pop_front(), fTotSize, XrdCpMessage::len, XrdCpMessage::buf, XrdCpMessage::offs, fWriteCnd, and XrdSysCondVar::Signal().
Referenced by doCp_xrd2xrd(), doCp_xrd2loc(), and Clear().
| int XrdCpMthrQueue::GetLength | ( | ) | [inline] |
Referenced by doCp_xrd2xrd(), and doCp_xrd2loc().
| int XrdCpMthrQueue::PutBuffer | ( | void * | buf, |
| long long | offs, | ||
| int | len | ||
| ) |
References FALSE, fMutex, fTotSize, CPMTQ_BUFFSIZE, TRUE, fWriteCnd, XrdSysCondVar::Wait(), XrdCpMessage::offs, XrdCpMessage::buf, XrdCpMessage::len, fMsgQue, XrdClientVector::Push_back(), fReadSem, and XrdSysSemWait::Post().
Referenced by ReaderThread_xrd(), ReaderThread_xrd_xtreme(), and ReaderThread_loc().
Member Data Documentation
int XrdCpMthrQueue::fMsgIter [private] |
XrdClientVector<XrdCpMessage*> XrdCpMthrQueue::fMsgQue [private] |
Referenced by XrdCpMthrQueue(), PutBuffer(), and GetBuffer().
XrdSysRecMutex XrdCpMthrQueue::fMutex [private] |
Referenced by PutBuffer(), and GetBuffer().
XrdSysSemWait XrdCpMthrQueue::fReadSem [private] |
Referenced by PutBuffer(), and GetBuffer().
long XrdCpMthrQueue::fTotSize [private] |
Referenced by XrdCpMthrQueue(), PutBuffer(), GetBuffer(), and Clear().
XrdSysCondVar XrdCpMthrQueue::fWriteCnd [private] |
Referenced by PutBuffer(), and GetBuffer().
The documentation for this class was generated from the following files:
