From: Aaron Schulz <aschulz@wikimedia.org>
Date: Sat, 2 May 2015 20:07:55 +0000 (-0700)
Subject: Made JobQueueAggregatorRedis make sure the wiki set key is up-to-date
X-Git-Tag: 1.31.0-rc.0~11487^2
X-Git-Url: http://git.cyclocoop.org/%7B%24admin_url%7Dcompta/comptes/journal.php?a=commitdiff_plain;h=ff83473c818f040fcb82d31e09b224a376aedcbc;p=lhc%2Fweb%2Fwiklou.git

Made JobQueueAggregatorRedis make sure the wiki set key is up-to-date

Change-Id: I84ccfd990fada80ee3005b746d33ed4473abb6d8
---

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