Directory: | cvmfs/ |
---|---|
File: | cvmfs/util/atomic.h |
Date: | 2025-06-22 02:36:02 |
Exec | Total | Coverage | |
---|---|---|---|
Lines: | 41 | 43 | 95.3% |
Branches: | 8 | 8 | 100.0% |
Line | Branch | Exec | Source |
---|---|---|---|
1 | /** | ||
2 | * This file is part of the CernVM File System. | ||
3 | * | ||
4 | * Defines wrapper functions for atomic integer operations. Atomic operations | ||
5 | * are handled by GCC. | ||
6 | */ | ||
7 | |||
8 | #ifndef CVMFS_UTIL_ATOMIC_H_ | ||
9 | #define CVMFS_UTIL_ATOMIC_H_ | ||
10 | |||
11 | #include <stdint.h> | ||
12 | |||
13 | #ifdef CVMFS_NAMESPACE_GUARD | ||
14 | namespace CVMFS_NAMESPACE_GUARD { | ||
15 | #endif | ||
16 | |||
17 | typedef int32_t atomic_int32; | ||
18 | typedef int64_t atomic_int64; | ||
19 | |||
20 | 18834388 | static void inline __attribute__((used)) atomic_init32(atomic_int32 *a) { | |
21 | 18834388 | *a = 0; | |
22 | 18834388 | } | |
23 | |||
24 | 776172 | static void inline __attribute__((used)) atomic_init64(atomic_int64 *a) { | |
25 | 776172 | *a = 0; | |
26 | 776172 | } | |
27 | |||
28 | 2467998201 | static int32_t inline __attribute__((used)) atomic_read32(atomic_int32 *a) { | |
29 | 2467998201 | return __sync_fetch_and_add(a, 0); | |
30 | } | ||
31 | |||
32 | 1999701392 | static int64_t inline __attribute__((used)) atomic_read64(atomic_int64 *a) { | |
33 | 1999701392 | return __sync_fetch_and_add(a, 0); | |
34 | } | ||
35 | |||
36 | 684591834 | static void inline __attribute__((used)) atomic_write32(atomic_int32 *a, | |
37 | int32_t value) { | ||
38 |
2/2✓ Branch 1 taken 1540006888 times.
✓ Branch 2 taken 846771054 times.
|
2224598722 | while (!__sync_bool_compare_and_swap(a, atomic_read32(a), value)) { |
39 | } | ||
40 | 846771054 | } | |
41 | |||
42 | 724722997 | static void inline __attribute__((used)) atomic_write64(atomic_int64 *a, | |
43 | int64_t value) { | ||
44 |
2/2✓ Branch 1 taken 1281925162 times.
✓ Branch 2 taken 877996418 times.
|
2006648159 | while (!__sync_bool_compare_and_swap(a, atomic_read64(a), value)) { |
45 | } | ||
46 | 877996418 | } | |
47 | |||
48 | 322410330 | static void inline __attribute__((used)) atomic_inc32(atomic_int32 *a) { | |
49 | 322410330 | (void)__sync_fetch_and_add(a, 1); | |
50 | 322410330 | } | |
51 | |||
52 | 520576374 | static void inline __attribute__((used)) atomic_inc64(atomic_int64 *a) { | |
53 | 520576374 | (void)__sync_fetch_and_add(a, 1); | |
54 | 520576374 | } | |
55 | |||
56 | 245873569 | static void inline __attribute__((used)) atomic_dec32(atomic_int32 *a) { | |
57 | 245873569 | (void)__sync_fetch_and_sub(a, 1); | |
58 | 245873569 | } | |
59 | |||
60 | 204565902 | static void inline __attribute__((used)) atomic_dec64(atomic_int64 *a) { | |
61 | 204565902 | (void)__sync_fetch_and_sub(a, 1); | |
62 | 204565902 | } | |
63 | |||
64 | 16102210 | static int32_t inline __attribute__((used)) atomic_xadd32(atomic_int32 *a, | |
65 | int32_t offset) { | ||
66 |
2/2✓ Branch 0 taken 9428127 times.
✓ Branch 1 taken 6674083 times.
|
16102210 | if (offset < 0) |
67 | 9428127 | return __sync_fetch_and_sub(a, -offset); | |
68 | 6674083 | return __sync_fetch_and_add(a, offset); | |
69 | } | ||
70 | |||
71 | 5449938 | static int64_t inline __attribute__((used)) atomic_xadd64(atomic_int64 *a, | |
72 | int64_t offset) { | ||
73 |
2/2✓ Branch 0 taken 1597243 times.
✓ Branch 1 taken 3852695 times.
|
5449938 | if (offset < 0) |
74 | 1597243 | return __sync_fetch_and_sub(a, -offset); | |
75 | 3852695 | return __sync_fetch_and_add(a, offset); | |
76 | } | ||
77 | |||
78 | 1319247 | static bool inline __attribute__((used)) atomic_cas32(atomic_int32 *a, | |
79 | int32_t cmp, | ||
80 | int32_t newval) { | ||
81 | 1319247 | return __sync_bool_compare_and_swap(a, cmp, newval); | |
82 | } | ||
83 | |||
84 | ✗ | static bool inline __attribute__((used)) atomic_cas64(atomic_int64 *a, | |
85 | int64_t cmp, | ||
86 | int64_t newval) { | ||
87 | // Clang 3.5 has a bug in optimized __sync_bool_compare_and_swap: | ||
88 | // https://bugs.llvm.org//show_bug.cgi?format=multiple&id=21499 | ||
89 | ✗ | return __sync_bool_compare_and_swap(a, cmp, newval); | |
90 | } | ||
91 | |||
92 | 294 | static void inline __attribute__((used)) MemoryFence() { | |
93 | 294 | asm __volatile__("" : : : "memory"); | |
94 | 294 | } | |
95 | |||
96 | #ifdef CVMFS_NAMESPACE_GUARD | ||
97 | } // namespace CVMFS_NAMESPACE_GUARD | ||
98 | #endif | ||
99 | |||
100 | #endif // CVMFS_UTIL_ATOMIC_H_ | ||
101 |