![]() |
XRootD
|
#include <XrdFrmXfrQueue.hh>
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 (int ioQType) |
static int | Init () |
static void | StopMon (void *parg) |
Static Public Attributes | |
static const int | useAnyQ = 0 |
static const int | useInpQ = 1 |
static const int | useOutQ = -1 |
Definition at line 41 of file XrdFrmXfrQueue.hh.
|
inline |
Definition at line 59 of file XrdFrmXfrQueue.hh.
|
inline |
Definition at line 60 of file XrdFrmXfrQueue.hh.
|
static |
Definition at line 73 of file XrdFrmXfrQueue.cc.
References XrdFrmXfrJob::Act, XrdCms::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, and XrdOucTrace::What.
Referenced by XrdFrmReqBoss::Process(), and XrdFrmMigrate::Queue().
|
static |
Definition at line 185 of file XrdFrmXfrQueue.cc.
References XrdFrcReqFile::Del(), XrdFrmXfrJob::Next, XrdOucTList::next, XrdFrmXfrJob::NoteList, XrdFrcRequest::Notify, XrdFrmXfrJob::qNum, XrdFrmXfrJob::reqData, XrdFrmXfrJob::reqFile, XrdFrmXfrJob::reqFQ, XrdFrmXfrJob::RetCode, and XrdOucTList::text.
Referenced by XrdFrmTransfer::Start().
|
static |
Definition at line 220 of file XrdFrmXfrQueue.cc.
Referenced by XrdFrmTransfer::Start().
|
static |
Definition at line 239 of file XrdFrmXfrQueue.cc.
References XrdCms::Config, XrdSysError::Emsg(), InitStop(), XrdFrmXfrJob::Next, XrdFrcRequest::numQ, XrdSysThread::Run(), XrdFrc::Say, and XRDSYSTHREAD_BIND.
Referenced by XrdFrmTransfer::Init().
|
static |
Definition at line 438 of file XrdFrmXfrQueue.cc.
References XrdSysError::Emsg(), XrdFrmXfrJob::Next, XrdFrc::Say, XrdSysTimer::Snooze(), and stat().
Referenced by InitStop().
|
static |
Definition at line 50 of file XrdFrmXfrQueue.hh.
Referenced by XrdFrmTransfer::Init().
|
static |
Definition at line 49 of file XrdFrmXfrQueue.hh.
Referenced by XrdFrmTransfer::Init().
|
static |
Definition at line 51 of file XrdFrmXfrQueue.hh.
Referenced by XrdFrmTransfer::Init().