MediaWiki  1.30.0
JobQueueGroup Class Reference

Class to handle enqueueing of background jobs. More...

Collaboration diagram for JobQueueGroup:

Public Member Functions

 __destruct ()
 
 ack (Job $job)
 Acknowledge that a job was completed. More...
 
 deduplicateRootJob (Job $job)
 Register the "root job" of a given job into the queue for de-duplication. More...
 
 get ( $type)
 Get the job queue object for a given queue type. More...
 
 getDefaultQueueTypes ()
 Get the list of default queue types. More...
 
 getQueueSizes ()
 Get the size of the queus for a list of job types. More...
 
 getQueuesWithJobs ()
 Get the list of job types that have non-empty queues. More...
 
 getQueueTypes ()
 Get the list of queue types. More...
 
 lazyPush ( $jobs)
 Buffer jobs for insertion via push() or call it now if in CLI mode. More...
 
 pop ( $qtype=self::TYPE_DEFAULT, $flags=0, array $blacklist=[])
 Pop a job off one of the job queues. More...
 
 push ( $jobs)
 Insert jobs into the respective queues of which they belong. More...
 
 queuesHaveJobs ( $type=self::TYPE_ANY)
 Check if there are any queues with jobs (this is cached) More...
 
 waitForBackups ()
 Wait for any replica DBs or backup queue servers to catch up. More...
 

Static Public Member Functions

static destroySingletons ()
 Destroy the singleton instances. More...
 
static pushLazyJobs ()
 Push all jobs buffered via lazyPush() into their respective queues. More...
 
static singleton ( $wiki=false)
 

Public Attributes

const CACHE_VERSION = 1
 
const PROC_CACHE_TTL = 15
 
const TYPE_ANY = 2
 
const TYPE_DEFAULT = 1
 
const USE_CACHE = 1
 

Protected Member Functions

 __construct ( $wiki, $readOnlyReason)
 
 getCoalescedQueues ()
 

Protected Attributes

Job[] $bufferedJobs = []
 
ProcessCacheLRU $cache
 
array $coalescedQueues
 Map of (bucket => (queue => JobQueue, types => list of types) More...
 
bool $invalidWiki = false
 Whether the wiki is not recognized in configuration. More...
 
string bool $readOnlyReason
 Read only rationale (or false if r/w) More...
 
string $wiki
 Wiki ID. More...
 

Static Protected Attributes

static JobQueueGroup[] $instances = []
 

Private Member Functions

 assertValidJobs (array $jobs)
 
 getCachedConfigVar ( $name)
 

Detailed Description

Class to handle enqueueing of background jobs.

Since
1.21

Definition at line 29 of file JobQueueGroup.php.

Constructor & Destructor Documentation

◆ __construct()

JobQueueGroup::__construct (   $wiki,
  $readOnlyReason 
)
protected
Parameters
string$wikiWiki ID
string | bool$readOnlyReasonRead-only reason or false

Definition at line 62 of file JobQueueGroup.php.

References $readOnlyReason, $wiki, cache, and wiki.

◆ __destruct()

JobQueueGroup::__destruct ( )

Definition at line 468 of file JobQueueGroup.php.

References $type, and captcha-old\count.

Member Function Documentation

◆ ack()

JobQueueGroup::ack ( Job  $job)

Acknowledge that a job was completed.

Parameters
Job$job
Returns
void

Definition at line 281 of file JobQueueGroup.php.

References $job, and Job\getType().

◆ assertValidJobs()

JobQueueGroup::assertValidJobs ( array  $jobs)
private
Parameters
array$jobs
Exceptions
InvalidArgumentException

Definition at line 460 of file JobQueueGroup.php.

References $job, and as.

Referenced by lazyPush(), and push().

◆ deduplicateRootJob()

JobQueueGroup::deduplicateRootJob ( Job  $job)

Register the "root job" of a given job into the queue for de-duplication.

This should only be called right after all the new jobs have been inserted.

Parameters
Job$job
Returns
bool

Definition at line 292 of file JobQueueGroup.php.

References $job, and Job\getType().

◆ destroySingletons()

◆ get()

JobQueueGroup::get (   $type)

Get the job queue object for a given queue type.

Parameters
string$type
Returns
JobQueue

Definition at line 104 of file JobQueueGroup.php.

References $readOnlyReason, $type, $wgJobTypeConf, $wiki, JobQueue\factory(), global, and JobQueueAggregator\singleton().

◆ getCachedConfigVar()

JobQueueGroup::getCachedConfigVar (   $name)
private
Parameters
string$name
Returns
mixed

Definition at line 434 of file JobQueueGroup.php.

References $cache, $GLOBALS, $name, $value, $wgConf, $wiki, ObjectCache\getMainWANInstance(), global, IExpiringStore\TTL_PROC_LONG, use, wfWikiID(), and wiki.

Referenced by getQueueTypes().

◆ getCoalescedQueues()

JobQueueGroup::getCoalescedQueues ( )
protected
Returns
array

Definition at line 403 of file JobQueueGroup.php.

References $coalescedQueues, $queue, $type, $wgJobTypeConf, as, JobQueue\factory(), getQueueTypes(), global, and wiki.

Referenced by getQueueSizes(), and getQueuesWithJobs().

◆ getDefaultQueueTypes()

JobQueueGroup::getDefaultQueueTypes ( )

Get the list of default queue types.

Returns
array List of strings

Definition at line 326 of file JobQueueGroup.php.

References $wgJobTypesExcludedFromDefaultQueue, getQueueTypes(), and global.

Referenced by pop(), and queuesHaveJobs().

◆ getQueueSizes()

JobQueueGroup::getQueueSizes ( )

Get the size of the queus for a list of job types.

Returns
array Map of (job type => size)

Definition at line 384 of file JobQueueGroup.php.

References $type, as, getCoalescedQueues(), and getQueueTypes().

◆ getQueuesWithJobs()

JobQueueGroup::getQueuesWithJobs ( )

Get the list of job types that have non-empty queues.

Returns
array List of job types that have non-empty queues

Definition at line 361 of file JobQueueGroup.php.

References $type, as, getCoalescedQueues(), and getQueueTypes().

Referenced by pop(), and queuesHaveJobs().

◆ getQueueTypes()

JobQueueGroup::getQueueTypes ( )

Get the list of queue types.

Returns
array List of strings

Definition at line 317 of file JobQueueGroup.php.

References getCachedConfigVar().

Referenced by getCoalescedQueues(), getDefaultQueueTypes(), getQueueSizes(), and getQueuesWithJobs().

◆ lazyPush()

JobQueueGroup::lazyPush (   $jobs)

Buffer jobs for insertion via push() or call it now if in CLI mode.

Note that pushLazyJobs() is registered as a deferred update just before DeferredUpdates::doUpdates() in MediaWiki and JobRunner classes in order to be executed as the very last deferred update (T100085, T154425).

Parameters
IJobSpecification | IJobSpecification[]$jobsA single Job or a list of Jobs
Returns
void
Since
1.26

Definition at line 190 of file JobQueueGroup.php.

References assertValidJobs(), and push().

◆ pop()

JobQueueGroup::pop (   $qtype = self::TYPE_DEFAULT,
  $flags = 0,
array  $blacklist = [] 
)

Pop a job off one of the job queues.

This pops a job off a queue as specified by $wgJobTypeConf and updates the aggregate job queue information cache as needed.

Parameters
int | string$qtypeJobQueueGroup::TYPE_* constant or job type string
int$flagsBitfield of JobQueueGroup::USE_* constants
array$blacklistList of job types to ignore
Returns
Job|bool Returns false on failure

Definition at line 238 of file JobQueueGroup.php.

References $flags, $job, $type, as, cache, getDefaultQueueTypes(), and getQueuesWithJobs().

◆ push()

JobQueueGroup::push (   $jobs)

Insert jobs into the respective queues of which they belong.

This inserts the jobs into the queue specified by $wgJobTypeConf and updates the aggregate job queue information cache as needed.

Parameters
IJobSpecification | IJobSpecification[]$jobsA single Job or a list of Jobs
Exceptions
InvalidArgumentException
Returns
void

Definition at line 131 of file JobQueueGroup.php.

References $cache, $e, $job, $type, $wgJobTypesExcludedFromDefaultQueue, as, assertValidJobs(), cache, captcha-old\count, ObjectCache\getLocalClusterInstance(), global, MWExceptionHandler\logException(), and ProcessCacheLRU\set().

Referenced by lazyPush().

◆ pushLazyJobs()

static JobQueueGroup::pushLazyJobs ( )
static

Push all jobs buffered via lazyPush() into their respective queues.

Returns
void
Since
1.26

Definition at line 215 of file JobQueueGroup.php.

References $e, as, and MWExceptionHandler\logException().

◆ queuesHaveJobs()

JobQueueGroup::queuesHaveJobs (   $type = self::TYPE_ANY)

Check if there are any queues with jobs (this is cached)

Parameters
int$typeJobQueueGroup::TYPE_* constant
Returns
bool
Since
1.23

Definition at line 339 of file JobQueueGroup.php.

References $cache, $type, $value, captcha-old\count, ProcessCacheLRU\get(), getDefaultQueueTypes(), ObjectCache\getLocalClusterInstance(), getQueuesWithJobs(), and wiki.

◆ singleton()

◆ waitForBackups()

JobQueueGroup::waitForBackups ( )

Wait for any replica DBs or backup queue servers to catch up.

This does nothing for certain queue classes.

Returns
void

Definition at line 303 of file JobQueueGroup.php.

References $type, $wgJobTypeConf, as, and global.

Member Data Documentation

◆ $bufferedJobs

Job [] JobQueueGroup::$bufferedJobs = []
protected

Definition at line 47 of file JobQueueGroup.php.

◆ $cache

ProcessCacheLRU JobQueueGroup::$cache
protected

Definition at line 34 of file JobQueueGroup.php.

Referenced by getCachedConfigVar(), push(), and queuesHaveJobs().

◆ $coalescedQueues

array JobQueueGroup::$coalescedQueues
protected

Map of (bucket => (queue => JobQueue, types => list of types)

Definition at line 44 of file JobQueueGroup.php.

Referenced by getCoalescedQueues().

◆ $instances

JobQueueGroup [] JobQueueGroup::$instances = []
staticprotected

Definition at line 31 of file JobQueueGroup.php.

◆ $invalidWiki

bool JobQueueGroup::$invalidWiki = false
protected

Whether the wiki is not recognized in configuration.

Definition at line 41 of file JobQueueGroup.php.

◆ $readOnlyReason

string bool JobQueueGroup::$readOnlyReason
protected

Read only rationale (or false if r/w)

Definition at line 39 of file JobQueueGroup.php.

Referenced by __construct(), and get().

◆ $wiki

string JobQueueGroup::$wiki
protected

Wiki ID.

Definition at line 37 of file JobQueueGroup.php.

Referenced by __construct(), get(), getCachedConfigVar(), and singleton().

◆ CACHE_VERSION

const JobQueueGroup::CACHE_VERSION = 1

Definition at line 56 of file JobQueueGroup.php.

◆ PROC_CACHE_TTL

const JobQueueGroup::PROC_CACHE_TTL = 15

Definition at line 54 of file JobQueueGroup.php.

◆ TYPE_ANY

const JobQueueGroup::TYPE_ANY = 2

Definition at line 50 of file JobQueueGroup.php.

◆ TYPE_DEFAULT

const JobQueueGroup::TYPE_DEFAULT = 1

Definition at line 49 of file JobQueueGroup.php.

Referenced by JobRunner\run(), and MediaWiki\triggerAsyncJobs().

◆ USE_CACHE

const JobQueueGroup::USE_CACHE = 1

Definition at line 52 of file JobQueueGroup.php.

Referenced by JobRunner\run().


The documentation for this class was generated from the following file: