mirror of
https://github.com/MariaDB/server.git
synced 2025-09-15 05:41:27 +03:00
Correct used configuration and force server restarts before test case. Add wait condition instead of sleep to verify that all expected nodes are back to cluster. Signed-off-by: Julius Goryavsky <julius.goryavsky@mariadb.com>
70 lines
2.0 KiB
Plaintext
70 lines
2.0 KiB
Plaintext
connection node_2;
|
|
connection node_1;
|
|
connection node_1;
|
|
connection node_2;
|
|
connection node_3;
|
|
connection node_1;
|
|
CREATE TABLE t1 (f1 INTEGER PRIMARY KEY);
|
|
INSERT INTO t1 VALUES (01), (02), (03), (04), (05);
|
|
connection node_2;
|
|
Unloading wsrep provider ...
|
|
SET GLOBAL wsrep_cluster_address = '';
|
|
connection node_1;
|
|
connection node_3;
|
|
Unloading wsrep provider ...
|
|
SET GLOBAL wsrep_cluster_address = '';
|
|
connection node_1;
|
|
INSERT INTO t1 VALUES (11), (12), (13), (14), (15);
|
|
INSERT INTO t1 VALUES (21), (22), (23), (24), (25);
|
|
SET GLOBAL wsrep_provider_options = 'dbug=d,ist_sender_send_after_get_buffers';
|
|
connection node_2;
|
|
connection node_1;
|
|
INSERT INTO t1 VALUES (31), (32), (33), (34), (35);
|
|
connection node_3;
|
|
connection node_1;
|
|
SHOW STATUS LIKE 'wsrep_debug_sync_waiters';
|
|
Variable_name Value
|
|
wsrep_debug_sync_waiters ist_sender_send_after_get_buffers ist_sender_send_after_get_buffers
|
|
INSERT INTO t1 VALUES (41), (42), (43), (44), (45);
|
|
CREATE TABLE t2 (f1 LONGTEXT);
|
|
INSERT INTO t2 VALUES (REPEAT('x', 512 * 1024));
|
|
INSERT INTO t2 VALUES (REPEAT('x', 512 * 1024));
|
|
INSERT INTO t2 VALUES (REPEAT('x', 512 * 1024));
|
|
SET GLOBAL wsrep_provider_options = 'dbug=';
|
|
SET GLOBAL wsrep_provider_options = 'signal=ist_sender_send_after_get_buffers';
|
|
INSERT INTO t1 VALUES (51), (52), (53), (54), (55);
|
|
connection node_2;
|
|
connection node_1;
|
|
connection node_3;
|
|
connection node_1;
|
|
connection node_2;
|
|
SELECT COUNT(*) AS EXPECT_30 FROM t1;
|
|
EXPECT_30
|
|
30
|
|
SELECT COUNT(*) AS EXPECT_3 FROM t2;
|
|
EXPECT_3
|
|
3
|
|
SELECT LENGTH(f1) = 512 * 1024 FROM t2;
|
|
LENGTH(f1) = 512 * 1024
|
|
1
|
|
1
|
|
1
|
|
CALL mtr.add_suppression("WSREP: Unsupported protocol downgrade: incremental data collection disabled");
|
|
connection node_3;
|
|
SELECT COUNT(*) AS EXPECT_30 FROM t1;
|
|
EXPECT_30
|
|
30
|
|
SELECT COUNT(*) AS EXPECT_3 FROM t2;
|
|
EXPECT_3
|
|
3
|
|
SELECT LENGTH(f1) = 512 * 1024 FROM t2;
|
|
LENGTH(f1) = 512 * 1024
|
|
1
|
|
1
|
|
1
|
|
CALL mtr.add_suppression("WSREP: Unsupported protocol downgrade: incremental data collection disabled");
|
|
DROP TABLE t1, t2;
|
|
disconnect node_3;
|
|
disconnect node_2;
|
|
disconnect node_1;
|