mirror of
https://github.com/MariaDB/server.git
synced 2025-02-09 23:24:11 +01:00
49fa5f6b5f
Add more inserts before wsrep_slave_threads is set to 1 and add wait_condition to wait all of them are replicated before wait_condition about number of wsrep_slave_threads. Signed-off-by: Julius Goryavsky <julius.goryavsky@mariadb.com>
55 lines
1.9 KiB
Text
55 lines
1.9 KiB
Text
connection node_2;
|
|
connection node_1;
|
|
connection node_1;
|
|
SET @wsrep_slave_threads_orig = @@wsrep_slave_threads;
|
|
CREATE TABLE t1 (f1 INTEGER PRIMARY KEY AUTO_INCREMENT) Engine=InnoDB;
|
|
SET GLOBAL wsrep_slave_threads = 10;
|
|
# Set slave threads to 10 step 1
|
|
SELECT VARIABLE_VALUE AS EXPECT_10 FROM INFORMATION_SCHEMA.GLOBAL_STATUS WHERE VARIABLE_NAME = 'wsrep_applier_thread_count';
|
|
EXPECT_10
|
|
10
|
|
SET GLOBAL wsrep_slave_threads = 1;
|
|
connection node_2;
|
|
INSERT INTO t1 VALUES (NULL);
|
|
connection node_1;
|
|
# Wait until one of the appliers has exited
|
|
SELECT VARIABLE_VALUE AS EXPECT_9 FROM INFORMATION_SCHEMA.GLOBAL_STATUS WHERE VARIABLE_NAME = 'wsrep_applier_thread_count';
|
|
EXPECT_9
|
|
9
|
|
SET GLOBAL wsrep_slave_threads = 10;
|
|
# Set slave threads to 10 step 2
|
|
SELECT VARIABLE_VALUE AS EXPECT_10 FROM INFORMATION_SCHEMA.GLOBAL_STATUS WHERE VARIABLE_NAME = 'wsrep_applier_thread_count';
|
|
EXPECT_10
|
|
10
|
|
SET GLOBAL wsrep_slave_threads = 20;
|
|
# Set slave threads to 20
|
|
SELECT VARIABLE_VALUE AS EXPECT_20 FROM INFORMATION_SCHEMA.GLOBAL_STATUS WHERE VARIABLE_NAME = 'wsrep_applier_thread_count';
|
|
EXPECT_20
|
|
20
|
|
SET GLOBAL wsrep_slave_threads = 1;
|
|
connection node_2;
|
|
connection node_1;
|
|
# Wait until 19 of the appliers has exited
|
|
SELECT VARIABLE_VALUE AS EXPECT_1 FROM INFORMATION_SCHEMA.GLOBAL_STATUS WHERE VARIABLE_NAME = 'wsrep_applier_thread_count';
|
|
EXPECT_1
|
|
1
|
|
SELECT COUNT(*) AS EXPECT_51 FROM t1;
|
|
EXPECT_51
|
|
51
|
|
SET GLOBAL wsrep_slave_threads = 10;
|
|
# Set slave threads to 10 step 3
|
|
SELECT VARIABLE_VALUE AS EXPECT_10 FROM INFORMATION_SCHEMA.GLOBAL_STATUS WHERE VARIABLE_NAME = 'wsrep_applier_thread_count';
|
|
EXPECT_10
|
|
10
|
|
connection node_1;
|
|
SET GLOBAL wsrep_slave_threads = 1;
|
|
connection node_2;
|
|
connection node_1;
|
|
# Wait until slave threads back to 1
|
|
SELECT VARIABLE_VALUE AS EXPECT_1 FROM INFORMATION_SCHEMA.GLOBAL_STATUS WHERE VARIABLE_NAME = 'wsrep_applier_thread_count';
|
|
EXPECT_1
|
|
1
|
|
SELECT COUNT(*) AS EXPECT_101 FROM t1;
|
|
EXPECT_101
|
|
101
|
|
DROP TABLE t1;
|