Change-Id: I3ef8c56e1a3e16875c7282afc4d3d0b135bd776d
if ( count( $ids ) ) {
$dbw->delete( 'job', array( 'job_id' => $ids ), __METHOD__ );
$count += $dbw->affectedRows();
+ JobQueue::incrStats( 'job-abandon', $this->type, $dbw->affectedRows() );
}
$dbw->unlock( "jobqueue-recycle-{$this->type}", __METHOD__ );
list( $released, $abandoned, $pruned ) = $res;
$count += $released + $pruned;
JobQueue::incrStats( 'job-recycle', $this->type, count( $released ) );
+ JobQueue::incrStats( 'job-abandon', $this->type, count( $abandoned ) );
}
} catch ( RedisException $e ) {
$this->throwRedisException( $this->server, $conn, $e );