JobQueueAggregator.php

Go to the documentation of this file.

<?php
abstract class JobQueueAggregator {
    protected static $instance = null;
 
    protected function __construct( array $params ) {
    }
 
    final public static function singleton() {
        global $wgJobQueueAggregator;
 
        if ( !isset( self::$instance ) ) {
            $class = $wgJobQueueAggregator['class'];
            $obj = new $class( $wgJobQueueAggregator );
            if ( !( $obj instanceof JobQueueAggregator ) ) {
                throw new MWException( "Class '$class' is not a JobQueueAggregator class." );
            }
            self::$instance = $obj;
        }
 
        return self::$instance;
    }
 
    final public static function destroySingleton() {
        self::$instance = null;
    }
 
    final public function notifyQueueEmpty( $wiki, $type ) {
        wfProfileIn( __METHOD__ );
        $ok = $this->doNotifyQueueEmpty( $wiki, $type );
        wfProfileOut( __METHOD__ );
 
        return $ok;
    }
 
    abstract protected function doNotifyQueueEmpty( $wiki, $type );
 
    final public function notifyQueueNonEmpty( $wiki, $type ) {
        wfProfileIn( __METHOD__ );
        $ok = $this->doNotifyQueueNonEmpty( $wiki, $type );
        wfProfileOut( __METHOD__ );
 
        return $ok;
    }
 
    abstract protected function doNotifyQueueNonEmpty( $wiki, $type );
 
    final public function getAllReadyWikiQueues() {
        wfProfileIn( __METHOD__ );
        $res = $this->doGetAllReadyWikiQueues();
        wfProfileOut( __METHOD__ );
 
        return $res;
    }
 
    abstract protected function doGetAllReadyWikiQueues();
 
    final public function purge() {
        wfProfileIn( __METHOD__ );
        $res = $this->doPurge();
        wfProfileOut( __METHOD__ );
 
        return $res;
    }
 
    abstract protected function doPurge();
 
    protected function findPendingWikiQueues() {
        global $wgLocalDatabases;
 
        $pendingDBs = array(); // (job type => (db list))
        foreach ( $wgLocalDatabases as $db ) {
            foreach ( JobQueueGroup::singleton( $db )->getQueuesWithJobs() as $type ) {
                $pendingDBs[$type][] = $db;
            }
        }
 
        return $pendingDBs;
    }
}