1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
|
# This is an auxilary file to use with MTS slave.
# Idea is to make workers in different states and check the output.
# This include file always creates a table in starting and deletes the table in the end
#
# Usage
# [ --let $exec_trx2 = 1 ]
# [ --let $exec_trx4 = 1 ]
# [ --let $exec_trx5 = 1 ]
# --source extra/rpl_tests/rpl_mts_spco_check_worker_states.inc
#
# Parameters:
#
# $exec_trx2
# Enable this if worker 2 should be in executing state
# i.e, 'Applying batch of row changes (write)' or 'update' else it will go to 'Waiting for preceding transaction to commit'
#
# $exec_trx4
# Enable this if worker 4 should be in executing state
# i.e, 'Applying batch of row changes (write)' or 'update' else it will go to 'Waiting for preceding transaction to commit'
#
# $exec_trx5
# Enable this if worker 5 should be in executing state
# i.e, 'Applying batch of row changes (write)' or 'update' else it will go to 'Waiting for preceding transaction to commit'
#
# Worker 1 and 3 will be executing state
# i.e, 'Applying batch of row changes (write)' or 'update'
--let $n_executing_workers = 2
--source include/rpl_connection_master.inc
CREATE TABLE t1(a INT PRIMARY KEY);
--source include/sync_slave_sql_with_master.inc
--echo # Execute transactions on slave
--source include/rpl_connection_slave.inc
# Save binlog_format
--let $binlog_format = `SELECT @@binlog_format`
# Adding INSERT without commit would block INSERTs from slave worker
# thread and put them in executing state
BEGIN;
INSERT INTO t1 VALUES (1);
if ($exec_trx2) {
INSERT INTO t1 VALUES (2);
--inc $n_executing_workers
}
if ($exec_trx4) {
INSERT INTO t1 VALUES (4);
--inc $n_executing_workers
}
if ($exec_trx5) {
INSERT INTO t1 VALUES (5);
--inc $n_executing_workers
}
--echo # Block transaction that needs to rollback
--source include/rpl_connection_slave1.inc
BEGIN;
INSERT INTO t1 VALUES (3);
# Add some data to master with same commit parent.
--source include/rpl_connection_master.inc
--let $debug_point=set_commit_parent_100
--source include/add_debug_point.inc
INSERT INTO t1 VALUES (1);
INSERT INTO t1 VALUES (2);
INSERT INTO t1 VALUES (3);
INSERT INTO t1 VALUES (4);
INSERT INTO t1 VALUES (5);
--source include/rpl_connection_slave.inc
# Check if $n_executing_workers are in blocked state
if ($binlog_format == 'ROW'){
--let $wait_condition= SELECT count(*) = $n_executing_workers FROM performance_schema.threads WHERE PROCESSLIST_STATE="Applying batch of row changes (write)"
--source include/wait_condition_or_abort.inc
}
if ($binlog_format!= 'ROW'){
--let $wait_condition= SELECT count(*) = $n_executing_workers FROM performance_schema.threads WHERE PROCESSLIST_STATE="update"
--source include/wait_condition_or_abort.inc
}
# As $n_executing_workers transaction are blocked the remaining i.e. (5 - $n_executing_workers) should be in waiting state
--let $wait_condition= SELECT count(*) = 5 - $n_executing_workers FROM performance_schema.threads WHERE PROCESSLIST_STATE="Waiting for preceding transaction to commit"
--source include/wait_condition_or_abort.inc
--echo # Commit transaction to make 3rd worker thread rollback
--source include/rpl_connection_slave1.inc
COMMIT;
--echo # Wait until slave worker has failed due to duplicate entry
--let $slave_param= Last_Errno
--let $slave_param_value= convert_error(ER_DUP_ENTRY)
--source include/wait_for_slave_param.inc
--echo # Release other worker threads
--source include/rpl_connection_slave.inc
ROLLBACK;
--echo # Wait for all worker threads to exit
--let $slave_timeout= 60
--let $slave_param= Slave_SQL_Running
--let $slave_param_value= No
--source include/wait_for_slave_param.inc
# 3 rows are committed on slave
--let $assert_text= Verify table t1 has 3 values
--let $assert_cond= "[SELECT count(*) COUNT FROM t1, COUNT, 1]" = "3"
--source include/assert.inc
--echo # Delete conflicting transactions on slave
--source include/rpl_connection_slave.inc
BEGIN;
DELETE FROM t1 WHERE a = 3;
if ($exec_trx4) {
DELETE FROM t1 WHERE a = 4;
}
if ($exec_trx5) {
DELETE FROM t1 WHERE a = 5;
}
COMMIT;
--echo # Start slave sql thread
--source include/start_slave_sql.inc
--let $slave_timeout= 60
--let $slave_param= Slave_SQL_Running_State
--let $slave_param_value= Replica has read all relay log; waiting for more updates
--source include/wait_for_slave_param.inc
--source include/rpl_connection_master.inc
--source include/sync_slave_sql_with_master.inc
--let $assert_text= Verify table t1 has 5 rows
--let $assert_cond= "[SELECT count(*) COUNT FROM t1, COUNT, 1]" = "5"
--source include/assert.inc
--source include/rpl_connection_master.inc
--let $debug_point=set_commit_parent_100
--source include/remove_debug_point.inc
DROP TABLE t1;
--source include/sync_slave_sql_with_master.inc
|
