diff options
author | Pierre Schmitz <pierre@archlinux.de> | 2015-12-17 09:15:42 +0100 |
---|---|---|
committer | Pierre Schmitz <pierre@archlinux.de> | 2015-12-17 09:44:51 +0100 |
commit | a1789ddde42033f1b05cc4929491214ee6e79383 (patch) | |
tree | 63615735c4ddffaaabf2428946bb26f90899f7bf /includes/jobqueue/aggregator | |
parent | 9e06a62f265e3a2aaabecc598d4bc617e06fa32d (diff) |
Update to MediaWiki 1.26.0
Diffstat (limited to 'includes/jobqueue/aggregator')
-rw-r--r-- | includes/jobqueue/aggregator/JobQueueAggregator.php | 2 | ||||
-rw-r--r-- | includes/jobqueue/aggregator/JobQueueAggregatorRedis.php | 8 |
2 files changed, 9 insertions, 1 deletions
diff --git a/includes/jobqueue/aggregator/JobQueueAggregator.php b/includes/jobqueue/aggregator/JobQueueAggregator.php index febc277a..aa02d1fa 100644 --- a/includes/jobqueue/aggregator/JobQueueAggregator.php +++ b/includes/jobqueue/aggregator/JobQueueAggregator.php @@ -169,4 +169,4 @@ class JobQueueAggregatorNull extends JobQueueAggregator { protected function doPurge() { return true; } -}
\ No newline at end of file +} 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 |