summaryrefslogtreecommitdiff
path: root/includes/jobqueue/aggregator/JobQueueAggregatorRedis.php
diff options
context:
space:
mode:
Diffstat (limited to 'includes/jobqueue/aggregator/JobQueueAggregatorRedis.php')
-rw-r--r--includes/jobqueue/aggregator/JobQueueAggregatorRedis.php8
1 files changed, 8 insertions, 0 deletions
diff --git a/includes/jobqueue/aggregator/JobQueueAggregatorRedis.php b/includes/jobqueue/aggregator/JobQueueAggregatorRedis.php
index 847dd6f4..6c49646b 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();
@@ -198,6 +199,13 @@ class JobQueueAggregatorRedis extends JobQueueAggregator {
}
/**
+ * @return string
+ */
+ private function getWikiSetKey() {
+ return "jobqueue:aggregator:s-wikis:v2"; // global
+ }
+
+ /**
* @param string $type
* @param string $wiki
* @return string