![]() |
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, XrdOucHash< T >::Add(), XrdFrm::Config, XrdFrcReqFile::Del(), XrdOucHash< T >::Find(), Hash_keep, XrdFrcRequest::LFN, XrdFrcRequest::LFO, XrdFrmConfig::LocalPath(), XrdSysMutex::Lock(), XrdFrcRequest::msgFail, XrdFrcRequest::msgSucc, XrdFrmXfrJob::Next, XrdFrmXfrJob::NoteList, XrdFrcRequest::Notify, XrdFrcRequest::numQ, XrdFrcRequest::Options, XrdFrcRequest::outQ, XrdFrmXfrJob::PFN, XrdFrmXfrJob::pfnEnd, XrdSysSemaphore::Post(), XrdFrmXfrJob::qNum, XrdFrmXfrJob::reqData, XrdFrmXfrJob::reqFile, XrdFrmXfrJob::reqFQ, XrdFrmXfrJob::RetCode, Say, stat, XrdFrmConfig::Stat(), XrdFrc::Trace, TRACE_Debug, XrdFrmXfrJob::Type, XrdSysMutex::UnLock(), XrdFrcRequest::User, XrdFrmConfig::Verbose, and XrdOucTrace::What.
Referenced by XrdFrmReqBoss::Process(), and XrdFrmMigrate::Queue().
|
static |
Definition at line 185 of file XrdFrmXfrQueue.cc.
References XrdOucHash< T >::Del(), XrdFrcReqFile::Del(), XrdSysMutex::Lock(), XrdFrmXfrJob::Next, XrdOucTList::next, XrdFrmXfrJob::NoteList, XrdFrcRequest::Notify, XrdFrmXfrJob::qNum, XrdFrmXfrJob::reqData, XrdFrmXfrJob::reqFile, XrdFrmXfrJob::reqFQ, XrdFrmXfrJob::RetCode, XrdOucTList::text, and XrdSysMutex::UnLock().
Referenced by XrdFrmTransfer::Start().
|
static |
Definition at line 220 of file XrdFrmXfrQueue.cc.
References XrdSysSemaphore::Wait().
Referenced by XrdFrmTransfer::Start().
|
static |
Definition at line 239 of file XrdFrmXfrQueue.cc.
References XrdFrmConfig::AdminPath, XrdFrm::Config, InitStop(), XrdFrmXfrJob::Next, XrdFrcRequest::numQ, XrdSysThread::Run(), Say, XrdFrmConfig::xfrMax, and XRDSYSTHREAD_BIND.
Referenced by XrdFrmTransfer::Init().
|
static |
Definition at line 438 of file XrdFrmXfrQueue.cc.
References XrdSysMutex::Lock(), XrdFrmXfrJob::Next, XrdSysSemaphore::Post(), Say, XrdSysTimer::Snooze(), stat, and XrdSysMutex::UnLock().
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().