#include <XrdFrmMigrate.hh>
Definition at line 40 of file XrdFrmMigrate.hh.
◆ XrdFrmMigrate()
XrdFrmMigrate::XrdFrmMigrate |
( |
| ) |
|
|
inline |
◆ ~XrdFrmMigrate()
XrdFrmMigrate::~XrdFrmMigrate |
( |
| ) |
|
|
inline |
◆ Display()
void XrdFrmMigrate::Display |
( |
| ) |
|
|
static |
Definition at line 137 of file XrdFrmMigrate.cc.
144 Say.
Say(
"=====> ",
"Migrate configuration:");
149 {
Say.
Say(
"=====> ",
"Scanning ", (vP->
Val?
"r/w: ":
"r/o: "), vP->
Name);
151 while(tP) {
Say.
Say(
"=====> ",
"Excluded ", tP->
text); tP = tP->
next;}
void Say(const char *text1, const char *text2=0, const char *txt3=0, const char *text4=0, const char *text5=0, const char *txt6=0)
References XrdCms::Config, XrdFrmConfig::VPInfo::Dir, XrdFrmConfig::VPInfo::Name, XrdFrmConfig::VPInfo::Next, XrdOucTList::next, XrdFrc::Say, XrdSysError::Say(), XrdOucTList::text, and XrdFrmConfig::VPInfo::Val.
◆ Migrate()
void XrdFrmMigrate::Migrate |
( |
int |
doinit = 1 | ) |
|
|
static |
Definition at line 202 of file XrdFrmMigrate.cc.
215 Say.
Emsg(
"Migrate", retc,
"create migrtion thread");
223 do{migWait =
Config.WaitMigr; numMig = 0;
225 while((wTime = Advance()))
226 {
if ((migWait -= wTime) <= 0)
break;
229 while(fsDefer) {fP = fsDefer; fsDefer = fsDefer->
Next;
delete fP;}
230 sprintf(buff,
"%d file%s selected for transfer.",numMig,(numMig==1?
"":
"s"));
void * XrdMigrateStart(void *parg)
#define XRDSYSTHREAD_BIND
int Emsg(const char *esfx, int ecode, const char *text1, const char *text2=0)
static int Run(pthread_t *, void *(*proc)(void *), void *arg, int opts=0, const char *desc=0)
static void Snooze(int seconds)
References XrdCms::Config, XrdSysError::Emsg(), XrdFrmFileset::Next, XrdSysThread::Run(), XrdFrc::Say, XrdSysTimer::Snooze(), XrdMigrateStart(), and XRDSYSTHREAD_BIND.
Referenced by XrdFrmXfrDaemon::Init(), and XrdMigrateStart().
◆ Queue()
Definition at line 240 of file XrdFrmMigrate.cc.
242 static int reqID = 0;
247 memset(&myReq, 0,
sizeof(myReq));
249 sprintf(myReq.
ID,
"Internal%d", reqID++);
251 myReq.
addTOD =
static_cast<long long>(time(0));
static int Add(XrdFrcRequest *rP, XrdFrcReqFile *reqF, int theQ)
References XrdFrmXfrQueue::Add(), XrdFrcRequest::addTOD, XrdFrmFileset::basePath(), XrdCms::Config, XrdFrcRequest::ID, XrdFrcRequest::LFN, XrdFrcRequest::migQ, XrdFrcRequest::Migrate, XrdCmsConfig::myProg, XrdFrcRequest::Options, strlcpy(), and XrdFrcRequest::User.
The documentation for this class was generated from the following files: