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 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(), XrdCmsConfig::ossFS, XrdOucProg::Run(), S_IRGRP, S_IROTH, S_IRUSR, S_IWUSR, XrdFrc::Say, XrdSysError::Say(), snprintf, 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, open(), S_IRGRP, S_IROTH, S_IRUSR, and S_IWUSR.

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(), XrdFrcRequest::Migrate, 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, and XrdOucTrace::What.

void XrdFrmTransfer::Throwaway

(

)

[private]

References XrdCms::Config, DEBUG, EPNAME, XrdCmsConfig::ossFS, 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, F_SETFD, fcntl(), FD_CLOEXEC, 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]

References index(), and rindex.

int XrdFrmTransfer::TrackDC

(

char *

Rfn

)

[private]

References Hash_data_is_key, and rindex.

---

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