#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.
138{
141
142
143
144 Say.Say(
"=====> ",
"Migrate configuration:");
145
146
147
148 while(vP)
149 {
Say.Say(
"=====> ",
"Scanning ", (vP->
Val?
"r/w: ":
"r/o: "), vP->Name);
151 while(tP) {
Say.Say(
"=====> ",
"Excluded ", tP->
text); tP = tP->
next;}
153 }
154}
XrdOucPup XrdCmsParser::Pup & Say
References XrdFrm::Config, XrdFrmConfig::VPInfo::Dir, XrdFrmConfig::VPInfo::Name, XrdFrmConfig::VPInfo::Next, XrdOucTList::next, XrdFrmConfig::pathList, Say, XrdOucTList::text, and XrdFrmConfig::VPInfo::Val.
◆ Migrate()
void XrdFrmMigrate::Migrate |
( |
int | doinit = 1 | ) |
|
|
static |
Definition at line 202 of file XrdFrmMigrate.cc.
203{
205 char buff[80];
206 int migWait, wTime;
207
208
209
210 if (doinit)
211 {pthread_t tid;
212 int retc;
215 Say.Emsg(
"Migrate", retc,
"create migrtion thread");
216 return;
217 }
218
219
220
221
222
224 Scan();
225 while((wTime = Advance()))
226 {if ((migWait -= wTime) <= 0) break;
228 }
229 while(fsDefer) {fP = fsDefer; fsDefer = fsDefer->
Next;
delete fP;}
230 sprintf(buff, "%d file%s selected for transfer.",numMig,(numMig==1?"":"s"));
231 Say.Emsg(
"Migrate", buff);
233 } while(1);
234}
void * XrdMigrateStart(void *parg)
#define XRDSYSTHREAD_BIND
static int Run(pthread_t *, void *(*proc)(void *), void *arg, int opts=0, const char *desc=0)
static void Snooze(int seconds)
References XrdFrm::Config, XrdFrmFileset::Next, XrdSysThread::Run(), Say, XrdSysTimer::Snooze(), XrdFrmConfig::WaitMigr, XrdMigrateStart(), and XRDSYSTHREAD_BIND.
Referenced by XrdFrmXfrDaemon::Init(), and XrdMigrateStart().
◆ Queue()
Definition at line 240 of file XrdFrmMigrate.cc.
241{
242 static int reqID = 0;
244
245
246
247 memset(&myReq, 0, sizeof(myReq));
249 sprintf(myReq.
ID,
"Internal%d", reqID++);
251 myReq.
addTOD =
static_cast<long long>(time(0));
254
255
256
257 delete sP;
258}
int LogicalPath(const char *oldp, char *newp, int newpsz)
static int Add(XrdFrcRequest *rP, XrdFrcReqFile *reqF, int theQ)
References XrdFrmXfrQueue::Add(), XrdFrcRequest::addTOD, XrdFrmFileset::basePath(), XrdFrm::Config, XrdFrcRequest::ID, XrdFrcRequest::LFN, XrdFrmConfig::LogicalPath(), XrdFrcRequest::migQ, XrdFrcRequest::Migrate, XrdFrmConfig::myProg, XrdFrcRequest::Options, strlcpy(), and XrdFrcRequest::User.
The documentation for this class was generated from the following files: