Bug: T135690
Change-Id: If79ca385884f422e5ed11e77b29033c8cabf494c
foreach ( $deleteWheres as $deleteWhere ) {
$this->mDb->delete( $table, $deleteWhere, __METHOD__ );
$this->mDb->commit( __METHOD__, 'flush' );
foreach ( $deleteWheres as $deleteWhere ) {
$this->mDb->delete( $table, $deleteWhere, __METHOD__ );
$this->mDb->commit( __METHOD__, 'flush' );
- wfGetLBFactory()->waitForReplication();
+ wfGetLBFactory()->waitForReplication( [ 'wiki' => $this->mDb->getWikiID() ] );
}
$insertBatches = array_chunk( $insertions, self::BATCH_SIZE );
foreach ( $insertBatches as $insertBatch ) {
$this->mDb->insert( $table, $insertBatch, __METHOD__, 'IGNORE' );
$this->mDb->commit( __METHOD__, 'flush' );
}
$insertBatches = array_chunk( $insertions, self::BATCH_SIZE );
foreach ( $insertBatches as $insertBatch ) {
$this->mDb->insert( $table, $insertBatch, __METHOD__, 'IGNORE' );
$this->mDb->commit( __METHOD__, 'flush' );
- wfGetLBFactory()->waitForReplication();
+ wfGetLBFactory()->waitForReplication( [ 'wiki' => $this->mDb->getWikiID() ] );
}
if ( count( $insertions ) ) {
}
if ( count( $insertions ) ) {