GCC Code Coverage Report

Directory: cvmfs/
File: cvmfs/ingestion/item.cc
Date: 2026-08-09 02:40:25
Exec Total Coverage
Lines: 142 142 100.0%
Branches: 35 64 54.7%
Line Branch Exec Source
1 /**
2 * This file is part of the CernVM File System.
3 */
4
5 #include "item.h"
6
7 #include <algorithm>
8 #include <cassert>
9 #include <cstdlib>
10 #include <cstring>
11
12 #include "ingestion/ingestion_source.h"
13 #include "item_mem.h"
14 #include "util/concurrency.h"
15 #include "util/smalloc.h"
16
17 9864836 FileItem::FileItem(IngestionSource *source,
18 uint64_t min_chunk_size,
19 uint64_t avg_chunk_size,
20 uint64_t max_chunk_size,
21 zlib::Algorithms compression_algorithm,
22 shash::Algorithms hash_algorithm,
23 shash::Suffix hash_suffix,
24 bool may_have_chunks,
25 9864836 bool has_legacy_bulk_chunk)
26 9864836 : source_(source)
27 9864836 , compression_algorithm_(compression_algorithm)
28 9864836 , hash_algorithm_(hash_algorithm)
29 9864836 , hash_suffix_(hash_suffix)
30 9864836 , has_legacy_bulk_chunk_(has_legacy_bulk_chunk)
31 9864836 , size_(kSizeUnknown)
32 9864836 , may_have_chunks_(may_have_chunks)
33
1/2
✓ Branch 1 taken 9864836 times.
✗ Branch 2 not taken.
 9864836 , chunk_detector_(min_chunk_size, avg_chunk_size, max_chunk_size)
34
1/2
✓ Branch 1 taken 9864836 times.
✗ Branch 2 not taken.
 9864836 , bulk_hash_(hash_algorithm)
35
1/2
✓ Branch 2 taken 9864836 times.
✗ Branch 3 not taken.
 19729672 , chunks_(1) {
36 9864836 const int retval = pthread_mutex_init(&lock_, NULL);
37
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 9864836 times.
 9864836 assert(retval == 0);
38 9864836 atomic_init64(&nchunks_in_fly_);
39 9864836 atomic_init32(&is_fully_chunked_);
40 9864836 }
41
42 9851657 FileItem::~FileItem() { pthread_mutex_destroy(&lock_); }
43
44 9770304 void FileItem::RegisterChunk(const FileChunk &file_chunk) {
45 9770304 const MutexLockGuard lock_guard(lock_);
46
47
2/2
✓ Branch 1 taken 17359 times.
✓ Branch 2 taken 9752945 times.
 9770304 switch (file_chunk.content_hash().suffix) {
48 17359 case shash::kSuffixPartial:
49
1/2
✓ Branch 1 taken 17359 times.
✗ Branch 2 not taken.
 17359 chunks_.PushBack(file_chunk);
50 17359 break;
51
52 9752945 default:
53
1/2
✗ Branch 1 not taken.
✓ Branch 2 taken 9752945 times.
 9752945 assert(file_chunk.offset() == 0);
54
1/2
✗ Branch 1 not taken.
✓ Branch 2 taken 9752945 times.
 9752945 assert(file_chunk.size() == size_);
55 9752945 bulk_hash_ = file_chunk.content_hash();
56 9752945 break;
57 }
58 9770304 atomic_dec64(&nchunks_in_fly_);
59 9770304 }
60
61
62 //------------------------------------------------------------------------------
63
64
65 9982754 ChunkItem::ChunkItem(FileItem *file_item, uint64_t offset)
66 9980492 : file_item_(file_item)
67 9980492 , offset_(offset)
68 9980492 , size_(0)
69 9980492 , is_bulk_chunk_(false)
70 9980492 , upload_handle_(NULL)
71
1/2
✓ Branch 4 taken 9980180 times.
✗ Branch 5 not taken.
 9982754 , compressor_(NULL) {
72 9980180 hash_ctx_.algorithm = file_item->hash_algorithm();
73
1/2
✓ Branch 1 taken 9978113 times.
✗ Branch 2 not taken.
 9979283 hash_ctx_.size = shash::GetContextSize(hash_ctx_.algorithm);
74 9978113 hash_ctx_.buffer = hash_ctx_buffer_;
75
1/2
✓ Branch 1 taken 9981467 times.
✗ Branch 2 not taken.
 9978113 shash::Init(hash_ctx_);
76 9981467 hash_value_.algorithm = hash_ctx_.algorithm;
77 9981467 hash_value_.suffix = shash::kSuffixPartial;
78 9981467 file_item_->IncNchunksInFly();
79 9985367 }
80
81
82 9742274 void ChunkItem::MakeBulkChunk() {
83 9742274 is_bulk_chunk_ = true;
84 9742274 hash_value_.suffix = file_item_->hash_suffix();
85 9739388 }
86
87
88 22706924 zlib::Compressor *ChunkItem::GetCompressor() {
89
2/2
✓ Branch 1 taken 9761218 times.
✓ Branch 2 taken 12945394 times.
 22706924 if (!compressor_.IsValid()) {
90 compressor_ = zlib::Compressor::Construct(
91
2/4
✓ Branch 2 taken 9767068 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 9764845 times.
✗ Branch 6 not taken.
 9761218 file_item_->compression_algorithm());
92 }
93 22710239 return compressor_.weak_ref();
94 }
95
96
97 9764962 void ChunkItem::ReleaseCompressor() { compressor_.Destroy(); }
98
99
100 //------------------------------------------------------------------------------
101
102 atomic_int64 BlockItem::managed_bytes_ = 0;
103
104
105 124384 BlockItem::BlockItem(ItemAllocator *allocator)
106 124384 : allocator_(allocator)
107 124384 , type_(kBlockHollow)
108 124384 , tag_(-1)
109 124384 , file_item_(NULL)
110 124384 , chunk_item_(NULL)
111 124384 , data_(NULL)
112 124384 , capacity_(0)
113 124384 , size_(0) { }
114
115
116 71774695 BlockItem::BlockItem(int64_t tag, ItemAllocator *allocator)
117 71716225 : allocator_(allocator)
118 71716225 , type_(kBlockHollow)
119 71716225 , tag_(tag)
120 71716225 , file_item_(NULL)
121 71716225 , chunk_item_(NULL)
122 71716225 , data_(NULL)
123 71716225 , capacity_(0)
124 71774695 , size_(0) {
125
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 71716225 times.
 71716225 assert(tag_ >= 0);
126 71716225 }
127
128
129 71940552 BlockItem::~BlockItem() {
130
2/2
✓ Branch 0 taken 30132618 times.
✓ Branch 1 taken 41807934 times.
 71940552 if (data_)
131 30132618 allocator_->Free(data_);
132 71950146 atomic_xadd64(&managed_bytes_, -static_cast<int64_t>(capacity_));
133 72022281 }
134
135
136 10743741 void BlockItem::Discharge() {
137 10743741 data_ = NULL;
138 10743741 size_ = capacity_ = 0;
139 10743741 }
140
141
142 29480509 void BlockItem::MakeStop() {
143
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 29480509 times.
 29480509 assert(type_ == kBlockHollow);
144 29480509 type_ = kBlockStop;
145 29480509 }
146
147
148 15077476 void BlockItem::MakeData(uint32_t capacity) {
149
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 15077476 times.
 15077476 assert(type_ == kBlockHollow);
150
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 15077476 times.
 15077476 assert(allocator_ != NULL);
151
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 15077476 times.
 15077476 assert(capacity > 0);
152
153 15077476 type_ = kBlockData;
154 15077476 capacity_ = capacity;
155 15077476 data_ = reinterpret_cast<unsigned char *>(allocator_->Malloc(capacity_));
156 15085744 atomic_xadd64(&managed_bytes_, static_cast<int64_t>(capacity_));
157 15085744 }
158
159
160 /**
161 * Move data from one block to another.
162 */
163 10739763 void BlockItem::MakeDataMove(BlockItem *other) {
164
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 10739763 times.
 10739763 assert(type_ == kBlockHollow);
165
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 10739763 times.
 10739763 assert(other->type_ == kBlockData);
166
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 10739763 times.
 10739763 assert(other->size_ > 0);
167
168 10739763 type_ = kBlockData;
169 10739763 capacity_ = size_ = other->size_;
170 10739763 data_ = other->data_;
171 10739763 allocator_ = other->allocator_;
172
173 10739763 other->Discharge();
174 10741167 }
175
176
177 /**
178 * Copy a piece of one block's data into a new block.
179 */
180 16530963 void BlockItem::MakeDataCopy(const unsigned char *data, uint32_t size) {
181
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 16530963 times.
 16530963 assert(type_ == kBlockHollow);
182
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 16530963 times.
 16530963 assert(allocator_ != NULL);
183
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 16530963 times.
 16530963 assert(size > 0);
184
185 16530963 type_ = kBlockData;
186 16530963 capacity_ = size_ = size;
187 16530963 data_ = reinterpret_cast<unsigned char *>(allocator_->Malloc(capacity_));
188 16559814 memcpy(data_, data, size);
189 16559814 atomic_xadd64(&managed_bytes_, static_cast<int64_t>(capacity_));
190 16552872 }
191
192
193 1508641 void BlockItem::Reset() {
194
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 1508641 times.
 1508641 assert(type_ == kBlockData);
195
196 1508641 atomic_xadd64(&managed_bytes_, -static_cast<int64_t>(capacity_));
197 1508992 allocator_->Free(data_);
198 1508953 data_ = NULL;
199 1508953 size_ = capacity_ = 0;
200 1508953 type_ = kBlockHollow;
201 1508953 }
202
203
204 49779840 void BlockItem::SetChunkItem(ChunkItem *value) {
205
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 49779840 times.
 49779840 assert(value != NULL);
206
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 49779840 times.
 49779840 assert(chunk_item_ == NULL);
207 49779840 chunk_item_ = value;
208 49779840 }
209
210
211 71683878 void BlockItem::SetFileItem(FileItem *value) {
212
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 71683878 times.
 71683878 assert(value != NULL);
213
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 71683878 times.
 71683878 assert(file_item_ == NULL);
214 71683878 file_item_ = value;
215 71683878 }
216
217
218 22528 uint32_t BlockItem::Write(void *buf, uint32_t count) {
219
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 22528 times.
 22528 assert(type_ == kBlockData);
220
221 22528 const uint32_t remaining = capacity_ - size_;
222 22528 const uint32_t nbytes = std::min(remaining, count);
223 22528 memcpy(data_ + size_, buf, nbytes);
224 22528 size_ += nbytes;
225 22528 return nbytes;
226 }
227