XrdFrmMigrate Class Reference

#include <XrdFrmMigrate.hh>

List of all members.

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 XrdFrmFilesetfsDefer
static int numMig


Detailed Description

Definition at line 24 of file XrdFrmMigrate.hh.


Constructor & Destructor Documentation

XrdFrmMigrate::XrdFrmMigrate (  )  [inline]

Definition at line 34 of file XrdFrmMigrate.hh.

XrdFrmMigrate::~XrdFrmMigrate (  )  [inline]

Definition at line 35 of file XrdFrmMigrate.hh.


Member Function Documentation

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().

Referenced by Advance(), and Scan().

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().


Member Data Documentation

XrdOucHash< char > XrdFrmMigrate::BadFiles [static, private]

Definition at line 51 of file XrdFrmMigrate.hh.

Referenced by Scan(), and Screen().

XrdFrmFileset * XrdFrmMigrate::fsDefer [static, private]

Definition at line 52 of file XrdFrmMigrate.hh.

Referenced by Advance(), Defer(), and Migrate().

int XrdFrmMigrate::numMig [static, private]

Definition at line 53 of file XrdFrmMigrate.hh.

Referenced by Migrate(), and Queue().


The documentation for this class was generated from the following files:
Generated on Tue Jul 5 16:50:31 2011 for ROOT_528-00b_version by  doxygen 1.5.1