#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] |
1.5.1