XrdOssCsiFileAioJob Class Reference

#include <XrdOssCsiFileAio.hh>

Inheritance diagram for XrdOssCsiFileAioJob:

Collaboration diagram for XrdOssCsiFileAioJob:

Public Member Functions
	XrdOssCsiFileAioJob ()
virtual	~XrdOssCsiFileAioJob ()
void	DoIt ()
void	DoItRead1 ()
void	DoItRead2 ()
void	DoItWrite1 ()
void	DoItWrite2 ()
void	Init (XrdOssCsiFile *fp, XrdOssCsiFileAio *nio, XrdSfsAio *aiop, bool isPg, bool read)
void	PrepareRead2 ()
void	PrepareWrite2 ()
Public Member Functions inherited from XrdJob
	XrdJob (const char *desc="")
virtual	~XrdJob ()

Additional Inherited Members
Public Attributes inherited from XrdJob
const char *	Comment
XrdJob *	NextJob

Detailed Description

Definition at line 42 of file XrdOssCsiFileAio.hh.

Constructor & Destructor Documentation

XrdOssCsiFileAioJob()

XrdOssCsiFileAioJob::XrdOssCsiFileAioJob ( )

inline

Definition at line 46 of file XrdOssCsiFileAio.hh.

{ }

~XrdOssCsiFileAioJob()

virtual XrdOssCsiFileAioJob::~XrdOssCsiFileAioJob ( )

inlinevirtual

Definition at line 47 of file XrdOssCsiFileAio.hh.

{ }

Member Function Documentation

DoIt()

void XrdOssCsiFileAioJob::DoIt ( )

inlinevirtual

Implements XrdJob.

Definition at line 69 of file XrdOssCsiFileAio.hh.

   {
      switch(jobtype_)
      {
         case JobReadStep1:
            // take rangelock, then submit aio read
            DoItRead1();
            break;
 
         case JobReadStep2:
            // fetch any extra bytes then verify/fetch csvec
            DoItRead2();
            break;
 
         case JobWriteStep1:
            // lock byte range, update/store csvec and queue aio write
            DoItWrite1();
            break;
 
         case JobWriteStep2:
            // check return from aio write, write any extra
            DoItWrite2();
            break;
      }
   }

References DoItRead1(), DoItRead2(), DoItWrite1(), and DoItWrite2().

Here is the call graph for this function:

DoItRead1()

void XrdOssCsiFileAioJob::DoItRead1

(

)

Definition at line 285 of file XrdOssCsiFileAio.hh.

{
   // this job takes rangelock and then queues aio read
 
   // lock range
   fp_->Pages()->LockTrackinglen(nio_->rg_, (off_t)aiop_->sfsAio.aio_offset,
                                (off_t)(aiop_->sfsAio.aio_offset+aiop_->sfsAio.aio_nbytes), true);
 
   const int ret = fp_->successor_->Read(nio_);
   if (ret<0)
   {
      aiop_->Result = ret;
      aiop_->doneRead();
      nio_->Recycle();
      return;
   }
}

Referenced by DoIt().

Here is the caller graph for this function:

DoItRead2()

void XrdOssCsiFileAioJob::DoItRead2

(

)

Definition at line 218 of file XrdOssCsiFileAio.hh.

{
   // this job runs after async Read
   // range was already locked read-only before the read
 
   if (aiop_->Result<0 || nio_->sfsAio.aio_nbytes==0)
   {
      aiop_->doneRead();
      nio_->Recycle();
      return;
   }
 
   // if this is a pg operation and this was a short read, try to complete,
   // otherwise caller will have to deal with joining csvec values from repeated reads
 
   ssize_t toread = nio_->sfsAio.aio_nbytes - nio_->Result;
   ssize_t nread = nio_->Result;
 
   if (!pg_)
   {
      // not a pg operation, no need to read more
      toread = 0;
   }
   char *p = (char*)nio_->sfsAio.aio_buf;
   while(toread>0)
   {
      const ssize_t rret = fp_->successor_->Read(&p[nread], nio_->sfsAio.aio_offset+nread, toread);
      if (rret == 0) break;
      if (rret<0)
      {
         aiop_->Result = rret;
         aiop_->doneRead();
         nio_->Recycle();
         return;
      }
      toread -= rret;
      nread += rret;
   }
   aiop_->Result = nread;
 
   ssize_t puret;
   if (pg_)
   {
      puret = fp_->Pages()->FetchRange(fp_->successor_,
                                      (void *)nio_->sfsAio.aio_buf,
                                      (off_t)nio_->sfsAio.aio_offset,
                                      (size_t)nio_->Result,
                                      (uint32_t*)nio_->cksVec,
                                      nio_->pgOpts_,
                                      nio_->rg_);
   }
   else
   {
      puret = fp_->Pages()->VerifyRange(fp_->successor_,
                                       (void *)nio_->sfsAio.aio_buf,
                                       (off_t)nio_->sfsAio.aio_offset,
                                       (size_t)nio_->Result,
                                       nio_->rg_);
   }
   if (puret<0)
   {
      aiop_->Result = puret;
   }
   aiop_->doneRead();
   nio_->Recycle();
}

References aiocb::aio_nbytes, and XrdSfsAio::sfsAio.

Referenced by DoIt().

Here is the caller graph for this function:

DoItWrite1()

void XrdOssCsiFileAioJob::DoItWrite1

(

)

Definition at line 303 of file XrdOssCsiFileAio.hh.

{
   // this job runs before async Write
 
   // lock range
   fp_->Pages()->LockTrackinglen(nio_->rg_, (off_t)aiop_->sfsAio.aio_offset,
                                (off_t)(aiop_->sfsAio.aio_offset+aiop_->sfsAio.aio_nbytes), false);
   int puret;
   if (pg_) {
      puret = fp_->Pages()->StoreRange(fp_->successor_,
                                      (const void *)aiop_->sfsAio.aio_buf, (off_t)aiop_->sfsAio.aio_offset,
                                      (size_t)aiop_->sfsAio.aio_nbytes, (uint32_t*)aiop_->cksVec, nio_->pgOpts_, nio_->rg_);
 
   }
   else
   {
      puret = fp_->Pages()->UpdateRange(fp_->successor_,
                                       (const void *)aiop_->sfsAio.aio_buf, (off_t)aiop_->sfsAio.aio_offset,
                                       (size_t)aiop_->sfsAio.aio_nbytes, nio_->rg_);
   }
   if (puret<0)
   {
      nio_->rg_.ReleaseAll();
      fp_->resyncSizes();
      aiop_->Result = puret;
      aiop_->doneWrite();
      nio_->Recycle();
      return;
   }
 
   const int ret = fp_->successor_->Write(nio_);
   if (ret<0)
   {
      nio_->rg_.ReleaseAll();
      fp_->resyncSizes();
      aiop_->Result = ret;
      aiop_->doneWrite();
      nio_->Recycle();
      return;
   }
}

Referenced by DoIt().

Here is the caller graph for this function:

DoItWrite2()

void XrdOssCsiFileAioJob::DoItWrite2

(

)

Definition at line 345 of file XrdOssCsiFileAio.hh.

{
   // this job runs after the async Write
 
   if (aiop_->Result<0)
   {
      nio_->rg_.ReleaseAll();
      fp_->resyncSizes();
      aiop_->doneWrite();
      nio_->Recycle();
      return;
   }
 
   // in case there was a short write during the async write, finish
   // writing the data now, otherwise the crc values will be inconsistent
   ssize_t towrite = nio_->sfsAio.aio_nbytes - nio_->Result;
   ssize_t nwritten = nio_->Result;
   const char *p = (const char*)nio_->sfsAio.aio_buf;
   while(towrite>0)
   {
      const ssize_t wret = fp_->successor_->Write(&p[nwritten], nio_->sfsAio.aio_offset+nwritten, towrite);
      if (wret<0)
      {
         aiop_->Result = wret;
         nio_->rg_.ReleaseAll();
         fp_->resyncSizes();
         aiop_->doneWrite();
         nio_->Recycle();
         return;
      }
      towrite -= wret;
      nwritten += wret;
   }
   aiop_->Result = nwritten;
   aiop_->doneWrite();
   nio_->Recycle();
}

Referenced by DoIt().

Here is the caller graph for this function:

Init()

void XrdOssCsiFileAioJob::Init ( XrdOssCsiFile * fp, XrdOssCsiFileAio * nio, XrdSfsAio * aiop, bool isPg, bool read )

inline

Definition at line 49 of file XrdOssCsiFileAio.hh.

   {
      fp_   = fp;
      nio_  = nio;
      aiop_ = aiop;
      pg_   = isPg;
      read_ = read;
      jobtype_ = (read_) ? JobReadStep1 : JobWriteStep1;
   }

References read.

PrepareRead2()

void XrdOssCsiFileAioJob::PrepareRead2 ( )

inline

Definition at line 64 of file XrdOssCsiFileAio.hh.

   {
      jobtype_ = JobReadStep2;
   }

PrepareWrite2()

void XrdOssCsiFileAioJob::PrepareWrite2 ( )

inline

Definition at line 59 of file XrdOssCsiFileAio.hh.

   {
      jobtype_ = JobWriteStep2;
   }

---

The documentation for this class was generated from the following file:

• XrdOssCsiFileAio.hh