XrdFrmTransfer Class Reference

#include <XrdFrmTransfer.hh>

Collaboration diagram for XrdFrmTransfer:

Public Member Functions
void	Start ()
	XrdFrmTransfer ()
	~XrdFrmTransfer ()

Static Public Member Functions
static const char *	checkFF (const char *Path)
static int	Init ()

Private Member Functions
const char *	Fetch ()
const char *	FetchDone (char *lfnpath, struct stat &Stat, int &rc)
const char *	ffCheck ()
void	ffMake (int nofile=0)
int	SetupCmd (XrdFrmTranArg *aP)
int	TrackDC (char *Lfn, char *Mdp, char *Rfn)
int	TrackDC (char *Rfn)
const char *	Throw ()
void	Throwaway ()
void	ThrowDone (XrdFrmTranChk *cP, time_t endTime)
const char *	ThrowOK (XrdFrmTranChk *cP)

Private Attributes
XrdOucProg *	xfrCmd [4]
XrdFrmXfrJob *	xfrP
char	cmdBuff [4096]

Static Private Attributes
static XrdSysMutex	pMutex
static XrdOucHash< char >	pTab

Constructor & Destructor Documentation

XrdFrmTransfer::XrdFrmTransfer

(

)

References XrdCms::Config, and XrdFrc::Say.

XrdFrmTransfer::~XrdFrmTransfer ( )

inline

Member Function Documentation

const char * XrdFrmTransfer::checkFF ( const char *  Path )

static

References XrdCms::Config, DEBUG, EPNAME, XrdCmsConfig::ossFS, stat(), XrdOss::Unlink(), and XRDOSS_isPFN.

Referenced by XrdFrmMigrate::Eligible().

const char * XrdFrmTransfer::Fetch ( )

private

References XrdCms::Config, XrdOss::Create(), DEBUG, XrdSysError::Emsg(), EPNAME, XrdFrmMonitor::Map(), XrdFrmMonitor::monSTAGE, XrdCmsConfig::ossFS, XrdOucProg::Run(), XrdFrc::Say, XrdSysError::Say(), stat(), strlcpy(), XrdFrmTranArg::theCmd, XrdFrmTranArg::theDst, XrdFrmTranArg::theINS, XrdFrmTranArg::theSrc, XrdFrmTranArg::theVec, XrdFrc::Trace, TRACE_Debug, XrdOss::Unlink(), XrdOucTrace::What, XRDOSS_mkpath, and XROOTD_MON_MAPSTAG.

const char * XrdFrmTransfer::FetchDone ( char *  lfnpath, struct stat &  Stat, int &  rc  )

private

References XrdFrmCns::Add(), XrdOucXAttr< T >::Attr, XrdCms::Config, XrdFrcXAttrCpy::cpyTime, XrdSysError::Emsg(), XrdCmsConfig::ossFS, XrdOss::Rename(), XrdFrc::Say, XrdOucXAttr< T >::Set(), stat(), and unlink().

const char * XrdFrmTransfer::ffCheck ( )

private

void XrdFrmTransfer::ffMake ( int  nofile = 0 )

private

References close(), and open().

int XrdFrmTransfer::Init ( )

static

References XrdFrc::CID, XrdCms::Config, XrdSysError::Emsg(), XrdFrcCID::Init(), XrdFrmXfrQueue::Init(), InitXfer(), XrdSysThread::Run(), XrdFrc::Say, and XRDSYSTHREAD_BIND.

Referenced by XrdFrmXfrDaemon::Init().

int XrdFrmTransfer::SetupCmd ( XrdFrmTranArg *  aP )

private

References XrdFrc::CID, CMS_CID, XrdCms::Config, XrdSysError::Emsg(), XrdFrcCID::Get(), Info, XrdFrcRequest::makeRW, XrdOucMsubs::maxElem, XrdCmsConfig::myName, XrdOucEnv::Put(), XrdFrc::Say, SEC_HOST, XrdOucProg::Setup(), XrdOucMsubs::Subs(), XrdFrmTranArg::theCmd, XrdFrmTranArg::theDst, XrdFrmTranArg::theEnv, XrdFrmTranArg::theINS, XrdFrmTranArg::theMDP, XrdFrmTranArg::theSrc, XrdFrmTranArg::theVec, and XRD_INS.

void XrdFrmTransfer::Start

(

)

References XrdCms::Config, DEBUG, XrdFrmXfrQueue::Done(), EPNAME, XrdFrmXfrQueue::Get(), XrdFrcRequest::outQ, XrdFrc::Say, and XrdSysError::Say().

Referenced by InitXfer().

const char * XrdFrmTransfer::Throw ( )

private

References XrdCms::Config, XrdSysError::Emsg(), XrdFrmMonitor::Map(), XrdFrcRequest::Migrate, XrdFrmMonitor::monMIGR, XrdFrcRequest::Purge, XrdOucProg::Run(), XrdFrc::Say, XrdSysError::Say(), stat(), XrdFrmTranArg::theCmd, XrdFrmTranArg::theDst, XrdFrmTranArg::theINS, XrdFrmTranArg::theMDP, XrdFrmTranArg::theSrc, XrdFrmTranArg::theVec, XrdFrc::Trace, TRACE_Debug, XrdOucTrace::What, and XROOTD_MON_MAPMIGR.

void XrdFrmTransfer::Throwaway ( )

private

References XrdCms::Config, DEBUG, EPNAME, XrdCmsConfig::ossFS, XrdFrmCns::Rm(), XrdOss::Unlink(), XRDOSS_isMIG, and XRDOSS_isPFN.

void XrdFrmTransfer::ThrowDone ( XrdFrmTranChk *  cP, time_t  endTime  )

private

References XrdOucXAttr< T >::Attr, XrdCms::Config, XrdFrcXAttrCpy::cpyTime, XrdSysError::Emsg(), XrdFrmTranChk::lkfd, XrdFrmTranChk::lkfx, XrdFrc::Say, XrdOucXAttr< T >::Set(), stat(), and unlink().

const char * XrdFrmTransfer::ThrowOK ( XrdFrmTranChk *  cP )

private

References XrdOucXAttr< T >::Attr, close(), XrdCms::Config, XrdFrcXAttrCpy::cpyTime, fcntl(), XrdOucXAttr< T >::Get(), XrdFrmTranChk::lkfd, XrdFrmTranChk::lkfx, XrdOucSxeq::noWait, open(), XrdFrcRequest::Purge, XrdOucSxeq::Serialize(), XrdFrmTranChk::Stat, and stat().

int XrdFrmTransfer::TrackDC ( char *  Lfn, char *  Mdp, char *  Rfn  )

private

int XrdFrmTransfer::TrackDC ( char *  Rfn )

private

References Hash_data_is_key.

Member Data Documentation

char XrdFrmTransfer::cmdBuff[4096]

private

XrdSysMutex XrdFrmTransfer::pMutex

staticprivate

XrdOucHash< char > XrdFrmTransfer::pTab

staticprivate

XrdOucProg* XrdFrmTransfer::xfrCmd[4]

private

XrdFrmXfrJob* XrdFrmTransfer::xfrP

private

---

The documentation for this class was generated from the following files:

• XrdFrmTransfer.hh
• XrdFrmTransfer.cc