dépôts
/
lhc
/
web
/
wiklou.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Prevent write operations to database replicas.
[lhc/web/wiklou.git]
/
maintenance
/
rebuildrecentchanges.php
diff --git
a/maintenance/rebuildrecentchanges.php
b/maintenance/rebuildrecentchanges.php
index
a2cf3c5
..
bbf91f5
100644
(file)
--- a/
maintenance/rebuildrecentchanges.php
+++ b/
maintenance/rebuildrecentchanges.php
@@
-61,7
+61,7
@@
class RebuildRecentchanges extends Maintenance {
( $this->hasOption( 'from' ) && !$this->hasOption( 'to' ) ) ||
( !$this->hasOption( 'from' ) && $this->hasOption( 'to' ) )
) {
( $this->hasOption( 'from' ) && !$this->hasOption( 'to' ) ) ||
( !$this->hasOption( 'from' ) && $this->hasOption( 'to' ) )
) {
- $this->
error( "Both 'from' and 'to' must be given, or neither", 1
);
+ $this->
fatalError( "Both 'from' and 'to' must be given, or neither"
);
}
$this->rebuildRecentChangesTablePass1();
}
$this->rebuildRecentChangesTablePass1();
@@
-109,7
+109,7
@@
class RebuildRecentchanges extends Maintenance {
'rc_timestamp < ' . $dbw->addQuotes( $dbw->timestamp( $this->cutoffTo ) )
]
);
'rc_timestamp < ' . $dbw->addQuotes( $dbw->timestamp( $this->cutoffTo ) )
]
);
- foreach ( array_chunk( $rcids, $this->
mBatchSize
) as $rcidBatch ) {
+ foreach ( array_chunk( $rcids, $this->
getBatchSize()
) as $rcidBatch ) {
$dbw->delete( 'recentchanges', [ 'rc_id' => $rcidBatch ], __METHOD__ );
wfGetLBFactory()->waitForReplication();
}
$dbw->delete( 'recentchanges', [ 'rc_id' => $rcidBatch ], __METHOD__ );
wfGetLBFactory()->waitForReplication();
}
@@
-166,7
+166,7
@@
class RebuildRecentchanges extends Maintenance {
] + $rcCommentStore->insert( $dbw, $comment ),
__METHOD__
);
] + $rcCommentStore->insert( $dbw, $comment ),
__METHOD__
);
- if ( ( ++$inserted % $this->
mBatchSize
) == 0 ) {
+ if ( ( ++$inserted % $this->
getBatchSize()
) == 0 ) {
wfGetLBFactory()->waitForReplication();
}
}
wfGetLBFactory()->waitForReplication();
}
}
@@
-256,7
+256,7
@@
class RebuildRecentchanges extends Maintenance {
$lastOldId = intval( $obj->rc_this_oldid );
$lastSize = $size;
$lastOldId = intval( $obj->rc_this_oldid );
$lastSize = $size;
- if ( ( ++$updated % $this->
mBatchSize
) == 0 ) {
+ if ( ( ++$updated % $this->
getBatchSize()
) == 0 ) {
wfGetLBFactory()->waitForReplication();
}
}
wfGetLBFactory()->waitForReplication();
}
}
@@
-340,7
+340,7
@@
class RebuildRecentchanges extends Maintenance {
__METHOD__
);
__METHOD__
);
- if ( ( ++$inserted % $this->
mBatchSize
) == 0 ) {
+ if ( ( ++$inserted % $this->
getBatchSize()
) == 0 ) {
wfGetLBFactory()->waitForReplication();
}
}
wfGetLBFactory()->waitForReplication();
}
}
@@
-392,7
+392,7
@@
class RebuildRecentchanges extends Maintenance {
__METHOD__
);
__METHOD__
);
- foreach ( array_chunk( $rcids, $this->
mBatchSize
) as $rcidBatch ) {
+ foreach ( array_chunk( $rcids, $this->
getBatchSize()
) as $rcidBatch ) {
$dbw->update(
'recentchanges',
[ 'rc_bot' => 1 ],
$dbw->update(
'recentchanges',
[ 'rc_bot' => 1 ],
@@
-474,7
+474,7
@@
class RebuildRecentchanges extends Maintenance {
__METHOD__
);
__METHOD__
);
- if ( ( ++$updates % $this->
mBatchSize
) == 0 ) {
+ if ( ( ++$updates % $this->
getBatchSize()
) == 0 ) {
wfGetLBFactory()->waitForReplication();
}
}
wfGetLBFactory()->waitForReplication();
}
}