36#ifndef CONTROL_EVENT_INCLUDED
37#define CONTROL_EVENT_INCLUDED
130 unsigned int flags_arg, uint64_t pos_arg)
133 ident_len(ident_len_arg ? ident_len_arg : strlen(new_log_ident_arg)),
158 void print_event_info(std::ostream &)
override;
159 void print_long_info(std::ostream &)
override;
339 void print_event_info(std::ostream &
info)
override;
340 void print_long_info(std::ostream &
info)
override;
389 void print_event_info(std::ostream &)
override {}
390 void print_long_info(std::ostream &
info)
override;
477 void print_event_info(std::ostream &
info)
override;
478 void print_long_info(std::ostream &
info)
override;
533 void print_event_info(std::ostream &
info)
override;
534 void print_long_info(std::ostream &
info)
override;
625 void print_event_info(std::ostream &)
override {}
626 void print_long_info(std::ostream &)
override {}
682 void print_event_info(std::ostream &)
override {}
683 void print_long_info(std::ostream &)
override {}
821 uint16_t compression_type,
822 uint64_t uncompressed_size);
911 void print_event_info(std::ostream &)
override;
912 void print_long_info(std::ostream &)
override;
1049 long long int sequence_number_arg,
1050 bool may_have_sbr_stmts_arg,
1051 unsigned long long int original_commit_timestamp_arg,
1052 unsigned long long int immediate_commit_timestamp_arg,
1053 uint32_t original_server_version_arg,
1054 uint32_t immediate_server_version_arg)
1067 void print_event_info(std::ostream &)
override {}
1068 void print_long_info(std::ostream &)
override {}
1199 std::uint64_t value);
1257 void print_event_info(std::ostream &)
override {}
1258 void print_long_info(std::ostream &)
override {}
1337 bool is_gtid_specified_arg)
1345 std::list<const char *> *
set,
1346 uint32_t remaining_buffer);
1351 void print_event_info(std::ostream &)
override {}
1352 void print_long_info(std::ostream &)
override {}
1442 void print_event_info(std::ostream &)
override {}
1443 void print_long_info(std::ostream &)
override {}
1555 void print_event_info(std::ostream &
info)
override;
1556 void print_long_info(std::ostream &
info)
override;
Contains the classes representing events occurring in the replication stream.
#define LOG_EVENT_HEADER_LEN
Definition: binlog_event.h:414
#define LOG_EVENT_MINIMAL_HEADER_LEN
Fixed header length, where 4.x and 5.0 agree.
Definition: binlog_event.h:428
#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:396
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:819
@ TRANSACTION_PAYLOAD_HEADER_LEN
Definition: binlog_event.h:861
GTID stands for Global Transaction IDentifier It is composed of two parts:
Definition: control_events.h:1005
long long int sequence_number
Definition: control_events.h:1014
static const int POST_HEADER_LENGTH
Total length of post header.
Definition: control_events.h:1142
static const int LOGICAL_TIMESTAMP_TYPECODE_LENGTH
Length of typecode for logical timestamps.
Definition: control_events.h:1087
static const int ENCODED_GNO_LENGTH
Definition: control_events.h:1085
virtual std::int64_t get_gno() const
Definition: control_events.h:1139
static const int LOGICAL_TIMESTAMP_TYPECODE
Definition: control_events.h:1091
static const int ENCODED_SERVER_VERSION_LENGTH
Definition: control_events.h:1111
bool may_have_sbr_stmts
Transaction might have changes logged with SBR.
Definition: control_events.h:1018
static const int ORIGINAL_COMMIT_TIMESTAMP_LENGTH
Definition: control_events.h:1094
static const int TRANSACTION_LENGTH_MIN_LENGTH
Definition: control_events.h:1101
Uuid get_uuid() const
Definition: control_events.h:1140
uint32_t original_server_version
The version of the server where the transaction was originally executed.
Definition: control_events.h:1175
unsigned long long int original_commit_timestamp
Timestamp when the transaction was committed on the originating master.
Definition: control_events.h:1020
static const int ORIGINAL_SERVER_VERSION_LENGTH
Length of original_server_version.
Definition: control_events.h:1104
int get_commit_group_ticket_length() const
Returns the length of the packed commit_group_ticket field.
Definition: control_events.cpp:574
unsigned long long int immediate_commit_timestamp
Timestamp when the transaction was committed on the nearest master.
Definition: control_events.h:1022
static const int ENCODED_SID_LENGTH
Definition: control_events.h:1084
int get_server_version_length() const
We only store the immediate_server_version if both server versions are the same.
Definition: control_events.h:1124
static const int FULL_COMMIT_TIMESTAMP_LENGTH
Definition: control_events.h:1096
static const int TRANSACTION_LENGTH_MAX_LENGTH
Definition: control_events.h:1102
static const int FULL_SERVER_VERSION_LENGTH
Length of original and immediate server version.
Definition: control_events.h:1108
gtid_info gtid_info_struct
Definition: control_events.h:1130
static const int ENCODED_COMMIT_TIMESTAMP_LENGTH
Definition: control_events.h:1099
static const int IMMEDIATE_COMMIT_TIMESTAMP_LENGTH
Definition: control_events.h:1093
uint32_t immediate_server_version
The version of the immediate server.
Definition: control_events.h:1177
Gtid_event(const char *buf, const Format_description_event *fde)
Ctor of Gtid_event.
Definition: control_events.cpp:417
int get_commit_timestamp_length() const
Definition: control_events.h:1114
static const int64_t MIN_GNO
Definition: control_events.h:1134
static constexpr int COMMIT_GROUP_TICKET_LENGTH
Definition: control_events.h:1075
unsigned const char FLAG_MAY_HAVE_SBR
GTID flags constants.
Definition: control_events.h:1016
bool has_commit_timestamps
Definition: control_events.h:1023
long long int last_committed
Definition: control_events.h:1013
std::uint64_t commit_group_ticket
Ticket number used to group sessions together during the BGC.
Definition: control_events.h:1180
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:1048
static constexpr std::uint64_t kGroupTicketUnset
Definition: control_events.h:1080
static const int IMMEDIATE_SERVER_VERSION_LENGTH
Length of immediate_server_version.
Definition: control_events.h:1106
static const int MAX_DATA_LENGTH
Definition: control_events.h:1155
static const int MAX_EVENT_LENGTH
Definition: control_events.h:1160
static const int ENCODED_FLAG_LENGTH
Definition: control_events.h:1083
Uuid Uuid_parent_struct
Definition: control_events.h:1131
unsigned long long int transaction_length
The length of the transaction in bytes.
Definition: control_events.h:1025
static const int LOGICAL_TIMESTAMP_LENGTH
Length of two logical timestamps.
Definition: control_events.h:1089
void set_trx_length(unsigned long long int transaction_length_arg)
Set the transaction length information.
Definition: control_events.h:1170
static const std::int64_t GNO_END
One-past-the-max value of GNO.
Definition: control_events.h:1136
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:581
Replication event to ensure to replica that source is alive.
Definition: control_events.h:1523
void set_log_position(uint64_t position)
Definition: control_events.cpp:744
uint64_t get_log_position() const
Definition: control_events.cpp:750
uint64_t m_log_position
Definition: control_events.h:1560
static uint64_t max_encoding_length()
This member function returns the len of the event.
Definition: control_events.cpp:757
virtual ~Heartbeat_event_v2() override=default
const std::string get_log_filename() const
Definition: control_events.cpp:747
std::string m_log_filename
Definition: control_events.h:1559
Heartbeat_event_v2()
Creates an empty heartbeat event.
Definition: control_events.cpp:738
void set_log_filename(const std::string name)
Definition: control_events.cpp:741
Replication event to ensure to replica that source is alive.
Definition: control_events.h:1597
unsigned int ident_len
Definition: control_events.h:1617
const char * log_ident
Definition: control_events.h:1616
unsigned int get_ident_len()
Definition: control_events.h:1613
const char * get_log_ident()
Definition: control_events.h:1611
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:703
Base class for ignorable log events.
Definition: control_events.h:665
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:674
Class representing an incident, an occurrence out of the ordinary, that happened on the master.
Definition: control_events.h:431
enum_incident get_incident_type()
Definition: control_events.h:445
size_t message_length
Definition: control_events.h:483
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:452
enum_incident incident
Definition: control_events.h:481
char * get_message()
Definition: control_events.h:446
char * message
Definition: control_events.h:482
enum_incident
Enumeration of the incidents that can occur for the server.
Definition: control_events.h:436
@ INCIDENT_LOST_EVENTS
There are possibly lost events in the replication stream.
Definition: control_events.h:440
@ INCIDENT_COUNT
Shall be last event of the enumeration.
Definition: control_events.h:442
@ INCIDENT_NONE
No incident.
Definition: control_events.h:438
Definition: control_events.h:1233
size_t buf_size
Definition: control_events.h:1261
const unsigned char * buf
Definition: control_events.h:1262
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:1253
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:107
size_t ident_len
Definition: control_events.h:110
uint64_t pos
Definition: control_events.h:112
unsigned int flags
Definition: control_events.h:111
const char * new_log_ident
Definition: control_events.h:109
~Rotate_event() override
Definition: control_events.h:162
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:129
@ RELAY_LOG
Definition: control_events.h:117
@ DUP_NAME
Definition: control_events.h:116
@ R_POS_OFFSET
Definition: control_events.h:122
@ R_IDENT_OFFSET
Definition: control_events.h:123
A stop event is written to the log files under these circumstances:
Definition: control_events.h:370
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:376
This class is used to combine the information of the ongoing transaction including the write set and ...
Definition: control_events.h:1321
static const int ENCODED_SNAPSHOT_VERSION_LEN_OFFSET
Definition: control_events.h:1374
uint32_t encoded_snapshot_version_length
Definition: control_events.h:1360
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_THREAD_ID_OFFSET
Definition: control_events.h:1370
static const int ENCODED_SERVER_UUID_LEN_OFFSET
Definition: control_events.h:1368
const unsigned char * encoded_snapshot_version
Definition: control_events.h:1359
std::list< const char * > write_set
Definition: control_events.h:1361
Transaction_context_event(unsigned int thread_id_arg, bool is_gtid_specified_arg)
Definition: control_events.h:1336
static const int ENCODED_GTID_SPECIFIED_OFFSET
Definition: control_events.h:1372
static const int ENCODED_READ_WRITE_SET_ITEM_LEN
Definition: control_events.h:1382
std::list< const char * > read_set
Definition: control_events.h:1362
const char * server_uuid
Definition: control_events.h:1356
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:609
static const int ENCODED_READ_SET_ITEMS_OFFSET
Definition: control_events.h:1378
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:647
uint32_t thread_id
Definition: control_events.h:1357
bool gtid_specified
Definition: control_events.h:1358
~Transaction_context_event() override
Destructor of the Transaction_context_event class.
Definition: control_events.cpp:657
static const int ENCODED_SNAPSHOT_VERSION_LEN
Definition: control_events.h:1383
static const int ENCODED_WRITE_SET_ITEMS_OFFSET
Definition: control_events.h:1376
Event that encloses all the events of a transaction.
Definition: control_events.h:726
uint64_t m_uncompressed_size
The uncompressed size of the data.
Definition: control_events.h:751
const char * m_payload
The compressed data, when entire payload is in one chunk.
Definition: control_events.h:737
uint64_t m_payload_size
The size of the compressed data.
Definition: control_events.h:743
static constexpr size_t end_mark_max_length
Definition: control_events.h:780
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:777
static constexpr size_t uncompressed_size_max_length
Definition: control_events.h:779
uint64_t get_payload_size() const
Definition: control_events.h:861
void set_compression_type(transaction::compression::type type)
Set the compression type used for the enclosed payload.
Definition: control_events.h:842
static constexpr size_t payload_size_max_length
Definition: control_events.h:778
transaction::compression::type get_compression_type() const
Definition: control_events.h:847
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:799
uint64_t get_uncompressed_size() const
Return the alleged uncompressed size according to the field stored in the event.
Definition: control_events.h:877
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:804
const char * get_payload() const
Definition: control_events.h:892
mysqlns::buffer::Buffer_sequence_view<> Buffer_sequence_view_t
Definition: control_events.h:728
static constexpr size_t max_payload_data_header_length
The maximum size of the "payload data header".
Definition: control_events.h:790
void set_uncompressed_size(uint64_t size)
Set the uncompressed size of the payload.
Definition: control_events.h:870
void set_payload(const char *data)
Set the (possibly compressed) payload for the event.
Definition: control_events.h:889
Transaction_payload_event & operator=(const Transaction_payload_event &)=delete
Buffer_sequence_view_t * m_buffer_sequence_view
The compressed data, when payload consists of a sequence of buffers.
Definition: control_events.h:740
std::string to_string() const
Definition: control_events.cpp:389
void set_payload_size(uint64_t size)
Set the (compressed) size of the payload in this event.
Definition: control_events.h:858
transaction::compression::type m_compression_type
The compression algorithm that was used.
Definition: control_events.h:746
Transaction_payload_event(const Transaction_payload_event &)=delete
~Transaction_payload_event() override
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:1422
static const int ENCODED_CERT_INFO_KEY_SIZE_LEN
Definition: control_events.h:1471
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:676
static const int ENCODED_SEQ_NUMBER_OFFSET
Definition: control_events.h:1453
char view_id[ENCODED_VIEW_ID_MAX_LEN]
Definition: control_events.h:1474
static const int ENCODED_CERT_INFO_SIZE_OFFSET
Definition: control_events.h:1455
static const int ENCODED_CERT_INFO_VALUE_LEN
Definition: control_events.h:1472
static const int ENCODED_VIEW_ID_MAX_LEN
Definition: control_events.h:1470
std::map< std::string, std::string > certification_info
Definition: control_events.h:1478
static const int ENCODED_VIEW_ID_OFFSET
Definition: control_events.h:1451
long long int seq_number
Definition: control_events.h:1476
~View_change_event() override
Destructor of the View_change_event class.
Definition: control_events.cpp:701
An XA_prepare event is generated for a XA prepared transaction.
Definition: control_events.h:579
MY_XID const & get_xid() const
Retrieves the content of my_xid member variable.
Definition: control_events.cpp:352
MY_XID my_xid
Definition: control_events.h:598
void * xid
Definition: control_events.h:599
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:608
bool one_phase
Definition: control_events.h:600
static const int MY_XIDDATASIZE
Definition: control_events.h:584
static const uint16_t ser_buf_size
Definition: control_events.h:596
bool is_one_phase() const
Whether or not this XA_prepare_event represents an XA COMMIT ONE PHASE.
Definition: control_events.cpp:350
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:514
uint64_t xid
Definition: control_events.h:531
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:521
Sequence of memory buffers.
Definition: buffer_sequence_view.h:71
Fido Client Authentication nullptr
Definition: fido_client_plugin.cc:221
#define ST_SERVER_VER_SPLIT_LEN
Definition: binlog_event.h:76
type
Definition: base.h:32
@ NONE
Definition: base.h:37
The namespace contains classes representing events that can occur in a replication stream.
constexpr size_t max_log_event_size
The maximum value for MAX_ALLOWED_PACKET.
Definition: binlog_event.h:419
Log_event_type
Enumeration type for the different types of log events.
Definition: binlog_event.h:274
@ XA_PREPARE_LOG_EVENT
Definition: binlog_event.h:349
@ 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:331
@ PREVIOUS_GTIDS_LOG_EVENT
Definition: binlog_event.h:342
@ TRANSACTION_CONTEXT_EVENT
Definition: binlog_event.h:344
@ INCIDENT_EVENT
Something out of the ordinary happened on the master.
Definition: binlog_event.h:317
@ GTID_LOG_EVENT
Definition: binlog_event.h:339
@ ROTATE_EVENT
Definition: binlog_event.h:290
@ XID_EVENT
Definition: binlog_event.h:301
@ STOP_EVENT
Definition: binlog_event.h:289
Definition: buf0block_hint.cc:29
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
This is a POD.
Definition: uuid.h:60
Definition: control_events.h:587
long gtrid_length
Definition: control_events.h:589
long bqual_length
Definition: control_events.h:590
char data[MY_XIDDATASIZE]
Definition: control_events.h:591
long formatID
Definition: control_events.h:588
Structure to hold the members declared in the class Gtid_log_event those member are objects of classe...
Definition: control_events.h:717
int64_t rpl_gtid_gno
Definition: control_events.h:719
int32_t rpl_gtid_sidno
Definition: control_events.h:718
Include file for Sun RPC to compile out of the box.
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:211