1include/rpl_init.inc [topology=1->2] 2connection server_2; 3include/stop_slave.inc 4CHANGE MASTER TO master_use_gtid= current_pos; 5include/start_slave.inc 6connection server_1; 7CREATE TABLE t1 (a INT); 8FLUSH LOGS; 9connection server_2; 10connection server_1; 11SET gtid_domain_id=10; 12INSERT INTO t1 VALUES (1); 13INSERT INTO t1 VALUES (2); 14SET gtid_seq_no=100; 15INSERT INTO t1 VALUES (3); 16INSERT INTO t1 VALUES (4); 17INSERT INTO t1 VALUES (5); 18connection server_2; 19include/stop_slave.inc 20SELECT * FROM t1 ORDER BY a; 21a 221 232 243 254 265 27connection server_1; 28include/kill_binlog_dump_threads.inc 29INSERT INTO t1 VALUES (10); 30SET @old_debug= @@GLOBAL.debug_dbug; 31SET GLOBAL debug_dbug="+d,dummy_disable_default_dbug_output"; 32SET GLOBAL debug_dbug="+d,gtid_force_reconnect_at_10_1_100"; 33connection server_2; 34include/start_slave.inc 35SELECT * FROM t1 ORDER BY a; 36a 371 382 393 404 415 4210 43include/stop_slave.inc 44TRUNCATE t1; 45RESET MASTER; 46SET GLOBAL gtid_slave_pos= ""; 47connection server_1; 48SET GLOBAL debug_dbug= @old_debug; 49TRUNCATE t1; 50RESET MASTER; 51SET gtid_domain_id=10; 52SET gtid_seq_no=50; 53INSERT INTO t1 VALUES (1); 54SET gtid_domain_id=11; 55INSERT INTO t1 VALUES (11); 56SET gtid_domain_id=10; 57SET gtid_seq_no=100; 58INSERT INTO t1 VALUES (2); 59SET gtid_domain_id=11; 60INSERT INTO t1 VALUES (12); 61SET gtid_domain_id=10; 62INSERT INTO t1 VALUES (3); 63SET gtid_domain_id=11; 64SET gtid_seq_no=200; 65INSERT INTO t1 VALUES (13); 66connection server_2; 67START SLAVE UNTIL master_gtid_pos="10-1-50,11-1-200"; 68include/wait_for_slave_to_stop.inc 69SELECT * FROM t1 ORDER BY a; 70a 711 7211 7312 7413 75connection server_1; 76include/kill_binlog_dump_threads.inc 77INSERT INTO t1 VALUES (20); 78SET GLOBAL debug_dbug="+d,dummy_disable_default_dbug_output"; 79SET GLOBAL debug_dbug="+d,gtid_force_reconnect_at_10_1_100"; 80connection server_2; 81include/start_slave.inc 82SELECT * FROM t1 ORDER BY a; 83a 841 852 863 8711 8812 8913 9020 91include/stop_slave.inc 92TRUNCATE t1; 93RESET MASTER; 94SET GLOBAL gtid_slave_pos= ""; 95connection server_1; 96SET GLOBAL debug_dbug= @old_debug; 97TRUNCATE t1; 98RESET MASTER; 99include/kill_binlog_dump_threads.inc 100SET gtid_domain_id= 9; 101SET gtid_seq_no= 50; 102INSERT INTO t1 VALUES (1); 103SET gtid_domain_id= 10; 104INSERT INTO t1 VALUES (11); 105SET gtid_domain_id= 9; 106INSERT INTO t1 VALUES (2); 107SET gtid_domain_id= 10; 108SET gtid_seq_no= 100; 109INSERT INTO t1 VALUES (12); 110SET gtid_domain_id= 9; 111INSERT INTO t1 VALUES (3); 112SET gtid_domain_id= 10; 113SET gtid_seq_no= 200; 114INSERT INTO t1 VALUES (13); 115SET gtid_domain_id= 10; 116SET GLOBAL debug_dbug="+d,dummy_disable_default_dbug_output"; 117SET GLOBAL debug_dbug="+d,gtid_force_reconnect_at_10_1_100"; 118connection server_2; 119START SLAVE UNTIL master_gtid_pos="9-1-50,10-1-200"; 120include/wait_for_slave_to_stop.inc 121SELECT * FROM t1 ORDER BY a; 122a 1231 12411 12512 12613 127connection server_1; 128SET GLOBAL debug_dbug= @old_debug; 129INSERT INTO t1 VALUES (20); 130connection server_2; 131include/start_slave.inc 132SELECT * FROM t1 ORDER BY a; 133a 1341 1352 1363 13711 13812 13913 14020 141*** Test when slave IO thread needs to reconnect in the middle of an event group. *** 142connection server_2; 143include/stop_slave.inc 144TRUNCATE t1; 145RESET MASTER; 146SET GLOBAL gtid_slave_pos= ""; 147connection server_1; 148SET GLOBAL debug_dbug= @old_debug; 149TRUNCATE t1; 150RESET MASTER; 151include/kill_binlog_dump_threads.inc 152SET GLOBAL debug_dbug="+d,dummy_disable_default_dbug_output"; 153SET GLOBAL debug_dbug="+d,binlog_force_reconnect_after_22_events"; 154CREATE TABLE t2 (a INT PRIMARY KEY) ENGINE=InnoDB; 155INSERT INTO t2 VALUES (1); 156BEGIN; 157INSERT INTO t2 VALUES (10); 158INSERT INTO t2 VALUES (11); 159COMMIT; 160BEGIN; 161INSERT INTO t2 VALUES (20); 162INSERT INTO t2 VALUES (21); 163INSERT INTO t2 VALUES (22); 164INSERT INTO t2 VALUES (23); 165INSERT INTO t2 VALUES (24); 166INSERT INTO t2 VALUES (25); 167INSERT INTO t2 VALUES (26); 168INSERT INTO t2 VALUES (27); 169INSERT INTO t2 VALUES (28); 170INSERT INTO t2 VALUES (29); 171COMMIT; 172connection server_2; 173include/start_slave.inc 174SELECT * FROM t2 ORDER BY a; 175a 1761 17710 17811 17920 18021 18122 18223 18324 18425 18526 18627 18728 18829 189connection server_1; 190SET GLOBAL debug_dbug= @old_debug; 191connection server_1; 192DROP TABLE t1, t2; 193include/rpl_end.inc 194