GCC Code Coverage Report

Directory: cvmfs/
File: cvmfs/cache_tiered.cc
Date: 2026-05-24 02:35:55
Exec Total Coverage
Lines: 82 129 63.6%
Branches: 52 132 39.4%
Line Branch Exec Source
1 /**
2 * This file is part of the CernVM File System.
3 */
4
5 #include "cache_tiered.h"
6
7 #include <errno.h>
8
9 #include <string>
10 #include <vector>
11
12 #include "util/posix.h" // IWYU pragma: keep
13
14
15 ✗ std::string TieredCacheManager::Describe() {
16 return "Tiered Cache\n"
17 " - upper layer: "
18 ✗ + upper_->Describe() + " - lower layer: " + lower_->Describe();
19 }
20
21
22 ✗ bool TieredCacheManager::DoFreeState(void *data) {
23 ✗ SavedState *state = reinterpret_cast<SavedState *>(data);
24 ✗ upper_->FreeState(-1, state->state_upper);
25 ✗ lower_->FreeState(-1, state->state_lower);
26 ✗ delete state;
27 ✗ return true;
28 }
29
30
31 ✗ int TieredCacheManager::DoRestoreState(void *data) {
32 ✗ SavedState *state = reinterpret_cast<SavedState *>(data);
33 ✗ const int new_root_fd = upper_->RestoreState(-1, state->state_upper);
34 // The lower cache layer does not keep the root catalog open
35 ✗ const int retval = lower_->RestoreState(-1, state->state_lower);
36 ✗ assert(retval == -1);
37 ✗ return new_root_fd;
38 }
39
40
41 ✗ void *TieredCacheManager::DoSaveState() {
42 ✗ SavedState *state = new SavedState();
43 ✗ state->state_upper = upper_->SaveState(-1);
44 ✗ state->state_lower = lower_->SaveState(-1);
45 ✗ return state;
46 }
47
48
49 30 int TieredCacheManager::Open(const LabeledObject &object) {
50
1/2
✓ Branch 1 taken 30 times.
✗ Branch 2 not taken.
 30 const int fd = upper_->Open(object);
51
3/4
✓ Branch 0 taken 25 times.
✓ Branch 1 taken 5 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 25 times.
 30 if ((fd >= 0) || (fd != -ENOENT)) {
52 5 return fd;
53 }
54
55
1/2
✓ Branch 1 taken 25 times.
✗ Branch 2 not taken.
 25 const int fd2 = lower_->Open(object);
56
2/2
✓ Branch 0 taken 20 times.
✓ Branch 1 taken 5 times.
 25 if (fd2 < 0) {
57 20 return fd;
58 } // NOTE: use error code from upper.
59
60 // Lower cache hit; upper cache miss. Copy object into the upper cache.
61
1/2
✓ Branch 1 taken 5 times.
✗ Branch 2 not taken.
 5 const int64_t size = lower_->GetSize(fd2);
62
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 5 times.
 5 if (size < 0) {
63 ✗ lower_->Close(fd2);
64 ✗ return fd;
65 }
66
67
1/2
✓ Branch 1 taken 5 times.
✗ Branch 2 not taken.
 5 void *txn = alloca(upper_->SizeOfTxn());
68
2/4
✓ Branch 1 taken 5 times.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
✓ Branch 4 taken 5 times.
 5 if (upper_->StartTxn(object.id, size, txn) < 0) {
69 ✗ lower_->Close(fd2);
70 ✗ return fd;
71 }
72
1/2
✓ Branch 1 taken 5 times.
✗ Branch 2 not taken.
 5 upper_->CtrlTxn(object.label, 0, txn);
73
74 5 std::vector<char> m_buffer;
75
1/2
✓ Branch 1 taken 5 times.
✗ Branch 2 not taken.
 5 m_buffer.resize(kCopyBufferSize);
76 5 uint64_t remaining = size;
77 5 uint64_t offset = 0;
78
2/2
✓ Branch 0 taken 5 times.
✓ Branch 1 taken 5 times.
 10 while (remaining > 0) {
79 5 const unsigned nbytes = remaining > kCopyBufferSize ? kCopyBufferSize
80 : remaining;
81
1/2
✓ Branch 2 taken 5 times.
✗ Branch 3 not taken.
 5 int64_t result = lower_->Pread(fd2, &m_buffer[0], nbytes, offset);
82 // The file we are reading is supposed to be exactly `size` bytes.
83
2/4
✓ Branch 0 taken 5 times.
✗ Branch 1 not taken.
✗ Branch 2 not taken.
✓ Branch 3 taken 5 times.
 5 if ((result < 0) || (result != nbytes)) {
84 ✗ lower_->Close(fd2);
85 ✗ upper_->AbortTxn(txn);
86 ✗ return fd;
87 }
88
1/2
✓ Branch 2 taken 5 times.
✗ Branch 3 not taken.
 5 result = upper_->Write(&m_buffer[0], nbytes, txn);
89
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 5 times.
 5 if (result < 0) {
90 ✗ lower_->Close(fd2);
91 ✗ upper_->AbortTxn(txn);
92 ✗ return fd;
93 }
94 5 offset += nbytes;
95 5 remaining -= nbytes;
96 }
97
1/2
✓ Branch 1 taken 5 times.
✗ Branch 2 not taken.
 5 lower_->Close(fd2);
98
1/2
✓ Branch 1 taken 5 times.
✗ Branch 2 not taken.
 5 const int fd_return = upper_->OpenFromTxn(txn);
99
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 5 times.
 5 if (fd_return < 0) {
100 ✗ upper_->AbortTxn(txn);
101 ✗ return fd;
102 }
103
2/4
✓ Branch 1 taken 5 times.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
✓ Branch 4 taken 5 times.
 5 if (upper_->CommitTxn(txn) < 0) {
104 ✗ upper_->Close(fd_return);
105 ✗ return fd;
106 }
107 5 return fd_return;
108 5 }
109
110
111 15 int TieredCacheManager::StartTxn(const shash::Any &id,
112 uint64_t size,
113 void *txn) {
114 15 const int upper_result = upper_->StartTxn(id, size, txn);
115
3/4
✓ Branch 0 taken 5 times.
✓ Branch 1 taken 10 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 5 times.
 15 if (lower_readonly_ || (upper_result < 0)) {
116 10 return upper_result;
117 }
118
119 5 void *txn2 = static_cast<char *>(txn) + upper_->SizeOfTxn();
120 5 const int lower_result = lower_->StartTxn(id, size, txn2);
121
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 5 times.
 5 if (lower_result < 0) {
122 ✗ upper_->AbortTxn(txn);
123 }
124 5 return lower_result;
125 }
126
127
128 175 CacheManager *TieredCacheManager::Create(CacheManager *upper_cache,
129 CacheManager *lower_cache) {
130 TieredCacheManager *cache_mgr = new TieredCacheManager(upper_cache,
131
1/2
✓ Branch 2 taken 175 times.
✗ Branch 3 not taken.
 175 lower_cache);
132
1/2
✓ Branch 0 taken 175 times.
✗ Branch 1 not taken.
 175 delete cache_mgr->quota_mgr_;
133 175 cache_mgr->quota_mgr_ = upper_cache->quota_mgr();
134
135 175 return cache_mgr;
136 }
137
138
139 10 void TieredCacheManager::CtrlTxn(const Label &label,
140 const int flags,
141 void *txn) {
142 10 upper_->CtrlTxn(label, flags, txn);
143
2/2
✓ Branch 0 taken 5 times.
✓ Branch 1 taken 5 times.
 10 if (!lower_readonly_) {
144 5 void *txn2 = static_cast<char *>(txn) + upper_->SizeOfTxn();
145 5 lower_->CtrlTxn(label, flags, txn2);
146 }
147 10 }
148
149
150 10 int64_t TieredCacheManager::Write(const void *buf, uint64_t size, void *txn) {
151 10 const int upper_result = upper_->Write(buf, size, txn);
152
3/4
✓ Branch 0 taken 5 times.
✓ Branch 1 taken 5 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 5 times.
 10 if (lower_readonly_ || (upper_result < 0)) {
153 5 return upper_result;
154 }
155
156 5 void *txn2 = static_cast<char *>(txn) + upper_->SizeOfTxn();
157 5 return lower_->Write(buf, size, txn2);
158 }
159
160
161 5 int TieredCacheManager::Reset(void *txn) {
162
1/2
✓ Branch 1 taken 5 times.
✗ Branch 2 not taken.
 5 const int upper_result = upper_->Reset(txn);
163
164 5 int lower_result = upper_result;
165
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 5 times.
 5 if (!lower_readonly_) {
166 ✗ void *txn2 = static_cast<char *>(txn) + upper_->SizeOfTxn();
167 ✗ lower_result = lower_->Reset(txn2);
168 }
169
170
1/2
✓ Branch 0 taken 5 times.
✗ Branch 1 not taken.
 5 return (upper_result < 0) ? upper_result : lower_result;
171 }
172
173
174 5 int TieredCacheManager::AbortTxn(void *txn) {
175
1/2
✓ Branch 1 taken 5 times.
✗ Branch 2 not taken.
 5 const int upper_result = upper_->AbortTxn(txn);
176
177 5 int lower_result = upper_result;
178
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 5 times.
 5 if (!lower_readonly_) {
179 ✗ void *txn2 = static_cast<char *>(txn) + upper_->SizeOfTxn();
180 ✗ lower_result = lower_->AbortTxn(txn2);
181 }
182
183
1/2
✓ Branch 0 taken 5 times.
✗ Branch 1 not taken.
 5 return (upper_result < 0) ? upper_result : lower_result;
184 }
185
186
187 10 int TieredCacheManager::CommitTxn(void *txn) {
188
1/2
✓ Branch 1 taken 10 times.
✗ Branch 2 not taken.
 10 const int upper_result = upper_->CommitTxn(txn);
189
190 10 int lower_result = upper_result;
191
2/2
✓ Branch 0 taken 5 times.
✓ Branch 1 taken 5 times.
 10 if (!lower_readonly_) {
192
1/2
✓ Branch 1 taken 5 times.
✗ Branch 2 not taken.
 5 void *txn2 = static_cast<char *>(txn) + upper_->SizeOfTxn();
193
1/2
✓ Branch 1 taken 5 times.
✗ Branch 2 not taken.
 5 lower_result = lower_->CommitTxn(txn2);
194 }
195
196
1/2
✓ Branch 0 taken 10 times.
✗ Branch 1 not taken.
 10 return (upper_result < 0) ? upper_result : lower_result;
197 }
198
199
200 144 manifest::Breadcrumb TieredCacheManager::LoadBreadcrumb(
201 const std::string &fqrn) {
202 144 manifest::Breadcrumb breadcrumb = upper_->LoadBreadcrumb(fqrn);
203
1/2
✓ Branch 1 taken 144 times.
✗ Branch 2 not taken.
 144 if (!breadcrumb.IsValid())
204 144 breadcrumb = lower_->LoadBreadcrumb(fqrn);
205 144 return breadcrumb;
206 }
207
208
209 ✗ bool TieredCacheManager::StoreBreadcrumb(const manifest::Manifest &manifest) {
210 ✗ const bool upper_success = upper_->StoreBreadcrumb(manifest);
211 ✗ bool lower_success = true;
212 ✗ if (!lower_readonly_)
213 ✗ lower_success = lower_->StoreBreadcrumb(manifest);
214 ✗ return upper_success && lower_success;
215 }
216
217
218 ✗ void TieredCacheManager::Spawn() {
219 ✗ upper_->Spawn();
220 ✗ lower_->Spawn();
221 }
222
223
224 700 TieredCacheManager::~TieredCacheManager() {
225 350 quota_mgr_ = NULL; // gets deleted by upper
226
1/2
✓ Branch 0 taken 175 times.
✗ Branch 1 not taken.
 350 delete upper_;
227
1/2
✓ Branch 0 taken 175 times.
✗ Branch 1 not taken.
 350 delete lower_;
228 700 }
229