mirror of
https://github.com/MariaDB/server.git
synced 2025-04-22 07:05:33 +02:00

A GTID event can have variable length, with contributing factors such as the variable length from the flags2 and optional extra flags fields. These fields are bitmaps, where each set bit indicates an additional value that should be appended to the event, e.g. multi-engine transactions append a number to indicate the number of additional engines a transaction uses. However, if a flags bit is set, and no additional fields are appended to the event, MDEV-33672 reports that the server can still try to read from memory as if it did exist. Note, however, in debug builds, this condition is asserted for FL_EXTRA_MULTI_ENGINE. This patch fixes this to check that the length of the event is aligned with the expectation set by the flags for FL_PREPARED_XA, FL_COMPLETED_XA, and FL_EXTRA_MULTI_ENGINE. Reviewed By ============ Kristian Nielsen <knielsen@knielsen-hq.org>
122 lines
3.3 KiB
Text
122 lines
3.3 KiB
Text
include/master-slave.inc
|
|
[connection master]
|
|
#
|
|
# Initialize test data
|
|
connection master;
|
|
create table t1 (a int) engine=innodb;
|
|
include/save_master_gtid.inc
|
|
set @@SESSION.debug_dbug= "+d,binlog_force_commit_id";
|
|
connection slave;
|
|
set SQL_LOG_BIN= 0;
|
|
call mtr.add_suppression('Found invalid event in binary log');
|
|
call mtr.add_suppression('Slave SQL.*Relay log read failure: Could not parse relay log event entry.* 1594');
|
|
set SQL_LOG_BIN= 1;
|
|
include/sync_with_master_gtid.inc
|
|
include/stop_slave.inc
|
|
include/start_slave.inc
|
|
#
|
|
# Test FL_PREPARED_XA
|
|
connection master;
|
|
set @@SESSION.debug_dbug= "+d,negate_xid_from_gtid";
|
|
set @commit_id= 100;
|
|
XA START 'x1';
|
|
insert into t1 values (1);
|
|
XA END 'x1';
|
|
XA PREPARE 'x1';
|
|
set @@SESSION.debug_dbug= "-d,negate_xid_from_gtid";
|
|
XA COMMIT 'x1';
|
|
include/save_master_gtid.inc
|
|
# Waiting for slave to find invalid event..
|
|
connection slave;
|
|
include/wait_for_slave_sql_error.inc [errno=1594]
|
|
STOP SLAVE IO_THREAD;
|
|
# Reset master binlogs (as there is an invalid event) and slave state
|
|
connection master;
|
|
RESET MASTER;
|
|
connection slave;
|
|
RESET MASTER;
|
|
RESET SLAVE;
|
|
set @@global.gtid_slave_pos="";
|
|
include/start_slave.inc
|
|
#
|
|
# Test FL_COMPLETED_XA
|
|
connection master;
|
|
set @commit_id= 101;
|
|
XA START 'x1';
|
|
insert into t1 values (2);
|
|
XA END 'x1';
|
|
XA PREPARE 'x1';
|
|
set @@SESSION.debug_dbug= "+d,negate_xid_from_gtid";
|
|
XA COMMIT 'x1';
|
|
set @@SESSION.debug_dbug= "-d,negate_xid_from_gtid";
|
|
include/save_master_gtid.inc
|
|
# Waiting for slave to find invalid event..
|
|
connection slave;
|
|
include/wait_for_slave_sql_error.inc [errno=1594]
|
|
STOP SLAVE IO_THREAD;
|
|
# Cleanup hanging XA PREPARE on slave
|
|
set statement SQL_LOG_BIN=0 for XA COMMIT 'x1';
|
|
# Reset master binlogs (as there is an invalid event) and slave state
|
|
connection master;
|
|
RESET MASTER;
|
|
connection slave;
|
|
RESET MASTER;
|
|
RESET SLAVE;
|
|
set @@global.gtid_slave_pos="";
|
|
include/start_slave.inc
|
|
#
|
|
# Test Missing xid.data (but has format id and length description parts)
|
|
connection master;
|
|
set @commit_id= 101;
|
|
XA START 'x1';
|
|
insert into t1 values (1);
|
|
XA END 'x1';
|
|
XA PREPARE 'x1';
|
|
set @@SESSION.debug_dbug= "+d,negate_xid_data_from_gtid";
|
|
XA COMMIT 'x1';
|
|
set @@SESSION.debug_dbug= "-d,negate_xid_data_from_gtid";
|
|
include/save_master_gtid.inc
|
|
# Waiting for slave to find invalid event..
|
|
connection slave;
|
|
include/wait_for_slave_sql_error.inc [errno=1594]
|
|
STOP SLAVE IO_THREAD;
|
|
# Cleanup hanging XA PREPARE on slave
|
|
set statement SQL_LOG_BIN=0 for XA COMMIT 'x1';
|
|
# Reset master binlogs (as there is an invalid event) and slave state
|
|
connection master;
|
|
RESET MASTER;
|
|
connection slave;
|
|
RESET MASTER;
|
|
RESET SLAVE;
|
|
set @@global.gtid_slave_pos="";
|
|
include/start_slave.inc
|
|
#
|
|
# Test FL_EXTRA_MULTI_ENGINE
|
|
connection master;
|
|
set @old_dbug= @@SESSION.debug_dbug;
|
|
set @@SESSION.debug_dbug= "+d,inject_fl_extra_multi_engine_into_gtid";
|
|
set @commit_id= 102;
|
|
insert into t1 values (3);
|
|
include/save_master_gtid.inc
|
|
set @@SESSION.debug_dbug=@old_dbug;
|
|
connection slave;
|
|
# Waiting for slave to find invalid event..
|
|
include/wait_for_slave_sql_error.inc [errno=1594]
|
|
STOP SLAVE IO_THREAD;
|
|
# Reset master binlogs (as there is an invalid event) and slave state
|
|
connection master;
|
|
RESET MASTER;
|
|
connection slave;
|
|
RESET SLAVE;
|
|
RESET MASTER;
|
|
set @@global.gtid_slave_pos="";
|
|
include/start_slave.inc
|
|
#
|
|
# Cleanup
|
|
connection master;
|
|
drop table t1;
|
|
include/save_master_gtid.inc
|
|
connection slave;
|
|
include/sync_with_master_gtid.inc
|
|
include/rpl_end.inc
|
|
# End of rpl_gtid_header_valid.test
|