XrdFrmReqFile Class Reference

#include <XrdFrmReqFile.hh>

List of all members.

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

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

XrdFrmReqFile::FileHdr HdrData
char * lokFN
int lokFD
int reqFD
char * reqFN
int isAgent

Static Private Attributes

static const int ReqSize = sizeof(XrdFrmRequest)

Classes

struct  FileHdr
struct  recEnt
class  rqMonitor

Detailed Description

Definition at line 18 of file XrdFrmReqFile.hh.

Member Enumeration Documentation

enum XrdFrmReqFile::LockType [private]

Definition at line 42 of file XrdFrmReqFile.hh.

Constructor & Destructor Documentation

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

Definition at line 43 of file XrdFrmReqFile.cc.

References HdrData, isAgent, lokFD, lokFN, reqFD, reqFN, strcat(), and strcpy().

XrdFrmReqFile::~XrdFrmReqFile (  )  [inline]

Definition at line 39 of file XrdFrmReqFile.hh.

Member Function Documentation

void XrdFrmReqFile::Add ( XrdFrmRequest *  rP  ) 

Definition at line 59 of file XrdFrmReqFile.cc.

References XrdSysError::Emsg(), 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(), XrdFrm::Say(), stat, and XrdFrmRequest::This.

Referenced by XrdFrmReqAgent::Start().

void XrdFrmReqFile::Can ( XrdFrmRequest *  rP  ) 

Definition at line 108 of file XrdFrmReqFile.cc.

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

void XrdFrmReqFile::Del ( XrdFrmRequest *  rP  ) 

Definition at line 149 of file XrdFrmReqFile.cc.

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

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

int XrdFrmReqFile::Get ( XrdFrmRequest *  rP  ) 

Definition at line 171 of file XrdFrmReqFile.cc.

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

int XrdFrmReqFile::Init (  ) 

Definition at line 200 of file XrdFrmReqFile.cc.

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

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

Definition at line 294 of file XrdFrmReqFile.cc.

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

Referenced by XrdFrmReqAgent::NextLFN().

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

Definition at line 339 of file XrdFrmReqFile.cc.

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, i, XrdFrmRequest::ID, if(), k, XrdFrmRequest::LFN, XrdFrmRequest::LFO, XrdFrmRequest::makeRW, XrdFrmRequest::msgFail, XrdFrmRequest::msgSucc, n, XrdFrmRequest::Notify, XrdFrmRequest::Opaque, XrdFrmRequest::OPc, XrdFrmRequest::Options, XrdFrmRequest::Prty, sprintf(), strlcpy(), tval, XrdFrmRequest::User, and RooFit::What().

Referenced by List().

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

Definition at line 427 of file XrdFrmReqFile.cc.

References XrdSysError::Emsg(), FileLock(), lkNone, and XrdFrm::Say().

Referenced by Add().

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

Definition at line 437 of file XrdFrmReqFile.cc.

References XrdSysError::Emsg(), FileLock(), lkNone, and XrdFrm::Say().

Referenced by Can().

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

Definition at line 447 of file XrdFrmReqFile.cc.

References XrdSysError::Emsg(), FileLock(), lkNone, and XrdFrm::Say().

Referenced by Del().

int XrdFrmReqFile::FailIni ( const char *  lfn  )  [private]

Definition at line 457 of file XrdFrmReqFile.cc.

References XrdSysError::Emsg(), FileLock(), lkNone, reqFN, and XrdFrm::Say().

Referenced by Init().

int XrdFrmReqFile::FileLock ( LockType  ltype = lkExcl  )  [private]

Definition at line 468 of file XrdFrmReqFile.cc.

References close, XrdSysError::Emsg(), F_SETFD, fcntl(), FD_CLOEXEC, FLOCK_t, HdrData, isAgent, lkExcl, lkNone, lkShare, lokFD, lokFN, open, pread, reqFN, XrdFrm::Say(), and RooFit::What().

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

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

Definition at line 516 of file XrdFrmReqFile.cc.

References XrdSysError::Emsg(), pread, reqFN, ReqSize, and XrdFrm::Say().

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

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

Definition at line 529 of file XrdFrmReqFile.cc.

References XrdSysError::Emsg(), fsync, HdrData, pwrite, reqFN, ReqSize, and XrdFrm::Say().

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

int XrdFrmReqFile::ReWrite ( recEnt *  rP  )  [private]

Definition at line 547 of file XrdFrmReqFile.cc.

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

Member Data Documentation

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

Definition at line 44 of file XrdFrmReqFile.hh.

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

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

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

char* XrdFrmReqFile::lokFN [private]

Definition at line 61 of file XrdFrmReqFile.hh.

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

int XrdFrmReqFile::lokFD [private]

Definition at line 62 of file XrdFrmReqFile.hh.

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

int XrdFrmReqFile::reqFD [private]

Definition at line 63 of file XrdFrmReqFile.hh.

Referenced by Add(), Can(), and XrdFrmReqFile().

char* XrdFrmReqFile::reqFN [private]

Definition at line 64 of file XrdFrmReqFile.hh.

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

int XrdFrmReqFile::isAgent [private]

Definition at line 66 of file XrdFrmReqFile.hh.

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

The documentation for this class was generated from the following files:
Generated on Tue Jul 5 16:50:33 2011 for ROOT_528-00b_version by  doxygen 1.5.1