GCC Code Coverage Report

Directory: cvmfs/
File: cvmfs/mountpoint.cc
Date: 2025-07-13 02:35:07
Exec Total Coverage
Lines: 954 1346 70.9%
Branches: 1211 2996 40.4%
Line Branch Exec Source
1 /**
2 * This file is part of the CernVM File System.
3 */
4
5 #include "mountpoint.h"
6
7 #include <errno.h>
8 #include <fcntl.h>
9 #include <inttypes.h>
10 #include <stdint.h>
11 #include <unistd.h>
12
13 #include <algorithm>
14 #include <cassert>
15 #include <climits>
16 #include <cstring>
17 #include <vector>
18
19 #include "duplex_fuse.h" // NOLINT
20
21 #ifndef CVMFS_LIBCVMFS
22 #ifdef FUSE_CAP_EXPORT_SUPPORT
23 #define CVMFS_NFS_SUPPORT
24 #else
25 #warning "No NFS support, Fuse too old"
26 #endif
27 #endif
28
29 #include "authz/authz_curl.h"
30 #include "authz/authz_fetch.h"
31 #include "authz/authz_session.h"
32 #include "backoff.h"
33 #include "cache.h"
34 #include "cache_extern.h"
35 #include "cache_posix.h"
36 #include "cache_ram.h"
37 #include "cache_stream.h"
38 #include "cache_tiered.h"
39 #include "catalog.h"
40 #include "catalog_mgr_client.h"
41 #include "clientctx.h"
42 #include "crypto/signature.h"
43 #include "duplex_sqlite3.h"
44 #include "fetch.h"
45 #include "file_chunk.h"
46 #include "globals.h"
47 #include "glue_buffer.h"
48 #include "google/protobuf/stubs/common.h"
49 #include "history.h"
50 #include "history_sqlite.h"
51 #include "lru_md.h"
52 #include "manifest.h"
53 #include "manifest_fetch.h"
54 #include "network/download.h"
55 #include "nfs_maps.h"
56 #ifdef CVMFS_NFS_SUPPORT
57 #include "nfs_maps_leveldb.h"
58 #include "nfs_maps_sqlite.h"
59 #endif
60 #include "options.h"
61 #include "quota_posix.h"
62 #include "resolv_conf_event_handler.h"
63 #include "sqlitemem.h"
64 #include "sqlitevfs.h"
65 #include "statistics.h"
66 #include "telemetry_aggregator.h"
67 #include "tracer.h"
68 #include "util/concurrency.h"
69 #include "util/logging.h"
70 #include "util/platform.h"
71 #include "util/pointer.h"
72 #include "util/posix.h"
73 #include "util/string.h"
74 #include "util/uuid.h"
75 #include "wpad.h"
76
77 using namespace std; // NOLINT
78
79
80 bool FileSystem::g_alive = false;
81 const char *FileSystem::kDefaultCacheBase = "/var/lib/cvmfs";
82 const char *FileSystem::kDefaultCacheMgrInstance = "default";
83
84
85 1194 FileSystem::IoErrorInfo::IoErrorInfo() : counter_(NULL), timestamp_last_(0) { }
86
87 ✗ void FileSystem::IoErrorInfo::Reset() {
88 ✗ counter_->Set(0);
89 ✗ timestamp_last_ = 0;
90 }
91
92 ✗ void FileSystem::IoErrorInfo::AddIoError() {
93 ✗ perf::Inc(counter_);
94 ✗ timestamp_last_ = time(NULL);
95 }
96
97 1194 void FileSystem::IoErrorInfo::SetCounter(perf::Counter *c) { counter_ = c; }
98
99 ✗ int64_t FileSystem::IoErrorInfo::count() { return counter_->Get(); }
100
101 ✗ time_t FileSystem::IoErrorInfo::timestamp_last() { return timestamp_last_; }
102
103
104 /**
105 * A cache instance name is part of a bash parameter and can only contain
106 * certain characters.
107 */
108 64 bool FileSystem::CheckInstanceName(const std::string &instance) {
109
2/2
✓ Branch 1 taken 4 times.
✓ Branch 2 taken 60 times.
 64 if (instance.length() > 24)
110 4 return false;
111
1/2
✓ Branch 1 taken 60 times.
✗ Branch 2 not taken.
 60 const sanitizer::CacheInstanceSanitizer instance_sanitizer;
112
3/4
✓ Branch 1 taken 60 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 8 times.
✓ Branch 4 taken 52 times.
 60 if (!instance_sanitizer.IsValid(instance)) {
113
2/4
✓ Branch 1 taken 8 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 8 times.
✗ Branch 5 not taken.
 16 boot_error_ = "invalid instance name (" + instance + "), "
114
1/2
✓ Branch 1 taken 8 times.
✗ Branch 2 not taken.
 8 + "only characters a-z, A-Z, 0-9, _ are allowed";
115 8 boot_status_ = loader::kFailCacheDir;
116 8 return false;
117 }
118 52 return true;
119 60 }
120
121
122 /**
123 * Not all possible combinations of cache flags / modes are valid.
124 */
125 1151 bool FileSystem::CheckPosixCacheSettings(
126 const FileSystem::PosixCacheSettings &settings) {
127
4/4
✓ Branch 0 taken 112 times.
✓ Branch 1 taken 1039 times.
✓ Branch 2 taken 12 times.
✓ Branch 3 taken 100 times.
 1151 if (settings.is_alien && settings.is_shared) {
128 boot_error_ = "Failure: shared local disk cache and alien cache mutually "
129 12 "exclusive. Please turn off shared local disk cache.";
130 12 boot_status_ = loader::kFailOptions;
131 12 return false;
132 }
133
4/4
✓ Branch 0 taken 100 times.
✓ Branch 1 taken 1039 times.
✓ Branch 2 taken 8 times.
✓ Branch 3 taken 92 times.
 1139 if (settings.is_alien && settings.is_managed) {
134 boot_error_ = "Failure: quota management and alien cache mutually "
135 8 "exclusive. Please turn off quota limit.";
136 8 boot_status_ = loader::kFailOptions;
137 8 return false;
138 }
139
140
2/2
✓ Branch 0 taken 687 times.
✓ Branch 1 taken 444 times.
 1131 if (type_ == kFsLibrary) {
141
3/4
✓ Branch 0 taken 683 times.
✓ Branch 1 taken 4 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 683 times.
 687 if (settings.is_shared || settings.is_managed) {
142 boot_error_ = "Failure: libcvmfs supports only unmanaged exclusive cache "
143 4 "or alien cache.";
144 4 boot_status_ = loader::kFailOptions;
145 4 return false;
146 }
147 }
148
149
4/4
✓ Branch 0 taken 432 times.
✓ Branch 1 taken 695 times.
✓ Branch 2 taken 4 times.
✓ Branch 3 taken 428 times.
 1127 if (settings.cache_base_defined && settings.cache_dir_defined) {
150 boot_error_ = "'CVMFS_CACHE_BASE' and 'CVMFS_CACHE_DIR' are mutually "
151 4 "exclusive";
152 4 boot_status_ = loader::kFailOptions;
153 4 return false;
154 }
155
156 1123 return true;
157 }
158
159
160 /**
161 * Creation of state and manager classes. The destructor should mirror this
162 * method.
163 */
164 1194 FileSystem *FileSystem::Create(const FileSystem::FileSystemInfo &fs_info) {
165
3/6
✓ Branch 1 taken 1194 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 1194 times.
✗ Branch 5 not taken.
✓ Branch 7 taken 1194 times.
✗ Branch 8 not taken.
 1194 UniquePtr<FileSystem> file_system(new FileSystem(fs_info));
166
167
1/2
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
 1194 file_system->SetupGlobalEnvironmentParams();
168
169
1/2
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
 1194 file_system->SetupLogging();
170
1/2
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
 1194 LogCvmfs(kLogCvmfs, kLogDebug, "Options:\n%s",
171
1/2
✓ Branch 3 taken 1194 times.
✗ Branch 4 not taken.
 2388 file_system->options_mgr()->Dump().c_str());
172
173
1/2
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
 1194 file_system->CreateStatistics();
174
1/2
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
 1194 file_system->SetupSqlite();
175
2/4
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✓ Branch 5 taken 1194 times.
 1194 if (!file_system->DetermineNfsMode())
176 ✗ return file_system.Release();
177
3/4
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
✓ Branch 4 taken 43 times.
✓ Branch 5 taken 1151 times.
 1194 if (!file_system->SetupWorkspace())
178 43 return file_system.Release();
179
180 // Redirect SQlite temp directory to workspace (global variable)
181 1151 const unsigned length_tempdir = file_system->workspace_.length() + 1;
182
1/2
✓ Branch 1 taken 1151 times.
✗ Branch 2 not taken.
 1151 sqlite3_temp_directory = static_cast<char *>(sqlite3_malloc(length_tempdir));
183 1151 snprintf(sqlite3_temp_directory,
184 length_tempdir,
185 "%s",
186 1151 file_system->workspace_.c_str());
187
188
3/4
✓ Branch 2 taken 1151 times.
✗ Branch 3 not taken.
✓ Branch 4 taken 36 times.
✓ Branch 5 taken 1115 times.
 1151 if (!file_system->TriageCacheMgr())
189 36 return file_system.Release();
190
1/2
✓ Branch 2 taken 1115 times.
✗ Branch 3 not taken.
 1115 file_system->SetupUuid();
191
1/4
✗ Branch 2 not taken.
✓ Branch 3 taken 1115 times.
✗ Branch 4 not taken.
✗ Branch 5 not taken.
 1115 if (!file_system->SetupNfsMaps())
192 ✗ return file_system.Release();
193
1/2
✓ Branch 2 taken 1115 times.
✗ Branch 3 not taken.
 1115 const bool retval = sqlite::RegisterVfsRdOnly(file_system->cache_mgr_,
194 1115 file_system->statistics_,
195 sqlite::kVfsOptDefault);
196
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 1115 times.
 1115 assert(retval);
197 1115 file_system->has_custom_sqlitevfs_ = true;
198
199
1/2
✓ Branch 1 taken 1115 times.
✗ Branch 2 not taken.
 1115 ClientCtx::GetInstance();
200
201 1115 file_system->boot_status_ = loader::kFailOk;
202 1115 return file_system.Release();
203 1194 }
204
205
206 1194 void FileSystem::CreateStatistics() {
207
2/4
✓ Branch 1 taken 1194 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 1194 times.
✗ Branch 5 not taken.
 1194 statistics_ = new perf::Statistics();
208
209 // Register the ShortString's static counters
210
3/6
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 1194 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 1194 times.
✗ Branch 10 not taken.
 1194 statistics_->Register("pathstring.n_instances", "Number of instances");
211
3/6
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 1194 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 1194 times.
✗ Branch 10 not taken.
 1194 statistics_->Register("pathstring.n_overflows", "Number of overflows");
212
3/6
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 1194 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 1194 times.
✗ Branch 10 not taken.
 1194 statistics_->Register("namestring.n_instances", "Number of instances");
213
3/6
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 1194 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 1194 times.
✗ Branch 10 not taken.
 1194 statistics_->Register("namestring.n_overflows", "Number of overflows");
214
3/6
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 1194 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 1194 times.
✗ Branch 10 not taken.
 1194 statistics_->Register("linkstring.n_instances", "Number of instances");
215
3/6
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 1194 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 1194 times.
✗ Branch 10 not taken.
 1194 statistics_->Register("linkstring.n_overflows", "Number of overflows");
216
217 // Callback counters
218
3/6
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 1194 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 1194 times.
✗ Branch 10 not taken.
 1194 n_fs_open_ = statistics_->Register("cvmfs.n_fs_open",
219 "Overall number of file open operations");
220
3/6
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 1194 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 1194 times.
✗ Branch 10 not taken.
 1194 n_fs_dir_open_ = statistics_->Register(
221 "cvmfs.n_fs_dir_open", "Overall number of directory open operations");
222
3/6
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 1194 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 1194 times.
✗ Branch 10 not taken.
 1194 n_fs_lookup_ = statistics_->Register("cvmfs.n_fs_lookup",
223 "Number of lookups");
224
3/6
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 1194 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 1194 times.
✗ Branch 10 not taken.
 1194 n_fs_lookup_negative_ = statistics_->Register("cvmfs.n_fs_lookup_negative",
225 "Number of negative lookups");
226
3/6
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 1194 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 1194 times.
✗ Branch 10 not taken.
 1194 n_fs_stat_ = statistics_->Register("cvmfs.n_fs_stat", "Number of stats");
227
3/6
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 1194 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 1194 times.
✗ Branch 10 not taken.
 1194 n_fs_stat_stale_ = statistics_->Register(
228 "cvmfs.n_fs_stat_stale",
229 "Number of stats for stale (open, meanwhile changed) regular files");
230
3/6
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 1194 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 1194 times.
✗ Branch 10 not taken.
 1194 n_fs_statfs_ = statistics_->Register("cvmfs.n_fs_statfs",
231 "Overall number of statsfs calls");
232
3/6
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 1194 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 1194 times.
✗ Branch 10 not taken.
 1194 n_fs_statfs_cached_ = statistics_->Register(
233 "cvmfs.n_fs_statfs_cached",
234 "Number of statsfs calls that accessed the cached statfs info");
235
3/6
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 1194 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 1194 times.
✗ Branch 10 not taken.
 1194 n_fs_read_ = statistics_->Register("cvmfs.n_fs_read", "Number of files read");
236
3/6
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 1194 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 1194 times.
✗ Branch 10 not taken.
 1194 n_fs_readlink_ = statistics_->Register("cvmfs.n_fs_readlink",
237 "Number of links read");
238
3/6
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 1194 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 1194 times.
✗ Branch 10 not taken.
 1194 n_fs_forget_ = statistics_->Register("cvmfs.n_fs_forget",
239 "Number of inode forgets");
240
3/6
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 1194 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 1194 times.
✗ Branch 10 not taken.
 1194 n_fs_inode_replace_ = statistics_->Register(
241 "cvmfs.n_fs_inode_replace",
242 "Number of stale inodes that got replaced by an up-to-date version");
243
3/6
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 1194 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 1194 times.
✗ Branch 10 not taken.
 1194 no_open_files_ = statistics_->Register("cvmfs.no_open_files",
244 "Number of currently opened files");
245
3/6
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 1194 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 1194 times.
✗ Branch 10 not taken.
 1194 no_open_dirs_ = statistics_->Register(
246 "cvmfs.no_open_dirs", "Number of currently opened directories");
247
3/6
✓ Branch 1 taken 1194 times.
✗ Branch 2 not taken.
✓ Branch 5 taken 1194 times.
✗ Branch 6 not taken.
✓ Branch 8 taken 1194 times.
✗ Branch 9 not taken.
 1194 io_error_info_.SetCounter(
248 1194 statistics_->Register("cvmfs.n_io_error", "Number of I/O errors"));
249
3/6
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 1194 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 1194 times.
✗ Branch 10 not taken.
 1194 n_eio_total_ = statistics_->Register(
250 "eio.total",
251 "EIO returned to calling process. Sum of individual eio counters");
252
3/6
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 1194 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 1194 times.
✗ Branch 10 not taken.
 1194 n_eio_01_ = statistics_->Register(
253 "eio.01", "EIO returned by cvmfs.cc:cvmfs_lookup() - lookup failed");
254
3/6
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 1194 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 1194 times.
✗ Branch 10 not taken.
 1194 n_eio_02_ = statistics_->Register("eio.02",
255 "EIO returned by cvmfs.cc:ReplyNegative() "
256 "- CVMFS-specific metadata not found");
257
3/6
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 1194 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 1194 times.
✗ Branch 10 not taken.
 1194 n_eio_03_ = statistics_->Register(
258 "eio.03",
259 "EIO returned by cvmfs.cc:cvmfs_opendir() - failed to open directory ");
260
3/6
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 1194 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 1194 times.
✗ Branch 10 not taken.
 1194 n_eio_04_ = statistics_->Register("eio.04",
261 "EIO returned by cvmfs.cc:cvmfs_open() "
262 "- chunked file does not have any chunks");
263
3/6
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 1194 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 1194 times.
✗ Branch 10 not taken.
 1194 n_eio_05_ = statistics_->Register(
264 "eio.05",
265 "EIO returned by cvmfs.cc:cvmfs_read() - failed to fetch chunk");
266
3/6
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 1194 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 1194 times.
✗ Branch 10 not taken.
 1194 n_eio_06_ = statistics_->Register(
267 "eio.06", "EIO returned by cvmfs.cc:cvmfs_open() - failed to open file");
268
3/6
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 1194 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 1194 times.
✗ Branch 10 not taken.
 1194 n_eio_07_ = statistics_->Register(
269 "eio.07", "EIO returned by cvmfs.cc:cvmfs_read() - failed to read chunk");
270
3/6
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 1194 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 1194 times.
✗ Branch 10 not taken.
 1194 n_eio_08_ = statistics_->Register(
271 "eio.08", "EIO returned by cvmfs.cc:cvmfs_read() - failed to read file");
272
3/6
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 1194 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 1194 times.
✗ Branch 10 not taken.
 1194 n_emfile_ = statistics_->Register(
273 "eio.emfile",
274 "EMFILE returned by cvmfs.cc:cvmfs_read(): too many open files");
275
276 1194 string optarg;
277
3/10
✓ Branch 1 taken 1194 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 1194 times.
✗ Branch 5 not taken.
✗ Branch 7 not taken.
✓ Branch 8 taken 1194 times.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
 2388 if (options_mgr_->GetValue("CVMFS_INSTRUMENT_FUSE", &optarg)
278
3/10
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✓ Branch 5 taken 1194 times.
✗ Branch 7 not taken.
✗ Branch 8 not taken.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✓ Branch 11 taken 1194 times.
✗ Branch 12 not taken.
 2388 && options_mgr_->IsOn(optarg)) {
279 ✗ HighPrecisionTimer::g_is_enabled = true;
280 }
281
282
2/4
✓ Branch 1 taken 1194 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 1194 times.
✗ Branch 5 not taken.
 1194 hist_fs_lookup_ = new Log2Histogram(30);
283
2/4
✓ Branch 1 taken 1194 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 1194 times.
✗ Branch 5 not taken.
 1194 hist_fs_forget_ = new Log2Histogram(30);
284
2/4
✓ Branch 1 taken 1194 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 1194 times.
✗ Branch 5 not taken.
 1194 hist_fs_forget_multi_ = new Log2Histogram(30);
285
2/4
✓ Branch 1 taken 1194 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 1194 times.
✗ Branch 5 not taken.
 1194 hist_fs_getattr_ = new Log2Histogram(30);
286
2/4
✓ Branch 1 taken 1194 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 1194 times.
✗ Branch 5 not taken.
 1194 hist_fs_readlink_ = new Log2Histogram(30);
287
2/4
✓ Branch 1 taken 1194 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 1194 times.
✗ Branch 5 not taken.
 1194 hist_fs_opendir_ = new Log2Histogram(30);
288
2/4
✓ Branch 1 taken 1194 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 1194 times.
✗ Branch 5 not taken.
 1194 hist_fs_releasedir_ = new Log2Histogram(30);
289
2/4
✓ Branch 1 taken 1194 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 1194 times.
✗ Branch 5 not taken.
 1194 hist_fs_readdir_ = new Log2Histogram(30);
290
2/4
✓ Branch 1 taken 1194 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 1194 times.
✗ Branch 5 not taken.
 1194 hist_fs_open_ = new Log2Histogram(30);
291
2/4
✓ Branch 1 taken 1194 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 1194 times.
✗ Branch 5 not taken.
 1194 hist_fs_read_ = new Log2Histogram(30);
292
2/4
✓ Branch 1 taken 1194 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 1194 times.
✗ Branch 5 not taken.
 1194 hist_fs_release_ = new Log2Histogram(30);
293 1194 }
294
295
296 /**
297 * Figure out mode of operation and cache directory. Checking options for
298 * sanity is in a separate method.
299 */
300 1119 FileSystem::PosixCacheSettings FileSystem::DeterminePosixCacheSettings(
301 const string &instance) {
302 1119 string optarg;
303 1119 PosixCacheSettings settings;
304
305
5/16
✓ Branch 1 taken 1119 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 1119 times.
✗ Branch 5 not taken.
✓ Branch 7 taken 1119 times.
✗ Branch 8 not taken.
✓ Branch 10 taken 1119 times.
✗ Branch 11 not taken.
✗ Branch 13 not taken.
✓ Branch 14 taken 1119 times.
✗ Branch 15 not taken.
✗ Branch 16 not taken.
✗ Branch 18 not taken.
✗ Branch 19 not taken.
✗ Branch 21 not taken.
✗ Branch 22 not taken.
 2238 if (options_mgr_->GetValue(MkCacheParm("CVMFS_CACHE_REFCOUNT", instance),
306 &optarg)
307
3/10
✓ Branch 2 taken 1119 times.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✓ Branch 5 taken 1119 times.
✗ Branch 7 not taken.
✗ Branch 8 not taken.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✓ Branch 11 taken 1119 times.
✗ Branch 12 not taken.
 2238 && options_mgr_->IsOff(optarg)) {
308 ✗ settings.do_refcount = false;
309 }
310
311
6/16
✓ Branch 1 taken 1119 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 1119 times.
✗ Branch 5 not taken.
✓ Branch 7 taken 1119 times.
✗ Branch 8 not taken.
✓ Branch 10 taken 1119 times.
✗ Branch 11 not taken.
✓ Branch 13 taken 8 times.
✓ Branch 14 taken 1111 times.
✗ Branch 15 not taken.
✗ Branch 16 not taken.
✗ Branch 18 not taken.
✗ Branch 19 not taken.
✗ Branch 21 not taken.
✗ Branch 22 not taken.
 2238 if (options_mgr_->GetValue(MkCacheParm("CVMFS_CACHE_SHARED", instance),
312 &optarg)
313
7/10
✓ Branch 2 taken 1119 times.
✗ Branch 3 not taken.
✓ Branch 4 taken 416 times.
✓ Branch 5 taken 703 times.
✓ Branch 7 taken 416 times.
✗ Branch 8 not taken.
✓ Branch 9 taken 8 times.
✓ Branch 10 taken 408 times.
✓ Branch 11 taken 1119 times.
✗ Branch 12 not taken.
 2238 && options_mgr_->IsOn(optarg)) {
314 8 settings.is_shared = true;
315 }
316
5/16
✓ Branch 1 taken 1119 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 1119 times.
✗ Branch 5 not taken.
✓ Branch 7 taken 1119 times.
✗ Branch 8 not taken.
✓ Branch 10 taken 1119 times.
✗ Branch 11 not taken.
✗ Branch 13 not taken.
✓ Branch 14 taken 1119 times.
✗ Branch 15 not taken.
✗ Branch 16 not taken.
✗ Branch 18 not taken.
✗ Branch 19 not taken.
✗ Branch 21 not taken.
✗ Branch 22 not taken.
 2238 if (options_mgr_->GetValue(MkCacheParm("CVMFS_CACHE_SERVER_MODE", instance),
317 &optarg)
318
3/10
✓ Branch 2 taken 1119 times.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✓ Branch 5 taken 1119 times.
✗ Branch 7 not taken.
✗ Branch 8 not taken.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✓ Branch 11 taken 1119 times.
✗ Branch 12 not taken.
 2238 && options_mgr_->IsOn(optarg)) {
319 ✗ settings.avoid_rename = true;
320 }
321
322
2/2
✓ Branch 0 taken 432 times.
✓ Branch 1 taken 687 times.
 1119 if (type_ == kFsFuse)
323 432 settings.quota_limit = kDefaultQuotaLimit;
324
5/8
✓ Branch 2 taken 1119 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 1119 times.
✗ Branch 6 not taken.
✓ Branch 8 taken 1119 times.
✗ Branch 9 not taken.
✓ Branch 13 taken 44 times.
✓ Branch 14 taken 1075 times.
 1119 if (options_mgr_->GetValue(MkCacheParm("CVMFS_CACHE_QUOTA_LIMIT", instance),
325 &optarg)) {
326
1/2
✓ Branch 1 taken 44 times.
✗ Branch 2 not taken.
 44 settings.quota_limit = String2Int64(optarg) * 1024 * 1024;
327 }
328
2/2
✓ Branch 0 taken 400 times.
✓ Branch 1 taken 719 times.
 1119 if (settings.quota_limit > 0)
329 400 settings.is_managed = true;
330
331
1/2
✓ Branch 1 taken 1119 times.
✗ Branch 2 not taken.
 1119 settings.cache_path = kDefaultCacheBase;
332
5/8
✓ Branch 2 taken 1119 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 1119 times.
✗ Branch 6 not taken.
✓ Branch 8 taken 1119 times.
✗ Branch 9 not taken.
✓ Branch 13 taken 436 times.
✓ Branch 14 taken 683 times.
 1119 if (options_mgr_->GetValue(MkCacheParm("CVMFS_CACHE_BASE", instance),
333 &optarg)) {
334
1/2
✓ Branch 1 taken 436 times.
✗ Branch 2 not taken.
 436 settings.cache_path = MakeCanonicalPath(optarg);
335 436 settings.cache_base_defined = true;
336 }
337
2/2
✓ Branch 0 taken 8 times.
✓ Branch 1 taken 1111 times.
 1119 if (settings.is_shared) {
338
1/2
✓ Branch 1 taken 8 times.
✗ Branch 2 not taken.
 8 settings.cache_path += "/shared";
339 } else {
340
2/4
✓ Branch 1 taken 1111 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 1111 times.
✗ Branch 5 not taken.
 1111 settings.cache_path += "/" + name_;
341 }
342
343 // CheckCacheMode makes sure that CVMFS_CACHE_DIR and CVMFS_CACHE_BASE are
344 // not set at the same time.
345
5/8
✓ Branch 2 taken 1119 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 1119 times.
✗ Branch 6 not taken.
✓ Branch 8 taken 1119 times.
✗ Branch 9 not taken.
✓ Branch 13 taken 683 times.
✓ Branch 14 taken 436 times.
 1119 if (options_mgr_->GetValue(MkCacheParm("CVMFS_CACHE_DIR", instance),
346 &optarg)) {
347 683 settings.cache_dir_defined = true;
348
1/2
✓ Branch 1 taken 683 times.
✗ Branch 2 not taken.
 683 settings.cache_path = optarg;
349 }
350
5/8
✓ Branch 2 taken 1119 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 1119 times.
✗ Branch 6 not taken.
✓ Branch 8 taken 1119 times.
✗ Branch 9 not taken.
✓ Branch 13 taken 100 times.
✓ Branch 14 taken 1019 times.
 1119 if (options_mgr_->GetValue(MkCacheParm("CVMFS_CACHE_ALIEN", instance),
351 &optarg)) {
352 100 settings.is_alien = true;
353
1/2
✓ Branch 1 taken 100 times.
✗ Branch 2 not taken.
 100 settings.cache_path = optarg;
354 }
355 // We already changed the cwd to the workspace
356 // Which is only done if using FUSE
357
6/6
✓ Branch 0 taken 432 times.
✓ Branch 1 taken 687 times.
✓ Branch 3 taken 408 times.
✓ Branch 4 taken 24 times.
✓ Branch 5 taken 408 times.
✓ Branch 6 taken 711 times.
 1119 if ((type_ == kFsFuse) && (settings.cache_path == workspace_fullpath_)) {
358
1/2
✓ Branch 1 taken 408 times.
✗ Branch 2 not taken.
 408 settings.cache_path = ".";
359 }
360
361 // The cache workspace usually is the cache directory, unless explicitly
362 // set otherwise
363
1/2
✓ Branch 1 taken 1119 times.
✗ Branch 2 not taken.
 1119 settings.workspace = settings.cache_path;
364
6/16
✓ Branch 1 taken 1119 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 1119 times.
✗ Branch 5 not taken.
✓ Branch 7 taken 1119 times.
✗ Branch 8 not taken.
✓ Branch 10 taken 1119 times.
✗ Branch 11 not taken.
✓ Branch 13 taken 46 times.
✓ Branch 14 taken 1073 times.
✗ Branch 15 not taken.
✗ Branch 16 not taken.
✗ Branch 18 not taken.
✗ Branch 19 not taken.
✗ Branch 21 not taken.
✗ Branch 22 not taken.
 2238 if (options_mgr_->GetValue(MkCacheParm("CVMFS_CACHE_WORKSPACE", instance),
365 &optarg)
366
9/20
✓ Branch 2 taken 1119 times.
✗ Branch 3 not taken.
✓ Branch 4 taken 1119 times.
✗ Branch 5 not taken.
✓ Branch 8 taken 1119 times.
✗ Branch 9 not taken.
✓ Branch 11 taken 1119 times.
✗ Branch 12 not taken.
✓ Branch 13 taken 46 times.
✓ Branch 14 taken 1073 times.
✓ Branch 15 taken 1119 times.
✗ Branch 16 not taken.
✓ Branch 18 taken 1119 times.
✗ Branch 19 not taken.
✓ Branch 21 taken 1119 times.
✗ Branch 22 not taken.
✗ Branch 23 not taken.
✗ Branch 24 not taken.
✗ Branch 26 not taken.
✗ Branch 27 not taken.
 2238 || options_mgr_->GetValue("CVMFS_WORKSPACE", &optarg)) {
367 // Used for the shared quota manager
368
1/2
✓ Branch 1 taken 46 times.
✗ Branch 2 not taken.
 46 settings.workspace = optarg;
369 }
370
371 2238 return settings;
372 1119 }
373
374
375 1194 bool FileSystem::DetermineNfsMode() {
376 1194 string optarg;
377
378
4/10
✓ Branch 1 taken 1194 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 1194 times.
✗ Branch 5 not taken.
✓ Branch 7 taken 16 times.
✓ Branch 8 taken 1178 times.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
 2388 if (options_mgr_->GetValue("CVMFS_NFS_SOURCE", &optarg)
379
6/10
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
✓ Branch 4 taken 16 times.
✓ Branch 5 taken 1178 times.
✓ Branch 7 taken 16 times.
✗ Branch 8 not taken.
✓ Branch 9 taken 16 times.
✗ Branch 10 not taken.
✓ Branch 11 taken 1194 times.
✗ Branch 12 not taken.
 2388 && options_mgr_->IsOn(optarg)) {
380 16 nfs_mode_ |= kNfsMaps;
381
4/6
✓ Branch 2 taken 16 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 16 times.
✗ Branch 6 not taken.
✓ Branch 9 taken 12 times.
✓ Branch 10 taken 4 times.
 16 if (options_mgr_->GetValue("CVMFS_NFS_SHARED", &optarg)) {
382 12 nfs_mode_ |= kNfsMapsHa;
383
1/2
✓ Branch 1 taken 12 times.
✗ Branch 2 not taken.
 12 nfs_maps_dir_ = optarg;
384 }
385 }
386
387
3/4
✓ Branch 0 taken 725 times.
✓ Branch 1 taken 469 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 725 times.
 1194 if ((type_ == kFsLibrary) && (nfs_mode_ != kNfsNone)) {
388 ✗ boot_error_ = "Failure: libcvmfs does not support NFS export.";
389 ✗ boot_status_ = loader::kFailOptions;
390 ✗ return false;
391 }
392 1194 return true;
393 1194 }
394
395
396 1194 FileSystem::FileSystem(const FileSystem::FileSystemInfo &fs_info)
397
1/2
✓ Branch 1 taken 1194 times.
✗ Branch 2 not taken.
 1194 : name_(fs_info.name)
398
1/2
✓ Branch 1 taken 1194 times.
✗ Branch 2 not taken.
 1194 , exe_path_(fs_info.exe_path)
399 1194 , type_(fs_info.type)
400 1194 , options_mgr_(fs_info.options_mgr)
401 1194 , wait_workspace_(fs_info.wait_workspace)
402 1194 , foreground_(fs_info.foreground)
403 1194 , n_fs_open_(NULL)
404 1194 , n_fs_dir_open_(NULL)
405 1194 , n_fs_lookup_(NULL)
406 1194 , n_fs_lookup_negative_(NULL)
407 1194 , n_fs_stat_(NULL)
408 1194 , n_fs_stat_stale_(NULL)
409 1194 , n_fs_statfs_(NULL)
410 1194 , n_fs_statfs_cached_(NULL)
411 1194 , n_fs_read_(NULL)
412 1194 , n_fs_readlink_(NULL)
413 1194 , n_fs_forget_(NULL)
414 1194 , n_fs_inode_replace_(NULL)
415 1194 , no_open_files_(NULL)
416 1194 , no_open_dirs_(NULL)
417 1194 , n_eio_total_(NULL)
418 1194 , n_eio_01_(NULL)
419 1194 , n_eio_02_(NULL)
420 1194 , n_eio_03_(NULL)
421 1194 , n_eio_04_(NULL)
422 1194 , n_eio_05_(NULL)
423 1194 , n_eio_06_(NULL)
424 1194 , n_eio_07_(NULL)
425 1194 , n_eio_08_(NULL)
426 1194 , n_emfile_(NULL)
427 1194 , statistics_(NULL)
428 1194 , fd_workspace_lock_(-1)
429 1194 , found_previous_crash_(false)
430 1194 , nfs_mode_(kNfsNone)
431 1194 , cache_mgr_(NULL)
432 1194 , uuid_cache_(NULL)
433 1194 , nfs_maps_(NULL)
434 2388 , has_custom_sqlitevfs_(false) {
435
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 1194 times.
 1194 assert(!g_alive);
436 1194 g_alive = true;
437 1194 g_uid = geteuid();
438 1194 g_gid = getegid();
439
440 1194 string optarg;
441 4776 if (options_mgr_->GetValue(
442
8/26
✓ Branch 1 taken 1194 times.
✗ Branch 2 not taken.
✓ Branch 5 taken 1194 times.
✗ Branch 6 not taken.
✓ Branch 8 taken 1194 times.
✗ Branch 9 not taken.
✓ Branch 11 taken 1194 times.
✗ Branch 12 not taken.
✓ Branch 14 taken 1194 times.
✗ Branch 15 not taken.
✓ Branch 17 taken 1194 times.
✗ Branch 18 not taken.
✓ Branch 20 taken 1194 times.
✗ Branch 21 not taken.
✗ Branch 23 not taken.
✓ Branch 24 taken 1194 times.
✗ Branch 25 not taken.
✗ Branch 26 not taken.
✗ Branch 28 not taken.
✗ Branch 29 not taken.
✗ Branch 31 not taken.
✗ Branch 32 not taken.
✗ Branch 34 not taken.
✗ Branch 35 not taken.
✗ Branch 37 not taken.
✗ Branch 38 not taken.
 2388 MkCacheParm("CVMFS_CACHE_SERVER_MODE", kDefaultCacheMgrInstance),
443 &optarg)
444
3/10
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✓ Branch 5 taken 1194 times.
✗ Branch 7 not taken.
✗ Branch 8 not taken.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✓ Branch 11 taken 1194 times.
✗ Branch 12 not taken.
 2388 && options_mgr_->IsOn(optarg)) {
445 ✗ g_raw_symlinks = true;
446 }
447 1194 }
448
449
450 1190 FileSystem::~FileSystem() {
451 1190 ClientCtx::CleanupInstance();
452
453
2/2
✓ Branch 0 taken 1112 times.
✓ Branch 1 taken 78 times.
 1190 if (has_custom_sqlitevfs_)
454 1112 sqlite::UnregisterVfsRdOnly();
455
456
2/2
✓ Branch 0 taken 1112 times.
✓ Branch 1 taken 78 times.
 1190 delete uuid_cache_;
457
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 1190 times.
 1190 delete nfs_maps_;
458
2/2
✓ Branch 0 taken 1112 times.
✓ Branch 1 taken 78 times.
 1190 delete cache_mgr_;
459
460
2/2
✓ Branch 0 taken 1148 times.
✓ Branch 1 taken 42 times.
 1190 if (sqlite3_temp_directory) {
461 1148 sqlite3_free(sqlite3_temp_directory);
462 1148 sqlite3_temp_directory = NULL;
463 }
464
465
2/2
✓ Branch 1 taken 1148 times.
✓ Branch 2 taken 42 times.
 1190 if (!path_crash_guard_.empty())
466 1148 unlink(path_crash_guard_.c_str());
467
2/2
✓ Branch 1 taken 1148 times.
✓ Branch 2 taken 42 times.
 1190 if (!path_workspace_lock_.empty())
468 1148 unlink(path_workspace_lock_.c_str());
469
2/2
✓ Branch 0 taken 1148 times.
✓ Branch 1 taken 42 times.
 1190 if (fd_workspace_lock_ >= 0)
470 1148 UnlockFile(fd_workspace_lock_);
471
472 1190 sqlite3_shutdown();
473 1190 SqliteMemoryManager::CleanupInstance();
474
475
1/2
✓ Branch 0 taken 1190 times.
✗ Branch 1 not taken.
 1190 delete hist_fs_lookup_;
476
1/2
✓ Branch 0 taken 1190 times.
✗ Branch 1 not taken.
 1190 delete hist_fs_forget_multi_;
477
1/2
✓ Branch 0 taken 1190 times.
✗ Branch 1 not taken.
 1190 delete hist_fs_forget_;
478
1/2
✓ Branch 0 taken 1190 times.
✗ Branch 1 not taken.
 1190 delete hist_fs_getattr_;
479
1/2
✓ Branch 0 taken 1190 times.
✗ Branch 1 not taken.
 1190 delete hist_fs_readlink_;
480
1/2
✓ Branch 0 taken 1190 times.
✗ Branch 1 not taken.
 1190 delete hist_fs_opendir_;
481
1/2
✓ Branch 0 taken 1190 times.
✗ Branch 1 not taken.
 1190 delete hist_fs_releasedir_;
482
1/2
✓ Branch 0 taken 1190 times.
✗ Branch 1 not taken.
 1190 delete hist_fs_readdir_;
483
1/2
✓ Branch 0 taken 1190 times.
✗ Branch 1 not taken.
 1190 delete hist_fs_open_;
484
1/2
✓ Branch 0 taken 1190 times.
✗ Branch 1 not taken.
 1190 delete hist_fs_read_;
485
1/2
✓ Branch 0 taken 1190 times.
✗ Branch 1 not taken.
 1190 delete hist_fs_release_;
486
1/2
✓ Branch 0 taken 1190 times.
✗ Branch 1 not taken.
 1190 delete statistics_;
487
488 1190 SetLogSyslogPrefix("");
489 1190 SetLogMicroSyslog("");
490 1190 SetLogDebugFile("");
491 1190 google::protobuf::ShutdownProtobufLibrary();
492 1190 g_alive = false;
493 1190 }
494
495
496 1152 bool FileSystem::LockWorkspace() {
497
1/2
✓ Branch 2 taken 1152 times.
✗ Branch 3 not taken.
 1152 path_workspace_lock_ = workspace_ + "/lock." + name_;
498 1152 fd_workspace_lock_ = TryLockFile(path_workspace_lock_);
499
2/2
✓ Branch 0 taken 1151 times.
✓ Branch 1 taken 1 times.
 1152 if (fd_workspace_lock_ >= 0)
500 1151 return true;
501
502
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 1 times.
 1 if (fd_workspace_lock_ == -1) {
503 ✗ boot_error_ = "could not acquire workspace lock (" + StringifyInt(errno)
504 ✗ + ")";
505 ✗ boot_status_ = loader::kFailCacheDir;
506 ✗ return false;
507 }
508
509
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 1 times.
 1 assert(fd_workspace_lock_ == -2);
510
511
1/2
✓ Branch 0 taken 1 times.
✗ Branch 1 not taken.
 1 if (!wait_workspace_) {
512 1 boot_status_ = loader::kFailLockWorkspace;
513 1 return false;
514 }
515
516 ✗ fd_workspace_lock_ = LockFile(path_workspace_lock_);
517 ✗ if (fd_workspace_lock_ < 0) {
518 ✗ boot_error_ = "could not acquire workspace lock (" + StringifyInt(errno)
519 ✗ + ")";
520 ✗ boot_status_ = loader::kFailCacheDir;
521 ✗ return false;
522 }
523 ✗ return true;
524 }
525
526
527 1090 void FileSystem::LogSqliteError(void *user_data __attribute__((unused)),
528 int sqlite_extended_error,
529 const char *message) {
530 1090 int log_dest = kLogDebug;
531 1090 const int sqlite_error = sqlite_extended_error & 0xFF;
532
2/2
✓ Branch 0 taken 24 times.
✓ Branch 1 taken 1066 times.
 1090 switch (sqlite_error) {
533 24 case SQLITE_INTERNAL:
534 case SQLITE_PERM:
535 case SQLITE_NOMEM:
536 case SQLITE_IOERR:
537 case SQLITE_CORRUPT:
538 case SQLITE_FULL:
539 case SQLITE_CANTOPEN:
540 case SQLITE_MISUSE:
541 case SQLITE_FORMAT:
542 case SQLITE_NOTADB:
543 24 log_dest |= kLogSyslogErr;
544 24 break;
545 1066 case SQLITE_WARNING:
546 case SQLITE_NOTICE:
547 default:
548 1066 break;
549 }
550
0/2
✗ Branch 0 not taken.
✗ Branch 1 not taken.
 1090 LogCvmfs(kLogCvmfs, log_dest, "SQlite3: %s (%d)", message,
551 sqlite_extended_error);
552 1090 }
553
554
555 /**
556 * Creates the cache parameter for a specific instance of the cache. Injects
557 * the instance name such that CVMFS_CACHE_FOO_BAR becomes
558 * CVMFS_CACHE_<INSTANCE>_FOO_BAR
559 */
560 10414 string FileSystem::MkCacheParm(const string &generic_parameter,
561 const string &instance) {
562
3/6
✓ Branch 2 taken 10414 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 10414 times.
✗ Branch 6 not taken.
✗ Branch 7 not taken.
✓ Branch 8 taken 10414 times.
 10414 assert(HasPrefix(generic_parameter, "CVMFS_CACHE_", false));
563
564
2/2
✓ Branch 1 taken 10054 times.
✓ Branch 2 taken 360 times.
 10414 if (instance == kDefaultCacheMgrInstance) {
565 // Compatibility parameter names
566 10054 if ((generic_parameter == "CVMFS_CACHE_SHARED")
567
5/6
✓ Branch 0 taken 1107 times.
✓ Branch 1 taken 8947 times.
✓ Branch 3 taken 1107 times.
✗ Branch 4 not taken.
✓ Branch 5 taken 1107 times.
✓ Branch 6 taken 8947 times.
 10054 && !options_mgr_->IsDefined(generic_parameter)) {
568
1/2
✓ Branch 2 taken 1107 times.
✗ Branch 3 not taken.
 1107 return "CVMFS_SHARED_CACHE";
569 }
570 8947 if ((generic_parameter == "CVMFS_CACHE_ALIEN")
571
5/6
✓ Branch 0 taken 1107 times.
✓ Branch 1 taken 7840 times.
✓ Branch 3 taken 1107 times.
✗ Branch 4 not taken.
✓ Branch 5 taken 1107 times.
✓ Branch 6 taken 7840 times.
 8947 && !options_mgr_->IsDefined(generic_parameter)) {
572
1/2
✓ Branch 2 taken 1107 times.
✗ Branch 3 not taken.
 1107 return "CVMFS_ALIEN_CACHE";
573 }
574 7840 if ((generic_parameter == "CVMFS_CACHE_SERVER_MODE")
575
5/6
✓ Branch 0 taken 2301 times.
✓ Branch 1 taken 5539 times.
✓ Branch 3 taken 2301 times.
✗ Branch 4 not taken.
✓ Branch 5 taken 2301 times.
✓ Branch 6 taken 5539 times.
 7840 && !options_mgr_->IsDefined(generic_parameter)) {
576
1/2
✓ Branch 2 taken 2301 times.
✗ Branch 3 not taken.
 2301 return "CVMFS_SERVER_CACHE_MODE";
577 }
578 5539 if ((generic_parameter == "CVMFS_CACHE_QUOTA_LIMIT")
579
5/6
✓ Branch 0 taken 1107 times.
✓ Branch 1 taken 4432 times.
✓ Branch 3 taken 1107 times.
✗ Branch 4 not taken.
✓ Branch 5 taken 1107 times.
✓ Branch 6 taken 4432 times.
 5539 && !options_mgr_->IsDefined(generic_parameter)) {
580
1/2
✓ Branch 2 taken 1107 times.
✗ Branch 3 not taken.
 1107 return "CVMFS_QUOTA_LIMIT";
581 }
582 4432 return generic_parameter;
583 }
584
585
3/6
✓ Branch 2 taken 360 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 360 times.
✗ Branch 6 not taken.
✓ Branch 8 taken 360 times.
✗ Branch 9 not taken.
 720 return "CVMFS_CACHE_" + instance + "_" + generic_parameter.substr(12);
586 }
587
588
589 ✗ void FileSystem::ResetErrorCounters() {
590 ✗ io_error_info_.Reset();
591 ✗ n_eio_total_->Set(0);
592 ✗ n_eio_01_->Set(0);
593 ✗ n_eio_02_->Set(0);
594 ✗ n_eio_03_->Set(0);
595 ✗ n_eio_04_->Set(0);
596 ✗ n_eio_05_->Set(0);
597 ✗ n_eio_06_->Set(0);
598 ✗ n_eio_07_->Set(0);
599 ✗ n_eio_08_->Set(0);
600 ✗ n_emfile_->Set(0);
601 }
602
603
604 /**
605 * Can be recursive for the tiered cache manager.
606 */
607 1199 CacheManager *FileSystem::SetupCacheMgr(const string &instance) {
608
3/4
✓ Branch 2 taken 1199 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 4 times.
✓ Branch 6 taken 1195 times.
 1199 if (constructed_instances_.find(instance) != constructed_instances_.end()) {
609
1/2
✓ Branch 1 taken 4 times.
✗ Branch 2 not taken.
 4 boot_error_ = "circular cache definition: " + instance;
610 4 boot_status_ = loader::kFailCacheDir;
611 4 return NULL;
612 }
613
1/2
✓ Branch 1 taken 1195 times.
✗ Branch 2 not taken.
 1195 constructed_instances_.insert(instance);
614
615
1/2
✓ Branch 2 taken 1195 times.
✗ Branch 3 not taken.
 1195 LogCvmfs(kLogCvmfs, kLogDebug, "setting up cache manager instance %s",
616 instance.c_str());
617 1195 string instance_type;
618
2/2
✓ Branch 1 taken 1107 times.
✓ Branch 2 taken 88 times.
 1195 if (instance == kDefaultCacheMgrInstance) {
619
1/2
✓ Branch 1 taken 1107 times.
✗ Branch 2 not taken.
 1107 instance_type = "posix";
620 } else {
621
3/6
✓ Branch 2 taken 88 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 88 times.
✗ Branch 6 not taken.
✓ Branch 8 taken 88 times.
✗ Branch 9 not taken.
 88 options_mgr_->GetValue(MkCacheParm("CVMFS_CACHE_TYPE", instance),
622 &instance_type);
623 }
624
2/2
✓ Branch 1 taken 1119 times.
✓ Branch 2 taken 76 times.
 1195 if (instance_type == "posix") {
625
1/2
✓ Branch 1 taken 1119 times.
✗ Branch 2 not taken.
 1119 return SetupPosixCacheMgr(instance);
626
2/2
✓ Branch 1 taken 40 times.
✓ Branch 2 taken 36 times.
 76 } else if (instance_type == "ram") {
627
1/2
✓ Branch 1 taken 40 times.
✗ Branch 2 not taken.
 40 return SetupRamCacheMgr(instance);
628
2/2
✓ Branch 1 taken 32 times.
✓ Branch 2 taken 4 times.
 36 } else if (instance_type == "tiered") {
629
1/2
✓ Branch 1 taken 32 times.
✗ Branch 2 not taken.
 32 return SetupTieredCacheMgr(instance);
630
1/2
✗ Branch 1 not taken.
✓ Branch 2 taken 4 times.
 4 } else if (instance_type == "external") {
631 ✗ return SetupExternalCacheMgr(instance);
632 } else {
633
1/2
✓ Branch 1 taken 4 times.
✗ Branch 2 not taken.
 4 boot_error_ = "invalid cache manager type for '" + instance
634
2/4
✓ Branch 1 taken 4 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 4 times.
✗ Branch 5 not taken.
 4 + "':" + instance_type;
635 4 boot_status_ = loader::kFailCacheDir;
636 4 return NULL;
637 }
638 1195 }
639
640
641 ✗ CacheManager *FileSystem::SetupExternalCacheMgr(const string &instance) {
642 ✗ string optarg;
643 ✗ unsigned nfiles = kDefaultNfiles;
644 ✗ if (options_mgr_->GetValue("CVMFS_NFILES", &optarg))
645 ✗ nfiles = String2Uint64(optarg);
646 ✗ vector<string> cmd_line;
647 ✗ if (options_mgr_->GetValue(MkCacheParm("CVMFS_CACHE_CMDLINE", instance),
648 &optarg)) {
649 ✗ cmd_line = SplitString(optarg, ',');
650 }
651
652 ✗ if (!options_mgr_->GetValue(MkCacheParm("CVMFS_CACHE_LOCATOR", instance),
653 &optarg)) {
654 ✗ boot_error_ = MkCacheParm("CVMFS_CACHE_LOCATOR", instance) + " missing";
655 ✗ boot_status_ = loader::kFailCacheDir;
656 ✗ return NULL;
657 }
658
659 const UniquePtr<ExternalCacheManager::PluginHandle> plugin_handle(
660 ✗ ExternalCacheManager::CreatePlugin(optarg, cmd_line));
661 ✗ if (!plugin_handle->IsValid()) {
662 ✗ boot_error_ = plugin_handle->error_msg();
663 ✗ boot_status_ = loader::kFailCacheDir;
664 ✗ return NULL;
665 }
666 ✗ ExternalCacheManager *cache_mgr = ExternalCacheManager::Create(
667 ✗ plugin_handle->fd_connection(), nfiles, name_ + ":" + instance);
668 ✗ if (cache_mgr == NULL) {
669 ✗ boot_error_ = "failed to create external cache manager for " + instance;
670 ✗ boot_status_ = loader::kFailCacheDir;
671 ✗ return NULL;
672 }
673 ✗ cache_mgr->AcquireQuotaManager(ExternalQuotaManager::Create(cache_mgr));
674 ✗ return cache_mgr;
675 }
676
677
678 1119 CacheManager *FileSystem::SetupPosixCacheMgr(const string &instance) {
679
1/2
✓ Branch 1 taken 1119 times.
✗ Branch 2 not taken.
 1119 const PosixCacheSettings settings = DeterminePosixCacheSettings(instance);
680
3/4
✓ Branch 1 taken 1119 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 12 times.
✓ Branch 4 taken 1107 times.
 1119 if (!CheckPosixCacheSettings(settings))
681 12 return NULL;
682 UniquePtr<PosixCacheManager> cache_mgr(PosixCacheManager::Create(
683 settings.cache_path,
684 1107 settings.is_alien,
685 1107 settings.avoid_rename ? PosixCacheManager::kRenameLink
686 : PosixCacheManager::kRenameNormal,
687
3/6
✗ Branch 0 not taken.
✓ Branch 1 taken 1107 times.
✓ Branch 3 taken 1107 times.
✗ Branch 4 not taken.
✓ Branch 6 taken 1107 times.
✗ Branch 7 not taken.
 1107 settings.do_refcount));
688
1/2
✗ Branch 1 not taken.
✓ Branch 2 taken 1107 times.
 1107 if (!cache_mgr.IsValid()) {
689 ✗ boot_error_ = "Failed to setup posix cache '" + instance + "' in "
690 ✗ + settings.cache_path + ": " + strerror(errno);
691 ✗ boot_status_ = loader::kFailCacheDir;
692 ✗ return NULL;
693 }
694
695 // Sentinel file for future use
696 // Might be a read-only cache
697 1107 const bool ignore_failure = settings.is_alien;
698
2/4
✓ Branch 1 taken 1107 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 1107 times.
✗ Branch 5 not taken.
 1107 CreateFile(settings.cache_path + "/.cvmfscache", 0600, ignore_failure);
699
700
2/2
✓ Branch 0 taken 396 times.
✓ Branch 1 taken 711 times.
 1107 if (settings.is_managed) {
701
2/4
✓ Branch 2 taken 396 times.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✓ Branch 5 taken 396 times.
 396 if (!SetupPosixQuotaMgr(settings, cache_mgr.weak_ref()))
702 ✗ return NULL;
703 }
704 1107 return cache_mgr.Release();
705 1119 }
706
707
708 40 CacheManager *FileSystem::SetupRamCacheMgr(const string &instance) {
709 40 string optarg;
710 40 unsigned nfiles = kDefaultNfiles;
711
3/6
✓ Branch 2 taken 40 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 40 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 40 times.
 40 if (options_mgr_->GetValue("CVMFS_NFILES", &optarg)) {
712 ✗ nfiles = String2Uint64(optarg);
713 }
714 uint64_t sz_cache_bytes;
715
4/8
✓ Branch 2 taken 40 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 40 times.
✗ Branch 6 not taken.
✓ Branch 8 taken 40 times.
✗ Branch 9 not taken.
✓ Branch 13 taken 40 times.
✗ Branch 14 not taken.
 40 if (options_mgr_->GetValue(MkCacheParm("CVMFS_CACHE_SIZE", instance),
716 &optarg)) {
717
3/6
✓ Branch 2 taken 40 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 40 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 40 times.
 40 if (HasSuffix(optarg, "%", false)) {
718 ✗ sz_cache_bytes = platform_memsize() * String2Uint64(optarg) / 100;
719 } else {
720
1/2
✓ Branch 1 taken 40 times.
✗ Branch 2 not taken.
 40 sz_cache_bytes = String2Uint64(optarg) * 1024 * 1024;
721 }
722 } else {
723 ✗ sz_cache_bytes = platform_memsize() >> 5; // ~3%
724 }
725 40 MemoryKvStore::MemoryAllocator alloc = MemoryKvStore::kMallocHeap;
726
5/8
✓ Branch 2 taken 40 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 40 times.
✗ Branch 6 not taken.
✓ Branch 8 taken 40 times.
✗ Branch 9 not taken.
✓ Branch 13 taken 8 times.
✓ Branch 14 taken 32 times.
 40 if (options_mgr_->GetValue(MkCacheParm("CVMFS_CACHE_MALLOC", instance),
727 &optarg)) {
728
2/2
✓ Branch 1 taken 4 times.
✓ Branch 2 taken 4 times.
 8 if (optarg == "libc") {
729 4 alloc = MemoryKvStore::kMallocLibc;
730
1/2
✗ Branch 1 not taken.
✓ Branch 2 taken 4 times.
 4 } else if (optarg == "heap") {
731 ✗ alloc = MemoryKvStore::kMallocHeap;
732 } else {
733 boot_error_ = "Failure: unknown malloc "
734
4/8
✓ Branch 2 taken 4 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 4 times.
✗ Branch 6 not taken.
✓ Branch 8 taken 4 times.
✗ Branch 9 not taken.
✓ Branch 11 taken 4 times.
✗ Branch 12 not taken.
 8 + MkCacheParm("CVMFS_CACHE_MALLOC", instance) + "="
735
1/2
✓ Branch 1 taken 4 times.
✗ Branch 2 not taken.
 4 + optarg;
736 4 boot_status_ = loader::kFailOptions;
737 4 return NULL;
738 }
739 }
740 36 sz_cache_bytes = RoundUp8(
741 36 std::max(static_cast<uint64_t>(40 * 1024 * 1024), sz_cache_bytes));
742 RamCacheManager *cache_mgr = new RamCacheManager(
743 sz_cache_bytes,
744 nfiles,
745 alloc,
746
4/8
✓ Branch 1 taken 36 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 36 times.
✗ Branch 5 not taken.
✓ Branch 7 taken 36 times.
✗ Branch 8 not taken.
✓ Branch 10 taken 36 times.
✗ Branch 11 not taken.
 36 perf::StatisticsTemplate("cache." + instance, statistics_));
747
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 36 times.
 36 if (cache_mgr == NULL) {
748 ✗ boot_error_ = "failed to create ram cache manager for " + instance;
749 ✗ boot_status_ = loader::kFailCacheDir;
750 ✗ return NULL;
751 }
752
3/6
✓ Branch 1 taken 36 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 36 times.
✗ Branch 5 not taken.
✓ Branch 7 taken 36 times.
✗ Branch 8 not taken.
 36 cache_mgr->AcquireQuotaManager(new NoopQuotaManager());
753 36 return cache_mgr;
754 40 }
755
756
757 32 CacheManager *FileSystem::SetupTieredCacheMgr(const string &instance) {
758 32 string optarg;
759
5/8
✓ Branch 2 taken 32 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 32 times.
✗ Branch 6 not taken.
✓ Branch 8 taken 32 times.
✗ Branch 9 not taken.
✓ Branch 13 taken 4 times.
✓ Branch 14 taken 28 times.
 32 if (!options_mgr_->GetValue(MkCacheParm("CVMFS_CACHE_UPPER", instance),
760 &optarg)) {
761
3/6
✓ Branch 2 taken 4 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 4 times.
✗ Branch 6 not taken.
✓ Branch 8 taken 4 times.
✗ Branch 9 not taken.
 4 boot_error_ = MkCacheParm("CVMFS_CACHE_UPPER", instance) + " missing";
762 4 boot_status_ = loader::kFailOptions;
763 4 return NULL;
764 }
765
2/4
✓ Branch 1 taken 28 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 28 times.
✗ Branch 5 not taken.
 28 UniquePtr<CacheManager> upper(SetupCacheMgr(optarg));
766
1/2
✗ Branch 1 not taken.
✓ Branch 2 taken 28 times.
 28 if (!upper.IsValid())
767 ✗ return NULL;
768
769
5/8
✓ Branch 2 taken 28 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 28 times.
✗ Branch 6 not taken.
✓ Branch 8 taken 28 times.
✗ Branch 9 not taken.
✓ Branch 13 taken 4 times.
✓ Branch 14 taken 24 times.
 28 if (!options_mgr_->GetValue(MkCacheParm("CVMFS_CACHE_LOWER", instance),
770 &optarg)) {
771
3/6
✓ Branch 2 taken 4 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 4 times.
✗ Branch 6 not taken.
✓ Branch 8 taken 4 times.
✗ Branch 9 not taken.
 4 boot_error_ = MkCacheParm("CVMFS_CACHE_LOWER", instance) + " missing";
772 4 boot_status_ = loader::kFailOptions;
773 4 return NULL;
774 }
775
2/4
✓ Branch 1 taken 24 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 24 times.
✗ Branch 5 not taken.
 24 UniquePtr<CacheManager> lower(SetupCacheMgr(optarg));
776
2/2
✓ Branch 1 taken 4 times.
✓ Branch 2 taken 20 times.
 24 if (!lower.IsValid())
777 4 return NULL;
778
779
1/2
✓ Branch 3 taken 20 times.
✗ Branch 4 not taken.
 20 CacheManager *tiered = TieredCacheManager::Create(upper.Release(),
780 lower.Release());
781
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 20 times.
 20 if (tiered == NULL) {
782 ✗ boot_error_ = "Failed to setup tiered cache manager " + instance;
783 ✗ boot_status_ = loader::kFailCacheDir;
784 ✗ return NULL;
785 }
786 80 if (options_mgr_->GetValue(
787
5/16
✓ Branch 1 taken 20 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 20 times.
✗ Branch 5 not taken.
✓ Branch 7 taken 20 times.
✗ Branch 8 not taken.
✓ Branch 10 taken 20 times.
✗ Branch 11 not taken.
✗ Branch 13 not taken.
✓ Branch 14 taken 20 times.
✗ Branch 15 not taken.
✗ Branch 16 not taken.
✗ Branch 18 not taken.
✗ Branch 19 not taken.
✗ Branch 21 not taken.
✗ Branch 22 not taken.
 40 MkCacheParm("CVMFS_CACHE_LOWER_READONLY", instance), &optarg)
788
3/10
✓ Branch 2 taken 20 times.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✓ Branch 5 taken 20 times.
✗ Branch 7 not taken.
✗ Branch 8 not taken.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✓ Branch 11 taken 20 times.
✗ Branch 12 not taken.
 40 && options_mgr_->IsOn(optarg)) {
789 ✗ static_cast<TieredCacheManager *>(tiered)->SetLowerReadOnly();
790 }
791 20 return tiered;
792 32 }
793
794
795 1151 bool FileSystem::SetupCrashGuard() {
796
2/4
✓ Branch 1 taken 1151 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 1151 times.
✗ Branch 5 not taken.
 1151 path_crash_guard_ = workspace_ + "/running." + name_;
797 platform_stat64 info;
798 1151 int retval = platform_stat(path_crash_guard_.c_str(), &info);
799
2/2
✓ Branch 0 taken 4 times.
✓ Branch 1 taken 1147 times.
 1151 if (retval == 0) {
800 4 found_previous_crash_ = true;
801
1/2
✓ Branch 1 taken 4 times.
✗ Branch 2 not taken.
 4 LogCvmfs(kLogCvmfs, kLogDebug | kLogSyslogWarn,
802 "looks like cvmfs has been crashed previously");
803 }
804
1/2
✓ Branch 2 taken 1151 times.
✗ Branch 3 not taken.
 1151 retval = open(path_crash_guard_.c_str(), O_RDONLY | O_CREAT, 0600);
805
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 1151 times.
 1151 if (retval < 0) {
806 ✗ boot_error_ = "could not open running sentinel (" + StringifyInt(errno)
807 ✗ + ")";
808 ✗ boot_status_ = loader::kFailCacheDir;
809 ✗ return false;
810 }
811
1/2
✓ Branch 1 taken 1151 times.
✗ Branch 2 not taken.
 1151 close(retval);
812 1151 return true;
813 }
814
815
816 1151 bool FileSystem::SetupCwd() {
817
2/2
✓ Branch 0 taken 464 times.
✓ Branch 1 taken 687 times.
 1151 if (type_ == kFsFuse) {
818 // Try to jump to workspace / cache directory. This tests, if it is
819 // accessible and it brings speed later on.
820 464 const int retval = chdir(workspace_.c_str());
821
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 464 times.
 464 if (retval != 0) {
822 ✗ boot_error_ = "workspace " + workspace_ + " is unavailable";
823 ✗ boot_status_ = loader::kFailCacheDir;
824 ✗ return false;
825 }
826 464 workspace_ = ".";
827 464 return true;
828 }
829
830 // Note: as of version 2.4 support for CVMFS_CWD_CACHE is dropped due to
831 // disproportionate large complexity to configure correctly. This affects
832 // only libcvmfs, mostly the legacy part.
833 // string optarg;
834 // if (options_mgr_->GetValue("CVMFS_CWD_CACHE", &optarg) &&
835 // options_mgr_->IsOn(optarg))
836 // {
837 // ...
838 // }
839 687 return true;
840 }
841
842
843 /**
844 * Environment variables useful, e.g., for variant symlinks
845 */
846 2388 void FileSystem::SetupGlobalEnvironmentParams() {
847 2388 setenv("CVMFS_ARCH", GetArch().c_str(), 1 /* overwrite */);
848 2388 }
849
850
851 1194 void FileSystem::SetupLoggingStandalone(const OptionsManager &options_mgr,
852 const std::string &prefix) {
853
1/2
✓ Branch 1 taken 1194 times.
✗ Branch 2 not taken.
 1194 SetupGlobalEnvironmentParams();
854
855 1194 string optarg;
856
4/6
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 1194 times.
✗ Branch 6 not taken.
✓ Branch 9 taken 342 times.
✓ Branch 10 taken 852 times.
 1194 if (options_mgr.GetValue("CVMFS_SYSLOG_LEVEL", &optarg))
857
2/4
✓ Branch 1 taken 342 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 342 times.
✗ Branch 5 not taken.
 342 SetLogSyslogLevel(String2Uint64(optarg));
858
3/6
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 1194 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 1194 times.
 1194 if (options_mgr.GetValue("CVMFS_SYSLOG_FACILITY", &optarg))
859 ✗ SetLogSyslogFacility(String2Int64(optarg));
860
3/6
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 1194 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 1194 times.
 1194 if (options_mgr.GetValue("CVMFS_USYSLOG", &optarg))
861 ✗ SetLogMicroSyslog(optarg);
862
3/6
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 1194 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 1194 times.
 1194 if (options_mgr.GetValue("CVMFS_DEBUGLOG", &optarg))
863 ✗ SetLogDebugFile(optarg);
864
4/6
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 1194 times.
✗ Branch 6 not taken.
✓ Branch 9 taken 76 times.
✓ Branch 10 taken 1118 times.
 1194 if (options_mgr.GetValue("CVMFS_SYSLOG_PREFIX", &optarg)) {
865
1/2
✓ Branch 1 taken 76 times.
✗ Branch 2 not taken.
 76 SetLogSyslogPrefix(optarg);
866 } else {
867
1/2
✓ Branch 1 taken 1118 times.
✗ Branch 2 not taken.
 1118 SetLogSyslogPrefix(prefix);
868 }
869 1194 }
870
871
872 1194 void FileSystem::SetupLogging() {
873 1194 SetupLoggingStandalone(*options_mgr_, name_);
874 1194 }
875
876
877 1115 bool FileSystem::SetupNfsMaps() {
878 #ifdef CVMFS_NFS_SUPPORT
879 ✗ if (!IsHaNfsSource())
880 ✗ nfs_maps_dir_ = workspace_;
881
882 ✗ string no_nfs_sentinel;
883 ✗ if (cache_mgr_->id() == kPosixCacheManager) {
884 ✗ PosixCacheManager *posix_cache_mgr = reinterpret_cast<PosixCacheManager *>(
885 cache_mgr_);
886 ✗ no_nfs_sentinel = posix_cache_mgr->cache_path() + "/no_nfs_maps." + name_;
887 ✗ if (!IsNfsSource()) {
888 // Might be a read-only cache
889 ✗ const bool ignore_failure = posix_cache_mgr->alien_cache();
890 ✗ CreateFile(no_nfs_sentinel, 0600, ignore_failure);
891 ✗ return true;
892 }
893 } else {
894 ✗ if (IsNfsSource()) {
895 ✗ boot_error_ = "NFS source only works with POSIX cache manager.";
896 ✗ boot_status_ = loader::kFailNfsMaps;
897 ✗ return false;
898 }
899 ✗ return true;
900 }
901
902 ✗ assert(cache_mgr_->id() == kPosixCacheManager);
903 ✗ assert(IsNfsSource());
904 ✗ if (!no_nfs_sentinel.empty() && FileExists(no_nfs_sentinel)) {
905 boot_error_ = "Cache was used without NFS maps before. "
906 ✗ "It has to be wiped out.";
907 ✗ boot_status_ = loader::kFailNfsMaps;
908 ✗ return false;
909 }
910
911 // nfs maps need to be protected by workspace lock
912 ✗ PosixCacheManager *posix_cache_mgr = reinterpret_cast<PosixCacheManager *>(
913 cache_mgr_);
914 ✗ if (posix_cache_mgr->cache_path() != workspace_) {
915 boot_error_ = "Cache directory and workspace must be identical for "
916 ✗ "NFS export";
917 ✗ boot_status_ = loader::kFailNfsMaps;
918 ✗ return false;
919 }
920
921 ✗ const string inode_cache_dir = nfs_maps_dir_ + "/nfs_maps." + name_;
922 ✗ if (!MkdirDeep(inode_cache_dir, 0700)) {
923 ✗ boot_error_ = "Failed to initialize NFS maps";
924 ✗ boot_status_ = loader::kFailNfsMaps;
925 ✗ return false;
926 }
927
928 // TODO(jblomer): make this a manager class
929 ✗ if (IsHaNfsSource()) {
930 ✗ nfs_maps_ = NfsMapsSqlite::Create(
931 inode_cache_dir,
932 catalog::ClientCatalogManager::kInodeOffset + 1,
933 ✗ found_previous_crash_,
934 statistics_);
935 } else {
936 ✗ nfs_maps_ = NfsMapsLeveldb::Create(
937 inode_cache_dir,
938 catalog::ClientCatalogManager::kInodeOffset + 1,
939 ✗ found_previous_crash_,
940 statistics_);
941 }
942
943 ✗ if (nfs_maps_ == NULL) {
944 ✗ boot_error_ = "Failed to initialize NFS maps";
945 ✗ boot_status_ = loader::kFailNfsMaps;
946 ✗ return false;
947 }
948
949 ✗ string optarg;
950 ✗ if (options_mgr_->GetValue("CVMFS_NFS_INTERLEAVED_INODES", &optarg)) {
951 ✗ vector<string> tokens = SplitString(optarg, '%');
952 ✗ if (tokens.size() != 2) {
953 boot_error_ = "invalid format for CVMFS_NFS_INTERLEAVED_INODES: "
954 ✗ + optarg;
955 ✗ boot_status_ = loader::kFailNfsMaps;
956 ✗ return false;
957 }
958 ✗ nfs_maps_->SetInodeResidue(String2Uint64(tokens[1]),
959 ✗ String2Uint64(tokens[0]));
960 }
961
962 ✗ return true;
963
964 #else
965 1115 return true;
966 #endif
967 }
968
969
970 396 bool FileSystem::SetupPosixQuotaMgr(
971 const FileSystem::PosixCacheSettings &settings, CacheManager *cache_mgr) {
972
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 396 times.
 396 assert(settings.quota_limit >= 0);
973 396 const int64_t quota_threshold = settings.quota_limit / 2;
974
1/2
✓ Branch 1 taken 396 times.
✗ Branch 2 not taken.
 396 string cache_workspace = settings.cache_path;
975
1/2
✗ Branch 1 not taken.
✓ Branch 2 taken 396 times.
 396 if (settings.cache_path != settings.workspace) {
976 ✗ LogCvmfs(kLogQuota, kLogDebug | kLogSyslog,
977 "using workspace %s to protect cache database in %s",
978 settings.workspace.c_str(), settings.cache_path.c_str());
979 ✗ cache_workspace += ":" + settings.workspace;
980 }
981 PosixQuotaManager *quota_mgr;
982
983
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 396 times.
 396 if (settings.is_shared) {
984 ✗ quota_mgr = PosixQuotaManager::CreateShared(exe_path_,
985 cache_workspace,
986 ✗ settings.quota_limit,
987 quota_threshold,
988 ✗ foreground_);
989 ✗ if (quota_mgr == NULL) {
990 ✗ boot_error_ = "Failed to initialize shared lru cache";
991 ✗ boot_status_ = loader::kFailQuota;
992 ✗ return false;
993 }
994 } else {
995 792 quota_mgr = PosixQuotaManager::Create(cache_workspace,
996 396 settings.quota_limit,
997 quota_threshold,
998
1/2
✓ Branch 1 taken 396 times.
✗ Branch 2 not taken.
 396 found_previous_crash_);
999
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 396 times.
 396 if (quota_mgr == NULL) {
1000 ✗ boot_error_ = "Failed to initialize lru cache";
1001 ✗ boot_status_ = loader::kFailQuota;
1002 ✗ return false;
1003 }
1004 }
1005
1006
3/6
✓ Branch 1 taken 396 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 396 times.
✗ Branch 5 not taken.
✗ Branch 6 not taken.
✓ Branch 7 taken 396 times.
 396 if (quota_mgr->GetSize() > quota_mgr->GetCapacity()) {
1007 ✗ LogCvmfs(kLogCvmfs, kLogDebug | kLogSyslog,
1008 "cache is already beyond quota size "
1009 "(size: %" PRId64 ", capacity: %" PRId64 "), cleaning up",
1010 ✗ quota_mgr->GetSize(), quota_mgr->GetCapacity());
1011 ✗ if (!quota_mgr->Cleanup(quota_threshold)) {
1012 ✗ delete quota_mgr;
1013 ✗ boot_error_ = "Failed to clean up cache";
1014 ✗ boot_status_ = loader::kFailQuota;
1015 ✗ return false;
1016 }
1017 }
1018
1019
1/2
✓ Branch 1 taken 396 times.
✗ Branch 2 not taken.
 396 const int retval = cache_mgr->AcquireQuotaManager(quota_mgr);
1020
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 396 times.
 396 assert(retval);
1021 396 LogCvmfs(kLogCvmfs, kLogDebug,
1022 "CernVM-FS: quota initialized, current size %luMB",
1023
2/4
✓ Branch 1 taken 396 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 396 times.
✗ Branch 5 not taken.
 396 quota_mgr->GetSize() / (1024 * 1024));
1024 396 return true;
1025 396 }
1026
1027
1028 1194 void FileSystem::SetupSqlite() {
1029 // Make sure SQlite starts clean after initialization
1030 1194 sqlite3_shutdown();
1031
1032 int retval;
1033 1194 retval = sqlite3_config(SQLITE_CONFIG_LOG, FileSystem::LogSqliteError, NULL);
1034
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 1194 times.
 1194 assert(retval == SQLITE_OK);
1035 1194 retval = sqlite3_config(SQLITE_CONFIG_MULTITHREAD);
1036
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 1194 times.
 1194 assert(retval == SQLITE_OK);
1037 1194 SqliteMemoryManager::GetInstance()->AssignGlobalArenas();
1038
1039 // Disable SQlite3 file locking
1040 1194 retval = sqlite3_vfs_register(sqlite3_vfs_find("unix-none"), 1);
1041
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 1194 times.
 1194 assert(retval == SQLITE_OK);
1042 1194 }
1043
1044
1045 1194 bool FileSystem::SetupWorkspace() {
1046 1194 string optarg;
1047 // This is very similar to "determine cache dir". It's for backward
1048 // compatibility with classic cache configuration where there was no
1049 // distinction between workspace and cache.
1050 // Complicated cache configurations should explicitly set CVMFS_WORKSPACE.
1051
1/2
✓ Branch 1 taken 1194 times.
✗ Branch 2 not taken.
 1194 workspace_ = kDefaultCacheBase;
1052
4/6
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 1194 times.
✗ Branch 6 not taken.
✓ Branch 9 taken 473 times.
✓ Branch 10 taken 721 times.
 1194 if (options_mgr_->GetValue("CVMFS_CACHE_BASE", &optarg))
1053
1/2
✓ Branch 1 taken 473 times.
✗ Branch 2 not taken.
 473 workspace_ = MakeCanonicalPath(optarg);
1054
4/10
✓ Branch 1 taken 1194 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 1194 times.
✗ Branch 5 not taken.
✓ Branch 7 taken 8 times.
✓ Branch 8 taken 1186 times.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
 2388 if (options_mgr_->GetValue("CVMFS_SHARED_CACHE", &optarg)
1055
7/10
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
✓ Branch 4 taken 449 times.
✓ Branch 5 taken 745 times.
✓ Branch 7 taken 449 times.
✗ Branch 8 not taken.
✓ Branch 9 taken 8 times.
✓ Branch 10 taken 441 times.
✓ Branch 11 taken 1194 times.
✗ Branch 12 not taken.
 2388 && options_mgr_->IsOn(optarg)) {
1056
1/2
✓ Branch 1 taken 8 times.
✗ Branch 2 not taken.
 8 workspace_ += "/shared";
1057 } else {
1058
2/4
✓ Branch 1 taken 1186 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 1186 times.
✗ Branch 5 not taken.
 1186 workspace_ += "/" + name_;
1059 }
1060
4/6
✓ Branch 2 taken 1194 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 1194 times.
✗ Branch 6 not taken.
✓ Branch 9 taken 725 times.
✓ Branch 10 taken 469 times.
 1194 if (options_mgr_->GetValue("CVMFS_CACHE_DIR", &optarg)) {
1061
4/6
✓ Branch 2 taken 725 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 725 times.
✗ Branch 6 not taken.
✓ Branch 9 taken 4 times.
✓ Branch 10 taken 721 times.
 725 if (options_mgr_->IsDefined("CVMFS_CACHE_BASE")) {
1062 boot_error_ = "'CVMFS_CACHE_BASE' and 'CVMFS_CACHE_DIR' are mutually "
1063
1/2
✓ Branch 1 taken 4 times.
✗ Branch 2 not taken.
 4 "exclusive";
1064 4 boot_status_ = loader::kFailOptions;
1065 4 return false;
1066 }
1067
1/2
✓ Branch 1 taken 721 times.
✗ Branch 2 not taken.
 721 workspace_ = optarg;
1068 }
1069
4/6
✓ Branch 2 taken 1190 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 1190 times.
✗ Branch 6 not taken.
✓ Branch 9 taken 42 times.
✓ Branch 10 taken 1148 times.
 1190 if (options_mgr_->GetValue("CVMFS_WORKSPACE", &optarg))
1070
1/2
✓ Branch 1 taken 42 times.
✗ Branch 2 not taken.
 42 workspace_ = optarg;
1071
1/2
✓ Branch 1 taken 1190 times.
✗ Branch 2 not taken.
 1190 workspace_fullpath_ = workspace_;
1072
1073 // If workspace and alien cache are the same directory, we need to open
1074 // permission now to 0770 to avoid a race when fixing it later
1075 1190 const int mode = 0770;
1076
3/4
✓ Branch 1 taken 1190 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 38 times.
✓ Branch 4 taken 1152 times.
 1190 if (!MkdirDeep(workspace_, mode, false)) {
1077
1/2
✓ Branch 1 taken 38 times.
✗ Branch 2 not taken.
 38 boot_error_ = "cannot create workspace directory " + workspace_;
1078 38 boot_status_ = loader::kFailCacheDir;
1079 38 return false;
1080 }
1081
1082
3/4
✓ Branch 1 taken 1152 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 1 times.
✓ Branch 4 taken 1151 times.
 1152 if (!LockWorkspace())
1083 1 return false;
1084
2/4
✓ Branch 1 taken 1151 times.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
✓ Branch 4 taken 1151 times.
 1151 if (!SetupCwd())
1085 ✗ return false;
1086
2/4
✓ Branch 1 taken 1151 times.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
✓ Branch 4 taken 1151 times.
 1151 if (!SetupCrashGuard())
1087 ✗ return false;
1088
1089 1151 return true;
1090 1194 }
1091
1092
1093 1115 void FileSystem::SetupUuid() {
1094
1/2
✓ Branch 2 taken 1115 times.
✗ Branch 3 not taken.
 1115 uuid_cache_ = cvmfs::Uuid::Create(workspace_ + "/uuid");
1095
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 1115 times.
 1115 if (uuid_cache_ == NULL) {
1096 ✗ LogCvmfs(kLogCvmfs, kLogDebug | kLogSyslogWarn,
1097 "failed to load/store %s/uuid", workspace_.c_str());
1098 ✗ uuid_cache_ = cvmfs::Uuid::Create("");
1099 ✗ assert(uuid_cache_ != NULL);
1100 }
1101 1115 }
1102
1103
1104 /**
1105 * Required by CernVM: the fuse module needs to free r/w file descriptor to the
1106 * cache in order to properly unravel the file system stack on shutdown.
1107 */
1108 ✗ void FileSystem::TearDown2ReadOnly() {
1109 ✗ if ((cache_mgr_ != NULL) && (cache_mgr_->id() == kPosixCacheManager)) {
1110 ✗ PosixCacheManager *posix_cache_mgr = reinterpret_cast<PosixCacheManager *>(
1111 cache_mgr_);
1112 ✗ posix_cache_mgr->TearDown2ReadOnly();
1113 }
1114
1115 ✗ unlink(path_crash_guard_.c_str());
1116 ✗ LogCvmfs(kLogCache, kLogSyslog, "switch to read-only cache mode");
1117 ✗ SetLogMicroSyslog("");
1118 }
1119
1120
1121 ✗ void FileSystem::RemapCatalogFd(int from, int to) {
1122 ✗ sqlite::RegisterFdMapping(from, to);
1123 }
1124
1125 ✗ void FileSystem::ReplaceCacheManager(CacheManager *new_cache_mgr) {
1126 ✗ cache_mgr_ = new_cache_mgr;
1127 ✗ sqlite::ReplaceCacheManager(new_cache_mgr);
1128 }
1129
1130
1131 1151 bool FileSystem::TriageCacheMgr() {
1132
1/2
✓ Branch 1 taken 1151 times.
✗ Branch 2 not taken.
 1151 cache_mgr_instance_ = kDefaultCacheMgrInstance;
1133 1151 string instance;
1134
4/10
✓ Branch 1 taken 1151 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 1151 times.
✗ Branch 5 not taken.
✓ Branch 7 taken 48 times.
✓ Branch 8 taken 1103 times.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
 2302 if (options_mgr_->GetValue("CVMFS_CACHE_PRIMARY", &instance)
1135
5/8
✓ Branch 2 taken 1151 times.
✗ Branch 3 not taken.
✓ Branch 4 taken 48 times.
✓ Branch 5 taken 1103 times.
✓ Branch 7 taken 48 times.
✗ Branch 8 not taken.
✓ Branch 9 taken 1151 times.
✗ Branch 10 not taken.
 2302 && !instance.empty()) {
1136
3/4
✓ Branch 1 taken 48 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 4 times.
✓ Branch 4 taken 44 times.
 48 if (!CheckInstanceName(instance))
1137 4 return false;
1138
1/2
✓ Branch 1 taken 44 times.
✗ Branch 2 not taken.
 44 cache_mgr_instance_ = instance;
1139 }
1140
1141
1/2
✓ Branch 1 taken 1147 times.
✗ Branch 2 not taken.
 1147 cache_mgr_ = SetupCacheMgr(cache_mgr_instance_);
1142
2/2
✓ Branch 0 taken 32 times.
✓ Branch 1 taken 1115 times.
 1147 if (cache_mgr_ == NULL)
1143 32 return false;
1144
1145 1115 std::string optarg;
1146
3/10
✓ Branch 1 taken 1115 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 1115 times.
✗ Branch 5 not taken.
✗ Branch 7 not taken.
✓ Branch 8 taken 1115 times.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
 2230 if (options_mgr_->GetValue("CVMFS_STREAMING_CACHE", &optarg)
1147
3/10
✓ Branch 2 taken 1115 times.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✓ Branch 5 taken 1115 times.
✗ Branch 7 not taken.
✗ Branch 8 not taken.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✓ Branch 11 taken 1115 times.
✗ Branch 12 not taken.
 2230 && options_mgr_->IsOn(optarg)) {
1148 ✗ unsigned nfiles = kDefaultNfiles;
1149 ✗ if (options_mgr_->GetValue("CVMFS_NFILES", &optarg))
1150 ✗ nfiles = String2Uint64(optarg);
1151 ✗ size_t buffer_size = StreamingCacheManager::kDefaultBufferSize;
1152 ✗ if (options_mgr_->GetValue("CVMFS_STREAMING_CACHE_BUFFER_SIZE", &optarg))
1153 ✗ buffer_size = String2Uint64(optarg);
1154 ✗ cache_mgr_ = new StreamingCacheManager(nfiles, cache_mgr_, NULL, NULL,
1155 ✗ buffer_size, statistics_);
1156 }
1157
1158 1115 return true;
1159 1151 }
1160
1161
1162 //------------------------------------------------------------------------------
1163
1164
1165 const char *MountPoint::kDefaultAuthzSearchPath = "/usr/libexec/cvmfs/authz";
1166 const char *MountPoint::kDefaultBlacklist = "/etc/cvmfs/blacklist";
1167
1168 686 bool MountPoint::CheckBlacklists() {
1169 686 blacklist_paths_.clear();
1170 686 string blacklist;
1171
4/6
✓ Branch 2 taken 686 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 686 times.
✗ Branch 6 not taken.
✓ Branch 9 taken 678 times.
✓ Branch 10 taken 8 times.
 686 if (!options_mgr_->GetValue("CVMFS_BLACKLIST", &blacklist))
1172
1/2
✓ Branch 1 taken 678 times.
✗ Branch 2 not taken.
 678 blacklist = kDefaultBlacklist;
1173
1/2
✓ Branch 1 taken 686 times.
✗ Branch 2 not taken.
 686 blacklist_paths_.push_back(blacklist);
1174
1175 686 bool append = false;
1176
3/4
✓ Branch 1 taken 686 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 4 times.
✓ Branch 4 taken 682 times.
 686 if (FileExists(blacklist)) {
1177
2/4
✓ Branch 1 taken 4 times.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
✓ Branch 4 taken 4 times.
 4 if (!signature_mgr_->LoadBlacklist(blacklist, append)) {
1178 ✗ boot_error_ = "failed to load blacklist " + blacklist;
1179 ✗ boot_status_ = loader::kFailSignature;
1180 ✗ return false;
1181 }
1182 4 append = true;
1183 }
1184
1185 686 string config_repository_path;
1186
3/4
✓ Branch 1 taken 686 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 12 times.
✓ Branch 4 taken 674 times.
 686 if (options_mgr_->HasConfigRepository(fqrn_, &config_repository_path)) {
1187
1/2
✓ Branch 1 taken 12 times.
✗ Branch 2 not taken.
 12 blacklist = config_repository_path + "blacklist";
1188
1/2
✓ Branch 1 taken 12 times.
✗ Branch 2 not taken.
 12 blacklist_paths_.push_back(blacklist);
1189
3/4
✓ Branch 1 taken 12 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 8 times.
✓ Branch 4 taken 4 times.
 12 if (FileExists(blacklist)) {
1190
2/4
✓ Branch 1 taken 8 times.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
✓ Branch 4 taken 8 times.
 8 if (!signature_mgr_->LoadBlacklist(blacklist, append)) {
1191 ✗ boot_error_ = "failed to load blacklist from config repository";
1192 ✗ boot_status_ = loader::kFailSignature;
1193 ✗ return false;
1194 }
1195 }
1196 }
1197
1198 686 return true;
1199 686 }
1200
1201
1202 /**
1203 * Like CheckBlacklists but supposed to be used after bootstrap, possibly in
1204 * multi-threaded context.
1205 */
1206 8 bool MountPoint::ReloadBlacklists() {
1207 8 const bool result = true;
1208 8 bool append = false;
1209
2/2
✓ Branch 1 taken 12 times.
✓ Branch 2 taken 8 times.
 20 for (unsigned i = 0; i < blacklist_paths_.size(); ++i) {
1210
1/2
✓ Branch 2 taken 12 times.
✗ Branch 3 not taken.
 12 const string blacklist = blacklist_paths_[i];
1211
2/4
✓ Branch 1 taken 12 times.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
✓ Branch 4 taken 12 times.
 12 if (FileExists(blacklist)) {
1212 ✗ const bool retval = signature_mgr_->LoadBlacklist(blacklist, append);
1213 // TODO(jblomer): this can leave us with a half-loaded blacklist
1214 ✗ if (!retval)
1215 ✗ return false;
1216 ✗ append = true;
1217 }
1218
1/2
✓ Branch 1 taken 12 times.
✗ Branch 2 not taken.
 12 }
1219 8 return result;
1220 }
1221
1222 /**
1223 * Disables kernel caching of symlinks.
1224 * Symlink caching requires fuse >= 3.10 (FUSE_CAP_CACHE_SYMLINKS) and
1225 * linux kernel >= 4.2. Some OS might backport it.
1226 *
1227 * NOTE: This function should only be called before or within cvmfs_init().
1228 *
1229 */
1230 ✗ void MountPoint::DisableCacheSymlinks() { cache_symlinks_ = false; }
1231
1232 /**
1233 * Instead of invalidate dentries, they should be expired.
1234 * Fixes issues with mount-on-top mounts and symlink caching.
1235 */
1236 ✗ void MountPoint::EnableFuseExpireEntry() { fuse_expire_entry_ = true; }
1237
1238
1239 /**
1240 * The option_mgr parameter can be NULL, in which case the global option manager
1241 * from the file system is used.
1242 */
1243 690 MountPoint *MountPoint::Create(const string &fqrn,
1244 FileSystem *file_system,
1245 OptionsManager *options_mgr) {
1246
2/2
✓ Branch 0 taken 376 times.
✓ Branch 1 taken 314 times.
 690 if (options_mgr == NULL)
1247 376 options_mgr = file_system->options_mgr();
1248 UniquePtr<MountPoint> mountpoint(
1249
3/6
✓ Branch 1 taken 690 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 690 times.
✗ Branch 5 not taken.
✓ Branch 7 taken 690 times.
✗ Branch 8 not taken.
 690 new MountPoint(fqrn, file_system, options_mgr));
1250
1251 // At this point, we have a repository name, the type (fuse or library) and
1252 // an options manager (which can be the same than the FileSystem's one).
1253
1254
1/2
✓ Branch 2 taken 690 times.
✗ Branch 3 not taken.
 690 mountpoint->CreateStatistics();
1255
1/2
✓ Branch 2 taken 690 times.
✗ Branch 3 not taken.
 690 mountpoint->CreateAuthz();
1256
2/4
✓ Branch 1 taken 690 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 690 times.
✗ Branch 5 not taken.
 690 mountpoint->backoff_throttle_ = new BackoffThrottle();
1257
1258
7/10
✓ Branch 2 taken 690 times.
✗ Branch 3 not taken.
✓ Branch 4 taken 686 times.
✓ Branch 5 taken 4 times.
✓ Branch 8 taken 686 times.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✓ Branch 11 taken 686 times.
✓ Branch 12 taken 4 times.
✓ Branch 13 taken 686 times.
 690 if (!mountpoint->CreateSignatureManager() || !mountpoint->CheckBlacklists())
1259 4 return mountpoint.Release();
1260
3/4
✓ Branch 2 taken 686 times.
✗ Branch 3 not taken.
✓ Branch 4 taken 292 times.
✓ Branch 5 taken 394 times.
 686 if (!mountpoint->CreateDownloadManagers())
1261 292 return mountpoint.Release();
1262
2/4
✓ Branch 2 taken 394 times.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✓ Branch 5 taken 394 times.
 394 if (file_system->cache_mgr()->id() == kStreamingCacheManager) {
1263 StreamingCacheManager
1264 ✗ *streaming_cachemgr = dynamic_cast<StreamingCacheManager *>(
1265 ✗ file_system->cache_mgr());
1266 ✗ streaming_cachemgr->SetRegularDownloadManager(mountpoint->download_mgr());
1267 ✗ streaming_cachemgr->SetExternalDownloadManager(
1268 mountpoint->external_download_mgr());
1269 }
1270
2/4
✓ Branch 2 taken 394 times.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✓ Branch 5 taken 394 times.
 394 if (!mountpoint->CreateResolvConfWatcher()) {
1271 ✗ return mountpoint.Release();
1272 }
1273
1/2
✓ Branch 2 taken 394 times.
✗ Branch 3 not taken.
 394 mountpoint->CreateFetchers();
1274
3/4
✓ Branch 2 taken 394 times.
✗ Branch 3 not taken.
✓ Branch 4 taken 102 times.
✓ Branch 5 taken 292 times.
 394 if (!mountpoint->CreateCatalogManager())
1275 102 return mountpoint.Release();
1276
2/4
✓ Branch 2 taken 292 times.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✓ Branch 5 taken 292 times.
 292 if (!mountpoint->CreateTracer())
1277 ✗ return mountpoint.Release();
1278
1279
1/2
✓ Branch 2 taken 292 times.
✗ Branch 3 not taken.
 292 mountpoint->ReEvaluateAuthz();
1280
1/2
✓ Branch 2 taken 292 times.
✗ Branch 3 not taken.
 292 mountpoint->CreateTables();
1281
2/4
✓ Branch 2 taken 292 times.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✓ Branch 5 taken 292 times.
 292 if (!mountpoint->SetupBehavior())
1282 ✗ return mountpoint.Release();
1283
1284 292 mountpoint->boot_status_ = loader::kFailOk;
1285 292 return mountpoint.Release();
1286 690 }
1287
1288
1289 690 void MountPoint::CreateAuthz() {
1290 690 string optarg;
1291 690 string authz_helper;
1292
3/6
✓ Branch 2 taken 690 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 690 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 690 times.
 690 if (options_mgr_->GetValue("CVMFS_AUTHZ_HELPER", &optarg))
1293 ✗ authz_helper = optarg;
1294
1/2
✓ Branch 2 taken 690 times.
✗ Branch 3 not taken.
 690 string authz_search_path(kDefaultAuthzSearchPath);
1295
3/6
✓ Branch 2 taken 690 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 690 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 690 times.
 690 if (options_mgr_->GetValue("CVMFS_AUTHZ_SEARCH_PATH", &optarg))
1296 ✗ authz_search_path = optarg;
1297
1298 1380 authz_fetcher_ = new AuthzExternalFetcher(fqrn_, authz_helper,
1299
2/4
✓ Branch 1 taken 690 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 690 times.
✗ Branch 5 not taken.
 690 authz_search_path, options_mgr_);
1300
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 690 times.
 690 assert(authz_fetcher_ != NULL);
1301
1302
1/2
✓ Branch 1 taken 690 times.
✗ Branch 2 not taken.
 690 authz_session_mgr_ = AuthzSessionManager::Create(authz_fetcher_, statistics_);
1303
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 690 times.
 690 assert(authz_session_mgr_ != NULL);
1304
1305
2/4
✓ Branch 1 taken 690 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 690 times.
✗ Branch 5 not taken.
 690 authz_attachment_ = new AuthzAttachment(authz_session_mgr_);
1306
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 690 times.
 690 assert(authz_attachment_ != NULL);
1307 690 }
1308
1309
1310 394 bool MountPoint::CreateCatalogManager() {
1311 394 string optarg;
1312
1313
2/4
✓ Branch 1 taken 394 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 394 times.
✗ Branch 5 not taken.
 394 catalog_mgr_ = new catalog::ClientCatalogManager(this);
1314
1315
1/2
✓ Branch 1 taken 394 times.
✗ Branch 2 not taken.
 394 SetupInodeAnnotation();
1316
3/4
✓ Branch 1 taken 394 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 4 times.
✓ Branch 4 taken 390 times.
 394 if (!SetupOwnerMaps())
1317 4 return false;
1318
1/2
✓ Branch 1 taken 390 times.
✗ Branch 2 not taken.
 390 shash::Any root_hash;
1319
3/4
✓ Branch 1 taken 390 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 8 times.
✓ Branch 4 taken 382 times.
 390 if (!DetermineRootHash(&root_hash))
1320 8 return false;
1321
1322 bool retval;
1323
2/2
✓ Branch 1 taken 122 times.
✓ Branch 2 taken 260 times.
 382 if (root_hash.IsNull()) {
1324
1/2
✓ Branch 1 taken 122 times.
✗ Branch 2 not taken.
 122 retval = catalog_mgr_->Init();
1325 } else {
1326 260 fixed_catalog_ = true;
1327
2/8
✓ Branch 1 taken 260 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 260 times.
✗ Branch 5 not taken.
✗ Branch 7 not taken.
✗ Branch 8 not taken.
✗ Branch 10 not taken.
✗ Branch 11 not taken.
 520 const bool alt_root_path = options_mgr_->GetValue("CVMFS_ALT_ROOT_PATH",
1328 &optarg)
1329
3/10
✓ Branch 2 taken 260 times.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✓ Branch 5 taken 260 times.
✗ Branch 7 not taken.
✗ Branch 8 not taken.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✓ Branch 11 taken 260 times.
✗ Branch 12 not taken.
 520 && options_mgr_->IsOn(optarg);
1330
1/2
✓ Branch 1 taken 260 times.
✗ Branch 2 not taken.
 260 retval = catalog_mgr_->InitFixed(root_hash, alt_root_path);
1331 }
1332
2/2
✓ Branch 0 taken 86 times.
✓ Branch 1 taken 296 times.
 382 if (!retval) {
1333
1/2
✓ Branch 1 taken 86 times.
✗ Branch 2 not taken.
 86 boot_error_ = "Failed to initialize root file catalog";
1334 86 boot_status_ = loader::kFailCatalog;
1335 86 return false;
1336 }
1337
1338
3/4
✓ Branch 1 taken 296 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 4 times.
✓ Branch 4 taken 292 times.
 296 if (catalog_mgr_->IsRevisionBlacklisted()) {
1339
1/2
✓ Branch 1 taken 4 times.
✗ Branch 2 not taken.
 4 boot_error_ = "repository revision blacklisted";
1340 4 boot_status_ = loader::kFailRevisionBlacklisted;
1341 4 return false;
1342 }
1343
1344
3/10
✓ Branch 1 taken 292 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 292 times.
✗ Branch 5 not taken.
✗ Branch 7 not taken.
✓ Branch 8 taken 292 times.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
 584 if (options_mgr_->GetValue("CVMFS_AUTO_UPDATE", &optarg)
1345
3/10
✓ Branch 2 taken 292 times.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✓ Branch 5 taken 292 times.
✗ Branch 7 not taken.
✗ Branch 8 not taken.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✓ Branch 11 taken 292 times.
✗ Branch 12 not taken.
 584 && !options_mgr_->IsOn(optarg)) {
1346 ✗ fixed_catalog_ = true;
1347 }
1348
1349
3/6
✓ Branch 2 taken 292 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 292 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 292 times.
 292 if (options_mgr_->GetValue("CVMFS_CATALOG_WATERMARK", &optarg)) {
1350 ✗ catalog_mgr_->SetCatalogWatermark(String2Uint64(optarg));
1351 } else {
1352 unsigned soft_limit;
1353 unsigned hard_limit;
1354
1/2
✓ Branch 1 taken 292 times.
✗ Branch 2 not taken.
 292 GetLimitNoFile(&soft_limit, &hard_limit);
1355 292 catalog_mgr_->SetCatalogWatermark(soft_limit / 4);
1356 }
1357
1358
1/2
✗ Branch 1 not taken.
✓ Branch 2 taken 292 times.
 292 if (catalog_mgr_->volatile_flag()) {
1359 ✗ LogCvmfs(kLogCvmfs, kLogDebug, "content of repository flagged as VOLATILE");
1360 }
1361
1362 292 return true;
1363 394 }
1364
1365
1366 686 bool MountPoint::CreateDownloadManagers() {
1367 686 string optarg;
1368
1/2
✓ Branch 1 taken 686 times.
✗ Branch 2 not taken.
 1372 download_mgr_ = new download::DownloadManager(
1369 kDefaultNumConnections,
1370
4/8
✓ Branch 2 taken 686 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 686 times.
✗ Branch 6 not taken.
✓ Branch 9 taken 686 times.
✗ Branch 10 not taken.
✓ Branch 12 taken 686 times.
✗ Branch 13 not taken.
 2058 perf::StatisticsTemplate("download", statistics_));
1371
1/2
✓ Branch 1 taken 686 times.
✗ Branch 2 not taken.
 686 download_mgr_->SetCredentialsAttachment(authz_attachment_);
1372
1373 // must be set before proxy and host chains are being initialized
1374 // error output is handled in SetShardingPolicy
1375
3/6
✓ Branch 2 taken 686 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 686 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 686 times.
 686 if (options_mgr_->GetValue("CVMFS_PROXY_SHARDING_POLICY", &optarg)) {
1376 ✗ if (optarg.compare("EXTERNAL") == 0) {
1377 ✗ download_mgr_->SetShardingPolicy(download::kShardingPolicyExternal);
1378 ✗ download_mgr_->SetFqrn(fqrn());
1379 }
1380 }
1381
1382
3/10
✓ Branch 1 taken 686 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 686 times.
✗ Branch 5 not taken.
✗ Branch 7 not taken.
✓ Branch 8 taken 686 times.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
 1372 if (options_mgr_->GetValue("CVMFS_FAILOVER_INDEFINITELY", &optarg)
1383
3/10
✓ Branch 2 taken 686 times.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✓ Branch 5 taken 686 times.
✗ Branch 7 not taken.
✗ Branch 8 not taken.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✓ Branch 11 taken 686 times.
✗ Branch 12 not taken.
 1372 && options_mgr_->IsOn(optarg)) {
1384 ✗ download_mgr_->SetFailoverIndefinitely();
1385 }
1386
1387
3/6
✓ Branch 2 taken 686 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 686 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 686 times.
 686 if (options_mgr_->GetValue("CVMFS_METALINK_URL", &optarg)) {
1388 ✗ download_mgr_->SetMetalinkChain(optarg);
1389 // host chain will be set later when the metalink server is contacted
1390 ✗ download_mgr_->SetHostChain("");
1391 // metalink requires redirects
1392 ✗ download_mgr_->EnableRedirects();
1393
4/6
✓ Branch 2 taken 686 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 686 times.
✗ Branch 6 not taken.
✓ Branch 9 taken 398 times.
✓ Branch 10 taken 288 times.
 686 } else if (options_mgr_->GetValue("CVMFS_SERVER_URL", &optarg)) {
1394
1/2
✓ Branch 1 taken 398 times.
✗ Branch 2 not taken.
 398 download_mgr_->SetHostChain(optarg);
1395 }
1396
1397
3/10
✓ Branch 1 taken 686 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 686 times.
✗ Branch 5 not taken.
✗ Branch 7 not taken.
✓ Branch 8 taken 686 times.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
 1372 if (options_mgr_->GetValue("_CVMFS_DEVEL_IGNORE_SIGNATURE_FAILURES", &optarg)
1398
3/10
✓ Branch 2 taken 686 times.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✓ Branch 5 taken 686 times.
✗ Branch 7 not taken.
✗ Branch 8 not taken.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✓ Branch 11 taken 686 times.
✗ Branch 12 not taken.
 1372 && options_mgr_->IsOn(optarg)) {
1399 ✗ download_mgr_->EnableIgnoreSignatureFailures();
1400 ✗ LogCvmfs(kLogCvmfs, kLogDebug | kLogSyslogWarn,
1401 "Development option: Activate ignore signature failures during "
1402 "download. "
1403 "DO NOT USE IN PRODUCTION");
1404 }
1405
1406
1/2
✓ Branch 1 taken 686 times.
✗ Branch 2 not taken.
 686 SetupDnsTuning(download_mgr_);
1407
1/2
✓ Branch 1 taken 686 times.
✗ Branch 2 not taken.
 686 SetupHttpTuning();
1408
1409 686 string forced_proxy_template;
1410
3/6
✓ Branch 2 taken 686 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 686 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 686 times.
 686 if (options_mgr_->GetValue("CVMFS_PROXY_TEMPLATE", &optarg))
1411 ✗ forced_proxy_template = optarg;
1412
2/4
✓ Branch 2 taken 686 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 686 times.
✗ Branch 6 not taken.
 686 download_mgr_->SetProxyTemplates(file_system_->uuid_cache()->uuid(),
1413 forced_proxy_template);
1414
1415 686 string proxies;
1416
4/6
✓ Branch 2 taken 686 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 686 times.
✗ Branch 6 not taken.
✓ Branch 9 taken 394 times.
✓ Branch 10 taken 292 times.
 686 if (options_mgr_->GetValue("CVMFS_HTTP_PROXY", &optarg))
1417
1/2
✓ Branch 1 taken 394 times.
✗ Branch 2 not taken.
 394 proxies = optarg;
1418
1/2
✓ Branch 1 taken 686 times.
✗ Branch 2 not taken.
 1372 proxies = download::ResolveProxyDescription(
1419 proxies,
1420
4/8
✓ Branch 1 taken 686 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 686 times.
✗ Branch 5 not taken.
✓ Branch 7 taken 686 times.
✗ Branch 8 not taken.
✓ Branch 10 taken 686 times.
✗ Branch 11 not taken.
 1372 file_system_->workspace() + "/proxies" + GetUniqFileSuffix(),
1421 686 download_mgr_);
1422
2/2
✓ Branch 1 taken 292 times.
✓ Branch 2 taken 394 times.
 686 if (proxies == "") {
1423
1/2
✓ Branch 1 taken 292 times.
✗ Branch 2 not taken.
 292 boot_error_ = "failed to discover HTTP proxy servers";
1424 292 boot_status_ = loader::kFailWpad;
1425 292 return false;
1426 }
1427 394 string fallback_proxies;
1428
3/6
✓ Branch 2 taken 394 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 394 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 394 times.
 394 if (options_mgr_->GetValue("CVMFS_FALLBACK_PROXY", &optarg))
1429 ✗ fallback_proxies = optarg;
1430
1/2
✓ Branch 1 taken 394 times.
✗ Branch 2 not taken.
 394 download_mgr_->SetProxyChain(proxies, fallback_proxies,
1431 download::DownloadManager::kSetProxyBoth);
1432
1433
2/8
✓ Branch 1 taken 394 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 394 times.
✗ Branch 5 not taken.
✗ Branch 7 not taken.
✗ Branch 8 not taken.
✗ Branch 10 not taken.
✗ Branch 11 not taken.
 788 const bool do_geosort = options_mgr_->GetValue("CVMFS_USE_GEOAPI", &optarg)
1434
3/10
✓ Branch 2 taken 394 times.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✓ Branch 5 taken 394 times.
✗ Branch 7 not taken.
✗ Branch 8 not taken.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✓ Branch 11 taken 394 times.
✗ Branch 12 not taken.
 788 && options_mgr_->IsOn(optarg);
1435
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 394 times.
 394 if (do_geosort) {
1436 ✗ download_mgr_->ProbeGeo();
1437 }
1438
4/6
✓ Branch 2 taken 394 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 394 times.
✗ Branch 6 not taken.
✓ Branch 9 taken 16 times.
✓ Branch 10 taken 378 times.
 394 if (options_mgr_->GetValue("CVMFS_MAX_SERVERS", &optarg)) {
1439
1/2
✓ Branch 1 taken 16 times.
✗ Branch 2 not taken.
 16 const unsigned max_servers = String2Uint64(optarg);
1440 16 std::vector<std::string> host_chain;
1441
1/2
✓ Branch 1 taken 16 times.
✗ Branch 2 not taken.
 16 download_mgr_->GetHostInfo(&host_chain, NULL, NULL);
1442
6/6
✓ Branch 0 taken 12 times.
✓ Branch 1 taken 4 times.
✓ Branch 3 taken 4 times.
✓ Branch 4 taken 8 times.
✓ Branch 5 taken 4 times.
✓ Branch 6 taken 12 times.
 16 if (max_servers > 0 && max_servers < host_chain.size()) {
1443
1/2
✓ Branch 1 taken 4 times.
✗ Branch 2 not taken.
 4 host_chain.resize(max_servers);
1444
1/2
✓ Branch 1 taken 4 times.
✗ Branch 2 not taken.
 4 download_mgr_->SetHostChain(host_chain);
1445 }
1446 16 }
1447
1448
3/10
✓ Branch 1 taken 394 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 394 times.
✗ Branch 5 not taken.
✗ Branch 7 not taken.
✓ Branch 8 taken 394 times.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
 788 if (options_mgr_->GetValue("CVMFS_USE_SSL_SYSTEM_CA", &optarg)
1449
3/10
✓ Branch 2 taken 394 times.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✓ Branch 5 taken 394 times.
✗ Branch 7 not taken.
✗ Branch 8 not taken.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✓ Branch 11 taken 394 times.
✗ Branch 12 not taken.
 788 && options_mgr_->IsOn(optarg)) {
1450 ✗ download_mgr_->UseSystemCertificatePath();
1451 }
1452
1453
3/10
✓ Branch 1 taken 394 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 394 times.
✗ Branch 5 not taken.
✗ Branch 7 not taken.
✓ Branch 8 taken 394 times.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
 788 if (options_mgr_->GetValue("CVMFS_PROXY_SHARD", &optarg)
1454
3/10
✓ Branch 2 taken 394 times.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✓ Branch 5 taken 394 times.
✗ Branch 7 not taken.
✗ Branch 8 not taken.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✓ Branch 11 taken 394 times.
✗ Branch 12 not taken.
 788 && options_mgr_->IsOn(optarg)) {
1455 ✗ download_mgr_->ShardProxies();
1456 }
1457
1458 // configure http tracing header
1459
3/10
✓ Branch 1 taken 394 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 394 times.
✗ Branch 5 not taken.
✗ Branch 7 not taken.
✓ Branch 8 taken 394 times.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
 788 if (options_mgr_->GetValue("CVMFS_HTTP_TRACING", &optarg)
1460
3/10
✓ Branch 2 taken 394 times.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✓ Branch 5 taken 394 times.
✗ Branch 7 not taken.
✗ Branch 8 not taken.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✓ Branch 11 taken 394 times.
✗ Branch 12 not taken.
 788 && options_mgr_->IsOn(optarg)) {
1461 ✗ download_mgr_->EnableHTTPTracing();
1462 ✗ if (options_mgr_->GetValue("CVMFS_HTTP_TRACING_HEADERS", &optarg)) {
1463 ✗ if (optarg.size() > 1000) {
1464 ✗ LogCvmfs(kLogCvmfs, kLogSyslogErr | kLogDebug,
1465 "CVMFS_HTTP_TRACING_HEADERS too large ( max 1000 chars, given "
1466 "%ld )",
1467 optarg.size());
1468 } else {
1469 ✗ std::vector<std::string> tokens = SplitString(optarg, '|');
1470 ✗ const sanitizer::AlphaNumSanitizer sanitizer;
1471
1472 ✗ for (unsigned int i = 0; i < tokens.size(); i++) {
1473 ✗ const std::string token = Trim(tokens[i]);
1474
1475 ✗ std::vector<std::string> key_val = SplitString(token, ':');
1476
1477 ✗ if (key_val.size() != 2) {
1478 ✗ LogCvmfs(kLogCvmfs, kLogSyslogErr | kLogDebug,
1479 "Http tracing header: Skipping current token part of "
1480 "CVMFS_HTTP_TRACING_HEADERS! Invalid "
1481 "<key:value> pair. Token: %s",
1482 token.c_str());
1483 ✗ continue;
1484 }
1485
1486 ✗ const std::string prefix = "X-CVMFS-";
1487 ✗ const std::string key = Trim(key_val[0]);
1488
1489 ✗ if (!sanitizer.IsValid(key)) {
1490 ✗ LogCvmfs(kLogCvmfs, kLogSyslogErr | kLogDebug,
1491 "Http tracing header: Skipping current token part of "
1492 "CVMFS_HTTP_TRACING_HEADERS! Invalid key. Only "
1493 "alphanumeric keys "
1494 "are allowed (a-z, A-Z, 0-9). Token: %s",
1495 token.c_str());
1496 ✗ continue;
1497 }
1498
1499 ✗ const std::string final_token = prefix + key + ": "
1500 ✗ + Trim(key_val[1]);
1501
1502 ✗ download_mgr_->AddHTTPTracingHeader(final_token);
1503 }
1504 }
1505 }
1506 }
1507
1508
1/2
✓ Branch 1 taken 394 times.
✗ Branch 2 not taken.
 394 return SetupExternalDownloadMgr(do_geosort);
1509 686 }
1510
1511 394 bool MountPoint::CreateResolvConfWatcher() {
1512 394 std::string roaming_value;
1513
2/4
✓ Branch 2 taken 394 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 394 times.
✗ Branch 6 not taken.
 394 options_mgr_->GetValue("CVMFS_DNS_ROAMING", &roaming_value);
1514
3/10
✓ Branch 1 taken 394 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 394 times.
✗ Branch 5 not taken.
✗ Branch 7 not taken.
✓ Branch 8 taken 394 times.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
 788 if (options_mgr_->IsDefined("CVMFS_DNS_ROAMING")
1515
3/10
✓ Branch 2 taken 394 times.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✓ Branch 5 taken 394 times.
✗ Branch 7 not taken.
✗ Branch 8 not taken.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✓ Branch 11 taken 394 times.
✗ Branch 12 not taken.
 788 && options_mgr_->IsOn(roaming_value)) {
1516 ✗ LogCvmfs(kLogCvmfs, kLogDebug,
1517 "DNS roaming is enabled for this repository.");
1518 // Create a file watcher to update the DNS settings of the download
1519 // managers when there are changes to /etc/resolv.conf
1520 ✗ resolv_conf_watcher_ = file_watcher::FileWatcher::Create();
1521
1522 ✗ if (resolv_conf_watcher_) {
1523 ResolvConfEventHandler *handler = new ResolvConfEventHandler(
1524 ✗ download_mgr_, external_download_mgr_);
1525 ✗ resolv_conf_watcher_->RegisterHandler("/etc/resolv.conf", handler);
1526 }
1527 } else {
1528
1/2
✓ Branch 1 taken 394 times.
✗ Branch 2 not taken.
 394 LogCvmfs(kLogCvmfs, kLogDebug,
1529 "DNS roaming is disabled for this repository.");
1530 }
1531 394 return true;
1532 394 }
1533
1534 394 void MountPoint::CreateFetchers() {
1535 394 fetcher_ = new cvmfs::Fetcher(file_system_->cache_mgr(),
1536 download_mgr_,
1537 backoff_throttle_,
1538
4/8
✓ Branch 2 taken 394 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 394 times.
✗ Branch 6 not taken.
✓ Branch 8 taken 394 times.
✗ Branch 9 not taken.
✓ Branch 11 taken 394 times.
✗ Branch 12 not taken.
 394 perf::StatisticsTemplate("fetch", statistics_));
1539
1540 788 external_fetcher_ = new cvmfs::Fetcher(
1541 394 file_system_->cache_mgr(),
1542 external_download_mgr_,
1543 backoff_throttle_,
1544
4/8
✓ Branch 2 taken 394 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 394 times.
✗ Branch 6 not taken.
✓ Branch 8 taken 394 times.
✗ Branch 9 not taken.
✓ Branch 11 taken 394 times.
✗ Branch 12 not taken.
 394 perf::StatisticsTemplate("fetch-external", statistics_));
1545 394 }
1546
1547
1548 690 bool MountPoint::CreateSignatureManager() {
1549 690 string optarg;
1550
2/4
✓ Branch 1 taken 690 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 690 times.
✗ Branch 5 not taken.
 690 signature_mgr_ = new signature::SignatureManager();
1551
1/2
✓ Branch 1 taken 690 times.
✗ Branch 2 not taken.
 690 signature_mgr_->Init();
1552
1553 690 string public_keys;
1554
4/6
✓ Branch 2 taken 690 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 690 times.
✗ Branch 6 not taken.
✓ Branch 9 taken 328 times.
✓ Branch 10 taken 362 times.
 690 if (options_mgr_->GetValue("CVMFS_PUBLIC_KEY", &optarg)) {
1555
1/2
✓ Branch 1 taken 328 times.
✗ Branch 2 not taken.
 328 public_keys = optarg;
1556
3/6
✓ Branch 2 taken 362 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 362 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 362 times.
 362 } else if (options_mgr_->GetValue("CVMFS_KEYS_DIR", &optarg)) {
1557 // Collect .pub files from CVMFS_KEYS_DIR
1558 ✗ public_keys = JoinStrings(FindFilesBySuffix(optarg, ".pub"), ":");
1559 } else {
1560
5/10
✓ Branch 2 taken 362 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 362 times.
✗ Branch 7 not taken.
✓ Branch 10 taken 362 times.
✗ Branch 11 not taken.
✓ Branch 13 taken 362 times.
✗ Branch 14 not taken.
✓ Branch 16 taken 362 times.
✗ Branch 17 not taken.
 724 public_keys = JoinStrings(FindFilesBySuffix("/etc/cvmfs/keys", ".pub"),
1561 362 ":");
1562 }
1563
1564
3/4
✓ Branch 1 taken 690 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 4 times.
✓ Branch 4 taken 686 times.
 690 if (!signature_mgr_->LoadPublicRsaKeys(public_keys)) {
1565
1/2
✓ Branch 1 taken 4 times.
✗ Branch 2 not taken.
 4 boot_error_ = "failed to load public key(s)";
1566 4 boot_status_ = loader::kFailSignature;
1567 4 return false;
1568 }
1569
1570
2/2
✓ Branch 1 taken 324 times.
✓ Branch 2 taken 362 times.
 686 if (public_keys.size() > 0) {
1571
1/2
✓ Branch 2 taken 324 times.
✗ Branch 3 not taken.
 324 LogCvmfs(kLogCvmfs, kLogDebug, "CernVM-FS: using public key(s) %s",
1572 public_keys.c_str());
1573 } else {
1574
1/2
✓ Branch 1 taken 362 times.
✗ Branch 2 not taken.
 362 LogCvmfs(kLogCvmfs, kLogDebug | kLogSyslogWarn, "no public key loaded");
1575 }
1576
1577 686 return true;
1578 690 }
1579
1580
1581 690 void MountPoint::CreateStatistics() {
1582 690 statistics_ = file_system_->statistics()->Fork();
1583
2/2
✓ Branch 1 taken 299 times.
✓ Branch 2 taken 391 times.
 690 if (file_system_->type() != FileSystem::kFsFuse)
1584 299 return;
1585
1586 // TODO(jblomer): this should be registered by the tracker
1587
3/6
✓ Branch 2 taken 391 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 391 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 391 times.
✗ Branch 10 not taken.
 391 statistics_->Register("inode_tracker.n_insert",
1588 "overall number of accessed inodes");
1589
3/6
✓ Branch 2 taken 391 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 391 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 391 times.
✗ Branch 10 not taken.
 391 statistics_->Register("inode_tracker.n_remove",
1590 "overall number of evicted inodes");
1591
3/6
✓ Branch 2 taken 391 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 391 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 391 times.
✗ Branch 10 not taken.
 391 statistics_->Register("inode_tracker.no_reference",
1592 "currently active inodes");
1593
3/6
✓ Branch 2 taken 391 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 391 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 391 times.
✗ Branch 10 not taken.
 391 statistics_->Register("inode_tracker.n_hit_inode",
1594 "overall number of inode lookups");
1595
3/6
✓ Branch 2 taken 391 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 391 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 391 times.
✗ Branch 10 not taken.
 391 statistics_->Register("inode_tracker.n_hit_path",
1596 "overall number of successful path lookups");
1597
3/6
✓ Branch 2 taken 391 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 391 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 391 times.
✗ Branch 10 not taken.
 391 statistics_->Register("inode_tracker.n_miss_path",
1598 "overall number of unsuccessful path lookups");
1599
1600
3/6
✓ Branch 2 taken 391 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 391 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 391 times.
✗ Branch 10 not taken.
 391 statistics_->Register("dentry_tracker.n_insert",
1601 "overall number of added negative cache entries");
1602
3/6
✓ Branch 2 taken 391 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 391 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 391 times.
✗ Branch 10 not taken.
 391 statistics_->Register("dentry_tracker.n_remove",
1603 "overall number of evicted negative cache entries");
1604
3/6
✓ Branch 2 taken 391 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 391 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 391 times.
✗ Branch 10 not taken.
 391 statistics_->Register("dentry_tracker.n_prune",
1605 "overall number of prune calls");
1606
1607
3/6
✓ Branch 2 taken 391 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 391 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 391 times.
✗ Branch 10 not taken.
 391 statistics_->Register("page_cache_tracker.n_insert",
1608 "overall number of added page cache entries");
1609
3/6
✓ Branch 2 taken 391 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 391 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 391 times.
✗ Branch 10 not taken.
 391 statistics_->Register("page_cache_tracker.n_remove",
1610 "overall number of evicted page cache entries");
1611
3/6
✓ Branch 2 taken 391 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 391 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 391 times.
✗ Branch 10 not taken.
 391 statistics_->Register("page_cache_tracker.n_open_direct",
1612 "overall number of direct I/O open calls");
1613
3/6
✓ Branch 2 taken 391 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 391 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 391 times.
✗ Branch 10 not taken.
 391 statistics_->Register(
1614 "page_cache_tracker.n_open_flush",
1615 "overall number of open calls where the file's page cache gets flushed");
1616
3/6
✓ Branch 2 taken 391 times.
✗ Branch 3 not taken.
✓ Branch 6 taken 391 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 391 times.
✗ Branch 10 not taken.
 391 statistics_->Register(
1617 "page_cache_tracker.n_open_cached",
1618 "overall number of open calls where the file's page cache is reused");
1619 }
1620
1621
1622 292 void MountPoint::CreateTables() {
1623
2/2
✓ Branch 1 taken 225 times.
✓ Branch 2 taken 67 times.
 292 if (file_system_->type() != FileSystem::kFsFuse) {
1624 // Libcvmfs simplified tables
1625
2/4
✓ Branch 1 taken 225 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 225 times.
✗ Branch 5 not taken.
 225 md5path_cache_ = new lru::Md5PathCache(kLibPathCacheSize, statistics_);
1626
2/4
✓ Branch 1 taken 225 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 225 times.
✗ Branch 5 not taken.
 225 simple_chunk_tables_ = new SimpleChunkTables();
1627 225 return;
1628 }
1629
1630
2/4
✓ Branch 1 taken 67 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 67 times.
✗ Branch 5 not taken.
 67 chunk_tables_ = new ChunkTables();
1631
1632 67 string optarg;
1633 67 uint64_t mem_cache_size = kDefaultMemcacheSize;
1634
3/6
✓ Branch 2 taken 67 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 67 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 67 times.
 67 if (options_mgr_->GetValue("CVMFS_MEMCACHE_SIZE", &optarg))
1635 ✗ mem_cache_size = String2Uint64(optarg) * 1024 * 1024;
1636
1637 const double memcache_unit_size = (static_cast<double>(kInodeCacheFactor)
1638
1/2
✓ Branch 1 taken 67 times.
✗ Branch 2 not taken.
 67 * lru::Md5PathCache::GetEntrySize())
1639
1/2
✓ Branch 1 taken 67 times.
✗ Branch 2 not taken.
 67 + lru::InodeCache::GetEntrySize()
1640
1/2
✓ Branch 1 taken 67 times.
✗ Branch 2 not taken.
 67 + lru::PathCache::GetEntrySize();
1641 67 const unsigned memcache_num_units = mem_cache_size
1642 67 / static_cast<unsigned>(
1643 memcache_unit_size);
1644 // Number of cache entries must be a multiple of 64
1645 67 const unsigned mask_64 = ~((1 << 6) - 1);
1646
2/4
✓ Branch 1 taken 67 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 67 times.
✗ Branch 5 not taken.
 67 inode_cache_ = new lru::InodeCache(memcache_num_units & mask_64, statistics_);
1647
2/4
✓ Branch 1 taken 67 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 67 times.
✗ Branch 5 not taken.
 67 path_cache_ = new lru::PathCache(memcache_num_units & mask_64, statistics_);
1648 134 md5path_cache_ = new lru::Md5PathCache((memcache_num_units * 7) & mask_64,
1649
2/4
✓ Branch 1 taken 67 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 67 times.
✗ Branch 5 not taken.
 67 statistics_);
1650
1651
2/4
✓ Branch 1 taken 67 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 67 times.
✗ Branch 5 not taken.
 67 inode_tracker_ = new glue::InodeTracker();
1652
2/4
✓ Branch 1 taken 67 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 67 times.
✗ Branch 5 not taken.
 67 dentry_tracker_ = new glue::DentryTracker();
1653
2/4
✓ Branch 1 taken 67 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 67 times.
✗ Branch 5 not taken.
 67 page_cache_tracker_ = new glue::PageCacheTracker();
1654
1/2
✗ Branch 1 not taken.
✓ Branch 2 taken 67 times.
 67 if (file_system_->IsNfsSource())
1655 ✗ page_cache_tracker_->Disable();
1656 67 }
1657
1658 /**
1659 * Will create a tracer for the current mount point
1660 * Tracefile path, Trace buffer size and trace buffer flush threshold
1661 * can be configured by the options: CVMFS_TRACEFILE,
1662 * CVMFS_TRACEBUFFER, CVMFS_TRACEBUFFER_THRESHOLD(respectively)
1663 * VMFS_TRACEBUFFER and CVMFS_TRACEBUFFER_THRESHOLD will silently fallback
1664 * to default values if configuration values don't exist or are invalid
1665 */
1666 292 bool MountPoint::CreateTracer() {
1667 292 string optarg;
1668
2/4
✓ Branch 1 taken 292 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 292 times.
✗ Branch 5 not taken.
 292 tracer_ = new Tracer();
1669
3/6
✓ Branch 2 taken 292 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 292 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 292 times.
 292 if (options_mgr_->GetValue("CVMFS_TRACEFILE", &optarg)) {
1670 ✗ if (file_system_->type() != FileSystem::kFsFuse) {
1671 ✗ boot_error_ = "tracer is only supported in the fuse module";
1672 ✗ boot_status_ = loader::kFailOptions;
1673 ✗ return false;
1674 }
1675 ✗ const string tracebuffer_file = optarg;
1676 ✗ uint64_t tracebuffer_size = kTracerBufferSize;
1677 ✗ uint64_t tracebuffer_threshold = kTracerFlushThreshold;
1678
1679 ✗ if (options_mgr_->GetValue("CVMFS_TRACEBUFFER", &optarg)) {
1680 ✗ tracebuffer_size = String2Uint64(optarg);
1681 }
1682 ✗ if (options_mgr_->GetValue("CVMFS_TRACEBUFFER_THRESHOLD", &optarg)) {
1683 ✗ tracebuffer_threshold = String2Uint64(optarg);
1684 }
1685 ✗ assert(tracebuffer_size <= INT_MAX && tracebuffer_threshold <= INT_MAX);
1686 ✗ LogCvmfs(kLogCvmfs, kLogDebug,
1687 "Initialising tracer with buffer size %" PRIu64
1688 " and threshold %" PRIu64,
1689 tracebuffer_size, tracebuffer_threshold);
1690 ✗ tracer_->Activate(tracebuffer_size, tracebuffer_threshold,
1691 tracebuffer_file);
1692 }
1693 292 return true;
1694 292 }
1695
1696
1697 390 bool MountPoint::DetermineRootHash(shash::Any *root_hash) {
1698 390 string optarg;
1699
4/6
✓ Branch 2 taken 390 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 390 times.
✗ Branch 6 not taken.
✓ Branch 9 taken 252 times.
✓ Branch 10 taken 138 times.
 390 if (options_mgr_->GetValue("CVMFS_ROOT_HASH", &optarg)) {
1700
1/2
✓ Branch 2 taken 252 times.
✗ Branch 3 not taken.
 252 *root_hash = MkFromHexPtr(shash::HexPtr(optarg), shash::kSuffixCatalog);
1701 252 return true;
1702 }
1703
1704
4/10
✓ Branch 1 taken 138 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 138 times.
✗ Branch 5 not taken.
✓ Branch 7 taken 122 times.
✓ Branch 8 taken 16 times.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
 276 if (!options_mgr_->IsDefined("CVMFS_REPOSITORY_TAG")
1705
12/20
✓ Branch 2 taken 138 times.
✗ Branch 3 not taken.
✓ Branch 4 taken 130 times.
✓ Branch 5 taken 8 times.
✓ Branch 8 taken 130 times.
✗ Branch 9 not taken.
✓ Branch 11 taken 130 times.
✗ Branch 12 not taken.
✓ Branch 13 taken 122 times.
✓ Branch 14 taken 8 times.
✓ Branch 15 taken 130 times.
✓ Branch 16 taken 8 times.
✓ Branch 18 taken 130 times.
✓ Branch 19 taken 8 times.
✓ Branch 21 taken 138 times.
✗ Branch 22 not taken.
✗ Branch 23 not taken.
✗ Branch 24 not taken.
✗ Branch 26 not taken.
✗ Branch 27 not taken.
 276 && !options_mgr_->IsDefined("CVMFS_REPOSITORY_DATE")) {
1706 122 root_hash->SetNull();
1707 122 return true;
1708 }
1709
1710 16 string history_path;
1711
2/4
✓ Branch 1 taken 16 times.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
✓ Branch 4 taken 16 times.
 16 if (!FetchHistory(&history_path))
1712 ✗ return false;
1713
1/2
✓ Branch 1 taken 16 times.
✗ Branch 2 not taken.
 16 const UnlinkGuard history_file(history_path);
1714 const UniquePtr<history::History> tag_db(
1715
2/4
✓ Branch 1 taken 16 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 16 times.
✗ Branch 5 not taken.
 16 history::SqliteHistory::Open(history_path));
1716
1/2
✗ Branch 1 not taken.
✓ Branch 2 taken 16 times.
 16 if (!tag_db.IsValid()) {
1717 ✗ LogCvmfs(kLogCvmfs, kLogDebug | kLogSyslog,
1718 "failed to open history database (%s)", history_path.c_str());
1719 ✗ boot_error_ = "failed to open history database";
1720 ✗ boot_status_ = loader::kFailHistory;
1721 ✗ return false;
1722 }
1723
1724
1/2
✓ Branch 1 taken 16 times.
✗ Branch 2 not taken.
 16 history::History::Tag tag;
1725 bool retval;
1726
4/6
✓ Branch 2 taken 16 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 16 times.
✗ Branch 6 not taken.
✓ Branch 9 taken 8 times.
✓ Branch 10 taken 8 times.
 16 if (!options_mgr_->GetValue("CVMFS_REPOSITORY_TAG", &repository_tag_)) {
1727 8 string repository_date;
1728 // options_mgr_->IsDefined("CVMFS_REPOSITORY_DATE") must be true
1729
2/4
✓ Branch 2 taken 8 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 8 times.
✗ Branch 6 not taken.
 8 options_mgr_->GetValue("CVMFS_REPOSITORY_DATE", &repository_date);
1730
1/2
✓ Branch 1 taken 8 times.
✗ Branch 2 not taken.
 8 const time_t repository_utctime = IsoTimestamp2UtcTime(repository_date);
1731
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 8 times.
 8 if (repository_utctime == 0) {
1732 boot_error_ = "invalid timestamp in CVMFS_REPOSITORY_DATE: "
1733 ✗ + repository_date + ". Use YYYY-MM-DDTHH:MM:SSZ";
1734 ✗ boot_status_ = loader::kFailHistory;
1735 ✗ return false;
1736 }
1737
1/2
✓ Branch 2 taken 8 times.
✗ Branch 3 not taken.
 8 retval = tag_db->GetByDate(repository_utctime, &tag);
1738
2/2
✓ Branch 0 taken 4 times.
✓ Branch 1 taken 4 times.
 8 if (!retval) {
1739 boot_error_ = "no repository state as early as utc timestamp "
1740
2/4
✓ Branch 1 taken 4 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 4 times.
✗ Branch 5 not taken.
 4 + StringifyTime(repository_utctime, true);
1741 4 boot_status_ = loader::kFailHistory;
1742 4 return false;
1743 }
1744
1/5
✗ Branch 2 not taken.
✓ Branch 3 taken 4 times.
✗ Branch 4 not taken.
✗ Branch 6 not taken.
✗ Branch 7 not taken.
 8 LogCvmfs(kLogCvmfs, kLogDebug | kLogSyslog,
1745 "time stamp %s UTC resolved to tag '%s'",
1746
1/2
✓ Branch 1 taken 4 times.
✗ Branch 2 not taken.
 8 StringifyTime(repository_utctime, true).c_str(), tag.name.c_str());
1747
1/2
✓ Branch 1 taken 4 times.
✗ Branch 2 not taken.
 4 repository_tag_ = tag.name;
1748
2/2
✓ Branch 1 taken 4 times.
✓ Branch 2 taken 4 times.
 8 } else {
1749
1/2
✓ Branch 2 taken 8 times.
✗ Branch 3 not taken.
 8 retval = tag_db->GetByName(repository_tag_, &tag);
1750
2/2
✓ Branch 0 taken 4 times.
✓ Branch 1 taken 4 times.
 8 if (!retval) {
1751
1/2
✓ Branch 1 taken 4 times.
✗ Branch 2 not taken.
 4 boot_error_ = "no such tag: " + repository_tag_;
1752 4 boot_status_ = loader::kFailHistory;
1753 4 return false;
1754 }
1755 }
1756
1/2
✓ Branch 2 taken 8 times.
✗ Branch 3 not taken.
 8 LogCvmfs(kLogCvmfs, kLogDebug, "mounting tag %s", tag.name.c_str());
1757
1758 8 *root_hash = tag.root_hash;
1759 8 return true;
1760 390 }
1761
1762
1763 16 bool MountPoint::FetchHistory(std::string *history_path) {
1764 manifest::Failures retval_mf;
1765 16 manifest::ManifestEnsemble ensemble;
1766
2/4
✓ Branch 2 taken 16 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 16 times.
✗ Branch 6 not taken.
 16 retval_mf = manifest::Fetch("", fqrn_, 0, NULL, signature_mgr_, download_mgr_,
1767 &ensemble);
1768
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 16 times.
 16 if (retval_mf != manifest::kFailOk) {
1769 ✗ boot_error_ = "Failed to fetch manifest";
1770 ✗ boot_status_ = loader::kFailHistory;
1771 ✗ return false;
1772 }
1773 16 const shash::Any history_hash = ensemble.manifest->history();
1774
1/2
✗ Branch 1 not taken.
✓ Branch 2 taken 16 times.
 16 if (history_hash.IsNull()) {
1775 ✗ boot_error_ = "No history";
1776 ✗ boot_status_ = loader::kFailHistory;
1777 ✗ return false;
1778 }
1779
1780 16 CacheManager::Label label;
1781 16 label.flags = CacheManager::kLabelHistory;
1782
1/2
✓ Branch 1 taken 16 times.
✗ Branch 2 not taken.
 16 label.path = fqrn_;
1783
2/4
✓ Branch 2 taken 16 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 16 times.
✗ Branch 6 not taken.
 48 const int fd = fetcher_->Fetch(
1784
1/2
✓ Branch 1 taken 16 times.
✗ Branch 2 not taken.
 32 CacheManager::LabeledObject(history_hash, label));
1785
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 16 times.
 16 if (fd < 0) {
1786 ✗ boot_error_ = "failed to download history: " + StringifyInt(-fd);
1787 ✗ boot_status_ = loader::kFailHistory;
1788 ✗ return false;
1789 }
1790 // We have the custom sqlite vfs driver installed
1791
2/4
✓ Branch 1 taken 16 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 16 times.
✗ Branch 5 not taken.
 16 *history_path = "@" + StringifyInt(fd);
1792 16 return true;
1793 16 }
1794
1795
1796 ✗ unsigned MountPoint::GetEffectiveTtlSec() {
1797 unsigned max_ttl;
1798 {
1799 ✗ const MutexLockGuard lock_guard(lock_max_ttl_);
1800 ✗ max_ttl = max_ttl_sec_;
1801 }
1802 ✗ const unsigned catalog_ttl_sec = catalog_mgr_->GetTTL();
1803
1804 ✗ return max_ttl ? std::min(max_ttl, catalog_ttl_sec) : catalog_ttl_sec;
1805 }
1806
1807
1808 ✗ unsigned MountPoint::GetMaxTtlMn() {
1809 ✗ const MutexLockGuard lock_guard(lock_max_ttl_);
1810 ✗ return max_ttl_sec_ / 60;
1811 }
1812
1813
1814 /**
1815 * Files in the workspace from different file systems / mountpoints need to
1816 * have different names. Used, for example, for caching proxy settings.
1817 */
1818 686 string MountPoint::GetUniqFileSuffix() {
1819
3/6
✓ Branch 2 taken 686 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 686 times.
✗ Branch 6 not taken.
✓ Branch 8 taken 686 times.
✗ Branch 9 not taken.
 1372 return "." + file_system_->name() + "-" + fqrn_;
1820 }
1821
1822
1823 690 MountPoint::MountPoint(const string &fqrn,
1824 FileSystem *file_system,
1825 690 OptionsManager *options_mgr)
1826
1/2
✓ Branch 1 taken 690 times.
✗ Branch 2 not taken.
 690 : fqrn_(fqrn)
1827
2/4
✓ Branch 2 taken 690 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 690 times.
✗ Branch 6 not taken.
 690 , uuid_(cvmfs::Uuid::Create(""))
1828 690 , file_system_(file_system)
1829 690 , options_mgr_(options_mgr)
1830 690 , statistics_(NULL)
1831 690 , telemetry_aggr_(NULL)
1832 690 , authz_fetcher_(NULL)
1833 690 , authz_session_mgr_(NULL)
1834 690 , authz_attachment_(NULL)
1835 690 , backoff_throttle_(NULL)
1836 690 , signature_mgr_(NULL)
1837 690 , download_mgr_(NULL)
1838 690 , external_download_mgr_(NULL)
1839 690 , fetcher_(NULL)
1840 690 , external_fetcher_(NULL)
1841 690 , inode_annotation_(NULL)
1842 690 , catalog_mgr_(NULL)
1843 690 , chunk_tables_(NULL)
1844 690 , simple_chunk_tables_(NULL)
1845 690 , inode_cache_(NULL)
1846 690 , path_cache_(NULL)
1847 690 , md5path_cache_(NULL)
1848 690 , tracer_(NULL)
1849 690 , inode_tracker_(NULL)
1850 690 , dentry_tracker_(NULL)
1851 690 , page_cache_tracker_(NULL)
1852 690 , statfs_cache_(NULL)
1853 690 , resolv_conf_watcher_(NULL)
1854 690 , max_ttl_sec_(kDefaultMaxTtlSec)
1855 690 , kcache_timeout_sec_(static_cast<double>(kDefaultKCacheTtlSec))
1856 690 , fixed_catalog_(false)
1857 690 , enforce_acls_(false)
1858 690 , cache_symlinks_(false)
1859 690 , fuse_expire_entry_(false)
1860 690 , has_membership_req_(false)
1861
2/4
✓ Branch 2 taken 690 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 690 times.
✗ Branch 6 not taken.
 690 , talk_socket_path_(std::string("./cvmfs_io.") + fqrn)
1862 690 , talk_socket_uid_(0)
1863 1380 , talk_socket_gid_(0) {
1864 690 const int retval = pthread_mutex_init(&lock_max_ttl_, NULL);
1865
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 690 times.
 690 assert(retval == 0);
1866 690 }
1867
1868
1869 690 MountPoint::~MountPoint() {
1870 690 pthread_mutex_destroy(&lock_max_ttl_);
1871
1872
2/2
✓ Branch 0 taken 67 times.
✓ Branch 1 taken 623 times.
 690 delete page_cache_tracker_;
1873
2/2
✓ Branch 0 taken 67 times.
✓ Branch 1 taken 623 times.
 690 delete dentry_tracker_;
1874
2/2
✓ Branch 0 taken 67 times.
✓ Branch 1 taken 623 times.
 690 delete inode_tracker_;
1875
2/2
✓ Branch 0 taken 292 times.
✓ Branch 1 taken 398 times.
 690 delete tracer_;
1876
2/2
✓ Branch 0 taken 292 times.
✓ Branch 1 taken 398 times.
 690 delete md5path_cache_;
1877
2/2
✓ Branch 0 taken 67 times.
✓ Branch 1 taken 623 times.
 690 delete path_cache_;
1878
2/2
✓ Branch 0 taken 67 times.
✓ Branch 1 taken 623 times.
 690 delete inode_cache_;
1879
2/2
✓ Branch 0 taken 225 times.
✓ Branch 1 taken 465 times.
 690 delete simple_chunk_tables_;
1880
2/2
✓ Branch 0 taken 67 times.
✓ Branch 1 taken 623 times.
 690 delete chunk_tables_;
1881
1882
2/2
✓ Branch 0 taken 394 times.
✓ Branch 1 taken 296 times.
 690 delete catalog_mgr_;
1883
2/2
✓ Branch 0 taken 394 times.
✓ Branch 1 taken 296 times.
 690 delete inode_annotation_;
1884
2/2
✓ Branch 0 taken 394 times.
✓ Branch 1 taken 296 times.
 690 delete external_fetcher_;
1885
2/2
✓ Branch 0 taken 394 times.
✓ Branch 1 taken 296 times.
 690 delete fetcher_;
1886
1887
2/2
✓ Branch 0 taken 394 times.
✓ Branch 1 taken 296 times.
 690 delete external_download_mgr_;
1888
2/2
✓ Branch 0 taken 686 times.
✓ Branch 1 taken 4 times.
 690 delete download_mgr_;
1889
1890
1/2
✓ Branch 0 taken 690 times.
✗ Branch 1 not taken.
 690 if (signature_mgr_ != NULL) {
1891 690 signature_mgr_->Fini();
1892
1/2
✓ Branch 0 taken 690 times.
✗ Branch 1 not taken.
 690 delete signature_mgr_;
1893 }
1894
1895
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 690 times.
 690 if (resolv_conf_watcher_ != NULL) {
1896 ✗ resolv_conf_watcher_->Stop();
1897 ✗ delete resolv_conf_watcher_;
1898 }
1899
1900
1/2
✓ Branch 0 taken 690 times.
✗ Branch 1 not taken.
 690 delete backoff_throttle_;
1901
1/2
✓ Branch 0 taken 690 times.
✗ Branch 1 not taken.
 690 delete authz_attachment_;
1902
1/2
✓ Branch 0 taken 690 times.
✗ Branch 1 not taken.
 690 delete authz_session_mgr_;
1903
1/2
✓ Branch 0 taken 690 times.
✗ Branch 1 not taken.
 690 delete authz_fetcher_;
1904
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 690 times.
 690 delete telemetry_aggr_;
1905
1/2
✓ Branch 0 taken 690 times.
✗ Branch 1 not taken.
 690 delete statistics_;
1906
1/2
✓ Branch 0 taken 690 times.
✗ Branch 1 not taken.
 690 delete uuid_;
1907
1908
2/2
✓ Branch 0 taken 292 times.
✓ Branch 1 taken 398 times.
 690 delete statfs_cache_;
1909 690 }
1910
1911
1912 294 void MountPoint::ReEvaluateAuthz() {
1913
1/2
✓ Branch 1 taken 294 times.
✗ Branch 2 not taken.
 294 const string old_membership_req = membership_req_;
1914
1/2
✓ Branch 1 taken 294 times.
✗ Branch 2 not taken.
 294 has_membership_req_ = catalog_mgr_->GetVOMSAuthz(&membership_req_);
1915
1/2
✗ Branch 1 not taken.
✓ Branch 2 taken 294 times.
 294 if (old_membership_req != membership_req_) {
1916 ✗ authz_session_mgr_->ClearSessionCache();
1917 ✗ authz_attachment_->set_membership(membership_req_);
1918 }
1919 294 }
1920
1921
1922 ✗ void MountPoint::SetMaxTtlMn(unsigned value_minutes) {
1923 ✗ const MutexLockGuard lock_guard(lock_max_ttl_);
1924 ✗ max_ttl_sec_ = value_minutes * 60;
1925 }
1926
1927 292 bool MountPoint::SetupBehavior() {
1928 292 string optarg;
1929
1930
3/6
✓ Branch 2 taken 292 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 292 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 292 times.
 292 if (options_mgr_->GetValue("CVMFS_MAX_TTL", &optarg))
1931 ✗ SetMaxTtlMn(String2Uint64(optarg));
1932
1933
3/6
✓ Branch 2 taken 292 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 292 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 292 times.
 292 if (options_mgr_->GetValue("CVMFS_KCACHE_TIMEOUT", &optarg)) {
1934 // Can be negative and should then be interpreted as 0.0
1935 ✗ kcache_timeout_sec_ = std::max(0.0,
1936 ✗ static_cast<double>(String2Int64(optarg)));
1937 }
1938 292 LogCvmfs(kLogCvmfs, kLogDebug, "kernel caches expire after %d seconds",
1939
1/2
✓ Branch 1 taken 292 times.
✗ Branch 2 not taken.
 292 static_cast<int>(kcache_timeout_sec_));
1940
1941 292 uint64_t statfs_time_cache_valid = 0;
1942
3/6
✓ Branch 2 taken 292 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 292 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 292 times.
 292 if (options_mgr_->GetValue("CVMFS_STATFS_CACHE_TIMEOUT", &optarg)) {
1943 ✗ statfs_time_cache_valid = static_cast<uint64_t>(String2Uint64(optarg));
1944 }
1945
1/2
✓ Branch 1 taken 292 times.
✗ Branch 2 not taken.
 292 LogCvmfs(kLogCvmfs, kLogDebug, "statfs cache expires after %d seconds",
1946 static_cast<int>(statfs_time_cache_valid));
1947
1/2
✓ Branch 1 taken 292 times.
✗ Branch 2 not taken.
 292 statfs_cache_ = new StatfsCache(statfs_time_cache_valid);
1948
1949 MagicXattrManager::EVisibility
1950 292 xattr_visibility = MagicXattrManager::kVisibilityRootOnly;
1951
3/6
✓ Branch 2 taken 292 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 292 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 292 times.
 292 if (options_mgr_->GetValue("CVMFS_HIDE_MAGIC_XATTRS", &optarg)) {
1952 ✗ if (options_mgr_->IsOn(optarg))
1953 ✗ xattr_visibility = MagicXattrManager::kVisibilityNever;
1954 ✗ else if (options_mgr_->IsOff(optarg))
1955 ✗ xattr_visibility = MagicXattrManager::kVisibilityAlways;
1956 }
1957
3/6
✓ Branch 2 taken 292 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 292 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 292 times.
 292 if (options_mgr_->GetValue("CVMFS_MAGIC_XATTRS_VISIBILITY", &optarg)) {
1958 ✗ if (ToUpper(optarg) == "ROOTONLY") {
1959 ✗ xattr_visibility = MagicXattrManager::kVisibilityRootOnly;
1960 ✗ } else if (ToUpper(optarg) == "NEVER") {
1961 ✗ xattr_visibility = MagicXattrManager::kVisibilityNever;
1962 ✗ } else if (ToUpper(optarg) == "ALWAYS") {
1963 ✗ xattr_visibility = MagicXattrManager::kVisibilityAlways;
1964 } else {
1965 ✗ LogCvmfs(kLogCvmfs, kLogSyslogWarn | kLogDebug,
1966 "unsupported setting: CVMFS_MAGIC_XATTRS_VISIBILITY=%s",
1967 optarg.c_str());
1968 }
1969 }
1970
1971 292 std::set<gid_t> protected_xattr_gids;
1972
3/6
✓ Branch 2 taken 292 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 292 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 292 times.
 292 if (options_mgr_->GetValue("CVMFS_XATTR_PRIVILEGED_GIDS", &optarg)) {
1973 ✗ std::vector<string> tmp = SplitString(optarg, ',');
1974
1975 ✗ for (size_t i = 0; i < tmp.size(); i++) {
1976 ✗ const std::string trimmed = Trim(tmp[i]);
1977 ✗ LogCvmfs(kLogCvmfs, kLogDebug, "Privileged gid for xattr added: %s",
1978 trimmed.c_str());
1979 ✗ protected_xattr_gids.insert(static_cast<gid_t>(String2Uint64(trimmed)));
1980 }
1981 }
1982 292 std::set<std::string> protected_xattrs;
1983
3/6
✓ Branch 2 taken 292 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 292 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 292 times.
 292 if (options_mgr_->GetValue("CVMFS_XATTR_PROTECTED_XATTRS", &optarg)) {
1984 ✗ std::vector<string> tmp = SplitString(optarg, ',');
1985
1986 ✗ for (size_t i = 0; i < tmp.size(); i++) {
1987 ✗ const std::string trimmed = Trim(tmp[i]);
1988 ✗ LogCvmfs(kLogCvmfs, kLogDebug, "Protected xattr added: %s",
1989 trimmed.c_str());
1990 ✗ protected_xattrs.insert(trimmed);
1991 }
1992
1993 // root has always access to xattr
1994 ✗ if (protected_xattr_gids.count(0) < 1) {
1995 ✗ protected_xattr_gids.insert(0);
1996 ✗ LogCvmfs(kLogCvmfs, kLogDebug,
1997 "Automatically added root to have access to protected xattrs.");
1998 }
1999 }
2000 292 magic_xattr_mgr_ = new MagicXattrManager(
2001
2/4
✓ Branch 1 taken 292 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 292 times.
✗ Branch 5 not taken.
 292 this, xattr_visibility, protected_xattrs, protected_xattr_gids);
2002
2003
2004
3/10
✓ Branch 1 taken 292 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 292 times.
✗ Branch 5 not taken.
✗ Branch 7 not taken.
✓ Branch 8 taken 292 times.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
 584 if (options_mgr_->GetValue("CVMFS_ENFORCE_ACLS", &optarg)
2005
3/10
✓ Branch 2 taken 292 times.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✓ Branch 5 taken 292 times.
✗ Branch 7 not taken.
✗ Branch 8 not taken.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✓ Branch 11 taken 292 times.
✗ Branch 12 not taken.
 584 && options_mgr_->IsOn(optarg)) {
2006 ✗ enforce_acls_ = true;
2007 }
2008
2009
3/10
✓ Branch 1 taken 292 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 292 times.
✗ Branch 5 not taken.
✗ Branch 7 not taken.
✓ Branch 8 taken 292 times.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
 584 if (options_mgr_->GetValue("CVMFS_CACHE_SYMLINKS", &optarg)
2010
3/10
✓ Branch 2 taken 292 times.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✓ Branch 5 taken 292 times.
✗ Branch 7 not taken.
✗ Branch 8 not taken.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✓ Branch 11 taken 292 times.
✗ Branch 12 not taken.
 584 && options_mgr_->IsOn(optarg)) {
2011 ✗ cache_symlinks_ = true;
2012 }
2013
2014
2015
3/6
✓ Branch 2 taken 292 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 292 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 292 times.
 292 if (options_mgr_->GetValue("CVMFS_TALK_SOCKET", &optarg)) {
2016 ✗ talk_socket_path_ = optarg;
2017 }
2018
3/6
✓ Branch 2 taken 292 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 292 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 292 times.
 292 if (options_mgr_->GetValue("CVMFS_TALK_OWNER", &optarg)) {
2019 ✗ const bool retval = GetUidOf(optarg, &talk_socket_uid_, &talk_socket_gid_);
2020 ✗ if (!retval) {
2021 ✗ boot_error_ = "unknown owner of cvmfs_talk socket: " + optarg;
2022 ✗ boot_status_ = loader::kFailOptions;
2023 ✗ return false;
2024 }
2025 }
2026
2027 // this can be later be changed to switch through different
2028 // telemetryAggregators
2029
3/10
✓ Branch 1 taken 292 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 292 times.
✗ Branch 5 not taken.
✗ Branch 7 not taken.
✓ Branch 8 taken 292 times.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
 584 if (options_mgr_->GetValue("CVMFS_TELEMETRY_SEND", &optarg)
2030
3/10
✓ Branch 2 taken 292 times.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✓ Branch 5 taken 292 times.
✗ Branch 7 not taken.
✗ Branch 8 not taken.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✓ Branch 11 taken 292 times.
✗ Branch 12 not taken.
 584 && options_mgr_->IsOn(optarg)) {
2031 ✗ int telemetry_send_rate_sec = kDefaultTelemetrySendRateSec;
2032 ✗ if (options_mgr_->GetValue("CVMFS_TELEMETRY_RATE", &optarg)) {
2033 ✗ telemetry_send_rate_sec = static_cast<int>(String2Uint64(optarg));
2034
2035 // minimum send rate: 5sec
2036 ✗ if (telemetry_send_rate_sec < kMinimumTelemetrySendRateSec) {
2037 ✗ telemetry_send_rate_sec = kMinimumTelemetrySendRateSec;
2038 }
2039
2040 ✗ telemetry_aggr_ = perf::TelemetryAggregator::Create(
2041 statistics_,
2042 telemetry_send_rate_sec,
2043 options_mgr_,
2044 this,
2045 ✗ fqrn_,
2046 perf::kTelemetryInflux);
2047 ✗ LogCvmfs(kLogTelemetry, kLogSyslog | kLogDebug,
2048 "Enable telemetry to report every %d seconds",
2049 telemetry_send_rate_sec);
2050 }
2051 }
2052
2053 292 return true;
2054 292 }
2055
2056
2057 /**
2058 * Called twice once for the regular download manager and once for the external
2059 * download manager.
2060 */
2061 686 void MountPoint::SetupDnsTuning(download::DownloadManager *manager) {
2062 686 string optarg;
2063 686 unsigned dns_timeout_ms = download::DownloadManager::kDnsDefaultTimeoutMs;
2064 686 unsigned dns_retries = download::DownloadManager::kDnsDefaultRetries;
2065
3/6
✓ Branch 2 taken 686 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 686 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 686 times.
 686 if (options_mgr_->GetValue("CVMFS_DNS_TIMEOUT", &optarg))
2066 ✗ dns_timeout_ms = String2Uint64(optarg) * 1000;
2067
3/6
✓ Branch 2 taken 686 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 686 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 686 times.
 686 if (options_mgr_->GetValue("CVMFS_DNS_RETRIES", &optarg))
2068 ✗ dns_retries = String2Uint64(optarg);
2069
1/2
✓ Branch 1 taken 686 times.
✗ Branch 2 not taken.
 686 manager->SetDnsParameters(dns_retries, dns_timeout_ms);
2070
2071 // Rest has to be after SetDnsParameters because SetDnsParameters might
2072 // construct a new resolver object
2073
2074 686 unsigned dns_min_ttl = dns::Resolver::kDefaultMinTtl;
2075 686 unsigned dns_max_ttl = dns::Resolver::kDefaultMaxTtl;
2076
3/6
✓ Branch 2 taken 686 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 686 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 686 times.
 686 if (options_mgr_->GetValue("CVMFS_DNS_MIN_TTL", &optarg))
2077 ✗ dns_min_ttl = String2Uint64(optarg);
2078
3/6
✓ Branch 2 taken 686 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 686 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 686 times.
 686 if (options_mgr_->GetValue("CVMFS_DNS_MAX_TTL", &optarg))
2079 ✗ dns_max_ttl = String2Uint64(optarg);
2080
1/2
✓ Branch 1 taken 686 times.
✗ Branch 2 not taken.
 686 manager->SetDnsTtlLimits(dns_min_ttl, dns_max_ttl);
2081
2082
3/6
✓ Branch 2 taken 686 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 686 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 686 times.
 686 if (options_mgr_->GetValue("CVMFS_DNS_SERVER", &optarg)) {
2083 ✗ download_mgr_->SetDnsServer(optarg);
2084 }
2085
2086
3/6
✓ Branch 2 taken 686 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 686 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 686 times.
 686 if (options_mgr_->GetValue("CVMFS_IPFAMILY_PREFER", &optarg)) {
2087 ✗ switch (String2Int64(optarg)) {
2088 ✗ case 4:
2089 ✗ manager->SetIpPreference(dns::kIpPreferV4);
2090 ✗ break;
2091 ✗ case 6:
2092 ✗ manager->SetIpPreference(dns::kIpPreferV6);
2093 ✗ break;
2094 }
2095 }
2096
3/6
✓ Branch 2 taken 686 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 686 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 686 times.
 686 if (options_mgr_->GetValue("CVMFS_MAX_IPADDR_PER_PROXY", &optarg))
2097 ✗ manager->SetMaxIpaddrPerProxy(String2Uint64(optarg));
2098 686 }
2099
2100
2101 394 bool MountPoint::SetupExternalDownloadMgr(bool dogeosort) {
2102 394 string optarg;
2103
2/4
✓ Branch 2 taken 394 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 394 times.
✗ Branch 6 not taken.
 1182 external_download_mgr_ = download_mgr_->Clone(
2104
2/4
✓ Branch 2 taken 394 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 394 times.
✗ Branch 6 not taken.
 788 perf::StatisticsTemplate("download-external", statistics_), "external");
2105
2106 unsigned timeout;
2107 unsigned timeout_direct;
2108
1/2
✓ Branch 1 taken 394 times.
✗ Branch 2 not taken.
 394 download_mgr_->GetTimeout(&timeout, &timeout_direct);
2109
3/6
✓ Branch 2 taken 394 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 394 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 394 times.
 394 if (options_mgr_->GetValue("CVMFS_EXTERNAL_TIMEOUT", &optarg)) {
2110 ✗ timeout = String2Uint64(optarg);
2111 }
2112
3/6
✓ Branch 2 taken 394 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 394 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 394 times.
 394 if (options_mgr_->GetValue("CVMFS_EXTERNAL_TIMEOUT_DIRECT", &optarg)) {
2113 ✗ timeout_direct = String2Uint64(optarg);
2114 }
2115
1/2
✓ Branch 1 taken 394 times.
✗ Branch 2 not taken.
 394 external_download_mgr_->SetTimeout(timeout, timeout_direct);
2116
2117
3/6
✓ Branch 2 taken 394 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 394 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 394 times.
 394 if (options_mgr_->GetValue("CVMFS_EXTERNAL_METALINK", &optarg)) {
2118 ✗ external_download_mgr_->SetMetalinkChain(optarg);
2119 // host chain will be set later when the metalink server is contacted
2120 ✗ external_download_mgr_->SetHostChain("");
2121 // metalink requires redirects
2122 ✗ external_download_mgr_->EnableRedirects();
2123
4/6
✓ Branch 2 taken 394 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 394 times.
✗ Branch 6 not taken.
✓ Branch 9 taken 8 times.
✓ Branch 10 taken 386 times.
 394 } else if (options_mgr_->GetValue("CVMFS_EXTERNAL_URL", &optarg)) {
2124
1/2
✓ Branch 1 taken 8 times.
✗ Branch 2 not taken.
 8 external_download_mgr_->SetHostChain(optarg);
2125
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 8 times.
 8 if (dogeosort) {
2126 ✗ std::vector<std::string> host_chain;
2127 ✗ external_download_mgr_->GetHostInfo(&host_chain, NULL, NULL);
2128 ✗ download_mgr_->GeoSortServers(&host_chain);
2129 ✗ external_download_mgr_->SetHostChain(host_chain);
2130 }
2131 } else {
2132
2/4
✓ Branch 2 taken 386 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 386 times.
✗ Branch 6 not taken.
 386 external_download_mgr_->SetHostChain("");
2133 }
2134
2135
4/6
✓ Branch 2 taken 394 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 394 times.
✗ Branch 6 not taken.
✓ Branch 9 taken 12 times.
✓ Branch 10 taken 382 times.
 394 if (options_mgr_->GetValue("CVMFS_EXTERNAL_MAX_SERVERS", &optarg)) {
2136
1/2
✓ Branch 1 taken 12 times.
✗ Branch 2 not taken.
 12 const unsigned max_servers = String2Uint64(optarg);
2137 12 std::vector<std::string> host_chain;
2138
1/2
✓ Branch 1 taken 12 times.
✗ Branch 2 not taken.
 12 external_download_mgr_->GetHostInfo(&host_chain, NULL, NULL);
2139
6/6
✓ Branch 0 taken 8 times.
✓ Branch 1 taken 4 times.
✓ Branch 3 taken 4 times.
✓ Branch 4 taken 4 times.
✓ Branch 5 taken 4 times.
✓ Branch 6 taken 8 times.
 12 if (max_servers > 0 && max_servers < host_chain.size()) {
2140
1/2
✓ Branch 1 taken 4 times.
✗ Branch 2 not taken.
 4 host_chain.resize(max_servers);
2141
1/2
✓ Branch 1 taken 4 times.
✗ Branch 2 not taken.
 4 external_download_mgr_->SetHostChain(host_chain);
2142 }
2143 12 }
2144
2145
1/2
✓ Branch 2 taken 394 times.
✗ Branch 3 not taken.
 394 string proxies = "DIRECT";
2146
3/6
✓ Branch 2 taken 394 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 394 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 394 times.
 394 if (options_mgr_->GetValue("CVMFS_EXTERNAL_HTTP_PROXY", &optarg)) {
2147 ✗ proxies = download::ResolveProxyDescription(
2148 optarg,
2149 ✗ file_system_->workspace() + "/proxies-external" + GetUniqFileSuffix(),
2150 ✗ external_download_mgr_);
2151 ✗ if (proxies == "") {
2152 ✗ boot_error_ = "failed to discover external HTTP proxy servers";
2153 ✗ boot_status_ = loader::kFailWpad;
2154 ✗ return false;
2155 }
2156 }
2157 394 string fallback_proxies;
2158
3/6
✓ Branch 2 taken 394 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 394 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 394 times.
 394 if (options_mgr_->GetValue("CVMFS_EXTERNAL_FALLBACK_PROXY", &optarg))
2159 ✗ fallback_proxies = optarg;
2160
1/2
✓ Branch 1 taken 394 times.
✗ Branch 2 not taken.
 394 external_download_mgr_->SetProxyChain(
2161 proxies, fallback_proxies, download::DownloadManager::kSetProxyBoth);
2162
2163 394 return true;
2164 394 }
2165
2166
2167 686 void MountPoint::SetupHttpTuning() {
2168 686 string optarg;
2169
2170 // TODO(jblomer): avoid double default settings
2171
2172 686 unsigned timeout = kDefaultTimeoutSec;
2173 686 unsigned timeout_direct = kDefaultTimeoutSec;
2174
3/6
✓ Branch 2 taken 686 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 686 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 686 times.
 686 if (options_mgr_->GetValue("CVMFS_TIMEOUT", &optarg))
2175 ✗ timeout = String2Uint64(optarg);
2176
3/6
✓ Branch 2 taken 686 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 686 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 686 times.
 686 if (options_mgr_->GetValue("CVMFS_TIMEOUT_DIRECT", &optarg))
2177 ✗ timeout_direct = String2Uint64(optarg);
2178
1/2
✓ Branch 1 taken 686 times.
✗ Branch 2 not taken.
 686 download_mgr_->SetTimeout(timeout, timeout_direct);
2179
2180 686 unsigned max_retries = kDefaultRetries;
2181 686 unsigned backoff_init = kDefaultBackoffInitMs;
2182 686 unsigned backoff_max = kDefaultBackoffMaxMs;
2183
4/6
✓ Branch 2 taken 686 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 686 times.
✗ Branch 6 not taken.
✓ Branch 9 taken 461 times.
✓ Branch 10 taken 225 times.
 686 if (options_mgr_->GetValue("CVMFS_MAX_RETRIES", &optarg))
2184
1/2
✓ Branch 1 taken 461 times.
✗ Branch 2 not taken.
 461 max_retries = String2Uint64(optarg);
2185
3/6
✓ Branch 2 taken 686 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 686 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 686 times.
 686 if (options_mgr_->GetValue("CVMFS_BACKOFF_INIT", &optarg))
2186 ✗ backoff_init = String2Uint64(optarg) * 1000;
2187
3/6
✓ Branch 2 taken 686 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 686 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 686 times.
 686 if (options_mgr_->GetValue("CVMFS_BACKOFF_MAX", &optarg))
2188 ✗ backoff_max = String2Uint64(optarg) * 1000;
2189
1/2
✓ Branch 1 taken 686 times.
✗ Branch 2 not taken.
 686 download_mgr_->SetRetryParameters(max_retries, backoff_init, backoff_max);
2190
2191
3/6
✓ Branch 2 taken 686 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 686 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 686 times.
 686 if (options_mgr_->GetValue("CVMFS_LOW_SPEED_LIMIT", &optarg))
2192 ✗ download_mgr_->SetLowSpeedLimit(String2Uint64(optarg));
2193
3/6
✓ Branch 2 taken 686 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 686 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 686 times.
 686 if (options_mgr_->GetValue("CVMFS_PROXY_RESET_AFTER", &optarg)) {
2194 ✗ download_mgr_->SetProxyGroupResetDelay(String2Uint64(optarg));
2195 // Use the proxy reset delay as the default for the metalink reset delay
2196 ✗ download_mgr_->SetMetalinkResetDelay(String2Uint64(optarg));
2197 }
2198
3/6
✓ Branch 2 taken 686 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 686 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 686 times.
 686 if (options_mgr_->GetValue("CVMFS_METALINK_RESET_AFTER", &optarg))
2199 ✗ download_mgr_->SetMetalinkResetDelay(String2Uint64(optarg));
2200
3/6
✓ Branch 2 taken 686 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 686 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 686 times.
 686 if (options_mgr_->GetValue("CVMFS_HOST_RESET_AFTER", &optarg))
2201 ✗ download_mgr_->SetHostResetDelay(String2Uint64(optarg));
2202
2203
3/10
✓ Branch 1 taken 686 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 686 times.
✗ Branch 5 not taken.
✗ Branch 7 not taken.
✓ Branch 8 taken 686 times.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
 1372 if (options_mgr_->GetValue("CVMFS_FOLLOW_REDIRECTS", &optarg)
2204
3/10
✓ Branch 2 taken 686 times.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✓ Branch 5 taken 686 times.
✗ Branch 7 not taken.
✗ Branch 8 not taken.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✓ Branch 11 taken 686 times.
✗ Branch 12 not taken.
 1372 && options_mgr_->IsOn(optarg)) {
2205 ✗ download_mgr_->EnableRedirects();
2206 }
2207
3/10
✓ Branch 1 taken 686 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 686 times.
✗ Branch 5 not taken.
✗ Branch 7 not taken.
✓ Branch 8 taken 686 times.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
 1372 if (options_mgr_->GetValue("CVMFS_SEND_INFO_HEADER", &optarg)
2208
3/10
✓ Branch 2 taken 686 times.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✓ Branch 5 taken 686 times.
✗ Branch 7 not taken.
✗ Branch 8 not taken.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✓ Branch 11 taken 686 times.
✗ Branch 12 not taken.
 1372 && options_mgr_->IsOn(optarg)) {
2209 ✗ download_mgr_->EnableInfoHeader();
2210 }
2211 686 }
2212
2213
2214 394 void MountPoint::SetupInodeAnnotation() {
2215 394 string optarg;
2216
2217
1/2
✗ Branch 1 not taken.
✓ Branch 2 taken 394 times.
 394 if (file_system_->IsNfsSource()) {
2218 ✗ inode_annotation_ = new catalog::InodeNfsGenerationAnnotation();
2219 } else {
2220
1/2
✓ Branch 1 taken 394 times.
✗ Branch 2 not taken.
 394 inode_annotation_ = new catalog::InodeGenerationAnnotation();
2221 }
2222
3/6
✓ Branch 2 taken 394 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 394 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 394 times.
 394 if (options_mgr_->GetValue("CVMFS_INITIAL_GENERATION", &optarg)) {
2223 ✗ inode_annotation_->IncGeneration(String2Uint64(optarg));
2224 }
2225
2226
2/2
✓ Branch 1 taken 95 times.
✓ Branch 2 taken 299 times.
 394 if (file_system_->type() == FileSystem::kFsFuse) {
2227 95 catalog_mgr_->SetInodeAnnotation(inode_annotation_);
2228 }
2229 394 }
2230
2231
2232 394 bool MountPoint::SetupOwnerMaps() {
2233 394 string optarg;
2234 394 catalog::OwnerMap uid_map;
2235 394 catalog::OwnerMap gid_map;
2236
2237
4/6
✓ Branch 2 taken 394 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 394 times.
✗ Branch 6 not taken.
✓ Branch 9 taken 4 times.
✓ Branch 10 taken 390 times.
 394 if (options_mgr_->GetValue("CVMFS_UID_MAP", &optarg)) {
2238
2/4
✓ Branch 1 taken 4 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 4 times.
✗ Branch 4 not taken.
 4 if (!uid_map.Read(optarg)) {
2239
1/2
✓ Branch 1 taken 4 times.
✗ Branch 2 not taken.
 4 boot_error_ = "failed to parse uid map " + optarg;
2240 4 boot_status_ = loader::kFailOptions;
2241 4 return false;
2242 }
2243 }
2244
3/6
✓ Branch 2 taken 390 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 390 times.
✗ Branch 6 not taken.
✗ Branch 9 not taken.
✓ Branch 10 taken 390 times.
 390 if (options_mgr_->GetValue("CVMFS_GID_MAP", &optarg)) {
2245 ✗ if (!gid_map.Read(optarg)) {
2246 ✗ boot_error_ = "failed to parse gid map " + optarg;
2247 ✗ boot_status_ = loader::kFailOptions;
2248 ✗ return false;
2249 }
2250 }
2251
1/2
✓ Branch 1 taken 390 times.
✗ Branch 2 not taken.
 390 catalog_mgr_->SetOwnerMaps(uid_map, gid_map);
2252
2253 // TODO(jblomer): make local to catalog manager
2254
3/10
✓ Branch 1 taken 390 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 390 times.
✗ Branch 5 not taken.
✗ Branch 7 not taken.
✓ Branch 8 taken 390 times.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
 780 if (options_mgr_->GetValue("CVMFS_CLAIM_OWNERSHIP", &optarg)
2255
3/10
✓ Branch 2 taken 390 times.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✓ Branch 5 taken 390 times.
✗ Branch 7 not taken.
✗ Branch 8 not taken.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✓ Branch 11 taken 390 times.
✗ Branch 12 not taken.
 780 && options_mgr_->IsOn(optarg)) {
2256 ✗ g_claim_ownership = true;
2257 }
2258
3/10
✓ Branch 1 taken 390 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 390 times.
✗ Branch 5 not taken.
✗ Branch 7 not taken.
✓ Branch 8 taken 390 times.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
 780 if (options_mgr_->GetValue("CVMFS_WORLD_READABLE", &optarg)
2259
3/10
✓ Branch 2 taken 390 times.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✓ Branch 5 taken 390 times.
✗ Branch 7 not taken.
✗ Branch 8 not taken.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✓ Branch 11 taken 390 times.
✗ Branch 12 not taken.
 780 && options_mgr_->IsOn(optarg)) {
2260 ✗ g_world_readable = true;
2261 }
2262
2263
2264 390 return true;
2265 394 }
2266