37 #define TRACELINK aioP->dataLink
45 const char *TraceID =
"AioFob";
63 TRACEI(FSAIO, what<<
" aio "
81 for (
int i = 0; i < maxQ; i++)
82 {
while((aioP = aioQ[i].first))
83 {aioQ[i].first = aioP->nextTask;
105 while((aioP = aioQ[pathID].first))
106 {aioQ[pathID].first = aioP->nextTask;
110 aioQ[pathID].last = 0;
111 Running[pathID] =
false;
129 {
if (aioQ[pathID].last) aioQ[pathID].last->nextTask = aioP;
130 else aioQ[pathID].first = aioP;
131 aioQ[pathID].last = aioP;
133 if (maxQ <= pathID) maxQ = pathID+1;
137 Running[pathID] =
true;
154 if (aioQ[pathID].first)
156 if (!(aioQ[pathID].first = aioP->nextTask)) aioQ[pathID].last = 0;
159 Running[pathID] =
true;
161 }
else Running[pathID] =
false;
XrdSysTrace XrdXrootdTrace
void Schedule(XrdJob *jp)
void Schedule(XrdXrootdAioTask *aioP)
virtual void Recycle(bool release)=0
XrdXrootdProtocol * Protocol