![]() |
XRootD
|
#include <XrdPosixFileRH.hh>
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) |
![]() | |
XrdJob (const char *desc="") | |
virtual | ~XrdJob () |
![]() | |
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 ResponseHandler * | Wrap (std::function< void(XRootDStatus &, AnyObject &)> func) |
static ResponseHandler * | Wrap (std::function< void(XRootDStatus *, AnyObject *)> func) |
Additional Inherited Members | |
![]() | |
const char * | Comment |
XrdJob * | NextJob |
Definition at line 47 of file XrdPosixFileRH.hh.
Enumerator | |
---|---|
nonIO | |
isRead | |
isReadV | |
isWrite | |
isReadP | |
isWriteP |
Definition at line 52 of file XrdPosixFileRH.hh.
|
static |
Definition at line 76 of file XrdPosixFileRH.cc.
References XrdSysMutex::Lock(), and XrdSysMutex::UnLock().
Referenced by XrdPosixFile::pgRead(), XrdPosixFile::pgWrite(), XrdPosixFile::Read(), XrdPosixFile::ReadV(), XrdPosixFile::Sync(), and XrdPosixFile::Write().
|
inlinevirtual |
Implements XrdJob.
Definition at line 58 of file XrdPosixFileRH.hh.
References Recycle().
|
virtual |
Called when a response to associated request arrives or an error occurs
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.
References XrdOucPgrwUtils::csCalc(), XrdPosixObject::ecMsg, 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(), XrdPosixGlobals::schedP, XrdScheduler::Schedule(), XrdPosixObject::unRef(), and XrdPosixFile::UpdtSize().
void XrdPosixFileRH::Recycle | ( | void | ) |
Definition at line 168 of file XrdPosixFileRH.cc.
References XrdSysMutex::Lock(), and XrdSysMutex::UnLock().
Referenced by DoIt().
void XrdPosixFileRH::Sched | ( | int | result | ) |
Definition at line 185 of file XrdPosixFileRH.cc.
References XrdSysThread::Run(), XrdPosixGlobals::schedP, and XrdScheduler::Schedule().
Referenced by XrdPosixFile::pgRead(), XrdPosixFile::pgWrite(), XrdPosixFile::Read(), XrdPosixFile::ReadV(), XrdPosixFile::Sync(), and XrdPosixFile::Write().
|
inline |
Definition at line 65 of file XrdPosixFileRH.hh.
Referenced by XrdPosixFile::pgRead(), and XrdPosixFile::pgWrite().
|
inlinestatic |
Definition at line 69 of file XrdPosixFileRH.hh.
Referenced by XrdPosixConfig::SetConfig().