XrdCl::EcHandler Class Reference

#include <XrdClEcHandler.hh>

Inheritance diagram for XrdCl::EcHandler:

Collaboration diagram for XrdCl::EcHandler:

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
Public Member Functions inherited from XrdCl::FilePlugIn
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

Constructor & Destructor Documentation

XrdCl::EcHandler::EcHandler ( const URL &  redir, XrdEc::ObjCfg *  objcfg, std::unique_ptr< CheckSumHelper >  cksHelper  )

inline

References XrdEc::Config::enable_plugins, and XrdEc::Config::Instance().

virtual XrdCl::EcHandler::~EcHandler ( )

inlinevirtual

Member Function Documentation

XRootDStatus XrdCl::EcHandler::Close ( ResponseHandler *  handler, uint16_t  timeout  )

inlinevirtual

See Also

XrdCl::File::Close

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.

bool XrdCl::EcHandler::IsOpen ( ) const

inlinevirtual

See Also

XrdCl::File::IsOpen

Reimplemented from XrdCl::FilePlugIn.

References reader, and writer.

XRootDStatus XrdCl::EcHandler::LoadPlacement ( )

inlineprivate

References 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::ServerSpaceInfo::SelectLocations(), and XrdCl::stError.

Referenced by Open().

XRootDStatus XrdCl::EcHandler::LoadPlacement ( const std::string &  path )

inlineprivate

References XrdCl::LocationInfo::At(), XrdCl::FileSystem::DeepLocate(), XrdCl::errInvalidOp, fs, XrdCl::LocationInfo::Location::GetAddress(), XrdCl::LocationInfo::GetSize(), XrdCl::FileSystem::GetXAttr(), XrdCl::Status::IsOK(), XrdCl::OpenFlags::None, objcfg, and XrdCl::stError.

XRootDStatus XrdCl::EcHandler::Open ( uint16_t  flags, ResponseHandler *  handler, uint16_t  timeout  )

inline

References XrdCl::OpenFlags::Delete, XrdCl::errNotSupported, XrdCl::URL::GetPath(), XrdCl::Status::IsOK(), LoadPlacement(), XrdCl::OpenFlags::New, objcfg, XrdCl::OpenFlags::Read, reader, redir, XrdCl::stError, XrdCl::OpenFlags::Update, XrdCl::OpenFlags::Write, and writer.

Referenced by Open().

XRootDStatus XrdCl::EcHandler::Open ( const std::string &  url, OpenFlags::Flags  flags, Access::Mode  mode, ResponseHandler *  handler, uint16_t  timeout  )

inlinevirtual

See Also

XrdCl::File::Open

Reimplemented from XrdCl::FilePlugIn.

References Open(), and nlohmann::detail::void().

XRootDStatus XrdCl::EcHandler::PgRead ( uint64_t  offset, uint32_t  size, void *  buffer, ResponseHandler *  handler, uint16_t  timeout  )

inlinevirtual

See Also

XrdCl::File::PgRead - async

Reimplemented from XrdCl::FilePlugIn.

References Read().

XRootDStatus XrdCl::EcHandler::PgWrite ( uint64_t  offset, uint32_t  size, const void *  buffer, std::vector< uint32_t > &  cksums, ResponseHandler *  handler, uint16_t  timeout = 0  )

inlinevirtual

See Also

XrdCl::File::PgWrite - async

Reimplemented from XrdCl::FilePlugIn.

References XrdOucPgrwUtils::csCalc(), XrdCl::errInvalidArgs, XrdCl::stError, and Write().

XRootDStatus XrdCl::EcHandler::Read ( uint64_t  offset, uint32_t  size, void *  buffer, ResponseHandler *  handler, uint16_t  timeout  )

inlinevirtual

See Also

XrdCl::File::Read

Reimplemented from XrdCl::FilePlugIn.

References XrdCl::errInternal, reader, and XrdCl::stError.

Referenced by PgRead().

static void XrdCl::EcHandler::Schedule ( ResponseHandler *  handler, AnyObject *  rsp  )

inlinestaticprivate

References XrdCl::PostMaster::GetJobManager(), XrdCl::DefaultEnv::GetPostMaster(), and XrdCl::JobManager::QueueJob().

Referenced by Stat().

XRootDStatus XrdCl::EcHandler::Stat ( bool  force, ResponseHandler *  handler, uint16_t  timeout  )

inlinevirtual

See Also

XrdCl::File::Stat

Reimplemented from XrdCl::FilePlugIn.

References XrdCl::errInvalidOp, fs, XrdCl::URL::GetPath(), objcfg, reader, redir, Schedule(), XrdCl::FileSystem::Stat(), statcache, StatRsp(), XrdCl::stError, and writer.

static AnyObject* XrdCl::EcHandler::StatRsp ( uint64_t  size )

inlinestaticprivate

References XrdCl::AnyObject::Set(), and XrdCl::StatInfo::SetSize().

Referenced by Stat().

XRootDStatus XrdCl::EcHandler::Write ( uint64_t  offset, uint32_t  size, const void *  buffer, ResponseHandler *  handler, uint16_t  timeout  )

inlinevirtual

See Also

File::Write

Reimplemented from XrdCl::FilePlugIn.

References cksHelper, curroff, XrdCl::errInternal, XrdCl::errNotSupported, XrdCl::stError, and writer.

Referenced by PgWrite().

Member Data Documentation

std::unique_ptr<CheckSumHelper> XrdCl::EcHandler::cksHelper

private

Referenced by Close(), and Write().

uint64_t XrdCl::EcHandler::curroff

private

Referenced by Close(), and Write().

FileSystem XrdCl::EcHandler::fs

private

Referenced by Close(), LoadPlacement(), and Stat().

std::unique_ptr<XrdEc::ObjCfg> XrdCl::EcHandler::objcfg

private

Referenced by Close(), LoadPlacement(), Open(), and Stat().

std::unique_ptr<XrdEc::Reader> XrdCl::EcHandler::reader

private

Referenced by Close(), IsOpen(), Open(), Read(), and Stat().

URL XrdCl::EcHandler::redir

private

Referenced by Close(), Open(), and Stat().

std::unique_ptr<StatInfo> XrdCl::EcHandler::statcache

private

Referenced by Stat().

std::unique_ptr<XrdEc::StrmWriter> XrdCl::EcHandler::writer

private

Referenced by Close(), IsOpen(), Open(), Stat(), and Write().

---

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

• XrdClEcHandler.hh