MediaWiki REL1_28
JobRunner Class Reference

Job queue runner utility methods. More...

Inheritance diagram for JobRunner:
Collaboration diagram for JobRunner:

Public Member Functions

 __construct (LoggerInterface $logger=null)
 
 run (array $options)
 Run jobs of the specified number/type for the specified time.
 
 setDebugHandler ( $debug)
 
 setLogger (LoggerInterface $logger)
 

Public Attributes

const ERROR_BACKOFF_TTL = 1
 
const LAG_CHECK_PERIOD = 1.0
 
const MAX_ALLOWED_LAG = 3
 

Protected Attributes

callable null $debug
 Debug output handler.
 
 $logger
 

Private Member Functions

 checkMemoryOK ()
 Make sure that this script is not too close to the memory usage limit.
 
 commitMasterChanges (LBFactory $lbFactory, Job $job, $fnameTrxOwner)
 Issue a commit on all masters who are currently in a transaction and have made changes to the database.
 
 debugCallback ( $msg)
 Log the job message.
 
 executeJob (Job $job, LBFactory $lbFactory, $stats, $popTime)
 
 getBackoffTimeToWait (Job $job)
 
 getMaxRssKb ()
 
 loadBackoffs (array $backoffs, $mode='wait')
 Get the previous backoff expiries from persistent storage On I/O or lock acquisition failure this returns the original $backoffs.
 
 syncBackoffDeltas (array $backoffs, array &$deltas, $mode='wait')
 Merge the current backoff expiries from persistent storage.
 

Detailed Description

Job queue runner utility methods.

Since
1.24

Definition at line 37 of file JobRunner.php.

Constructor & Destructor Documentation

◆ __construct()

JobRunner::__construct ( LoggerInterface  $logger = null)
Parameters
LoggerInterface$logger

Definition at line 68 of file JobRunner.php.

References $logger, and setLogger().

Member Function Documentation

◆ checkMemoryOK()

JobRunner::checkMemoryOK ( )
private

Make sure that this script is not too close to the memory usage limit.

It is better to die in between jobs than OOM right in the middle of one.

Returns
bool

Definition at line 461 of file JobRunner.php.

References debugCallback(), and list.

Referenced by run().

◆ commitMasterChanges()

JobRunner::commitMasterChanges ( LBFactory  $lbFactory,
Job  $job,
  $fnameTrxOwner 
)
private

Issue a commit on all masters who are currently in a transaction and have made changes to the database.

It also supports sometimes waiting for the local wiki's replica DBs to catch up. See the documentation for $wgJobSerialCommitThreshold for more.

Parameters
LBFactory$lbFactory
Job$job
string$fnameTrxOwner
Exceptions
DBError

Definition at line 506 of file JobRunner.php.

References $job, $lbFactory, $time, $wgJobSerialCommitThreshold, debugCallback(), global, use, and wfWikiID().

Referenced by executeJob().

◆ debugCallback()

JobRunner::debugCallback (   $msg)
private

Log the job message.

Parameters
string$msgThe message to log

Definition at line 489 of file JobRunner.php.

References TS_DB, and wfTimestamp().

Referenced by checkMemoryOK(), commitMasterChanges(), and executeJob().

◆ executeJob()

JobRunner::executeJob ( Job  $job,
LBFactory  $lbFactory,
  $stats,
  $popTime 
)
private
Parameters
Job$job
LBFactory$lbFactory
StatsdDataFactory$stats
float$popTime
Returns
array Map of status/error/timeMs

Definition at line 263 of file JobRunner.php.

References $e, $job, $lbFactory, $status, commitMasterChanges(), debugCallback(), getMaxRssKb(), TS_UNIX, and wfTimestamp().

Referenced by run().

◆ getBackoffTimeToWait()

JobRunner::getBackoffTimeToWait ( Job  $job)
private
Parameters
Job$job
Returns
int Seconds for this runner to avoid doing more jobs of this type
See also
$wgJobBackoffThrottling

Definition at line 350 of file JobRunner.php.

References $job, $wgJobBackoffThrottling, and global.

Referenced by run().

◆ getMaxRssKb()

JobRunner::getMaxRssKb ( )
private
Returns
int|null Max memory RSS in kilobytes

Definition at line 339 of file JobRunner.php.

References wfGetRusage().

Referenced by executeJob().

◆ loadBackoffs()

JobRunner::loadBackoffs ( array  $backoffs,
  $mode = 'wait' 
)
private

Get the previous backoff expiries from persistent storage On I/O or lock acquisition failure this returns the original $backoffs.

Parameters
array$backoffsMap of (job type => UNIX timestamp)
string$modeLock wait mode - "wait" or "nowait"
Returns
array Map of (job type => backoff expiry timestamp)

Definition at line 384 of file JobRunner.php.

References $content, $timestamp, $type, as, and wfTempDir().

Referenced by syncBackoffDeltas().

◆ run()

JobRunner::run ( array  $options)

Run jobs of the specified number/type for the specified time.

The response map has a 'job' field that lists status of each job, including:

  • type : the job type
  • status : ok/failed
  • error : any error message string
  • time : the job run time in ms The response map also has:
  • backoffs : the (job type => seconds) map of backoff times
  • elapsed : the total time spent running tasks in ms
  • reached : the reason the script finished, one of (none-ready, job-limit, time-limit, memory-limit)

This method outputs status information only if a debug handler was set. Any exceptions are caught and logged, but are not reported as output.

Parameters
array$optionsMap of parameters:
  • type : the job type (or false for the default types)
  • maxJobs : maximum number of jobs to run
  • maxTime : maximum time in seconds before stopping
  • throttle : whether to respect job backoff configuration
Returns
array Summary response that can easily be JSON serialized

Definition at line 99 of file JobRunner.php.

References $e, $job, $lbFactory, $options, $response, $type, $wait, $wgJobClasses, $wgTrxProfilerLimits, checkMemoryOK(), executeJob(), false, getBackoffTimeToWait(), global, Profiler\instance(), list, JobQueueGroup\singleton(), syncBackoffDeltas(), JobQueueGroup\TYPE_DEFAULT, JobQueueGroup\USE_CACHE, wfReadOnly(), and wfWikiID().

◆ setDebugHandler()

JobRunner::setDebugHandler (   $debug)
Parameters
callable$debugOptional debug output handler

Definition at line 53 of file JobRunner.php.

References $debug.

◆ setLogger()

JobRunner::setLogger ( LoggerInterface  $logger)
Parameters
LoggerInterface$logger
Returns
void

Definition at line 61 of file JobRunner.php.

References $logger.

Referenced by __construct().

◆ syncBackoffDeltas()

JobRunner::syncBackoffDeltas ( array  $backoffs,
array $deltas,
  $mode = 'wait' 
)
private

Merge the current backoff expiries from persistent storage.

The $deltas map is set to an empty array on success. On I/O or lock acquisition failure this returns the original $backoffs.

Parameters
array$backoffsMap of (job type => UNIX timestamp)
array$deltasMap of (job type => seconds)
string$modeLock wait mode - "wait" or "nowait"
Returns
array The new backoffs account for $backoffs and the latest file data

Definition at line 421 of file JobRunner.php.

References $content, $timestamp, $type, as, loadBackoffs(), and wfTempDir().

Referenced by run().

Member Data Documentation

◆ $debug

callable null JobRunner::$debug
protected

Debug output handler.

Definition at line 39 of file JobRunner.php.

Referenced by setDebugHandler().

◆ $logger

LoggerInterface JobRunner::$logger
protected

Definition at line 44 of file JobRunner.php.

Referenced by __construct(), and setLogger().

◆ ERROR_BACKOFF_TTL

const JobRunner::ERROR_BACKOFF_TTL = 1

Definition at line 48 of file JobRunner.php.

◆ LAG_CHECK_PERIOD

const JobRunner::LAG_CHECK_PERIOD = 1.0

Definition at line 47 of file JobRunner.php.

◆ MAX_ALLOWED_LAG

const JobRunner::MAX_ALLOWED_LAG = 3

Definition at line 46 of file JobRunner.php.


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