DeferredUpdates.php

Go to the documentation of this file.

<?php
interface DeferrableUpdate {
        function doUpdate();
}

class DeferredUpdates {
        private static $updates = array();

        public static function addUpdate( DeferrableUpdate $update ) {
                array_push( self::$updates, $update );
        }

        public static function addHTMLCacheUpdate( $title, $table ) {
                self::addUpdate( new HTMLCacheUpdate( $title, $table ) );
        }

        public static function doUpdates( $commit = '' ) {
                global $wgDeferredUpdateList;

                wfProfileIn( __METHOD__ );

                $updates = array_merge( $wgDeferredUpdateList, self::$updates );

                // No need to get master connections in case of empty updates array
                if ( !count( $updates ) ) {
                        wfProfileOut( __METHOD__ );
                        return;
                }

                $doCommit = $commit == 'commit';
                if ( $doCommit ) {
                        $dbw = wfGetDB( DB_MASTER );
                }

                foreach ( $updates as $update ) {
                        $update->doUpdate();

                        if ( $doCommit && $dbw->trxLevel() ) {
                                $dbw->commit( __METHOD__ );
                        }
                }

                self::clearPendingUpdates();
                wfProfileOut( __METHOD__ );
        }

        public static function clearPendingUpdates() {
                global $wgDeferredUpdateList;
                $wgDeferredUpdateList = self::$updates = array();
        }
}