XrdFrmTransfer Class Reference

#include <XrdFrmTransfer.hh>

Collaboration diagram for XrdFrmTransfer:

List of all members.

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 EPNAME, stat(), XrdCms::Config, DEBUG, XrdCmsConfig::ossFS, XrdOss::Unlink(), and XRDOSS_isPFN.

Referenced by XrdFrmMigrate::Eligible().

const char * XrdFrmTransfer::Fetch

(

)

[private]

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

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

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

const char * XrdFrmTransfer::ffCheck

(

)

[private]

void XrdFrmTransfer::ffMake

(

int

nofile = 0

)

[private]

References S_IRUSR, S_IWUSR, S_IRGRP, S_IROTH, open(), and close.

int XrdFrmTransfer::Init

(

)

[static]

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

Referenced by XrdFrmXfrDaemon::Init().

int XrdFrmTransfer::SetupCmd

(

XrdFrmTranArg *

aP

)

[private]

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

void XrdFrmTransfer::Start

(

)

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

Referenced by InitXfer().

const char * XrdFrmTransfer::Throw

(

)

[private]

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

void XrdFrmTransfer::Throwaway

(

)

[private]

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

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

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

const char * XrdFrmTransfer::ThrowOK

(

XrdFrmTranChk *

cP

)

[private]

References close, stat(), open(), fcntl(), F_SETFD, FD_CLOEXEC, XrdOucSxeq::Serialize(), XrdOucSxeq::noWait, XrdCms::Config, XrdOucXAttr::Attr, XrdOucXAttr::Get(), XrdFrmTranChk::Stat, XrdFrcRequest::Purge, XrdFrmTranChk::lkfd, and XrdFrmTranChk::lkfx.

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

References index(), and rindex.

int XrdFrmTransfer::TrackDC

(

char *

Rfn

)

[private]

References rindex, and Hash_data_is_key.

---

Member Data Documentation

char XrdFrmTransfer::cmdBuff[4096] [private]

XrdSysMutex XrdFrmTransfer::pMutex [static, private]

XrdOucHash< char > XrdFrmTransfer::pTab [static, private]

XrdOucProg* XrdFrmTransfer::xfrCmd[4] [private]

XrdFrmXfrJob* XrdFrmTransfer::xfrP [private]

---

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

• XrdFrmTransfer.hh
• XrdFrmTransfer.cc