X-Git-Url: http://git.heureux-cyclage.org/?a=blobdiff_plain;f=includes%2Fjobqueue%2FJobQueueSecondTestQueue.php;h=01f467f20b4e75e14177486f4b6b933f879cf0e8;hb=5a942200818a213c7a269aca866f767f398afc7e;hp=4e3409af73b2a1311cf12711a7a8881369875885;hpb=af1eb78810933b67e332b6887f89722215b55fd1;p=lhc%2Fweb%2Fwiklou.git diff --git a/includes/jobqueue/JobQueueSecondTestQueue.php b/includes/jobqueue/JobQueueSecondTestQueue.php index 4e3409af73..01f467f20b 100644 --- a/includes/jobqueue/JobQueueSecondTestQueue.php +++ b/includes/jobqueue/JobQueueSecondTestQueue.php @@ -27,6 +27,11 @@ class JobQueueSecondTestQueue extends JobQueue { */ private $debugQueue; + /** + * @var bool + */ + private $onlyWriteToDebugQueue; + protected function __construct( array $params ) { if ( !isset( $params['mainqueue'] ) ) { throw new MWException( "mainqueue parameter must be provided to the debug queue" ); @@ -39,6 +44,7 @@ class JobQueueSecondTestQueue extends JobQueue { $conf = [ 'wiki' => $params['wiki'], 'type' => $params['type'] ]; $this->mainQueue = JobQueue::factory( $params['mainqueue'] + $conf ); $this->debugQueue = JobQueue::factory( $params['debugqueue'] + $conf ); + $this->onlyWriteToDebugQueue = isset( $params['readonly'] ) ? $params['readonly'] : false; // We need to construct parent after creating the main and debug queue // because super constructor calls some methods we delegate to the main queue. @@ -118,7 +124,9 @@ class JobQueueSecondTestQueue extends JobQueue { * @param int $flags */ protected function doBatchPush( array $jobs, $flags ) { - $this->mainQueue->doBatchPush( $jobs, $flags ); + if ( !$this->onlyWriteToDebugQueue ) { + $this->mainQueue->doBatchPush( $jobs, $flags ); + } try { $this->debugQueue->doBatchPush( $jobs, $flags );