XrdCpMthrQueue Class Reference

#include <XrdCpMthrQueue.hh>

Collaboration diagram for XrdCpMthrQueue:

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

Constructor & Destructor Documentation

XrdCpMthrQueue::XrdCpMthrQueue

(

)

References XrdClientVector< T >::Clear(), fMsgQue, and fTotSize.

XrdCpMthrQueue::~XrdCpMthrQueue ( )

inline

Member Function Documentation

void XrdCpMthrQueue::Clear

(

)

References fMsgQue, fTotSize, GetBuffer(), and XrdClientVector< T >::GetSize().

int XrdCpMthrQueue::GetBuffer	(	void **	buf,
		long long &	offs,
		int &	len
	)

References XrdCpMessage::buf, fMsgQue, fMutex, fReadSem, fTotSize, fWriteSem, fWrWait, XrdClientVector< T >::GetSize(), XrdCpMessage::len, XrdSysMutex::Lock(), XrdCpMessage::offs, XrdClientVector< T >::Pop_front(), XrdSysSemaphore::Post(), XrdSysMutex::UnLock(), and XrdSysSemWait::Wait().

Referenced by Clear(), doCp_loc2xrd(), doCp_xrd2loc(), and doCp_xrd2xrd().

int XrdCpMthrQueue::GetLength ( )

inline

Referenced by doCp_xrd2loc(), and doCp_xrd2xrd().

int XrdCpMthrQueue::PutBuffer	(	void *	buf,
		long long	offs,
		int	len
	)

References XrdCpMessage::buf, CPMTQ_BUFFSIZE, fMsgQue, fMutex, fReadSem, fTotSize, fWriteSem, fWrWait, XrdCpMessage::len, XrdSysMutex::Lock(), XrdCpMessage::offs, XrdSysSemWait::Post(), XrdClientVector< T >::Push_back(), XrdSysMutex::UnLock(), and XrdSysSemaphore::Wait().

Referenced by ReaderThread_loc(), ReaderThread_xrd(), and ReaderThread_xrd_xtreme().

Member Data Documentation

int XrdCpMthrQueue::fMsgIter

private

XrdClientVector<XrdCpMessage*> XrdCpMthrQueue::fMsgQue

private

Referenced by Clear(), GetBuffer(), PutBuffer(), and XrdCpMthrQueue().

XrdSysRecMutex XrdCpMthrQueue::fMutex

private

Referenced by GetBuffer(), and PutBuffer().

XrdSysSemWait XrdCpMthrQueue::fReadSem

private

Referenced by GetBuffer(), and PutBuffer().

long XrdCpMthrQueue::fTotSize

private

Referenced by Clear(), GetBuffer(), PutBuffer(), and XrdCpMthrQueue().

XrdSysSemaphore XrdCpMthrQueue::fWriteSem

private

Referenced by GetBuffer(), and PutBuffer().

int XrdCpMthrQueue::fWrWait

private

Referenced by GetBuffer(), and PutBuffer().

---

The documentation for this class was generated from the following files:

• XrdCpMthrQueue.hh
• XrdCpMthrQueue.cc