|
MediaWiki
REL1_23
|
Class to handle tracking information about all queues. More...

Public Member Functions | |
| getAllReadyWikiQueues () | |
| Get the list of all of the queues with jobs. | |
| notifyQueueEmpty ($wiki, $type) | |
| Mark a queue as being empty. | |
| notifyQueueNonEmpty ($wiki, $type) | |
| Mark a queue as being non-empty. | |
| purge () | |
| Purge all of the aggregator information. | |
Static Public Member Functions | |
| static | destroySingleton () |
| Destroy the singleton instance. | |
| static | singleton () |
Protected Member Functions | |
| __construct (array $params) | |
| doGetAllReadyWikiQueues () | |
| doNotifyQueueEmpty ($wiki, $type) | |
| doNotifyQueueNonEmpty ($wiki, $type) | |
| doPurge () | |
| findPendingWikiQueues () | |
| Get all databases that have a pending job. | |
Static Protected Attributes | |
| static | $instance = null |
Class to handle tracking information about all queues.
Definition at line 30 of file JobQueueAggregator.php.
| JobQueueAggregator::__construct | ( | array $ | params | ) | [protected] |
| array | $params |
Reimplemented in JobQueueAggregatorRedis, and JobQueueAggregatorMemc.
Definition at line 37 of file JobQueueAggregator.php.
| static JobQueueAggregator::destroySingleton | ( | ) | [static, final] |
| JobQueueAggregator::doGetAllReadyWikiQueues | ( | ) | [abstract, protected] |
Reimplemented in JobQueueAggregatorRedis, and JobQueueAggregatorMemc.
Referenced by getAllReadyWikiQueues().
| JobQueueAggregator::doNotifyQueueEmpty | ( | $ | wiki, |
| $ | type | ||
| ) | [abstract, protected] |
Reimplemented in JobQueueAggregatorRedis, and JobQueueAggregatorMemc.
Referenced by notifyQueueEmpty().
| JobQueueAggregator::doNotifyQueueNonEmpty | ( | $ | wiki, |
| $ | type | ||
| ) | [abstract, protected] |
Reimplemented in JobQueueAggregatorMemc, and JobQueueAggregatorRedis.
Referenced by notifyQueueNonEmpty().
| JobQueueAggregator::doPurge | ( | ) | [abstract, protected] |
Reimplemented in JobQueueAggregatorRedis, and JobQueueAggregatorMemc.
Referenced by purge().
| JobQueueAggregator::findPendingWikiQueues | ( | ) | [protected] |
Get all databases that have a pending job.
This poll all the queues and is this expensive.
Definition at line 150 of file JobQueueAggregator.php.
References array(), as, global, and JobQueueGroup\singleton().
| JobQueueAggregator::getAllReadyWikiQueues | ( | ) | [final] |
Get the list of all of the queues with jobs.
Definition at line 113 of file JobQueueAggregator.php.
References $res, doGetAllReadyWikiQueues(), wfProfileIn(), and wfProfileOut().
| JobQueueAggregator::notifyQueueEmpty | ( | $ | wiki, |
| $ | type | ||
| ) | [final] |
Mark a queue as being empty.
| string | $wiki | |
| string | $type |
Definition at line 75 of file JobQueueAggregator.php.
References $ok, doNotifyQueueEmpty(), wfProfileIn(), and wfProfileOut().
| JobQueueAggregator::notifyQueueNonEmpty | ( | $ | wiki, |
| $ | type | ||
| ) | [final] |
Mark a queue as being non-empty.
| string | $wiki | |
| string | $type |
Definition at line 95 of file JobQueueAggregator.php.
References $ok, doNotifyQueueNonEmpty(), wfProfileIn(), and wfProfileOut().
| JobQueueAggregator::purge | ( | ) | [final] |
Purge all of the aggregator information.
Definition at line 131 of file JobQueueAggregator.php.
References $res, doPurge(), wfProfileIn(), and wfProfileOut().
| static JobQueueAggregator::singleton | ( | ) | [static, final] |
| MWException |
Definition at line 44 of file JobQueueAggregator.php.
References $instance, and global.
Referenced by NextJobDB\execute().
JobQueueAggregator::$instance = null [static, protected] |
Definition at line 32 of file JobQueueAggregator.php.
Referenced by singleton().