XrdFrcReqFile Class Reference

#include <XrdFrcReqFile.hh>

Collaboration diagram for XrdFrcReqFile:

List of all members.

Classes
struct	FileHdr
struct	recEnt
class	rqMonitor
Public Member Functions
void	Add (XrdFrcRequest *rP)
void	Can (XrdFrcRequest *rP)
void	Del (XrdFrcRequest *rP)
int	Get (XrdFrcRequest *rP)
int	Init ()
char *	List (char *Buff, int bsz, int &Offs, XrdFrcRequest::Item *ITList=0, int ITNum=0)
void	ListL (XrdFrcRequest &tmpReq, char *Buff, int bsz, XrdFrcRequest::Item *ITList, int ITNum)
	XrdFrcReqFile (const char *fn, int aVal)
	~XrdFrcReqFile ()
Private Types
enum	LockType { lkNone, lkShare, lkExcl, lkInit }
Private Member Functions
void	FailAdd (char *lfn, int unlk=1)
void	FailCan (char *rid, int unlk=1)
void	FailDel (char *lfn, int unlk=1)
int	FailIni (const char *lfn)
int	FileLock (LockType ltype=lkExcl)
int	reqRead (void *Buff, int Offs)
int	reqWrite (void *Buff, int Offs, int updthdr=1)
int	ReWrite (recEnt *rP)
Private Attributes
struct XrdFrcReqFile::FileHdr	HdrData
char *	lokFN
int	lokFD
int	reqFD
char *	reqFN
int	isAgent
Static Private Attributes
static const int	ReqSize = sizeof(XrdFrcRequest)

---

Member Enumeration Documentation

enum XrdFrcReqFile::LockType [private]

Enumerator:

lkNone
lkShare
lkExcl
lkInit

---

Constructor & Destructor Documentation

XrdFrcReqFile::XrdFrcReqFile	(	const char *	fn,
		int	aVal
	)

XrdFrcReqFile::~XrdFrcReqFile

(

)

[inline]

---

Member Function Documentation

void XrdFrcReqFile::Add

(

XrdFrcRequest *

rP

)

References XrdFrcRequest::LFN, stat(), fstat(), XrdFrc::Say, XrdSysError::Emsg(), XrdFrcRequest::Options, XrdFrcRequest::Register, XrdFrcRequest::Next, and XrdFrcRequest::This.

Referenced by XrdFrcReqAgent::Start().

void XrdFrcReqFile::Can

(

XrdFrcRequest *

rP

)

References stat(), fstat(), XrdFrcRequest::ID, fsync(), XrdFrc::Say, and XrdSysError::Emsg().

void XrdFrcReqFile::Del

(

XrdFrcRequest *

rP

)

References XrdFrcRequest::LFN, XrdFrcRequest::Next, and XrdFrcRequest::This.

Referenced by XrdFrmXfrQueue::Add(), and XrdFrmXfrQueue::Done().

void XrdFrcReqFile::FailAdd	(	char *	lfn,
		int	unlk = 1
	)		[private]

References XrdFrc::Say, and XrdSysError::Emsg().

void XrdFrcReqFile::FailCan	(	char *	rid,
		int	unlk = 1
	)		[private]

References XrdFrc::Say, and XrdSysError::Emsg().

void XrdFrcReqFile::FailDel	(	char *	lfn,
		int	unlk = 1
	)		[private]

References XrdFrc::Say, and XrdSysError::Emsg().

int XrdFrcReqFile::FailIni

(

const char *

lfn

)

[private]

References XrdFrc::Say, and XrdSysError::Emsg().

int XrdFrcReqFile::FileLock

(

LockType

ltype = lkExcl

)

[private]

References FLOCK_t, close, fcntl(), XrdFrc::Say, XrdSysError::Emsg(), open(), F_SETFD, FD_CLOEXEC, and pread().

int XrdFrcReqFile::Get

(

XrdFrcRequest *

rP

)

int XrdFrcReqFile::Init

(

)

References EPNAME, Mode, S_IRUSR, S_IWUSR, S_IRGRP, S_IROTH, stat(), open(), XrdFrc::Say, XrdSysError::Emsg(), fcntl(), F_SETFD, FD_CLOEXEC, fstat(), XrdFrcRequest::Register, DEBUG, XrdFrc::CID, and XrdFrcCID::Ref().

char * XrdFrcReqFile::List	(	char *	Buff,
		int	bsz,
		int &	Offs,
		XrdFrcRequest::Item *	ITList = 0,
		int	ITNum = 0
	)

References pread(), XrdFrcRequest::LFN, XrdFrcRequest::addTOD, XrdFrcRequest::Opaque, XrdFrcRequest::Options, XrdFrcRequest::Register, strlcpy(), XrdFrc::Say, and XrdSysError::Emsg().

Referenced by XrdFrcReqAgent::NextLFN().

void XrdFrcReqFile::ListL	(	XrdFrcRequest &	tmpReq,
		char *	Buff,
		int	bsz,
		XrdFrcRequest::Item *	ITList,
		int	ITNum
	)

References XrdFrcRequest::LFO, XrdFrcRequest::LFN, strlcpy(), XrdFrcRequest::Opaque, XrdFrcRequest::Options, XrdFrcRequest::msgFail, XrdFrcRequest::msgSucc, XrdFrcRequest::Notify, XrdFrcRequest::OPc, XrdFrcRequest::Prty, XrdFrcRequest::addTOD, XrdFrcRequest::getQWT, XrdFrcRequest::ID, and XrdFrcRequest::User.

int XrdFrcReqFile::reqRead	(	void *	Buff,
		int	Offs
	)		[private]

References pread(), XrdFrc::Say, and XrdSysError::Emsg().

int XrdFrcReqFile::reqWrite	(	void *	Buff,
		int	Offs,
		int	updthdr = 1
	)		[private]

References pwrite(), fsync(), XrdFrc::Say, and XrdSysError::Emsg().

int XrdFrcReqFile::ReWrite

(

XrdFrcReqFile::recEnt *

rP

)

[private]

References Mode, S_IRUSR, S_IWUSR, S_IRGRP, S_IROTH, open(), XrdFrc::Say, XrdSysError::Emsg(), fcntl(), F_SETFD, FD_CLOEXEC, XrdFrcReqFile::recEnt::reqData, XrdFrcRequest::This, XrdFrcRequest::Next, XrdFrcReqFile::recEnt::Next, ftruncate(), rename(), and close.

---

Member Data Documentation

struct XrdFrcReqFile::FileHdr XrdFrcReqFile::HdrData [private]

int XrdFrcReqFile::isAgent [private]

int XrdFrcReqFile::lokFD [private]

char* XrdFrcReqFile::lokFN [private]

int XrdFrcReqFile::reqFD [private]

char* XrdFrcReqFile::reqFN [private]

const int XrdFrcReqFile::ReqSize = sizeof(XrdFrcRequest) [static, private]

---

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

• XrdFrcReqFile.hh
• XrdFrcReqFile.cc