dépôts
/
lhc
/
web
/
wiklou.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Removed unused variable in doFlushCaches()
[lhc/web/wiklou.git]
/
includes
/
jobqueue
/
JobQueueFederated.php
diff --git
a/includes/jobqueue/JobQueueFederated.php
b/includes/jobqueue/JobQueueFederated.php
index
d985d44
..
b86819e
100644
(file)
--- a/
includes/jobqueue/JobQueueFederated.php
+++ b/
includes/jobqueue/JobQueueFederated.php
@@
-386,14
+386,6
@@
class JobQueueFederated extends JobQueue {
}
protected function doFlushCaches() {
}
protected function doFlushCaches() {
- static $types = array(
- 'empty',
- 'size',
- 'acquiredcount',
- 'delayedcount',
- 'abandonedcount'
- );
-
/** @var JobQueue $queue */
foreach ( $this->partitionQueues as $queue ) {
$queue->doFlushCaches();
/** @var JobQueue $queue */
foreach ( $this->partitionQueues as $queue ) {
$queue->doFlushCaches();
@@
-422,6
+414,17
@@
class JobQueueFederated extends JobQueue {
return $iterator;
}
return $iterator;
}
+ public function getAllAcquiredJobs() {
+ $iterator = new AppendIterator();
+
+ /** @var JobQueue $queue */
+ foreach ( $this->partitionQueues as $queue ) {
+ $iterator->append( $queue->getAllAcquiredJobs() );
+ }
+
+ return $iterator;
+ }
+
public function getAllAbandonedJobs() {
$iterator = new AppendIterator();
public function getAllAbandonedJobs() {
$iterator = new AppendIterator();