![]() |
CernVM-FS
2.13.0
|
#include <item.h>
Public Member Functions | |
ChunkItem (FileItem *file_item, uint64_t offset) | |
void | MakeBulkChunk () |
bool | IsSolePiece () |
bool | is_bulk_chunk () |
FileItem * | file_item () |
uint64_t | offset () |
uint64_t | size () |
upload::UploadStreamHandle * | upload_handle () |
zlib::Compressor * | GetCompressor () |
void | ReleaseCompressor () |
shash::ContextPtr | hash_ctx () |
shash::Any * | hash_ptr () |
void | set_size (uint64_t val) |
void | set_upload_handle (upload::UploadStreamHandle *val) |
Private Attributes | |
FileItem * | file_item_ |
uint64_t | offset_ |
uint64_t | size_ |
bool | is_bulk_chunk_ |
upload::UploadStreamHandle * | upload_handle_ |
UniquePtr< zlib::Compressor > | compressor_ |
shash::ContextPtr | hash_ctx_ |
shash::Any | hash_value_ |
unsigned char | hash_ctx_buffer_ [shash::kMaxContextSize] |
Additional Inherited Members | |
![]() | |
SingleCopy () | |
A chunk stores the state of compression and hashing contexts as the blocks move through the pipeline. A chunk can be a "bulk chunk" corresponding to the processed data of an entire file, or it can be a partial chunk of a (large) input file.
ChunkItem::ChunkItem | ( | FileItem * | file_item, |
uint64_t | offset | ||
) |
|
inline |
Definition at line 135 of file item.h.
Referenced by TaskWrite::OnChunkComplete().
zlib::Compressor * ChunkItem::GetCompressor | ( | ) |
Definition at line 93 of file item.cc.
Referenced by TaskCompress::Process().
|
inline |
Definition at line 145 of file item.h.
Referenced by TaskHash::Process().
|
inline |
Definition at line 146 of file item.h.
Referenced by TaskWrite::OnChunkComplete(), TaskHash::Process(), and TaskWrite::Process().
|
inline |
Definition at line 130 of file item.h.
Referenced by TaskWrite::Process().
void ChunkItem::MakeBulkChunk | ( | ) |
Definition at line 87 of file item.cc.
Referenced by TaskWrite::Process(), and TaskChunk::Process().
|
inline |
Definition at line 136 of file item.h.
Referenced by TaskWrite::OnChunkComplete(), and TaskChunk::Process().
void ChunkItem::ReleaseCompressor | ( | ) |
Definition at line 102 of file item.cc.
Referenced by TaskCompress::Process().
|
inline |
Definition at line 148 of file item.h.
Referenced by TaskChunk::Process().
|
inline |
Definition at line 149 of file item.h.
Referenced by TaskWrite::Process().
|
inline |
Definition at line 137 of file item.h.
Referenced by TaskWrite::OnChunkComplete().
|
inline |
Definition at line 138 of file item.h.
Referenced by TaskWrite::Process().
|
private |
Definition at line 167 of file item.h.
Referenced by GetCompressor(), and ReleaseCompressor().
|
private |
Definition at line 155 of file item.h.
Referenced by ChunkItem(), file_item(), GetCompressor(), IsSolePiece(), and MakeBulkChunk().
|
private |
Definition at line 168 of file item.h.
Referenced by ChunkItem(), and hash_ctx().
|
private |
Definition at line 170 of file item.h.
Referenced by ChunkItem().
|
private |
Definition at line 169 of file item.h.
Referenced by ChunkItem(), hash_ptr(), and MakeBulkChunk().
|
private |
Definition at line 162 of file item.h.
Referenced by is_bulk_chunk(), IsSolePiece(), and MakeBulkChunk().
|
private |
Definition at line 156 of file item.h.
Referenced by IsSolePiece(), and offset().
|
private |
The size of a chunk is not defined before the corresponding stop block has been dispatched.
Definition at line 161 of file item.h.
Referenced by IsSolePiece(), set_size(), and size().
|
private |
Deleted by the uploader.
Definition at line 166 of file item.h.
Referenced by set_upload_handle(), and upload_handle().