XrdPosixFileRH Class Reference

#include <XrdPosixFileRH.hh>

Inheritance diagram for XrdPosixFileRH:

Collaboration diagram for XrdPosixFileRH:

Public Types
enum	ioType {   nonIO = 0 ,   isRead = 1 ,   isReadV = 2 ,   isWrite = 3 ,   isReadP = 4 ,   isWriteP = 5 }

Public Member Functions
void	DoIt ()
void	HandleResponse (XrdCl::XRootDStatus *status, XrdCl::AnyObject *response)
void	Recycle ()
void	Sched (int result)
void	setCSVec (std::vector< uint32_t > *csv, int *csf, bool fcs=false)
Public Member Functions inherited from XrdJob
	XrdJob (const char *desc="")
virtual	~XrdJob ()
Public Member Functions inherited from XrdCl::ResponseHandler
virtual	~ResponseHandler ()
virtual void	HandleResponseWithHosts (XRootDStatus *status, AnyObject *response, HostList *hostList)

Static Public Member Functions
static XrdPosixFileRH *	Alloc (XrdOucCacheIOCB *cbp, XrdPosixFile *fp, long long offs, int xResult, ioType typeIO)
static void	SetMax (int mval)
Static Public Member Functions inherited from XrdCl::ResponseHandler
static ResponseHandler *	Wrap (std::function< void(XRootDStatus &, AnyObject &)> func)
static ResponseHandler *	Wrap (std::function< void(XRootDStatus *, AnyObject *)> func)

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

Detailed Description

Definition at line 47 of file XrdPosixFileRH.hh.

Member Enumeration Documentation

ioType

enum XrdPosixFileRH::ioType

Enumerator
nonIO
isRead
isReadV
isWrite
isReadP
isWriteP

Definition at line 52 of file XrdPosixFileRH.hh.

            {nonIO = 0, isRead = 1, isReadV = 2, isWrite = 3,
                                    isReadP = 4, isWriteP= 5};

Member Function Documentation

Alloc()

XrdPosixFileRH * XrdPosixFileRH::Alloc ( XrdOucCacheIOCB * cbp, XrdPosixFile * fp, long long offs, int xResult, ioType typeIO )

static

Definition at line 76 of file XrdPosixFileRH.cc.

{
   XrdPosixFileRH *newCB;
 
// Try to allocate an prexisting object otherwise get a new one
//
   myMutex.Lock();
   if ((newCB = freeRH)) {freeRH = newCB->next; numFree--;}
      else newCB = new XrdPosixFileRH;
   myMutex.UnLock();
 
// Initialize the callback and return it
//
   newCB->theCB   = cbp;
   newCB->theFile = fp;
   newCB->csVec   = 0;
   newCB->csfix   = 0;
   newCB->offset  = offs;
   newCB->result  = xResult;
   newCB->typeIO  = typeIO;
   newCB->csFrc   = false;
   return newCB;
}

Referenced by XrdPosixFile::pgRead(), XrdPosixFile::pgWrite(), XrdPosixFile::Read(), XrdPosixFile::ReadV(), XrdPosixFile::Sync(), and XrdPosixFile::Write().

Here is the caller graph for this function:

DoIt()

void XrdPosixFileRH::DoIt ( )

inlinevirtual

Implements XrdJob.

Definition at line 58 of file XrdPosixFileRH.hh.

{theCB->Done(result); Recycle();}

References Recycle().

Here is the call graph for this function:

HandleResponse()

void XrdPosixFileRH::HandleResponse ( XrdCl::XRootDStatus * status, XrdCl::AnyObject * response )

virtual

Called when a response to associated request arrives or an error occurs

Parameters

status	status of the request
response	an object associated with the response (request dependent)

Reimplemented from XrdCl::ResponseHandler.

Definition at line 108 of file XrdPosixFileRH.cc.

{
 
// Determine ending status. Note: error indicated as result set to -errno.
//
        if (!(status->IsOK()))
           result = XrdPosixMap::Result(*status, theFile->ecMsg, false);
   else if (typeIO == nonIO) result = 0;
   else if (typeIO == isRead)
           {XrdCl::ChunkInfo *cInfo = 0;
            union {uint32_t ubRead; int ibRead;};
            response->Get(cInfo);
            ubRead = (cInfo ? cInfo->length : 0);
            result = ibRead;
           }
   else if (typeIO == isReadP)
           {XrdCl::PageInfo *pInfo = 0;
            union {uint32_t ubRead; int ibRead;};
            response->Get(pInfo);
            if (pInfo)
               {ubRead = pInfo->GetLength();
                result = ibRead;
                if (csVec) 
                   {if (!csFrc || pInfo->GetCksums().size() != 0 || result <= 0)
                       *csVec = std::move(pInfo->GetCksums() );
                       else {uint64_t offs = pInfo->GetOffset();
                             void *buff = pInfo->GetBuffer();
                             XrdOucPgrwUtils::csCalc((const char *)buff,
                                                     (ssize_t)offs, ubRead,
                                                     *csVec);
                            }
                    csVec = 0;
                   }
                if (csfix) *csfix = pInfo->GetNbRepair();
               } else {
                result = 0;
                if (csVec) {csVec->clear(); csVec = 0;}
               }
           }
   else if (typeIO == isWrite) theFile->UpdtSize(offset+result);
 
// Get rid of things we don't need
//
   delete status;
   delete response;
 
// Now schedule our XrdOucCacheIOCB callback
//
   theFile->unRef();
   if (XrdPosixGlobals::schedP) XrdPosixGlobals::schedP->Schedule(this);
      else {pthread_t tid;
            XrdSysThread::Run(&tid, callDoIt, this, 0, "PosixFileRH");
           }
}

References XrdOucPgrwUtils::csCalc(), XrdCl::AnyObject::Get(), XrdCl::PageInfo::GetBuffer(), XrdCl::PageInfo::GetCksums(), XrdCl::PageInfo::GetLength(), XrdCl::PageInfo::GetNbRepair(), XrdCl::PageInfo::GetOffset(), XrdCl::Status::IsOK(), isRead, isReadP, isWrite, XrdCl::ChunkInfo::length, nonIO, XrdPosixMap::Result(), XrdSysThread::Run(), and XrdPosixGlobals::schedP.

Here is the call graph for this function:

Recycle()

void XrdPosixFileRH::Recycle

(

)

Definition at line 168 of file XrdPosixFileRH.cc.

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

Referenced by DoIt().

Here is the caller graph for this function:

Sched()

void XrdPosixFileRH::Sched

(

int

result

)

Definition at line 185 of file XrdPosixFileRH.cc.

{
// Set result
//
   result = rval;
 
// Now schedule this callback
//
   if (XrdPosixGlobals::schedP) XrdPosixGlobals::schedP->Schedule(this);
      else {pthread_t tid;
            XrdSysThread::Run(&tid, callDoIt, this, 0, "PosixFileRH");
           }
}

References XrdSysThread::Run(), and XrdPosixGlobals::schedP.

Referenced by XrdPosixFile::pgRead(), XrdPosixFile::pgWrite(), XrdPosixFile::Read(), XrdPosixFile::ReadV(), XrdPosixFile::Sync(), and XrdPosixFile::Write().

Here is the call graph for this function:

Here is the caller graph for this function:

setCSVec()

void XrdPosixFileRH::setCSVec ( std::vector< uint32_t > * csv, int * csf, bool fcs = false )

inline

Definition at line 65 of file XrdPosixFileRH.hh.

                                {csVec = csv; csfix = csf; csFrc = fcs;}

Referenced by XrdPosixFile::pgRead(), and XrdPosixFile::pgWrite().

Here is the caller graph for this function:

SetMax()

void XrdPosixFileRH::SetMax ( int mval )

inlinestatic

Definition at line 69 of file XrdPosixFileRH.hh.

{maxFree = mval;}

Referenced by XrdPosixConfig::SetConfig().

Here is the caller graph for this function:

---

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

• XrdPosixFileRH.hh
• XrdPosixFileRH.cc