XrdFrmPstgXfr Class Reference

#include <XrdFrmPstgXfr.hh>

Collaboration diagram for XrdFrmPstgXfr:

List of all members.

Public Member Functions
void	Start ()
	XrdFrmPstgXfr ()
	~XrdFrmPstgXfr ()
Static Public Member Functions
static int	Init ()
static int	Queue (XrdFrmPstgReq::Request *rP, int slot)
Private Member Functions
const char *	Stage (XrdFrmPstgXrq *xP, int &retcode)
int	StageCmd (XrdFrmPstgXrq *xP, XrdOucEnv *theEnv)
const char *	StageOpt (XrdFrmPstgXrq *xP)
Static Private Member Functions
static int	Notify (XrdFrmPstgReq::Request *rP, int rc, const char *msg=0)
static void	Send2File (char *Dest, char *Msg, int Mln)
static void	Send2UDP (char *Dest, char *Msg, int Mln)
Private Attributes
XrdOucProg *	xfrCmd
char	cmdBuff [4096]
Static Private Attributes
static XrdSysMutex	hMutex
static XrdOucHash< XrdFrmPstgXrq >	hTab
static XrdSysMutex	qMutex
static XrdSysSemaphore	qReady
static XrdSysSemaphore	qAvail
static struct XrdFrmPstgXrq *	First = 0
static struct XrdFrmPstgXrq *	Last = 0
static struct XrdFrmPstgXrq *	Free = 0

---

Constructor & Destructor Documentation

XrdFrmPstgXfr::XrdFrmPstgXfr

(

)

References Say, and xfrCmd.

XrdFrmPstgXfr::~XrdFrmPstgXfr

(

)

[inline]

---

Member Function Documentation

int XrdFrmPstgXfr::Init

(

)

[static]

References XrdCms::Config, Free, XrdFrmPstgXrq::Next, XrdSysSemaphore::Post(), and qAvail.

Referenced by mainConfig().

int XrdFrmPstgXfr::Notify	(	XrdFrmPstgReq::Request *	rP,
		int	rc,
		const char *	msg = 0
	)			[static, private]

References XrdFrmPstgReq::Request::ID, index(), XrdFrmPstgReq::Request::LFN, XrdFrmPstgReq::msgFail, XrdFrmPstgReq::msgSucc, XrdFrmPstgReq::Request::Notify, XrdFrmPstgReq::Request::Options, Say, Send2File(), and Send2UDP().

Referenced by Queue(), and Start().

int XrdFrmPstgXfr::Queue	(	XrdFrmPstgReq::Request *	rP,
		int	slot
	)			[static]

References XrdOucHash< T >::Add(), XrdCms::Config, DEBUG, XrdFrmPstgReq::Del(), EPNAME, XrdOucHash< T >::Find(), First, Free, Hash_keep, hMutex, hTab, Last, XrdFrmPstgReq::Request::LFN, XrdSysMutex::Lock(), XrdFrmPstgReq::msgFail, XrdFrmPstgReq::msgSucc, XrdFrmPstgXrq::Next, XrdFrmPstgXrq::NoteList, Notify(), XrdFrmPstgReq::Request::Notify, XrdFrmPstgReq::Request::Options, XrdFrmPstgXrq::PFN, XrdFrmPstgXrq::pfnEnd, XrdFrmPstgXrq::PFNSZ, XrdSysSemaphore::Post(), qAvail, qMutex, qReady, XrdFrmPstgXrq::reqData, XrdFrm::rQueue, XrdFrmPstgXrq::Slot, stat(), XrdSysMutex::UnLock(), and XrdSysSemaphore::Wait().

Referenced by XrdFrmPstg::Server_Stage().

void XrdFrmPstgXfr::Send2File	(	char *	Dest,
		char *	Msg,
		int	Mln
	)			[static, private]

References close, DEBUG, EPNAME, open(), Say, and write().

Referenced by Notify().

void XrdFrmPstgXfr::Send2UDP	(	char *	Dest,
		char *	Msg,
		int	Mln
	)			[static, private]

References DEBUG, EPNAME, Say, and XrdNetMsg::Send().

Referenced by Notify().

const char * XrdFrmPstgXfr::Stage	(	XrdFrmPstgXrq *	xP,
		int &	retcode
	)			[private]

References XrdFrmPstgReq::Request::addTOD, close, XrdCms::Config, XrdOss::Create(), DEBUG, EPNAME, XrdFrmPstgReq::Request::LFN, XrdXrootdMonitor::Map(), XrdFrmPstgReq::Request::Opaque, open(), XrdCmsConfig::ossFS, XrdFrmPstgXrq::PFN, XrdFrmPstgXrq::pfnEnd, XrdOss::Rename(), XrdFrmPstgXrq::reqData, XrdOucProg::Run(), S_IRGRP, S_IRUSR, S_IWUSR, Say, XrdSysTimer::Snooze(), snprintf, StageCmd(), stat(), strlcpy(), XrdOss::Unlink(), unlink(), XrdFrmPstgReq::Request::User, xfrCmd, XRDOSS_mkpath, and XROOTD_MON_MAPSTAG.

Referenced by Start().

int XrdFrmPstgXfr::StageCmd	(	XrdFrmPstgXrq *	xP,
		XrdOucEnv *	theEnv
	)			[private]

References cmdBuff, XrdCms::Config, XrdFrmPstgReq::Request::ID, Info, XrdFrmPstgReq::Request::LFN, XrdOucMsubs::maxElem, XrdFrmPstgReq::Request::Options, XrdFrmPstgXrq::PFN, XrdFrmPstgReq::Request::Prty, XrdFrmPstgXrq::reqData, Say, XrdOucProg::Setup(), StageOpt(), XrdFrmPstgReq::stgRW, XrdFrmPstgReq::Request::User, and xfrCmd.

Referenced by Stage().

const char * XrdFrmPstgXfr::StageOpt

(

XrdFrmPstgXrq *

xP

)

[private]

References XrdFrmPstgReq::msgFail, XrdFrmPstgReq::msgSucc, XrdFrmPstgReq::Request::Options, and XrdFrmPstgXrq::reqData.

Referenced by StageCmd().

void XrdFrmPstgXfr::Start

(

)

References DEBUG, XrdFrmPstgReq::Del(), XrdOucHash< T >::Del(), EPNAME, First, Free, hMutex, hTab, Last, XrdFrmPstgReq::Request::LFN, XrdSysMutex::Lock(), XrdOucTList::next, XrdFrmPstgXrq::Next, XrdFrmPstgXrq::NoteList, XrdFrmPstgReq::Request::Notify, Notify(), XrdFrmPstgXrq::PFN, XrdSysSemaphore::Post(), qAvail, qMutex, qReady, XrdFrmPstgXrq::reqData, XrdFrm::rQueue, XrdFrmPstgXrq::Slot, Stage(), XrdOucTList::text, XrdSysMutex::UnLock(), XrdFrmPstgReq::Request::User, and XrdSysSemaphore::Wait().

Referenced by mainXfer().

---

Member Data Documentation

char XrdFrmPstgXfr::cmdBuff[4096] [private]

Referenced by StageCmd().

XrdFrmPstgXrq * XrdFrmPstgXfr::First = 0 [static, private]

Referenced by Queue(), and Start().

XrdFrmPstgXrq * XrdFrmPstgXfr::Free = 0 [static, private]

Referenced by Init(), Queue(), and Start().

XrdSysMutex XrdFrmPstgXfr::hMutex [static, private]

Referenced by Queue(), and Start().

XrdOucHash< XrdFrmPstgXrq > XrdFrmPstgXfr::hTab [static, private]

Referenced by Queue(), and Start().

XrdFrmPstgXrq * XrdFrmPstgXfr::Last = 0 [static, private]

Referenced by Queue(), and Start().

XrdSysSemaphore XrdFrmPstgXfr::qAvail [static, private]

Referenced by Init(), Queue(), and Start().

XrdSysMutex XrdFrmPstgXfr::qMutex [static, private]

Referenced by Queue(), and Start().

XrdSysSemaphore XrdFrmPstgXfr::qReady [static, private]

Referenced by Queue(), and Start().

XrdOucProg* XrdFrmPstgXfr::xfrCmd [private]

Referenced by Stage(), StageCmd(), and XrdFrmPstgXfr().

---

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

• XrdFrmPstgXfr.hh
• XrdFrmPstgXfr.cc