X-Git-Url: http://git.cyclocoop.org/?a=blobdiff_plain;f=maintenance%2FcopyJobQueue.php;h=c5a78278f7fda245ec62c87923618e2151d4c9f0;hb=1d00b757fc894d93624cd53121aa274118f17cb2;hp=c91264ce2131e008109c3f8c317438edd75e5ad4;hpb=fcda8ed55cc25b7f5cd045c6945a1f8b85344205;p=lhc%2Fweb%2Fwiklou.git diff --git a/maintenance/copyJobQueue.php b/maintenance/copyJobQueue.php index c91264ce21..c5a78278f7 100644 --- a/maintenance/copyJobQueue.php +++ b/maintenance/copyJobQueue.php @@ -21,7 +21,7 @@ * @ingroup Maintenance */ -require_once( __DIR__ . '/Maintenance.php' ); +require_once __DIR__ . '/Maintenance.php'; /** * Copy all jobs from one job queue system to another. @@ -78,17 +78,15 @@ class CopyJobQueue extends Maintenance { ++$total; $batch[] = $job; if ( count( $batch ) >= $this->mBatchSize ) { - if ( $dst->push( $batch ) ) { - $totalOK += count( $batch ); - } + $dst->push( $batch ); + $totalOK += count( $batch ); $batch = array(); $dst->waitForBackups(); } } if ( count( $batch ) ) { - if ( $dst->push( $batch ) ) { - $totalOK += count( $batch ); - } + $dst->push( $batch ); + $totalOK += count( $batch ); $dst->waitForBackups(); } return array( $total, $totalOK );