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
|
# ==== Purpose ====
#
# Verify that Seconds_Behind_Master is calculated correctly on a
# Multi-threaded Slave.
#
# ==== References ====
# Bug #25407335 SLAVE DON'T REPORT SECONDS_BEHIND_MASTER WHEN RUNNING
# REPLICA_PARALLEL_WORKERS > 0
#
# Must be statement as we rely on PROCESSLIST's Info column
--source include/have_binlog_format_statement.inc
# This test uses debug_sync
--source include/have_debug.inc
--source include/have_debug_sync.inc
--let $rpl_skip_start_slave= 1
--source include/master-slave.inc
# Bug #25407335 SLAVE DON'T REPORT SECONDS_BEHIND_MASTER WHEN RUNNING
# REPLICA_PARALLEL_WORKERS > 0
# Start slave in MTS mode
connection slave;
--let $debug_point= dbug.mta.force_clock_diff_eq_0
--source include/add_debug_point.inc
SET @save_replica_parallel_type = @@GLOBAL.replica_parallel_type;
SET @save.replica_parallel_workers= @@global.replica_parallel_workers;
SET @save_replica_transaction_retries= @@global.replica_transaction_retries;
SET @save_replica_preserve_commit_order= @@global.replica_preserve_commit_order;
--echo # Test for PARALLEL_DATABASE
SET GLOBAL replica_parallel_type = 'DATABASE';
SET @@global.replica_parallel_workers= 4;
SET @@global.replica_preserve_commit_order=0;
--source extra/rpl_tests/rpl_seconds_behind_master_mts_type_database.test
--echo # Test for LOGICAL_CLOCK
SET GLOBAL replica_parallel_type = 'LOGICAL_CLOCK';
SET GLOBAL replica_parallel_workers = 3;
SET GLOBAL replica_preserve_commit_order=1;
--source extra/rpl_tests/rpl_seconds_behind_master_mts_logical_clock.test
#Cleanup
--let $debug_point= dbug.mta.force_clock_diff_eq_0
--source include/remove_debug_point.inc
SET @@GLOBAL.replica_parallel_type= @save_replica_parallel_type;
--disable_warnings
SET @@global.replica_parallel_workers= @save.replica_parallel_workers;
--enable_warnings
SET @@global.replica_transaction_retries= @save_replica_transaction_retries;
SET @@global.replica_preserve_commit_order= @save_replica_preserve_commit_order;
--source include/start_slave.inc
--source include/rpl_end.inc
|
