Skip to content

Commit f3eb1d0

Browse files
committed
rpl_parallel_multilevel2 can be 1 or 3 binlog groups
1 parent 54287ad commit f3eb1d0

File tree

2 files changed

+14
-12
lines changed

2 files changed

+14
-12
lines changed

mysql-test/suite/rpl/r/rpl_parallel_multilevel2.result

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -47,18 +47,18 @@ include/sync_with_master_gtid.inc
4747
SELECT * FROM t1 ORDER BY a;
4848
a b
4949
1 10
50-
SELECT variable_value - @group_commits FROM information_schema.global_status
51-
WHERE variable_name = 'binlog_group_commits';
52-
variable_value - @group_commits
53-
3
50+
SELECT IF((commits.variable_value - @group_commits) IN (1,3), "OK", "Not 1 or 3 groups"),
51+
((commits.variable_value - @group_commits) - (reason_usec.variable_value - @group_commit_reason_usec)) as diff
52+
FROM information_schema.global_status commits
53+
JOIN information_schema.global_status reason_usec
54+
WHERE commits.variable_name = 'binlog_group_commits'
55+
AND reason_usec.variable_name = 'binlog_group_commit_reason_usec';
56+
IF((commits.variable_value - @group_commits) IN (1,3), "OK", "Not 1 or 3 groups") diff
57+
OK 0
5458
SELECT variable_value - @group_commit_reason_count FROM information_schema.global_status
5559
WHERE variable_name = 'binlog_group_commit_reason_count';
5660
variable_value - @group_commit_reason_count
5761
0
58-
SELECT variable_value - @group_commit_reason_usec FROM information_schema.global_status
59-
WHERE variable_name = 'binlog_group_commit_reason_usec';
60-
variable_value - @group_commit_reason_usec
61-
3
6262
SELECT variable_value - @group_commit_reason_transaction FROM information_schema.global_status
6363
WHERE variable_name = 'binlog_group_commit_reason_transaction';
6464
variable_value - @group_commit_reason_transaction

mysql-test/suite/rpl/t/rpl_parallel_multilevel2.test

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -76,12 +76,14 @@ SELECT * FROM t1 ORDER BY a;
7676

7777
# Measure status(es)
7878
--connection server_2
79-
SELECT variable_value - @group_commits FROM information_schema.global_status
80-
WHERE variable_name = 'binlog_group_commits';
79+
SELECT IF((commits.variable_value - @group_commits) IN (1,3), "OK", "Not 1 or 3 groups"),
80+
((commits.variable_value - @group_commits) - (reason_usec.variable_value - @group_commit_reason_usec)) as diff
81+
FROM information_schema.global_status commits
82+
JOIN information_schema.global_status reason_usec
83+
WHERE commits.variable_name = 'binlog_group_commits'
84+
AND reason_usec.variable_name = 'binlog_group_commit_reason_usec';
8185
SELECT variable_value - @group_commit_reason_count FROM information_schema.global_status
8286
WHERE variable_name = 'binlog_group_commit_reason_count';
83-
SELECT variable_value - @group_commit_reason_usec FROM information_schema.global_status
84-
WHERE variable_name = 'binlog_group_commit_reason_usec';
8587
SELECT variable_value - @group_commit_reason_transaction FROM information_schema.global_status
8688
WHERE variable_name = 'binlog_group_commit_reason_transaction';
8789
SELECT variable_value - @group_commit_reason_immediate FROM information_schema.global_status

0 commit comments

Comments
 (0)