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 |
![]() | |
void | Completed (XrdXrootdAioBuff *aioP) |
const char * | ID () |
void | Init (XrdXrootdProtocol *protP, XrdXrootdResponse &resp, XrdXrootdFile *fP) |
XrdXrootdProtocol * | urProtocol () |
![]() | |
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 | |
![]() | |
XrdJob * | NextJob |
const char * | Comment |
![]() | |
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) |
![]() | |
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 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 |