GCC Code Coverage Report


Directory: cvmfs/
File: cvmfs/util/concurrency.cc
Date: 2025-08-31 02:39:21
Exec Total Coverage
Lines: 34 36 94.4%
Branches: 11 20 55.0%

Line Branch Exec Source
1 /**
2 * This file is part of the CernVM File System.
3 */
4
5
6 #include "util/concurrency.h"
7
8 #include <pthread.h>
9 #include <unistd.h>
10
11 #include <cassert>
12 #include <cstddef>
13
14 #include "util/logging.h"
15 #include "util/mutex.h"
16
17 #ifdef CVMFS_NAMESPACE_GUARD
18 namespace CVMFS_NAMESPACE_GUARD {
19 #endif
20
21 965 unsigned int GetNumberOfCpuCores() {
22 965 const int numCPU = sysconf(_SC_NPROCESSORS_ONLN);
23
24
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 965 times.
965 if (numCPU <= 0) {
25 LogCvmfs(kLogSpooler, kLogWarning,
26 "Unable to determine the available "
27 "number of processors in the system... "
28 "falling back to default '%d'",
29 kFallbackNumberOfCpus);
30 return kFallbackNumberOfCpus;
31 }
32
33 965 return static_cast<unsigned int>(numCPU);
34 }
35
36 51241 Signal::Signal() : fired_(false) {
37 51241 int retval = pthread_mutex_init(&lock_, NULL);
38
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 51241 times.
51241 assert(retval == 0);
39 51241 retval = pthread_cond_init(&signal_, NULL);
40
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 51241 times.
51241 assert(retval == 0);
41 51241 }
42
43
44 51237 Signal::~Signal() {
45
1/2
✗ Branch 1 not taken.
✓ Branch 2 taken 51233 times.
51237 assert(IsSleeping());
46 51233 int res = pthread_cond_destroy(&signal_);
47
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 51237 times.
51237 assert(0 == res);
48 51237 res = pthread_mutex_destroy(&lock_);
49
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 51225 times.
51225 assert(0 == res);
50 51225 }
51
52
53 51843 void Signal::Wait() {
54 51843 const MutexLockGuard guard(lock_);
55
2/2
✓ Branch 0 taken 51112 times.
✓ Branch 1 taken 51843 times.
102955 while (!fired_) {
56
1/2
✓ Branch 1 taken 51112 times.
✗ Branch 2 not taken.
51112 const int retval = pthread_cond_wait(&signal_, &lock_);
57
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 51112 times.
51112 assert(retval == 0);
58 }
59 51843 fired_ = false;
60 51843 }
61
62
63 51843 void Signal::Wakeup() {
64 51843 const MutexLockGuard guard(lock_);
65 51843 fired_ = true;
66 51843 const int retval = pthread_cond_broadcast(&signal_);
67
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 51843 times.
51843 assert(retval == 0);
68 51843 }
69
70 51616 bool Signal::IsSleeping() {
71 51616 const MutexLockGuard guard(lock_);
72 103244 return fired_ == false;
73 51624 }
74
75 #ifdef CVMFS_NAMESPACE_GUARD
76 } // namespace CVMFS_NAMESPACE_GUARD
77 #endif
78