-
Notifications
You must be signed in to change notification settings - Fork 1.7k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
42 changed files
with
545 additions
and
88 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,95 @@ | ||
connect node_2a, 127.0.0.1, root, , test, $NODE_MYPORT_2; | ||
connection node_2a; | ||
connection node_1; | ||
RESET MASTER; | ||
connection node_2a; | ||
START SLAVE; | ||
connection node_1; | ||
CREATE TABLE t1 (f1 INTEGER PRIMARY KEY, f2 CHAR(1)) engine=innodb; | ||
INSERT INTO t1 VALUES (1, 'a'); | ||
INSERT INTO t1 VALUES (3, 'a'); | ||
set binlog_format=STATEMENT; | ||
SET AUTOCOMMIT=ON; | ||
START TRANSACTION; | ||
SELECT * FROM t1 FOR UPDATE; | ||
f1 f2 | ||
1 a | ||
3 a | ||
UPDATE t1 SET f2 = 'c' WHERE f1 > 1; | ||
connection node_2a; | ||
SET SESSION wsrep_sync_wait = 0; | ||
connect node_3, 127.0.0.1, root, , test, $NODE_MYPORT_3; | ||
connection node_3; | ||
SET SESSION wsrep_sync_wait = 0; | ||
connection node_2a; | ||
SET GLOBAL wsrep_provider_options = 'dbug=d,commit_monitor_enter_sync'; | ||
SET GLOBAL debug_dbug = "d,sync.wsrep_apply_cb"; | ||
connection node_3; | ||
INSERT INTO test.t1 VALUES (2, 'b'); | ||
connection node_1; | ||
COMMIT; | ||
connection node_2a; | ||
SET SESSION wsrep_on = 0; | ||
SET SESSION wsrep_on = 1; | ||
SET GLOBAL debug_dbug = ""; | ||
SET DEBUG_SYNC = "now SIGNAL signal.wsrep_apply_cb"; | ||
connection node_2a; | ||
SET GLOBAL wsrep_provider_options = 'dbug='; | ||
SET GLOBAL wsrep_provider_options = 'signal=commit_monitor_enter_sync'; | ||
connection node_1; | ||
SELECT COUNT(*) = 1 FROM t1 WHERE f2 = 'a'; | ||
COUNT(*) = 1 | ||
1 | ||
SELECT COUNT(*) = 1 FROM t1 WHERE f2 = 'c'; | ||
COUNT(*) = 1 | ||
1 | ||
SELECT * FROM t1; | ||
f1 f2 | ||
1 a | ||
3 c | ||
connection node_2a; | ||
set session wsrep_sync_wait=15; | ||
set session wsrep_sync_wait=0; | ||
wsrep_local_replays | ||
1 | ||
SELECT * FROM t1; | ||
f1 f2 | ||
1 a | ||
2 b | ||
3 c | ||
SET DEBUG_SYNC = "RESET"; | ||
# | ||
# test phase with real abort | ||
# | ||
connection node_1; | ||
set binlog_format=ROW; | ||
insert into t1 values (4, 'd'); | ||
SET AUTOCOMMIT=ON; | ||
START TRANSACTION; | ||
UPDATE t1 SET f2 = 'd' WHERE f1 = 3; | ||
connection node_2a; | ||
SET GLOBAL wsrep_provider_options = 'dbug=d,commit_monitor_enter_sync'; | ||
SET GLOBAL debug_dbug = "d,sync.wsrep_apply_cb"; | ||
connection node_3; | ||
UPDATE test.t1 SET f2 = 'e' WHERE f1 = 3; | ||
connection node_1; | ||
COMMIT; | ||
connection node_2a; | ||
SET GLOBAL debug_dbug = ""; | ||
SET DEBUG_SYNC = "now SIGNAL signal.wsrep_apply_cb"; | ||
connection node_2a; | ||
SET GLOBAL wsrep_provider_options = 'dbug='; | ||
SET GLOBAL wsrep_provider_options = 'signal=commit_monitor_enter_sync'; | ||
SET DEBUG_SYNC = "RESET"; | ||
connection node_2a; | ||
set session wsrep_sync_wait=15; | ||
SELECT COUNT(*) = 1 FROM test.t1 WHERE f2 = 'e'; | ||
COUNT(*) = 1 | ||
1 | ||
set session wsrep_sync_wait=0; | ||
STOP SLAVE; | ||
RESET SLAVE; | ||
DROP TABLE t1; | ||
connection node_1; | ||
DROP TABLE t1; | ||
RESET MASTER; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -1,11 +1,11 @@ | ||
connection node_1; | ||
SET SESSION wsrep_sync_wait=15; | ||
SELECT COUNT(DISTINCT uuid) FROM mtr_wsrep_notify.membership; | ||
COUNT(DISTINCT uuid) | ||
SELECT COUNT(DISTINCT uuid) AS EXPECT_2 FROM mtr_wsrep_notify.membership; | ||
EXPECT_2 | ||
2 | ||
SELECT MAX(size) FROM mtr_wsrep_notify.status; | ||
MAX(size) | ||
SELECT MAX(size) AS EXPECT_2 FROM mtr_wsrep_notify.status; | ||
EXPECT_2 | ||
2 | ||
SELECT COUNT(DISTINCT idx) FROM mtr_wsrep_notify.status; | ||
COUNT(DISTINCT idx) | ||
1 | ||
SELECT COUNT(DISTINCT idx) AS EXPECT_2 FROM mtr_wsrep_notify.status; | ||
EXPECT_2 | ||
2 | ||
DROP SCHEMA mtr_wsrep_notify; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1 @@ | ||
!include ../galera_2nodes_as_slave.cnf |
Oops, something went wrong.