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 ()
XrdProtocolMatch (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
XrdLinkLink
XrdBufferargp
XrdXrootdFileTableFTab
XrdXrootdMonitorMonitor
kXR_unt32 monUID
char monFILE
char monIO
char Status
unsigned char CapVer
XrdSecEntityClient
XrdSecProtocolAuthProt
XrdSecEntity Entity
XrdXrootdAioReqmyAioReq
char * myBuff
int myBlen
int myBlast
int(XrdXrootdProtocol::* Resume )()
XrdXrootdFilemyFile
long long myOffset
int myIOLen
int myStalls
int hcPrev
int hcNext
int hcNow
int halfBSize
XrdSysMutex streamMutex
XrdSysSemaphorereTry
XrdXrootdProtocolStream [maxStreams]
unsigned int mySID
char isActive
char isDead
char isBound
char isNOP
XrdXrootdPiopioFirst
XrdXrootdPiopioLast
XrdXrootdPiopioFree
short PathID
char doWrite
char doWriteC
XrdXrootdReqID ReqID
ClientRequest Request
XrdXrootdResponse Response

Static Protected Attributes

XrdXrootdXPath RPList
XrdXrootdXPath XPList
XrdSfsFileSystemosFS
XrdSecServiceCIA = 0
XrdXrootdFileLockLocker
XrdSchedulerSched
XrdBuffManagerBPool
XrdSysError eDest
const char * myInst = 0
const char * TraceID = "Protocol"
char * pidPath = strdup("/tmp")
int myPID = static_cast<int>(getpid())
XrdNetSocketAdminSock = 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
XrdXrootdJobJobCKS = 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
XrdXrootdStatsSI
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< XrdXrootdProtocolProtLink

Static Private Attributes

XrdObjectQ< XrdXrootdProtocolProtStack

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:37:22 2011 for xrootd by  doxygen 1.3.9.1