Class to handle job queues stored in the DB. More...

Inheritance diagram for JobQueueDB:

Collaboration diagram for JobQueueDB:

[legend]

Public Member Functions
	doBatchPushInternal (IDatabase $dbw, array $jobs, $flags, $method)
	This function should not be called outside of JobQueueDB.

	getAllAbandonedJobs ()

	getAllAcquiredJobs ()

	getAllQueuedJobs ()

	getCoalesceLocationInternal ()
	Do not use this function outside of JobQueue/JobQueueGroup.

	recycleAndDeleteStaleJobs ()
	Recycle or destroy any jobs that have been claimed for too long.

Public Member Functions inherited from JobQueue
	ack (RunnableJob $job)
	Acknowledge that a job was completed.

	batchPush (array $jobs, $flags=0)
	Push a batch of jobs into the queue.

	deduplicateRootJob (IJobSpecification $job)
	Register the "root job" of a given job into the queue for de-duplication.

	delayedJobsEnabled ()

	delete ()
	Delete all unclaimed and delayed jobs from the queue.

	flushCaches ()
	Clear any process and persistent caches.

	getAbandonedCount ()
	Get the number of acquired jobs that can no longer be attempted.

	getAcquiredCount ()
	Get the number of acquired jobs (these are temporarily out of the queue).

	getAllDelayedJobs ()
	Get an iterator to traverse over all delayed jobs in this queue.

	getDelayedCount ()
	Get the number of delayed jobs (these are temporarily out of the queue).

	getDomain ()

	getOrder ()

	getReadOnlyReason ()

	getSiblingQueueSizes (array $types)
	Check the size of each of the given queues.

	getSiblingQueuesWithJobs (array $types)
	Check whether each of the given queues are empty.

	getSize ()
	Get the number of available (unacquired, non-delayed) jobs in the queue.

	getType ()

	getWiki ()

	isEmpty ()
	Quickly check if the queue has no available (unacquired, non-delayed) jobs.

	pop ()
	Pop a job off of the queue.

	push ( $jobs, $flags=0)
	Push one or more jobs into the queue.

	waitForBackups ()
	Wait for any replica DBs or backup servers to catch up.

Static Public Member Functions
static	selectFields ()
	Return the list of job fields that should be selected.

Static Public Member Functions inherited from JobQueue
static	factory (array $params)
	Get a job queue object of the specified type.

Protected Member Functions
	__construct (array $params)
	Additional parameters include:

	claimOldest ( $uuid)
	Reserve a row with a single UPDATE without holding row locks over RTTs...

	claimRandom ( $uuid, $rand, $gte)
	Reserve a row with a single UPDATE without holding row locks over RTTs...

	doAck (RunnableJob $job)

	doBatchPush (array $jobs, $flags)

	doDeduplicateRootJob (IJobSpecification $job)

	doDelete ()

	doFlushCaches ()

	doGetAbandonedCount ()

	doGetAcquiredCount ()

	doGetSiblingQueueSizes (array $types)
	Stable to override.

	doGetSiblingQueuesWithJobs (array $types)
	Stable to override.

	doGetSize ()

	doIsEmpty ()

	doPop ()

	doWaitForBackups ()

	getDB ( $index)

	getDBException (DBError $e)

	getJobIterator (array $conds)

	getMasterDB ()

	getReplicaDB ()

	insertFields (IJobSpecification $job, IDatabase $db)

	jobFromRow ( $row)

	optimalOrder ()
	Get the default queue order to use if configuration does not specify one.

	supportedOrders ()
	Get the allowed queue orders for configuration validation.

Protected Member Functions inherited from JobQueue
	assertNotReadOnly ()

	doGetDelayedCount ()
	Stable to override.

	doIsRootJobOldDuplicate (IJobSpecification $job)
	Stable to override.

	factoryJob ( $command, $params)

	getRootJobCacheKey ( $signature)

	incrStats ( $key, $type, $delta=1)
	Call StatsdDataFactoryInterface::updateCount() for the queue overall and for the queue type.

	isRootJobOldDuplicate (IJobSpecification $job)
	Check if the "root" job of a given job has been superseded by a newer one.

	supportsDelayedJobs ()
	Find out if delayed jobs are supported for configuration validation.

Static Protected Member Functions
static	makeBlob ( $params)

Protected Attributes
string null	$cluster
	Name of an external DB cluster or null for the local DB cluster.

IMaintainableDatabase DBError null	$conn

array null	$server
	Server configuration array.

Protected Attributes inherited from JobQueue
int	$claimTTL
	Time to live in seconds.

string	$domain
	DB domain ID.

GlobalIdGenerator	$idGenerator

int	$maxTries
	Maximum number of times to try a job.

string	$order
	Job priority for pop()

string bool	$readOnlyReason
	Read only rationale (or false if r/w)

StatsdDataFactoryInterface	$stats

string	$type
	Job type.

WANObjectCache	$wanCache

const	QOS_ATOMIC = 1

const	ROOTJOB_TTL = 2419200

Private Member Functions
	getCacheKey ( $property)

	getScopedNoTrxFlag (IDatabase $db)

Private Attributes
const	CACHE_TTL_SHORT = 30

const	MAX_AGE_PRUNE = 604800

const	MAX_JOB_RANDOM = 2147483647

const	MAX_OFFSET = 255

Detailed Description

Class to handle job queues stored in the DB.

Since: 1.21

Definition at line 36 of file JobQueueDB.php.

Constructor & Destructor Documentation

◆ __construct()

JobQueueDB::__construct ( array $params )

protected

Additional parameters include:

server : Server configuration array for Database::factory. Overrides "cluster".
cluster : The name of an external cluster registered via LBFactory. If not specified, the primary DB cluster for the wiki will be used. This can be overridden with a custom cluster so that DB handles will be retrieved via LBFactory::getExternalLB() and getConnection().
Parameters

array $params

Reimplemented from JobQueue.

Definition at line 59 of file JobQueueDB.php.

Member Function Documentation

◆ claimOldest()

JobQueueDB::claimOldest ( $uuid )

protected

Reserve a row with a single UPDATE without holding row locks over RTTs...

Parameters

string $uuid 32 char hex string

Returns: stdClass|bool Row|false

Definition at line 417 of file JobQueueDB.php.

References getMasterDB(), getScopedNoTrxFlag(), and wfDebug().

Referenced by doPop().

◆ claimRandom()

JobQueueDB::claimRandom	(	$uuid,
		$rand,
		$gte
	)

protected

Reserve a row with a single UPDATE without holding row locks over RTTs...

Parameters

string	$uuid	32 char hex string
int	$rand	Random unsigned integer (31 bits)
bool	$gte	Search for job_random >= $random (otherwise job_random <= $random)

Returns: stdClass|bool Row|false

Definition at line 339 of file JobQueueDB.php.

References getCacheKey(), getMasterDB(), and getScopedNoTrxFlag().

Referenced by doPop().

◆ doAck()

JobQueueDB::doAck ( RunnableJob $job )

protected

See also: JobQueue::doAck()

Parameters

RunnableJob $job

Exceptions

MWException

Reimplemented from JobQueue.

Definition at line 479 of file JobQueueDB.php.

References $job, getDBException(), getMasterDB(), getScopedNoTrxFlag(), and JobQueue\incrStats().

◆ doBatchPush()

JobQueueDB::doBatchPush	(	array	$jobs,
			$flags
	)

protected

See also: JobQueue::doBatchPush()

Parameters

IJobSpecification[]	$jobs
int	$flags

Exceptions

DBError|Exception

Returns: void

Reimplemented from JobQueue.

Definition at line 201 of file JobQueueDB.php.

References doBatchPushInternal(), getMasterDB(), and getScopedNoTrxFlag().

◆ doBatchPushInternal()

JobQueueDB::doBatchPushInternal	(	IDatabase	$dbw,
		array	$jobs,
			$flags,
			$method
	)

This function should not be called outside of JobQueueDB.

SecurityCheck-SQLInjection Bug in phan-taint-check handling bulk inserts

Parameters

IDatabase	$dbw
IJobSpecification[]	$jobs
int	$flags
string	$method

Exceptions

DBError

Returns: void

Definition at line 234 of file JobQueueDB.php.

References $job, $res, Wikimedia\Rdbms\IDatabase\endAtomic(), getDBException(), JobQueue\incrStats(), Wikimedia\Rdbms\IDatabase\insert(), insertFields(), Wikimedia\Rdbms\IDatabase\select(), Wikimedia\Rdbms\IDatabase\startAtomic(), and wfDebug().

Referenced by doBatchPush().

◆ doDeduplicateRootJob()

JobQueueDB::doDeduplicateRootJob ( IJobSpecification $job )

protected

See also: JobQueue::doDeduplicateRootJob()

Parameters

IJobSpecification $job

Exceptions

MWException

Returns: bool

Reimplemented from JobQueue.

Definition at line 508 of file JobQueueDB.php.

References $job, getMasterDB(), and getScopedNoTrxFlag().

◆ doDelete()

JobQueueDB::doDelete ( )

protected

See also: JobQueue::doDelete()

Returns: bool

Reimplemented from JobQueue.

Definition at line 531 of file JobQueueDB.php.

References getDBException(), getMasterDB(), and getScopedNoTrxFlag().

◆ doFlushCaches()

JobQueueDB::doFlushCaches ( )

protected

Returns: void

Reimplemented from JobQueue.

Definition at line 563 of file JobQueueDB.php.

References JobQueue\$type, and getCacheKey().

◆ doGetAbandonedCount()

JobQueueDB::doGetAbandonedCount ( )

protected

See also: JobQueue::doGetAbandonedCount()

Returns: int

Exceptions

MWException

Reimplemented from JobQueue.

Definition at line 161 of file JobQueueDB.php.

References $dbr, getCacheKey(), getDBException(), getReplicaDB(), and getScopedNoTrxFlag().

◆ doGetAcquiredCount()

JobQueueDB::doGetAcquiredCount ( )

protected

See also: JobQueue::doGetAcquiredCount()

Returns: int

Reimplemented from JobQueue.

Definition at line 128 of file JobQueueDB.php.

References $dbr, getCacheKey(), getDBException(), getReplicaDB(), and getScopedNoTrxFlag().

◆ doGetSiblingQueueSizes()

JobQueueDB::doGetSiblingQueueSizes ( array $types )

protected

Stable to override.

See also: JobQueue::getSiblingQueuesSize()

Parameters

array $types List of queues types

Returns: array|null (list of queue types) or null if unsupported

Reimplemented from JobQueue.

Definition at line 646 of file JobQueueDB.php.

References $dbr, $res, getReplicaDB(), and getScopedNoTrxFlag().

◆ doGetSiblingQueuesWithJobs()

JobQueueDB::doGetSiblingQueuesWithJobs ( array $types )

protected

Stable to override.

See also: JobQueue::getSiblingQueuesWithJobs()

Parameters

array $types List of queues types

Returns: array|null (list of queue types) or null if unsupported

Reimplemented from JobQueue.

Definition at line 627 of file JobQueueDB.php.

References $dbr, $res, getReplicaDB(), and getScopedNoTrxFlag().

◆ doGetSize()

JobQueueDB::doGetSize ( )

protected

See also: JobQueue::doGetSize()

Returns: int

Reimplemented from JobQueue.

Definition at line 100 of file JobQueueDB.php.

References $dbr, getCacheKey(), getDBException(), getReplicaDB(), and getScopedNoTrxFlag().

◆ doIsEmpty()

JobQueueDB::doIsEmpty ( )

protected

See also: JobQueue::doIsEmpty()

Returns: bool

Reimplemented from JobQueue.

Definition at line 81 of file JobQueueDB.php.

References $dbr, getDBException(), getReplicaDB(), and getScopedNoTrxFlag().

◆ doPop()

JobQueueDB::doPop ( )

protected

See also: JobQueue::doPop()

Returns: RunnableJob|bool

Reimplemented from JobQueue.

Definition at line 291 of file JobQueueDB.php.

References $job, claimOldest(), claimRandom(), getDBException(), getMasterDB(), getScopedNoTrxFlag(), JobQueue\incrStats(), jobFromRow(), recycleAndDeleteStaleJobs(), and wfRandomString().

◆ doWaitForBackups()

JobQueueDB::doWaitForBackups ( )

protected

See also: JobQueue::doWaitForBackups()

Returns: void

Reimplemented from JobQueue.

Definition at line 548 of file JobQueueDB.php.

◆ getAllAbandonedJobs()

JobQueueDB::getAllAbandonedJobs ( )

See also: JobQueue::getAllAbandonedJobs()

Returns: Iterator

Reimplemented from JobQueue.

Definition at line 589 of file JobQueueDB.php.

References getJobIterator(), and JobQueue\getType().

◆ getAllAcquiredJobs()

JobQueueDB::getAllAcquiredJobs ( )

See also: JobQueue::getAllAcquiredJobs()

Returns: Iterator

Reimplemented from JobQueue.

Definition at line 581 of file JobQueueDB.php.

References getJobIterator(), and JobQueue\getType().

◆ getAllQueuedJobs()

JobQueueDB::getAllQueuedJobs ( )

See also: JobQueue::getAllQueuedJobs()

Returns: Iterator

Reimplemented from JobQueue.

Definition at line 573 of file JobQueueDB.php.

References getJobIterator(), and JobQueue\getType().

◆ getCacheKey()

JobQueueDB::getCacheKey ( $property )

private

Parameters

string $property

Returns: string

Definition at line 853 of file JobQueueDB.php.

References $cluster.

Referenced by claimRandom(), doFlushCaches(), doGetAbandonedCount(), doGetAcquiredCount(), and doGetSize().

◆ getCoalesceLocationInternal()

JobQueueDB::getCoalesceLocationInternal ( )

Do not use this function outside of JobQueue/JobQueueGroup.

Stable to override

Returns: string

Since: 1.22

Reimplemented from JobQueue.

Definition at line 617 of file JobQueueDB.php.

◆ getDB()

JobQueueDB::getDB ( $index )

protected

Parameters

int $index (DB_REPLICA/DB_MASTER)

Returns: IMaintainableDatabase

Definition at line 799 of file JobQueueDB.php.

References $conn.

◆ getDBException()

JobQueueDB::getDBException ( DBError $e )

protected

Parameters

DBError $e

Returns: JobQueueError

Definition at line 900 of file JobQueueDB.php.

Referenced by doAck(), doBatchPushInternal(), doDelete(), doGetAbandonedCount(), doGetAcquiredCount(), doGetSize(), doIsEmpty(), doPop(), getJobIterator(), and recycleAndDeleteStaleJobs().

◆ getJobIterator()

JobQueueDB::getJobIterator ( array $conds )

protected

Parameters

array $conds Query conditions

Returns: Iterator

Definition at line 601 of file JobQueueDB.php.

References $dbr, getDBException(), getReplicaDB(), getScopedNoTrxFlag(), and jobFromRow().

Referenced by getAllAbandonedJobs(), getAllAcquiredJobs(), and getAllQueuedJobs().

◆ getMasterDB()

JobQueueDB::getMasterDB ( )

protected

Exceptions

JobQueueConnectionError

Returns: IMaintainableDatabase

Definition at line 787 of file JobQueueDB.php.

References DB_MASTER, and getDB().

Referenced by claimOldest(), claimRandom(), doAck(), doBatchPush(), doDeduplicateRootJob(), doDelete(), doPop(), and recycleAndDeleteStaleJobs().

◆ getReplicaDB()

JobQueueDB::getReplicaDB ( )

protected

Exceptions

JobQueueConnectionError

Returns: IDatabase

Definition at line 775 of file JobQueueDB.php.

References DB_REPLICA, and getDB().

Referenced by doGetAbandonedCount(), doGetAcquiredCount(), doGetSiblingQueueSizes(), doGetSiblingQueuesWithJobs(), doGetSize(), doIsEmpty(), and getJobIterator().

◆ getScopedNoTrxFlag()

JobQueueDB::getScopedNoTrxFlag ( IDatabase $db )

private

Parameters

IDatabase $db

Returns: ScopedCallback

Definition at line 838 of file JobQueueDB.php.

References Wikimedia\Rdbms\IDatabase\clearFlag(), DBO_TRX, Wikimedia\Rdbms\IDatabase\getFlag(), and Wikimedia\Rdbms\IDatabase\setFlag().

Referenced by claimOldest(), claimRandom(), doAck(), doBatchPush(), doDeduplicateRootJob(), doDelete(), doGetAbandonedCount(), doGetAcquiredCount(), doGetSiblingQueueSizes(), doGetSiblingQueuesWithJobs(), doGetSize(), doIsEmpty(), doPop(), getJobIterator(), and recycleAndDeleteStaleJobs().

◆ insertFields()

JobQueueDB::insertFields	(	IJobSpecification	$job,
		IDatabase	$db
	)

protected

Parameters

IJobSpecification	$job
IDatabase	$db

Returns: array

Definition at line 754 of file JobQueueDB.php.

References $job, makeBlob(), NS_SPECIAL, serialize(), and Wikimedia\Rdbms\IDatabase\timestamp().

Referenced by doBatchPushInternal().

◆ jobFromRow()

JobQueueDB::jobFromRow ( $row )

protected

Parameters

stdClass $row

Returns: RunnableJob|null

Definition at line 881 of file JobQueueDB.php.

References $job, JobQueue\factoryJob(), and unserialize().

Referenced by doPop(), and getJobIterator().

◆ makeBlob()

static JobQueueDB::makeBlob ( $params )

staticprotected

Parameters

array | bool $params

Returns: string

Definition at line 869 of file JobQueueDB.php.

References serialize().

Referenced by insertFields().

◆ optimalOrder()

JobQueueDB::optimalOrder ( )

protected

Get the default queue order to use if configuration does not specify one.

Returns: string One of (random, timestamp, fifo, undefined)

Reimplemented from JobQueue.

Definition at line 73 of file JobQueueDB.php.

◆ recycleAndDeleteStaleJobs()

JobQueueDB::recycleAndDeleteStaleJobs ( )

Recycle or destroy any jobs that have been claimed for too long.

Returns: int Number of jobs recycled/deleted

Definition at line 667 of file JobQueueDB.php.

References $res, JobQueue\$type, getDBException(), getMasterDB(), getScopedNoTrxFlag(), and JobQueue\incrStats().

Referenced by doPop().

◆ selectFields()

static JobQueueDB::selectFields ( )

static

Return the list of job fields that should be selected.

Since: 1.23

Returns: array

Definition at line 909 of file JobQueueDB.php.

◆ supportedOrders()

JobQueueDB::supportedOrders ( )

protected

Get the allowed queue orders for configuration validation.

Returns: array Subset of (random, timestamp, fifo, undefined)

Reimplemented from JobQueue.

Definition at line 69 of file JobQueueDB.php.

Member Data Documentation

◆ $cluster

string null JobQueueDB::$cluster

protected

Name of an external DB cluster or null for the local DB cluster.

Definition at line 48 of file JobQueueDB.php.

Referenced by getCacheKey().

◆ $conn

IMaintainableDatabase DBError null JobQueueDB::$conn

protected

Definition at line 43 of file JobQueueDB.php.

Referenced by getDB().

◆ $server

array null JobQueueDB::$server

protected

Server configuration array.

Definition at line 46 of file JobQueueDB.php.

◆ CACHE_TTL_SHORT

const JobQueueDB::CACHE_TTL_SHORT = 30

private

Definition at line 37 of file JobQueueDB.php.

◆ MAX_AGE_PRUNE

const JobQueueDB::MAX_AGE_PRUNE = 604800

private

Definition at line 38 of file JobQueueDB.php.

◆ MAX_JOB_RANDOM

const JobQueueDB::MAX_JOB_RANDOM = 2147483647

private

Definition at line 39 of file JobQueueDB.php.

◆ MAX_OFFSET

const JobQueueDB::MAX_OFFSET = 255

private

Definition at line 40 of file JobQueueDB.php.

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

includes/jobqueue/JobQueueDB.php

Public Member Functions

Static Public Member Functions

Protected Member Functions

Static Protected Member Functions

Protected Attributes

Private Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ __construct()

Member Function Documentation

◆ claimOldest()

◆ claimRandom()

◆ doAck()

◆ doBatchPush()

◆ doBatchPushInternal()

◆ doDeduplicateRootJob()

◆ doDelete()

◆ doFlushCaches()

◆ doGetAbandonedCount()

◆ doGetAcquiredCount()

◆ doGetSiblingQueueSizes()

◆ doGetSiblingQueuesWithJobs()

◆ doGetSize()

◆ doIsEmpty()

◆ doPop()

◆ doWaitForBackups()

◆ getAllAbandonedJobs()

◆ getAllAcquiredJobs()

◆ getAllQueuedJobs()

◆ getCacheKey()

◆ getCoalesceLocationInternal()

◆ getDB()

◆ getDBException()

◆ getJobIterator()

◆ getMasterDB()

◆ getReplicaDB()

◆ getScopedNoTrxFlag()

◆ insertFields()

◆ jobFromRow()

◆ makeBlob()

◆ optimalOrder()

◆ recycleAndDeleteStaleJobs()

◆ selectFields()

◆ supportedOrders()

Member Data Documentation

◆ $cluster

◆ $conn

◆ $server

◆ CACHE_TTL_SHORT

◆ MAX_AGE_PRUNE

◆ MAX_JOB_RANDOM

◆ MAX_OFFSET