/tmp/bitcoin/src/semaphore_grant.h
Line | Count | Source |
1 | | // Copyright (c) 2009-2010 Satoshi Nakamoto |
2 | | // Copyright (c) 2009-present The Bitcoin Core developers |
3 | | // Distributed under the MIT software license, see the accompanying |
4 | | // file COPYING or http://www.opensource.org/licenses/mit-license.php. |
5 | | |
6 | | #ifndef BITCOIN_SEMAPHORE_GRANT_H |
7 | | #define BITCOIN_SEMAPHORE_GRANT_H |
8 | | |
9 | | #include <semaphore> |
10 | | |
11 | | /** RAII-style semaphore lock */ |
12 | | template <std::ptrdiff_t LeastMaxValue = std::counting_semaphore<>::max()> |
13 | | class CountingSemaphoreGrant |
14 | | { |
15 | | private: |
16 | | std::counting_semaphore<LeastMaxValue>* sem; |
17 | | bool fHaveGrant; |
18 | | |
19 | | public: |
20 | | void Acquire() noexcept |
21 | 5.37k | { |
22 | 5.37k | if (fHaveGrant) { |
23 | 0 | return; |
24 | 0 | } |
25 | 5.37k | sem->acquire(); |
26 | 5.37k | fHaveGrant = true; |
27 | 5.37k | } |
28 | | |
29 | | void Release() noexcept |
30 | 9.55k | { |
31 | 9.55k | if (!fHaveGrant) { |
32 | 4.00k | return; |
33 | 4.00k | } |
34 | 5.55k | sem->release(); |
35 | 5.55k | fHaveGrant = false; |
36 | 5.55k | } |
37 | | |
38 | | bool TryAcquire() noexcept |
39 | 179 | { |
40 | 179 | if (!fHaveGrant && sem->try_acquire()) { |
41 | 179 | fHaveGrant = true; |
42 | 179 | } |
43 | 179 | return fHaveGrant; |
44 | 179 | } |
45 | | |
46 | | // Disallow copy. |
47 | | CountingSemaphoreGrant(const CountingSemaphoreGrant&) = delete; |
48 | | CountingSemaphoreGrant& operator=(const CountingSemaphoreGrant&) = delete; |
49 | | |
50 | | // Allow move. |
51 | | CountingSemaphoreGrant(CountingSemaphoreGrant&& other) noexcept |
52 | 16 | { |
53 | 16 | sem = other.sem; |
54 | 16 | fHaveGrant = other.fHaveGrant; |
55 | 16 | other.fHaveGrant = false; |
56 | 16 | other.sem = nullptr; |
57 | 16 | } |
58 | | |
59 | | CountingSemaphoreGrant& operator=(CountingSemaphoreGrant&& other) noexcept |
60 | 673 | { |
61 | 673 | Release(); |
62 | 673 | sem = other.sem; |
63 | 673 | fHaveGrant = other.fHaveGrant; |
64 | 673 | other.fHaveGrant = false; |
65 | 673 | other.sem = nullptr; |
66 | 673 | return *this; |
67 | 673 | } |
68 | | |
69 | 2.29k | CountingSemaphoreGrant() noexcept : sem(nullptr), fHaveGrant(false) {} |
70 | | |
71 | 5.55k | explicit CountingSemaphoreGrant(std::counting_semaphore<LeastMaxValue>& sema, bool fTry = false) noexcept : sem(&sema), fHaveGrant(false) |
72 | 5.55k | { |
73 | 5.55k | if (fTry) { |
74 | 179 | TryAcquire(); |
75 | 5.37k | } else { |
76 | 5.37k | Acquire(); |
77 | 5.37k | } |
78 | 5.55k | } |
79 | | |
80 | | ~CountingSemaphoreGrant() |
81 | 7.87k | { |
82 | 7.87k | Release(); |
83 | 7.87k | } |
84 | | |
85 | | explicit operator bool() const noexcept |
86 | 181 | { |
87 | 181 | return fHaveGrant; |
88 | 181 | } |
89 | | }; |
90 | | |
91 | | using BinarySemaphoreGrant = CountingSemaphoreGrant<1>; |
92 | | |
93 | | #endif // BITCOIN_SEMAPHORE_GRANT_H |