percona/percona-toolkit
1
0
Fork 0
mirror of https://github.com/percona/percona-toolkit.git synced 2025-09-11 13:40:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

pt-heartbeat sometimes failed with --sleep due to race condition

Browse Source
This commit is contained in:
Frank Cizmich
2015-03-30 19:27:46 -03:00
parent 1ccd6e528a
commit 33956074af
1 changed files with 8 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
bin/pt-heartbeat
View File

@@ -5286,13 +5286,14 @@ sub main {
) { ) {
eval { eval {
my $next_interval = $get_next_interval->(); my $next_interval = $get_next_interval->();
if ( time >= $next_interval ) { my $time = time;
if ( $time >= $next_interval ) {
do { $next_interval = $get_next_interval->() } do { $next_interval = $get_next_interval->() }
until $next_interval > time; until $next_interval > $time;
PTDEBUG && _d("Missed last interval; next interval:", PTDEBUG && _d("Missed last interval; next interval:",
ts($next_interval)); ts($next_interval));
} }
sleep $next_interval - time; sleep $next_interval - $time;
PTDEBUG && _d('Woke up at', ts(time)); PTDEBUG && _d('Woke up at', ts(time));
# Connect or reconnect if necessary. # Connect or reconnect if necessary.
@@ -5419,13 +5420,14 @@ sub check_delay {
PTDEBUG && _d('Checking slave', $dp->as_string($dsn)); PTDEBUG && _d('Checking slave', $dp->as_string($dsn));
my $next_interval = $get_next_interval->(); my $next_interval = $get_next_interval->();
if ( time >= $next_interval ) { my $time = time;
if ( $time >= $next_interval ) {
do { $next_interval = $get_next_interval->() } do { $next_interval = $get_next_interval->() }
until $next_interval > time; until $next_interval > $time;
PTDEBUG && _d("Missed last interval; next interval:", PTDEBUG && _d("Missed last interval; next interval:",
ts($next_interval)); ts($next_interval));
} }
sleep $next_interval - time; sleep $next_interval - $time;
PTDEBUG && _d('Woke up at', ts(time)); PTDEBUG && _d('Woke up at', ts(time));
my ($delay, $hostname, $master_server_id) = $get_delay->($sth); my ($delay, $hostname, $master_server_id) = $get_delay->($sth);