}
public function execute() {
- global $slaveIndexes, $wgDBservers;
- $slaveIndexes = array();
+ global $wgDBservers;
+ $this->slaveIndexes = array();
for ( $i = 1; $i < count( $wgDBservers ); $i++ ) {
if ( wfGetLB()->isNonZeroLoad( $i ) ) {
- $slaveIndexes[] = $i;
+ $this->slaveIndexes[] = $i;
}
}
}
$this->output( "\n" );
- global $slaveIndexes;
- foreach ( $slaveIndexes as $i ) {
+ foreach ( $this->slaveIndexes as $i ) {
$db = wfGetDB( $i );
$res = $db->select( 'page', array( 'page_id', 'page_latest' ), array( 'page_id<6054123' ), __METHOD__ );
foreach ( $res as $row ) {
* @param $pageID int The page_id to fix
*/
private function desyncFixPage( $pageID ) {
- global $slaveIndexes;
-
# Check for a corrupted page_latest
$dbw = wfGetDB( DB_MASTER );
$dbw->begin();
__METHOD__, 'FOR UPDATE' );
# list( $masterFile, $masterPos ) = $dbw->getMasterPos();
$found = false;
- foreach ( $slaveIndexes as $i ) {
+ foreach ( $this->slaveIndexes as $i ) {
$db = wfGetDB( $i );
/*
if ( !$db->masterPosWait( $masterFile, $masterPos, 10 ) ) {
$dbw->insert( 'revision', get_object_vars( $row ), __METHOD__, 'IGNORE' );
}
} else {
- foreach ( $slaveIndexes as $i ) {
+ foreach ( $this->slaveIndexes as $i ) {
$db = wfGetDB( $i );
$db->insert( 'revision', get_object_vars( $row ), __METHOD__, 'IGNORE' );
}
if ( $toMaster ) {
$dbw->insert( 'text', get_object_vars( $row ), __METHOD__, 'IGNORE' );
} else {
- foreach ( $slaveIndexes as $i ) {
+ foreach ( $this->slaveIndexes as $i ) {
$db = wfGetDB( $i );
$db->insert( 'text', get_object_vars( $row ), __METHOD__, 'IGNORE' );
}
if ( $toMaster ) {
# $dbw->update( 'page', array( 'page_latest' => $realLatest ), array( 'page_id' => $pageID ), __METHOD__ );
} else {
- foreach ( $slaveIndexes as $i ) {
+ foreach ( $this->slaveIndexes as $i ) {
$db = wfGetDB( $i );
$db->update( 'page', array( 'page_latest' => $realLatest ), array( 'page_id' => $pageID ), __METHOD__ );
}