GCC Code Coverage Report

Directory: cvmfs/
File: cvmfs/catalog_rw.cc
Date: 2025-10-19 02:35:28
Exec Total Coverage
Lines: 308 393 78.4%
Branches: 266 723 36.8%
Line Branch Exec Source
1 /**
2 * This file is part of the CernVM File System.
3 */
4
5 #define __STDC_FORMAT_MACROS
6
7 #include "catalog_rw.h"
8
9 #include <inttypes.h>
10
11 #include <cstdio>
12 #include <cstdlib>
13
14 #include "util/concurrency.h"
15 #include "util/exception.h"
16 #include "util/logging.h"
17 #include "xattr.h"
18
19 using namespace std; // NOLINT
20
21 namespace catalog {
22
23 const double WritableCatalog::kMaximalFreePageRatio = 0.20;
24 const double WritableCatalog::kMaximalRowIdWasteRatio = 0.25;
25
26
27 2978 WritableCatalog::WritableCatalog(const string &path,
28 const shash::Any &catalog_hash,
29 Catalog *parent,
30 2978 const bool is_not_root)
31 5956 : Catalog(PathString(path.data(), path.length()),
32 catalog_hash, // This is 0 for a newly created catalog!
33 parent,
34 is_not_root)
35 2978 , sql_insert_(NULL)
36 2978 , sql_unlink_(NULL)
37 2978 , sql_touch_(NULL)
38 2978 , sql_update_(NULL)
39 2978 , sql_chunk_insert_(NULL)
40 2978 , sql_chunks_remove_(NULL)
41 2978 , sql_chunks_count_(NULL)
42 2978 , sql_max_link_id_(NULL)
43 2978 , sql_inc_linkcount_(NULL)
44
2/4
✓ Branch 2 taken 2978 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 2978 times.
✗ Branch 6 not taken.
 8934 , dirty_(false) {
45 2978 atomic_init32(&dirty_children_);
46 2978 }
47
48
49 840 WritableCatalog *WritableCatalog::AttachFreely(const string &root_path,
50 const string &file,
51 const shash::Any &catalog_hash,
52 Catalog *parent,
53 const bool is_not_root) {
54 WritableCatalog *catalog = new WritableCatalog(root_path, catalog_hash,
55
1/2
✓ Branch 2 taken 840 times.
✗ Branch 3 not taken.
 840 parent, is_not_root);
56 840 const bool successful_init = catalog->InitStandalone(file);
57
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 840 times.
 840 if (!successful_init) {
58 ✗ delete catalog;
59 ✗ return NULL;
60 }
61 840 return catalog;
62 }
63
64
65 11596 WritableCatalog::~WritableCatalog() {
66 // CAUTION HOT!
67 // (see Catalog.h - near the definition of FinalizePreparedStatements)
68 5798 FinalizePreparedStatements();
69 11596 }
70
71
72 2675 void WritableCatalog::Transaction() {
73
1/3
✓ Branch 2 taken 2675 times.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
 2675 LogCvmfs(kLogCatalog, kLogVerboseMsg, "opening SQLite transaction for '%s'",
74 5350 mountpoint().c_str());
75 2675 const bool retval = database().BeginTransaction();
76
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 2675 times.
 2675 assert(retval == true);
77 2675 }
78
79
80 2437 void WritableCatalog::Commit() {
81
1/3
✓ Branch 2 taken 2437 times.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
 2437 LogCvmfs(kLogCatalog, kLogVerboseMsg, "closing SQLite transaction for '%s'",
82 4874 mountpoint().c_str());
83 2437 const bool retval = database().CommitTransaction();
84
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 2437 times.
 2437 assert(retval == true);
85 2437 dirty_ = false;
86 2437 }
87
88
89 2978 void WritableCatalog::InitPreparedStatements() {
90 2978 Catalog::InitPreparedStatements(); // polymorphism: up call
91
92
2/4
✓ Branch 2 taken 2978 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 2978 times.
✗ Branch 7 not taken.
 5956 const bool retval = SqlCatalog(database(), "PRAGMA foreign_keys = ON;")
93
1/2
✓ Branch 1 taken 2978 times.
✗ Branch 2 not taken.
 2978 .Execute();
94
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 2978 times.
 2978 assert(retval);
95
1/2
✓ Branch 3 taken 2978 times.
✗ Branch 4 not taken.
 2978 sql_insert_ = new SqlDirentInsert(database());
96
1/2
✓ Branch 3 taken 2978 times.
✗ Branch 4 not taken.
 2978 sql_unlink_ = new SqlDirentUnlink(database());
97
1/2
✓ Branch 3 taken 2978 times.
✗ Branch 4 not taken.
 2978 sql_touch_ = new SqlDirentTouch(database());
98
1/2
✓ Branch 3 taken 2978 times.
✗ Branch 4 not taken.
 2978 sql_update_ = new SqlDirentUpdate(database());
99
1/2
✓ Branch 3 taken 2978 times.
✗ Branch 4 not taken.
 2978 sql_chunk_insert_ = new SqlChunkInsert(database());
100
1/2
✓ Branch 3 taken 2978 times.
✗ Branch 4 not taken.
 2978 sql_chunks_remove_ = new SqlChunksRemove(database());
101
1/2
✓ Branch 3 taken 2978 times.
✗ Branch 4 not taken.
 2978 sql_chunks_count_ = new SqlChunksCount(database());
102
1/2
✓ Branch 3 taken 2978 times.
✗ Branch 4 not taken.
 2978 sql_max_link_id_ = new SqlMaxHardlinkGroup(database());
103
1/2
✓ Branch 3 taken 2978 times.
✗ Branch 4 not taken.
 2978 sql_inc_linkcount_ = new SqlIncLinkcount(database());
104 2978 }
105
106
107 2899 void WritableCatalog::FinalizePreparedStatements() {
108 // no polymorphism: no up call (see Catalog.h -
109 // near the definition of this method)
110
1/2
✓ Branch 0 taken 2899 times.
✗ Branch 1 not taken.
 2899 delete sql_insert_;
111
1/2
✓ Branch 0 taken 2899 times.
✗ Branch 1 not taken.
 2899 delete sql_unlink_;
112
1/2
✓ Branch 0 taken 2899 times.
✗ Branch 1 not taken.
 2899 delete sql_touch_;
113
1/2
✓ Branch 0 taken 2899 times.
✗ Branch 1 not taken.
 2899 delete sql_update_;
114
1/2
✓ Branch 0 taken 2899 times.
✗ Branch 1 not taken.
 2899 delete sql_chunk_insert_;
115
1/2
✓ Branch 0 taken 2899 times.
✗ Branch 1 not taken.
 2899 delete sql_chunks_remove_;
116
1/2
✓ Branch 0 taken 2899 times.
✗ Branch 1 not taken.
 2899 delete sql_chunks_count_;
117
1/2
✓ Branch 0 taken 2899 times.
✗ Branch 1 not taken.
 2899 delete sql_max_link_id_;
118
1/2
✓ Branch 0 taken 2899 times.
✗ Branch 1 not taken.
 2899 delete sql_inc_linkcount_;
119 2899 }
120
121
122 /**
123 * Find out the maximal hardlink group id in this catalog.
124 */
125 75 uint32_t WritableCatalog::GetMaxLinkId() const {
126 75 int result = -1;
127
128
1/2
✓ Branch 1 taken 75 times.
✗ Branch 2 not taken.
 75 if (sql_max_link_id_->FetchRow()) {
129 75 result = sql_max_link_id_->GetMaxGroupId();
130 }
131 75 sql_max_link_id_->Reset();
132
133 75 return result;
134 }
135
136
137 /**
138 * Adds a directory entry.
139 * @param entry the DirectoryEntry to add to the catalog
140 * @param entry_path the full path of the DirectoryEntry to add
141 * @param parent_path the full path of the containing directory
142 */
143 15903 void WritableCatalog::AddEntry(const DirectoryEntry &entry,
144 const XattrList &xattrs,
145 const string &entry_path,
146 const string &parent_path) {
147
1/2
✓ Branch 1 taken 15903 times.
✗ Branch 2 not taken.
 15903 SetDirty();
148
149
1/6
✗ Branch 1 not taken.
✗ Branch 2 not taken.
✓ Branch 3 taken 15903 times.
✗ Branch 4 not taken.
✗ Branch 6 not taken.
✗ Branch 7 not taken.
 15903 LogCvmfs(kLogCatalog, kLogVerboseMsg, "add entry '%s' to '%s'",
150
1/2
✓ Branch 1 taken 15903 times.
✗ Branch 2 not taken.
 31806 entry_path.c_str(), mountpoint().c_str());
151
152
1/2
✓ Branch 2 taken 15903 times.
✗ Branch 3 not taken.
 15903 const shash::Md5 path_hash((shash::AsciiPtr(entry_path)));
153
1/2
✓ Branch 2 taken 15903 times.
✗ Branch 3 not taken.
 15903 const shash::Md5 parent_hash((shash::AsciiPtr(parent_path)));
154
1/2
✓ Branch 1 taken 15903 times.
✗ Branch 2 not taken.
 15903 DirectoryEntry effective_entry(entry);
155 15903 effective_entry.set_has_xattrs(!xattrs.IsEmpty());
156
157
1/2
✓ Branch 1 taken 15903 times.
✗ Branch 2 not taken.
 15903 bool retval = sql_insert_->BindPathHash(path_hash)
158
2/4
✓ Branch 1 taken 15903 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 15903 times.
✗ Branch 4 not taken.
 15903 && sql_insert_->BindParentPathHash(parent_hash)
159
3/6
✓ Branch 0 taken 15903 times.
✗ Branch 1 not taken.
✓ Branch 3 taken 15903 times.
✗ Branch 4 not taken.
✓ Branch 5 taken 15903 times.
✗ Branch 6 not taken.
 31806 && sql_insert_->BindDirent(effective_entry);
160
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 15903 times.
 15903 assert(retval);
161
1/2
✓ Branch 1 taken 15903 times.
✗ Branch 2 not taken.
 15903 if (xattrs.IsEmpty()) {
162
1/2
✓ Branch 1 taken 15903 times.
✗ Branch 2 not taken.
 15903 retval = sql_insert_->BindXattrEmpty();
163 } else {
164 ✗ retval = sql_insert_->BindXattr(xattrs);
165 }
166
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 15903 times.
 15903 assert(retval);
167
1/2
✓ Branch 1 taken 15903 times.
✗ Branch 2 not taken.
 15903 retval = sql_insert_->Execute();
168
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 15903 times.
 15903 assert(retval);
169
1/2
✓ Branch 1 taken 15903 times.
✗ Branch 2 not taken.
 15903 sql_insert_->Reset();
170
171
1/2
✓ Branch 1 taken 15903 times.
✗ Branch 2 not taken.
 15903 delta_counters_.Increment(effective_entry);
172 15903 }
173
174
175 /**
176 * Removes the specified entry from the catalog.
177 * Note: removing a directory which is non-empty results in dangling entries.
178 * (this should be treated in upper layers)
179 * @param entry_path the full path of the DirectoryEntry to delete
180 */
181 3916 void WritableCatalog::RemoveEntry(const string &file_path) {
182
1/2
✓ Branch 1 taken 3916 times.
✗ Branch 2 not taken.
 3916 DirectoryEntry entry;
183
2/4
✓ Branch 1 taken 3916 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 3916 times.
✗ Branch 5 not taken.
 3916 bool retval = LookupPath(PathString(file_path), &entry);
184
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 3916 times.
 3916 assert(retval);
185
186
1/2
✓ Branch 1 taken 3916 times.
✗ Branch 2 not taken.
 3916 SetDirty();
187
188 // If the entry used to be a chunked file... remove the chunks
189
1/2
✗ Branch 1 not taken.
✓ Branch 2 taken 3916 times.
 3916 if (entry.IsChunkedFile()) {
190 ✗ RemoveFileChunks(file_path);
191 }
192
193 // remove the entry itself
194
1/2
✓ Branch 2 taken 3916 times.
✗ Branch 3 not taken.
 3916 const shash::Md5 path_hash = shash::Md5(shash::AsciiPtr(file_path));
195
4/9
✓ Branch 1 taken 3916 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 3916 times.
✗ Branch 4 not taken.
✗ Branch 5 not taken.
✓ Branch 6 taken 3916 times.
✗ Branch 7 not taken.
✓ Branch 8 taken 3916 times.
✗ Branch 9 not taken.
 3916 retval = sql_unlink_->BindPathHash(path_hash) && sql_unlink_->Execute();
196
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 3916 times.
 3916 assert(retval);
197
1/2
✓ Branch 1 taken 3916 times.
✗ Branch 2 not taken.
 3916 sql_unlink_->Reset();
198
199
1/2
✓ Branch 1 taken 3916 times.
✗ Branch 2 not taken.
 3916 delta_counters_.Decrement(entry);
200 3916 }
201
202
203 ✗ void WritableCatalog::IncLinkcount(const string &path_within_group,
204 const int delta) {
205 ✗ SetDirty();
206
207 ✗ const shash::Md5 path_hash = shash::Md5(shash::AsciiPtr(path_within_group));
208
209 ✗ const bool retval = sql_inc_linkcount_->BindPathHash(path_hash)
210 ✗ && sql_inc_linkcount_->BindDelta(delta)
211 ✗ && sql_inc_linkcount_->Execute();
212 ✗ assert(retval);
213 ✗ sql_inc_linkcount_->Reset();
214 }
215
216
217 97 void WritableCatalog::TouchEntry(const DirectoryEntryBase &entry,
218 const XattrList &xattrs,
219 const shash::Md5 &path_hash) {
220
1/2
✓ Branch 1 taken 97 times.
✗ Branch 2 not taken.
 97 SetDirty();
221
222
1/2
✓ Branch 1 taken 97 times.
✗ Branch 2 not taken.
 97 catalog::DirectoryEntry prev_entry;
223
1/2
✓ Branch 1 taken 97 times.
✗ Branch 2 not taken.
 97 bool retval = LookupMd5Path(path_hash, &prev_entry);
224
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 97 times.
 97 assert(retval);
225
226
1/2
✓ Branch 1 taken 97 times.
✗ Branch 2 not taken.
 97 retval = sql_touch_->BindPathHash(path_hash)
227
3/6
✓ Branch 0 taken 97 times.
✗ Branch 1 not taken.
✓ Branch 3 taken 97 times.
✗ Branch 4 not taken.
✓ Branch 5 taken 97 times.
✗ Branch 6 not taken.
 97 && sql_touch_->BindDirentBase(entry);
228
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 97 times.
 97 assert(retval);
229
1/2
✓ Branch 1 taken 97 times.
✗ Branch 2 not taken.
 97 if (xattrs.IsEmpty()) {
230
1/2
✓ Branch 1 taken 97 times.
✗ Branch 2 not taken.
 97 retval = sql_touch_->BindXattrEmpty();
231
1/2
✗ Branch 1 not taken.
✓ Branch 2 taken 97 times.
 97 if (prev_entry.HasXattrs())
232 ✗ delta_counters_.self.xattrs--;
233 } else {
234 ✗ retval = sql_touch_->BindXattr(xattrs);
235 ✗ if (!prev_entry.HasXattrs())
236 ✗ delta_counters_.self.xattrs++;
237 }
238
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 97 times.
 97 assert(retval);
239
1/2
✓ Branch 1 taken 97 times.
✗ Branch 2 not taken.
 97 retval = sql_touch_->Execute();
240
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 97 times.
 97 assert(retval);
241
1/2
✓ Branch 1 taken 97 times.
✗ Branch 2 not taken.
 97 sql_touch_->Reset();
242 97 }
243
244
245 5962 void WritableCatalog::UpdateEntry(const DirectoryEntry &entry,
246 const shash::Md5 &path_hash) {
247 5962 SetDirty();
248
249 5962 const bool retval = sql_update_->BindPathHash(path_hash)
250
1/2
✓ Branch 1 taken 5962 times.
✗ Branch 2 not taken.
 5962 && sql_update_->BindDirent(entry)
251
2/4
✓ Branch 0 taken 5962 times.
✗ Branch 1 not taken.
✓ Branch 3 taken 5962 times.
✗ Branch 4 not taken.
 11924 && sql_update_->Execute();
252
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 5962 times.
 5962 assert(retval);
253 5962 sql_update_->Reset();
254 5962 }
255
256 382 void WritableCatalog::AddFileChunk(const std::string &entry_path,
257 const FileChunk &chunk) {
258
1/2
✓ Branch 1 taken 382 times.
✗ Branch 2 not taken.
 382 SetDirty();
259
260
1/2
✓ Branch 2 taken 382 times.
✗ Branch 3 not taken.
 382 const shash::Md5 path_hash((shash::AsciiPtr(entry_path)));
261
262
1/4
✓ Branch 3 taken 382 times.
✗ Branch 4 not taken.
✗ Branch 5 not taken.
✗ Branch 6 not taken.
 382 LogCvmfs(kLogCatalog, kLogVerboseMsg,
263 "adding chunk for %s from offset %ld "
264 "and chunk size: %ld bytes",
265 382 entry_path.c_str(), chunk.offset(), chunk.offset() + chunk.size());
266
267 382 delta_counters_.self.file_chunks++;
268
269
1/2
✓ Branch 1 taken 382 times.
✗ Branch 2 not taken.
 382 const bool retval = sql_chunk_insert_->BindPathHash(path_hash)
270
2/4
✓ Branch 1 taken 382 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 382 times.
✗ Branch 4 not taken.
 382 && sql_chunk_insert_->BindFileChunk(chunk)
271
3/6
✓ Branch 0 taken 382 times.
✗ Branch 1 not taken.
✓ Branch 3 taken 382 times.
✗ Branch 4 not taken.
✓ Branch 5 taken 382 times.
✗ Branch 6 not taken.
 764 && sql_chunk_insert_->Execute();
272
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 382 times.
 382 assert(retval);
273
1/2
✓ Branch 1 taken 382 times.
✗ Branch 2 not taken.
 382 sql_chunk_insert_->Reset();
274 382 }
275
276
277 /**
278 * Removes the file chunks for a given file path
279 * @param entry_path the file path to clear from it's file chunks
280 */
281 ✗ void WritableCatalog::RemoveFileChunks(const std::string &entry_path) {
282 ✗ const shash::Md5 path_hash((shash::AsciiPtr(entry_path)));
283 bool retval;
284
285 // subtract the number of chunks from the statistics counters
286 ✗ retval = sql_chunks_count_->BindPathHash(path_hash)
287 ✗ && sql_chunks_count_->Execute();
288 ✗ assert(retval);
289 ✗ const int chunks_count = sql_chunks_count_->GetChunkCount();
290 ✗ delta_counters_.self.file_chunks -= chunks_count;
291 ✗ sql_chunks_count_->Reset();
292
293 // remove the chunks associated to `entry_path`
294 ✗ retval = sql_chunks_remove_->BindPathHash(path_hash)
295 ✗ && sql_chunks_remove_->Execute();
296 ✗ assert(retval);
297 ✗ sql_chunks_remove_->Reset();
298 }
299
300
301 /**
302 * Sets the last modified time stamp of this catalog to current time.
303 */
304 5387 void WritableCatalog::UpdateLastModified() {
305
2/4
✓ Branch 4 taken 5387 times.
✗ Branch 5 not taken.
✓ Branch 7 taken 5387 times.
✗ Branch 8 not taken.
 5387 database().SetProperty("last_modified", static_cast<uint64_t>(time(NULL)));
306 5387 }
307
308
309 /**
310 * Increments the revision of the catalog in the database.
311 */
312 1567 void WritableCatalog::IncrementRevision() { SetRevision(GetRevision() + 1); }
313
314
315 1567 void WritableCatalog::SetRevision(const uint64_t new_revision) {
316
2/4
✓ Branch 3 taken 1567 times.
✗ Branch 4 not taken.
✓ Branch 6 taken 1567 times.
✗ Branch 7 not taken.
 1567 database().SetProperty("revision", new_revision);
317 1567 }
318
319
320 ✗ void WritableCatalog::SetBranch(const std::string &branch_name) {
321 ✗ database().SetProperty("branch", branch_name);
322 }
323
324
325 ✗ void WritableCatalog::SetTTL(const uint64_t new_ttl) {
326 ✗ database().SetProperty("TTL", new_ttl);
327 }
328
329
330 ✗ bool WritableCatalog::SetVOMSAuthz(const std::string &voms_authz) {
331 ✗ return database().SetVOMSAuthz(voms_authz);
332 }
333
334
335 /**
336 * Sets the content hash of the previous catalog revision.
337 */
338 1567 void WritableCatalog::SetPreviousRevision(const shash::Any &hash) {
339
2/4
✓ Branch 4 taken 1567 times.
✗ Branch 5 not taken.
✓ Branch 7 taken 1567 times.
✗ Branch 8 not taken.
 1567 database().SetProperty("previous_revision", hash.ToString());
340 1567 }
341
342
343 /**
344 * Moves a subtree from this catalog into a just created nested catalog.
345 */
346 965 void WritableCatalog::Partition(WritableCatalog *new_nested_catalog) {
347 // Create connection between parent and child catalogs
348
3/6
✓ Branch 1 taken 965 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 965 times.
✗ Branch 5 not taken.
✓ Branch 7 taken 965 times.
✗ Branch 8 not taken.
 965 MakeTransitionPoint(new_nested_catalog->mountpoint().ToString());
349
1/2
✓ Branch 1 taken 965 times.
✗ Branch 2 not taken.
 965 new_nested_catalog->MakeNestedRoot();
350 965 delta_counters_.subtree.directories++; // Root directory in nested catalog
351
352 // Move the present directory tree into the newly created nested catalog
353 // if we hit nested catalog mountpoints on the way, we return them through
354 // the passed list
355 965 vector<string> GrandChildMountpoints;
356
3/6
✓ Branch 1 taken 965 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 965 times.
✗ Branch 5 not taken.
✓ Branch 7 taken 965 times.
✗ Branch 8 not taken.
 965 MoveToNested(new_nested_catalog->mountpoint().ToString(), new_nested_catalog,
357 &GrandChildMountpoints);
358
359 // Nested catalog mountpoints found in the moved directory structure are now
360 // links to nested catalogs of the newly created nested catalog.
361 // Move these references into the new nested catalog
362
1/2
✓ Branch 1 taken 965 times.
✗ Branch 2 not taken.
 965 MoveCatalogsToNested(GrandChildMountpoints, new_nested_catalog);
363 965 }
364
365
366 965 void WritableCatalog::MakeTransitionPoint(const string &mountpoint) {
367 // Find the directory entry to edit
368
1/2
✓ Branch 1 taken 965 times.
✗ Branch 2 not taken.
 965 DirectoryEntry transition_entry;
369
1/2
✓ Branch 1 taken 965 times.
✗ Branch 2 not taken.
 965 const bool retval = LookupPath(
370
1/2
✓ Branch 3 taken 965 times.
✗ Branch 4 not taken.
 1930 PathString(mountpoint.data(), mountpoint.length()), &transition_entry);
371
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 965 times.
 965 assert(retval);
372
373
2/4
✓ Branch 1 taken 965 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 965 times.
✗ Branch 5 not taken.
 965 assert(transition_entry.IsDirectory()
374 && !transition_entry.IsNestedCatalogRoot());
375
376 965 transition_entry.set_is_nested_catalog_mountpoint(true);
377
1/2
✓ Branch 1 taken 965 times.
✗ Branch 2 not taken.
 965 UpdateEntry(transition_entry, mountpoint);
378 965 }
379
380
381 965 void WritableCatalog::MakeNestedRoot() {
382
1/2
✓ Branch 1 taken 965 times.
✗ Branch 2 not taken.
 965 DirectoryEntry root_entry;
383
2/4
✓ Branch 1 taken 965 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 965 times.
✗ Branch 5 not taken.
 965 const bool retval = LookupPath(mountpoint(), &root_entry);
384
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 965 times.
 965 assert(retval);
385
386
2/4
✓ Branch 1 taken 965 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 965 times.
✗ Branch 5 not taken.
 965 assert(root_entry.IsDirectory() && !root_entry.IsNestedCatalogMountpoint());
387
388 965 root_entry.set_is_nested_catalog_root(true);
389
3/6
✓ Branch 1 taken 965 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 965 times.
✗ Branch 5 not taken.
✓ Branch 7 taken 965 times.
✗ Branch 8 not taken.
 965 UpdateEntry(root_entry, mountpoint().ToString());
390 965 }
391
392
393 1634 void WritableCatalog::MoveToNestedRecursively(
394 const string directory,
395 WritableCatalog *new_nested_catalog,
396 vector<string> *grand_child_mountpoints) {
397 // After creating a new nested catalog we have to move all elements
398 // now contained by the new one. List and move them recursively.
399 1634 DirectoryEntryList listing;
400 1634 const bool resolve_magic_symlinks = false;
401
2/4
✓ Branch 1 taken 1634 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 1634 times.
✗ Branch 5 not taken.
 1634 bool retval = ListingPath(PathString(directory), &listing,
402 resolve_magic_symlinks);
403
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 1634 times.
 1634 assert(retval);
404
405 // Go through the listing
406 1634 const XattrList empty_xattrs;
407 1634 for (DirectoryEntryList::const_iterator i = listing.begin(),
408 1634 iEnd = listing.end();
409
2/2
✓ Branch 1 taken 3598 times.
✓ Branch 2 taken 1634 times.
 5232 i != iEnd;
410 3598 ++i) {
411
1/2
✓ Branch 2 taken 3598 times.
✗ Branch 3 not taken.
 3598 const string full_path = i->GetFullPath(directory);
412
413 // The entries are first inserted into the new catalog
414
1/2
✗ Branch 2 not taken.
✓ Branch 3 taken 3598 times.
 3598 if (i->HasXattrs()) {
415 ✗ XattrList xattrs;
416 ✗ retval = LookupXattrsPath(PathString(full_path), &xattrs);
417 ✗ assert(retval);
418 ✗ assert(!xattrs.IsEmpty());
419 ✗ new_nested_catalog->AddEntry(*i, xattrs, full_path);
420 ✗ } else {
421
1/2
✓ Branch 2 taken 3598 times.
✗ Branch 3 not taken.
 3598 new_nested_catalog->AddEntry(*i, empty_xattrs, full_path);
422 }
423
424 // Then we check if we have some special cases:
425
1/2
✗ Branch 2 not taken.
✓ Branch 3 taken 3598 times.
 3598 if (i->IsNestedCatalogMountpoint()) {
426 ✗ grand_child_mountpoints->push_back(full_path);
427
2/2
✓ Branch 2 taken 669 times.
✓ Branch 3 taken 2929 times.
 3598 } else if (i->IsDirectory()) {
428 // Recurse deeper into the directory tree
429
2/4
✓ Branch 1 taken 669 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 669 times.
✗ Branch 5 not taken.
 669 MoveToNestedRecursively(full_path, new_nested_catalog,
430 grand_child_mountpoints);
431
1/2
✗ Branch 2 not taken.
✓ Branch 3 taken 2929 times.
 2929 } else if (i->IsChunkedFile()) {
432 ✗ MoveFileChunksToNested(full_path, i->hash_algorithm(),
433 new_nested_catalog);
434 }
435
436 // Remove the entry from the current catalog
437
1/2
✓ Branch 1 taken 3598 times.
✗ Branch 2 not taken.
 3598 RemoveEntry(full_path);
438 3598 }
439 1634 }
440
441
442 965 void WritableCatalog::MoveCatalogsToNested(
443 const vector<string> &nested_catalogs,
444 WritableCatalog *new_nested_catalog) {
445 1930 for (vector<string>::const_iterator i = nested_catalogs.begin(),
446 965 iEnd = nested_catalogs.end();
447
1/2
✗ Branch 1 not taken.
✓ Branch 2 taken 965 times.
 965 i != iEnd;
448 ✗ ++i) {
449 ✗ shash::Any hash_nested;
450 uint64_t size_nested;
451 ✗ const bool retval = FindNested(PathString(*i), &hash_nested, &size_nested);
452 ✗ assert(retval);
453
454 ✗ Catalog *attached_reference = NULL;
455 ✗ RemoveNestedCatalog(*i, &attached_reference);
456
457 ✗ new_nested_catalog->InsertNestedCatalog(*i, attached_reference, hash_nested,
458 size_nested);
459 }
460 965 }
461
462
463 ✗ void WritableCatalog::MoveFileChunksToNested(
464 const std::string &full_path,
465 const shash::Algorithms algorithm,
466 WritableCatalog *new_nested_catalog) {
467 ✗ FileChunkList chunks;
468 ✗ ListPathChunks(PathString(full_path), algorithm, &chunks);
469 ✗ assert(chunks.size() > 0);
470
471 ✗ for (unsigned i = 0; i < chunks.size(); ++i) {
472 ✗ new_nested_catalog->AddFileChunk(full_path, *chunks.AtPtr(i));
473 }
474 }
475
476
477 /**
478 * Insert a nested catalog reference into this catalog.
479 * The attached catalog object of this mountpoint can be specified (optional)
480 * This way, the in-memory representation of the catalog tree is updated, too
481 * @param mountpoint the path to the catalog to add a reference to
482 * @param attached_reference can contain a reference to the attached catalog
483 * object of mountpoint
484 * @param content_hash can be set to safe a content hash together with the
485 * reference
486 */
487 1435 void WritableCatalog::InsertNestedCatalog(const string &mountpoint,
488 Catalog *attached_reference,
489 const shash::Any content_hash,
490 const uint64_t size) {
491 1435 const string hash_string = (!content_hash.IsNull()) ? content_hash.ToString()
492
6/12
✓ Branch 0 taken 470 times.
✓ Branch 1 taken 965 times.
✓ Branch 3 taken 470 times.
✗ Branch 4 not taken.
✗ Branch 5 not taken.
✗ Branch 6 not taken.
✓ Branch 7 taken 965 times.
✗ Branch 8 not taken.
✓ Branch 9 taken 965 times.
✓ Branch 10 taken 470 times.
✗ Branch 11 not taken.
✗ Branch 12 not taken.
 1435 : "";
493
494 1435 SqlCatalog stmt(database(), "INSERT INTO nested_catalogs (path, sha1, size) "
495
2/4
✓ Branch 2 taken 1435 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 1435 times.
✗ Branch 6 not taken.
 4305 "VALUES (:p, :sha1, :size);");
496
1/2
✓ Branch 1 taken 1435 times.
✗ Branch 2 not taken.
 1435 const bool retval = stmt.BindText(1, mountpoint)
497
2/4
✓ Branch 1 taken 1435 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 1435 times.
✗ Branch 4 not taken.
 1435 && stmt.BindText(2, hash_string)
498
5/11
✓ Branch 0 taken 1435 times.
✗ Branch 1 not taken.
✓ Branch 3 taken 1435 times.
✗ Branch 4 not taken.
✓ Branch 5 taken 1435 times.
✗ Branch 6 not taken.
✗ Branch 7 not taken.
✓ Branch 8 taken 1435 times.
✗ Branch 9 not taken.
✓ Branch 10 taken 1435 times.
✗ Branch 11 not taken.
 2870 && stmt.BindInt64(3, size) && stmt.Execute();
499
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 1435 times.
 1435 assert(retval);
500
501 // If a reference of the in-memory object of the newly referenced
502 // catalog was passed, we add this to our own children
503
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 1435 times.
 1435 if (attached_reference != NULL)
504 ✗ AddChild(attached_reference);
505
506
1/2
✓ Branch 1 taken 1435 times.
✗ Branch 2 not taken.
 1435 ResetNestedCatalogCacheUnprotected();
507
508 1435 delta_counters_.self.nested_catalogs++;
509 1435 }
510
511
512 /**
513 * Registers a snapshot in /.cvmfs/snapshots. Note that bind mountpoints are
514 * not universally handled: in Partition and MergeIntoParent, bind mountpoint
515 * handling is missing!
516 */
517 ✗ void WritableCatalog::InsertBindMountpoint(const string &mountpoint,
518 const shash::Any content_hash,
519 const uint64_t size) {
520 ✗ SqlCatalog stmt(database(),
521 "INSERT INTO bind_mountpoints (path, sha1, size) "
522 ✗ "VALUES (:p, :sha1, :size);");
523 ✗ const bool retval = stmt.BindText(1, mountpoint)
524 ✗ && stmt.BindText(2, content_hash.ToString())
525 ✗ && stmt.BindInt64(3, size) && stmt.Execute();
526 ✗ assert(retval);
527 }
528
529
530 /**
531 * Remove a nested catalog reference from the database.
532 * If the catalog 'mountpoint' is currently attached as a child, it will be
533 * removed, too (but not detached).
534 * @param[in] mountpoint the mountpoint of the nested catalog to dereference in
535 the database
536 * @param[out] attached_reference is set to the object of the attached child or
537 * to NULL
538 */
539 141 void WritableCatalog::RemoveNestedCatalog(const string &mountpoint,
540 Catalog **attached_reference) {
541
1/2
✓ Branch 1 taken 141 times.
✗ Branch 2 not taken.
 141 shash::Any dummy;
542 uint64_t dummy_size;
543
2/4
✓ Branch 3 taken 141 times.
✗ Branch 4 not taken.
✓ Branch 6 taken 141 times.
✗ Branch 7 not taken.
 141 bool retval = FindNested(PathString(mountpoint.data(), mountpoint.length()),
544 &dummy, &dummy_size);
545
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 141 times.
 141 assert(retval);
546
547
2/4
✓ Branch 2 taken 141 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 141 times.
✗ Branch 7 not taken.
 282 SqlCatalog stmt(database(), "DELETE FROM nested_catalogs WHERE path = :p;");
548
4/9
✓ Branch 1 taken 141 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 141 times.
✗ Branch 4 not taken.
✗ Branch 5 not taken.
✓ Branch 6 taken 141 times.
✗ Branch 7 not taken.
✓ Branch 8 taken 141 times.
✗ Branch 9 not taken.
 141 retval = stmt.BindText(1, mountpoint) && stmt.Execute();
549
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 141 times.
 141 assert(retval);
550
551 // If the reference was successfully deleted, we also have to check whether
552 // there is also an attached reference in our in-memory data.
553 // In this case we remove the child and return it through **attached_reference
554
2/4
✓ Branch 1 taken 141 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 141 times.
✗ Branch 5 not taken.
 141 Catalog *child = FindChild(PathString(mountpoint));
555
2/2
✓ Branch 0 taken 75 times.
✓ Branch 1 taken 66 times.
 141 if (child != NULL)
556
1/2
✓ Branch 1 taken 75 times.
✗ Branch 2 not taken.
 75 RemoveChild(child);
557
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 141 times.
 141 if (attached_reference != NULL)
558 ✗ *attached_reference = child;
559
560
1/2
✓ Branch 1 taken 141 times.
✗ Branch 2 not taken.
 141 ResetNestedCatalogCacheUnprotected();
561
562 141 delta_counters_.self.nested_catalogs--;
563 141 }
564
565
566 /**
567 * Unregisters a snapshot from /.cvmfs/snapshots. Note that bind mountpoints
568 * are not universally handled: in Partition and MergeIntoParent, bind
569 * mountpoint handling is missing!
570 */
571 ✗ void WritableCatalog::RemoveBindMountpoint(const std::string &mountpoint) {
572 ✗ shash::Any dummy;
573 uint64_t dummy_size;
574 ✗ bool retval = FindNested(PathString(mountpoint.data(), mountpoint.length()),
575 &dummy, &dummy_size);
576 ✗ assert(retval);
577
578 ✗ SqlCatalog stmt(database(), "DELETE FROM bind_mountpoints WHERE path = :p;");
579 ✗ retval = stmt.BindText(1, mountpoint) && stmt.Execute();
580 ✗ assert(retval);
581 }
582
583
584 /**
585 * Updates the link to a nested catalog in the database.
586 * @param path the path of the nested catalog to update
587 * @param hash the hash to set the given nested catalog link to
588 * @param size the uncompressed catalog database file size
589 * @param child_counters the statistics counters of the nested catalog
590 */
591 902 void WritableCatalog::UpdateNestedCatalog(const std::string &path,
592 const shash::Any &hash,
593 const uint64_t size,
594 const DeltaCounters &child_counters) {
595 902 const MutexLockGuard guard(lock_);
596
1/2
✓ Branch 1 taken 902 times.
✗ Branch 2 not taken.
 902 SetDirty();
597
598
1/2
✓ Branch 1 taken 902 times.
✗ Branch 2 not taken.
 902 child_counters.PopulateToParent(&delta_counters_);
599
600
1/2
✓ Branch 1 taken 902 times.
✗ Branch 2 not taken.
 902 const string hash_str = hash.ToString();
601 const string sql = "UPDATE nested_catalogs SET sha1 = :sha1, size = :size "
602
1/2
✓ Branch 2 taken 902 times.
✗ Branch 3 not taken.
 902 "WHERE path = :path;";
603
1/2
✓ Branch 2 taken 902 times.
✗ Branch 3 not taken.
 902 SqlCatalog stmt(database(), sql);
604
605
3/7
✓ Branch 1 taken 902 times.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
✓ Branch 4 taken 902 times.
✗ Branch 5 not taken.
✓ Branch 6 taken 902 times.
✗ Branch 7 not taken.
 1804 const bool retval = stmt.BindText(1, hash_str) && stmt.BindInt64(2, size)
606
5/11
✓ Branch 0 taken 902 times.
✗ Branch 1 not taken.
✓ Branch 3 taken 902 times.
✗ Branch 4 not taken.
✓ Branch 5 taken 902 times.
✗ Branch 6 not taken.
✗ Branch 7 not taken.
✓ Branch 8 taken 902 times.
✗ Branch 9 not taken.
✓ Branch 10 taken 902 times.
✗ Branch 11 not taken.
 1804 && stmt.BindText(3, path) && stmt.Execute();
607
608
1/2
✓ Branch 1 taken 902 times.
✗ Branch 2 not taken.
 902 ResetNestedCatalogCacheUnprotected();
609
610
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 902 times.
 902 assert(retval);
611 902 }
612
613
614 75 void WritableCatalog::MergeIntoParent() {
615
2/4
✓ Branch 1 taken 75 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 75 times.
✗ Branch 5 not taken.
 75 assert(!IsRoot() && HasParent());
616 75 WritableCatalog *parent = GetWritableParent();
617
618 75 CopyToParent();
619
620 // Copy the nested catalog references
621 75 CopyCatalogsToParent();
622
623 // Fix counters in parent
624 75 delta_counters_.PopulateToParent(&parent->delta_counters_);
625 75 Counters &counters = GetWritableCounters();
626 75 counters.ApplyDelta(delta_counters_);
627 75 counters.MergeIntoParent(&parent->delta_counters_);
628
629 // Remove the nested catalog reference for this nested catalog.
630 // From now on this catalog will be dangling!
631
2/4
✓ Branch 2 taken 75 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 75 times.
✗ Branch 6 not taken.
 75 parent->RemoveNestedCatalog(this->mountpoint().ToString(), NULL);
632 75 }
633
634
635 ✗ void WritableCatalog::RemoveFromParent() {
636 ✗ assert(!IsRoot() && HasParent());
637 ✗ WritableCatalog *parent = GetWritableParent();
638
639 // Remove the nested catalog reference for this nested catalog.
640 // From now on this catalog will be dangling!
641 ✗ parent->RemoveNestedCatalog(this->mountpoint().ToString(), NULL);
642 ✗ parent->delta_counters_.RemoveFromSubtree(
643 ✗ Counters::Diff(Counters(), GetCounters()));
644 }
645
646
647 75 void WritableCatalog::CopyCatalogsToParent() {
648
1/2
✓ Branch 1 taken 75 times.
✗ Branch 2 not taken.
 75 WritableCatalog *parent = GetWritableParent();
649
650 // Obtain a list of all nested catalog references
651
1/2
✓ Branch 1 taken 75 times.
✗ Branch 2 not taken.
 75 const NestedCatalogList nested_catalog_references = ListOwnNestedCatalogs();
652
653 // Go through the list and update the databases
654 // simultaneously we are checking if the referenced catalogs are currently
655 // attached and update the in-memory data structures as well
656 150 for (NestedCatalogList::const_iterator i = nested_catalog_references.begin(),
657 75 iEnd = nested_catalog_references.end();
658
1/2
✗ Branch 1 not taken.
✓ Branch 2 taken 75 times.
 75 i != iEnd;
659 ✗ ++i) {
660 ✗ Catalog *child = FindChild(i->mountpoint);
661 ✗ parent->InsertNestedCatalog(i->mountpoint.ToString(), child, i->hash,
662 ✗ i->size);
663 ✗ parent->delta_counters_.self.nested_catalogs--; // Will be fixed later
664 }
665 75 }
666
667 75 void WritableCatalog::CopyToParent() {
668 // We could simply copy all entries from this database to the 'other' database
669 // BUT: 1. this would create collisions in hardlink group IDs.
670 // therefore we first update all hardlink group IDs to fit behind the
671 // ones in the 'other' database
672 // 2. the root entry of the nested catalog is present twice:
673 // 1. in the parent directory (as mount point) and
674 // 2. in the nested catalog (as root entry)
675 // therefore we delete the mount point from the parent before merging
676
677
1/2
✓ Branch 1 taken 75 times.
✗ Branch 2 not taken.
 75 WritableCatalog *parent = GetWritableParent();
678
679 // Update hardlink group IDs in this nested catalog.
680 // To avoid collisions we add the maximal present hardlink group ID in parent
681 // to all hardlink group IDs in the nested catalog.
682
1/2
✓ Branch 1 taken 75 times.
✗ Branch 2 not taken.
 75 const uint64_t offset = static_cast<uint64_t>(parent->GetMaxLinkId()) << 32;
683 const string update_link_ids = "UPDATE catalog SET hardlinks = hardlinks + "
684
2/4
✓ Branch 1 taken 75 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 75 times.
✗ Branch 5 not taken.
 150 + StringifyInt(offset)
685
1/2
✓ Branch 1 taken 75 times.
✗ Branch 2 not taken.
 75 + " WHERE hardlinks > (1 << 32);";
686
687
1/2
✓ Branch 2 taken 75 times.
✗ Branch 3 not taken.
 75 SqlCatalog sql_update_link_ids(database(), update_link_ids);
688
1/2
✓ Branch 1 taken 75 times.
✗ Branch 2 not taken.
 75 bool retval = sql_update_link_ids.Execute();
689
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 75 times.
 75 assert(retval);
690
691 // Remove the nested catalog root.
692 // It is already present in the parent.
693
3/6
✓ Branch 1 taken 75 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 75 times.
✗ Branch 5 not taken.
✓ Branch 7 taken 75 times.
✗ Branch 8 not taken.
 75 RemoveEntry(this->mountpoint().ToString());
694
695 // Now copy all DirectoryEntries to the 'other' catalog.
696 // There will be no data collisions, as we resolved them beforehand
697
1/2
✓ Branch 0 taken 75 times.
✗ Branch 1 not taken.
 75 if (dirty_)
698
1/2
✓ Branch 1 taken 75 times.
✗ Branch 2 not taken.
 75 Commit();
699
2/2
✓ Branch 0 taken 31 times.
✓ Branch 1 taken 44 times.
 75 if (parent->dirty_)
700
1/2
✓ Branch 1 taken 31 times.
✗ Branch 2 not taken.
 31 parent->Commit();
701
2/4
✓ Branch 1 taken 75 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 75 times.
✗ Branch 5 not taken.
 225 SqlCatalog sql_attach(database(), "ATTACH '" + parent->database_path()
702
1/2
✓ Branch 1 taken 75 times.
✗ Branch 2 not taken.
 150 + "' "
703
1/2
✓ Branch 1 taken 75 times.
✗ Branch 2 not taken.
 75 "AS other;");
704
1/2
✓ Branch 1 taken 75 times.
✗ Branch 2 not taken.
 75 retval = sql_attach.Execute();
705
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 75 times.
 75 assert(retval);
706
2/4
✓ Branch 2 taken 75 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 75 times.
✗ Branch 7 not taken.
 150 retval = SqlCatalog(database(), "INSERT INTO other.catalog "
707 "SELECT * FROM main.catalog;")
708
1/2
✓ Branch 1 taken 75 times.
✗ Branch 2 not taken.
 75 .Execute();
709
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 75 times.
 75 assert(retval);
710
2/4
✓ Branch 2 taken 75 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 75 times.
✗ Branch 7 not taken.
 150 retval = SqlCatalog(database(), "INSERT INTO other.chunks "
711 "SELECT * FROM main.chunks;")
712
1/2
✓ Branch 1 taken 75 times.
✗ Branch 2 not taken.
 75 .Execute();
713
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 75 times.
 75 assert(retval);
714
3/6
✓ Branch 2 taken 75 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 75 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 75 times.
✗ Branch 10 not taken.
 75 retval = SqlCatalog(database(), "DETACH other;").Execute();
715
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 75 times.
 75 assert(retval);
716
1/2
✓ Branch 1 taken 75 times.
✗ Branch 2 not taken.
 75 parent->SetDirty();
717
718 // Change the just copied nested catalog root to an ordinary directory
719 // (the nested catalog is merged into it's parent)
720
1/2
✓ Branch 1 taken 75 times.
✗ Branch 2 not taken.
 75 DirectoryEntry old_root_entry;
721
2/4
✓ Branch 1 taken 75 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 75 times.
✗ Branch 5 not taken.
 75 retval = parent->LookupPath(this->mountpoint(), &old_root_entry);
722
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 75 times.
 75 assert(retval);
723
724
3/6
✓ Branch 1 taken 75 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 75 times.
✗ Branch 5 not taken.
✓ Branch 7 taken 75 times.
✗ Branch 8 not taken.
 75 assert(old_root_entry.IsDirectory()
725 && old_root_entry.IsNestedCatalogMountpoint()
726 && !old_root_entry.IsNestedCatalogRoot());
727
728 // Remove the nested catalog root mark
729 75 old_root_entry.set_is_nested_catalog_mountpoint(false);
730
3/6
✓ Branch 1 taken 75 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 75 times.
✗ Branch 5 not taken.
✓ Branch 7 taken 75 times.
✗ Branch 8 not taken.
 75 parent->UpdateEntry(old_root_entry, this->mountpoint().ToString());
731 75 }
732
733
734 /**
735 * Writes delta_counters_ to the database.
736 */
737 2532 void WritableCatalog::UpdateCounters() {
738 2532 const bool retval = delta_counters_.WriteToDatabase(database())
739
2/4
✓ Branch 0 taken 2532 times.
✗ Branch 1 not taken.
✓ Branch 3 taken 2532 times.
✗ Branch 4 not taken.
 2532 && ReadCatalogCounters();
740
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 2532 times.
 2532 assert(retval);
741 2532 }
742
743
744 /**
745 * Checks if the database of this catalogs needs cleanup and defragments it
746 * if necessary
747 */
748 1567 void WritableCatalog::VacuumDatabaseIfNecessary() {
749 1567 const CatalogDatabase &db = database();
750 1567 bool needs_defragmentation = false;
751 1567 double ratio = 0.0;
752 1567 std::string reason;
753 1567 const MutexLockGuard m(lock_);
754
755
2/4
✓ Branch 1 taken 1567 times.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
✓ Branch 4 taken 1567 times.
 1567 if ((ratio = db.GetFreePageRatio()) > kMaximalFreePageRatio) {
756 ✗ needs_defragmentation = true;
757 ✗ reason = "free pages";
758
3/4
✓ Branch 1 taken 1567 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 417 times.
✓ Branch 4 taken 1150 times.
 1567 } else if ((ratio = db.GetRowIdWasteRatio()) > kMaximalRowIdWasteRatio) {
759 417 needs_defragmentation = true;
760
1/2
✓ Branch 1 taken 417 times.
✗ Branch 2 not taken.
 417 reason = "wasted row IDs";
761 }
762
763
2/2
✓ Branch 0 taken 417 times.
✓ Branch 1 taken 1150 times.
 1567 if (needs_defragmentation) {
764
3/14
✓ Branch 1 taken 324 times.
✓ Branch 2 taken 93 times.
✗ Branch 3 not taken.
✓ Branch 4 taken 417 times.
✗ Branch 5 not taken.
✗ Branch 6 not taken.
✗ Branch 7 not taken.
✗ Branch 8 not taken.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✗ Branch 11 not taken.
✗ Branch 12 not taken.
✗ Branch 14 not taken.
✗ Branch 15 not taken.
 927 LogCvmfs(kLogCatalog, kLogStdout | kLogNoLinebreak,
765 "Note: Catalog at %s gets defragmented (%.2f%% %s)... ",
766
3/6
✓ Branch 2 taken 93 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 93 times.
✓ Branch 6 taken 324 times.
✗ Branch 8 not taken.
✗ Branch 9 not taken.
 927 (IsRoot()) ? "/" : mountpoint().c_str(), ratio * 100.0,
767 reason.c_str());
768
2/4
✓ Branch 1 taken 417 times.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
✓ Branch 4 taken 417 times.
 417 if (!db.Vacuum()) {
769 ✗ PANIC(kLogStderr, "failed (SQLite: %s)", db.GetLastErrorMsg().c_str());
770 }
771
1/2
✓ Branch 1 taken 417 times.
✗ Branch 2 not taken.
 417 LogCvmfs(kLogCatalog, kLogStdout, "done");
772 }
773 1567 }
774
775 } // namespace catalog
776