1 #ifndef _XRDOSSCSIFILEAIO_H
2 #define _XRDOSSCSIFILEAIO_H
139 std::lock_guard<std::mutex> guard(
store_->
mtx_);
167 job_.
Init(file,
this, aiop, isPgOp, isread);
176 std::lock_guard<std::mutex> guard(store->
mtx_);
245 if (rret == 0)
break;
bool pg_
Definition: XrdOssCsiFileAio.hh:104
void SchedReadJob2()
Definition: XrdOssCsiFileAio.hh:194
XrdOssCsiRangeGuard rg_
Definition: XrdOssCsiFileAio.hh:114
XrdOssCsiFileAio * list_
Definition: XrdOssCsi.hh:53
size_t aio_nbytes
Definition: XrdSfsAio.hh:48
void aioDec()
Definition: XrdOssCsi.hh:120
uint32_t * cksVec
Definition: XrdSfsAio.hh:63
struct aiocb sfsAio
Definition: XrdSfsAio.hh:62
const char * TIdent
Definition: XrdSfsAio.hh:67
bool read_
Definition: XrdOssCsiFileAio.hh:105
void LockTrackinglen(XrdOssCsiRangeGuard &, off_t, off_t, bool)
virtual void doneRead()=0
Definition: XrdOssCsi.hh:46
virtual void doneWrite()=0
XrdSfsAio * parentaio_
Definition: XrdOssCsiFileAio.hh:210
void SchedWriteJob2()
Definition: XrdOssCsiFileAio.hh:183
Definition: XrdOssCsiFileAio.hh:106
Definition: XrdOssCsiFileAio.hh:109
void DoItRead2()
Definition: XrdOssCsiFileAio.hh:218
Definition: XrdScheduler.hh:45
XrdOssDF * successor_
Definition: XrdOssHandler.hh:81
virtual ~XrdOssCsiFileAioJob()
Definition: XrdOssCsiFileAio.hh:47
XrdOssCsiFileAioJob job_
Definition: XrdOssCsiFileAio.hh:213
uint64_t pgOpts_
Definition: XrdOssCsiFileAio.hh:115
virtual void doneWrite()
Definition: XrdOssCsiFileAio.hh:124
int FetchRange(XrdOssDF *, const void *, off_t, size_t, uint32_t *, uint64_t, XrdOssCsiRangeGuard &)
std::mutex mtx_
Definition: XrdOssCsi.hh:52
enum XrdOssCsiFileAioJob::@101 jobtype_
void PrepareRead2()
Definition: XrdOssCsiFileAio.hh:64
void aioInc()
Definition: XrdOssCsi.hh:111
XrdOssCsiFileAioJob()
Definition: XrdOssCsiFileAio.hh:46
XrdOssCsiPages * Pages()
Definition: XrdOssCsi.hh:140
XrdSfsAio * aiop_
Definition: XrdOssCsiFileAio.hh:103
XrdScheduler * Sched_
Definition: XrdOssCsiFileAio.hh:214
Definition: XrdOssCsi.hh:73
virtual void Recycle()
Definition: XrdOssCsiFileAio.hh:131
Definition: XrdOssCsiRanges.hh:57
Definition: XrdOssCsiFileAio.hh:106
int aio_reqprio
Definition: XrdSfsAio.hh:50
void Init(XrdSfsAio *aiop, XrdOssCsiFile *file, bool isPgOp, uint64_t opts, bool isread)
Definition: XrdOssCsiFileAio.hh:153
Definition: XrdOssCsiFileAio.hh:42
static XrdScheduler * Sched_
Definition: XrdOssCsi.hh:216
XrdOssCsiFile * fp_
Definition: XrdOssCsiFileAio.hh:101
virtual ssize_t Read(off_t offset, size_t size)
Definition: XrdOss.hh:281
void DoItWrite1()
Definition: XrdOssCsiFileAio.hh:303
Definition: XrdOssCsiFileAio.hh:106
XrdOssCsiFile * file_
Definition: XrdOssCsiFileAio.hh:211
int StoreRange(XrdOssDF *, const void *, off_t, size_t, uint32_t *, uint64_t, XrdOssCsiRangeGuard &)
int UpdateRange(XrdOssDF *, const void *, off_t, size_t, XrdOssCsiRangeGuard &)
void SchedReadJob()
Definition: XrdOssCsiFileAio.hh:200
~XrdOssCsiFileAio()
Definition: XrdOssCsiFileAio.hh:206
void SchedWriteJob()
Definition: XrdOssCsiFileAio.hh:189
off_t aio_offset
Definition: XrdSfsAio.hh:49
void PrepareWrite2()
Definition: XrdOssCsiFileAio.hh:59
void DoItRead1()
Definition: XrdOssCsiFileAio.hh:285
void Init(XrdOssCsiFile *fp, XrdOssCsiFileAio *nio, XrdSfsAio *aiop, bool isPg, bool read)
Definition: XrdOssCsiFileAio.hh:49
int VerifyRange(XrdOssDF *, const void *, off_t, size_t, XrdOssCsiRangeGuard &)
#define read(a, b, c)
Definition: XrdPosix.hh:77
Definition: XrdSfsAio.hh:58
void DoIt()
Definition: XrdOssCsiFileAio.hh:69
static XrdOssCsiFileAio * Alloc(XrdOssCsiFileAioStore *store)
Definition: XrdOssCsiFileAio.hh:171
Definition: XrdOssCsiFileAio.hh:106
ssize_t Result
Definition: XrdSfsAio.hh:65
bool isPgOp_
Definition: XrdOssCsiFileAio.hh:212
void DoItWrite2()
Definition: XrdOssCsiFileAio.hh:345
XrdOssCsiFileAio(XrdOssCsiFileAioStore *store)
Definition: XrdOssCsiFileAio.hh:205
virtual ssize_t Write(const void *buffer, off_t offset, size_t size)
Definition: XrdOss.hh:345
void * aio_buf
Definition: XrdSfsAio.hh:47
XrdOssCsiFileAio * next_
Definition: XrdOssCsiFileAio.hh:215
int aio_fildes
Definition: XrdSfsAio.hh:46
virtual void doneRead()
Definition: XrdOssCsiFileAio.hh:117
void Schedule(XrdJob *jp)
XrdOssCsiFileAio * nio_
Definition: XrdOssCsiFileAio.hh:102
XrdOssCsiFileAioStore * store_
Definition: XrdOssCsiFileAio.hh:209