#include <XrdFrmTransfer.hh>
List of all members.
Constructor & Destructor Documentation
XrdFrmTransfer::XrdFrmTransfer |
( |
| ) |
|
XrdFrmTransfer::~XrdFrmTransfer |
( |
| ) |
[inline] |
Member Function Documentation
const char * XrdFrmTransfer::checkFF |
( |
const char * |
Path | ) |
[static] |
const char * XrdFrmTransfer::Fetch |
( |
| ) |
[private] |
References XrdFrmConfig::cmdAlloc, XrdFrmConfig::cmdStats, XrdFrmConfig::cmsPath, XrdFrm::Config, XrdOss::Create(), DEBUG, XrdSysError::Emsg(), EPNAME, XrdNetCmsNotify::Have(), XrdFrmMonitor::Map(), XrdFrmConfig::monStage, XrdFrmConfig::Cmd::Opts, XrdFrmConfig::ossFS, XrdFrmConfig::RemotePath(), XrdOucProg::Run(), S_IRGRP, S_IROTH, S_IRUSR, S_IWUSR, XrdSysError::Say(), XrdFrm::Say, snprintf, stat(), strlcpy(), XrdFrmTranArg::theCmd, XrdFrmTranArg::theDst, XrdFrmTranArg::theINS, XrdFrmTranArg::theSrc, XrdFrmConfig::Cmd::theVec, XrdFrmTranArg::theVec, XrdFrm::Trace, TRACE_Debug, XrdOss::Unlink(), XrdOucTrace::What, XrdFrmConfig::xfrCmd, XRDOSS_mkpath, and XROOTD_MON_MAPSTAG.
const char * XrdFrmTransfer::FetchDone |
( |
char * |
lfnpath, |
|
|
int & |
rc, |
|
|
time_t |
lktime |
|
) |
| [private] |
References XrdOucXAttr< T >::Attr, XrdFrm::Config, XrdFrmXAttrCpy::cpyTime, XrdSysError::Emsg(), XrdFrmConfig::ossFS, XrdOss::Rename(), XrdFrmConfig::runNew, XrdFrmConfig::runOld, XrdFrm::Say, XrdOucXAttr< T >::Set(), stat(), and unlink().
const char * XrdFrmTransfer::ffCheck |
( |
| ) |
[private] |
void XrdFrmTransfer::ffMake |
( |
int |
nofile = 0 | ) |
[private] |
int XrdFrmTransfer::Init |
( |
| ) |
[static] |
References XrdFrm::CID, XrdFrm::Config, XrdSysError::Emsg(), XrdFrmXfrQueue::Init(), XrdFrmCID::Init(), InitXfer(), XrdFrmConfig::QPath, XrdSysThread::Run(), XrdFrm::Say, XrdFrmConfig::xfrMax, and XRDSYSTHREAD_BIND.
Referenced by XrdFrmXfrDaemon::Init().
References XrdFrm::CID, CMS_CID, XrdFrm::Config, XrdSysError::Emsg(), XrdFrmCID::Get(), Info, XrdFrmRequest::makeRW, XrdOucMsubs::maxElem, XrdOucEnv::Put(), XrdFrm::Say, XrdOucProg::Setup(), XrdOucMsubs::Subs(), XrdFrmConfig::the_N2N, XrdFrmTranArg::theCmd, XrdFrmTranArg::theDst, XrdFrmTranArg::theEnv, XrdFrmTranArg::theINS, XrdFrmTranArg::theMDP, XrdFrmTranArg::theSrc, XrdFrmTranArg::theVec, and XRD_INS.
void XrdFrmTransfer::Start |
( |
| ) |
|
const char * XrdFrmTransfer::Throw |
( |
| ) |
[private] |
References XrdFrmConfig::cmdMDP, XrdFrmConfig::cmdStats, XrdFrm::Config, XrdSysError::Emsg(), XrdFrmRequest::Migrate, XrdFrmConfig::Cmd::Opts, XrdFrmRequest::Purge, XrdFrmConfig::RemotePath(), XrdOucProg::Run(), XrdSysError::Say(), XrdFrm::Say, stat(), XrdFrmTranArg::theCmd, XrdFrmTranArg::theDst, XrdFrmTranArg::theINS, XrdFrmTranArg::theMDP, XrdFrmTranArg::theSrc, XrdFrmConfig::Cmd::theVec, XrdFrmTranArg::theVec, XrdFrm::Trace, TRACE_Debug, XrdOucTrace::What, and XrdFrmConfig::xfrCmd.
void XrdFrmTransfer::Throwaway |
( |
| ) |
[private] |
void XrdFrmTransfer::ThrowDone |
( |
XrdFrmTranChk * |
cP, |
|
|
time_t |
endTime |
|
) |
| [private] |
References XrdOucXAttr< T >::Attr, XrdFrm::Config, XrdFrmXAttrCpy::cpyTime, XrdSysError::Emsg(), XrdFrmTranChk::lkfd, XrdFrmTranChk::lkfx, XrdFrmConfig::runNew, XrdFrm::Say, XrdOucXAttr< T >::Set(), stat(), and unlink().
const char * XrdFrmTransfer::ThrowOK |
( |
XrdFrmTranChk * |
cP | ) |
[private] |
References XrdOucXAttr< T >::Attr, close, XrdFrm::Config, XrdFrmXAttrCpy::cpyTime, F_SETFD, fcntl(), FD_CLOEXEC, XrdOucXAttr< T >::Get(), XrdFrmTranChk::lkfd, XrdFrmTranChk::lkfx, XrdOucSxeq::noWait, open(), XrdFrmRequest::Purge, XrdFrmConfig::runNew, XrdFrmConfig::runOld, XrdOucSxeq::Serialize(), XrdFrmTranChk::Stat, and stat().
int XrdFrmTransfer::TrackDC |
( |
char * |
Rfn | ) |
[private] |
int XrdFrmTransfer::TrackDC |
( |
char * |
Lfn, |
|
|
char * |
Mdp, |
|
|
char * |
Rfn |
|
) |
| [private] |
Member Data Documentation
The documentation for this class was generated from the following files: