X-Git-Url: https://git.heureux-cyclage.org/?a=blobdiff_plain;f=includes%2Fdeferred%2FLinksUpdate.php;h=5e02c5cc6cf14eeb7cadb78baf808caae1dca32a;hb=8a43c5afdf0736f5c60ec587da5c230cf53a8ab1;hp=22944eb7a61d2f34bc131f4f43f7d0e1478dcadb;hpb=161e8669fe285b20d4534ca14a4ffdbe2271801a;p=lhc%2Fweb%2Fwiklou.git

diff --git a/includes/deferred/LinksUpdate.php b/includes/deferred/LinksUpdate.php
index 22944eb7a6..5e02c5cc6c 100644
--- a/includes/deferred/LinksUpdate.php
+++ b/includes/deferred/LinksUpdate.php
@@ -304,7 +304,7 @@ class LinksUpdate extends SqlDataUpdate implements EnqueueableDataUpdate {
 	 * @param array $cats
 	 */
 	function invalidateCategories( $cats ) {
-		$this->invalidatePages( NS_CATEGORY, array_keys( $cats ) );
+		PurgeJobUtils::invalidatePages( $this->mDb, NS_CATEGORY, array_keys( $cats ) );
 	}
 
 	/**
@@ -323,7 +323,7 @@ class LinksUpdate extends SqlDataUpdate implements EnqueueableDataUpdate {
 	 * @param array $images
 	 */
 	function invalidateImageDescriptions( $images ) {
-		$this->invalidatePages( NS_FILE, array_keys( $images ) );
+		PurgeJobUtils::invalidatePages( $this->mDb, NS_FILE, array_keys( $images ) );
 	}
 
 	/**
@@ -335,6 +335,7 @@ class LinksUpdate extends SqlDataUpdate implements EnqueueableDataUpdate {
 	 */
 	private function incrTableUpdate( $table, $prefix, $deletions, $insertions ) {
 		$bSize = RequestContext::getMain()->getConfig()->get( 'UpdateRowsPerQuery' );
+		$factory = wfGetLBFactory();
 
 		if ( $table === 'page_props' ) {
 			$fromField = 'pp_page';
@@ -386,15 +387,17 @@ class LinksUpdate extends SqlDataUpdate implements EnqueueableDataUpdate {
 
 		foreach ( $deleteWheres as $deleteWhere ) {
 			$this->mDb->delete( $table, $deleteWhere, __METHOD__ );
-			$this->mDb->commit( __METHOD__, 'flush' );
-			wfGetLBFactory()->waitForReplication( [ 'wiki' => $this->mDb->getWikiID() ] );
+			$factory->commitAndWaitForReplication(
+				__METHOD__, $this->ticket, [ 'wiki' => $this->mDb->getWikiID() ]
+			);
 		}
 
 		$insertBatches = array_chunk( $insertions, $bSize );
 		foreach ( $insertBatches as $insertBatch ) {
 			$this->mDb->insert( $table, $insertBatch, __METHOD__, 'IGNORE' );
-			$this->mDb->commit( __METHOD__, 'flush' );
-			wfGetLBFactory()->waitForReplication( [ 'wiki' => $this->mDb->getWikiID() ] );
+			$factory->commitAndWaitForReplication(
+				__METHOD__, $this->ticket, [ 'wiki' => $this->mDb->getWikiID() ]
+			);
 		}
 
 		if ( count( $insertions ) ) {