GCC Code Coverage Report

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