Style and commenting tweaks to CategoryMembershipChangeJob

[lhc/web/wiklou.git] / includes / jobqueue / jobs / CategoryMembershipChangeJob.php

diff --git a/includes/jobqueue/jobs/CategoryMembershipChangeJob.php b/includes/jobqueue/jobs/CategoryMembershipChangeJob.php
index d34ea41..5dc2acb 100644 (file)
--- a/includes/jobqueue/jobs/CategoryMembershipChangeJob.php
+++ b/includes/jobqueue/jobs/CategoryMembershipChangeJob.php
@@ -49,7 +49,6 @@ class CategoryMembershipChangeJob extends Job {
                }
 
                $dbw = wfGetDB( DB_MASTER );
-
                // Use a named lock so that jobs for this page see each others' changes
                $lockKey = "CategoryMembershipUpdates:{$page->getId()}";
                $scopedLock = $dbw->getScopedLockAndFlush( $lockKey, __METHOD__, 10 );
@@ -58,19 +57,20 @@ class CategoryMembershipChangeJob extends Job {
                        return false;
                }
 
-               $cutoffUnix = wfTimestamp( TS_UNIX, $this->params['revTimestamp'] );
-               // Using ENQUEUE_FUDGE_SEC handles jobs inserted out of revision order due to the delay
-               // between COMMIT and actual enqueueing of the CategoryMembershipChangeJob job.
-               $cutoffUnix -= self::ENQUEUE_FUDGE_SEC;
-
                $dbr = wfGetDB( DB_SLAVE, array( 'recentchanges' ) );
-               if ( !wfGetLB()->safeWaitForPos( $dbr ) ) {
+               // Wait till the slave is caught up so that jobs for this page see each others' changes
+               if ( !wfGetLB()->safeWaitForMasterPos( $dbr ) ) {
                        $this->setLastError( "Timed out while waiting for slave to catch up" );
                        return false;
                }
-
+               // Clear any stale REPEATABLE-READ snapshot
                $dbr->commit( __METHOD__, 'flush' );
 
+               $cutoffUnix = wfTimestamp( TS_UNIX, $this->params['revTimestamp'] );
+               // Using ENQUEUE_FUDGE_SEC handles jobs inserted out of revision order due to the delay
+               // between COMMIT and actual enqueueing of the CategoryMembershipChangeJob job.
+               $cutoffUnix -= self::ENQUEUE_FUDGE_SEC;
+
                // Get the newest revision that has a SRC_CATEGORIZE row...
                $row = $dbr->selectRow(
                        array( 'revision', 'recentchanges' ),