MediaWiki
1.33.1
|
Class to handle job queues stored in PHP memory for testing. More...
Public Member Functions | |
__construct (array $params) | |
getAllAcquiredJobs () | |
getAllQueuedJobs () | |
jobFromSpecInternal (IJobSpecification $spec) | |
Public Member Functions inherited from JobQueue | |
ack (Job $job) | |
Acknowledge that a job was completed. More... | |
batchPush (array $jobs, $flags=0) | |
Push a batch of jobs into the queue. More... | |
deduplicateRootJob (IJobSpecification $job) | |
Register the "root job" of a given job into the queue for de-duplication. More... | |
delayedJobsEnabled () | |
delete () | |
Deleted all unclaimed and delayed jobs from the queue. More... | |
flushCaches () | |
Clear any process and persistent caches. More... | |
getAbandonedCount () | |
Get the number of acquired jobs that can no longer be attempted. More... | |
getAcquiredCount () | |
Get the number of acquired jobs (these are temporarily out of the queue). More... | |
getAllAbandonedJobs () | |
Get an iterator to traverse over all abandoned jobs in this queue. More... | |
getAllDelayedJobs () | |
Get an iterator to traverse over all delayed jobs in this queue. More... | |
getCoalesceLocationInternal () | |
Do not use this function outside of JobQueue/JobQueueGroup. More... | |
getDelayedCount () | |
Get the number of delayed jobs (these are temporarily out of the queue). More... | |
getDomain () | |
getOrder () | |
getReadOnlyReason () | |
getSiblingQueueSizes (array $types) | |
Check the size of each of the given queues. More... | |
getSiblingQueuesWithJobs (array $types) | |
Check whether each of the given queues are empty. More... | |
getSize () | |
Get the number of available (unacquired, non-delayed) jobs in the queue. More... | |
getType () | |
getWiki () | |
isEmpty () | |
Quickly check if the queue has no available (unacquired, non-delayed) jobs. More... | |
pop () | |
Pop a job off of the queue. More... | |
push ( $jobs, $flags=0) | |
Push one or more jobs into the queue. More... | |
waitForBackups () | |
Wait for any replica DBs or backup servers to catch up. More... | |
Protected Member Functions | |
doAck (Job $job) | |
doBatchPush (array $jobs, $flags) | |
doDelete () | |
doGetAcquiredCount () | |
doGetSize () | |
doIsEmpty () | |
doPop () | |
optimalOrder () | |
supportedOrders () | |
Protected Member Functions inherited from JobQueue | |
assertNotReadOnly () | |
doDeduplicateRootJob (IJobSpecification $job) | |
doFlushCaches () | |
doGetAbandonedCount () | |
doGetDelayedCount () | |
doGetSiblingQueueSizes (array $types) | |
doGetSiblingQueuesWithJobs (array $types) | |
doIsRootJobOldDuplicate (Job $job) | |
doWaitForBackups () | |
getRootJobCacheKey ( $signature) | |
incrStats ( $key, $type, $delta=1) | |
Call wfIncrStats() for the queue overall and for the queue type. More... | |
isRootJobOldDuplicate (Job $job) | |
Check if the "root" job of a given job has been superseded by a newer one. More... | |
supportsDelayedJobs () | |
Find out if delayed jobs are supported for configuration validation. More... | |
Static Protected Attributes | |
static array[] | $data = [] |
Private Member Functions | |
& | getQueueData ( $field, $init=null) |
Additional Inherited Members | |
Static Public Member Functions inherited from JobQueue | |
static | factory (array $params) |
Get a job queue object of the specified type. More... | |
Public Attributes inherited from JobQueue | |
const | QOS_ATOMIC = 1 |
const | ROOTJOB_TTL = 2419200 |
Protected Attributes inherited from JobQueue | |
int | $claimTTL |
Time to live in seconds. More... | |
string | $domain |
DB domain ID. More... | |
BagOStuff | $dupCache |
int | $maxTries |
Maximum number of times to try a job. More... | |
string | $order |
Job priority for pop() More... | |
string bool | $readOnlyReason |
Read only rationale (or false if r/w) More... | |
StatsdDataFactoryInterface | $stats |
string | $type |
Job type. More... | |
Class to handle job queues stored in PHP memory for testing.
JobQueueGroup does not remember every queue instance, so statically track it here
Definition at line 31 of file JobQueueMemory.php.
JobQueueMemory::__construct | ( | array | $params | ) |
array | $params |
JobQueueError |
Reimplemented from JobQueue.
Definition at line 35 of file JobQueueMemory.php.
References $params.
|
protected |
Job | $job |
Reimplemented from JobQueue.
Definition at line 148 of file JobQueueMemory.php.
References $job, JobQueue\getAcquiredCount(), and getQueueData().
|
protected |
IJobSpecification[] | $jobs | |
int | $flags |
Reimplemented from JobQueue.
Definition at line 47 of file JobQueueMemory.php.
References $job, as, getQueueData(), and serialize().
|
protected |
Reimplemented from JobQueue.
Definition at line 160 of file JobQueueMemory.php.
|
protected |
Reimplemented from JobQueue.
Definition at line 105 of file JobQueueMemory.php.
References captcha-old\count, and getQueueData().
|
protected |
Reimplemented from JobQueue.
Definition at line 94 of file JobQueueMemory.php.
References captcha-old\count, and getQueueData().
Referenced by doIsEmpty(), and doPop().
|
protected |
Reimplemented from JobQueue.
Definition at line 85 of file JobQueueMemory.php.
References doGetSize().
|
protected |
Reimplemented from JobQueue.
Definition at line 116 of file JobQueueMemory.php.
References $job, doGetSize(), getQueueData(), jobFromSpecInternal(), and key.
JobQueueMemory::getAllAcquiredJobs | ( | ) |
Reimplemented from JobQueue.
Definition at line 193 of file JobQueueMemory.php.
References $value, getQueueData(), and jobFromSpecInternal().
JobQueueMemory::getAllQueuedJobs | ( | ) |
Reimplemented from JobQueue.
Definition at line 174 of file JobQueueMemory.php.
References $value, getQueueData(), and jobFromSpecInternal().
|
private |
string | $field | |
mixed | $init |
Definition at line 222 of file JobQueueMemory.php.
References $data, JobQueue\$domain, JobQueue\$type, and type.
Referenced by doAck(), doBatchPush(), doGetAcquiredCount(), doGetSize(), doPop(), getAllAcquiredJobs(), and getAllQueuedJobs().
JobQueueMemory::jobFromSpecInternal | ( | IJobSpecification | $spec | ) |
IJobSpecification | $spec |
Definition at line 212 of file JobQueueMemory.php.
References Job\factory(), IJobSpecification\getParams(), IJobSpecification\getTitle(), and IJobSpecification\getType().
Referenced by doPop(), getAllAcquiredJobs(), and getAllQueuedJobs().
|
protected |
Reimplemented from JobQueue.
Definition at line 76 of file JobQueueMemory.php.
|
protected |
Reimplemented from JobQueue.
Definition at line 67 of file JobQueueMemory.php.
|
staticprotected |
Definition at line 33 of file JobQueueMemory.php.