percona/percona-toolkit
1
0
Fork 0
mirror of https://github.com/percona/percona-toolkit.git synced 2025-12-20 02:20:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

PT-2340 - Support MySQL 8.4

Browse Source 
- s/slave lag/replica lag/ in reports
This commit is contained in:
Sveta Smirnova
2024-10-07 15:52:38 +03:00
parent aab0b0cd22
commit a2102efb86
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
bin/pt-archiver
View File

@@ -7285,7 +7285,7 @@ sub main {
PTDEBUG && _d('Got another row in this chunk'); PTDEBUG && _d('Got another row in this chunk');
} }
# Check slave lag and wait if slave is too far behind. # Check replica lag and wait if slave is too far behind.
# Do this check every 100 rows # Do this check every 100 rows
if (@lag_dbh && $lag_count++ % 100 == 0 ) { if (@lag_dbh && $lag_count++ % 100 == 0 ) {
foreach my $lag_server (@lag_dbh) { foreach my $lag_server (@lag_dbh) {
@@ -7294,9 +7294,9 @@ sub main {
if ( $lag_dbh ) { if ( $lag_dbh ) {
my $lag = $ms->get_replica_lag($lag_dbh); my $lag = $ms->get_replica_lag($lag_dbh);
while ( !defined $lag || $lag > $o->get('max-lag') ) { while ( !defined $lag || $lag > $o->get('max-lag') ) {
PTDEBUG && _d("Sleeping: slave lag for server '$id' is", $lag); PTDEBUG && _d("Sleeping: replica lag for server '$id' is", $lag);
if ($o->got('progress')) { if ($o->got('progress')) {
_d("Sleeping: slave lag for server '$id' is", $lag); _d("Sleeping: replica lag for server '$id' is", $lag);
} }
sleep($o->get('check-interval')); sleep($o->get('check-interval'));
$lag = $ms->get_replica_lag($lag_dbh); $lag = $ms->get_replica_lag($lag_dbh);

2
bin/pt-online-schema-change
View File

@@ -9272,7 +9272,7 @@ sub main {
} }
if ( my $dsn = $o->get('check-replica-lag') ) { if ( my $dsn = $o->get('check-replica-lag') ) {
PTDEBUG && _d('Will use --check-replica-lag to check for slave lag'); PTDEBUG && _d('Will use --check-replica-lag to check for replica lag');
my $cxn = $make_cxn->( my $cxn = $make_cxn->(
dsn_string => $o->get('check-replica-lag'), dsn_string => $o->get('check-replica-lag'),
#prev_dsn => $cxn->dsn(), #prev_dsn => $cxn->dsn(),