GCC Code Coverage Report

Directory: cvmfs/
File: cvmfs/file_chunk.cc
Date: 2026-04-05 02:35:23
Exec Total Coverage
Lines: 108 136 79.4%
Branches: 63 110 57.3%
Line Branch Exec Source
1 /**
2 * This file is part of the CernVM File System.
3 */
4
5
6 #include "file_chunk.h"
7
8 #include <cassert>
9
10 #include "util/murmur.hxx"
11 #include "util/platform.h"
12
13 using namespace std; // NOLINT
14
15 ✗ static inline uint32_t hasher_uint64t(const uint64_t &value) {
16 ✗ return MurmurHash2(&value, sizeof(value), 0x07387a4f);
17 }
18
19
20 //------------------------------------------------------------------------------
21
22
23 480 unsigned FileChunkReflist::FindChunkIdx(const uint64_t off) {
24
2/4
✓ Branch 0 taken 480 times.
✗ Branch 1 not taken.
✓ Branch 3 taken 480 times.
✗ Branch 4 not taken.
 480 assert(list && (list->size() > 0));
25 480 unsigned idx_low = 0;
26 480 unsigned idx_high = list->size() - 1;
27 480 unsigned chunk_idx = idx_high / 2;
28
2/2
✓ Branch 0 taken 816 times.
✓ Branch 1 taken 384 times.
 1200 while (idx_low < idx_high) {
29
2/2
✓ Branch 2 taken 144 times.
✓ Branch 3 taken 672 times.
 816 if (static_cast<uint64_t>(list->AtPtr(chunk_idx)->offset()) > off) {
30
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 144 times.
 144 assert(idx_high > 0);
31 144 idx_high = chunk_idx - 1;
32 } else {
33 672 if ((chunk_idx == list->size() - 1)
34
5/6
✓ Branch 0 taken 672 times.
✗ Branch 1 not taken.
✓ Branch 4 taken 96 times.
✓ Branch 5 taken 576 times.
✓ Branch 6 taken 96 times.
✓ Branch 7 taken 576 times.
 672 || (static_cast<uint64_t>(list->AtPtr(chunk_idx + 1)->offset())
35 > off)) {
36 96 break;
37 }
38 576 idx_low = chunk_idx + 1;
39 }
40 720 chunk_idx = idx_low + (idx_high - idx_low) / 2;
41 }
42 480 return chunk_idx;
43 }
44
45
46 /**
47 * Returns a consistent hash over hashes of the chunks. Used by libcvmfs.
48 */
49 49 shash::Any FileChunkReflist::HashChunkList() {
50 49 const shash::Algorithms algo = list->AtPtr(0)->content_hash().algorithm;
51
1/2
✓ Branch 1 taken 49 times.
✗ Branch 2 not taken.
 49 shash::ContextPtr ctx(algo);
52 49 ctx.buffer = alloca(ctx.size);
53
1/2
✓ Branch 1 taken 49 times.
✗ Branch 2 not taken.
 49 shash::Init(ctx);
54
2/2
✓ Branch 1 taken 98 times.
✓ Branch 2 taken 49 times.
 147 for (unsigned i = 0; i < list->size(); ++i) {
55 98 shash::Update(
56
1/2
✓ Branch 3 taken 98 times.
✗ Branch 4 not taken.
 98 list->AtPtr(i)->content_hash().digest, shash::kDigestSizes[algo], ctx);
57 }
58
1/2
✓ Branch 1 taken 49 times.
✗ Branch 2 not taken.
 49 shash::Any result(algo);
59
1/2
✓ Branch 1 taken 49 times.
✗ Branch 2 not taken.
 49 shash::Final(ctx, &result);
60 98 return result;
61 }
62
63
64 //------------------------------------------------------------------------------
65
66
67 623 void ChunkTables::InitLocks() {
68 623 lock = reinterpret_cast<pthread_mutex_t *>(smalloc(sizeof(pthread_mutex_t)));
69 623 const int retval = pthread_mutex_init(lock, NULL);
70
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 623 times.
 623 assert(retval == 0);
71
72
2/2
✓ Branch 0 taken 79744 times.
✓ Branch 1 taken 623 times.
 80367 for (unsigned i = 0; i < kNumHandleLocks; ++i) {
73 pthread_mutex_t *m = reinterpret_cast<pthread_mutex_t *>(
74 79744 smalloc(sizeof(pthread_mutex_t)));
75 79744 const int retval = pthread_mutex_init(m, NULL);
76
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 79744 times.
 79744 assert(retval == 0);
77
1/2
✓ Branch 1 taken 79744 times.
✗ Branch 2 not taken.
 79744 handle_locks.PushBack(m);
78 }
79 623 }
80
81
82 623 void ChunkTables::InitHashmaps() {
83 623 handle2uniqino.Init(16, 0, hasher_uint64t);
84 623 handle2fd.Init(16, 0, hasher_uint64t);
85 623 inode2chunks.Init(16, 0, hasher_uint64t);
86 623 inode2references.Init(16, 0, hasher_uint64t);
87 623 }
88
89
90
4/8
✓ Branch 2 taken 623 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 623 times.
✗ Branch 6 not taken.
✓ Branch 8 taken 623 times.
✗ Branch 9 not taken.
✓ Branch 11 taken 623 times.
✗ Branch 12 not taken.
 623 ChunkTables::ChunkTables() {
91 623 next_handle = 2;
92 623 version = kVersion;
93
1/2
✓ Branch 1 taken 623 times.
✗ Branch 2 not taken.
 623 InitLocks();
94
1/2
✓ Branch 1 taken 623 times.
✗ Branch 2 not taken.
 623 InitHashmaps();
95 623 }
96
97
98 623 ChunkTables::~ChunkTables() {
99 623 pthread_mutex_destroy(lock);
100 623 free(lock);
101
2/2
✓ Branch 0 taken 79744 times.
✓ Branch 1 taken 623 times.
 80367 for (unsigned i = 0; i < kNumHandleLocks; ++i) {
102 79744 pthread_mutex_destroy(handle_locks.At(i));
103 79744 free(handle_locks.At(i));
104 }
105 623 }
106
107
108 ✗ ChunkTables::ChunkTables(const ChunkTables &other) {
109 ✗ version = kVersion;
110 ✗ InitLocks();
111 ✗ InitHashmaps();
112 ✗ CopyFrom(other);
113 }
114
115
116 ✗ ChunkTables &ChunkTables::operator=(const ChunkTables &other) {
117 ✗ if (&other == this)
118 ✗ return *this;
119
120 ✗ handle2uniqino.Clear();
121 ✗ handle2fd.Clear();
122 ✗ inode2chunks.Clear();
123 ✗ inode2references.Clear();
124 ✗ CopyFrom(other);
125 ✗ return *this;
126 }
127
128
129 ✗ void ChunkTables::CopyFrom(const ChunkTables &other) {
130 ✗ assert(version == other.version);
131 ✗ next_handle = other.next_handle;
132 ✗ inode2references = other.inode2references;
133 ✗ inode2chunks = other.inode2chunks;
134 ✗ handle2fd = other.handle2fd;
135 ✗ handle2uniqino = other.handle2uniqino;
136 }
137
138
139 ✗ pthread_mutex_t *ChunkTables::Handle2Lock(const uint64_t handle) const {
140 ✗ const uint32_t hash = hasher_uint64t(handle);
141 ✗ const double bucket = static_cast<double>(hash)
142 ✗ * static_cast<double>(kNumHandleLocks)
143 / static_cast<double>((uint32_t)(-1));
144 ✗ return handle_locks.At((uint32_t)bucket % kNumHandleLocks);
145 }
146
147
148 //------------------------------------------------------------------------------
149
150
151 222 SimpleChunkTables::SimpleChunkTables() {
152 222 lock_ = reinterpret_cast<pthread_mutex_t *>(smalloc(sizeof(pthread_mutex_t)));
153 222 const int retval = pthread_mutex_init(lock_, NULL);
154
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 222 times.
 222 assert(retval == 0);
155 222 }
156
157
158 220 SimpleChunkTables::~SimpleChunkTables() {
159
2/2
✓ Branch 1 taken 47 times.
✓ Branch 2 taken 220 times.
 267 for (unsigned i = 0; i < fd_table_.size(); ++i) {
160
1/2
✓ Branch 1 taken 47 times.
✗ Branch 2 not taken.
 47 delete fd_table_[i].chunk_reflist.list;
161 }
162 220 pthread_mutex_destroy(lock_);
163 220 free(lock_);
164 220 }
165
166
167 376 int SimpleChunkTables::Add(FileChunkReflist chunks) {
168
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 376 times.
 376 assert(chunks.list != NULL);
169
1/2
✓ Branch 1 taken 376 times.
✗ Branch 2 not taken.
 376 OpenChunks new_entry;
170
1/2
✓ Branch 1 taken 376 times.
✗ Branch 2 not taken.
 376 new_entry.chunk_reflist = chunks;
171
1/2
✓ Branch 1 taken 376 times.
✗ Branch 2 not taken.
 376 new_entry.chunk_fd = new ChunkFd();
172 376 unsigned i = 0;
173 376 Lock();
174
2/2
✓ Branch 1 taken 705 times.
✓ Branch 2 taken 329 times.
 1034 for (; i < fd_table_.size(); ++i) {
175
2/2
✓ Branch 1 taken 47 times.
✓ Branch 2 taken 658 times.
 705 if (fd_table_[i].chunk_reflist.list == NULL) {
176
1/2
✓ Branch 2 taken 47 times.
✗ Branch 3 not taken.
 47 fd_table_[i] = new_entry;
177 47 Unlock();
178 47 return i;
179 }
180 }
181
1/2
✓ Branch 1 taken 329 times.
✗ Branch 2 not taken.
 329 fd_table_.push_back(new_entry);
182 329 Unlock();
183 329 return i;
184 376 }
185
186
187 141 SimpleChunkTables::OpenChunks SimpleChunkTables::Get(int fd) {
188 141 OpenChunks result;
189
2/2
✓ Branch 0 taken 47 times.
✓ Branch 1 taken 94 times.
 141 if (fd < 0)
190 47 return result;
191
192 94 const unsigned idx = static_cast<unsigned>(fd);
193 94 Lock();
194
2/2
✓ Branch 1 taken 47 times.
✓ Branch 2 taken 47 times.
 94 if (idx < fd_table_.size())
195
1/2
✓ Branch 2 taken 47 times.
✗ Branch 3 not taken.
 47 result = fd_table_[idx];
196 94 Unlock();
197 94 return result;
198 }
199
200
201 423 void SimpleChunkTables::Release(int fd) {
202
2/2
✓ Branch 0 taken 47 times.
✓ Branch 1 taken 376 times.
 423 if (fd < 0)
203 47 return;
204
205 376 Lock();
206 376 const unsigned idx = static_cast<unsigned>(fd);
207
2/2
✓ Branch 1 taken 47 times.
✓ Branch 2 taken 329 times.
 376 if (idx >= fd_table_.size()) {
208 47 Unlock();
209 47 return;
210 }
211
212
1/2
✓ Branch 1 taken 329 times.
✗ Branch 2 not taken.
 329 delete fd_table_[idx].chunk_reflist.list;
213 329 fd_table_[idx].chunk_reflist.list = NULL;
214 329 fd_table_[idx].chunk_reflist.path.Assign("", 0);
215
1/2
✓ Branch 1 taken 329 times.
✗ Branch 2 not taken.
 329 delete fd_table_[idx].chunk_fd;
216 329 fd_table_[idx].chunk_fd = NULL;
217
6/6
✓ Branch 1 taken 564 times.
✓ Branch 2 taken 47 times.
✓ Branch 4 taken 282 times.
✓ Branch 5 taken 282 times.
✓ Branch 6 taken 282 times.
✓ Branch 7 taken 329 times.
 611 while (!fd_table_.empty() && (fd_table_.back().chunk_reflist.list == NULL)) {
218 282 fd_table_.pop_back();
219 }
220 329 Unlock();
221 }
222