XrdFrcReqFile Class Reference

#include <XrdFrcReqFile.hh>

Collaboration diagram for XrdFrcReqFile:

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
XrdSysMutex	flMutex
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, XrdFrcRequest::LFN, 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(), fcntl(), FLOCK_t, open(), pread(), and XrdFrc::Say.

int XrdFrcReqFile::Get

(

XrdFrcRequest *

rP

)

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

int XrdFrcReqFile::Init

(

)

References XrdFrcRequest::addTOD, XrdFrc::CID, DEBUG, XrdSysError::Emsg(), EPNAME, fcntl(), fstat(), XrdFrcRequest::LFN, Mode, XrdFrcRequest::Opaque, open(), XrdFrcRequest::Options, XrdFrcCID::Ref(), XrdFrcRequest::Register, 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(), fcntl(), ftruncate(), Mode, XrdFrcRequest::Next, XrdFrcReqFile::recEnt::Next, open(), rename(), XrdFrcReqFile::recEnt::reqData, XrdFrc::Say, and XrdFrcRequest::This.

Member Data Documentation

XrdSysMutex XrdFrcReqFile::flMutex

private

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)

staticprivate

---

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

• XrdFrcReqFile.hh
• XrdFrcReqFile.cc