xrootd
|
#include <XrdXrootdAioTask.hh>
Public Member Functions | |
void | Completed (XrdXrootdAioBuff *aioP) |
const char * | ID () |
void | Init (XrdXrootdProtocol *protP, XrdXrootdResponse &resp, XrdXrootdFile *fP) |
virtual void | Read (long long offs, int dlen)=0 |
virtual void | Recycle (bool release)=0 |
XrdXrootdProtocol * | urProtocol () |
virtual int | Write (long long offs, int dlen)=0 |
![]() | |
virtual void | DoIt ()=0 |
XrdJob (const char *desc="") | |
virtual | ~XrdJob () |
Protected Member Functions | |
XrdXrootdAioTask (const char *what="aio request") | |
virtual | ~XrdXrootdAioTask () |
virtual void | CopyF2L ()=0 |
virtual int | CopyL2F ()=0 |
virtual bool | CopyL2F (XrdXrootdAioBuff *aioP)=0 |
bool | Drain () |
int | gdDone () override |
void | gdFail () override |
XrdXrootdAioBuff * | getBuff (bool wait) |
void | SendError (int rc, const char *eText) |
void | SendFSError (int rc) |
bool | Validate (XrdXrootdAioBuff *aioP) |
Protected Attributes | |
XrdSysMutex | aioMutex |
XrdSysCondVar2 | aioReady |
XrdXrootdAioBuff * | pendQ |
XrdXrootdAioBuff * | pendQEnd |
union { | |
XrdXrootdNormAio * nextNorm | |
XrdXrootdPgrwAio * nextPgrw | |
XrdXrootdAioTask * nextTask | |
}; | |
XrdXrootdProtocol * | Protocol |
XrdLink * | dataLink |
XrdXrootdFile * | dataFile |
union { | |
XrdXrootdAioBuff * finalRead | |
XrdXrootdAioBuff * pendWrite | |
}; | |
off_t | highOffset |
off_t | dataOffset |
int | dataLen |
char | aioState |
RAtomic_uchar | inFlight |
RAtomic_bool | isDone |
char | Status |
XrdXrootdResponse | Response |
Static Protected Attributes | |
static const char * | TraceID |
static const int | aioDead = 0x01 |
static const int | aioHeld = 0x02 |
static const int | aioPage = 0x04 |
static const int | aioRead = 0x08 |
static const int | aioSchd = 0x10 |
static const int | Offline = 0 |
static const int | Running = 1 |
static const int | Waiting = 2 |
Private Member Functions | |
bool | Wait4Buff (int maxWait=0) |
Friends | |
class | XrdXrootdAioFob |
Additional Inherited Members | |
![]() | |
XrdJob * | NextJob |
const char * | Comment |
|
inlineprotected |
|
inlineprotectedvirtual |
void XrdXrootdAioTask::Completed | ( | XrdXrootdAioBuff * | aioP | ) |
|
protectedpure virtual |
Implemented in XrdXrootdPgrwAio, and XrdXrootdNormAio.
|
protectedpure virtual |
Implemented in XrdXrootdPgrwAio, and XrdXrootdNormAio.
|
protectedpure virtual |
Implemented in XrdXrootdPgrwAio, and XrdXrootdNormAio.
|
protected |
|
overrideprotected |
|
overrideprotected |
|
protected |
const char* XrdXrootdAioTask::ID | ( | ) |
void XrdXrootdAioTask::Init | ( | XrdXrootdProtocol * | protP, |
XrdXrootdResponse & | resp, | ||
XrdXrootdFile * | fP | ||
) |
|
pure virtual |
Implemented in XrdXrootdPgrwAio, and XrdXrootdNormAio.
|
pure virtual |
Implemented in XrdXrootdPgrwAio, and XrdXrootdNormAio.
|
protected |
|
protected |
|
inline |
|
protected |
|
private |
|
pure virtual |
Implemented in XrdXrootdPgrwAio, and XrdXrootdNormAio.
|
friend |
union { ... } |
union { ... } |
|
staticprotected |
|
staticprotected |
|
protected |
|
staticprotected |
|
staticprotected |
|
protected |
|
staticprotected |
|
protected |
|
protected |
|
protected |
|
protected |
|
protected |
XrdXrootdAioBuff* XrdXrootdAioTask::finalRead |
|
protected |
|
protected |
|
protected |
XrdXrootdNormAio* XrdXrootdAioTask::nextNorm |
XrdXrootdPgrwAio* XrdXrootdAioTask::nextPgrw |
XrdXrootdAioTask* XrdXrootdAioTask::nextTask |
|
staticprotected |
|
protected |
|
protected |
XrdXrootdAioBuff* XrdXrootdAioTask::pendWrite |
|
protected |
|
protected |
|
staticprotected |
|
protected |
|
staticprotected |
|
staticprotected |