XrdOfsPoscq Class Reference

#include <XrdOfsPoscq.hh>

Collaboration diagram for XrdOfsPoscq:

List of all members.

Classes
struct	FileSlot
struct	recEnt
struct	Request
Public Member Functions
int	Add (const char *Tident, const char *Lfn)
int	Commit (const char *Lfn, int Offset)
int	Del (const char *Lfn, int Offset, int Unlink=0)
recEnt *	Init (int &Ok)
int	Num ()
	XrdOfsPoscq (XrdSysError *erp, XrdOss *oss, const char *fn)
	~XrdOfsPoscq ()
Static Public Member Functions
static recEnt *	List (XrdSysError *Say, const char *theFN)
Static Public Attributes
static const int	ReqOffs = 64
static const int	ReqSize = sizeof(Request)
Private Member Functions
void	FailIni (const char *lfn)
int	reqRead (void *Buff, int Offs)
int	reqWrite (void *Buff, int Bsz, int Offs)
int	ReWrite (recEnt *rP)
int	VerOffset (const char *Lfn, int Offset)
Private Attributes
XrdSysMutex	myMutex
XrdSysError *	eDest
XrdOss *	ossFS
FileSlot *	SlotList
FileSlot *	SlotLust
char *	pocFN
int	pocSZ
int	pocFD
int	pocIQ

---

Constructor & Destructor Documentation

XrdOfsPoscq::XrdOfsPoscq	(	XrdSysError *	erp,
		XrdOss *	oss,
		const char *	fn
	)

References eDest, ossFS, pocFN, pocFD, pocSZ, pocIQ, SlotList, and SlotLust.

XrdOfsPoscq::~XrdOfsPoscq

(

)

[inline]

---

Member Function Documentation

int XrdOfsPoscq::Add	(	const char *	Tident,
		const char *	Lfn
	)

References XrdOfsPoscq::Request::addT, strlcpy(), XrdOfsPoscq::Request::LFN, XrdOfsPoscq::Request::User, XrdOfsPoscq::Request::Reserved, myMutex, XrdSysMutex::Lock(), SlotList, XrdOfsPoscq::FileSlot::Offset, XrdOfsPoscq::FileSlot::Next, SlotLust, pocSZ, ReqSize, pocIQ, XrdSysMutex::UnLock(), reqWrite(), eDest, and XrdSysError::Emsg().

Referenced by XrdOfsFile::open().

int XrdOfsPoscq::Commit	(	const char *	Lfn,
		int	Offset
	)

References VerOffset(), reqWrite(), eDest, and XrdSysError::Emsg().

Referenced by XrdOfsFile::open().

int XrdOfsPoscq::Del	(	const char *	Lfn,
		int	Offset,
		int	Unlink = 0
	)

References VerOffset(), ossFS, XrdOss::Unlink(), eDest, XrdSysError::Emsg(), reqWrite(), myMutex, XrdSysMutex::Lock(), SlotLust, XrdOfsPoscq::FileSlot::Next, XrdOfsPoscq::FileSlot::Offset, SlotList, pocIQ, and XrdSysMutex::UnLock().

Referenced by XrdOfsFile::open(), XrdOfsFile::close(), XrdOfs::Unpersist(), and XrdOfs::ConfigPosc().

void XrdOfsPoscq::FailIni

(

const char *

lfn

)

[private]

References eDest, XrdSysError::Emsg(), and pocFN.

Referenced by Init().

XrdOfsPoscq::recEnt * XrdOfsPoscq::Init

(

int &

Ok

)

References Mode, S_IRUSR, S_IWUSR, S_IRGRP, S_IROTH, stat(), pocFD, open(), pocFN, eDest, XrdSysError::Emsg(), fstat(), FailIni(), ReqSize, pocSZ, ReqOffs, ftruncate(), pread(), XrdOfsPoscq::Request::LFN, ossFS, XrdOss::Stat(), S_ISREG, S_IAMB, XrdSysError::Say(), and ReWrite().

Referenced by XrdOfs::ConfigPosc().

XrdOfsPoscq::recEnt * XrdOfsPoscq::List	(	XrdSysError *	Say,
		const char *	theFN
	)		[static]

References stat(), open(), XrdSysError::Emsg(), fstat(), close, ReqSize, ReqOffs, pread(), and XrdOfsPoscq::Request::LFN.

int XrdOfsPoscq::Num

(

)

[inline]

References pocIQ.

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

int XrdOfsPoscq::reqWrite	(	void *	Buff,
		int	Bsz,
		int	Offs
	)		[private]

References pwrite(), pocFD, fsync(), eDest, XrdSysError::Emsg(), and pocFN.

Referenced by Add(), Commit(), Del(), and ReWrite().

int XrdOfsPoscq::ReWrite

(

XrdOfsPoscq::recEnt *

rP

)

[private]

References Mode, S_IRUSR, S_IWUSR, S_IRGRP, S_IROTH, ReqOffs, pocFN, open(), eDest, XrdSysError::Emsg(), pocFD, XrdOfsPoscq::recEnt::Offset, reqWrite(), XrdOfsPoscq::recEnt::reqData, ReqSize, XrdOfsPoscq::recEnt::Next, rename(), close, and pocSZ.

Referenced by Init().

int XrdOfsPoscq::VerOffset	(	const char *	Lfn,
		int	Offset
	)		[private]

References ReqOffs, ReqSize, eDest, and XrdSysError::Emsg().

Referenced by Commit(), and Del().

---

Member Data Documentation

XrdSysError* XrdOfsPoscq::eDest [private]

Referenced by XrdOfsPoscq(), Add(), Commit(), Del(), Init(), FailIni(), reqWrite(), ReWrite(), and VerOffset().

XrdSysMutex XrdOfsPoscq::myMutex [private]

Referenced by Add(), and Del().

XrdOss* XrdOfsPoscq::ossFS [private]

Referenced by XrdOfsPoscq(), Del(), and Init().

int XrdOfsPoscq::pocFD [private]

Referenced by XrdOfsPoscq(), Init(), reqWrite(), and ReWrite().

char* XrdOfsPoscq::pocFN [private]

Referenced by XrdOfsPoscq(), Init(), FailIni(), reqWrite(), and ReWrite().

int XrdOfsPoscq::pocIQ [private]

Referenced by XrdOfsPoscq(), Add(), Del(), and Num().

int XrdOfsPoscq::pocSZ [private]

Referenced by XrdOfsPoscq(), Add(), Init(), and ReWrite().

const int XrdOfsPoscq::ReqOffs = 64 [static]

Referenced by Init(), List(), ReWrite(), and VerOffset().

const int XrdOfsPoscq::ReqSize = sizeof(Request) [static]

Referenced by Add(), Init(), List(), ReWrite(), and VerOffset().

FileSlot* XrdOfsPoscq::SlotList [private]

Referenced by XrdOfsPoscq(), Add(), and Del().

FileSlot* XrdOfsPoscq::SlotLust [private]

Referenced by XrdOfsPoscq(), Add(), and Del().

---

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

• XrdOfsPoscq.hh
• XrdOfsPoscq.cc