← Back to branch summary

~percona-toolkit-dev/percona-toolkit/cant-nibble-bug-918056

« back to all changes in this revision

Viewing changes to lib/ReplicaLagWaiter.pm

  • Committer: Daniel Nichter
  • Date: 2012-01-19 19:46:56 UTC
  • Revision ID: daniel@percona.com-20120119194656-3l1nzgtq1p7xvigo
Replace MKDEBUG with PTDEBUG in modules.

Show diffs side-by-side

added added

removed removed

Lines of Context:
lib/ReplicaLagWaiter.pm
25
25
use strict;
26
26
use warnings FATAL => 'all';
27
27
use English qw(-no_match_vars);
28
 
use constant MKDEBUG => $ENV{MKDEBUG} || 0;
 
28
use constant PTDEBUG => $ENV{PTDEBUG} || 0;
29
29
 
30
30
use Time::HiRes qw(sleep time);
31
31
use Data::Dumper;
112
112
   # First check all slaves.
113
113
   my @lagged_slaves = map { {cxn=>$_, lag=>undef} } @$slaves;  
114
114
   while ( $oktorun->() && @lagged_slaves ) {
115
 
      MKDEBUG && _d('Checking slave lag');
 
115
      PTDEBUG && _d('Checking slave lag');
116
116
      for my $i ( 0..$#lagged_slaves ) {
117
117
         my $lag = $get_lag->($lagged_slaves[$i]->{cxn});
118
 
         MKDEBUG && _d($lagged_slaves[$i]->{cxn}->name(),
 
118
         PTDEBUG && _d($lagged_slaves[$i]->{cxn}->name(),
119
119
            'slave lag:', $lag);
120
120
         if ( !defined $lag || $lag > $max_lag ) {
121
121
            $lagged_slaves[$i]->{lag} = $lag;
135
135
            :                                           1;
136
136
         } @lagged_slaves;
137
137
         $worst = $lagged_slaves[0];
138
 
         MKDEBUG && _d(scalar @lagged_slaves, 'slaves are lagging, worst:',
 
138
         PTDEBUG && _d(scalar @lagged_slaves, 'slaves are lagging, worst:',
139
139
            $worst->{lag}, 'on', Dumper($worst->{cxn}->dsn()));
140
140
 
141
141
         if ( $pr ) {
149
149
            );
150
150
         }
151
151
 
152
 
         MKDEBUG && _d('Calling sleep callback');
 
152
         PTDEBUG && _d('Calling sleep callback');
153
153
         $sleep->($worst->{cxn}, $worst->{lag});
154
154
      }
155
155
   }
156
156
 
157
 
   MKDEBUG && _d('All slaves caught up');
 
157
   PTDEBUG && _d('All slaves caught up');
158
158
   return;
159
159
}
160
160