Directory: | cvmfs/ |
---|---|
File: | cvmfs/util/atomic.h |
Date: | 2025-07-13 02:35:07 |
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 | 15464364 | static void inline __attribute__((used)) atomic_init32(atomic_int32 *a) { | |
21 | 15464364 | *a = 0; | |
22 | 15464364 | } | |
23 | |||
24 | 1465339 | static void inline __attribute__((used)) atomic_init64(atomic_int64 *a) { | |
25 | 1465339 | *a = 0; | |
26 | 1465339 | } | |
27 | |||
28 | 1965569603 | static int32_t inline __attribute__((used)) atomic_read32(atomic_int32 *a) { | |
29 | 1965569603 | return __sync_fetch_and_add(a, 0); | |
30 | } | ||
31 | |||
32 | 1772072401 | static int64_t inline __attribute__((used)) atomic_read64(atomic_int64 *a) { | |
33 | 1772072401 | return __sync_fetch_and_add(a, 0); | |
34 | } | ||
35 | |||
36 | 609763242 | static void inline __attribute__((used)) atomic_write32(atomic_int32 *a, | |
37 | int32_t value) { | ||
38 |
2/2✓ Branch 1 taken 1343897963 times.
✓ Branch 2 taken 744932452 times.
|
1953661205 | while (!__sync_bool_compare_and_swap(a, atomic_read32(a), value)) { |
39 | } | ||
40 | 744932452 | } | |
41 | |||
42 | 622738067 | static void inline __attribute__((used)) atomic_write64(atomic_int64 *a, | |
43 | int64_t value) { | ||
44 |
2/2✓ Branch 1 taken 1177312437 times.
✓ Branch 2 taken 766054186 times.
|
1800050504 | while (!__sync_bool_compare_and_swap(a, atomic_read64(a), value)) { |
45 | } | ||
46 | 766054186 | } | |
47 | |||
48 | 316083600 | static void inline __attribute__((used)) atomic_inc32(atomic_int32 *a) { | |
49 | 316083600 | (void)__sync_fetch_and_add(a, 1); | |
50 | 316083600 | } | |
51 | |||
52 | 370323213 | static void inline __attribute__((used)) atomic_inc64(atomic_int64 *a) { | |
53 | 370323213 | (void)__sync_fetch_and_add(a, 1); | |
54 | 370323213 | } | |
55 | |||
56 | 214034520 | static void inline __attribute__((used)) atomic_dec32(atomic_int32 *a) { | |
57 | 214034520 | (void)__sync_fetch_and_sub(a, 1); | |
58 | 214034520 | } | |
59 | |||
60 | 185813443 | static void inline __attribute__((used)) atomic_dec64(atomic_int64 *a) { | |
61 | 185813443 | (void)__sync_fetch_and_sub(a, 1); | |
62 | 185813443 | } | |
63 | |||
64 | 11661616 | static int32_t inline __attribute__((used)) atomic_xadd32(atomic_int32 *a, | |
65 | int32_t offset) { | ||
66 |
2/2✓ Branch 0 taken 7118540 times.
✓ Branch 1 taken 4543076 times.
|
11661616 | if (offset < 0) |
67 | 7118540 | return __sync_fetch_and_sub(a, -offset); | |
68 | 4543076 | return __sync_fetch_and_add(a, offset); | |
69 | } | ||
70 | |||
71 | 17289725 | static int64_t inline __attribute__((used)) atomic_xadd64(atomic_int64 *a, | |
72 | int64_t offset) { | ||
73 |
2/2✓ Branch 0 taken 4138640 times.
✓ Branch 1 taken 13151085 times.
|
17289725 | if (offset < 0) |
74 | 4138640 | return __sync_fetch_and_sub(a, -offset); | |
75 | 13151085 | return __sync_fetch_and_add(a, offset); | |
76 | } | ||
77 | |||
78 | 741005 | static bool inline __attribute__((used)) atomic_cas32(atomic_int32 *a, | |
79 | int32_t cmp, | ||
80 | int32_t newval) { | ||
81 | 741005 | 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 | 150 | static void inline __attribute__((used)) MemoryFence() { | |
93 | 150 | asm __volatile__("" : : : "memory"); | |
94 | 150 | } | |
95 | |||
96 | #ifdef CVMFS_NAMESPACE_GUARD | ||
97 | } // namespace CVMFS_NAMESPACE_GUARD | ||
98 | #endif | ||
99 | |||
100 | #endif // CVMFS_UTIL_ATOMIC_H_ | ||
101 |