4 require_once( 'commandLine.inc' );
6 //$wgDebugLogFile = '/dev/stdout';
8 $slaveIndexes = array();
9 for ( $i = 1; $i < count( $wgDBservers ); $i++
) {
10 if ( $wgLoadBalancer->isNonZeroLoad( $i ) ) {
15 foreach ( $wgLoadBalancer->mServers as $i => $server ) {
16 $wgLoadBalancer->mServers[$i]['flags'] |= DBO_DEBUG;
18 $reportingInterval = 1000;
20 if ( isset( $args[0] ) ) {
21 desyncFixPage( $args[0] );
23 $dbw =& wfGetDB( DB_MASTER
);
24 $maxPage = $dbw->selectField( 'page', 'MAX(page_id)', false, 'fixDesync.php' );
25 for ( $i=1; $i <= $maxPage; $i++
) {
27 if ( !($i %
$reportingInterval) ) {
33 function desyncFixPage( $pageID ) {
35 $fname = 'desyncFixPage';
37 # Check for a corrupted page_latest
38 $dbw =& wfGetDB( DB_MASTER
);
39 $realLatest = $dbw->selectField( 'page', 'page_latest', array( 'page_id' => $pageID ), $fname );
41 foreach ( $slaveIndexes as $i ) {
43 $latest = $db->selectField( 'page', 'page_latest', array( 'page_id' => $pageID ), $fname );
44 $max = $db->selectField( 'revision', 'MAX(rev_id)', false, $fname );
45 if ( $latest != $realLatest && $realLatest < $max ) {
46 print "page_latest corrupted in page $pageID, server $i\n";
55 # Find the missing revision
56 $res = $dbw->select( 'revision', array( 'rev_id' ), array( 'rev_page' => $pageID ), $fname );
58 while ( $row = $dbw->fetchObject( $res ) ) {
59 $masterIDs[] = $row->rev_id
;
61 $dbw->freeResult( $res );
63 $res = $db->select( 'revision', array( 'rev_id' ), array( 'rev_page' => $pageID ), $fname );
65 while ( $row = $db->fetchObject( $res ) ) {
66 $slaveIDs[] = $row->rev_id
;
68 $db->freeResult( $res );
69 $missingIDs = array_diff( $masterIDs, $slaveIDs );
71 if ( count( $missingIDs ) ) {
72 print "Found " . count( $missingIDs ) . " missing revision(s), copying from master... ";
73 foreach ( $missingIDs as $rid ) {
76 $row = $dbw->selectRow( 'revision', '*', array( 'rev_id' => $rid ), $fname );
77 foreach ( $slaveIndexes as $i ) {
79 $db->insert( 'revision', get_object_vars( $row ), $fname, 'IGNORE' );
83 $row = $dbw->selectRow( 'text', '*', array( 'old_id' => $row->rev_text_id
), $fname );
84 foreach ( $slaveIndexes as $i ) {
86 $db->insert( 'text', get_object_vars( $row ), $fname, 'IGNORE' );
92 print "Fixing page_latest... ";
93 foreach ( $slaveIndexes as $i ) {
95 $db->update( 'page', array( 'page_latest' => $realLatest ), array( 'page_id' => $pageID ), $fname );