xrootd
|
#include <XrdClEcHandler.hh>
Public Member Functions | |
EcHandler (const URL &redir, XrdEc::ObjCfg *objcfg, std::unique_ptr< CheckSumHelper > cksHelper) | |
virtual | ~EcHandler () |
XRootDStatus | Open (uint16_t flags, ResponseHandler *handler, uint16_t timeout) |
XRootDStatus | Open (const std::string &url, OpenFlags::Flags flags, Access::Mode mode, ResponseHandler *handler, uint16_t timeout) |
XRootDStatus | Close (ResponseHandler *handler, uint16_t timeout) |
XRootDStatus | Stat (bool force, ResponseHandler *handler, uint16_t timeout) |
XRootDStatus | Read (uint64_t offset, uint32_t size, void *buffer, ResponseHandler *handler, uint16_t timeout) |
XRootDStatus | PgRead (uint64_t offset, uint32_t size, void *buffer, ResponseHandler *handler, uint16_t timeout) |
XRootDStatus | Write (uint64_t offset, uint32_t size, const void *buffer, ResponseHandler *handler, uint16_t timeout) |
XRootDStatus | PgWrite (uint64_t offset, uint32_t size, const void *buffer, std::vector< uint32_t > &cksums, ResponseHandler *handler, uint16_t timeout=0) |
bool | IsOpen () const |
![]() | |
virtual | ~FilePlugIn () |
Destructor. More... | |
virtual XRootDStatus | Read (uint64_t offset, uint32_t size, Optional< uint64_t > fdoff, int fd, ResponseHandler *handler, uint16_t timeout=0) |
virtual XRootDStatus | Write (uint64_t offset, Buffer &&buffer, ResponseHandler *handler, uint16_t timeout=0) |
virtual XRootDStatus | Write (uint64_t offset, uint32_t size, Optional< uint64_t > fdoff, int fd, ResponseHandler *handler, uint16_t timeout=0) |
virtual XRootDStatus | Sync (ResponseHandler *handler, uint16_t timeout) |
virtual XRootDStatus | Truncate (uint64_t size, ResponseHandler *handler, uint16_t timeout) |
virtual XRootDStatus | VectorRead (const ChunkList &chunks, void *buffer, ResponseHandler *handler, uint16_t timeout) |
virtual XRootDStatus | VectorWrite (const ChunkList &chunks, ResponseHandler *handler, uint16_t timeout=0) |
virtual XRootDStatus | WriteV (uint64_t offset, const struct iovec *iov, int iovcnt, ResponseHandler *handler, uint16_t timeout=0) |
virtual XRootDStatus | Fcntl (const Buffer &arg, ResponseHandler *handler, uint16_t timeout) |
virtual XRootDStatus | Visa (ResponseHandler *handler, uint16_t timeout) |
virtual bool | SetProperty (const std::string &name, const std::string &value) |
virtual bool | GetProperty (const std::string &name, std::string &value) const |
Private Member Functions | |
XRootDStatus | LoadPlacement () |
XRootDStatus | LoadPlacement (const std::string &path) |
Static Private Member Functions | |
static AnyObject * | StatRsp (uint64_t size) |
static void | Schedule (ResponseHandler *handler, AnyObject *rsp) |
Private Attributes | |
URL | redir |
FileSystem | fs |
std::unique_ptr< XrdEc::ObjCfg > | objcfg |
std::unique_ptr < XrdEc::StrmWriter > | writer |
std::unique_ptr< XrdEc::Reader > | reader |
uint64_t | curroff |
std::unique_ptr< CheckSumHelper > | cksHelper |
std::unique_ptr< StatInfo > | statcache |
|
inline |
References XrdEc::Config::enable_plugins, and XrdEc::Config::Instance().
|
inlinevirtual |
|
inlinevirtual |
Reimplemented from XrdCl::FilePlugIn.
References cksHelper, curroff, XrdCl::errNotSupported, XrdCl::Buffer::FromString(), fs, XrdCl::URL::GetPath(), XrdCl::ResponseHandler::HandleResponse(), XrdCl::Status::IsOK(), objcfg, XrdCl::QueryCode::OpaqueFile, XrdCl::FileSystem::Query(), reader, redir, XrdCl::stError, nlohmann::to_string(), XrdCl::ResponseHandler::Wrap(), and writer.
|
inlinevirtual |
|
inlineprivate |
References XrdCl::LocationInfo::Add(), XrdCl::LocationInfo::At(), XrdCl::LocationInfo::Begin(), XrdCl::FileSystem::DeepLocate(), XrdCl::LocationInfo::End(), XrdCl::errInvalidOp, fs, XrdCl::LocationInfo::GetSize(), XrdCl::Status::IsOK(), XrdCl::OpenFlags::None, objcfg, XrdCl::LocationInfo::ServerOnline, and XrdCl::stError.
Referenced by Open().
|
inlineprivate |
|
inline |
|
inlinevirtual |
Reimplemented from XrdCl::FilePlugIn.
References Open(), and nlohmann::detail::void().
|
inlinevirtual |
|
inlinevirtual |
Reimplemented from XrdCl::FilePlugIn.
References XrdOucPgrwUtils::csCalc(), XrdCl::errInvalidArgs, XrdCl::stError, and Write().
|
inlinevirtual |
Reimplemented from XrdCl::FilePlugIn.
References XrdCl::errInternal, reader, and XrdCl::stError.
Referenced by PgRead().
|
inlinestaticprivate |
References XrdCl::PostMaster::GetJobManager(), XrdCl::DefaultEnv::GetPostMaster(), and XrdCl::JobManager::QueueJob().
Referenced by Stat().
|
inlinevirtual |
Reimplemented from XrdCl::FilePlugIn.
References XrdCl::errInvalidOp, fs, XrdCl::URL::GetPath(), objcfg, reader, redir, Schedule(), XrdCl::FileSystem::Stat(), statcache, StatRsp(), XrdCl::stError, and writer.
|
inlinestaticprivate |
References XrdCl::AnyObject::Set(), and XrdCl::StatInfo::SetSize().
Referenced by Stat().
|
inlinevirtual |
Reimplemented from XrdCl::FilePlugIn.
References cksHelper, curroff, XrdCl::errInternal, XrdCl::errNotSupported, XrdCl::stError, and writer.
Referenced by PgWrite().
|
private |
|
private |
Referenced by Close(), LoadPlacement(), and Stat().
|
private |
Referenced by Close(), LoadPlacement(), Open(), and Stat().
|
private |
|
private |