DeferredUpdates.php

Go to the documentation of this file.

<?php
namespace MediaWiki\Deferred;
 
use LogicException;
use MediaWiki\Exception\ErrorPageError;
use MediaWiki\Exception\MWExceptionHandler;
use MediaWiki\Logger\LoggerFactory;
use Throwable;
use Wikimedia\Rdbms\IDatabase;
use Wikimedia\ScopedCallback;
use Wikimedia\Timestamp\ConvertibleTimestamp;
 
class DeferredUpdates {
    public const ALL = 0;
    public const PRESEND = 1;
    public const POSTSEND = 2;
 
    public const STAGES = [ self::PRESEND, self::POSTSEND ];
 
    private static $scopeStack;
 
    private static $preventOpportunisticUpdates = 0;
 
    private static function getScopeStack(): DeferredUpdatesScopeStack {
        self::$scopeStack ??= new DeferredUpdatesScopeMediaWikiStack();
        return self::$scopeStack;
    }
 
    public static function setScopeStack( DeferredUpdatesScopeStack $scopeStack ): void {
        if ( !defined( 'MW_PHPUNIT_TEST' ) ) {
            throw new LogicException( 'Cannot reconfigure DeferredUpdates outside tests' );
        }
        self::$scopeStack = $scopeStack;
    }
 
    public static function addUpdate( DeferrableUpdate $update, $stage = self::POSTSEND ) {
        self::getScopeStack()->current()->addUpdate( $update, $stage );
        self::tryOpportunisticExecute();
    }
 
    public static function addCallableUpdate(
        $callable,
        $stage = self::POSTSEND,
        $dependeeDbws = []
    ) {
        self::addUpdate( new MWCallableUpdate( $callable, wfGetCaller(), $dependeeDbws ), $stage );
    }
 
    private static function run( DeferrableUpdate $update ): ?Throwable {
        $logger = LoggerFactory::getInstance( 'DeferredUpdates' );
 
        $type = get_class( $update )
            . ( $update instanceof DeferrableCallback ? '_' . $update->getOrigin() : '' );
        $updateId = spl_object_id( $update );
        $logger->debug( "DeferredUpdates::run: started $type #{updateId}", [ 'updateId' => $updateId ] );
 
        $updateException = null;
 
        $startTime = ConvertibleTimestamp::hrtime();
        try {
            self::attemptUpdate( $update );
        } catch ( Throwable $updateException ) {
            MWExceptionHandler::logException( $updateException );
            $logger->error(
                "Deferred update '{deferred_type}' failed to run.",
                [
                    'deferred_type' => $type,
                    'exception' => $updateException,
                ]
            );
            self::getScopeStack()->onRunUpdateFailed( $update );
        } finally {
            $walltime = ( ConvertibleTimestamp::hrtime() - $startTime ) / 1e9;
            $logger->debug( "DeferredUpdates::run: ended $type #{updateId}, processing time: {walltime}", [
                'updateId' => $updateId,
                'walltime' => $walltime,
            ] );
        }
 
        // Try to push the update as a job so it can run later if possible
        if ( $updateException && $update instanceof EnqueueableDataUpdate ) {
            try {
                self::getScopeStack()->queueDataUpdate( $update );
            } catch ( Throwable $jobException ) {
                MWExceptionHandler::logException( $jobException );
                $logger->error(
                    "Deferred update '{deferred_type}' failed to enqueue as a job.",
                    [
                        'deferred_type' => $type,
                        'exception' => $jobException,
                    ]
                );
                self::getScopeStack()->onRunUpdateFailed( $update );
            }
        }
 
        return $updateException;
    }
 
    public static function doUpdates( $stage = self::ALL ) {
        $guiError = null;
        '@phan-var ErrorPageError $guiError';
        $exception = null;
        '@phan-var Throwable $exception';
 
        $scope = self::getScopeStack()->current();
 
        // T249069: recursion is not possible once explicit transaction rounds are involved
        $activeUpdate = $scope->getActiveUpdate();
        if ( $activeUpdate ) {
            $class = get_class( $activeUpdate );
            if ( !( $activeUpdate instanceof TransactionRoundAwareUpdate ) ) {
                throw new LogicException(
                    __METHOD__ . ": reached from $class, which is not TransactionRoundAwareUpdate"
                );
            }
            if ( $activeUpdate->getTransactionRoundRequirement() !== $activeUpdate::TRX_ROUND_ABSENT ) {
                throw new LogicException(
                    __METHOD__ . ": reached from $class, which does not specify TRX_ROUND_ABSENT"
                );
            }
        }
 
        $scope->processUpdates(
            $stage,
            static function ( DeferrableUpdate $update, $activeStage ) use ( &$guiError, &$exception ) {
                $scopeStack = self::getScopeStack();
                $childScope = $scopeStack->descend( $activeStage, $update );
                try {
                    $e = self::run( $update );
                    $guiError = $guiError ?: ( $e instanceof ErrorPageError ? $e : null );
                    $exception = $exception ?: $e;
                    // Any addUpdate() calls between descend() and ascend() used the sub-queue.
                    // In rare cases, DeferrableUpdate::doUpdates() will process them by calling
                    // doUpdates() itself. In any case, process remaining updates in the subqueue.
                    // them, enqueuing them, or transferring them to the parent scope
                    // queues as appropriate...
                    $childScope->processUpdates(
                        $activeStage,
                        static function ( DeferrableUpdate $sub ) use ( &$guiError, &$exception ) {
                            $e = self::run( $sub );
                            $guiError = $guiError ?: ( $e instanceof ErrorPageError ? $e : null );
                            $exception = $exception ?: $e;
                        }
                    );
                } finally {
                    $scopeStack->ascend();
                }
            }
        );
 
        // VW-style hack to work around T190178, so we can make sure
        // PageMetaDataUpdater doesn't throw exceptions.
        if ( $exception && defined( 'MW_PHPUNIT_TEST' ) ) {
            // @phan-suppress-next-line PhanThrowTypeMismatch
            throw $exception;
        }
 
        // Throw the first of any GUI errors as long as the context is HTTP pre-send. However,
        // callers should check permissions *before* enqueueing updates. If the main transaction
        // round actions succeed but some deferred updates fail due to permissions errors then
        // there is a risk that some secondary data was not properly updated.
        if ( $guiError && $stage === self::PRESEND && !headers_sent() ) {
            throw $guiError;
        }
    }
 
    public static function tryOpportunisticExecute(): bool {
        // Leave execution up to the current loop if an update is already in progress
        // or if updates are explicitly disabled
        if ( self::getRecursiveExecutionStackDepth()
            || self::$preventOpportunisticUpdates
        ) {
            return false;
        }
 
        if ( self::getScopeStack()->allowOpportunisticUpdates() ) {
            self::doUpdates( self::ALL );
            return true;
        }
 
        return false;
    }
 
    #[\NoDiscard]
    public static function preventOpportunisticUpdates(): ScopedCallback {
        self::$preventOpportunisticUpdates++;
        return new ScopedCallback( static function () {
            self::$preventOpportunisticUpdates--;
        } );
    }
 
    public static function pendingUpdatesCount() {
        return self::getScopeStack()->current()->pendingUpdatesCount();
    }
 
    public static function getPendingUpdates( $stage = self::ALL ) {
        return self::getScopeStack()->current()->getPendingUpdates( $stage );
    }
 
    public static function clearPendingUpdates() {
        self::getScopeStack()->current()->clearPendingUpdates();
    }
 
    public static function getRecursiveExecutionStackDepth() {
        return self::getScopeStack()->getRecursiveDepth();
    }
 
    public static function attemptUpdate( DeferrableUpdate $update ) {
        self::getScopeStack()->onRunUpdateStart( $update );
 
        $update->doUpdate();
 
        self::getScopeStack()->onRunUpdateEnd( $update );
    }
}
 
class_alias( DeferredUpdates::class, 'DeferredUpdates' );