| Server IP : 167.235.224.122 / Your IP : 216.73.216.110 Web Server : Apache/2.4.58 (Ubuntu) System : Linux newplayground 6.8.0-136-generic #136-Ubuntu SMP PREEMPT_DYNAMIC Wed Jul 1 21:33:11 UTC 2026 aarch64 User : deploy ( 1000) PHP Version : 8.4.23 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : OFF Directory : /var/www/html/wiki/extensions/SemanticMediaWiki/src/MediaWiki/ |
Upload File : |
<?php
namespace SMW\MediaWiki;
use JobQueueGroup;
/**
* MediaWiki's JobQueue contains mostly final methods making it difficult to use
* an instance during tests hence this class provides a reduced interface with
* mockable methods.
*
* @license GPL-2.0-or-later
* @since 3.0
*
* @author mwjames
*/
class JobQueue {
/**
* @var JobQueueGroup
*/
private $jobQueueGroup;
/**
* @var bool
*/
private $disableCache = false;
/**
* @since 3.0
*
* @param JobQueueGroup $jobQueueGroup
*/
public function __construct( JobQueueGroup $jobQueueGroup ) {
$this->jobQueueGroup = $jobQueueGroup;
}
/**
* @since 3.0
*
* @param bool $disableCache
*/
public function disableCache( $disableCache = true ) {
$this->disableCache = (bool)$disableCache;
}
/**
* @since 3.0
*
* @param string $type
*
* @return bool
*/
public function isDelayedJobsEnabled( $type ) {
return $this->jobQueueGroup->get( $this->mapLegacyType( $type ) )->delayedJobsEnabled();
}
/**
* @since 3.0
*
* @param array $list
*
* @return
*/
public function runFromQueue( array $list ) {
$log = [];
foreach ( $list as $type => $amount ) {
if ( $amount == 0 || $amount === false ) {
continue;
}
$jobs = array_fill( 0, $amount, $type );
$log[$type] = [];
foreach ( $jobs as $job ) {
$j = $this->pop( $job );
if ( $j === false ) {
break;
}
$log[$type][] = $j->getTitle()->getPrefixedDBKey();
$j->run();
$this->ack( $j );
}
}
return $log;
}
/**
* @since 3.0
*
* @param string $type
*
* @return Job|bool
*/
public function pop( $type ) {
return $this->jobQueueGroup->get( $this->mapLegacyType( $type ) )->pop();
}
/**
* Acknowledge that a job was completed
*
* @since 3.0
*
* @param Job $job
*/
public function ack( \Job $job ) {
$this->jobQueueGroup->get( $job->getType() )->ack( $job );
}
/**
* @since 3.0
*
* @param string $type
*/
public function delete( $type ) {
$jobQueue = $this->jobQueueGroup->get( $this->mapLegacyType( $type ) );
$jobQueue->delete();
if ( $this->disableCache ) {
$jobQueue->flushCaches();
$this->disableCache = false;
}
}
/**
* @since 3.0
*
* @param Job|Job[] $jobs
*/
public function push( $jobs ) {
$this->jobQueueGroup->push( $jobs );
}
/**
* @since 3.0
*
* @param Job|Job[] $jobs
*/
public function lazyPush( $jobs ) {
$this->jobQueueGroup->lazyPush( $jobs );
}
/**
* @since 3.0
*
* @return array
*/
public function getQueueSizes() {
return $this->jobQueueGroup->getQueueSizes();
}
/**
* @since 3.0
*
* @param string $type
*
* @return int
*/
public function getQueueSize( $type ) {
$jobQueue = $this->jobQueueGroup->get( $this->mapLegacyType( $type ) );
if ( $this->disableCache ) {
$jobQueue->flushCaches();
$this->disableCache = false;
}
return $jobQueue->getSize();
}
/**
* @since 3.0
*
* @param string $type
*
* @return bool
*/
public function hasPendingJob( $type ) {
return $this->getQueueSize( $type ) > 0;
}
/**
* @note FIXME Remove with 3.1
* @since 3.0
*
* @param string $type
*
* @return string
*/
public static function mapLegacyType( $type ) {
// Legacy names
if ( strpos( $type, 'SMW\\' ) !== false ) {
$type = 'smw.' . lcfirst( str_replace( [ 'SMW\\', 'Job' ], '', $type ) );
}
return $type;
}
}