WL#14194 step 2.11: Thread stages

WL#14194: Replace old terms in replication system variables, options,
and strings.

Replace all occurrences of master/slave/mts by source/replica/mta, in
thread stages.

RB:25355

Author: Sven Sandberg

mysql-test/extra/rpl_tests/check_slave_delay.inc

@@ -36,8 +36,8 @@
 --source include/rpl_connection_master.inc
 --source include/sync_slave_sql_with_master.inc
 
---let $assert_text= Status should not be 'Waiting until MASTER_DELAY seconds after master executed event'
---let $assert_cond= NOT("[SHOW SLAVE STATUS, Slave_SQL_Running_State, 1]" LIKE "Waiting until % seconds after master executed event")
+--let $assert_text= Status should not be 'Waiting until SOURCE_DELAY seconds after source executed event'
+--let $assert_cond= NOT("[SHOW SLAVE STATUS, Slave_SQL_Running_State, 1]" LIKE "Waiting until % seconds after source executed event")
 --source include/assert.inc
 
 --source include/rpl_connection_master.inc

mysql-test/extra/rpl_tests/check_slave_delay_multi_source.inc

@@ -17,8 +17,8 @@
 --let $sync_slave_connection= $slave
 --source include/sync_slave_sql_with_master.inc
 
---let $assert_text= Status should not be 'Waiting until MASTER_DELAY seconds after master executed event'
---let $assert_cond= NOT("[SHOW SLAVE STATUS, Slave_SQL_Running_State, 1]" LIKE "Waiting until % seconds after master executed event")
+--let $assert_text= Status should not be 'Waiting until SOURCE_DELAY seconds after source executed event'
+--let $assert_cond= NOT("[SHOW SLAVE STATUS, Slave_SQL_Running_State, 1]" LIKE "Waiting until % seconds after source executed event")
 --source include/assert.inc
 
 --let $rpl_connection_name= $master

mysql-test/extra/rpl_tests/check_slave_delay_old.inc

@@ -45,8 +45,8 @@
 --let $assert_cond= $time_diff >= $delay
 --source include/assert.inc
 
---let $assert_text= Status should not be 'Waiting until MASTER_DELAY seconds after master executed event'
---let $assert_cond= NOT("[SHOW SLAVE STATUS, Slave_SQL_Running_State, 1]" LIKE "Waiting until % seconds after master executed event")
+--let $assert_text= Status should not be 'Waiting until SOURCE_DELAY seconds after source executed event'
+--let $assert_cond= NOT("[SHOW SLAVE STATUS, Slave_SQL_Running_State, 1]" LIKE "Waiting until % seconds after source executed event")
 --source include/assert.inc
 
 --source include/rpl_connection_master.inc

mysql-test/extra/rpl_tests/delayed_slave_wait_on_query.inc

@@ -33,8 +33,8 @@ connection master;
 --let $assert_cond= MAX(b) < $query_number FROM t1
 --source include/assert.inc
 
---let $assert_text= Status should be 'Waiting until MASTER_DELAY...'
---let $assert_cond= "[SHOW SLAVE STATUS, Slave_SQL_Running_State, 1]" LIKE "Waiting until MASTER_DELAY%"
+--let $assert_text= Status should be 'Waiting until SOURCE_DELAY...'
+--let $assert_cond= "[SHOW SLAVE STATUS, Slave_SQL_Running_State, 1]" LIKE "Waiting until SOURCE_DELAY%"
 --source include/assert.inc
 
 --echo # sleep 1*T
@@ -48,7 +48,7 @@ connection master;
 --source include/assert.inc
 
 --let $assert_text= Status should be 'Has read all relay log...'
---let $assert_cond= "[SHOW SLAVE STATUS, Slave_SQL_Running_State, 1]" LIKE "Slave has read all relay log%"
+--let $assert_cond= "[SHOW SLAVE STATUS, Slave_SQL_Running_State, 1]" LIKE "Replica has read all relay log%"
 --source include/assert.inc
 
 

mysql-test/extra/rpl_tests/rpl_check_ps_applier_status_by_worker_gtid_skipped_transaction.inc

@@ -17,7 +17,7 @@ DROP TABLE t;
 --source include/sync_slave_sql_with_master.inc
 
 --let $slave_param= Slave_SQL_Running_State
---let $slave_param_value= Slave has read all relay log; waiting for more updates
+--let $slave_param_value= Replica has read all relay log; waiting for more updates
 --source include/wait_for_slave_param.inc
 
 --let $last_processed_gtid_before= query_get_value(select LAST_PROCESSED_TRANSACTION from performance_schema.replication_applier_status_by_coordinator, LAST_PROCESSED_TRANSACTION, 1)

mysql-test/extra/rpl_tests/rpl_generate_mts_gap.test

@@ -43,5 +43,5 @@ INSERT INTO d1.t VALUES (2, 'T5');
 # Wait for coordinator to populate worker's queues.
 --let $show_statement= SHOW PROCESSLIST
 --let $field= State
---let $condition= = 'Slave has read all relay log; waiting for more updates'
+--let $condition= = 'Replica has read all relay log; waiting for more updates'
 --source include/wait_show_condition.inc

mysql-test/extra/rpl_tests/rpl_generate_mts_gap_with_missing_relaylog_begin.inc

@@ -73,7 +73,7 @@ INSERT INTO d1.t VALUES (2, 'T5');
 # Wait for coordinator to populate worker's queues.
 --let $show_statement= SHOW PROCESSLIST
 --let $field= State
---let $condition= = 'Slave has read all relay log; waiting for more updates'
+--let $condition= = 'Replica has read all relay log; waiting for more updates'
 --source include/wait_show_condition.inc
 
 # Kill the slave server

mysql-test/extra/rpl_tests/rpl_gtid_drop_table.test

@@ -321,7 +321,7 @@ CREATE TEMPORARY TABLE temp_non_trans_t2 (c1 INT) ENGINE=MyISAM;
 # FormatDescription event which tells slave SQL thread to drop all temporary
 --let $show_statement= SHOW PROCESSLIST
 --let $field= State
---let $condition= 'Slave has read all relay log; waiting for the slave I/O thread to update it';
+--let $condition= 'Replica has read all relay log; waiting for the slave I/O thread to update it';
 --source include/wait_show_condition.inc
 
 # Now we verify replica_open_temp_tables, it should be '0'

mysql-test/extra/rpl_tests/rpl_mts_pending_events.inc

@@ -88,7 +88,7 @@ if (!$tables_involved_in_test)
 --let $assert_cond= [SELECT count(*) FROM information_schema.processlist WHERE state = "Waiting for table metadata lock"] = 1
 --source include/assert.inc
 
---let $wait_condition= SELECT count(*) = 1 FROM information_schema.processlist WHERE state = "Waiting for Slave Workers to free pending events"
+--let $wait_condition= SELECT count(*) = 1 FROM information_schema.processlist WHERE state = "Waiting for Replica Workers to free pending events"
 --source include/wait_condition.inc
 
 --echo #

mysql-test/extra/rpl_tests/rpl_mts_spco_check_worker_states.inc

@@ -132,7 +132,7 @@ COMMIT;
 
 --let $slave_timeout= 60
 --let $slave_param= Slave_SQL_Running_State
---let $slave_param_value= Slave has read all relay log; waiting for more updates
+--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

mysql-test/extra/rpl_tests/rpl_mts_until.inc

@@ -77,7 +77,7 @@ if ($until_type == 'BEFORE_GTIDS')
 
 eval START SLAVE SQL_THREAD UNTIL $__until_clause;
 
---let $wait_condition= SELECT count(*) = 1 FROM information_schema.processlist WHERE state = "Waiting for workers to exit" OR state = "Waiting for Slave Worker to release partition"
+--let $wait_condition= SELECT count(*) = 1 FROM information_schema.processlist WHERE state = "Waiting for workers to exit" OR state = "Waiting for Replica Worker to release partition"
 --source include/wait_condition.inc
 
 --let $rpl_connection_name= server_2

mysql-test/extra/rpl_tests/rpl_multi_source_corrupt_repository.inc

@@ -321,11 +321,11 @@ while ($i <= $number_of_channels)
   --let $slave_timeout= 60
 
   --let $slave_param= Slave_IO_State
-  --let $slave_param_value= Waiting for master to send event
+  --let $slave_param_value= Waiting for source to send event
   --source include/wait_for_slave_param.inc
 
   --let $slave_param= Slave_SQL_Running_State
-  --let $slave_param_value= Slave has read all relay log; waiting for more updates
+  --let $slave_param_value= Replica has read all relay log; waiting for more updates
   --source include/wait_for_slave_param.inc
 
   --let $status_items=Last_IO_Errno,Last_IO_Error,Last_SQL_Errno,Last_SQL_Error,Channel_Name

mysql-test/extra/rpl_tests/rpl_multi_source_generate_mts_gap.test

@@ -51,5 +51,5 @@ BEGIN;
 # Wait for coordinator to populate worker's queues.
 --let $show_statement= SHOW PROCESSLIST
 --let $field= State
---let $condition= = 'Slave has read all relay log; waiting for more updates'
+--let $condition= = 'Replica has read all relay log; waiting for more updates'
 --source include/wait_show_condition.inc

mysql-test/extra/rpl_tests/rpl_sync_relay_log_info_assert_pos.inc

@@ -31,7 +31,7 @@ if ($_rrli_expected != "N")
 if ($is_slave_sql_running == 'Yes' )
 {
   --let $slave_param= Slave_SQL_Running_State
-  --let $slave_param_value= Slave has read all relay log; waiting for more updates
+  --let $slave_param_value= Replica has read all relay log; waiting for more updates
   --source include/wait_for_slave_param.inc
 }
 

mysql-test/extra/rpl_tests/rpl_trx_boundary_parser_one_step.inc

@@ -82,7 +82,7 @@ BEGIN;
 --eval INSERT INTO $table VALUES (@val)
 COMMIT;
 
-# Waiting for slave IO thread to stop
+# Waiting for replica IO thread to stop
 --source include/rpl_connection_slave.inc
 --source include/wait_for_slave_io_to_stop.inc
 

mysql-test/include/rpl_reset.inc

@@ -37,7 +37,7 @@
 #     Don't execute START REPLICA.
 #
 #   $slave_timeout
-#     Set the timeout when waiting for slave threads to stop and
+#     Set the timeout when waiting for replica threads to stop and
 #     start, respectively.  See include/wait_for_slave_param.inc
 #
 # Note:

mysql-test/include/rpl_start_slaves.inc

@@ -18,7 +18,7 @@
 #     See include/rpl_init.inc
 #
 #   $slave_timeout
-#     Set the timeout when waiting for slave threads to stop and
+#     Set the timeout when waiting for replica threads to stop and
 #     start, respectively.  See include/wait_for_slave_param.inc
 
 

mysql-test/include/rpl_stop_slaves.inc

@@ -16,7 +16,7 @@
 #     See include/stop_slave.inc
 #
 #   $slave_timeout
-#     Set the timeout when waiting for slave threads to stop.  See
+#     Set the timeout when waiting for replica threads to stop.  See
 #     include/wait_for_slave_param.inc
 #
 #   $rpl_debug

mysql-test/include/wait_for_slave_param.inc

@@ -171,7 +171,7 @@ while ($_slave_continue)
 
     if ($_show_slave_status_error_value)
     {
-      --echo **** ERROR: $slave_error_param = '$_show_slave_status_error_value' while waiting for slave parameter $slave_param $_slave_param_comparison $slave_param_value ****
+      --echo **** ERROR: $slave_error_param = '$_show_slave_status_error_value' while waiting for replica parameter $slave_param $_slave_param_comparison $slave_param_value ****
       --source include/show_rpl_debug_info.inc
       --die Error condition reached in include/wait_for_slave_param.inc
     }
@@ -188,7 +188,7 @@ while ($_slave_continue)
     {
       --let $end_to_wait=`select current_timestamp()`
 
-      --echo **** ERROR: timeout after $_slave_timeout ($end_to_wait - $start_to_wait) seconds while waiting for slave parameter $slave_param $_slave_param_comparison $slave_param_value ****
+      --echo **** ERROR: timeout after $_slave_timeout ($end_to_wait - $start_to_wait) seconds while waiting for replica parameter $slave_param $_slave_param_comparison $slave_param_value ****
       --source include/show_rpl_debug_info.inc
       --die Timeout in include/wait_for_slave_param.inc
     }

mysql-test/r/mysqlbinlog_raw_mode.result

@@ -288,7 +288,7 @@ UPDATE t1, t2 SET t1.a=10, t2.a=20;
 DROP TABLE t1,t2;
 flush logs;
 CREATE TABLE raw_mode_exit (exit_code INT);
-SELECT ((@id := id) - id) from information_schema.processlist where processlist.command like '%Binlog%' and state like '%Master has sent%';
+SELECT ((@id := id) - id) from information_schema.processlist where processlist.command like '%Binlog%' and state like '%Source has sent%';
 ((@id := id) - id)
 0
 Warnings:

mysql-test/suite/binlog/t/binlog_mysqlbinlog_raw.test

@@ -68,7 +68,7 @@ while ($iteration>0)
   --exec /bin/bash $script
 
   --echo # Step-3: Wait till dump thread transfer is completed.
-  let $wait_condition= SELECT id from information_schema.processlist where processlist.command like '%Binlog%' and state like '%Master has sent%';
+  let $wait_condition= SELECT id from information_schema.processlist where processlist.command like '%Binlog%' and state like '%Source has sent%';
   --source include/wait_condition.inc
 
   --echo # Step-4: copy binary log file that is downloaded till now before

mysql-test/suite/group_replication/r/gr_show_gr_activity.result

@@ -18,7 +18,7 @@ SET GLOBAL group_replication_group_name= "GROUP_REPLICATION_GROUP_NAME";
 START GROUP_REPLICATION;
 
 [connection server1]
-"Verifying GR activity on M1 by checking if master has sent all binlog to slave"
+"Verifying GR activity on M1 by checking if master has sent all binlog to replica"
 
 [connection server2]
 "Verifying GR activity on M2 by checking if slave has read all relay log"

mysql-test/suite/group_replication/t/gr_applier_channel_stop_with_pending_transactions.test

@@ -61,7 +61,7 @@ INSERT INTO t1 VALUES (1);
 --let $rpl_connection_name= server_2
 --source include/rpl_connection.inc
 
---let $wait_condition=SELECT COUNT(*)=1 FROM performance_schema.threads WHERE PROCESSLIST_STATE = 'Killing slave' AND PROCESSLIST_INFO = 'STOP SLAVE SQL_THREAD FOR CHANNEL "group_replication_applier"'
+--let $wait_condition=SELECT COUNT(*)=1 FROM performance_schema.threads WHERE PROCESSLIST_STATE = 'Killing replica' AND PROCESSLIST_INFO = 'STOP SLAVE SQL_THREAD FOR CHANNEL "group_replication_applier"'
 --source include/wait_condition.inc
 
 --echo

mysql-test/suite/group_replication/t/gr_show_gr_activity.test

@@ -57,11 +57,11 @@ while($i)
 # Verify GR activity on M1 using SHOW PROCESSLIST;
 --let $show_statement= SHOW PROCESSLIST;
 let $field= State;
-let $condition= = 'Master has sent all binlog to slave; waiting for more updates';
+let $condition= = 'Source has sent all binlog to replica; waiting for more updates';
 --source include/wait_show_condition.inc
 # Verify GR activity on M1 using select from INFORMATION_SCHEMA.PROCESSLIST
---echo "Verifying GR activity on M1 by checking if master has sent all binlog to slave"
---let $wait_condition= SELECT COUNT(*)=1 FROM INFORMATION_SCHEMA.PROCESSLIST WHERE STATE='Master has sent all binlog to slave; waiting for more updates';
+--echo "Verifying GR activity on M1 by checking if master has sent all binlog to replica"
+--let $wait_condition= SELECT COUNT(*)=1 FROM INFORMATION_SCHEMA.PROCESSLIST WHERE STATE='Source has sent all binlog to replica; waiting for more updates';
 --source include/wait_condition.inc
 
 --echo
@@ -70,11 +70,11 @@ let $condition= = 'Master has sent all binlog to slave; waiting for more updates
 # Verify GR activity on M2 using SHOW PROCESSLIST;
 let $show_statement= SHOW PROCESSLIST;
 let $field= State;
-let $condition= = 'Slave has read all relay log; waiting for more updates';
+let $condition= = 'Replica has read all relay log; waiting for more updates';
 --source include/wait_show_condition.inc
 # Verify GR activity on M2 using select from INFORMATION_SCHEMA.PROCESSLIST
 --echo "Verifying GR activity on M2 by checking if slave has read all relay log"
---let $wait_condition= SELECT COUNT(*)>=1 FROM INFORMATION_SCHEMA.PROCESSLIST WHERE State='Slave has read all relay log; waiting for more updates';
+--let $wait_condition= SELECT COUNT(*)>=1 FROM INFORMATION_SCHEMA.PROCESSLIST WHERE State='Replica has read all relay log; waiting for more updates';
 --source include/wait_condition.inc
 
 # Restart slave sql_thread for group replication applier channel

mysql-test/suite/ndb_rpl/t/ndb_rpl_circular_2ch_rep_status.test

@@ -116,10 +116,10 @@ select
 #let $cluster_b_master_log_pos = query_get_value("SELECT Position from mysql.ndb_binlog_index WHERE epoch >= $max_applied_cluster_b_epoch", Position, 1);
 #--echo Now change new Slave servers to new Master file + pos
 #--connection master
-#--echo Changing master to $cluster_b_master_log_file, $cluster_b_master_log_pos
+#--echo Changing replication source to $cluster_b_master_log_file, $cluster_b_master_log_pos
 #eval CHANGE MASTER TO MASTER_LOG_FILE="$cluster_b_master_log_file", MASTER_LOG_POS=$cluster_b_master_log_pos;
 #--connection slave1
-#--echo Changing master to $cluster_a_master_log_file, $cluster_a_master_log_pos
+#--echo Changing replication source to $cluster_a_master_log_file, $cluster_a_master_log_pos
 #eval CHANGE MASTER TO MASTER_LOG_FILE="$cluster_a_master_log_file", MASTER_LOG_POS=$cluster_a_master_log_pos;
 
 --echo Get current master status on Cluster A new master (next pos in Binlog)

mysql-test/suite/perfschema/r/rpl_threads.result

@@ -19,12 +19,12 @@ select COMMAND, STATE
 from INFORMATION_SCHEMA.PROCESSLIST
 where ID = @master_dump_pid;
 COMMAND	STATE
-Binlog Dump	Master has sent all binlog to slave; waiting for more updates
+Binlog Dump	Source has sent all binlog to replica; waiting for more updates
 select NAME, TYPE, PROCESSLIST_COMMAND, PROCESSLIST_STATE
 from performance_schema.threads
 where PROCESSLIST_ID = @master_dump_pid;
 NAME	TYPE	PROCESSLIST_COMMAND	PROCESSLIST_STATE
-thread/sql/one_connection	FOREGROUND	Binlog Dump	Master has sent all binlog to slave; waiting for more updates
+thread/sql/one_connection	FOREGROUND	Binlog Dump	Source has sent all binlog to replica; waiting for more updates
 select THREAD_ID from performance_schema.threads
 where PROCESSLIST_ID = @master_dump_pid
 into @master_dump_tid;
@@ -41,18 +41,18 @@ VARIABLE_NAME	VARIABLE_VALUE
 Compression_level	0
 "============ Performance schema on slave ============"
 select ID from INFORMATION_SCHEMA.PROCESSLIST
-where STATE like "Waiting for master to send event%"
+where STATE like "Waiting for source to send event%"
   into @slave_io_pid;
 select COMMAND, STATE
 from INFORMATION_SCHEMA.PROCESSLIST
 where ID = @slave_io_pid;
 COMMAND	STATE
-Connect	Waiting for master to send event
+Connect	Waiting for source to send event
 select NAME, TYPE, PROCESSLIST_COMMAND, PROCESSLIST_STATE
 from performance_schema.threads
 where PROCESSLIST_ID = @slave_io_pid;
 NAME	TYPE	PROCESSLIST_COMMAND	PROCESSLIST_STATE
-thread/sql/slave_io	FOREGROUND	Connect	Waiting for master to send event
+thread/sql/slave_io	FOREGROUND	Connect	Waiting for source to send event
 select THREAD_ID from performance_schema.threads
 where PROCESSLIST_ID = @slave_io_pid
 into @slave_io_tid;
@@ -68,18 +68,18 @@ where VARIABLE_NAME = 'Compression_level' and THREAD_ID = @slave_io_tid;
 VARIABLE_NAME	VARIABLE_VALUE
 Compression_level	0
 select ID from INFORMATION_SCHEMA.PROCESSLIST
-where STATE like "Slave has read all relay log%"
+where STATE like "Replica has read all relay log%"
   into @slave_sql_pid;
 select COMMAND, STATE
 from INFORMATION_SCHEMA.PROCESSLIST
 where ID = @slave_sql_pid;
 COMMAND	STATE
-Query	Slave has read all relay log; waiting for more updates
+Query	Replica has read all relay log; waiting for more updates
 select NAME, TYPE, PROCESSLIST_COMMAND, PROCESSLIST_STATE
 from performance_schema.threads
 where PROCESSLIST_ID = @slave_sql_pid;
 NAME	TYPE	PROCESSLIST_COMMAND	PROCESSLIST_STATE
-thread/sql/slave_sql	FOREGROUND	Query	Slave has read all relay log; waiting for more updates
+thread/sql/slave_sql	FOREGROUND	Query	Replica has read all relay log; waiting for more updates
 select THREAD_ID from performance_schema.threads
 where PROCESSLIST_ID = @slave_sql_pid
 into @slave_sql_tid;

mysql-test/suite/perfschema/t/rpl_threads.test

@@ -61,7 +61,7 @@ sync_slave_with_master;
 # Read the ID of the SLAVE IO thread,
 # as exposed in PROCESSLIST.
 select ID from INFORMATION_SCHEMA.PROCESSLIST
-  where STATE like "Waiting for master to send event%"
+  where STATE like "Waiting for source to send event%"
   into @slave_io_pid;
 
 select COMMAND, STATE
@@ -91,7 +91,7 @@ select VARIABLE_NAME, VARIABLE_VALUE
 # Read the ID of the SLAVE SQL thread,
 # as exposed in PROCESSLIST.
 select ID from INFORMATION_SCHEMA.PROCESSLIST
-  where STATE like "Slave has read all relay log%"
+  where STATE like "Replica has read all relay log%"
   into @slave_sql_pid;
 
 select COMMAND, STATE

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

@@ -5,7 +5,7 @@ Note	####	Storing MySQL user name or password information in the master info rep
 [connection master]
 create view coord_wait_list as
 SELECT id from Information_Schema.processlist
-where state like 'Waiting for Slave Worker%';
+where state like 'Waiting for Replica Worker%';
 include/stop_slave.inc
 set @save.replica_parallel_workers= @@global.replica_parallel_workers;
 set @@global.replica_parallel_workers= 4;