![]() |
XRootD
|
#include <XrdOfsTPCProg.hh>
Public Member Functions | |
XrdOfsTPCProg (XrdOfsTPCProg *Prev, int num, int errMon) | |
~XrdOfsTPCProg () | |
void | Cancel () |
void | Run () |
int | Xeq (bool &isIPv4) |
Static Public Member Functions | |
static int | Init () |
static XrdOfsTPCProg * | Start (XrdOfsTPCJob *jP, int &rc) |
Definition at line 40 of file XrdOfsTPCProg.hh.
XrdOfsTPCProg::XrdOfsTPCProg | ( | XrdOfsTPCProg * | Prev, |
int | num, | ||
int | errMon | ||
) |
Definition at line 122 of file XrdOfsTPCProg.cc.
Referenced by Init().
|
inline |
Definition at line 57 of file XrdOfsTPCProg.hh.
|
inline |
Definition at line 44 of file XrdOfsTPCProg.hh.
References XrdOucStream::Drain().
Referenced by XrdOfsTPCJob::Del().
|
static |
Definition at line 167 of file XrdOfsTPCProg.cc.
References XrdOfsTPCProg(), XrdNetPMarkConfig::Cfg, GTRACE, OfsEroute, and XrdOucProg::Setup().
Referenced by XrdOfsTPC::Start().
void XrdOfsTPCProg::Run | ( | ) |
Definition at line 188 of file XrdOfsTPCProg.cc.
References XrdXrootdTpcMon::TpcInfo::begT, XrdNetPMarkConfig::Cfg, XrdXrootdTpcMon::TpcInfo::clID, XrdNetIdentity::Domain(), XrdOfsTPCJob::Done(), XrdOfsTPCInfo::Dst, XrdXrootdTpcMon::TpcInfo::dstURL, XrdXrootdTpcMon::TpcInfo::endRC, XrdXrootdTpcMon::TpcInfo::endT, XrdXrootdTpcMon::TpcInfo::fSize, XrdOfsTPC::Info, XrdXrootdTpcMon::TpcInfo::Init(), XrdXrootdTpcMon::TpcInfo::isIPv4, XrdOfsTPCInfo::Key, XrdOfsTPCInfo::Lfn, XrdSysMutex::Lock(), XrdXrootdTpcMon::TpcInfo::opts, XrdOfsTPCInfo::Org, XrdXrootdTpcMon::TpcInfo::srcURL, Stat, stat(), XrdOss::Stat(), XrdOfsTPCInfo::Str, XrdXrootdTpcMon::TpcInfo::strm, XrdSysMutex::UnLock(), Xeq(), and XrdOfsOss.
Referenced by XrdOfsTPCProgRun().
|
static |
Definition at line 253 of file XrdOfsTPCProg.cc.
References XrdSysThread::Run(), and XrdOfsTPCProgRun().
Referenced by XrdOfsTPCJob::Sync().
int XrdOfsTPCProg::Xeq | ( | bool & | isIPv4 | ) |
Definition at line 280 of file XrdOfsTPCProg.cc.
References XrdNetPMarkConfig::Cfg, XrdOfsTPCInfo::Cks, DEBUG, XrdOfsTPCInfo::Dst, XrdSysError::Emsg(), EPNAME, XrdOucStream::GetLine(), XrdOfsTPC::Info, XrdOfsTPCInfo::Key, XrdOfsTPCInfo::Lfn, OfsEroute, XrdOfsTPCInfo::Org, XrdOfsTPCInfo::Rpx, XrdOucProg::Run(), XrdOucProg::RunDone(), XrdSysError::Say(), XrdOfsTPCInfo::Spr, XrdOfsTPCInfo::Str, XrdOfsTPCInfo::Success(), tident, XrdOfsTPCInfo::Tpr, XrdOss::Unlink(), and XrdOfsOss.
Referenced by Run().