~percona-toolkit-dev/percona-toolkit/release-2.2.2

« back to all changes in this revision

Viewing changes to bin/pt-upgrade

  • Committer: Brian Fraser
  • Date: 2013-04-19 23:26:48 UTC
  • Revision ID: brian.fraser@percona.com-20130419232648-mjnd4rt9k4xldmjc
BuildĀ percona-toolkit-2.2.2

Show diffs side-by-side

added added

removed removed

Lines of Context:
60
60
# ###########################################################################
61
61
{
62
62
package Percona::Toolkit;
63
 
our $VERSION = '2.2.1';
 
63
our $VERSION = '2.2.2';
64
64
 
65
65
1;
66
66
}
2500
2500
   return $self->{hostname} || $self->{dsn_name} || 'unknown host';
2501
2501
}
2502
2502
 
 
2503
sub remove_duplicate_cxns {
 
2504
   my ($self, %args) = @_;
 
2505
   my @cxns     = @{$args{cxns}};
 
2506
   my $seen_ids = $args{seen_ids} || {};
 
2507
   PTDEBUG && _d("Removing duplicates from ", join(" ", map { $_->name } @cxns));
 
2508
   my @trimmed_cxns;
 
2509
 
 
2510
   for my $cxn ( @cxns ) {
 
2511
      my $dbh  = $cxn->dbh();
 
2512
      my $sql  = q{SELECT @@server_id};
 
2513
      PTDEBUG && _d($sql);
 
2514
      my ($id) = $dbh->selectrow_array($sql);
 
2515
      PTDEBUG && _d('Server ID for ', $cxn->name, ': ', $id);
 
2516
 
 
2517
      if ( ! $seen_ids->{$id}++ ) {
 
2518
         push @trimmed_cxns, $cxn
 
2519
      }
 
2520
      else {
 
2521
         PTDEBUG && _d("Removing ", $cxn->name,
 
2522
                       ", ID ", $id, ", because we've already seen it");
 
2523
      }
 
2524
   }
 
2525
 
 
2526
   return \@trimmed_cxns;
 
2527
}
 
2528
 
2503
2529
sub DESTROY {
2504
2530
   my ($self) = @_;
2505
2531
 
11142
11168
 
11143
11169
=head1 VERSION
11144
11170
 
11145
 
pt-upgrade 2.2.1
 
11171
pt-upgrade 2.2.2
11146
11172
 
11147
11173
=cut