#include <XrdEcReader.hh>
◆ dataarchs_t
◆ metadata_t
◆ missing_t
◆ urlmap_t
◆ Reader()
XrdEc::Reader::Reader |
( |
ObjCfg & |
objcfg | ) |
|
|
inline |
Constructor
- Parameters
-
objcfg | : configuration for the data object (e.g. number of data and parity stripes) |
◆ ~Reader()
virtual XrdEc::Reader::~Reader |
( |
| ) |
|
|
virtual |
◆ AddMissing()
void XrdEc::Reader::AddMissing |
( |
const buffer_t & |
cdbuff | ) |
|
|
private |
Add all the entries from given Central Directory to missing
- Parameters
-
cdbuff | : buffer containing central directory |
◆ Close()
◆ ErrorCorrected()
static callback_t XrdEc::Reader::ErrorCorrected |
( |
Reader * |
reader, |
|
|
std::shared_ptr< block_t > & |
self, |
|
|
size_t |
blkid, |
|
|
size_t |
strpid |
|
) |
| |
|
inlinestaticprivate |
◆ GetSize()
uint64_t XrdEc::Reader::GetSize |
( |
| ) |
|
|
inline |
- Returns
- : get file size
References filesize.
◆ IsMissing()
bool XrdEc::Reader::IsMissing |
( |
const std::string & |
fn | ) |
|
|
private |
Check if chunk file name is missing.
◆ MissingVectorRead()
void XrdEc::Reader::MissingVectorRead |
( |
std::shared_ptr< block_t > & |
block, |
|
|
size_t |
blkid, |
|
|
size_t |
strpid, |
|
|
uint16_t |
timeout = 0 |
|
) |
| |
|
private |
◆ Open()
Open the erasure coded / striped object
- Parameters
-
◆ ParseMetadata()
Parse metadata from chunk info object
- Parameters
-
ch | : chunk info object returned by a read operation |
◆ Read() [1/2]
void XrdEc::Reader::Read |
( |
size_t |
blknb, |
|
|
size_t |
strpnb, |
|
|
buffer_t & |
buffer, |
|
|
callback_t |
cb, |
|
|
uint16_t |
timeout = 0 |
|
) |
| |
|
private |
Read data from given stripes from given block
- Parameters
-
blknb | : number of the block |
strpnb | : number of stripe in the block |
buffer | : buffer for the data |
cb | : callback |
timeout | : operation timeout |
◆ Read() [2/2]
void XrdEc::Reader::Read |
( |
uint64_t |
offset, |
|
|
uint32_t |
length, |
|
|
void * |
buffer, |
|
|
XrdCl::ResponseHandler * |
handler, |
|
|
uint16_t |
timeout |
|
) |
| |
Read data from the data object
- Parameters
-
offset | : offset of the data to be read |
length | : length of the data to be read |
buffer | : buffer for the data to be read |
handler | : user callback |
◆ ReadMetadata()
Read metadata for the object
- Parameters
-
◆ ReadSize()
Read size from xattr
- Parameters
-
◆ VectorRead()
◆ ::MicroTest
◆ ::XrdEcTests
friend class ::XrdEcTests |
|
friend |
◆ block_t
◆ archiveIndices
std::map<std::string, size_t> XrdEc::Reader::archiveIndices |
|
private |
◆ blkmtx
std::mutex XrdEc::Reader::blkmtx |
|
private |
◆ block
std::shared_ptr<block_t> XrdEc::Reader::block |
|
private |
◆ dataarchs
◆ filesize
uint64_t XrdEc::Reader::filesize |
|
private |
◆ lstblk
size_t XrdEc::Reader::lstblk |
|
private |
◆ metadata
◆ missing
◆ missingChunksMutex
std::mutex XrdEc::Reader::missingChunksMutex |
|
private |
◆ missingChunksVectorRead
std::vector<std::tuple<size_t, size_t> > XrdEc::Reader::missingChunksVectorRead |
|
private |
◆ objcfg
◆ urlmap
◆ waitMissing
std::condition_variable XrdEc::Reader::waitMissing |
|
private |
The documentation for this class was generated from the following file: