File: gr_concurrent_select_group_member_actions.test

package info (click to toggle)
mysql-8.0 8.0.43-3
  • links: PTS, VCS
  • area: main
  • in suites: sid
  • size: 1,273,924 kB
  • sloc: cpp: 4,684,605; ansic: 412,450; pascal: 108,398; java: 83,641; perl: 30,221; cs: 27,067; sql: 26,594; sh: 24,181; python: 21,816; yacc: 17,169; php: 11,522; xml: 7,388; javascript: 7,076; makefile: 2,194; lex: 1,075; awk: 670; asm: 520; objc: 183; ruby: 97; lisp: 86
file content (74 lines) | stat: -rw-r--r-- 3,558 bytes parent folder | download
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
################################################################################
# This test validates that even when there are concurrent select on
# performance_schema.replication_group_member_actions table, server should work
# fine and remain online state.
#
# Test:
# 00. The test requires three servers: M1, M2 and M3.
# 01. On M1, connection thread(T1) executes a select query on
#     performance_schema.replication_group_member_actions table, then wait on
#     sync point.
# 02. Verify that T1 is waiting on sync point.
# 03. Remove the debug flag and execute the select query from another
#     connection.
# 04. Signal to continue T1 and verify that all members are online.
# 05. Cleaning up.
################################################################################

--source include/have_debug_sync.inc
--source include/big_test.inc
--source include/have_group_replication_plugin.inc
--let $rpl_server_count= 3
--source include/group_replication.inc

--echo
--echo #########################################################################
--echo # 01. On M1, connection thread(T1) executes the select query on
--echo #     performance_schema.replication_group_member_actions table, then
--echo #     wait on sync point.
--let $rpl_connection_name= server1
--source include/rpl_connection.inc
--let $_group_replication_action_enabled= query_get_value(SELECT enabled FROM performance_schema.replication_group_member_actions WHERE name = 'mysql_disable_super_read_only_if_primary', enabled, 1)

--let $debug_point=group_replication_wait_before_group_member_actions_read_column_value
--source include/add_debug_point.inc

--send SELECT enabled FROM performance_schema.replication_group_member_actions WHERE name = 'mysql_disable_super_read_only_if_primary'

--echo
--echo #########################################################################
--echo # 02. Verify that T1 is waiting on sync point.
--connect (server_1_2,127.0.0.1,root,,test,$MASTER_MYPORT,,)

--let $rpl_connection_name= server_1_2
--source include/rpl_connection.inc
--let $wait_condition=SELECT COUNT(*)=1 FROM INFORMATION_SCHEMA.PROCESSLIST WHERE State = 'debug sync point: now' and info = "SELECT enabled FROM performance_schema.replication_group_member_actions WHERE name = 'mysql_disable_super_read_only_if_primary'"
--source include/wait_condition.inc

--echo
--echo #########################################################################
--echo # 03. Remove the debug flag and execute the select query from another
--echo #     connection.
--let $debug_point=group_replication_wait_before_group_member_actions_read_column_value
--source include/remove_debug_point.inc

--replace_result $_group_replication_action_enabled MEMBER_ACTION
SELECT enabled FROM performance_schema.replication_group_member_actions WHERE name = 'mysql_disable_super_read_only_if_primary';

--echo
--echo ########################################################################
--echo # 04. Signal to continue T1 and verify that all members are online.
SET DEBUG_SYNC= 'now SIGNAL signal.after_group_member_actions_read_column_value_continue';

--let $rpl_connection_name= server1
--source include/rpl_connection.inc
--replace_result $_group_replication_action_enabled MEMBER_ACTION
--reap

let $wait_condition=SELECT COUNT(*)=3 FROM performance_schema.replication_group_members where MEMBER_STATE="ONLINE";
--source include/wait_condition.inc

--echo
--echo ################################################################
--echo # 05. Cleanup
--source include/group_replication_end.inc