|
xrootd
|
#include <XrdOfsTPCProg.hh>

Public Member Functions | |
| void | Cancel () |
| void | Run () |
| int | Xeq () |
| XrdOfsTPCProg (XrdOfsTPCProg *Prev, int num) | |
| ~XrdOfsTPCProg () | |
Static Public Member Functions | |
| static int | Init (char *XfrProg, int Num) |
| static XrdOfsTPCProg * | Start (XrdOfsTPCJob *jP, int &rc) |
Private Attributes | |
| XrdOucProg | Prog |
| XrdOucStream | JobStream |
| XrdOfsTPCProg * | Next |
| XrdOfsTPCJob * | Job |
| char | eRec [1024] |
| int | Pnum |
Static Private Attributes | |
| static XrdSysMutex | pgmMutex |
| static XrdOfsTPCProg * | pgmIdle = 0 |
| static const char * | XfrProg = 0 |
| XrdOfsTPCProg::XrdOfsTPCProg | ( | XrdOfsTPCProg * | Prev, |
| int | num | ||
| ) |
Referenced by Init().
|
inline |
|
inline |
References XrdOucStream::Drain(), and JobStream.
Referenced by XrdOfsTPCJob::Del().
|
static |
References pgmIdle, Prog, XrdOucProg::Setup(), XfrProg, and XrdOfsTPCProg().
Referenced by XrdOfsTPC::Start().
| void XrdOfsTPCProg::Run | ( | ) |
References XrdOfsTPCJob::Done(), eRec, Job, XrdSysMutex::Lock(), Next, pgmIdle, pgmMutex, XrdSysMutex::UnLock(), and Xeq().
Referenced by XrdOfsTPCProgRun().
|
static |
References Job, Next, pgmIdle, pgmMutex, XrdSysThread::Run(), and XrdOfsTPCProgRun().
Referenced by XrdOfsTPCJob::Sync().
| int XrdOfsTPCProg::Xeq | ( | ) |
References XrdOfsTPCInfo::Cks, XrdOfsTPC::cksType, DEBUG, XrdOfsTPCInfo::Dst, XrdSysError::Emsg(), EPNAME, eRec, XrdOucStream::GetLine(), XrdOfsTPC::Info, Job, JobStream, XrdOfsTPCInfo::Key, XrdOfsTPCInfo::Lfn, XrdOfsTPCInfo::Org, Pnum, Prog, XrdOucProg::Run(), XrdOucProg::RunDone(), tident, and XfrProg.
Referenced by Run().
|
private |
|
private |
|
private |
|
staticprivate |
|
staticprivate |
|
private |
Referenced by Xeq().
|
private |
1.8.3.1