33#ifndef MYSQL_BINLOG_EVENT_CONTROL_EVENTS_H
34#define MYSQL_BINLOG_EVENT_CONTROL_EVENTS_H
138 unsigned int flags_arg, uint64_t pos_arg)
141 ident_len(ident_len_arg ? ident_len_arg : strlen(new_log_ident_arg)),
166 void print_event_info(std::ostream &)
override;
167 void print_long_info(std::ostream &)
override;
347 void print_event_info(std::ostream &
info)
override;
348 void print_long_info(std::ostream &
info)
override;
397 void print_event_info(std::ostream &)
override {}
398 void print_long_info(std::ostream &
info)
override;
485 void print_event_info(std::ostream &
info)
override;
486 void print_long_info(std::ostream &
info)
override;
541 void print_event_info(std::ostream &
info)
override;
542 void print_long_info(std::ostream &
info)
override;
633 void print_event_info(std::ostream &)
override {}
634 void print_long_info(std::ostream &)
override {}
690 void print_event_info(std::ostream &)
override {}
691 void print_long_info(std::ostream &)
override {}
830 uint16_t compression_type,
831 uint64_t uncompressed_size);
920 void print_event_info(std::ostream &)
override;
921 void print_long_info(std::ostream &)
override;
1063 long long int sequence_number_arg,
1064 bool may_have_sbr_stmts_arg,
1065 unsigned long long int original_commit_timestamp_arg,
1066 unsigned long long int immediate_commit_timestamp_arg,
1067 uint32_t original_server_version_arg,
1068 uint32_t immediate_server_version_arg)
1078 if (may_have_sbr_stmts_arg) {
1085 void print_event_info(std::ostream &)
override {}
1086 void print_long_info(std::ostream &)
override {}
1111 return std::make_tuple(
1113 mysql::serialization::define_field_with_size<Uuid::BYTE_LENGTH>(
1124 this->original_commit_timestamp =
1149 return std::make_tuple(
1151 mysql::serialization::define_field_with_size<Uuid::BYTE_LENGTH>(
1162 return this->original_commit_timestamp ==
1281 constexpr std::size_t max_tagged_length =
1282 Encoder_type::get_max_size<Gtid_event>();
1284 return max_tagged_length;
1341 std::uint64_t value);
1403 void print_event_info(std::ostream &)
override {}
1404 void print_long_info(std::ostream &)
override {}
1490 std::list<const char *> *
set,
1491 uint32_t remaining_buffer);
1496 void print_event_info(std::ostream &)
override {}
1497 void print_long_info(std::ostream &)
override {}
1587 void print_event_info(std::ostream &)
override {}
1588 void print_long_info(std::ostream &)
override {}
1700 void print_event_info(std::ostream &
info)
override;
1701 void print_long_info(std::ostream &
info)
override;
Kerberos Client Authentication nullptr
Definition: auth_kerberos_client_plugin.cc:250
Contains the classes representing events occurring in the replication stream.
#define LOG_EVENT_HEADER_LEN
Definition: binlog_event.h:441
#define LOG_EVENT_MINIMAL_HEADER_LEN
Fixed header length, where 4.x and 5.0 agree.
Definition: binlog_event.h:455
#define ST_SERVER_VER_LEN
The length of the array server_version, which is used to store the version of MySQL server.
Definition: binlog_event.h:423
Container class that provides a sequence of buffers to the caller.
This is the abstract base class for binary log events.
Definition: binlog_event.h:857
@ TRANSACTION_PAYLOAD_HEADER_LEN
Definition: binlog_event.h:899
GTID stands for Global Transaction IDentifier It is composed of two parts:
Definition: control_events.h:1015
static const int ORIGINAL_COMMIT_TIMESTAMP_LENGTH
Definition: control_events.h:1205
int get_server_version_length() const
We only store the immediate_server_version if both server versions are the same.
Definition: control_events.h:1235
mysql::gtid::Tsid tsid_parent_struct
Definition: control_events.h:1242
uint64_t transaction_length
The length of the transaction in bytes.
Definition: control_events.h:1039
mysql::gtid::Tag_plain Tag_plain
Definition: control_events.h:1103
static const int ENCODED_COMMIT_TIMESTAMP_LENGTH
Definition: control_events.h:1210
Tag_plain generate_tag_specification() const
Definition: control_events.h:1267
static const int ENCODED_SID_LENGTH
Definition: control_events.h:1195
int get_commit_timestamp_length() const
Definition: control_events.h:1225
int64_t sequence_number
Definition: control_events.h:1024
mysql::serialization::Field_encode_predicate Field_encode_predicate
Definition: control_events.h:1101
static const int64_t MIN_GNO
Definition: control_events.h:1245
static constexpr std::size_t get_max_payload_size()
Get maximum size of event payload.
Definition: control_events.h:1280
uint32_t original_server_version
The version of the server where the transaction was originally executed.
Definition: control_events.h:1317
bool may_have_sbr_stmts
Transaction might have changes logged with SBR.
Definition: control_events.h:1028
Gtid_event(long long int last_committed_arg, long long int sequence_number_arg, bool may_have_sbr_stmts_arg, unsigned long long int original_commit_timestamp_arg, unsigned long long int immediate_commit_timestamp_arg, uint32_t original_server_version_arg, uint32_t immediate_server_version_arg)
Constructor.
Definition: control_events.h:1062
uint32_t immediate_server_version
The version of the immediate server.
Definition: control_events.h:1319
int64_t last_committed
Definition: control_events.h:1023
unsigned const char FLAG_MAY_HAVE_SBR
GTID flags constants.
Definition: control_events.h:1026
static constexpr int COMMIT_GROUP_TICKET_LENGTH
Definition: control_events.h:1093
static const int IMMEDIATE_COMMIT_TIMESTAMP_LENGTH
Definition: control_events.h:1204
static const std::int64_t GNO_END
One-past-the-max value of GNO.
Definition: control_events.h:1247
static constexpr std::uint64_t kGroupTicketUnset
Definition: control_events.h:1098
mysql::gtid::Tsid get_tsid() const
Definition: control_events.h:1251
void update_untagged_transaction_length()
Updates transaction length which was not yet considered.
Definition: control_events.cpp:655
gtid_info gtid_info_struct
Definition: control_events.h:1241
int get_commit_group_ticket_length() const
Returns the length of the packed commit_group_ticket field.
Definition: control_events.cpp:618
unsigned char gtid_flags
GTID flags, used bits:
Definition: control_events.h:1031
static const int LOGICAL_TIMESTAMP_TYPECODE_LENGTH
Length of typecode for logical timestamps.
Definition: control_events.h:1198
void set_commit_group_ticket_and_update_transaction_length(std::uint64_t value)
Set the commit_group_ticket and update the transaction length if needed, that is, if the commit_group...
Definition: control_events.cpp:626
void update_tagged_transaction_length(std::size_t trx_len_without_event_len)
Updated transaction length based on transaction length without event length.
Definition: control_events.cpp:670
uint64_t immediate_commit_timestamp
Timestamp when the transaction was committed on the nearest source.
Definition: control_events.h:1035
static const int TRANSACTION_LENGTH_MAX_LENGTH
Definition: control_events.h:1213
static const int FULL_COMMIT_TIMESTAMP_LENGTH
Definition: control_events.h:1207
static const int ENCODED_GNO_LENGTH
Definition: control_events.h:1196
bool is_tagged() const
Checks whether this Gtid log event contains a tag.
Definition: control_events.cpp:648
static constexpr std::size_t get_max_event_length()
Get maximum size of event.
Definition: control_events.h:1273
static const int ENCODED_FLAG_LENGTH
Definition: control_events.h:1194
Gtid_event(const char *buf, const Format_description_event *fde)
Ctor of Gtid_event.
Definition: control_events.cpp:448
unsigned long long get_trx_length() const
Definition: control_events.h:1314
static const int LOGICAL_TIMESTAMP_TYPECODE
Definition: control_events.h:1202
std::uint64_t commit_group_ticket
Ticket number used to group sessions together during the BGC.
Definition: control_events.h:1322
static const int LOGICAL_TIMESTAMP_LENGTH
Length of two logical timestamps.
Definition: control_events.h:1200
void read_gtid_tagged_log_event(const char *buf, std::size_t buf_size)
Function that reads GTID_TAGGED_LOG_EVENT event type from the given buffer.
Definition: control_events.cpp:427
decltype(auto) define_fields() const
Definition: control_events.h:1148
mysql::serialization::Field_missing_functor Field_missing_functor
Definition: control_events.h:1100
uint64_t original_commit_timestamp
Timestamp when the transaction was committed on the originating source.
Definition: control_events.h:1033
void set_trx_length(unsigned long long int transaction_length_arg)
Set the transaction length information.
Definition: control_events.h:1310
static const int IMMEDIATE_SERVER_VERSION_LENGTH
Length of immediate_server_version.
Definition: control_events.h:1217
static const int ENCODED_SERVER_VERSION_LENGTH
Definition: control_events.h:1222
static const int FULL_SERVER_VERSION_LENGTH
Length of original and immediate server version.
Definition: control_events.h:1219
static const int MAX_DATA_LENGTH
Definition: control_events.h:1296
static const int TRANSACTION_LENGTH_MIN_LENGTH
Definition: control_events.h:1212
bool has_commit_timestamps
Flag indicating whether this event contains commit timestamps.
Definition: control_events.h:1037
static const int ORIGINAL_SERVER_VERSION_LENGTH
Length of original_server_version.
Definition: control_events.h:1215
static const int POST_HEADER_LENGTH
Total length of post header.
Definition: control_events.h:1253
decltype(auto) define_fields()
Definition: control_events.h:1110
virtual std::int64_t get_gno() const
Definition: control_events.h:1250
Replication event to ensure to replica that source is alive.
Definition: control_events.h:1668
uint64_t m_log_position
Definition: control_events.h:1705
Heartbeat_event_v2()
Creates an empty heartbeat event.
Definition: control_events.cpp:834
virtual ~Heartbeat_event_v2() override=default
const std::string get_log_filename() const
Definition: control_events.cpp:843
uint64_t get_log_position() const
Definition: control_events.cpp:846
void set_log_position(uint64_t position)
Definition: control_events.cpp:840
static uint64_t max_encoding_length()
This member function returns the len of the event.
Definition: control_events.cpp:853
void set_log_filename(const std::string name)
Definition: control_events.cpp:837
std::string m_log_filename
Definition: control_events.h:1704
Replication event to ensure to replica that source is alive.
Definition: control_events.h:1742
unsigned int get_ident_len()
Definition: control_events.h:1758
Heartbeat_event(const char *buf, const Format_description_event *fde)
Sent by a source to a replica to let the replica know that the source is still alive.
Definition: control_events.cpp:799
const char * log_ident
Definition: control_events.h:1761
const char * get_log_ident()
Definition: control_events.h:1756
unsigned int ident_len
Definition: control_events.h:1762
Base class for ignorable log events.
Definition: control_events.h:673
Ignorable_event(Log_event_type type_arg=IGNORABLE_LOG_EVENT)
The minimal constructor and all it will do is set the type_code as IGNORABLE_LOG_EVENT in the header ...
Definition: control_events.h:682
Class representing an incident, an occurrence out of the ordinary, that happened on the master.
Definition: control_events.h:439
char * message
Definition: control_events.h:490
Incident_event(enum_incident incident_arg)
This will create an Incident_event with an empty message and set the type_code as INCIDENT_EVENT in t...
Definition: control_events.h:460
size_t message_length
Definition: control_events.h:491
enum_incident
Enumeration of the incidents that can occur for the server.
Definition: control_events.h:444
@ INCIDENT_NONE
No incident.
Definition: control_events.h:446
@ INCIDENT_LOST_EVENTS
There are possibly lost events in the replication stream.
Definition: control_events.h:448
@ INCIDENT_COUNT
Shall be last event of the enumeration.
Definition: control_events.h:450
enum_incident incident
Definition: control_events.h:489
char * get_message()
Definition: control_events.h:454
enum_incident get_incident_type()
Definition: control_events.h:453
Definition: control_events.h:1379
size_t buf_size
Definition: control_events.h:1407
Previous_gtids_event()
This is the minimal constructor, and set the type_code as PREVIOUS_GTIDS_LOG_EVENT in the header obje...
Definition: control_events.h:1399
const unsigned char * buf
Definition: control_events.h:1408
When a binary log file exceeds a size limit, a ROTATE_EVENT is written at the end of the file that po...
Definition: control_events.h:115
const char * new_log_ident
Definition: control_events.h:117
@ R_IDENT_OFFSET
Definition: control_events.h:131
@ R_POS_OFFSET
Definition: control_events.h:130
Rotate_event(const char *new_log_ident_arg, size_t ident_len_arg, unsigned int flags_arg, uint64_t pos_arg)
This is the minimal constructor, it will set the type code as ROTATE_EVENT.
Definition: control_events.h:137
@ DUP_NAME
Definition: control_events.h:124
@ RELAY_LOG
Definition: control_events.h:125
uint64_t pos
Definition: control_events.h:120
~Rotate_event() override
Definition: control_events.h:170
unsigned int flags
Definition: control_events.h:119
size_t ident_len
Definition: control_events.h:118
A stop event is written to the log files under these circumstances:
Definition: control_events.h:378
Stop_event()
It is the minimal constructor, and all it will do is set the type_code as STOP_EVENT in the header ob...
Definition: control_events.h:384
This class is used to combine the information of the ongoing transaction including the write set and ...
Definition: control_events.h:1467
static const int ENCODED_SNAPSHOT_VERSION_LEN_OFFSET
Definition: control_events.h:1519
~Transaction_context_event() override
Destructor of the Transaction_context_event class.
Definition: control_events.cpp:753
bool gtid_specified
Definition: control_events.h:1503
static const int ENCODED_SERVER_UUID_LEN_OFFSET
Definition: control_events.h:1513
static const int ENCODED_GTID_SPECIFIED_OFFSET
Definition: control_events.h:1517
static const int ENCODED_READ_WRITE_SET_ITEM_LEN
Definition: control_events.h:1527
static const char * read_data_set(const char *pos, uint32_t set_len, std::list< const char * > *set, uint32_t remaining_buffer)
static const int ENCODED_WRITE_SET_ITEMS_OFFSET
Definition: control_events.h:1521
static void clear_set(std::list< const char * > *set)
Function to clear the memory of the write_set and the read_set.
Definition: control_events.cpp:743
const unsigned char * encoded_snapshot_version
Definition: control_events.h:1504
uint32_t thread_id
Definition: control_events.h:1502
Transaction_context_event(const char *buf, const Format_description_event *fde)
Decodes the transaction_context_log_event of the ongoing transaction.
Definition: control_events.cpp:705
static const int ENCODED_READ_SET_ITEMS_OFFSET
Definition: control_events.h:1523
static const int ENCODED_THREAD_ID_OFFSET
Definition: control_events.h:1515
Transaction_context_event(unsigned int thread_id_arg, bool is_gtid_specified)
Definition: control_events.h:1482
std::list< const char * > read_set
Definition: control_events.h:1507
uint32_t encoded_snapshot_version_length
Definition: control_events.h:1505
static const int ENCODED_SNAPSHOT_VERSION_LEN
Definition: control_events.h:1528
const char * server_uuid
Definition: control_events.h:1501
std::list< const char * > write_set
Definition: control_events.h:1506
Event that encloses all the events of a transaction.
Definition: control_events.h:734
uint64_t m_payload_size
The size of the compressed data.
Definition: control_events.h:752
uint64_t get_uncompressed_size() const
Return the alleged uncompressed size according to the field stored in the event.
Definition: control_events.h:886
static constexpr size_t compression_type_max_length
There are four fields: "compression type", "payload size", "uncompressed size", and "end mark".
Definition: control_events.h:786
~Transaction_payload_event() override
const char * get_payload() const
Definition: control_events.h:901
void set_payload(const char *data)
Set the (possibly compressed) payload for the event.
Definition: control_events.h:898
Buffer_sequence_view_t * m_buffer_sequence_view
The compressed data, when payload consists of a sequence of buffers.
Definition: control_events.h:749
static constexpr size_t uncompressed_size_max_length
Definition: control_events.h:788
const char * m_payload
The compressed data, when entire payload is in one chunk.
Definition: control_events.h:746
mysql::binlog::event::compression::type m_compression_type
The compression algorithm that was used.
Definition: control_events.h:755
static constexpr size_t payload_size_max_length
Definition: control_events.h:787
Transaction_payload_event & operator=(const Transaction_payload_event &)=delete
static constexpr size_t max_length_of_all_headers
The maximum size of all headers, i.e., everything but the payload.
Definition: control_events.h:808
mysql::binlog::event::compression::type get_compression_type() const
Definition: control_events.h:856
void set_uncompressed_size(uint64_t size)
Set the uncompressed size of the payload.
Definition: control_events.h:879
static constexpr size_t max_payload_length
The maximum length of the payload size, defined such that the total event size does not exceed max_lo...
Definition: control_events.h:813
uint64_t get_payload_size() const
Definition: control_events.h:870
void set_payload_size(uint64_t size)
Set the (compressed) size of the payload in this event.
Definition: control_events.h:867
static constexpr size_t max_payload_data_header_length
The maximum size of the "payload data header".
Definition: control_events.h:799
static constexpr size_t end_mark_max_length
Definition: control_events.h:789
mysql::binlog::event::compression::buffer::Buffer_sequence_view<> Buffer_sequence_view_t
Definition: control_events.h:737
Transaction_payload_event(const Transaction_payload_event &)=delete
uint64_t m_uncompressed_size
The uncompressed size of the data.
Definition: control_events.h:760
void set_compression_type(mysql::binlog::event::compression::type type)
Set the compression type used for the enclosed payload.
Definition: control_events.h:851
std::string to_string() const
Definition: control_events.cpp:399
This class is used to add view change markers in the binary log when a member of the group enters or ...
Definition: control_events.h:1567
static const int ENCODED_SEQ_NUMBER_OFFSET
Definition: control_events.h:1598
static const int ENCODED_VIEW_ID_MAX_LEN
Definition: control_events.h:1615
long long int seq_number
Definition: control_events.h:1621
~View_change_event() override
Destructor of the View_change_event class.
Definition: control_events.cpp:797
static const int ENCODED_CERT_INFO_SIZE_OFFSET
Definition: control_events.h:1600
View_change_event(const char *buf, const Format_description_event *fde)
Decodes the view_change_log_event generated in case a server enters or leaves the group.
Definition: control_events.cpp:772
static const int ENCODED_CERT_INFO_KEY_SIZE_LEN
Definition: control_events.h:1616
static const int ENCODED_VIEW_ID_OFFSET
Definition: control_events.h:1596
static const int ENCODED_CERT_INFO_VALUE_LEN
Definition: control_events.h:1617
std::map< std::string, std::string > certification_info
Definition: control_events.h:1623
char view_id[ENCODED_VIEW_ID_MAX_LEN]
Definition: control_events.h:1619
An XA_prepare event is generated for a XA prepared transaction.
Definition: control_events.h:587
XA_prepare_event(void *xid_arg, bool oph_arg)
The minimal constructor of XA_prepare_event, it initializes the instance variable xid and set the typ...
Definition: control_events.h:616
static const uint16_t ser_buf_size
Definition: control_events.h:604
bool is_one_phase() const
Whether or not this XA_prepare_event represents an XA COMMIT ONE PHASE.
Definition: control_events.cpp:359
bool one_phase
Definition: control_events.h:608
MY_XID my_xid
Definition: control_events.h:606
void * xid
Definition: control_events.h:607
MY_XID const & get_xid() const
Retrieves the content of my_xid member variable.
Definition: control_events.cpp:361
static const int MY_XIDDATASIZE
Definition: control_events.h:592
An XID event is generated for a commit of a transaction that modifies one or more tables of an XA-cap...
Definition: control_events.h:522
Xid_event(uint64_t xid_arg)
The minimal constructor of Xid_event, it initializes the instance variable xid and set the type_code ...
Definition: control_events.h:529
uint64_t xid
Definition: control_events.h:539
Sequence of memory buffers.
Definition: buffer_sequence_view.h:71
Represents Transaction Source Identifier which is composed of source UUID and transaction tag.
Definition: tsid.h:46
const Tag & get_tag() const
Tag accessor.
Definition: tsid.h:110
Tag & get_tag_ref()
Tag accessor, non const (serialization)
Definition: tsid.h:114
const Uuid & get_uuid() const
UUID accessor.
Definition: tsid.h:122
Binary, read only archive implementation based on vector of bytes.
Definition: read_archive_binary.h:42
Interface for serializable data structures.
Definition: serializable.h:85
Basic serializer that is implementing Serializer interface.
Definition: serializer_default.h:62
Binary, write only archive implementation based on vector of bytes.
Definition: write_archive_binary.h:43
constexpr DWORD buf_size
Definition: create_def.cc:228
helpers aimed at deducing Field_type in case size is provided, and basic field and compound field def...
#define ST_SERVER_VER_SPLIT_LEN
Definition: binlog_event.h:87
Definition: buf0block_hint.cc:29
type
Definition: base.h:39
@ NONE
Definition: base.h:44
The namespace contains classes representing events that can occur in a replication stream.
Definition: binlog_event.cpp:35
constexpr size_t max_log_event_size
The maximum value for MAX_ALLOWED_PACKET.
Definition: binlog_event.h:446
Log_event_type
Enumeration type for the different types of log events.
Definition: binlog_event.h:285
@ INCIDENT_EVENT
Something out of the ordinary happened on the master.
Definition: binlog_event.h:328
@ XID_EVENT
Definition: binlog_event.h:312
@ IGNORABLE_LOG_EVENT
In some situations, it is necessary to send over ignorable data to the slave: data that a slave can h...
Definition: binlog_event.h:342
@ XA_PREPARE_LOG_EVENT
Definition: binlog_event.h:360
@ PREVIOUS_GTIDS_LOG_EVENT
Definition: binlog_event.h:353
@ STOP_EVENT
Definition: binlog_event.h:300
@ GTID_LOG_EVENT
Definition: binlog_event.h:350
@ ROTATE_EVENT
Definition: binlog_event.h:301
@ TRANSACTION_CONTEXT_EVENT
Definition: binlog_event.h:355
void bapi_free(void *ptr)
This is a wrapper function in order to free the memory allocated from the heap in the binlogevent lib...
Definition: wrapper_functions.h:212
mysql::gtid::Uuid Uuid
Definition: global.h:37
constexpr std::size_t tag_max_length
Maximal number of characters in a tag.
Definition: gtid_constants.h:43
auto define_field_with_size(Field_type &arg, Args &&... args)
Definition: field_definition_helpers.h:48
Field_encode_functor_type Field_encode_predicate
Type of the predicate telling serializer whether field is provided or not.
Definition: field_functor.h:46
auto define_field(Field_type &arg, Args &&... args)
Definition: field_definition_helpers.h:53
Field_decode_functor_type Field_missing_functor
Type of the predicate telling serializer what to do in case field is not provided.
Definition: field_functor.h:42
std::set< Key, Compare, ut::allocator< Key > > set
Specialization of set which uses ut_allocator.
Definition: ut0new.h:2881
required string type
Definition: replication_group_member_actions.proto:33
case opt name
Definition: sslopt-case.h:32
Definition: control_events.h:595
long formatID
Definition: control_events.h:596
char data[MY_XIDDATASIZE]
Definition: control_events.h:599
long bqual_length
Definition: control_events.h:598
long gtrid_length
Definition: control_events.h:597
Structure to hold the members declared in the class Gtid_log_event those member are objects of classe...
Definition: control_events.h:725
int64_t rpl_gtid_gno
Definition: control_events.h:727
int32_t rpl_gtid_sidno
Definition: control_events.h:726
Tag representation so that:
Definition: tag_plain.h:47
Uuid is a trivial and of standard layout The structure contains the following components.
Definition: uuid.h:63
std::array< unsigned char, BYTE_LENGTH > bytes
The data for this Uuid.
Definition: uuid.h:145
Include file for Sun RPC to compile out of the box.