mirror of
https://github.com/MariaDB/server.git
synced 2025-01-16 03:52:35 +01:00
eb4458e993
The current semi-sync binlog fail-over recovery process uses rpl_semi_sync_slave_enabled==TRUE as its condition to truncate a primary server’s binlog, as it is anticipating the server to re-join a replication topology as a replica. However, for servers configured with both rpl_semi_sync_master_enabled=1 and rpl_semi_sync_slave_enabled=1, if a primary is just re-started (i.e. retaining its role as master), it can truncate its binlog to drop transactions which its replica(s) has already received and executed. If this happens, when the replica reconnects, its gtid_slave_pos can be ahead of the recovered primary’s gtid_binlog_pos, resulting in an error state where the replica’s state is ahead of the primary’s. This patch changes the condition for semi-sync recovery to truncate the binlog to instead use the configuration variable --init-rpl-role, when set to SLAVE. This allows for both rpl_semi_sync_master_enabled and rpl_semi_sync_slave_enabled to be set for a primary that is restarted, and no transactions will be lost, so long as --init-rpl-role is not set to SLAVE. Reviewed By: ============ Sergei Golubchik <serg@mariadb.com>
70 lines
2.1 KiB
PHP
70 lines
2.1 KiB
PHP
connect(master1,localhost,root,,);
|
|
connect(master2,localhost,root,,);
|
|
connect(master3,localhost,root,,);
|
|
connect(master4,localhost,root,,);
|
|
|
|
--connection default
|
|
|
|
# First to commit few transactions
|
|
INSERT INTO t VALUES (10);
|
|
INSERT INTO tm VALUES (10);
|
|
|
|
--connection master1
|
|
# Hold insert after write to binlog and before "run_commit_ordered" in engine
|
|
SET DEBUG_SYNC= "commit_before_get_LOCK_commit_ordered SIGNAL master1_ready WAIT_FOR signal_never_arrives";
|
|
--send_eval $query1
|
|
|
|
--connection master2
|
|
SET DEBUG_SYNC= "now WAIT_FOR master1_ready";
|
|
SET DEBUG_SYNC= "commit_before_get_LOCK_after_binlog_sync SIGNAL master2_ready";
|
|
--send_eval $query2
|
|
|
|
--connection master3
|
|
SET DEBUG_SYNC= "now WAIT_FOR master2_ready";
|
|
SELECT @@global.gtid_binlog_pos as 'Before the crash';
|
|
|
|
--connection master4
|
|
# Simulate prepared & not-logged trx; it will never recover.
|
|
SET DEBUG_SYNC= "ha_commit_trans_before_log_and_order SIGNAL master4_ready WAIT_FOR signal_never_arrives";
|
|
--send INSERT INTO t4 VALUES (13)
|
|
|
|
--connection master3
|
|
SET DEBUG_SYNC= "now WAIT_FOR master4_ready";
|
|
SELECT @@global.gtid_binlog_pos as 'Before the crash and never logged trx';
|
|
|
|
--connection default
|
|
--source include/kill_mysqld.inc
|
|
--disconnect master1
|
|
--disconnect master2
|
|
--disconnect master3
|
|
--disconnect master4
|
|
|
|
#
|
|
# Server restart
|
|
#
|
|
--let $restart_parameters= --init-rpl-role=SLAVE --sync-binlog=1 --log-warnings=3
|
|
--source include/start_mysqld.inc
|
|
|
|
# Check error log for a successful truncate message.
|
|
--let $log_error_ = $MYSQLTEST_VARDIR/log/mysqld.1.err
|
|
|
|
--let SEARCH_FILE=$log_error_
|
|
--let SEARCH_PATTERN=Successfully truncated.*to remove transactions starting from GTID $truncate_gtid_pos
|
|
|
|
--source include/search_pattern_in_file.inc
|
|
|
|
--echo Pre-crash binlog file content:
|
|
--let $binlog_file= query_get_value(show binary logs, Log_name, $binlog_file_index)
|
|
--source include/show_binlog_events.inc
|
|
|
|
SELECT @@global.gtid_binlog_pos as 'After the crash';
|
|
--echo "One row should be present in table 't'"
|
|
SELECT * FROM t;
|
|
--echo "No row should be present in table 't4'"
|
|
SELECT * FROM t4;
|
|
|
|
# prepare binlog file index for the next test
|
|
--inc $binlog_file_index
|
|
|
|
# Local cleanup
|
|
DELETE FROM t;
|