/* Copyright (C) 2018-2022 MariaDB Corporation AB

[0] Fix | Delete

[1] Fix | Delete

This library is free software; you can redistribute it and/or

[2] Fix | Delete

modify it under the terms of the GNU Library General Public

[3] Fix | Delete

License as published by the Free Software Foundation; either

[4] Fix | Delete

version 2 of the License, or (at your option) any later version.

[5] Fix | Delete

[6] Fix | Delete

This library is distributed in the hope that it will be useful,

[7] Fix | Delete

but WITHOUT ANY WARRANTY; without even the implied warranty of

[8] Fix | Delete

MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU

[9] Fix | Delete

Library General Public License for more details.

[10] Fix | Delete

[11] Fix | Delete

You should have received a copy of the GNU Library General Public

[12] Fix | Delete

License along with this library; if not, write to the Free

[13] Fix | Delete

Software Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,

[14] Fix | Delete

MA 02111-1301, USA */

[15] Fix | Delete

#ifndef _mariadb_rpl_h_

[16] Fix | Delete

#define _mariadb_rpl_h_

[17] Fix | Delete

[18] Fix | Delete

#ifdef __cplusplus

[19] Fix | Delete

extern "C" {

[20] Fix | Delete

#endif

[21] Fix | Delete

[22] Fix | Delete

#include <stdint.h>

[23] Fix | Delete

#include <mariadb/ma_io.h>

[24] Fix | Delete

[25] Fix | Delete

#define MARIADB_RPL_VERSION 0x0002

[26] Fix | Delete

#define MARIADB_RPL_REQUIRED_VERSION 0x0002

[27] Fix | Delete

[28] Fix | Delete

#define RPL_BINLOG_MAGIC (const uchar*) "\xFE\x62\x69\x6E"

[29] Fix | Delete

#define RPL_BINLOG_MAGIC_SIZE 4

[30] Fix | Delete

[31] Fix | Delete

/* Protocol flags */

[32] Fix | Delete

#define MARIADB_RPL_BINLOG_DUMP_NON_BLOCK 1

[33] Fix | Delete

#define MARIADB_RPL_BINLOG_SEND_ANNOTATE_ROWS 2

[34] Fix | Delete

#define MARIADB_RPL_IGNORE_HEARTBEAT (1 << 17)

[35] Fix | Delete

[36] Fix | Delete

#define EVENT_HEADER_OFS 20

[37] Fix | Delete

[38] Fix | Delete

#define FL_STMT_END 1

[39] Fix | Delete

[40] Fix | Delete

/* GTID flags */

[41] Fix | Delete

[42] Fix | Delete

/* FL_STANDALONE is set in case there is no terminating COMMIT event. */

[43] Fix | Delete

#define FL_STANDALONE 0x01

[44] Fix | Delete

[45] Fix | Delete

/* FL_GROUP_COMMIT_ID is set when event group is part of a group commit */

[46] Fix | Delete

#define FL_GROUP_COMMIT_ID 0x02

[47] Fix | Delete

[48] Fix | Delete

/* FL_TRANSACTIONAL is set for an event group that can be safely rolled back

[49] Fix | Delete

(no MyISAM, eg.).

[50] Fix | Delete

*/

[51] Fix | Delete

#define FL_TRANSACTIONAL 0x04

[52] Fix | Delete

/*

[53] Fix | Delete

FL_ALLOW_PARALLEL reflects the (negation of the) value of

[54] Fix | Delete

@@SESSION.skip_parallel_replication at the time of commit.

[55] Fix | Delete

*/

[56] Fix | Delete

#define FL_ALLOW_PARALLEL 0x08;

[57] Fix | Delete

/*

[58] Fix | Delete

FL_WAITED is set if a row lock wait (or other wait) is detected during the

[59] Fix | Delete

execution of the transaction.

[60] Fix | Delete

*/

[61] Fix | Delete

#define FL_WAITED 0x10

[62] Fix | Delete

/* FL_DDL is set for event group containing DDL. */

[63] Fix | Delete

#define FL_DDL 0x20

[64] Fix | Delete

/* FL_PREPARED_XA is set for XA transaction. */

[65] Fix | Delete

#define FL_PREPARED_XA 0x40

[66] Fix | Delete

/* FL_"COMMITTED or ROLLED-BACK"_XA is set for XA transaction. */

[67] Fix | Delete

#define FL_COMPLETED_XA 0x80

[68] Fix | Delete

[69] Fix | Delete

[70] Fix | Delete

/* SEMI SYNCHRONOUS REPLICATION */

[71] Fix | Delete

#define SEMI_SYNC_INDICATOR 0xEF

[72] Fix | Delete

#define SEMI_SYNC_ACK_REQ 0x01

[73] Fix | Delete

[74] Fix | Delete

/* Options */

[75] Fix | Delete

enum mariadb_rpl_option {

[76] Fix | Delete

MARIADB_RPL_FILENAME, /* Filename and length */

[77] Fix | Delete

MARIADB_RPL_START, /* Start position */

[78] Fix | Delete

MARIADB_RPL_SERVER_ID, /* Server ID */

[79] Fix | Delete

MARIADB_RPL_FLAGS, /* Protocol flags */

[80] Fix | Delete

MARIADB_RPL_GTID_CALLBACK, /* GTID callback function */

[81] Fix | Delete

MARIADB_RPL_GTID_DATA, /* GTID data */

[82] Fix | Delete

MARIADB_RPL_BUFFER,

[83] Fix | Delete

MARIADB_RPL_VERIFY_CHECKSUM,

[84] Fix | Delete

MARIADB_RPL_UNCOMPRESS,

[85] Fix | Delete

MARIADB_RPL_HOST,

[86] Fix | Delete

MARIADB_RPL_PORT,

[87] Fix | Delete

MARIADB_RPL_EXTRACT_VALUES,

[88] Fix | Delete

MARIADB_RPL_SEMI_SYNC,

[89] Fix | Delete

};

[90] Fix | Delete

[91] Fix | Delete

/* Event types: From MariaDB Server sql/log_event.h */

[92] Fix | Delete

enum mariadb_rpl_event {

[93] Fix | Delete

UNKNOWN_EVENT= 0,

[94] Fix | Delete

START_EVENT_V3= 1,

[95] Fix | Delete

QUERY_EVENT= 2,

[96] Fix | Delete

STOP_EVENT= 3,

[97] Fix | Delete

ROTATE_EVENT= 4,

[98] Fix | Delete

INTVAR_EVENT= 5,

[99] Fix | Delete

LOAD_EVENT= 6,

[100] Fix | Delete

SLAVE_EVENT= 7,

[101] Fix | Delete

CREATE_FILE_EVENT= 8,

[102] Fix | Delete

APPEND_BLOCK_EVENT= 9,

[103] Fix | Delete

EXEC_LOAD_EVENT= 10,

[104] Fix | Delete

DELETE_FILE_EVENT= 11,

[105] Fix | Delete

NEW_LOAD_EVENT= 12,

[106] Fix | Delete

RAND_EVENT= 13,

[107] Fix | Delete

USER_VAR_EVENT= 14,

[108] Fix | Delete

FORMAT_DESCRIPTION_EVENT= 15,

[109] Fix | Delete

XID_EVENT= 16,

[110] Fix | Delete

BEGIN_LOAD_QUERY_EVENT= 17,

[111] Fix | Delete

EXECUTE_LOAD_QUERY_EVENT= 18,

[112] Fix | Delete

TABLE_MAP_EVENT = 19,

[113] Fix | Delete

[114] Fix | Delete

PRE_GA_WRITE_ROWS_EVENT = 20, /* deprecated */

[115] Fix | Delete

PRE_GA_UPDATE_ROWS_EVENT = 21, /* deprecated */

[116] Fix | Delete

PRE_GA_DELETE_ROWS_EVENT = 22, /* deprecated */

[117] Fix | Delete

[118] Fix | Delete

WRITE_ROWS_EVENT_V1 = 23,

[119] Fix | Delete

UPDATE_ROWS_EVENT_V1 = 24,

[120] Fix | Delete

DELETE_ROWS_EVENT_V1 = 25,

[121] Fix | Delete

INCIDENT_EVENT= 26,

[122] Fix | Delete

HEARTBEAT_LOG_EVENT= 27,

[123] Fix | Delete

IGNORABLE_LOG_EVENT= 28,

[124] Fix | Delete

ROWS_QUERY_LOG_EVENT= 29,

[125] Fix | Delete

WRITE_ROWS_EVENT = 30,

[126] Fix | Delete

UPDATE_ROWS_EVENT = 31,

[127] Fix | Delete

DELETE_ROWS_EVENT = 32,

[128] Fix | Delete

GTID_LOG_EVENT= 33,

[129] Fix | Delete

ANONYMOUS_GTID_LOG_EVENT= 34,

[130] Fix | Delete

PREVIOUS_GTIDS_LOG_EVENT= 35,

[131] Fix | Delete

TRANSACTION_CONTEXT_EVENT= 36,

[132] Fix | Delete

VIEW_CHANGE_EVENT= 37,

[133] Fix | Delete

XA_PREPARE_LOG_EVENT= 38,

[134] Fix | Delete

PARTIAL_UPDATE_ROWS_EVENT = 39,

[135] Fix | Delete

[136] Fix | Delete

/*

[137] Fix | Delete

Add new events here - right above this comment!

[138] Fix | Delete

Existing events (except ENUM_END_EVENT) should never change their numbers

[139] Fix | Delete

*/

[140] Fix | Delete

[141] Fix | Delete

/* New MySQL events are to be added right above this comment */

[142] Fix | Delete

MYSQL_EVENTS_END,

[143] Fix | Delete

[144] Fix | Delete

MARIA_EVENTS_BEGIN= 160,

[145] Fix | Delete

ANNOTATE_ROWS_EVENT= 160,

[146] Fix | Delete

BINLOG_CHECKPOINT_EVENT= 161,

[147] Fix | Delete

GTID_EVENT= 162,

[148] Fix | Delete

GTID_LIST_EVENT= 163,

[149] Fix | Delete

START_ENCRYPTION_EVENT= 164,

[150] Fix | Delete

QUERY_COMPRESSED_EVENT = 165,

[151] Fix | Delete

WRITE_ROWS_COMPRESSED_EVENT_V1 = 166,

[152] Fix | Delete

UPDATE_ROWS_COMPRESSED_EVENT_V1 = 167,

[153] Fix | Delete

DELETE_ROWS_COMPRESSED_EVENT_V1 = 168,

[154] Fix | Delete

WRITE_ROWS_COMPRESSED_EVENT = 169,

[155] Fix | Delete

UPDATE_ROWS_COMPRESSED_EVENT = 170,

[156] Fix | Delete

DELETE_ROWS_COMPRESSED_EVENT = 171,

[157] Fix | Delete

[158] Fix | Delete

/* Add new MariaDB events here - right above this comment! */

[159] Fix | Delete

[160] Fix | Delete

ENUM_END_EVENT /* end marker */

[161] Fix | Delete

};

[162] Fix | Delete

[163] Fix | Delete

/* ROWS_EVENT flags */

[164] Fix | Delete

[165] Fix | Delete

#define STMT_END_F 0x01

[166] Fix | Delete

#define NO_FOREIGN_KEY_CHECKS_F 0x02

[167] Fix | Delete

#define RELAXED_UNIQUE_KEY_CHECKS_F 0x04

[168] Fix | Delete

#define COMPLETE_ROWS_F 0x08

[169] Fix | Delete

#define NO_CHECK_CONSTRAINT_CHECKS_F 0x80

[170] Fix | Delete

[171] Fix | Delete

[172] Fix | Delete

enum mariadb_rpl_status_code {

[173] Fix | Delete

Q_FLAGS2_CODE= 0x00,

[174] Fix | Delete

Q_SQL_MODE_CODE= 0x01,

[175] Fix | Delete

Q_CATALOG_CODE= 0x02,

[176] Fix | Delete

Q_AUTO_INCREMENT_CODE= 0x03,

[177] Fix | Delete

Q_CHARSET_CODE= 0x04,

[178] Fix | Delete

Q_TIMEZONE_CODE= 0x05,

[179] Fix | Delete

Q_CATALOG_NZ_CODE= 0x06,

[180] Fix | Delete

Q_LC_TIME_NAMES_CODE= 0x07,

[181] Fix | Delete

Q_CHARSET_DATABASE_CODE= 0x08,

[182] Fix | Delete

Q_TABLE_MAP_FOR_UPDATE_CODE= 0x09,

[183] Fix | Delete

Q_MASTER_DATA_WRITTEN_CODE= 0x0A,

[184] Fix | Delete

Q_INVOKERS_CODE= 0x0B,

[185] Fix | Delete

Q_UPDATED_DB_NAMES_CODE= 0x0C,

[186] Fix | Delete

Q_MICROSECONDS_CODE= 0x0D,

[187] Fix | Delete

Q_COMMIT_TS_CODE= 0x0E, /* unused */

[188] Fix | Delete

Q_COMMIT_TS2_CODE= 0x0F, /* unused */

[189] Fix | Delete

Q_EXPLICIT_DEFAULTS_FOR_TIMESTAMP_CODE= 0x10,

[190] Fix | Delete

Q_DDL_LOGGED_WITH_XID_CODE= 0x11,

[191] Fix | Delete

Q_DEFAULT_COLLATION_FOR_UTF8_CODE= 0x12,

[192] Fix | Delete

Q_SQL_REQUIRE_PRIMARY_KEY_CODE= 0x13,

[193] Fix | Delete

Q_DEFAULT_TABLE_ENCRYPTION_CODE= 0x14,

[194] Fix | Delete

Q_HRNOW= 128, /* second part: 3 bytes */

[195] Fix | Delete

Q_XID= 129 /* xid: 8 bytes */

[196] Fix | Delete

};

[197] Fix | Delete

[198] Fix | Delete

#ifdef DEFAULT_CHARSET

[199] Fix | Delete

#undef DEFAULT_CHARSET

[200] Fix | Delete

#endif

[201] Fix | Delete

[202] Fix | Delete

enum opt_metadata_field_type

[203] Fix | Delete

{

[204] Fix | Delete

SIGNEDNESS = 1,

[205] Fix | Delete

DEFAULT_CHARSET,

[206] Fix | Delete

COLUMN_CHARSET,

[207] Fix | Delete

COLUMN_NAME,

[208] Fix | Delete

SET_STR_VALUE,

[209] Fix | Delete

ENUM_STR_VALUE,

[210] Fix | Delete

GEOMETRY_TYPE,

[211] Fix | Delete

SIMPLE_PRIMARY_KEY,

[212] Fix | Delete

PRIMARY_KEY_WITH_PREFIX,

[213] Fix | Delete

ENUM_AND_SET_DEFAULT_CHARSET,

[214] Fix | Delete

ENUM_AND_SET_COLUMN_CHARSET

[215] Fix | Delete

};

[216] Fix | Delete

[217] Fix | Delete

/* QFLAGS2 codes */

[218] Fix | Delete

#define OPTION_AUTO_IS_NULL 0x00040000

[219] Fix | Delete

#define OPTION_NOT_AUTOCOMMIT 0x00080000

[220] Fix | Delete

#define OPTION_NO_FOREIGN_KEY_CHECKS 0x04000000

[221] Fix | Delete

#define OPTION_RELAXED_UNIQUE_CHECKS 0x08000000

[222] Fix | Delete

[223] Fix | Delete

/* SQL modes */

[224] Fix | Delete

#define MODE_REAL_AS_FLOAT 0x00000001

[225] Fix | Delete

#define MODE_PIPES_AS_CONCAT 0x00000002

[226] Fix | Delete

#define MODE_ANSI_QUOTES 0x00000004

[227] Fix | Delete

#define MODE_IGNORE_SPACE 0x00000008

[228] Fix | Delete

#define MODE_NOT_USED 0x00000010

[229] Fix | Delete

#define MODE_ONLY_FULL_GROUP_BY 0x00000020

[230] Fix | Delete

#define MODE_NO_UNSIGNED_SUBTRACTION 0x00000040

[231] Fix | Delete

#define MODE_NO_DIR_IN_CREATE 0x00000080

[232] Fix | Delete

#define MODE_POSTGRESQL 0x00000100

[233] Fix | Delete

#define MODE_ORACLE 0x00000200

[234] Fix | Delete

#define MODE_MSSQL 0x00000400

[235] Fix | Delete

#define MODE_DB2 0x00000800

[236] Fix | Delete

#define MODE_MAXDB 0x00001000

[237] Fix | Delete

#define MODE_NO_KEY_OPTIONS 0x00002000

[238] Fix | Delete

#define MODE_NO_TABLE_OPTIONS 0x00004000

[239] Fix | Delete

#define MODE_NO_FIELD_OPTIONS 0x00008000

[240] Fix | Delete

#define MODE_MYSQL323 0x00010000

[241] Fix | Delete

#define MODE_MYSQL40 0x00020000

[242] Fix | Delete

#define MODE_ANSI 0x00040000

[243] Fix | Delete

#define MODE_NO_AUTO_VALUE_ON_ZERO 0x00080000

[244] Fix | Delete

#define MODE_NO_BACKSLASH_ESCAPES 0x00100000

[245] Fix | Delete

#define MODE_STRICT_TRANS_TABLES 0x00200000

[246] Fix | Delete

#define MODE_STRICT_ALL_TABLES 0x00400000

[247] Fix | Delete

#define MODE_NO_ZERO_IN_DATE 0x00800000

[248] Fix | Delete

#define MODE_NO_ZERO_DATE 0x01000000

[249] Fix | Delete

#define MODE_INVALID_DATES 0x02000000

[250] Fix | Delete

#define MODE_ERROR_FOR_DIVISION_BY_ZERO 0x04000000

[251] Fix | Delete

#define MODE_TRADITIONAL 0x08000000

[252] Fix | Delete

#define MODE_NO_AUTO_CREATE_USER 0x10000000

[253] Fix | Delete

#define MODE_HIGH_NOT_PRECEDENCE 0x20000000

[254] Fix | Delete

#define MODE_NO_ENGINE_SUBSTITUTION 0x40000000

[255] Fix | Delete

#define MODE_PAD_CHAR_TO_FULL_LENGTH 0x80000000

[256] Fix | Delete

[257] Fix | Delete

/* Log Event flags */

[258] Fix | Delete

[259] Fix | Delete

/* used in FOMRAT_DESCRIPTION_EVENT. Indicates if it

[260] Fix | Delete

is the active binary log.

[261] Fix | Delete

Note: When reading data via COM_BINLOG_DUMP this

[262] Fix | Delete

flag is never set.

[263] Fix | Delete

*/

[264] Fix | Delete

#define LOG_EVENT_BINLOG_IN_USE_F 0x0001

[265] Fix | Delete

[266] Fix | Delete

/* Looks like this flag is no longer in use */

[267] Fix | Delete

#define LOG_EVENT_FORCED_ROTATE_F 0x0002

[268] Fix | Delete

[269] Fix | Delete

/* Log entry depends on thread, e.g. when using user variables

[270] Fix | Delete

or temporary tables */

[271] Fix | Delete

#define LOG_EVENT_THREAD_SPECIFIC_F 0x0004

[272] Fix | Delete

[273] Fix | Delete

/* Indicates that the USE command can be suppressed before

[274] Fix | Delete

executing a statement: e.g. DRIP SCHEMA */

[275] Fix | Delete

#define LOG_EVENT_SUPPRESS_USE_F 0x0008

[276] Fix | Delete

[277] Fix | Delete

/* ??? */

[278] Fix | Delete

#define LOG_EVENT_UPDATE_TABLE_MAP_F 0x0010

[279] Fix | Delete

[280] Fix | Delete

/* Artifical event */

[281] Fix | Delete

#define LOG_EVENT_ARTIFICIAL_F 0x0020

[282] Fix | Delete

[283] Fix | Delete

/* ??? */

[284] Fix | Delete

#define LOG_EVENT_RELAY_LOG_F 0x0040

[285] Fix | Delete

[286] Fix | Delete

/* If an event is not supported, and LOG_EVENT_IGNORABLE_F was not

[287] Fix | Delete

set, an error will be reported. */

[288] Fix | Delete

#define LOG_EVENT_IGNORABLE_F 0x0080

[289] Fix | Delete

[290] Fix | Delete

/* ??? */

[291] Fix | Delete

#define LOG_EVENT_NO_FILTER_F 0x0100

[292] Fix | Delete

[293] Fix | Delete

/* ?? */

[294] Fix | Delete

#define LOG_EVENT_MTS_ISOLATE_F 0x0200

[295] Fix | Delete

[296] Fix | Delete

/* if session variable @@skip_repliation was set, this flag will be

[297] Fix | Delete

reported for events which should be skipped. */

[298] Fix | Delete

#define LOG_EVENT_SKIP_REPLICATION_F 0x8000

[299] Fix | Delete

[300] Fix | Delete

typedef struct {

[301] Fix | Delete

char *str;

[302] Fix | Delete

size_t length;

[303] Fix | Delete

} MARIADB_STRING;

[304] Fix | Delete

[305] Fix | Delete

enum mariadb_row_event_type {

[306] Fix | Delete

WRITE_ROWS= 0,

[307] Fix | Delete

UPDATE_ROWS= 1,

[308] Fix | Delete

DELETE_ROWS= 2

[309] Fix | Delete

};

[310] Fix | Delete

[311] Fix | Delete

/* Global transaction id */

[312] Fix | Delete

typedef struct st_mariadb_gtid {

[313] Fix | Delete

unsigned int domain_id;

[314] Fix | Delete

unsigned int server_id;

[315] Fix | Delete

unsigned long long sequence_nr;

[316] Fix | Delete

} MARIADB_GTID;

[317] Fix | Delete

[318] Fix | Delete

[319] Fix | Delete

/* Generic replication handle */

[320] Fix | Delete

typedef struct st_mariadb_rpl {

[321] Fix | Delete

unsigned int version;

[322] Fix | Delete

MYSQL *mysql;

[323] Fix | Delete

char *filename;

[324] Fix | Delete

uint32_t filename_length;

[325] Fix | Delete

uint32_t server_id;

[326] Fix | Delete

unsigned long start_position;

[327] Fix | Delete

uint16_t flags;

[328] Fix | Delete

uint8_t fd_header_len; /* header len from last format description event */

[329] Fix | Delete

uint8_t use_checksum;

[330] Fix | Delete

uint8_t artificial_checksum;

[331] Fix | Delete

uint8_t verify_checksum;

[332] Fix | Delete

uint8_t post_header_len[ENUM_END_EVENT];

[333] Fix | Delete

MA_FILE *fp;

[334] Fix | Delete

uint32_t error_no;

[335] Fix | Delete

char error_msg[MYSQL_ERRMSG_SIZE];

[336] Fix | Delete

uint8_t uncompress;

[337] Fix | Delete

char *host;

[338] Fix | Delete

uint32_t port;

[339] Fix | Delete

uint8_t extract_values;

[340] Fix | Delete

char nonce[12];

[341] Fix | Delete

uint8_t encrypted;

[342] Fix | Delete

uint8_t is_semi_sync;

[343] Fix | Delete

}MARIADB_RPL;

[344] Fix | Delete

[345] Fix | Delete

typedef struct st_mariadb_rpl_value {

[346] Fix | Delete

enum enum_field_types field_type;

[347] Fix | Delete

uint8_t is_null;

[348] Fix | Delete

uint8_t is_signed;

[349] Fix | Delete

union {

[350] Fix | Delete

int64_t ll;

[351] Fix | Delete

uint64_t ull;

[352] Fix | Delete

float f;

[353] Fix | Delete

double d;

[354] Fix | Delete

MYSQL_TIME tm;

[355] Fix | Delete

MARIADB_STRING str;

[356] Fix | Delete

} val;

[357] Fix | Delete

} MARIADB_RPL_VALUE;

[358] Fix | Delete

[359] Fix | Delete

typedef struct st_rpl_mariadb_row {

[360] Fix | Delete

uint32_t column_count;

[361] Fix | Delete

MARIADB_RPL_VALUE *columns;

[362] Fix | Delete

struct st_rpl_mariadb_row *next;

[363] Fix | Delete

} MARIADB_RPL_ROW;

[364] Fix | Delete

[365] Fix | Delete

/* Event header */

[366] Fix | Delete

struct st_mariadb_rpl_rotate_event {

[367] Fix | Delete

unsigned long long position;

[368] Fix | Delete

MARIADB_STRING filename;

[369] Fix | Delete

};

[370] Fix | Delete

[371] Fix | Delete

struct st_mariadb_rpl_query_event {

[372] Fix | Delete

uint32_t thread_id;

[373] Fix | Delete

uint32_t seconds;

[374] Fix | Delete

MARIADB_STRING database;

[375] Fix | Delete

uint32_t errornr;

[376] Fix | Delete

MARIADB_STRING status;

[377] Fix | Delete

MARIADB_STRING statement;

[378] Fix | Delete

};

[379] Fix | Delete

[380] Fix | Delete

struct st_mariadb_rpl_previous_gtid_event {

[381] Fix | Delete

MARIADB_CONST_DATA content;

[382] Fix | Delete

};

[383] Fix | Delete

[384] Fix | Delete

struct st_mariadb_rpl_gtid_list_event {

[385] Fix | Delete

uint32_t gtid_cnt;

[386] Fix | Delete

MARIADB_GTID *gtid;

[387] Fix | Delete

};

[388] Fix | Delete

[389] Fix | Delete

struct st_mariadb_rpl_format_description_event

[390] Fix | Delete

{

[391] Fix | Delete

uint16_t format;

[392] Fix | Delete

char *server_version;

[393] Fix | Delete

uint32_t timestamp;

[394] Fix | Delete

uint8_t header_len;

[395] Fix | Delete

MARIADB_STRING post_header_lengths;

[396] Fix | Delete

};

[397] Fix | Delete

[398] Fix | Delete

struct st_mariadb_rpl_checkpoint_event {

[399] Fix | Delete

MARIADB_STRING filename;

[400] Fix | Delete

};

[401] Fix | Delete

[402] Fix | Delete

struct st_mariadb_rpl_xid_event {

[403] Fix | Delete

uint64_t transaction_nr;

[404] Fix | Delete

};

[405] Fix | Delete

[406] Fix | Delete

struct st_mariadb_rpl_gtid_event {

[407] Fix | Delete

uint64_t sequence_nr;

[408] Fix | Delete

uint32_t domain_id;

[409] Fix | Delete

uint8_t flags;

[410] Fix | Delete

uint64_t commit_id;

[411] Fix | Delete

uint32_t format_id;

[412] Fix | Delete

uint8_t gtrid_len;

[413] Fix | Delete

uint8_t bqual_len;

[414] Fix | Delete

MARIADB_STRING xid;

[415] Fix | Delete

};

[416] Fix | Delete

[417] Fix | Delete

struct st_mariadb_rpl_annotate_rows_event {

[418] Fix | Delete

MARIADB_STRING statement;

[419] Fix | Delete

};

[420] Fix | Delete

[421] Fix | Delete

struct st_mariadb_rpl_table_map_event {

[422] Fix | Delete

unsigned long long table_id;

[423] Fix | Delete

MARIADB_STRING database;

[424] Fix | Delete

MARIADB_STRING table;

[425] Fix | Delete

uint32_t column_count;

[426] Fix | Delete

MARIADB_STRING column_types;

[427] Fix | Delete

MARIADB_STRING metadata;

[428] Fix | Delete

unsigned char *null_indicator;

[429] Fix | Delete

unsigned char *signed_indicator;

[430] Fix | Delete

MARIADB_CONST_DATA column_names;

[431] Fix | Delete

MARIADB_CONST_DATA geometry_types;

[432] Fix | Delete

uint32_t default_charset;

[433] Fix | Delete

MARIADB_CONST_DATA column_charsets;

[434] Fix | Delete

MARIADB_CONST_DATA simple_primary_keys;

[435] Fix | Delete

MARIADB_CONST_DATA prefixed_primary_keys;

[436] Fix | Delete

MARIADB_CONST_DATA set_values;

[437] Fix | Delete

MARIADB_CONST_DATA enum_values;

[438] Fix | Delete

uint8_t enum_set_default_charset;

[439] Fix | Delete

MARIADB_CONST_DATA enum_set_column_charsets;

[440] Fix | Delete

};

[441] Fix | Delete

[442] Fix | Delete

struct st_mariadb_rpl_rand_event {

[443] Fix | Delete

unsigned long long first_seed;

[444] Fix | Delete

unsigned long long second_seed;

[445] Fix | Delete

};

[446] Fix | Delete

[447] Fix | Delete

struct st_mariadb_rpl_intvar_event {

[448] Fix | Delete

unsigned long long value;

[449] Fix | Delete

uint8_t type;

[450] Fix | Delete

};

[451] Fix | Delete

[452] Fix | Delete

struct st_mariadb_begin_load_query_event {

[453] Fix | Delete

uint32_t file_id;

[454] Fix | Delete

unsigned char *data;

[455] Fix | Delete

};

[456] Fix | Delete

[457] Fix | Delete

struct st_mariadb_start_encryption_event {

[458] Fix | Delete

uint8_t scheme;

[459] Fix | Delete

uint32_t key_version;

[460] Fix | Delete

char nonce[12];

[461] Fix | Delete

};

[462] Fix | Delete

[463] Fix | Delete

struct st_mariadb_execute_load_query_event {

[464] Fix | Delete

uint32_t thread_id;

[465] Fix | Delete

uint32_t execution_time;

[466] Fix | Delete

MARIADB_STRING schema;

[467] Fix | Delete

uint16_t error_code;

[468] Fix | Delete

uint32_t file_id;

[469] Fix | Delete

uint32_t ofs1;

[470] Fix | Delete

uint32_t ofs2;

[471] Fix | Delete

uint8_t duplicate_flag;

[472] Fix | Delete

MARIADB_STRING status_vars;

[473] Fix | Delete

MARIADB_STRING statement;

[474] Fix | Delete

};

[475] Fix | Delete

[476] Fix | Delete

struct st_mariadb_rpl_uservar_event {

[477] Fix | Delete

MARIADB_STRING name;

[478] Fix | Delete

uint8_t is_null;

[479] Fix | Delete

uint8_t type;

[480] Fix | Delete

uint32_t charset_nr;

[481] Fix | Delete

MARIADB_STRING value;

[482] Fix | Delete

uint8_t flags;

[483] Fix | Delete

};

[484] Fix | Delete

[485] Fix | Delete

struct st_mariadb_rpl_rows_event {

[486] Fix | Delete

enum mariadb_row_event_type type;

[487] Fix | Delete

uint64_t table_id;

[488] Fix | Delete

uint16_t flags;

[489] Fix | Delete

uint32_t column_count;

[490] Fix | Delete

unsigned char *column_bitmap;

[491] Fix | Delete

unsigned char *column_update_bitmap;

[492] Fix | Delete

unsigned char *null_bitmap;

[493] Fix | Delete

size_t row_data_size;

[494] Fix | Delete

void *row_data;

[495] Fix | Delete

size_t extra_data_size;

[496] Fix | Delete

void *extra_data;

[497] Fix | Delete

uint8_t compressed;

[498] Fix | Delete

uint32_t row_count;

[499] Fix | Delete