GCC Code Coverage Report

Directory: cvmfs/
File: cvmfs/clientctx.cc
Date: 2026-09-20 02:39:58
Exec Total Coverage
Lines: 65 78 83.3%
Branches: 22 40 55.0%
Line Branch Exec Source
1 /**
2 * This file is part of the CernVM File System.
3 */
4
5 #include "clientctx.h"
6
7 #include <cassert>
8
9 #include "interrupt.h"
10 #include "util/concurrency.h"
11 #include "util/smalloc.h"
12
13 using namespace std; // NOLINT
14
15 ClientCtx *ClientCtx::instance_ = NULL;
16
17
18 3387 void ClientCtx::CleanupInstance() {
19
2/2
✓ Branch 0 taken 2850 times.
✓ Branch 1 taken 537 times.
 3387 delete instance_;
20 3387 instance_ = NULL;
21 3387 }
22
23
24 2858 ClientCtx::ClientCtx() {
25 2858 lock_tls_blocks_ = reinterpret_cast<pthread_mutex_t *>(
26 2858 smalloc(sizeof(pthread_mutex_t)));
27 2858 const int retval = pthread_mutex_init(lock_tls_blocks_, NULL);
28
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 2858 times.
 2858 assert(retval == 0);
29 2858 }
30
31
32 2850 ClientCtx::~ClientCtx() {
33 2850 pthread_mutex_destroy(lock_tls_blocks_);
34 2850 free(lock_tls_blocks_);
35
36
2/2
✓ Branch 1 taken 314 times.
✓ Branch 2 taken 2850 times.
 3164 for (unsigned i = 0; i < tls_blocks_.size(); ++i) {
37
1/2
✓ Branch 1 taken 314 times.
✗ Branch 2 not taken.
 314 delete tls_blocks_[i];
38 }
39
40 2850 const int retval = pthread_key_delete(thread_local_storage_);
41
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 2850 times.
 2850 assert(retval == 0);
42 2850 }
43
44
45 7878 ClientCtx *ClientCtx::GetInstance() {
46
2/2
✓ Branch 0 taken 2858 times.
✓ Branch 1 taken 5020 times.
 7878 if (instance_ == NULL) {
47 2858 instance_ = new ClientCtx();
48 2858 const int retval = pthread_key_create(&instance_->thread_local_storage_,
49 TlsDestructor);
50
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 2858 times.
 2858 assert(retval == 0);
51 }
52
53 7878 return instance_;
54 }
55
56
57 411 void ClientCtx::Get(uid_t *uid, gid_t *gid, pid_t *pid, InterruptCue **ic) {
58 ThreadLocalStorage *tls = static_cast<ThreadLocalStorage *>(
59 411 pthread_getspecific(thread_local_storage_));
60
4/4
✓ Branch 0 taken 382 times.
✓ Branch 1 taken 29 times.
✓ Branch 2 taken 29 times.
✓ Branch 3 taken 353 times.
 411 if ((tls == NULL) || !tls->is_set) {
61 58 *uid = -1;
62 58 *gid = -1;
63 58 *pid = -1;
64 58 *ic = NULL;
65 } else {
66 353 *uid = tls->uid;
67 353 *gid = tls->gid;
68 353 *pid = tls->pid;
69 353 *ic = tls->interrupt_cue;
70 }
71 411 }
72
73
74 3395 bool ClientCtx::IsSet() {
75 ThreadLocalStorage *tls = static_cast<ThreadLocalStorage *>(
76 3395 pthread_getspecific(thread_local_storage_));
77
2/2
✓ Branch 0 taken 1900 times.
✓ Branch 1 taken 1495 times.
 3395 if (tls == NULL)
78 1900 return false;
79
80 1495 return tls->is_set;
81 }
82
83
84 1514 void ClientCtx::Set(uid_t uid, gid_t gid, pid_t pid, InterruptCue *ic) {
85 ThreadLocalStorage *tls = static_cast<ThreadLocalStorage *>(
86 1514 pthread_getspecific(thread_local_storage_));
87
88
2/2
✓ Branch 0 taken 314 times.
✓ Branch 1 taken 1200 times.
 1514 if (tls == NULL) {
89
1/2
✓ Branch 1 taken 314 times.
✗ Branch 2 not taken.
 314 tls = new ThreadLocalStorage(uid, gid, pid, ic);
90 314 const int retval = pthread_setspecific(thread_local_storage_, tls);
91
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 314 times.
 314 assert(retval == 0);
92 314 const MutexLockGuard lock_guard(lock_tls_blocks_);
93
1/2
✓ Branch 1 taken 314 times.
✗ Branch 2 not taken.
 314 tls_blocks_.push_back(tls);
94 314 } else {
95 1200 tls->uid = uid;
96 1200 tls->gid = gid;
97 1200 tls->pid = pid;
98 1200 tls->interrupt_cue = ic;
99 1200 tls->is_set = true;
100 }
101 1514 }
102
103
104 ✗ void ClientCtx::TlsDestructor(void *data) {
105 ✗ ThreadLocalStorage *tls = static_cast<ClientCtx::ThreadLocalStorage *>(data);
106 ✗ delete tls;
107
108 ✗ assert(instance_);
109 ✗ const MutexLockGuard lock_guard(instance_->lock_tls_blocks_);
110 ✗ for (vector<ThreadLocalStorage *>::iterator
111 ✗ i = instance_->tls_blocks_.begin(),
112 ✗ iEnd = instance_->tls_blocks_.end();
113 ✗ i != iEnd;
114 ✗ ++i) {
115 ✗ if ((*i) == tls) {
116 ✗ instance_->tls_blocks_.erase(i);
117 ✗ break;
118 }
119 }
120 }
121
122
123 1340 void ClientCtx::Unset() {
124 ThreadLocalStorage *tls = static_cast<ThreadLocalStorage *>(
125 1340 pthread_getspecific(thread_local_storage_));
126
1/2
✓ Branch 0 taken 1340 times.
✗ Branch 1 not taken.
 1340 if (tls != NULL) {
127 1340 tls->is_set = false;
128 1340 tls->uid = -1;
129 1340 tls->gid = -1;
130 1340 tls->pid = -1;
131 1340 tls->interrupt_cue = NULL;
132 }
133 1340 }
134