From ff83473c818f040fcb82d31e09b224a376aedcbc Mon Sep 17 00:00:00 2001 From: Aaron Schulz Date: Sat, 2 May 2015 13:07:55 -0700 Subject: [PATCH] Made JobQueueAggregatorRedis make sure the wiki set key is up-to-date Change-Id: I84ccfd990fada80ee3005b746d33ed4473abb6d8 --- includes/jobqueue/aggregator/JobQueueAggregatorRedis.php | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/includes/jobqueue/aggregator/JobQueueAggregatorRedis.php b/includes/jobqueue/aggregator/JobQueueAggregatorRedis.php index 847dd6f4b7..6c49646b3b 100644 --- a/includes/jobqueue/aggregator/JobQueueAggregatorRedis.php +++ b/includes/jobqueue/aggregator/JobQueueAggregatorRedis.php @@ -77,6 +77,7 @@ class JobQueueAggregatorRedis extends JobQueueAggregator { try { $conn->multi( Redis::PIPELINE ); $conn->hSetNx( $this->getQueueTypesKey(), $type, 'enabled' ); + $conn->sAdd( $this->getWikiSetKey(), $wiki ); $conn->hSet( $this->getReadyQueueKey(), $this->encQueueName( $type, $wiki ), time() ); $conn->exec(); @@ -197,6 +198,13 @@ class JobQueueAggregatorRedis extends JobQueueAggregator { return "jobqueue:aggregator:h-queue-types:v2"; // global } + /** + * @return string + */ + private function getWikiSetKey() { + return "jobqueue:aggregator:s-wikis:v2"; // global + } + /** * @param string $type * @param string $wiki -- 2.20.1