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