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 $corrupt = findPageLatestCorruption();
26 foreach ( $corrupt as $id => $dummy ) {
30 for ( $i=1; $i <= $maxPage; $i++ ) {
32 if ( !($i % $reportingInterval) ) {
38 function findPageLatestCorruption() {
41 $dbw =& wfGetDB( DB_MASTER
);
43 $res = $dbw->select( 'page', array( 'page_id', 'page_latest' ), array( 'page_id<6054123' ), __METHOD__
);
44 print "Number of pages: " . $dbw->numRows( $res ) . "\n";
45 while ( $row = $dbw->fetchObject( $res ) ) {
46 $masterIDs[$row->page_id
] = $row->page_latest
;
47 if ( !( ++
$n %
10000 ) ) {
52 $dbw->freeResult( $res );
55 foreach ( $slaveIndexes as $i ) {
58 $res = $db->select( 'page', array( 'page_id', 'page_latest' ), array( 'page_id<6054123' ), __METHOD__
);
59 while ( $row = $db->fetchObject( $res ) ) {
60 if ( isset( $masterIDs[$row->page_id
] ) && $masterIDs[$row->page_id
] != $row->page_latest
) {
61 $desync[$row->page_id
] = true;
62 print $row->page_id
. "\t";
65 $db->freeResult( $res );
71 function desyncFixPage( $pageID ) {
73 $fname = 'desyncFixPage';
75 # Check for a corrupted page_latest
76 $dbw =& wfGetDB( DB_MASTER
);
78 $realLatest = $dbw->selectField( 'page', 'page_latest', array( 'page_id' => $pageID ),
79 $fname, 'FOR UPDATE' );
80 #list( $masterFile, $masterPos ) = $dbw->getMasterPos();
82 foreach ( $slaveIndexes as $i ) {
85 if ( !$db->masterPosWait( $masterFile, $masterPos, 10 ) ) {
86 echo "Slave is too lagged, aborting\n";
91 $latest = $db->selectField( 'page', 'page_latest', array( 'page_id' => $pageID ), $fname );
92 $max = $db->selectField( 'revision', 'MAX(rev_id)', false, $fname );
93 if ( $latest != $realLatest && $realLatest < $max ) {
94 print "page_latest corrupted in page $pageID, server $i\n";
100 print "page_id $pageID seems fine\n";
105 # Find the missing revisions
106 $res = $dbw->select( 'revision', array( 'rev_id' ), array( 'rev_page' => $pageID ),
107 $fname, 'FOR UPDATE' );
108 $masterIDs = array();
109 while ( $row = $dbw->fetchObject( $res ) ) {
110 $masterIDs[] = $row->rev_id
;
112 $dbw->freeResult( $res );
114 $res = $db->select( 'revision', array( 'rev_id' ), array( 'rev_page' => $pageID ), $fname );
116 while ( $row = $db->fetchObject( $res ) ) {
117 $slaveIDs[] = $row->rev_id
;
119 $db->freeResult( $res );
120 if ( count( $masterIDs ) < count( $slaveIDs ) ) {
121 $missingIDs = array_diff( $slaveIDs, $masterIDs );
122 if ( count( $missingIDs ) ) {
123 print "Found " . count( $missingIDs ) . " lost in master, copying from slave... ";
132 $missingIDs = array_diff( $masterIDs, $slaveIDs );
133 if ( count( $missingIDs ) ) {
134 print "Found " . count( $missingIDs ) . " missing revision(s), copying from master... ";
145 foreach ( $missingIDs as $rid ) {
148 $row = $dbFrom->selectRow( 'revision', '*', array( 'rev_id' => $rid ), $fname );
150 $id = $dbw->selectField( 'revision', 'rev_id', array( 'rev_id' => $rid ),
151 $fname, 'FOR UPDATE' );
153 echo "Revision already exists\n";
157 $dbw->insert( 'revision', get_object_vars( $row ), $fname, 'IGNORE' );
160 foreach ( $slaveIndexes as $i ) {
161 $db =& wfGetDB( $i );
162 $db->insert( 'revision', get_object_vars( $row ), $fname, 'IGNORE' );
167 $row = $dbFrom->selectRow( 'text', '*', array( 'old_id' => $row->rev_text_id
), $fname );
169 $dbw->insert( 'text', get_object_vars( $row ), $fname, 'IGNORE' );
171 foreach ( $slaveIndexes as $i ) {
172 $db =& wfGetDB( $i );
173 $db->insert( 'text', get_object_vars( $row ), $fname, 'IGNORE' );
181 print "Fixing page_latest... ";
183 #$dbw->update( 'page', array( 'page_latest' => $realLatest ), array( 'page_id' => $pageID ), $fname );
185 foreach ( $slaveIndexes as $i ) {
186 $db =& wfGetDB( $i );
187 $db->update( 'page', array( 'page_latest' => $realLatest ), array( 'page_id' => $pageID ), $fname );