XrdFrmXfrQueue Class Reference

#include <XrdFrmXfrQueue.hh>

Collaboration diagram for XrdFrmXfrQueue:

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 XrdFrmXfrJob::Act, XrdCopy::Config, XrdFrcReqFile::Del(), XrdSysError::Emsg(), Hash_keep, XrdFrcRequest::LFN, XrdFrcRequest::LFO, XrdFrcRequest::msgFail, XrdFrcRequest::msgSucc, XrdFrmXfrJob::Next, XrdFrmXfrJob::NoteList, XrdFrcRequest::Notify, XrdFrcRequest::numQ, XrdFrcRequest::Options, XrdFrcRequest::outQ, XrdFrmXfrJob::PFN, XrdFrmXfrJob::pfnEnd, XrdFrmXfrJob::qNum, XrdFrmXfrJob::reqData, XrdFrmXfrJob::reqFile, XrdFrmXfrJob::reqFQ, XrdFrmXfrJob::RetCode, XrdFrc::Say, XrdSysError::Say(), stat(), XrdFrc::Trace, TRACE_Debug, XrdFrmXfrJob::Type, XrdFrcRequest::User, XrdCpConfig::Verbose, and XrdOucTrace::What.

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

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

static

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

Referenced by XrdFrmTransfer::Start().

XrdFrmXfrJob * XrdFrmXfrQueue::Get ( )

static

Referenced by XrdFrmTransfer::Start().

int XrdFrmXfrQueue::Init ( )

static

References XrdCopy::Config, XrdSysError::Emsg(), InitStop(), XrdFrmXfrJob::Next, XrdFrcRequest::numQ, XrdSysThread::Run(), XrdFrc::Say, and XRDSYSTHREAD_BIND.

Referenced by XrdFrmTransfer::Init().

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

staticprivate

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

XrdFrmXfrJob * XrdFrmXfrQueue::Pull ( )

staticprivate

References XrdFrcRequest::getQ, XrdFrcRequest::migQ, XrdFrmXfrJob::Next, XrdFrcRequest::nilQ, XrdFrcRequest::putQ, and XrdFrcRequest::stgQ.

void XrdFrmXfrQueue::Send2File ( char *  Dest, char *  Msg, int  Mln  )

staticprivate

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

void XrdFrmXfrQueue::Send2UDP ( char *  Dest, char *  Msg, int  Mln  )

staticprivate

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

void XrdFrmXfrQueue::StopMon ( void *  parg )

static

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

Referenced by InitStop().

int XrdFrmXfrQueue::Stopped ( int  qNum )

staticprivate

References File, and stat().

const char * XrdFrmXfrQueue::xfrName ( XrdFrcRequest &  reqData, int  isOut  )

staticprivate

References XrdFrcRequest::getQ, XrdFrcRequest::migQ, XrdFrcRequest::Options, XrdFrcRequest::Purge, XrdFrcRequest::putQ, and XrdFrcRequest::stgQ.

Member Data Documentation

XrdSysMutex XrdFrmXfrQueue::hMutex

staticprivate

XrdOucHash< XrdFrmXfrJob > XrdFrmXfrQueue::hTab

staticprivate

XrdSysMutex XrdFrmXfrQueue::qMutex

staticprivate

XrdSysSemaphore XrdFrmXfrQueue::qReady

staticprivate

XrdFrmXfrQueue::theQueue XrdFrmXfrQueue::xfrQ

staticprivate

---

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

• XrdFrmXfrQueue.hh
• XrdFrmXfrQueue.cc