|
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 |
Public Member Functions inherited from XrdJob | |
| 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 | |
Public Attributes inherited from XrdJob | |
| 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 |
1.8.5