|
xrootd
|
#include <XrdXrootdPgrwAio.hh>


Public Member Functions | |
| void | DoIt () override |
| void | Read (long long offs, int dlen) override |
| void | Recycle (bool release) override |
| int | Write (long long offs, int dlen) override |
Public Member Functions inherited from XrdXrootdAioTask | |
| void | Completed (XrdXrootdAioBuff *aioP) |
| const char * | ID () |
| void | Init (XrdXrootdProtocol *protP, XrdXrootdResponse &resp, XrdXrootdFile *fP) |
| XrdXrootdProtocol * | urProtocol () |
Public Member Functions inherited from XrdJob | |
| XrdJob (const char *desc="") | |
| virtual | ~XrdJob () |
Static Public Member Functions | |
| static XrdXrootdPgrwAio * | Alloc (XrdXrootdProtocol *protP, XrdXrootdResponse &resp, XrdXrootdFile *fP, XrdXrootdPgwBadCS *bcsP=0) |
Static Public Attributes | |
| static const int | aioSZ = 64*1024 |
Private Member Functions | |
| XrdXrootdPgrwAio () | |
| virtual | ~XrdXrootdPgrwAio () |
| bool | CopyF2L_Add2Q (XrdXrootdAioPgrw *aioP=0) |
| void | CopyF2L () override |
| int | CopyL2F () override |
| bool | CopyL2F (XrdXrootdAioBuff *bP) override |
| bool | SendData (XrdXrootdAioBuff *bP, bool final=false) |
| int | SendDone () |
| bool | VerCks (XrdXrootdAioPgrw *aioP) |
Private Attributes | |
| XrdXrootdPgwBadCS * | badCSP |
Static Private Attributes | |
| static const char * | TraceID |
Additional Inherited Members | ||
Public Attributes inherited from XrdJob | ||
| XrdJob * | NextJob | |
| const char * | Comment | |
Protected Member Functions inherited from XrdXrootdAioTask | ||
| XrdXrootdAioTask (const char *what="aio request") | ||
| virtual | ~XrdXrootdAioTask () | |
| 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 inherited from XrdXrootdAioTask | ||
| 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 inherited from XrdXrootdAioTask | ||
| 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 | |
|
inlineprivate |
|
inlineprivatevirtual |
|
static |
|
overrideprivatevirtual |
Implements XrdXrootdAioTask.
|
private |
|
overrideprivatevirtual |
Implements XrdXrootdAioTask.
|
overrideprivatevirtual |
Implements XrdXrootdAioTask.
|
overridevirtual |
Implements XrdJob.
|
overridevirtual |
Implements XrdXrootdAioTask.
|
overridevirtual |
Implements XrdXrootdAioTask.
|
private |
|
private |
|
private |
|
overridevirtual |
Implements XrdXrootdAioTask.
|
static |
|
private |
|
staticprivate |