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 XrdSysError::Emsg(), fstat(), XrdFrcRequest::LFN, XrdFrcRequest::Next, XrdFrcRequest::Options, XrdFrcRequest::Register, XrdFrc::Say, stat(), and XrdFrcRequest::This.

Referenced by XrdFrcReqAgent::Start().

void XrdFrcReqFile::Can

(

XrdFrcRequest *

rP

)

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

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 XrdSysError::Emsg(), and XrdFrc::Say.

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

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

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

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

int XrdFrcReqFile::FailIni

(

const char *

lfn

)

[private]

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

int XrdFrcReqFile::FileLock

(

LockType

ltype = lkExcl

)

[private]

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

int XrdFrcReqFile::Get

(

XrdFrcRequest *

rP

)

int XrdFrcReqFile::Init

(

)

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

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

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

Referenced by XrdFrcReqAgent::NextLFN().

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

References XrdFrcRequest::addTOD, XrdFrcRequest::getLFN, XrdFrcRequest::getLFNCGI, XrdFrcRequest::getMODE, XrdFrcRequest::getNOTE, XrdFrcRequest::getOBJ, XrdFrcRequest::getOBJCGI, XrdFrcRequest::getOP, XrdFrcRequest::getPRTY, XrdFrcRequest::getQWT, XrdFrcRequest::getRID, XrdFrcRequest::getTOD, XrdFrcRequest::getUSER, XrdFrcRequest::ID, XrdFrcRequest::LFN, XrdFrcRequest::LFO, XrdFrcRequest::makeRW, XrdFrcRequest::msgFail, XrdFrcRequest::msgSucc, XrdFrcRequest::Notify, XrdFrcRequest::Opaque, XrdFrcRequest::OPc, XrdFrcRequest::Options, XrdFrcRequest::Prty, strlcpy(), and XrdFrcRequest::User.

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

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

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

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

int XrdFrcReqFile::ReWrite

(

XrdFrcReqFile::recEnt *

rP

)

[private]

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

---

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