MediaWiki  1.29.1
DeferredUpdates.php
Go to the documentation of this file.
1 <?php
26 
55  private static $preSendUpdates = [];
57  private static $postSendUpdates = [];
58 
59  const ALL = 0; // all updates; in web requests, use only after flushing the output buffer
60  const PRESEND = 1; // for updates that should run before flushing output buffer
61  const POSTSEND = 2; // for updates that should run after flushing output buffer
62 
63  const BIG_QUEUE_SIZE = 100;
64 
66  private static $executeContext;
67 
76  public static function addUpdate( DeferrableUpdate $update, $stage = self::POSTSEND ) {
78 
79  if ( self::$executeContext && self::$executeContext['stage'] >= $stage ) {
80  // This is a sub-DeferredUpdate; run it right after its parent update.
81  // Also, while post-send updates are running, push any "pre-send" jobs to the
82  // active post-send queue to make sure they get run this round (or at all).
83  self::$executeContext['subqueue'][] = $update;
84 
85  return;
86  }
87 
88  if ( $stage === self::PRESEND ) {
89  self::push( self::$preSendUpdates, $update );
90  } else {
91  self::push( self::$postSendUpdates, $update );
92  }
93 
94  // Try to run the updates now if in CLI mode and no transaction is active.
95  // This covers scripts that don't/barely use the DB but make updates to other stores.
96  if ( $wgCommandLineMode ) {
98  }
99  }
100 
111  public static function addCallableUpdate(
112  $callable, $stage = self::POSTSEND, IDatabase $dbw = null
113  ) {
114  self::addUpdate( new MWCallableUpdate( $callable, wfGetCaller(), $dbw ), $stage );
115  }
116 
123  public static function doUpdates( $mode = 'run', $stage = self::ALL ) {
124  $stageEffective = ( $stage === self::ALL ) ? self::POSTSEND : $stage;
125 
126  if ( $stage === self::ALL || $stage === self::PRESEND ) {
127  self::execute( self::$preSendUpdates, $mode, $stageEffective );
128  }
129 
130  if ( $stage === self::ALL || $stage == self::POSTSEND ) {
131  self::execute( self::$postSendUpdates, $mode, $stageEffective );
132  }
133  }
134 
140  public static function setImmediateMode( $value ) {
141  wfDeprecated( __METHOD__, '1.29' );
142  }
143 
148  private static function push( array &$queue, DeferrableUpdate $update ) {
149  if ( $update instanceof MergeableUpdate ) {
150  $class = get_class( $update ); // fully-qualified class
151  if ( isset( $queue[$class] ) ) {
153  $existingUpdate = $queue[$class];
154  $existingUpdate->merge( $update );
155  } else {
156  $queue[$class] = $update;
157  }
158  } else {
159  $queue[] = $update;
160  }
161  }
162 
172  protected static function execute( array &$queue, $mode, $stage ) {
173  $services = MediaWikiServices::getInstance();
174  $stats = $services->getStatsdDataFactory();
175  $lbFactory = $services->getDBLoadBalancerFactory();
176  $method = RequestContext::getMain()->getRequest()->getMethod();
177 
178  $ticket = $lbFactory->getEmptyTransactionTicket( __METHOD__ );
179 
181  $reportableError = null;
183  $updates = $queue;
184 
185  // Keep doing rounds of updates until none get enqueued...
186  while ( $updates ) {
187  $queue = []; // clear the queue
188 
189  // Order will be DataUpdate followed by generic DeferrableUpdate tasks
190  $updatesByType = [ 'data' => [], 'generic' => [] ];
191  foreach ( $updates as $du ) {
192  if ( $du instanceof DataUpdate ) {
193  $du->setTransactionTicket( $ticket );
194  $updatesByType['data'][] = $du;
195  } else {
196  $updatesByType['generic'][] = $du;
197  }
198 
199  $name = ( $du instanceof DeferrableCallback )
200  ? get_class( $du ) . '-' . $du->getOrigin()
201  : get_class( $du );
202  $stats->increment( 'deferred_updates.' . $method . '.' . $name );
203  }
204 
205  // Execute all remaining tasks...
206  foreach ( $updatesByType as $updatesForType ) {
207  foreach ( $updatesForType as $update ) {
208  self::$executeContext = [ 'stage' => $stage, 'subqueue' => [] ];
210  $guiError = self::runUpdate( $update, $lbFactory, $mode, $stage );
211  $reportableError = $reportableError ?: $guiError;
212  // Do the subqueue updates for $update until there are none
213  while ( self::$executeContext['subqueue'] ) {
214  $subUpdate = reset( self::$executeContext['subqueue'] );
215  $firstKey = key( self::$executeContext['subqueue'] );
216  unset( self::$executeContext['subqueue'][$firstKey] );
217 
218  if ( $subUpdate instanceof DataUpdate ) {
219  $subUpdate->setTransactionTicket( $ticket );
220  }
221 
222  $guiError = self::runUpdate( $subUpdate, $lbFactory, $mode, $stage );
223  $reportableError = $reportableError ?: $guiError;
224  }
225  self::$executeContext = null;
226  }
227  }
228 
229  $updates = $queue; // new snapshot of queue (check for new entries)
230  }
231 
232  if ( $reportableError ) {
233  throw $reportableError; // throw the first of any GUI errors
234  }
235  }
236 
244  private static function runUpdate(
245  DeferrableUpdate $update, LBFactory $lbFactory, $mode, $stage
246  ) {
247  $guiError = null;
248  try {
249  if ( $mode === 'enqueue' && $update instanceof EnqueueableDataUpdate ) {
250  // Run only the job enqueue logic to complete the update later
251  $spec = $update->getAsJobSpecification();
252  JobQueueGroup::singleton( $spec['wiki'] )->push( $spec['job'] );
253  } else {
254  // Run the bulk of the update now
255  $fnameTrxOwner = get_class( $update ) . '::doUpdate';
256  $lbFactory->beginMasterChanges( $fnameTrxOwner );
257  $update->doUpdate();
258  $lbFactory->commitMasterChanges( $fnameTrxOwner );
259  }
260  } catch ( Exception $e ) {
261  // Reporting GUI exceptions does not work post-send
262  if ( $e instanceof ErrorPageError && $stage === self::PRESEND ) {
263  $guiError = $e;
264  }
266  }
267 
268  return $guiError;
269  }
270 
281  public static function tryOpportunisticExecute( $mode = 'run' ) {
282  // execute() loop is already running
283  if ( self::$executeContext ) {
284  return false;
285  }
286 
287  // Avoiding running updates without them having outer scope
288  if ( !self::areDatabaseTransactionsActive() ) {
289  self::doUpdates( $mode );
290  return true;
291  }
292 
293  if ( self::pendingUpdatesCount() >= self::BIG_QUEUE_SIZE ) {
294  // If we cannot run the updates with outer transaction context, try to
295  // at least enqueue all the updates that support queueing to job queue
296  self::$preSendUpdates = self::enqueueUpdates( self::$preSendUpdates );
297  self::$postSendUpdates = self::enqueueUpdates( self::$postSendUpdates );
298  }
299 
300  return !self::pendingUpdatesCount();
301  }
302 
309  private static function enqueueUpdates( array $updates ) {
310  $remaining = [];
311 
312  foreach ( $updates as $update ) {
313  if ( $update instanceof EnqueueableDataUpdate ) {
314  $spec = $update->getAsJobSpecification();
315  JobQueueGroup::singleton( $spec['wiki'] )->push( $spec['job'] );
316  } else {
317  $remaining[] = $update;
318  }
319  }
320 
321  return $remaining;
322  }
323 
328  public static function pendingUpdatesCount() {
329  return count( self::$preSendUpdates ) + count( self::$postSendUpdates );
330  }
331 
336  public static function getPendingUpdates( $stage = self::ALL ) {
337  $updates = [];
338  if ( $stage === self::ALL || $stage === self::PRESEND ) {
339  $updates = array_merge( $updates, self::$preSendUpdates );
340  }
341  if ( $stage === self::ALL || $stage === self::POSTSEND ) {
342  $updates = array_merge( $updates, self::$postSendUpdates );
343  }
344  return $updates;
345  }
346 
351  public static function clearPendingUpdates() {
352  self::$preSendUpdates = [];
353  self::$postSendUpdates = [];
354  }
355 
359  private static function areDatabaseTransactionsActive() {
360  $lbFactory = MediaWikiServices::getInstance()->getDBLoadBalancerFactory();
361  if ( $lbFactory->hasTransactionRound() ) {
362  return true;
363  }
364 
365  $connsBusy = false;
366  $lbFactory->forEachLB( function ( LoadBalancer $lb ) use ( &$connsBusy ) {
367  $lb->forEachOpenMasterConnection( function ( IDatabase $conn ) use ( &$connsBusy ) {
368  if ( $conn->writesOrCallbacksPending() || $conn->explicitTrxActive() ) {
369  $connsBusy = true;
370  }
371  } );
372  } );
373 
374  return $connsBusy;
375  }
376 }
DeferredUpdates\ALL
const ALL
Definition: DeferredUpdates.php:59
captcha-old.count
count
Definition: captcha-old.py:225
MergeableUpdate
Interface that deferrable updates can implement.
Definition: MergeableUpdate.php:9
use
as see the revision history and available at free of to any person obtaining a copy of this software and associated documentation to deal in the Software without including without limitation the rights to use
Definition: MIT-LICENSE.txt:10
DeferrableUpdate\doUpdate
doUpdate()
Perform the actual work.
DeferredUpdates\addUpdate
static addUpdate(DeferrableUpdate $update, $stage=self::POSTSEND)
Add an update to the deferred list to be run later by execute()
Definition: DeferredUpdates.php:76
Wikimedia\Rdbms\LoadBalancer\forEachOpenMasterConnection
forEachOpenMasterConnection( $callback, array $params=[])
Call a function with each open connection object to a master.
Definition: LoadBalancer.php:1483
$name
Allows to change the fields on the form that will be generated $name
Definition: hooks.txt:304
DeferredUpdates\clearPendingUpdates
static clearPendingUpdates()
Clear all pending updates without performing them.
Definition: DeferredUpdates.php:351
$lbFactory
$lbFactory
Definition: doMaintenance.php:117
DeferredUpdates\$postSendUpdates
static DeferrableUpdate[] $postSendUpdates
Updates to be deferred until after request end.
Definition: DeferredUpdates.php:57
DeferrableCallback
Callback wrapper that has an originating method.
Definition: DeferrableCallback.php:8
DataUpdate
Abstract base class for update jobs that do something with some secondary data extracted from article...
Definition: DataUpdate.php:28
php
injection txt This is an overview of how MediaWiki makes use of dependency injection The design described here grew from the discussion of RFC T384 The term dependency this means that anything an object needs to operate should be injected from the the object itself should only know narrow no concrete implementation of the logic it relies on The requirement to inject everything typically results in an architecture that based on two main types of and essentially stateless service objects that use other service objects to operate on the value objects As of the beginning MediaWiki is only starting to use the DI approach Much of the code still relies on global state or direct resulting in a highly cyclical dependency which acts as the top level factory for services in MediaWiki which can be used to gain access to default instances of various services MediaWikiServices however also allows new services to be defined and default services to be redefined Services are defined or redefined by providing a callback the instantiator that will return a new instance of the service When it will create an instance of MediaWikiServices and populate it with the services defined in the files listed by thereby bootstrapping the DI framework Per $wgServiceWiringFiles lists includes ServiceWiring php
Definition: injection.txt:35
Wikimedia\Rdbms\IDatabase
Basic database interface for live and lazy-loaded relation database handles.
Definition: IDatabase.php:40
EnqueueableDataUpdate
Interface that marks a DataUpdate as enqueuable via the JobQueue.
Definition: EnqueueableDataUpdate.php:10
key
design txt This is a brief overview of the new design More thorough and up to date information is available on the documentation wiki at etc Handles the details of getting and saving to the user table of the and dealing with sessions and cookies OutputPage Encapsulates the entire HTML page that will be sent in response to any server request It is used by calling its functions to add in any and then calling but I prefer the flexibility This should also do the output encoding The system allocates a global one in $wgOut Title Represents the title of an and does all the work of translating among various forms such as plain database key
Definition: design.txt:25
DeferredUpdates\addCallableUpdate
static addCallableUpdate( $callable, $stage=self::POSTSEND, IDatabase $dbw=null)
Add a callable update.
Definition: DeferredUpdates.php:111
wfDeprecated
wfDeprecated( $function, $version=false, $component=false, $callerOffset=2)
Throws a warning that $function is deprecated.
Definition: GlobalFunctions.php:1128
$wgCommandLineMode
global $wgCommandLineMode
Definition: Setup.php:503
DeferredUpdates
Class for managing the deferred updates.
Definition: DeferredUpdates.php:53
MWExceptionHandler\rollbackMasterChangesAndLog
static rollbackMasterChangesAndLog( $e)
Roll back any open database transactions and log the stack trace of the exception.
Definition: MWExceptionHandler.php:93
$queue
$queue
Definition: mergeMessageFileList.php:161
DeferredUpdates\POSTSEND
const POSTSEND
Definition: DeferredUpdates.php:61
global
when a variable name is used in a it is silently declared as a new masking the global
Definition: design.txt:93
$services
static configuration should be added through ResourceLoaderGetConfigVars instead can be used to get the real title after the basic globals have been set but before ordinary actions take place or wrap services the preferred way to define a new service is the $wgServiceWiringFiles array $services
Definition: hooks.txt:2179
Wikimedia\Rdbms\LoadBalancer
Database connection, tracking, load balancing, and transaction manager for a cluster.
Definition: LoadBalancer.php:41
DeferredUpdates\setImmediateMode
static setImmediateMode( $value)
Definition: DeferredUpdates.php:140
$e
div flags Integer display flags(NO_ACTION_LINK, NO_EXTRA_USER_LINKS) 'LogException' returning false will NOT prevent logging $e
Definition: hooks.txt:2122
DeferredUpdates\BIG_QUEUE_SIZE
const BIG_QUEUE_SIZE
Definition: DeferredUpdates.php:63
$value
$value
Definition: styleTest.css.php:45
DeferredUpdates\execute
static execute(array &$queue, $mode, $stage)
Immediately run/queue a list of updates.
Definition: DeferredUpdates.php:172
DeferredUpdates\tryOpportunisticExecute
static tryOpportunisticExecute( $mode='run')
Run all deferred updates immediately if there are no DB writes active.
Definition: DeferredUpdates.php:281
Wikimedia\Rdbms\IDatabase\explicitTrxActive
explicitTrxActive()
DeferredUpdates\$executeContext
static array null $executeContext
Information about the current execute() call or null if not running.
Definition: DeferredUpdates.php:66
DeferredUpdates\areDatabaseTransactionsActive
static areDatabaseTransactionsActive()
Definition: DeferredUpdates.php:359
RequestContext\getMain
static getMain()
Static methods.
Definition: RequestContext.php:468
DeferredUpdates\doUpdates
static doUpdates( $mode='run', $stage=self::ALL)
Do any deferred updates and clear the list.
Definition: DeferredUpdates.php:123
DeferredUpdates\pendingUpdatesCount
static pendingUpdatesCount()
Definition: DeferredUpdates.php:328
MWCallableUpdate
Deferrable Update for closure/callback.
Definition: MWCallableUpdate.php:8
DeferredUpdates\PRESEND
const PRESEND
Definition: DeferredUpdates.php:60
DeferredUpdates\getPendingUpdates
static getPendingUpdates( $stage=self::ALL)
Definition: DeferredUpdates.php:336
Wikimedia\Rdbms\LBFactory
An interface for generating database load balancers.
Definition: LBFactory.php:38
JobQueueGroup\singleton
static singleton( $wiki=false)
Definition: JobQueueGroup.php:71
as
This document is intended to provide useful advice for parties seeking to redistribute MediaWiki to end users It s targeted particularly at maintainers for Linux since it s been observed that distribution packages of MediaWiki often break We ve consistently had to recommend that users seeking support use official tarballs instead of their distribution s and this often solves whatever problem the user is having It would be nice if this could such as
Definition: distributors.txt:9
DeferredUpdates\enqueueUpdates
static enqueueUpdates(array $updates)
Enqueue a job for each EnqueueableDataUpdate item and return the other items.
Definition: DeferredUpdates.php:309
DeferredUpdates\push
static push(array &$queue, DeferrableUpdate $update)
Definition: DeferredUpdates.php:148
DeferrableUpdate
Interface that deferrable updates should implement.
Definition: DeferrableUpdate.php:9
MediaWikiServices
injection txt This is an overview of how MediaWiki makes use of dependency injection The design described here grew from the discussion of RFC T384 The term dependency this means that anything an object needs to operate should be injected from the the object itself should only know narrow no concrete implementation of the logic it relies on The requirement to inject everything typically results in an architecture that based on two main types of and essentially stateless service objects that use other service objects to operate on the value objects As of the beginning MediaWiki is only starting to use the DI approach Much of the code still relies on global state or direct resulting in a highly cyclical dependency MediaWikiServices
Definition: injection.txt:23
DeferredUpdates\runUpdate
static runUpdate(DeferrableUpdate $update, LBFactory $lbFactory, $mode, $stage)
Definition: DeferredUpdates.php:244
DeferredUpdates\$preSendUpdates
static DeferrableUpdate[] $preSendUpdates
Updates to be deferred until before request end.
Definition: DeferredUpdates.php:55
ErrorPageError
An error page which can definitely be safely rendered using the OutputPage.
Definition: ErrorPageError.php:27
wfGetCaller
wfGetCaller( $level=2)
Get the name of the function which called this function wfGetCaller( 1 ) is the function with the wfG...
Definition: GlobalFunctions.php:1561
array
the array() calling protocol came about after MediaWiki 1.4rc1.
Wikimedia\Rdbms\IDatabase\writesOrCallbacksPending
writesOrCallbacksPending()
Returns true if there is a transaction open with possible write queries or transaction pre-commit/idl...