1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
|
/* Copyright (c) 2022, 2025, Oracle and/or its affiliates.
This program is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License, version 2.0,
as published by the Free Software Foundation.
This program is designed to work with certain software (including
but not limited to OpenSSL) that is licensed under separate terms,
as designated in a particular file or component or in included license
documentation. The authors of MySQL hereby grant you an additional
permission to link the program and your derivative works with the
separately licensed software that they have either included with
the program or referenced in the documentation.
This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU General Public License, version 2.0, for more details.
You should have received a copy of the GNU General Public License
along with this program; if not, write to the Free Software
Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA */
#ifndef BINLOG_ATOMIC_BCG_TICKET_H
#define BINLOG_ATOMIC_BCG_TICKET_H
#include <functional>
#include <limits>
#include <memory>
#include "sql/binlog/group_commit/atomic_bgc_ticket_guard.h"
#include "sql/binlog/group_commit/bgc_ticket.h"
#include "sql/memory/aligned_atomic.h"
namespace binlog {
class AtomicBgcTicketGuard;
class BgcTicket;
/// @brief Implements atomic ops on BgcTicket object
/// @details Impl based on Aligned_atomic
/// @see Bgc_ticket_manager
class AtomicBgcTicket {
public:
virtual ~AtomicBgcTicket() = default;
// Remove copy-move semantics
AtomicBgcTicket(AtomicBgcTicket const &) = delete;
AtomicBgcTicket(AtomicBgcTicket &&) = delete;
AtomicBgcTicket &operator=(AtomicBgcTicket const &) = delete;
AtomicBgcTicket &operator=(AtomicBgcTicket &&) = delete;
/// @brief Copying ctor
/// @param[in] src Pattern to copy from
/// @details AtomicBgcTicket is created based on src BgcTicket object
AtomicBgcTicket(const BgcTicket &src);
/// @brief Copying ctor
/// @param[in] src Pattern to copy from
/// @details AtomicBgcTicket is created based on src ValueType object
explicit AtomicBgcTicket(const BgcTicket::ValueType &src);
friend class AtomicBgcTicketGuard;
friend class BgcTicket;
/// @brief Creates the "lock" that is held for the returned
/// AtomicBgcTicketGuard object lifetime
/// @param[in] inc_next_before_release Before "release" operation, ticket
/// value is set to the value+1 in case inc_next_before_acquire is equal false
/// and inc_next_before_release is equal to true
AtomicBgcTicketGuard scoped_lock(bool inc_next_before_release = false);
/// @brief Creates the "lock" that is held for the returned
/// AtomicBgcTicketGuard object lifetime
AtomicBgcTicketGuard scoped_lock(const BgcTicket &next_value);
/// @brief Stream operator impl for AtomicBgcTicket class
/// @param[in] os Reference to stream obj
/// @param[in] arg Constant reference to AtomicBgcTicket object
/// @returns Reference to changed stream obj
friend std::ostream &operator<<(std::ostream &os, const AtomicBgcTicket &arg);
/// @brief Ticket mutator, atomic store op
/// @param[in] value Sets atomically m_ticket internal variable to "value"
void store(const BgcTicket &value);
/// @brief Ticket accessor, atomic load op
/// @returns BGC Ticket obtained during the atomic load op
BgcTicket load() const;
protected:
/// @brief Sets ticket synchronization value to "in use". Only one thread is
/// allowed to get into the critical section that starts with the "set_in_use"
/// op and ends with the "set_used"
/// @param[in] inc_next_before_acquire During the "acquire" operation, ticket
/// value is set to the value+1 in case inc_next_before_acquire is equal to
/// true.
/// @param[in] inc_next_before_release Before "release" operation, ticket
/// value is set to the value+1 in case inc_next_before_acquire is equal
/// false.
/// @returns previous ticket value (obtained before acquire op) and next
/// ticket value (set before release op)
std::pair<BgcTicket, BgcTicket> set_in_use(
bool inc_next_before_acquire = false,
bool inc_next_before_release = false);
/// @brief Sets ticket synchronization value to "used/free". Only one thread
/// is allowed to get into the critical section that starts with the
/// "set_in_use" op and ends with the "set_used"
/// @param[in] next_value Next ticket value set during the "release" op.
void set_used(const BgcTicket &next_value);
memory::Aligned_atomic<BgcTicket::ValueType>
m_ticket; ///< internal ticket representation
};
} // namespace binlog
#endif // BINLOG_ATOMIC_BCG_TICKET_H
|
