class JobQueueFederated extends JobQueue {
/** @var HashRing */
protected $partitionRing;
- /** @var array (partition name => JobQueue) reverse sorted by weight */
+ /** @var JobQueue[] (partition name => JobQueue) reverse sorted by weight */
protected $partitionQueues = [];
/** @var int Maximum number of partitions to try */
throw new MWException( "The given job has no defined partition name." );
}
- return $this->partitionQueues[$job->metadata['QueuePartition']]->ack( $job );
+ $this->partitionQueues[$job->metadata['QueuePartition']]->ack( $job );
}
protected function doIsRootJobOldDuplicate( Job $job ) {
- $params = $job->getRootJobParams();
- $sigature = $params['rootJobSignature'];
- $partition = $this->partitionRing->getLiveLocation( $sigature );
+ $signature = $job->getRootJobParams()['rootJobSignature'];
+ $partition = $this->partitionRing->getLiveLocation( $signature );
try {
return $this->partitionQueues[$partition]->doIsRootJobOldDuplicate( $job );
} catch ( JobQueueError $e ) {
if ( $this->partitionRing->ejectFromLiveRing( $partition, 5 ) ) {
- $partition = $this->partitionRing->getLiveLocation( $sigature );
+ $partition = $this->partitionRing->getLiveLocation( $signature );
return $this->partitionQueues[$partition]->doIsRootJobOldDuplicate( $job );
}
}
}
protected function doDeduplicateRootJob( IJobSpecification $job ) {
- $params = $job->getRootJobParams();
- $sigature = $params['rootJobSignature'];
- $partition = $this->partitionRing->getLiveLocation( $sigature );
+ $signature = $job->getRootJobParams()['rootJobSignature'];
+ $partition = $this->partitionRing->getLiveLocation( $signature );
try {
return $this->partitionQueues[$partition]->doDeduplicateRootJob( $job );
} catch ( JobQueueError $e ) {
if ( $this->partitionRing->ejectFromLiveRing( $partition, 5 ) ) {
- $partition = $this->partitionRing->getLiveLocation( $sigature );
+ $partition = $this->partitionRing->getLiveLocation( $signature );
return $this->partitionQueues[$partition]->doDeduplicateRootJob( $job );
}
}