#include <XrdFrmMigrate.hh>
Public Member Functions | |
XrdFrmMigrate () | |
~XrdFrmMigrate () | |
Static Public Member Functions | |
static void | Display () |
static void | Queue (XrdFrmFileset *sP) |
static void | Migrate (int doinit=1) |
Static Private Member Functions | |
static void | Add (XrdFrmFileset *fsp) |
static int | Advance () |
static void | Defer (XrdFrmFileset *sP) |
static const char * | Eligible (XrdFrmFileset *sP, time_t &xTime) |
static void | Remfix (const char *Ftype, const char *Fname) |
static void | Scan () |
static int | Screen (XrdFrmFileset *sP) |
Static Private Attributes | |
static XrdOucHash< char > | BadFiles |
static XrdFrmFileset * | fsDefer |
static int | numMig |
Definition at line 24 of file XrdFrmMigrate.hh.
XrdFrmMigrate::XrdFrmMigrate | ( | ) | [inline] |
Definition at line 34 of file XrdFrmMigrate.hh.
XrdFrmMigrate::~XrdFrmMigrate | ( | ) | [inline] |
Definition at line 35 of file XrdFrmMigrate.hh.
void XrdFrmMigrate::Display | ( | ) | [static] |
Definition at line 123 of file XrdFrmMigrate.cc.
References XrdFrm::Config(), XrdFrmConfig::VPInfo::Dir, XrdFrmConfig::VPInfo::Name, XrdOucTList::next, XrdFrmConfig::VPInfo::Next, XrdFrmConfig::pathList, XrdFrm::Say(), XrdSysError::Say(), XrdOucTList::text, and XrdFrmConfig::VPInfo::Val.
void XrdFrmMigrate::Queue | ( | XrdFrmFileset * | sP | ) | [static] |
Definition at line 226 of file XrdFrmMigrate.cc.
References XrdFrmXfrQueue::Add(), XrdFrmFileset::basePath(), XrdFrm::Config(), XrdFrmConfig::LogicalPath(), XrdFrmRequest::migQ, XrdFrmRequest::Migrate, XrdFrmConfig::myProg, numMig, sprintf(), and strlcpy().
Referenced by Add().
void XrdFrmMigrate::Migrate | ( | int | doinit = 1 |
) | [static] |
Definition at line 188 of file XrdFrmMigrate.cc.
References Advance(), XrdFrm::Config(), XrdSysError::Emsg(), fsDefer, XrdFrmFileset::Next, numMig, XrdSysThread::Run(), XrdFrm::Say(), Scan(), XrdSysTimer::Snooze(), sprintf(), XrdFrmConfig::WaitMigr, XrdMigrateStart(), and XRDSYSTHREAD_BIND.
Referenced by XrdFrmXfrDaemon::Init(), and XrdMigrateStart().
void XrdFrmMigrate::Add | ( | XrdFrmFileset * | fsp | ) | [static, private] |
Definition at line 54 of file XrdFrmMigrate.cc.
References XrdFrmFileset::basePath(), XrdFrm::Config(), DEBUG, Defer(), Eligible(), EPNAME, XrdFrmConfig::IdleHold, and Queue().
int XrdFrmMigrate::Advance | ( | ) | [static, private] |
Definition at line 78 of file XrdFrmMigrate.cc.
References Add(), XrdFrmFileset::baseFile(), XrdFrm::Config(), fsDefer, XrdFrmConfig::IdleHold, XrdFrmFileset::Next, XrdFrmFileset::Refresh(), and XrdOucNSWalk::NSEnt::Stat.
Referenced by Migrate().
void XrdFrmMigrate::Defer | ( | XrdFrmFileset * | sP | ) | [static, private] |
Definition at line 102 of file XrdFrmMigrate.cc.
References XrdFrmFileset::baseFile(), fsDefer, XrdFrmFileset::Next, and XrdOucNSWalk::NSEnt::Stat.
Referenced by Add().
const char * XrdFrmMigrate::Eligible | ( | XrdFrmFileset * | sP, | |
time_t & | xTime | |||
) | [static, private] |
Definition at line 146 of file XrdFrmMigrate.cc.
References XrdFrmFileset::baseFile(), XrdFrmTransfer::checkFF(), XrdFrmFileset::failFile(), XrdFrmFileset::failPath(), XrdFrmFileset::lockFile(), and XrdOucNSWalk::NSEnt::Stat.
Referenced by Add().
void XrdFrmMigrate::Remfix | ( | const char * | Ftype, | |
const char * | Fname | |||
) | [static, private] |
Definition at line 250 of file XrdFrmMigrate.cc.
References XrdFrm::Config(), XrdSysError::Emsg(), XrdFrmConfig::ossFS, XrdFrm::Say(), XrdOss::Unlink(), and XRDOSS_isPFN.
Referenced by Screen().
void XrdFrmMigrate::Scan | ( | ) | [static, private] |
Definition at line 262 of file XrdFrmMigrate.cc.
References Add(), BadFiles, XrdFrmFiles::CompressD, XrdFrm::Config(), XrdFrmConfig::VPInfo::Dir, XrdSysError::Emsg(), XrdFrmFiles::Get(), XrdFrmConfig::VPInfo::Name, XrdFrmConfig::VPInfo::Next, XrdFrmFiles::NoAutoDel, XrdMpx::Opts, XrdFrmConfig::pathList, XrdOucHash< T >::Purge(), XrdFrmFiles::Recursive, XrdFrm::Say(), Screen(), sprintf(), and VMSG.
Referenced by Migrate().
int XrdFrmMigrate::Screen | ( | XrdFrmFileset * | sP | ) | [static, private] |
Definition at line 310 of file XrdFrmMigrate.cc.
References XrdOucHash< T >::Add(), BadFiles, XrdFrmFileset::baseFile(), XrdFrmFileset::basePath(), XrdFrm::Config(), XrdFrmFileset::dirPath(), XrdSysError::Emsg(), XrdFrmFileset::failFile(), XrdFrmFileset::failPath(), XrdFrmConfig::Fix, Hash_data_is_key, XrdFrmFileset::lockFile(), XrdFrmFileset::lockPath(), Remfix(), XrdFrm::Say(), and RooFit::What().
Referenced by Scan().
XrdOucHash< char > XrdFrmMigrate::BadFiles [static, private] |
XrdFrmFileset * XrdFrmMigrate::fsDefer [static, private] |
int XrdFrmMigrate::numMig [static, private] |