xrootd
|
#include <XrdXrootdNormAio.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 XrdXrootdNormAio * | Alloc (XrdXrootdProtocol *protP, XrdXrootdResponse &resp, XrdXrootdFile *fP) |
Private Member Functions | |
XrdXrootdNormAio () | |
virtual | ~XrdXrootdNormAio () |
bool | CopyF2L_Add2Q (XrdXrootdAioBuff *aioP=0) |
void | CopyF2L () override |
int | CopyL2F () override |
bool | CopyL2F (XrdXrootdAioBuff *aioP) override |
bool | Send (XrdXrootdAioBuff *aioP, bool final=false) |
Private Attributes | |
XrdXrootdAioBuff * | sendQ |
off_t | sendOffset |
int | reorders |
bool | didSched |
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 |
|
overridevirtual |
Implements XrdXrootdAioTask.
|
private |
|
private |
|
private |
|
private |
|
staticprivate |