Go to the documentation of this file. 1 #ifndef __XRDXROOTDAIO__
2 #define __XRDXROOTDAIO__
118 static void Init(
int iosize,
int maxaiopr,
int maxaio=-80);
137 void Scuttle(
const char *opname);
static const char * TraceID
Definition: XrdXrootdAio.hh:74
static XrdXrootdAio * Alloc(XrdXrootdAioReq *arp, int bsize=0)
~XrdXrootdAio()
Definition: XrdXrootdAio.hh:67
static XrdXrootdAio * fqFirst
Definition: XrdXrootdAio.hh:79
Definition: XrdSysPthread.hh:165
void UnLock()
Definition: XrdXrootdAio.hh:139
static XrdXrootdAioReq * Alloc(XrdXrootdProtocol *p, char iot, int numaio=0)
int aioError
Definition: XrdXrootdAio.hh:164
XrdXrootdAioReq()
Definition: XrdXrootdAio.hh:126
Definition: XrdBuffer.hh:74
void DoIt()
Definition: XrdXrootdAio.hh:105
static XrdSysMutex fqMutex
Definition: XrdXrootdAio.hh:78
Definition: XrdXrootdResponse.hh:48
static XrdXrootdAioReq * addBlock()
XrdBuffer * buffp
Definition: XrdXrootdAio.hh:57
void Recycle(int deref=1, XrdXrootdAio *aiop=0)
off_t myOffset
Definition: XrdXrootdAio.hh:154
XrdXrootdAioReq * Next
Definition: XrdXrootdAio.hh:152
Definition: XrdXrootdStats.hh:39
static XrdXrootdAio * addBlock()
int Write(XrdXrootdAio *aiop)
char reDrive
Definition: XrdXrootdAio.hh:168
void sendError(char *tident)
static const char * TraceID
Definition: XrdXrootdAio.hh:141
static int Quantum
Definition: XrdXrootdAio.hh:146
Definition: XrdXrootdAio.hh:53
void Lock()
Definition: XrdXrootdAio.hh:136
static XrdSysMutex rqMutex
Definition: XrdXrootdAio.hh:143
XrdXrootdAioReq * aioReq
Definition: XrdXrootdAio.hh:83
static XrdXrootdAioReq * rqFirst
Definition: XrdXrootdAio.hh:144
int numActive
Definition: XrdXrootdAio.hh:162
static int maxAioPR
Definition: XrdXrootdAio.hh:148
static XrdBuffManager * BPool
Definition: XrdXrootdAio.hh:75
static void Init(int iosize, int maxaiopr, int maxaio=-80)
static XrdSysError * eDest
Definition: XrdXrootdAio.hh:142
XrdXrootdAio * aioDone
Definition: XrdXrootdAio.hh:160
XrdXrootdAio()
Definition: XrdXrootdAio.hh:66
static int maxAio
Definition: XrdXrootdAio.hh:80
int myIOLen
Definition: XrdXrootdAio.hh:155
Definition: XrdXrootdAio.hh:98
XrdXrootdFile * myFile
Definition: XrdXrootdAio.hh:158
Definition: XrdScheduler.hh:44
Definition: XrdLink.hh:63
static int QuantumMax
Definition: XrdXrootdAio.hh:147
char aioType
Definition: XrdXrootdAio.hh:165
static XrdXrootdStats * SI
Definition: XrdXrootdAio.hh:77
XrdXrootdAio * Pop()
Definition: XrdXrootdAio.hh:111
XrdLink * Link
Definition: XrdXrootdAio.hh:157
static int maxAioPR2
Definition: XrdXrootdAio.hh:149
XrdXrootdResponse Response
Definition: XrdXrootdAio.hh:170
Definition: XrdXrootdFile.hh:97
XrdXrootdAio * aioFree
Definition: XrdXrootdAio.hh:161
void UnLock()
Definition: XrdSysPthread.hh:222
Definition: XrdSfsAio.hh:57
XrdXrootdAio * Next
Definition: XrdXrootdAio.hh:82
void Lock()
Definition: XrdSysPthread.hh:220
unsigned int Instance
Definition: XrdXrootdAio.hh:156
Definition: XrdBuffer.hh:41
Definition: XrdXrootdProtocol.hh:93
static int QuantumMin
Definition: XrdXrootdAio.hh:145
char respDone
Definition: XrdXrootdAio.hh:166
Definition: XrdSysError.hh:89
void Clear(XrdLink *lnkp)
void Scuttle(const char *opname)
static XrdScheduler * Sched
Definition: XrdXrootdAio.hh:76
int aioTotal
Definition: XrdXrootdAio.hh:163
char isLocked
Definition: XrdXrootdAio.hh:167
void Push(XrdXrootdAio *newp)
Definition: XrdXrootdAio.hh:115
~XrdXrootdAioReq()
Definition: XrdXrootdAio.hh:127
XrdSysMutex aioMutex
Definition: XrdXrootdAio.hh:151