GCC Code Coverage Report

Directory: cvmfs/
File: cvmfs/fd_refcount_mgr.cc
Date: 2026-03-15 02:35:27
Exec Total Coverage
Lines: 80 80 100.0%
Branches: 45 76 59.2%
Line Branch Exec Source
1 /**
2 * This file is part of the CernVM File System.
3 */
4
5 #include "fd_refcount_mgr.h"
6
7 #include <fcntl.h>
8 #include <unistd.h>
9
10 #include <cassert>
11 #include <string>
12
13 #include "util/mutex.h"
14 #include "util/smalloc.h"
15
16
17 5893 int FdRefcountMgr::Open(const shash::Any id, const std::string &path) {
18 5893 int result = -1;
19 5893 const MutexLockGuard lock_guard(lock_cache_refcount_);
20
3/4
✓ Branch 1 taken 5893 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 5670 times.
✓ Branch 4 taken 223 times.
 5893 if (!map_fd_.Lookup(id, &result)) {
21
1/2
✓ Branch 2 taken 5670 times.
✗ Branch 3 not taken.
 5670 result = open(path.c_str(), O_RDONLY);
22
2/2
✓ Branch 0 taken 2486 times.
✓ Branch 1 taken 3184 times.
 5670 if (result >= 0) {
23
1/2
✓ Branch 1 taken 2486 times.
✗ Branch 2 not taken.
 2486 map_fd_.Insert(id, result);
24 }
25 }
26
2/2
✓ Branch 0 taken 2709 times.
✓ Branch 1 taken 3184 times.
 5893 if (result >= 0) {
27
1/2
✓ Branch 1 taken 2709 times.
✗ Branch 2 not taken.
 2709 FdRefcountInfo refc_info;
28
3/4
✓ Branch 1 taken 2709 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 223 times.
✓ Branch 4 taken 2486 times.
 2709 if (map_refcount_.Lookup(result, &refc_info)) {
29 223 refc_info.refcount++;
30 } else {
31 2486 refc_info.refcount = 1;
32 2486 refc_info.id = id;
33 }
34
1/2
✓ Branch 1 taken 2709 times.
✗ Branch 2 not taken.
 2709 map_refcount_.Insert(result, refc_info);
35 }
36 5893 return result;
37 5893 }
38
39 2556 int FdRefcountMgr::Close(int fd) {
40 2556 int retval = -1;
41 2556 const MutexLockGuard lock_guard(lock_cache_refcount_);
42
1/2
✓ Branch 1 taken 2556 times.
✗ Branch 2 not taken.
 2556 FdRefcountInfo refc_info;
43
3/4
✓ Branch 1 taken 2556 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 2515 times.
✓ Branch 4 taken 41 times.
 2556 if (map_refcount_.Lookup(fd, &refc_info)) {
44
2/2
✓ Branch 0 taken 169 times.
✓ Branch 1 taken 2346 times.
 2515 if (refc_info.refcount > 1) {
45 169 refc_info.refcount -= 1;
46
1/2
✓ Branch 1 taken 169 times.
✗ Branch 2 not taken.
 169 map_refcount_.Insert(fd, refc_info);
47 169 retval = 0;
48 } else {
49
1/2
✓ Branch 1 taken 2346 times.
✗ Branch 2 not taken.
 2346 retval = close(fd);
50
1/2
✓ Branch 1 taken 2346 times.
✗ Branch 2 not taken.
 2346 map_fd_.Erase(refc_info.id);
51
1/2
✓ Branch 1 taken 2346 times.
✗ Branch 2 not taken.
 2346 map_refcount_.Erase(fd);
52 }
53 } else {
54 // fd not present in our table - this should only happen
55 // when reloading from the normal posix cache manager!
56
1/2
✓ Branch 1 taken 41 times.
✗ Branch 2 not taken.
 41 LogCvmfs(kLogCache, kLogDebug,
57 "WARNING: trying to close fd that "
58 " is not in refcount tables");
59
1/2
✓ Branch 1 taken 41 times.
✗ Branch 2 not taken.
 41 retval = close(fd);
60 }
61 2556 return retval;
62 2556 }
63
64 102 int FdRefcountMgr::Dup(int fd) {
65 102 int retval = -1;
66 102 const MutexLockGuard lock_guard(lock_cache_refcount_);
67
1/2
✓ Branch 1 taken 102 times.
✗ Branch 2 not taken.
 102 FdRefcountInfo refc_info;
68
3/4
✓ Branch 1 taken 102 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 51 times.
✓ Branch 4 taken 51 times.
 102 if (map_refcount_.Lookup(fd, &refc_info)) {
69 51 refc_info.refcount += 1;
70
1/2
✓ Branch 1 taken 51 times.
✗ Branch 2 not taken.
 51 map_refcount_.Insert(fd, refc_info);
71 51 retval = fd;
72 } else {
73 // fd not present in our table - this should
74 // not happen in the current usage of Dup
75
1/2
✓ Branch 1 taken 51 times.
✗ Branch 2 not taken.
 51 LogCvmfs(kLogCache, kLogDebug,
76 "WARNING: trying to dup fd that "
77 " is not in refcount tables");
78 51 retval = dup(fd);
79 }
80 102 return retval;
81 102 }
82
83 41 FdRefcountMgr *FdRefcountMgr::Clone() {
84
1/2
✓ Branch 2 taken 41 times.
✗ Branch 3 not taken.
 41 FdRefcountMgr *clone = new FdRefcountMgr(map_refcount_, map_fd_);
85 41 return clone;
86 }
87
88 41 SmallHashDynamic<shash::Any, int> *FdRefcountMgr::GetFdMapPtr() {
89 41 return &map_fd_;
90 }
91
92 SmallHashDynamic<int, FdRefcountMgr::FdRefcountInfo> *
93 41 FdRefcountMgr::GetRefcountMapPtr() {
94 41 return &map_refcount_;
95 }
96
97 41 void FdRefcountMgr::AssignFrom(FdRefcountMgr *other) {
98 41 map_fd_ = *other->GetFdMapPtr();
99 41 map_refcount_ = *other->GetRefcountMapPtr();
100 41 }
101
102 6809 FdRefcountMgr::~FdRefcountMgr() {
103 6809 pthread_mutex_destroy(lock_cache_refcount_);
104 6809 free(lock_cache_refcount_);
105 6809 }
106
107
1/2
✓ Branch 2 taken 6777 times.
✗ Branch 3 not taken.
 6777 FdRefcountMgr::FdRefcountMgr() {
108
1/2
✓ Branch 1 taken 6777 times.
✗ Branch 2 not taken.
 6777 const shash::Any hash_null;
109
1/2
✓ Branch 1 taken 6777 times.
✗ Branch 2 not taken.
 6777 map_fd_.Init(16, hash_null, hasher_any);
110
1/2
✓ Branch 1 taken 6777 times.
✗ Branch 2 not taken.
 6777 map_refcount_.Init(16, -1, hasher_int);
111 6777 lock_cache_refcount_ = reinterpret_cast<pthread_mutex_t *>(
112 6777 smalloc(sizeof(pthread_mutex_t)));
113 6777 const int retval = pthread_mutex_init(lock_cache_refcount_, NULL);
114
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 6777 times.
 6777 assert(retval == 0);
115 6777 }
116
117 41 FdRefcountMgr::FdRefcountMgr(
118 const SmallHashDynamic<int, FdRefcountMgr::FdRefcountInfo> &map_refcount,
119
1/2
✓ Branch 2 taken 41 times.
✗ Branch 3 not taken.
 41 const SmallHashDynamic<shash::Any, int> &map_fd) {
120
1/2
✓ Branch 1 taken 41 times.
✗ Branch 2 not taken.
 41 const shash::Any hash_null;
121
1/2
✓ Branch 1 taken 41 times.
✗ Branch 2 not taken.
 41 map_fd_.Init(16, hash_null, hasher_any);
122
1/2
✓ Branch 1 taken 41 times.
✗ Branch 2 not taken.
 41 map_refcount_.Init(16, -1, hasher_int);
123
1/2
✓ Branch 1 taken 41 times.
✗ Branch 2 not taken.
 41 map_refcount_ = map_refcount;
124
1/2
✓ Branch 1 taken 41 times.
✗ Branch 2 not taken.
 41 map_fd_ = map_fd;
125 41 lock_cache_refcount_ = reinterpret_cast<pthread_mutex_t *>(
126 41 smalloc(sizeof(pthread_mutex_t)));
127 41 const int retval = pthread_mutex_init(lock_cache_refcount_, NULL);
128
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 41 times.
 41 assert(retval == 0);
129 41 }
130