GCC Code Coverage Report

Directory: cvmfs/
File: cvmfs/catalog_mgr_client.cc
Date: 2025-11-02 02:35:35
Exec Total Coverage
Lines: 211 232 90.9%
Branches: 185 323 57.3%
Line Branch Exec Source
1 /**
2 * This file is part of the CernVM file system.
3 */
4
5
6 #include "catalog_mgr_client.h"
7
8 #include <string>
9 #include <vector>
10
11 #include "cache_posix.h"
12 #include "crypto/signature.h"
13 #include "fetch.h"
14 #include "manifest.h"
15 #include "mountpoint.h"
16 #include "network/download.h"
17 #include "quota.h"
18 #include "statistics.h"
19 #include "util/posix.h"
20 #include "util/string.h"
21
22 using namespace std; // NOLINT
23
24 namespace catalog {
25
26 /**
27 * Triggered when the catalog is attached (db file opened)
28 */
29 901 void ClientCatalogManager::ActivateCatalog(Catalog *catalog) {
30 const Counters &counters = const_cast<const Catalog *>(catalog)
31 901 ->GetCounters();
32
2/2
✓ Branch 1 taken 757 times.
✓ Branch 2 taken 144 times.
 901 if (catalog->IsRoot()) {
33 757 all_inodes_ = counters.GetAllEntries();
34 }
35 901 loaded_inodes_ += counters.GetSelfEntries();
36 901 }
37
38
39 1019 ClientCatalogManager::ClientCatalogManager(MountPoint *mountpoint)
40 : AbstractCatalogManager<Catalog>(mountpoint->statistics())
41
1/2
✓ Branch 1 taken 1019 times.
✗ Branch 2 not taken.
 1019 , repo_name_(mountpoint->fqrn())
42 1019 , fetcher_(mountpoint->fetcher())
43 1019 , signature_mgr_(mountpoint->signature_mgr())
44
1/2
✓ Branch 2 taken 1019 times.
✗ Branch 3 not taken.
 1019 , workspace_(mountpoint->file_system()->workspace())
45 1019 , offline_mode_(false)
46 1019 , all_inodes_(0)
47 1019 , loaded_inodes_(0)
48
1/2
✓ Branch 1 taken 1019 times.
✗ Branch 2 not taken.
 1019 , fixed_root_catalog_()
49 1019 , fixed_alt_root_catalog_(false)
50
2/4
✓ Branch 5 taken 1019 times.
✗ Branch 6 not taken.
✓ Branch 8 taken 1019 times.
✗ Branch 9 not taken.
 2038 , root_fd_(-1) {
51
1/2
✓ Branch 1 taken 1019 times.
✗ Branch 2 not taken.
 1019 LogCvmfs(kLogCatalog, kLogDebug, "constructing client catalog manager");
52
3/6
✓ Branch 3 taken 1019 times.
✗ Branch 4 not taken.
✓ Branch 7 taken 1019 times.
✗ Branch 8 not taken.
✓ Branch 10 taken 1019 times.
✗ Branch 11 not taken.
 1019 n_certificate_hits_ = mountpoint->statistics()->Register(
53 "cache.n_certificate_hits", "Number of certificate hits");
54
3/6
✓ Branch 3 taken 1019 times.
✗ Branch 4 not taken.
✓ Branch 7 taken 1019 times.
✗ Branch 8 not taken.
✓ Branch 10 taken 1019 times.
✗ Branch 11 not taken.
 1019 n_certificate_misses_ = mountpoint->statistics()->Register(
55 "cache.n_certificate_misses", "Number of certificate misses");
56 1019 }
57
58
59 4076 ClientCatalogManager::~ClientCatalogManager() {
60 2038 LogCvmfs(kLogCache, kLogDebug, "unpinning / unloading all catalogs");
61
62 4076 for (map<PathString, shash::Any>::iterator i = mounted_catalogs_.begin(),
63 2038 iend = mounted_catalogs_.end();
64
2/2
✓ Branch 1 taken 899 times.
✓ Branch 2 taken 1019 times.
 3836 i != iend;
65 1798 ++i) {
66 1798 fetcher_->cache_mgr()->quota_mgr()->Unpin(i->second);
67 }
68 4076 }
69
70
71 901 Catalog *ClientCatalogManager::CreateCatalog(const PathString &mountpoint,
72 const shash::Any &catalog_hash,
73 catalog::Catalog *parent_catalog) {
74 901 mounted_catalogs_[mountpoint] = loaded_catalogs_[mountpoint];
75 901 loaded_catalogs_.erase(mountpoint);
76
1/2
✓ Branch 2 taken 901 times.
✗ Branch 3 not taken.
 901 return new Catalog(mountpoint, catalog_hash, parent_catalog);
77 }
78
79
80 184 shash::Any ClientCatalogManager::GetRootHash() {
81 184 ReadLock();
82
1/2
✓ Branch 2 taken 184 times.
✗ Branch 3 not taken.
 184 shash::Any result = mounted_catalogs_[PathString("", 0)];
83 184 Unlock();
84 184 return result;
85 }
86
87
88 /**
89 * Specialized initialization that uses a fixed root hash.
90 *
91 * @returns true - root catalog was successfully mounted
92 * false - otherwise
93 */
94 504 bool ClientCatalogManager::InitFixed(const shash::Any &root_hash,
95 bool alternative_path) {
96
1/2
✓ Branch 2 taken 504 times.
✗ Branch 3 not taken.
 504 LogCvmfs(kLogCatalog, kLogDebug, "Initialize catalog with fixed root hash %s",
97 1008 root_hash.ToString().c_str());
98 504 WriteLock();
99 504 fixed_alt_root_catalog_ = alternative_path;
100 504 fixed_root_catalog_ = root_hash;
101
102
1/2
✓ Branch 2 taken 504 times.
✗ Branch 3 not taken.
 504 const bool attached = MountCatalog(PathString("", 0), root_hash, NULL);
103 504 Unlock();
104
105
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 504 times.
 504 if (!attached) {
106 ✗ LogCvmfs(kLogCatalog, kLogDebug, "failed to initialize fixed root catalog");
107 }
108
109 504 return attached;
110 }
111
112 /**
113 * Gets information about the most recent root catalog, including even if it is
114 * a fixed root catalog. This is needed as Remount() does not know what kind of
115 * root catalog will be remounted.
116 *
117 * Checks the locations: mounted, alien cache and remote (server) and sets the
118 * fields of variable "result". For the most recent catalog the location, hash
119 * and revision number are set.
120 *
121 *
122 * @param [out] result All fields but sqlite_path will be set:
123 * mountpoint, root_ctl_location, root_ctlg_revision, hash
124 * @return kLoadUp2Date - if most recent root catalog is already mounted
125 * kLoadNew - otherwise
126 */
127 483 LoadReturn ClientCatalogManager::GetNewRootCatalogContext(
128 CatalogContext *result) {
129
2/4
✓ Branch 1 taken 483 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 483 times.
✗ Branch 5 not taken.
 483 result->SetMountpoint(PathString("", 0));
130
131 // quick escape if we have a fixed catalog
132
1/2
✗ Branch 1 not taken.
✓ Branch 2 taken 483 times.
 483 if (!fixed_root_catalog_.IsNull()) {
133 ✗ result->SetHash(fixed_root_catalog_);
134 ✗ result->SetRootCtlgRevision(GetRevisionNoLock());
135
136 // it might or might not be already mounted, but we do not care
137 // as we do no need to download and save the manifest
138 // (see LoadCatalogByHash()) as such we must set the location to this
139 ✗ result->SetRootCtlgLocation(kCtlgLocationMounted);
140 ✗ offline_mode_ = false;
141
142 // we can do this here as the very first time fixed catalog is loaded it
143 // call directly MountCatalog() and will skip the call to this function
144 // here
145 ✗ return catalog::kLoadUp2Date;
146 }
147
148 // 1) Get alien cache root catalog (local)
149
150 // Happens only on init/remount, i.e. quota won't delete a cached catalog
151
1/2
✓ Branch 1 taken 483 times.
✗ Branch 2 not taken.
 483 shash::Any local_newest_hash(shash::kSha1, shash::kSuffixCatalog);
152
1/2
✓ Branch 1 taken 483 times.
✗ Branch 2 not taken.
 483 shash::Any mounted_hash(shash::kSha1, shash::kSuffixCatalog);
153 483 uint64_t local_newest_timestamp = 0;
154 483 uint64_t local_newest_revision = manifest::Breadcrumb::kInvalidRevision;
155
156 483 const manifest::Breadcrumb breadcrumb = fetcher_->cache_mgr()->LoadBreadcrumb(
157
1/2
✓ Branch 1 taken 483 times.
✗ Branch 2 not taken.
 483 repo_name_);
158
3/4
✓ Branch 1 taken 483 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 96 times.
✓ Branch 4 taken 387 times.
 483 if (breadcrumb.IsValid()) {
159 96 local_newest_hash = breadcrumb.catalog_hash;
160 96 local_newest_timestamp = breadcrumb.timestamp;
161 96 local_newest_revision = breadcrumb.revision;
162
1/2
✓ Branch 3 taken 96 times.
✗ Branch 4 not taken.
 192 LogCvmfs(kLogCache, kLogDebug,
163 "Cached copy publish date %s (hash %s, revision %" PRIu64 ")",
164
1/2
✓ Branch 1 taken 96 times.
✗ Branch 2 not taken.
 192 StringifyTime(static_cast<int64_t>(local_newest_timestamp), true)
165 .c_str(),
166
1/2
✓ Branch 1 taken 96 times.
✗ Branch 2 not taken.
 192 local_newest_hash.ToString().c_str(), breadcrumb.revision);
167 } else {
168
1/2
✓ Branch 2 taken 387 times.
✗ Branch 3 not taken.
 387 LogCvmfs(kLogCache, kLogDebug, "Unable to read local checksum %s",
169
1/2
✓ Branch 1 taken 387 times.
✗ Branch 2 not taken.
 774 breadcrumb.ToString().c_str());
170 }
171
172 // 2) Select local newest catalog: mounted vs alien
173
174 483 result->SetRootCtlgLocation(kCtlgLocationBreadcrumb);
175 483 LoadReturn success_code = catalog::kLoadNew;
176
177
2/2
✓ Branch 1 taken 64 times.
✓ Branch 2 taken 419 times.
 483 if (mounted_catalogs_.size() > 0) {
178 const std::map<PathString, shash::Any>::iterator
179
2/4
✓ Branch 1 taken 64 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 64 times.
✗ Branch 5 not taken.
 64 curr_hash_itr = mounted_catalogs_.find(PathString("", 0));
180 64 mounted_hash = curr_hash_itr->second;
181 }
182
183 // We only look for currently loaded catalog if the revision is newer than
184 // the breadcrumb revision and both revision numbers are valid (!= -1ul).
185 483 if ((local_newest_revision <= GetRevisionNoLock()
186
1/2
✓ Branch 0 taken 387 times.
✗ Branch 1 not taken.
 387 || local_newest_revision == manifest::Breadcrumb::kInvalidRevision)
187
6/6
✓ Branch 0 taken 387 times.
✓ Branch 1 taken 96 times.
✓ Branch 3 taken 64 times.
✓ Branch 4 taken 419 times.
✓ Branch 5 taken 64 times.
✓ Branch 6 taken 419 times.
 870 && mounted_catalogs_.size() > 0) {
188 64 local_newest_hash = mounted_hash;
189 64 local_newest_revision = GetRevisionNoLock();
190 // if needed for integration test 707: breadcrumb_timestamp_newer()
191 64 local_newest_timestamp = GetTimestampNoLock() > local_newest_timestamp
192
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 64 times.
 64 ? GetTimestampNoLock()
193 : local_newest_timestamp;
194 64 result->SetRootCtlgLocation(kCtlgLocationMounted);
195 64 success_code = catalog::kLoadUp2Date;
196
4/6
✓ Branch 0 taken 32 times.
✓ Branch 1 taken 387 times.
✗ Branch 3 not taken.
✓ Branch 4 taken 32 times.
✗ Branch 5 not taken.
✓ Branch 6 taken 419 times.
 419 } else if (local_newest_revision == 0 && mounted_catalogs_.size() > 0) {
197 // breadcrumb has no revision
198 // TODO(heretherebedragons) this branch can be removed in future versions
199
200 // revisions are better, but if we dont have any we need to compare by
201 // timestamp (you can have multiple revisions in the same timestamp)
202 ✗ if (local_newest_timestamp < GetTimestampNoLock()) {
203 ✗ local_newest_hash = mounted_hash;
204 ✗ local_newest_revision = GetRevisionNoLock();
205 ✗ local_newest_timestamp = GetTimestampNoLock();
206 ✗ result->SetRootCtlgLocation(kCtlgLocationMounted);
207 ✗ success_code = catalog::kLoadUp2Date;
208 }
209 }
210
211 // 3) Get remote root catalog (fails if remote catalog is older)
212 manifest::Failures manifest_failure;
213 UniquePtr<CachedManifestEnsemble> ensemble(
214
2/4
✓ Branch 2 taken 483 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 483 times.
✗ Branch 7 not taken.
 483 new CachedManifestEnsemble(fetcher_->cache_mgr(), this));
215
2/4
✓ Branch 1 taken 483 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 483 times.
✗ Branch 5 not taken.
 483 manifest_failure = manifest::Fetch(
216 483 "", repo_name_, local_newest_timestamp, &local_newest_hash,
217 483 signature_mgr_, fetcher_->download_mgr(), ensemble.weak_ref());
218
219
2/2
✓ Branch 0 taken 285 times.
✓ Branch 1 taken 198 times.
 483 if (manifest_failure == manifest::kFailOk) {
220 // server has newest revision or no valid local revision
221 285 if (ensemble->manifest->revision() > local_newest_revision
222
2/2
✓ Branch 0 taken 64 times.
✓ Branch 1 taken 219 times.
 283 || local_newest_revision == manifest::Breadcrumb::kInvalidRevision
223 // if revision is 0 both local and server, load catalog from server
224 // as local is most likely just "initialized" without valid value
225
6/6
✓ Branch 0 taken 283 times.
✓ Branch 1 taken 2 times.
✓ Branch 4 taken 34 times.
✓ Branch 5 taken 30 times.
✓ Branch 6 taken 255 times.
✓ Branch 7 taken 30 times.
 602 || (ensemble->manifest->revision() == 0
226
1/2
✓ Branch 0 taken 34 times.
✗ Branch 1 not taken.
 34 && local_newest_revision == 0)) {
227 255 result->SetHash(ensemble->manifest->catalog_hash());
228 255 result->SetRootCtlgRevision(ensemble->manifest->revision());
229 255 result->SetRootCtlgLocation(kCtlgLocationServer);
230 255 fixed_alt_root_catalog_ = ensemble->manifest->has_alt_catalog_path();
231
232
1/2
✓ Branch 1 taken 255 times.
✗ Branch 2 not taken.
 255 result->TakeManifestEnsemble(
233 255 static_cast<manifest::ManifestEnsemble *>(ensemble.Release()));
234 255 offline_mode_ = false;
235
236 255 return catalog::kLoadNew;
237 }
238 }
239
1/2
✓ Branch 2 taken 228 times.
✗ Branch 3 not taken.
 228 LogCvmfs(kLogCache, kLogDebug,
240 "Failed fetch manifest from server: "
241 "manifest too old or server unreachable (%d - %s)",
242 manifest_failure, manifest::Code2Ascii(manifest_failure));
243
244 // total failure: server not reachable and no valid local hash
245
6/6
✓ Branch 0 taken 198 times.
✓ Branch 1 taken 30 times.
✓ Branch 3 taken 168 times.
✓ Branch 4 taken 30 times.
✓ Branch 5 taken 168 times.
✓ Branch 6 taken 60 times.
 228 if ((manifest_failure != manifest::kFailOk) && local_newest_hash.IsNull()) {
246
1/2
✓ Branch 1 taken 168 times.
✗ Branch 2 not taken.
 168 LogCvmfs(kLogCache, kLogDebug, "No valid root catalog found!");
247 168 return catalog::kLoadFail;
248 }
249
250 60 if (manifest_failure == manifest::kFailOk
251
5/6
✓ Branch 0 taken 30 times.
✓ Branch 1 taken 30 times.
✓ Branch 4 taken 30 times.
✗ Branch 5 not taken.
✓ Branch 6 taken 30 times.
✓ Branch 7 taken 30 times.
 60 && ensemble->manifest->revision() == local_newest_revision) {
252 30 offline_mode_ = false;
253 } else {
254 30 offline_mode_ = true;
255 }
256 60 result->SetHash(local_newest_hash);
257 60 result->SetRootCtlgRevision(local_newest_revision);
258
259 // for integration test 707: breadcrumb_revision_large()
260
4/8
✓ Branch 1 taken 60 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 60 times.
✗ Branch 4 not taken.
✓ Branch 6 taken 60 times.
✗ Branch 7 not taken.
✓ Branch 8 taken 60 times.
✗ Branch 9 not taken.
 60 if (breadcrumb.IsValid() && breadcrumb.catalog_hash == mounted_hash) {
261 60 success_code = catalog::kLoadUp2Date;
262 }
263
264 60 return success_code;
265 483 }
266
267 1213 std::string ClientCatalogManager::GetCatalogDescription(
268 const PathString &mountpoint, const shash::Any &hash) {
269
2/4
✓ Branch 1 taken 1213 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 1213 times.
✗ Branch 5 not taken.
 2426 return "file catalog at " + repo_name_ + ":"
270
2/4
✓ Branch 1 taken 1213 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 1213 times.
✗ Branch 5 not taken.
 3639 + (mountpoint.IsEmpty()
271
8/14
✓ Branch 0 taken 817 times.
✓ Branch 1 taken 396 times.
✓ Branch 4 taken 817 times.
✗ Branch 5 not taken.
✓ Branch 9 taken 396 times.
✗ Branch 10 not taken.
✓ Branch 12 taken 396 times.
✓ Branch 13 taken 817 times.
✓ Branch 15 taken 817 times.
✓ Branch 16 taken 396 times.
✗ Branch 19 not taken.
✗ Branch 20 not taken.
✗ Branch 22 not taken.
✗ Branch 23 not taken.
 2822 ? "/"
272 396 : string(mountpoint.GetChars(), mountpoint.GetLength()))
273
3/6
✓ Branch 2 taken 1213 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 1213 times.
✗ Branch 6 not taken.
✓ Branch 8 taken 1213 times.
✗ Branch 9 not taken.
 4852 + " (" + hash.ToString() + ")";
274 }
275
276 /**
277 * Loads (and fetches) a catalog by hash for a given mountpoint.
278 *
279 * Special case for root catalog: ctlg_context->root_ctlg_location must be
280 * given.
281 *
282 * @param [in, out] ctlg_context mandatory fields (input): mountpoint, hash
283 * additional mandatory fields for root catalog: root_ctlg_location
284 * output: sqlite_path is set if catalog fetch successful
285 * @return kLoadUp2Date for root catalog that is already mounted
286 * kLoadNew for any other successful load
287 * kLoadFail on failure
288 */
289 1141 LoadReturn ClientCatalogManager::LoadCatalogByHash(
290 CatalogContext *ctlg_context) {
291
1/2
✓ Branch 1 taken 1141 times.
✗ Branch 2 not taken.
 1141 const string catalog_descr = GetCatalogDescription(ctlg_context->mountpoint(),
292
1/2
✓ Branch 2 taken 1141 times.
✗ Branch 3 not taken.
 2282 ctlg_context->hash());
293
1/2
✓ Branch 2 taken 1141 times.
✗ Branch 3 not taken.
 1141 string alt_root_catalog_path = "";
294
295 // root catalog needs special handling because of alt_root_catalog_path
296
5/8
✓ Branch 1 taken 1141 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 817 times.
✓ Branch 4 taken 324 times.
✗ Branch 5 not taken.
✓ Branch 6 taken 817 times.
✗ Branch 7 not taken.
✓ Branch 8 taken 1141 times.
 1141 if (ctlg_context->IsRootCatalog() && fixed_alt_root_catalog_) {
297 ✗ alt_root_catalog_path = ctlg_context->hash().MakeAlternativePath();
298 }
299
300
1/2
✓ Branch 2 taken 1141 times.
✗ Branch 3 not taken.
 2282 const LoadReturn load_ret = FetchCatalogByHash(
301 1141 ctlg_context->hash(), catalog_descr, alt_root_catalog_path,
302 ctlg_context->GetSqlitePathPtr());
303
2/2
✓ Branch 0 taken 1111 times.
✓ Branch 1 taken 30 times.
 1141 if (load_ret == catalog::kLoadNew) {
304
2/4
✓ Branch 2 taken 1111 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 1111 times.
✗ Branch 6 not taken.
 1111 loaded_catalogs_[ctlg_context->mountpoint()] = ctlg_context->hash();
305
306
3/4
✓ Branch 1 taken 1111 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 817 times.
✓ Branch 4 taken 294 times.
 1111 if (ctlg_context->IsRootCatalog()) {
307
2/2
✓ Branch 1 taken 564 times.
✓ Branch 2 taken 253 times.
 817 if (ctlg_context->root_ctlg_location() == kCtlgLocationMounted) {
308 564 return kLoadUp2Date;
309 }
310
311 // if coming from server: update breadcrumb
312
1/2
✓ Branch 1 taken 253 times.
✗ Branch 2 not taken.
 253 if (ctlg_context->root_ctlg_location() == kCtlgLocationServer) {
313 // Store new manifest and certificate
314 253 CacheManager::Label label;
315
1/2
✓ Branch 1 taken 253 times.
✗ Branch 2 not taken.
 253 label.path = repo_name_;
316 253 label.flags |= CacheManager::kLabelCertificate;
317
3/4
✓ Branch 1 taken 253 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 220 times.
✓ Branch 4 taken 33 times.
 253 if (ctlg_context->manifest_ensemble()->cert_size > 0) {
318
1/2
✓ Branch 2 taken 220 times.
✗ Branch 3 not taken.
 440 fetcher_->cache_mgr()->CommitFromMem(
319
1/2
✓ Branch 1 taken 220 times.
✗ Branch 2 not taken.
 440 CacheManager::LabeledObject(
320 440 ctlg_context->manifest_ensemble()->manifest->certificate(),
321 label),
322
1/2
✓ Branch 1 taken 220 times.
✗ Branch 2 not taken.
 220 ctlg_context->manifest_ensemble()->cert_buf,
323
2/4
✓ Branch 1 taken 220 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 220 times.
✗ Branch 5 not taken.
 220 ctlg_context->manifest_ensemble()->cert_size);
324 }
325 253 fetcher_->cache_mgr()->StoreBreadcrumb(
326
2/4
✓ Branch 1 taken 253 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 253 times.
✗ Branch 5 not taken.
 253 *ctlg_context->manifest_ensemble()->manifest);
327 253 }
328 }
329 }
330
331 577 return load_ret;
332 1141 }
333
334 /**
335 * Fetch a catalog by hash either from cache or from remote.
336 * Successful load always returns kLoadNew (independent of the location) and
337 * sets the sqlite_path variable.
338 *
339 * @param [out] sqlite_path of the catalog if successfully fetched
340 * @return kLoadNew on success
341 * kLoadNoSpace out of space, no room on the device to open the catalog
342 * kLoadFail on all other failures
343 */
344 1141 LoadReturn ClientCatalogManager::FetchCatalogByHash(
345 const shash::Any &hash,
346 const string &name,
347 const std::string &alt_root_catalog_path,
348 std::string *sqlite_path) {
349
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 1141 times.
 1141 assert(hash.suffix == shash::kSuffixCatalog);
350 1141 CacheManager::Label label;
351
1/2
✓ Branch 1 taken 1141 times.
✗ Branch 2 not taken.
 1141 label.path = name;
352 1141 label.flags = CacheManager::kLabelCatalog;
353
2/4
✓ Branch 1 taken 1141 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 1141 times.
✗ Branch 5 not taken.
 1141 const int fd = fetcher_->Fetch(CacheManager::LabeledObject(hash, label),
354 alt_root_catalog_path);
355
2/2
✓ Branch 0 taken 1111 times.
✓ Branch 1 taken 30 times.
 1141 if (fd >= 0) {
356
2/2
✓ Branch 0 taken 755 times.
✓ Branch 1 taken 356 times.
 1111 if (root_fd_ < 0) {
357 755 root_fd_ = fd;
358 }
359
360
1/2
✓ Branch 1 taken 1111 times.
✗ Branch 2 not taken.
 1111 LogCvmfs(kLogCatalog, kLogDebug, "FetchCatalogByHash filedescriptor %d",
361 fd);
362
2/4
✓ Branch 1 taken 1111 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 1111 times.
✗ Branch 5 not taken.
 1111 *sqlite_path = "@" + StringifyInt(fd);
363 1111 return kLoadNew;
364 }
365
366
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 30 times.
 30 if (fd == -ENOSPC)
367 ✗ return kLoadNoSpace;
368
369 30 return kLoadFail;
370 1141 }
371
372 72 void ClientCatalogManager::StageNestedCatalogByHash(
373 const shash::Any &hash, const PathString &mountpoint) {
374
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 72 times.
 72 assert(hash.suffix == shash::kSuffixCatalog);
375
376 72 CacheManager::Label label;
377
1/2
✓ Branch 1 taken 72 times.
✗ Branch 2 not taken.
 72 label.path = GetCatalogDescription(mountpoint, hash);
378 72 label.flags = CacheManager::kLabelCatalog;
379
3/6
✓ Branch 2 taken 72 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 72 times.
✗ Branch 6 not taken.
✓ Branch 8 taken 72 times.
✗ Branch 9 not taken.
 72 const int fd = fetcher_->Fetch(CacheManager::LabeledObject(hash, label));
380
1/2
✓ Branch 0 taken 72 times.
✗ Branch 1 not taken.
 72 if (fd >= 0)
381
1/2
✓ Branch 2 taken 72 times.
✗ Branch 3 not taken.
 72 fetcher_->cache_mgr()->Close(fd);
382 72 }
383
384 2 void ClientCatalogManager::UnloadCatalog(const Catalog *catalog) {
385
1/2
✓ Branch 2 taken 2 times.
✗ Branch 3 not taken.
 2 LogCvmfs(kLogCache, kLogDebug, "unloading catalog %s",
386
1/2
✓ Branch 1 taken 2 times.
✗ Branch 2 not taken.
 4 catalog->mountpoint().c_str());
387
388
1/2
✓ Branch 1 taken 2 times.
✗ Branch 2 not taken.
 2 const map<PathString, shash::Any>::iterator iter = mounted_catalogs_.find(
389
1/2
✓ Branch 1 taken 2 times.
✗ Branch 2 not taken.
 4 catalog->mountpoint());
390
1/2
✗ Branch 2 not taken.
✓ Branch 3 taken 2 times.
 2 assert(iter != mounted_catalogs_.end());
391
1/2
✓ Branch 4 taken 2 times.
✗ Branch 5 not taken.
 2 fetcher_->cache_mgr()->quota_mgr()->Unpin(iter->second);
392
1/2
✓ Branch 1 taken 2 times.
✗ Branch 2 not taken.
 2 mounted_catalogs_.erase(iter);
393 2 const catalog::Counters &counters = catalog->GetCounters();
394
1/2
✓ Branch 1 taken 2 times.
✗ Branch 2 not taken.
 2 loaded_inodes_ -= counters.GetSelfEntries();
395 2 }
396
397
398 /**
399 * Checks if the current repository revision is blacklisted. The format
400 * of the blacklist lines is '<REPO N' where REPO is the repository name,
401 * N is the revision number, and the two parts are separated by whitespace.
402 * Any revision of REPO less than N is blacklisted.
403 * Note: no extra characters are allowed after N, not even whitespace.
404 * @return true if it is blacklisted, false otherwise
405 */
406 755 bool ClientCatalogManager::IsRevisionBlacklisted() {
407 755 const uint64_t revision = GetRevision();
408
409
1/2
✓ Branch 2 taken 755 times.
✗ Branch 3 not taken.
 755 LogCvmfs(kLogCache, kLogDebug,
410 "checking if %s revision %" PRIu64 " is blacklisted",
411 repo_name_.c_str(), revision);
412
413
1/2
✓ Branch 1 taken 755 times.
✗ Branch 2 not taken.
 755 vector<string> blacklist = signature_mgr_->GetBlacklist();
414
2/2
✓ Branch 1 taken 32 times.
✓ Branch 2 taken 723 times.
 755 for (unsigned i = 0; i < blacklist.size(); ++i) {
415
1/2
✓ Branch 2 taken 32 times.
✗ Branch 3 not taken.
 32 std::string line = blacklist[i];
416
2/4
✓ Branch 1 taken 32 times.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
✓ Branch 4 taken 32 times.
 32 if (line[0] != '<')
417 ✗ continue;
418 32 unsigned idx = repo_name_.length() + 1;
419
1/2
✗ Branch 1 not taken.
✓ Branch 2 taken 32 times.
 32 if (line.length() <= idx)
420 ✗ continue;
421
3/10
✓ Branch 1 taken 32 times.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
✓ Branch 4 taken 32 times.
✗ Branch 6 not taken.
✗ Branch 7 not taken.
✗ Branch 8 not taken.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✓ Branch 11 taken 32 times.
 32 if ((line[idx] != ' ') && (line[idx] != '\t'))
422 ✗ continue;
423
2/4
✓ Branch 1 taken 32 times.
✗ Branch 2 not taken.
✗ Branch 5 not taken.
✓ Branch 6 taken 32 times.
 32 if (line.substr(1, idx - 1) != repo_name_)
424 ✗ continue;
425 32 ++idx;
426
5/10
✓ Branch 1 taken 32 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 32 times.
✗ Branch 4 not taken.
✓ Branch 6 taken 32 times.
✗ Branch 7 not taken.
✗ Branch 8 not taken.
✓ Branch 9 taken 32 times.
✗ Branch 10 not taken.
✓ Branch 11 taken 32 times.
 32 while ((line[idx] == ' ') || (line[idx] == '\t'))
427 ✗ ++idx;
428
1/2
✗ Branch 1 not taken.
✓ Branch 2 taken 32 times.
 32 if (idx >= line.length())
429 ✗ continue;
430 uint64_t rev;
431
3/6
✓ Branch 1 taken 32 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 32 times.
✗ Branch 5 not taken.
✗ Branch 7 not taken.
✓ Branch 8 taken 32 times.
 32 if (!String2Uint64Parse(line.substr(idx), &rev))
432 ✗ continue;
433
1/2
✓ Branch 0 taken 32 times.
✗ Branch 1 not taken.
 32 if (revision < rev)
434 32 return true;
435
1/3
✗ Branch 1 not taken.
✗ Branch 2 not taken.
✓ Branch 3 taken 32 times.
 32 }
436
437 723 return false;
438 755 }
439
440
441 //------------------------------------------------------------------------------
442
443
444 285 void CachedManifestEnsemble::FetchCertificate(const shash::Any &hash) {
445 285 CacheManager::Label label;
446 285 label.flags |= CacheManager::kLabelCertificate;
447
1/2
✓ Branch 1 taken 285 times.
✗ Branch 2 not taken.
 285 label.path = catalog_mgr_->repo_name();
448 uint64_t size;
449
1/2
✓ Branch 1 taken 285 times.
✗ Branch 2 not taken.
 285 const bool retval = cache_mgr_->Open2Mem(
450
1/2
✓ Branch 1 taken 285 times.
✗ Branch 2 not taken.
 570 CacheManager::LabeledObject(hash, label), &cert_buf, &size);
451 285 cert_size = size;
452
2/2
✓ Branch 0 taken 2 times.
✓ Branch 1 taken 283 times.
 285 if (retval)
453 2 perf::Inc(catalog_mgr_->n_certificate_hits_);
454 else
455 283 perf::Inc(catalog_mgr_->n_certificate_misses_);
456 285 }
457
458 } // namespace catalog
459