XrdFrmXfrQueue Class Reference

#include <XrdFrmXfrQueue.hh>

Collaboration diagram for XrdFrmXfrQueue:

List of all members.

Classes
struct	theQueue
Public Member Functions
	XrdFrmXfrQueue ()
	~XrdFrmXfrQueue ()
Static Public Member Functions
static int	Add (XrdFrcRequest *rP, XrdFrcReqFile *reqF, int theQ)
static void	Done (XrdFrmXfrJob *xP, const char *Msg)
static XrdFrmXfrJob *	Get ()
static int	Init ()
static void	StopMon (void *parg)
Static Private Member Functions
static XrdFrmXfrJob *	Pull ()
static int	Notify (XrdFrcRequest *rP, int qN, int rc, const char *msg=0)
static void	Send2File (char *Dest, char *Msg, int Mln)
static void	Send2UDP (char *Dest, char *Msg, int Mln)
static int	Stopped (int qNum)
static const char *	xfrName (XrdFrcRequest &reqData, int isOut)
Static Private Attributes
static XrdSysMutex	hMutex
static XrdOucHash< XrdFrmXfrJob >	hTab
static XrdSysMutex	qMutex
static XrdSysSemaphore	qReady
static theQueue	xfrQ [XrdFrcRequest::numQ]

---

Constructor & Destructor Documentation

XrdFrmXfrQueue::XrdFrmXfrQueue

(

)

[inline]

XrdFrmXfrQueue::~XrdFrmXfrQueue

(

)

[inline]

---

Member Function Documentation

int XrdFrmXfrQueue::Add	(	XrdFrcRequest *	rP,
		XrdFrcReqFile *	reqF,
		int	theQ
	)		[static]

References stat(), XrdFrcRequest::numQ, XrdFrc::Say, XrdSysError::Emsg(), XrdFrcRequest::LFN, XrdFrcReqFile::Del(), XrdFrcRequest::LFO, XrdFrcRequest::Options, XrdFrcRequest::msgSucc, XrdFrcRequest::msgFail, XrdFrmXfrJob::reqData, XrdFrcRequest::Notify, XrdFrmXfrJob::NoteList, XrdCms::Config, XrdFrc::Trace, XrdOucTrace::What, TRACE_Debug, XrdSysError::Say(), XrdFrmXfrJob::Type, XrdFrcRequest::User, XrdFrmXfrJob::Next, XrdFrmXfrJob::reqFQ, XrdFrmXfrJob::reqFile, XrdFrmXfrJob::PFN, XrdFrmXfrJob::pfnEnd, XrdFrmXfrJob::RetCode, XrdFrmXfrJob::qNum, and Hash_keep.

Referenced by XrdFrmMigrate::Queue(), and XrdFrmReqBoss::Process().

void XrdFrmXfrQueue::Done	(	XrdFrmXfrJob *	xP,
		const char *	Msg
	)		[static]

References XrdFrmXfrJob::reqData, XrdFrmXfrJob::qNum, XrdFrmXfrJob::RetCode, XrdFrmXfrJob::NoteList, XrdFrcRequest::Notify, XrdOucTList::text, XrdOucTList::next, XrdFrmXfrJob::reqFQ, XrdFrcReqFile::Del(), XrdFrmXfrJob::reqFile, and XrdFrmXfrJob::Next.

Referenced by XrdFrmTransfer::Start().

XrdFrmXfrJob * XrdFrmXfrQueue::Get

(

)

[static]

Referenced by XrdFrmTransfer::Start().

int XrdFrmXfrQueue::Init

(

)

[static]

References XrdCms::Config, XrdCmsConfig::AdminPath, XrdSysThread::Run(), InitStop(), XRDSYSTHREAD_BIND, XrdFrc::Say, XrdSysError::Emsg(), and XrdFrmXfrJob::Next.

Referenced by XrdFrmTransfer::Init().

int XrdFrmXfrQueue::Notify	(	XrdFrcRequest *	rP,
		int	qN,
		int	rc,
		const char *	msg = 0
	)		[static, private]

References XrdFrcRequest::Notify, XrdFrcRequest::Options, XrdFrcRequest::msgSucc, XrdFrcRequest::msgFail, index(), XrdFrcRequest::LFN, XrdFrcRequest::ID, XrdFrc::Say, and XrdSysError::Emsg().

XrdFrmXfrJob * XrdFrmXfrQueue::Pull

(

)

[static, private]

References XrdFrcRequest::nilQ, and XrdFrmXfrJob::Next.

void XrdFrmXfrQueue::Send2File	(	char *	Dest,
		char *	Msg,
		int	Mln
	)		[static, private]

References EPNAME, DEBUG, open(), XrdFrc::Say, XrdSysError::Emsg(), fcntl(), F_SETFD, FD_CLOEXEC, write(), and close.

void XrdFrmXfrQueue::Send2UDP	(	char *	Dest,
		char *	Msg,
		int	Mln
	)		[static, private]

References EPNAME, XrdFrc::Say, DEBUG, and XrdNetMsg::Send().

void XrdFrmXfrQueue::StopMon

(

void *

parg

)

[static]

References stat(), XrdFrmXfrQueue::theQueue::Name, XrdFrmXfrQueue::theQueue::Alert, XrdSysSemaphore::Wait(), XrdFrmXfrQueue::theQueue::File, XrdFrc::Say, XrdSysError::Emsg(), XrdSysTimer::Snooze(), XrdFrmXfrQueue::theQueue::Stop, XrdFrmXfrQueue::theQueue::First, and XrdFrmXfrJob::Next.

Referenced by InitStop().

int XrdFrmXfrQueue::Stopped

(

int

qNum

)

[static, private]

References stat(), and File.

const char * XrdFrmXfrQueue::xfrName	(	XrdFrcRequest &	reqData,
		int	isOut
	)		[static, private]

References XrdFrcRequest::Options, and XrdFrcRequest::Purge.

---

Member Data Documentation

XrdSysMutex XrdFrmXfrQueue::hMutex [static, private]

XrdOucHash< XrdFrmXfrJob > XrdFrmXfrQueue::hTab [static, private]

XrdSysMutex XrdFrmXfrQueue::qMutex [static, private]

XrdSysSemaphore XrdFrmXfrQueue::qReady [static, private]

XrdFrmXfrQueue::theQueue XrdFrmXfrQueue::xfrQ [static, private]

---

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

• XrdFrmXfrQueue.hh
• XrdFrmXfrQueue.cc