XrdFrmReqFile Class Reference

#include <XrdFrmReqFile.hh>

Collaboration diagram for XrdFrmReqFile:

[legend]

List of all members.

Classes
struct	FileHdr
struct	recEnt
class	rqMonitor
Public Member Functions
void	Add (XrdFrmRequest *rP)
void	Can (XrdFrmRequest *rP)
void	Del (XrdFrmRequest *rP)
int	Get (XrdFrmRequest *rP)
int	Init ()
char *	List (char *Buff, int bsz, int &Offs, XrdFrmRequest::Item *ITList=0, int ITNum=0)
void	ListL (XrdFrmRequest &tmpReq, char *Buff, int bsz, XrdFrmRequest::Item *ITList, int ITNum)
	XrdFrmReqFile (const char *fn, int aVal)
	~XrdFrmReqFile ()
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 XrdFrmReqFile::FileHdr	HdrData
char *	lokFN
int	lokFD
int	reqFD
char *	reqFN
int	isAgent
Static Private Attributes
static const int	ReqSize = sizeof(XrdFrmRequest)

---

Member Enumeration Documentation

enum XrdFrmReqFile::LockType [private]

Enumerator:

lkNone
lkShare
lkExcl
lkInit

---

Constructor & Destructor Documentation

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

References HdrData, isAgent, lokFD, lokFN, reqFD, and reqFN.

XrdFrmReqFile::~XrdFrmReqFile

(

)

[inline]

---

Member Function Documentation

void XrdFrmReqFile::Add

(

XrdFrmRequest *

rP

)

References FailAdd(), FileLock(), XrdFrmReqFile::FileHdr::First, XrdFrmReqFile::FileHdr::Free, fstat, HdrData, isAgent, XrdFrmReqFile::FileHdr::Last, XrdFrmRequest::LFN, lkNone, XrdFrmRequest::Next, XrdFrmRequest::Options, XrdFrmRequest::Register, reqFD, reqFN, reqRead(), reqWrite(), Say, stat, and XrdFrmRequest::This.

Referenced by XrdFrmReqAgent::Start().

void XrdFrmReqFile::Can

(

XrdFrmRequest *

rP

)

References FailCan(), FileLock(), fstat, fsync, XrdFrmRequest::ID, isAgent, lkNone, reqFD, reqRead(), ReqSize, reqWrite(), Say, and stat.

void XrdFrmReqFile::Del

(

XrdFrmRequest *

rP

)

References FailDel(), FileLock(), XrdFrmReqFile::FileHdr::Free, HdrData, isAgent, XrdFrmRequest::LFN, lkNone, XrdFrmRequest::Next, reqWrite(), and XrdFrmRequest::This.

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

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

References FileLock(), lkNone, and Say.

Referenced by Add().

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

References FileLock(), lkNone, and Say.

Referenced by Can().

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

References FileLock(), lkNone, and Say.

Referenced by Del().

int XrdFrmReqFile::FailIni

(

const char *

lfn

)

[private]

References FileLock(), lkNone, reqFN, and Say.

Referenced by Init().

int XrdFrmReqFile::FileLock

(

LockType

ltype = lkExcl

)

[private]

References close, F_SETFD, fcntl(), FD_CLOEXEC, FLOCK_t, HdrData, isAgent, lkExcl, lkNone, lkShare, lokFD, lokFN, open, pread, reqFD, reqFN, and Say.

Referenced by Add(), Can(), Del(), FailAdd(), FailCan(), FailDel(), FailIni(), Get(), Init(), List(), and ReWrite().

int XrdFrmReqFile::Get

(

XrdFrmRequest *

rP

)

References FileLock(), XrdFrmReqFile::FileHdr::First, XrdFrmReqFile::FileHdr::Free, HdrData, lkNone, reqRead(), and reqWrite().

int XrdFrmReqFile::Init

(

)

References XrdFrm::CID, DEBUG, EPNAME, F_SETFD, FailIni(), fcntl(), FD_CLOEXEC, FileLock(), XrdFrmReqFile::FileHdr::Free, fstat, HdrData, isAgent, lkInit, lkNone, lokFD, lokFN, Mode, open, XrdFrmCID::Ref(), XrdFrmRequest::Register, reqFD, reqFN, reqRead(), ReqSize, reqWrite(), ReWrite(), S_IRGRP, S_IROTH, S_IRUSR, S_IWUSR, Say, and stat.

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

References XrdFrmRequest::addTOD, FileLock(), isAgent, XrdFrmRequest::LFN, ListL(), lkNone, lkShare, XrdFrmRequest::Opaque, XrdFrmRequest::Options, pread, XrdFrmRequest::Register, reqFD, reqFN, ReqSize, Say, and strlcpy().

Referenced by XrdFrmReqAgent::NextLFN().

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

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

Referenced by List().

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

References pread, reqFD, reqFN, ReqSize, and Say.

Referenced by Add(), Can(), Get(), and Init().

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

References fsync, HdrData, pwrite, reqFD, reqFN, ReqSize, and Say.

Referenced by Add(), Can(), Del(), Get(), Init(), and ReWrite().

int XrdFrmReqFile::ReWrite

(

XrdFrmReqFile::recEnt *

rP

)

[private]

References close, F_SETFD, fcntl(), FD_CLOEXEC, FileLock(), XrdFrmReqFile::FileHdr::First, XrdFrmReqFile::FileHdr::Free, ftruncate, HdrData, XrdFrmReqFile::FileHdr::Last, lkNone, Mode, XrdFrmReqFile::recEnt::Next, XrdFrmRequest::Next, open, rename, XrdFrmReqFile::recEnt::reqData, reqFD, reqFN, ReqSize, reqWrite(), S_IRGRP, S_IROTH, S_IRUSR, S_IWUSR, Say, and XrdFrmRequest::This.

Referenced by Init().

---

Member Data Documentation

struct XrdFrmReqFile::FileHdr XrdFrmReqFile::HdrData [private]

Referenced by Add(), Del(), FileLock(), Get(), Init(), reqWrite(), ReWrite(), and XrdFrmReqFile().

int XrdFrmReqFile::isAgent [private]

Referenced by Add(), Can(), Del(), FileLock(), Init(), List(), and XrdFrmReqFile().

int XrdFrmReqFile::lokFD [private]

Referenced by FileLock(), Init(), and XrdFrmReqFile().

char* XrdFrmReqFile::lokFN [private]

Referenced by FileLock(), Init(), and XrdFrmReqFile().

int XrdFrmReqFile::reqFD [private]

Referenced by Add(), Can(), FileLock(), Init(), List(), reqRead(), reqWrite(), ReWrite(), and XrdFrmReqFile().

char* XrdFrmReqFile::reqFN [private]

Referenced by Add(), FailIni(), FileLock(), Init(), List(), reqRead(), reqWrite(), ReWrite(), and XrdFrmReqFile().

const int XrdFrmReqFile::ReqSize = sizeof(XrdFrmRequest) [static, private]

Referenced by Can(), Init(), List(), reqRead(), reqWrite(), and ReWrite().

---

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

• XrdFrmReqFile.hh
• XrdFrmReqFile.cc