Classes | Public Types | Public Member Functions | Static Public Member Functions | Static Public Attributes | Private Types | Private Member Functions | Private Attributes

XrdFrmPstgReq Class Reference

#include <XrdFrmPstgReq.hh>

Collaboration diagram for XrdFrmPstgReq:
Collaboration graph
[legend]

List of all members.

Classes

struct  FileHdr
struct  recEnt
struct  Request

Public Types

enum  Item {
  getLFN = 0, getLFNCGI, getMODE, getNOTE,
  getPRTY, getQWT, getRID, getTOD,
  getUSER
}

Public Member Functions

void Add (Request *rP)
void Can (Request *rP)
void Del (Request *rP)
int Get (Request *rP)
int Init ()
char * List (char *Buff, int bsz, int &Offs, Item *ITList=0, int ITNum=0)
void ListL (XrdFrmPstgReq::Request tmpReq, char *Buff, int bsz, Item *ITList, int ITNum)
 XrdFrmPstgReq (const char *fn)
 ~XrdFrmPstgReq ()

Static Public Member Functions

static int Unique (const char *lkfn)

Static Public Attributes

static const int msgFail = 0x0001
static const int msgSucc = 0x0002
static const int stgRW = 0x0004
static const int maxPrty = 2
static const int ReqSize = sizeof(Request)

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 XrdFrmPstgReq::FileHdr HdrData
char * lokFN
int lokFD
int reqFD
char * reqFN

Member Enumeration Documentation

enum XrdFrmPstgReq::Item
Enumerator:
getLFN 
getLFNCGI 
getMODE 
getNOTE 
getPRTY 
getQWT 
getRID 
getTOD 
getUSER 
enum XrdFrmPstgReq::LockType [private]
Enumerator:
lkNone 
lkShare 
lkExcl 
lkInit 

Constructor & Destructor Documentation

XrdFrmPstgReq::XrdFrmPstgReq ( const char *  fn  ) 

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

XrdFrmPstgReq::~XrdFrmPstgReq (  )  [inline]

Member Function Documentation

void XrdFrmPstgReq::Add ( XrdFrmPstgReq::Request *  rP  ) 

References FailAdd(), FileLock(), XrdFrmPstgReq::FileHdr::First, XrdFrmPstgReq::FileHdr::Free, fstat(), HdrData, index(), XrdFrmPstgReq::FileHdr::Last, XrdFrmPstgReq::Request::LFN, lkNone, XrdFrmPstgReq::Request::Next, XrdFrmPstgReq::Request::Opaque, reqFD, reqFN, reqRead(), reqWrite(), Say, stat(), and XrdFrmPstgReq::Request::This.

Referenced by XrdFrmPstg::Agent_Add().

void XrdFrmPstgReq::Can ( XrdFrmPstgReq::Request *  rP  ) 

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

void XrdFrmPstgReq::Del ( XrdFrmPstgReq::Request *  rP  ) 

References FailDel(), FileLock(), XrdFrmPstgReq::FileHdr::Free, HdrData, XrdFrmPstgReq::Request::LFN, lkNone, XrdFrmPstgReq::Request::Next, reqWrite(), and XrdFrmPstgReq::Request::This.

Referenced by XrdFrmPstgXfr::Queue(), and XrdFrmPstgXfr::Start().

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

References FileLock(), lkNone, and Say.

Referenced by Add().

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

References FileLock(), lkNone, and Say.

Referenced by Can().

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

References FileLock(), lkNone, and Say.

Referenced by Del().

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

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

Referenced by Init().

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

References close, XrdCms::Config, fcntl(), FLOCK_t, HdrData, 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 XrdFrmPstgReq::Get ( XrdFrmPstgReq::Request *  rP  ) 

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

int XrdFrmPstgReq::Init (  ) 

References XrdCms::Config, DEBUG, EPNAME, FailIni(), FileLock(), XrdFrmPstgReq::FileHdr::Free, fstat(), HdrData, lkInit, lkNone, lokFD, lokFN, Mode, open(), reqFD, reqFN, reqRead(), ReqSize, reqWrite(), ReWrite(), S_IRGRP, S_IRUSR, S_IWUSR, Say, and stat().

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

References XrdFrmPstgReq::Request::addTOD, FileLock(), XrdFrmPstgReq::Request::LFN, ListL(), lkNone, lkShare, XrdFrmPstgReq::Request::Opaque, pread(), reqFD, reqFN, ReqSize, Say, and strlcpy().

void XrdFrmPstgReq::ListL ( XrdFrmPstgReq::Request  tmpReq,
char *  Buff,
int  bsz,
Item *  ITList,
int  ITNum 
)

References XrdFrmPstgReq::Request::addTOD, getLFN, getLFNCGI, getMODE, getNOTE, getPRTY, getQWT, getRID, getTOD, getUSER, XrdFrmPstgReq::Request::ID, XrdFrmPstgReq::Request::LFN, msgFail, msgSucc, XrdFrmPstgReq::Request::Notify, XrdFrmPstgReq::Request::Opaque, XrdFrmPstgReq::Request::Options, XrdFrmPstgReq::Request::Prty, stgRW, strlcpy(), and XrdFrmPstgReq::Request::User.

Referenced by List().

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

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

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

int XrdFrmPstgReq::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 XrdFrmPstgReq::ReWrite ( XrdFrmPstgReq::recEnt *  rP  )  [private]

References close, FileLock(), XrdFrmPstgReq::FileHdr::First, XrdFrmPstgReq::FileHdr::Free, ftruncate(), HdrData, XrdFrmPstgReq::FileHdr::Last, lkNone, Mode, XrdFrmPstgReq::recEnt::Next, XrdFrmPstgReq::Request::Next, open(), rename(), XrdFrmPstgReq::recEnt::reqData, reqFD, reqFN, ReqSize, reqWrite(), S_IRGRP, S_IRUSR, S_IWUSR, Say, and XrdFrmPstgReq::Request::This.

Referenced by Init().

int XrdFrmPstgReq::Unique ( const char *  lkfn  )  [static]

References close, XrdCms::Config, fcntl(), FLOCK_t, Mode, XrdCmsConfig::myProg, open(), S_IRGRP, S_IRUSR, S_IWUSR, and Say.

Referenced by mainConfig().

Member Data Documentation

struct XrdFrmPstgReq::FileHdr XrdFrmPstgReq::HdrData [private]

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

int XrdFrmPstgReq::lokFD [private]

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

char* XrdFrmPstgReq::lokFN [private]

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

const int XrdFrmPstgReq::maxPrty = 2 [static]

Referenced by XrdFrmPstg::Agent_Add(), XrdFrmPstg::Agent_Del(), XrdFrmPstg::Agent_Lst(), mainConfig(), and XrdFrmPstg::Server_Stage().

const int XrdFrmPstgReq::msgFail = 0x0001 [static]

Referenced by XrdFrmPstg::Agent_Add(), ListL(), XrdFrmPstgXfr::Notify(), XrdFrmPstgXfr::Queue(), and XrdFrmPstgXfr::StageOpt().

const int XrdFrmPstgReq::msgSucc = 0x0002 [static]

Referenced by XrdFrmPstg::Agent_Add(), ListL(), XrdFrmPstgXfr::Notify(), XrdFrmPstgXfr::Queue(), and XrdFrmPstgXfr::StageOpt().

int XrdFrmPstgReq::reqFD [private]

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

char* XrdFrmPstgReq::reqFN [private]

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

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

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

const int XrdFrmPstgReq::stgRW = 0x0004 [static]

Referenced by XrdFrmPstg::Agent_Add(), ListL(), and XrdFrmPstgXfr::StageCmd().

The documentation for this class was generated from the following files:
Generated on Wed Sep 1 2010 for xrootd by  doxygen 1.7.1