mirror of
https://github.com/MariaDB/server.git
synced 2025-07-14 07:18:12 +02:00
e972125f11
and specifically the ack receiving functionality.
Semisync is turned to be static instead of plugin so its functions
are invoked at the same points as RUN_HOOKS.
The RUN_HOOKS and the observer interface remain to be removed by later
patch.
Todo:
React on killed status by repl_semisync_master.wait_after_sync(). Currently
Repl_semi_sync_master::commit_trx does not check the killed status.
There were few bugfixes found that are present in mysql and its unclear
whether/how they are covered. Those include:
Bug#15985893: GTID SKIPPED EVENTS ON MASTER CAUSE SEMI SYNC TIME-OUTS
Bug#17932935 CALLING IS_SEMI_SYNC_SLAVE() IN EACH FUNCTION CALL
HAS BAD PERFORMANCE
Bug#20574628: SEMI-SYNC REPLICATION PERFORMANCE DEGRADES WITH A HIGH NUMBER OF THREADS
166 lines
4.9 KiB
Text
166 lines
4.9 KiB
Text
include/master-slave.inc
|
|
[connection master]
|
|
connection master;
|
|
call mtr.add_suppression("Timeout waiting for reply of binlog");
|
|
call mtr.add_suppression("Semi-sync master .* waiting for slave reply");
|
|
call mtr.add_suppression("Read semi-sync reply");
|
|
call mtr.add_suppression("Unsafe statement written to the binary log using statement format since BINLOG_FORMAT = STATEMENT.");
|
|
call mtr.add_suppression("mysqld: Got an error reading communication packets");
|
|
connection slave;
|
|
call mtr.add_suppression("Master server does not support semi-sync");
|
|
call mtr.add_suppression("Semi-sync slave .* reply");
|
|
call mtr.add_suppression("Slave SQL.*Request to stop slave SQL Thread received while applying a group that has non-transactional changes; waiting for completion of the group");
|
|
connection master;
|
|
set global rpl_semi_sync_master_enabled = 1;
|
|
connection slave;
|
|
include/stop_slave.inc
|
|
set global rpl_semi_sync_slave_enabled = 1;
|
|
include/start_slave.inc
|
|
connection master;
|
|
SET GLOBAL event_scheduler = ON;
|
|
CREATE TABLE t1 (i INT NOT NULL AUTO_INCREMENT PRIMARY KEY, f varchar(8)) ENGINE=ENGINE_TYPE;
|
|
INSERT INTO t1 (f) VALUES ('a'),('a'),('a'),('a'),('a');
|
|
INSERT INTO t1 SELECT i+5, f FROM t1;
|
|
INSERT INTO t1 SELECT i+10, f FROM t1;
|
|
CREATE EVENT ev1 ON SCHEDULE EVERY 1 SECOND
|
|
DO INSERT INTO t1 VALUES (SLEEP(5),CONCAT('ev1_',CONNECTION_ID()));
|
|
CREATE EVENT ev2 ON SCHEDULE EVERY 1 SECOND
|
|
DO INSERT INTO t1 VALUES (SLEEP(5),CONCAT('ev2_',CONNECTION_ID()));
|
|
connection slave;
|
|
STOP SLAVE IO_THREAD;
|
|
connection master;
|
|
connect m$run,localhost,root,,;
|
|
connection m20;
|
|
UPDATE t1 SET f = CONCAT('up_',CONNECTION_ID()) WHERE i = 20;
|
|
connection master;
|
|
connect m$run,localhost,root,,;
|
|
connection m19;
|
|
UPDATE t1 SET f = CONCAT('up_',CONNECTION_ID()) WHERE i = 19;
|
|
connection master;
|
|
connect m$run,localhost,root,,;
|
|
connection m18;
|
|
UPDATE t1 SET f = CONCAT('up_',CONNECTION_ID()) WHERE i = 18;
|
|
connection master;
|
|
connect m$run,localhost,root,,;
|
|
connection m17;
|
|
UPDATE t1 SET f = CONCAT('up_',CONNECTION_ID()) WHERE i = 17;
|
|
connection master;
|
|
connect m$run,localhost,root,,;
|
|
connection m16;
|
|
UPDATE t1 SET f = CONCAT('up_',CONNECTION_ID()) WHERE i = 16;
|
|
connection master;
|
|
connect m$run,localhost,root,,;
|
|
connection m15;
|
|
UPDATE t1 SET f = CONCAT('up_',CONNECTION_ID()) WHERE i = 15;
|
|
connection master;
|
|
connect m$run,localhost,root,,;
|
|
connection m14;
|
|
UPDATE t1 SET f = CONCAT('up_',CONNECTION_ID()) WHERE i = 14;
|
|
connection master;
|
|
connect m$run,localhost,root,,;
|
|
connection m13;
|
|
UPDATE t1 SET f = CONCAT('up_',CONNECTION_ID()) WHERE i = 13;
|
|
connection master;
|
|
connect m$run,localhost,root,,;
|
|
connection m12;
|
|
UPDATE t1 SET f = CONCAT('up_',CONNECTION_ID()) WHERE i = 12;
|
|
connection master;
|
|
connect m$run,localhost,root,,;
|
|
connection m11;
|
|
UPDATE t1 SET f = CONCAT('up_',CONNECTION_ID()) WHERE i = 11;
|
|
connection master;
|
|
connect m$run,localhost,root,,;
|
|
connection m10;
|
|
UPDATE t1 SET f = CONCAT('up_',CONNECTION_ID()) WHERE i = 10;
|
|
connection master;
|
|
connect m$run,localhost,root,,;
|
|
connection m9;
|
|
UPDATE t1 SET f = CONCAT('up_',CONNECTION_ID()) WHERE i = 9;
|
|
connection master;
|
|
connect m$run,localhost,root,,;
|
|
connection m8;
|
|
UPDATE t1 SET f = CONCAT('up_',CONNECTION_ID()) WHERE i = 8;
|
|
connection master;
|
|
connect m$run,localhost,root,,;
|
|
connection m7;
|
|
UPDATE t1 SET f = CONCAT('up_',CONNECTION_ID()) WHERE i = 7;
|
|
connection master;
|
|
connect m$run,localhost,root,,;
|
|
connection m6;
|
|
UPDATE t1 SET f = CONCAT('up_',CONNECTION_ID()) WHERE i = 6;
|
|
connection master;
|
|
connect m$run,localhost,root,,;
|
|
connection m5;
|
|
UPDATE t1 SET f = CONCAT('up_',CONNECTION_ID()) WHERE i = 5;
|
|
connection master;
|
|
connect m$run,localhost,root,,;
|
|
connection m4;
|
|
UPDATE t1 SET f = CONCAT('up_',CONNECTION_ID()) WHERE i = 4;
|
|
connection master;
|
|
connect m$run,localhost,root,,;
|
|
connection m3;
|
|
UPDATE t1 SET f = CONCAT('up_',CONNECTION_ID()) WHERE i = 3;
|
|
connection master;
|
|
connect m$run,localhost,root,,;
|
|
connection m2;
|
|
UPDATE t1 SET f = CONCAT('up_',CONNECTION_ID()) WHERE i = 2;
|
|
connection master;
|
|
connect m$run,localhost,root,,;
|
|
connection m1;
|
|
UPDATE t1 SET f = CONCAT('up_',CONNECTION_ID()) WHERE i = 1;
|
|
connection master;
|
|
connection master;
|
|
SET GLOBAL event_scheduler = OFF;
|
|
connection m20;
|
|
disconnect m20;
|
|
connection m19;
|
|
disconnect m19;
|
|
connection m18;
|
|
disconnect m18;
|
|
connection m17;
|
|
disconnect m17;
|
|
connection m16;
|
|
disconnect m16;
|
|
connection m15;
|
|
disconnect m15;
|
|
connection m14;
|
|
disconnect m14;
|
|
connection m13;
|
|
disconnect m13;
|
|
connection m12;
|
|
disconnect m12;
|
|
connection m11;
|
|
disconnect m11;
|
|
connection m10;
|
|
disconnect m10;
|
|
connection m9;
|
|
disconnect m9;
|
|
connection m8;
|
|
disconnect m8;
|
|
connection m7;
|
|
disconnect m7;
|
|
connection m6;
|
|
disconnect m6;
|
|
connection m5;
|
|
disconnect m5;
|
|
connection m4;
|
|
disconnect m4;
|
|
connection m3;
|
|
disconnect m3;
|
|
connection m2;
|
|
disconnect m2;
|
|
connection m1;
|
|
disconnect m1;
|
|
connection slave;
|
|
include/stop_slave.inc
|
|
set global rpl_semi_sync_slave_enabled = 0;
|
|
connection master;
|
|
set global rpl_semi_sync_master_enabled = 0;
|
|
connection slave;
|
|
include/start_slave.inc
|
|
connection master;
|
|
DROP EVENT ev1;
|
|
DROP EVENT ev2;
|
|
DROP TABLE t1;
|
|
connection slave;
|
|
include/rpl_end.inc
|