Main Page | Namespace List | Class Hierarchy | Class List | Directories | File List | Namespace Members | Class Members | File Members

XrdXrootdProtocol Struct Reference

#include <XrdXrootdProtocol.hh>

Inheritance diagram for XrdXrootdProtocol:

Inheritance graph
[legend]
Collaboration diagram for XrdXrootdProtocol:

Collaboration graph
[legend]
List of all members.

Public Member Functions

void DoIt ()
XrdProtocol * Match (XrdLink *lp)
int Process (XrdLink *lp)
void Recycle (XrdLink *lp, int consec, const char *reason)
int Stats (char *buff, int blen, int do_sync=0)
XrdXrootdProtocol operator= (const XrdXrootdProtocol &rhs)
 XrdXrootdProtocol ()
 ~XrdXrootdProtocol ()

Static Public Member Functions

int Configure (char *parms, XrdProtocol_Config *pi)
int StatGen (struct stat &buf, char *xxBuff)

Protected Attributes

int numReads
int numReadP
int numWrites
int numFiles
int cumReads
int cumReadP
int cumWrites
long long totReadP
XrdLink * Link
XrdBuffer * argp
XrdXrootdFileTable * FTab
XrdXrootdMonitor * Monitor
kXR_unt32 monUID
char monFILE
char monIO
char Status
unsigned char CapVer
XrdSecEntity * Client
XrdSecProtocol * AuthProt
XrdSecEntity Entity
XrdXrootdAioReq * myAioReq
char * myBuff
int myBlen
int myBlast
int(XrdXrootdProtocol::* Resume )()
XrdXrootdFile * myFile
long long myOffset
int myIOLen
int myStalls
int hcPrev
int hcNext
int hcNow
int halfBSize
XrdSysMutex streamMutex
XrdSysSemaphore * reTry
XrdXrootdProtocol * Stream [maxStreams]
unsigned int mySID
char isActive
char isDead
char isBound
char isNOP
XrdXrootdPio * pioFirst
XrdXrootdPio * pioLast
XrdXrootdPio * pioFree
short PathID
char doWrite
char doWriteC
XrdXrootdReqID ReqID
ClientRequest Request
XrdXrootdResponse Response

Static Protected Attributes

XrdXrootdXPath RPList
XrdXrootdXPath XPList
XrdSfsFileSystem * osFS
XrdSecService * CIA = 0
XrdXrootdFileLock * Locker
XrdScheduler * Sched
XrdBuffManager * BPool
XrdSysError eDest
const char * myInst = 0
const char * TraceID = "Protocol"
char * pidPath = strdup("/tmp")
int myPID = static_cast<int>(getpid())
XrdNetSocket * AdminSock = 0
int hailWait
int readWait
int Port
int Window
int WANPort
int WANWindow
char * SecLib = 0
char * FSLib = 0
char * Notify = 0
char isRedir = 0
char chkfsV = 0
XrdXrootdJob * JobCKS = 0
char * JobCKT = 0
XrdXrootdProtocol::RD_Table Route [RD_Num]
int as_maxperlnk = 8
int as_maxperreq = 8
int as_maxpersrv = 4096
int as_miniosz = 32768
int as_minsfsz = 8192
int as_segsize = 131072
int as_maxstalls = 5
int as_force = 0
int as_noaio = 0
int as_nosf = 0
int as_syncw = 0
int maxBuffsz
int maxTransz = 262144
const int maxRvecsz = 1024
XrdXrootdStats * SI
int hcMax = 28657
const int maxStreams = 16
const int maxPio = 4

Private Types

enum  RD_func {
  RD_chmod = 0, RD_dirlist, RD_locate, RD_mkdir,
  RD_mv, RD_prepare, RD_prepstg, RD_rm,
  RD_rmdir, RD_stat, RD_open1, RD_open2,
  RD_open3, RD_open4, RD_Num
}

Private Member Functions

int do_Admin ()
int do_Auth ()
int do_Bind ()
int do_Chmod ()
int do_CKsum (int canit)
int do_Close ()
int do_Dirlist ()
int do_Endsess ()
int do_Getfile ()
int do_Login ()
int do_Locate ()
int do_Mkdir ()
int do_Mv ()
int do_Offload (int pathID, int isRead)
int do_OffloadIO ()
int do_Open ()
int do_Ping ()
int do_Prepare ()
int do_Protocol ()
int do_Putfile ()
int do_Qconf ()
int do_Qfh ()
int do_Qopaque (short)
int do_Qspace ()
int do_Query ()
int do_Qxattr ()
int do_Read ()
int do_ReadV ()
int do_ReadAll (int asyncOK=1)
int do_ReadNone (int &retc, int &pathID)
int do_Rm ()
int do_Rmdir ()
int do_Set ()
int do_Set_Mon (XrdOucTokenizer &setargs)
int do_Stat ()
int do_Statx ()
int do_Sync ()
int do_Truncate ()
int do_Write ()
int do_WriteAll ()
int do_WriteCont ()
int do_WriteNone ()
int aio_Error (const char *op, int ecode)
int aio_Read ()
int aio_Write ()
int aio_WriteAll ()
int aio_WriteCont ()
void Assign (const XrdXrootdProtocol &rhs)
void Cleanup ()
int fsError (int rc, XrdOucErrInfo &myError)
int getBuff (const int isRead, int Quantum)
int getData (const char *dtype, char *buff, int blen)
int Process2 ()
void Reset ()
int rpEmsg (const char *op, char *fn)
int vpEmsg (const char *op, char *fn)

Static Private Member Functions

int Config (const char *fn)
int mapMode (int mode)
void PidFile ()
int rpCheck (char *fn, const char **opaque)
int Squash (char *)
int xapath (XrdOucStream &Config)
int xasync (XrdOucStream &Config)
int xcksum (XrdOucStream &Config)
int xexp (XrdOucStream &Config)
int xexpdo (char *path, int popt=0)
int xfsl (XrdOucStream &Config)
int xpidf (XrdOucStream &Config)
int xprep (XrdOucStream &Config)
int xlog (XrdOucStream &Config)
int xmon (XrdOucStream &Config)
int xred (XrdOucStream &Config)
void xred_set (RD_func func, const char *rHost, int rPort)
int xsecl (XrdOucStream &Config)
int xtrace (XrdOucStream &Config)

Private Attributes

XrdObject< XrdXrootdProtocol > ProtLink

Static Private Attributes

XrdObjectQ< XrdXrootdProtocol > ProtStack

Friends

class XrdXrootdAdmin
class XrdXrootdAioReq

Member Enumeration Documentation

enum XrdXrootdProtocol::RD_func [private]
 

Enumeration values:
RD_chmod 
RD_dirlist 
RD_locate 
RD_mkdir 
RD_mv 
RD_prepare 
RD_prepstg 
RD_rm 
RD_rmdir 
RD_stat 
RD_open1 
RD_open2 
RD_open3 
RD_open4 
RD_Num 

Constructor & Destructor Documentation

XrdXrootdProtocol::XrdXrootdProtocol (   ) 
 

XrdXrootdProtocol::~XrdXrootdProtocol (   )  [inline]
 

Member Function Documentation

int XrdXrootdProtocol::aio_Error (  const char *  op,
int  ecode
)  [private]
 

int XrdXrootdProtocol::aio_Read (   )  [private]
 

int XrdXrootdProtocol::aio_Write (   )  [private]
 

int XrdXrootdProtocol::aio_WriteAll (   )  [private]
 

int XrdXrootdProtocol::aio_WriteCont (   )  [private]
 

void XrdXrootdProtocol::Assign (  const XrdXrootdProtocol &  rhs  )  [private]
 

void XrdXrootdProtocol::Cleanup (   )  [private]
 

int XrdXrootdProtocol::Config (  const char *  fn  )  [static, private]
 

int XrdXrootdProtocol::Configure (  char *  parms,
XrdProtocol_Config *  pi
)  [static]
 

int XrdXrootdProtocol::do_Admin (   )  [private]
 

int XrdXrootdProtocol::do_Auth (   )  [private]
 

int XrdXrootdProtocol::do_Bind (   )  [private]
 

int XrdXrootdProtocol::do_Chmod (   )  [private]
 

int XrdXrootdProtocol::do_CKsum (  int  canit  )  [private]
 

int XrdXrootdProtocol::do_Close (   )  [private]
 

int XrdXrootdProtocol::do_Dirlist (   )  [private]
 

int XrdXrootdProtocol::do_Endsess (   )  [private]
 

int XrdXrootdProtocol::do_Getfile (   )  [private]
 

int XrdXrootdProtocol::do_Locate (   )  [private]
 

int XrdXrootdProtocol::do_Login (   )  [private]
 

int XrdXrootdProtocol::do_Mkdir (   )  [private]
 

int XrdXrootdProtocol::do_Mv (   )  [private]
 

int XrdXrootdProtocol::do_Offload (  int  pathID,
int  isRead
)  [private]
 

int XrdXrootdProtocol::do_OffloadIO (   )  [private]
 

int XrdXrootdProtocol::do_Open (   )  [private]
 

int XrdXrootdProtocol::do_Ping (   )  [private]
 

int XrdXrootdProtocol::do_Prepare (   )  [private]
 

int XrdXrootdProtocol::do_Protocol (   )  [private]
 

int XrdXrootdProtocol::do_Putfile (   )  [private]
 

int XrdXrootdProtocol::do_Qconf (   )  [private]
 

int XrdXrootdProtocol::do_Qfh (   )  [private]
 

int XrdXrootdProtocol::do_Qopaque (  short   )  [private]
 

int XrdXrootdProtocol::do_Qspace (   )  [private]
 

int XrdXrootdProtocol::do_Query (   )  [private]
 

int XrdXrootdProtocol::do_Qxattr (   )  [private]
 

int XrdXrootdProtocol::do_Read (   )  [private]
 

int XrdXrootdProtocol::do_ReadAll (  int  asyncOK = 1  )  [private]
 

int XrdXrootdProtocol::do_ReadNone (  int &  retc,
int &  pathID
)  [private]
 

int XrdXrootdProtocol::do_ReadV (   )  [private]
 

int XrdXrootdProtocol::do_Rm (   )  [private]
 

int XrdXrootdProtocol::do_Rmdir (   )  [private]
 

int XrdXrootdProtocol::do_Set (   )  [private]
 

int XrdXrootdProtocol::do_Set_Mon (  XrdOucTokenizer &  setargs  )  [private]
 

int XrdXrootdProtocol::do_Stat (   )  [private]
 

int XrdXrootdProtocol::do_Statx (   )  [private]
 

int XrdXrootdProtocol::do_Sync (   )  [private]
 

int XrdXrootdProtocol::do_Truncate (   )  [private]
 

int XrdXrootdProtocol::do_Write (   )  [private]
 

int XrdXrootdProtocol::do_WriteAll (   )  [private]
 

int XrdXrootdProtocol::do_WriteCont (   )  [private]
 

int XrdXrootdProtocol::do_WriteNone (   )  [private]
 

void XrdXrootdProtocol::DoIt (   )  [inline, virtual]
 

Implements XrdJob.

int XrdXrootdProtocol::fsError (  int  rc,
XrdOucErrInfo &  myError
)  [private]
 

int XrdXrootdProtocol::getBuff (  const int  isRead,
int  Quantum
)  [private]
 

int XrdXrootdProtocol::getData (  const char *  dtype,
char *  buff,
int  blen
)  [private]
 

int XrdXrootdProtocol::mapMode (  int  mode  )  [static, private]
 

XrdProtocol * XrdXrootdProtocol::Match (  XrdLink *  lp  )  [virtual]
 

Implements XrdProtocol.

XrdXrootdProtocol XrdXrootdProtocol::operator= (  const XrdXrootdProtocol &  rhs  ) 
 

void XrdXrootdProtocol::PidFile (   )  [static, private]
 

int XrdXrootdProtocol::Process (  XrdLink *  lp  )  [virtual]
 

Implements XrdProtocol.

int XrdXrootdProtocol::Process2 (   )  [private]
 

void XrdXrootdProtocol::Recycle (  XrdLink *  lp,
int  consec,
const char *  reason
)  [virtual]
 

Implements XrdProtocol.

void XrdXrootdProtocol::Reset (   )  [private]
 

int XrdXrootdProtocol::rpCheck (  char *  fn,
const char **  opaque
)  [static, private]
 

int XrdXrootdProtocol::rpEmsg (  const char *  op,
char *  fn
)  [private]
 

int XrdXrootdProtocol::Squash (  char *   )  [static, private]
 

int XrdXrootdProtocol::StatGen (  struct stat &  buf,
char *  xxBuff
)  [static]
 

int XrdXrootdProtocol::Stats (  char *  buff,
int  blen,
int  do_sync = 0
)  [virtual]
 

Implements XrdProtocol.

int XrdXrootdProtocol::vpEmsg (  const char *  op,
char *  fn
)  [private]
 

int XrdXrootdProtocol::xapath (  XrdOucStream &  Config  )  [static, private]
 

int XrdXrootdProtocol::xasync (  XrdOucStream &  Config  )  [static, private]
 

int XrdXrootdProtocol::xcksum (  XrdOucStream &  Config  )  [static, private]
 

int XrdXrootdProtocol::xexp (  XrdOucStream &  Config  )  [static, private]
 

int XrdXrootdProtocol::xexpdo (  char *  path,
int  popt = 0
)  [static, private]
 

int XrdXrootdProtocol::xfsl (  XrdOucStream &  Config  )  [static, private]
 

int XrdXrootdProtocol::xlog (  XrdOucStream &  Config  )  [static, private]
 

int XrdXrootdProtocol::xmon (  XrdOucStream &  Config  )  [static, private]
 

int XrdXrootdProtocol::xpidf (  XrdOucStream &  Config  )  [static, private]
 

int XrdXrootdProtocol::xprep (  XrdOucStream &  Config  )  [static, private]
 

int XrdXrootdProtocol::xred (  XrdOucStream &  Config  )  [static, private]
 

void XrdXrootdProtocol::xred_set (  RD_func  func,
const char *  rHost,
int  rPort
)  [static, private]
 

int XrdXrootdProtocol::xsecl (  XrdOucStream &  Config  )  [static, private]
 

int XrdXrootdProtocol::xtrace (  XrdOucStream &  Config  )  [static, private]
 

Friends And Related Function Documentation

friend class XrdXrootdAdmin [friend]
 

friend class XrdXrootdAioReq [friend]
 

Member Data Documentation

XrdNetSocket * XrdXrootdProtocol::AdminSock = 0 [static, protected]
 

XrdBuffer* XrdXrootdProtocol::argp [protected]
 

int XrdXrootdProtocol::as_force = 0 [static, protected]
 

int XrdXrootdProtocol::as_maxperlnk = 8 [static, protected]
 

int XrdXrootdProtocol::as_maxperreq = 8 [static, protected]
 

int XrdXrootdProtocol::as_maxpersrv = 4096 [static, protected]
 

int XrdXrootdProtocol::as_maxstalls = 5 [static, protected]
 

int XrdXrootdProtocol::as_miniosz = 32768 [static, protected]
 

int XrdXrootdProtocol::as_minsfsz = 8192 [static, protected]
 

int XrdXrootdProtocol::as_noaio = 0 [static, protected]
 

int XrdXrootdProtocol::as_nosf = 0 [static, protected]
 

int XrdXrootdProtocol::as_segsize = 131072 [static, protected]
 

int XrdXrootdProtocol::as_syncw = 0 [static, protected]
 

XrdSecProtocol* XrdXrootdProtocol::AuthProt [protected]
 

XrdBuffManager * XrdXrootdProtocol::BPool [static, protected]
 

unsigned char XrdXrootdProtocol::CapVer [protected]
 

char XrdXrootdProtocol::chkfsV = 0 [static, protected]
 

XrdSecService * XrdXrootdProtocol::CIA = 0 [static, protected]
 

XrdSecEntity* XrdXrootdProtocol::Client [protected]
 

int XrdXrootdProtocol::cumReadP [protected]
 

int XrdXrootdProtocol::cumReads [protected]
 

int XrdXrootdProtocol::cumWrites [protected]
 

char XrdXrootdProtocol::doWrite [protected]
 

char XrdXrootdProtocol::doWriteC [protected]
 

XrdSysError XrdXrootdProtocol::eDest [static, protected]
 

XrdSecEntity XrdXrootdProtocol::Entity [protected]
 

char * XrdXrootdProtocol::FSLib = 0 [static, protected]
 

XrdXrootdFileTable* XrdXrootdProtocol::FTab [protected]
 

int XrdXrootdProtocol::hailWait [static, protected]
 

int XrdXrootdProtocol::halfBSize [protected]
 

int XrdXrootdProtocol::hcMax = 28657 [static, protected]
 

int XrdXrootdProtocol::hcNext [protected]
 

int XrdXrootdProtocol::hcNow [protected]
 

int XrdXrootdProtocol::hcPrev [protected]
 

char XrdXrootdProtocol::isActive [protected]
 

char XrdXrootdProtocol::isBound [protected]
 

char XrdXrootdProtocol::isDead [protected]
 

char XrdXrootdProtocol::isNOP [protected]
 

char XrdXrootdProtocol::isRedir = 0 [static, protected]
 

XrdXrootdJob * XrdXrootdProtocol::JobCKS = 0 [static, protected]
 

char * XrdXrootdProtocol::JobCKT = 0 [static, protected]
 

XrdLink* XrdXrootdProtocol::Link [protected]
 

XrdXrootdFileLock * XrdXrootdProtocol::Locker [static, protected]
 

int XrdXrootdProtocol::maxBuffsz [static, protected]
 

const int XrdXrootdProtocol::maxPio = 4 [static, protected]
 

const int XrdXrootdProtocol::maxRvecsz = 1024 [static, protected]
 

const int XrdXrootdProtocol::maxStreams = 16 [static, protected]
 

int XrdXrootdProtocol::maxTransz = 262144 [static, protected]
 

char XrdXrootdProtocol::monFILE [protected]
 

char XrdXrootdProtocol::monIO [protected]
 

XrdXrootdMonitor* XrdXrootdProtocol::Monitor [protected]
 

kXR_unt32 XrdXrootdProtocol::monUID [protected]
 

XrdXrootdAioReq* XrdXrootdProtocol::myAioReq [protected]
 

int XrdXrootdProtocol::myBlast [protected]
 

int XrdXrootdProtocol::myBlen [protected]
 

char* XrdXrootdProtocol::myBuff [protected]
 

XrdXrootdFile* XrdXrootdProtocol::myFile [protected]
 

const char * XrdXrootdProtocol::myInst = 0 [static, protected]
 

int XrdXrootdProtocol::myIOLen [protected]
 

long long XrdXrootdProtocol::myOffset [protected]
 

int XrdXrootdProtocol::myPID = static_cast<int>(getpid()) [static, protected]
 

unsigned int XrdXrootdProtocol::mySID [protected]
 

int XrdXrootdProtocol::myStalls [protected]
 

char * XrdXrootdProtocol::Notify = 0 [static, protected]
 

int XrdXrootdProtocol::numFiles [protected]
 

int XrdXrootdProtocol::numReadP [protected]
 

int XrdXrootdProtocol::numReads [protected]
 

int XrdXrootdProtocol::numWrites [protected]
 

XrdSfsFileSystem * XrdXrootdProtocol::osFS [static, protected]
 

short XrdXrootdProtocol::PathID [protected]
 

char * XrdXrootdProtocol::pidPath = strdup("/tmp") [static, protected]
 

XrdXrootdPio* XrdXrootdProtocol::pioFirst [protected]
 

XrdXrootdPio* XrdXrootdProtocol::pioFree [protected]
 

XrdXrootdPio* XrdXrootdProtocol::pioLast [protected]
 

int XrdXrootdProtocol::Port [static, protected]
 

XrdObject<XrdXrootdProtocol> XrdXrootdProtocol::ProtLink [private]
 

XrdObjectQ< XrdXrootdProtocol > XrdXrootdProtocol::ProtStack [static, private]
 

int XrdXrootdProtocol::readWait [static, protected]
 

XrdXrootdReqID XrdXrootdProtocol::ReqID [protected]
 

ClientRequest XrdXrootdProtocol::Request [protected]
 

XrdXrootdResponse XrdXrootdProtocol::Response [protected]
 

int(XrdXrootdProtocol::* XrdXrootdProtocol::Resume)() [protected]
 

XrdSysSemaphore* XrdXrootdProtocol::reTry [protected]
 

struct XrdXrootdProtocol::RD_Table XrdXrootdProtocol::Route[RD_Num] [static, protected]
 

XrdXrootdXPath XrdXrootdProtocol::RPList [static, protected]
 

XrdScheduler * XrdXrootdProtocol::Sched [static, protected]
 

char * XrdXrootdProtocol::SecLib = 0 [static, protected]
 

XrdXrootdStats * XrdXrootdProtocol::SI [static, protected]
 

char XrdXrootdProtocol::Status [protected]
 

XrdXrootdProtocol* XrdXrootdProtocol::Stream[maxStreams] [protected]
 

XrdSysMutex XrdXrootdProtocol::streamMutex [protected]
 

long long XrdXrootdProtocol::totReadP [protected]
 

const char * XrdXrootdProtocol::TraceID = "Protocol" [static, protected]
 

int XrdXrootdProtocol::WANPort [static, protected]
 

int XrdXrootdProtocol::WANWindow [static, protected]
 

int XrdXrootdProtocol::Window [static, protected]
 

XrdXrootdXPath XrdXrootdProtocol::XPList [static, protected]
 

The documentation for this struct was generated from the following files:
Generated on Sun Nov 6 13:42:40 2011 for xrootd by  doxygen 1.3.9.1