dépôts
/
lhc
/
web
/
wiklou.git
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
|
inline
| side by side (parent:
ff7bc88
)
oops
author
Domas Mituzas
<midom@users.mediawiki.org>
Sun, 25 Mar 2007 20:09:21 +0000
(20:09 +0000)
committer
Domas Mituzas
<midom@users.mediawiki.org>
Sun, 25 Mar 2007 20:09:21 +0000
(20:09 +0000)
includes/JobQueue.php
patch
|
blob
|
history
diff --git
a/includes/JobQueue.php
b/includes/JobQueue.php
index
f291c07
..
54af5e7
100644
(file)
--- a/
includes/JobQueue.php
+++ b/
includes/JobQueue.php
@@
-43,22
+43,20
@@
abstract class Job {
$row = $dbr->selectRow( 'job', '*', "job_id >= ${offset}", __METHOD__,
array( 'ORDER BY' => 'job_id', 'LIMIT' => 1 ));
$row = $dbr->selectRow( 'job', '*', "job_id >= ${offset}", __METHOD__,
array( 'ORDER BY' => 'job_id', 'LIMIT' => 1 ));
-
+
// Refetching without offset is needed as some of job IDs could have had delayed commits
// and have lower IDs than jobs already executed, blame concurrency :)
// Refetching without offset is needed as some of job IDs could have had delayed commits
// and have lower IDs than jobs already executed, blame concurrency :)
-
- if ( $row === false
&& $offset != 0
) {
- $offset=0;
- $row = $dbr->selectRow( 'job', '*', '', __METHOD__,
- array( 'ORDER BY' => 'job_id', 'LIMIT' => 1 ));
+ //
+ if ( $row === false) {
+ if ($offset!=0)
+
$row = $dbr->selectRow( 'job', '*', '', __METHOD__,
+
array( 'ORDER BY' => 'job_id', 'LIMIT' => 1 ));
if ($row === false ) {
wfProfileOut( __METHOD__ );
return false;
}
if ($row === false ) {
wfProfileOut( __METHOD__ );
return false;
}
- }
-
- /* Still avoid scanning purged rows */
+ }
$offset = $row->job_id;
// Try to delete it from the master
$offset = $row->job_id;
// Try to delete it from the master