*
* @file
* @ingroup Maintenance
- * @author Aaron Schulz
*/
require_once __DIR__ . '/Maintenance.php';
$skipped = 0;
foreach ( $queue->getAllAbandonedJobs() as $job ) {
/** @var Job $job */
- if ( $job->getQueuedTimestamp() < $lastRepushTime ) {
+ if ( $job->getQueuedTimestamp() < wfTimestamp( TS_UNIX, $lastRepushTime ) ) {
++$skipped;
continue; // already re-pushed in prior round
}
$queue->push( $job );
++$count;
- if ( ( $count % $this->mBatchSize ) == 0 ) {
+ if ( ( $count % $this->getBatchSize() ) == 0 ) {
$queue->waitForBackups();
}
}