XrdPssAioCB Class Reference

#include <XrdPssAioCB.hh>

Inheritance diagram for XrdPssAioCB:

Collaboration diagram for XrdPssAioCB:

Public Member Functions
virtual void	Complete (ssize_t Result)
void	Recycle ()
Public Member Functions inherited from XrdPosixCallBackIO
	XrdPosixCallBackIO ()
virtual	~XrdPosixCallBackIO ()
Public Member Functions inherited from XrdOucCacheIOCB
	XrdOucCacheIOCB ()
virtual	~XrdOucCacheIOCB ()

Static Public Member Functions
static XrdPssAioCB *	Alloc (XrdSfsAio *aiop, bool isWr, bool pgrw=false)
static void	SetMax (int mval)

Public Attributes
std::vector< uint32_t >	csVec

Detailed Description

Definition at line 41 of file XrdPssAioCB.hh.

Member Function Documentation

Alloc()

XrdPssAioCB * XrdPssAioCB::Alloc ( XrdSfsAio *  aiop, bool  isWr, bool  pgrw = false  )

static

Definition at line 49 of file XrdPssAioCB.cc.

{
   XrdPssAioCB *newCB;
 
// Try to allocate an prexisting object otherwise get a new one
//
   myMutex.Lock();
   if ((newCB = freeCB)) {freeCB = newCB->next; numFree--;}
      else newCB = new XrdPssAioCB;
   myMutex.UnLock();
 
// Initialize the callback and return it
//
   newCB->theAIOP = aiop;
   newCB->isWrite = isWr;
   newCB->isPGrw  = pgrw;
   return newCB;
}

References XrdSysMutex::Lock(), and XrdSysMutex::UnLock().

Referenced by XrdPssFile::Fsync(), XrdPssFile::pgRead(), XrdPssFile::pgWrite(), XrdPssFile::Read(), and XrdPssFile::Write().

Here is the call graph for this function:

Here is the caller graph for this function:

Complete()

void XrdPssAioCB::Complete ( ssize_t  Result )

virtual

Implements XrdPosixCallBackIO.

Definition at line 73 of file XrdPssAioCB.cc.

{
 
// Set correct result
//
// std::cerr <<"AIO fin " <<(isWrite ? " write ":" read ")
//           <<theAIOP->sfsAio.aio_nbytes <<'@' <<theAIOP->sfsAio.aio_offset
//           <<" result " <<result <<std::endl;
   theAIOP->Result = (result < 0 ? -errno : result);
 
// Perform post processing for pgRead or pgWrite if successful
//
   if (isPGrw && result >= 0)
      {if (isWrite)
          {
          } else {
           if (csVec.size() && theAIOP->cksVec)
           memcpy(theAIOP->cksVec, csVec.data(), csVec.size()*sizeof(uint32_t));
          }
      }
 
// Invoke the callback
//
   if (isWrite) theAIOP->doneWrite();
      else      theAIOP->doneRead();
 
// Now recycle ourselves
//
   Recycle();
}

References csVec, and Recycle().

Here is the call graph for this function:

Recycle()

void XrdPssAioCB::Recycle

(

void

)

Definition at line 108 of file XrdPssAioCB.cc.

{
// Perform recycling
//
   myMutex.Lock();
   if (numFree >= maxFree) delete this;
      else {next   = freeCB;
            freeCB = this;
            numFree++;
            csVec.clear();
           }
   myMutex.UnLock();
}

References csVec, XrdSysMutex::Lock(), and XrdSysMutex::UnLock().

Referenced by Complete().

Here is the call graph for this function:

Here is the caller graph for this function:

SetMax()

static void XrdPssAioCB::SetMax ( int  mval )

inlinestatic

Definition at line 51 of file XrdPssAioCB.hh.

{maxFree = mval;}

Member Data Documentation

csVec

std::vector<uint32_t> XrdPssAioCB::csVec

Definition at line 53 of file XrdPssAioCB.hh.

Referenced by Complete(), XrdPssFile::pgRead(), XrdPssFile::pgWrite(), and Recycle().

---

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

• XrdPssAioCB.hh
• XrdPssAioCB.cc