3 * This script starts pending jobs.
6 * --maxjobs <num> (default 10000)
10 * @ingroup Maintenance
13 $optionsWithArgs = array( 'maxjobs', 'type', 'procs' );
14 $wgUseNormalUser = true;
15 require_once( 'commandLine.inc' );
17 if ( isset( $options['procs'] ) ) {
18 $procs = intval( $options['procs'] );
19 if ( $procs < 1 ||
$procs > 1000 ) {
20 echo "Invalid argument to --procs\n";
23 $fc = new ForkController( $procs );
24 if ( $fc->start( $procs ) != 'child' ) {
29 if ( isset( $options['maxjobs'] ) ) {
30 $maxJobs = $options['maxjobs'];
36 if ( isset( $options['type'] ) )
37 $type = $options['type'];
39 $wgTitle = Title
::newFromText( 'RunJobs.php' );
41 $dbw = wfGetDB( DB_MASTER
);
45 $conds = "job_cmd = " . $dbw->addQuotes($type);
47 while ( $dbw->selectField( 'job', 'job_id', $conds, 'runJobs.php' ) ) {
50 $job = ($type == false) ?
52 : Job
::pop_type($type);
58 $t = microtime( true );
60 $status = $job->run();
61 $t = microtime( true ) - $t;
62 $timeMs = intval( $t * 1000 );
64 runJobsLog( $job->toString() . " t=$timeMs error={$job->error}" );
66 runJobsLog( $job->toString() . " t=$timeMs good" );
68 if ( $maxJobs && ++
$n > $maxJobs ) {
75 function runJobsLog( $msg ) {
76 print wfTimestamp( TS_DB
) . " $msg\n";
77 wfDebugLog( 'runJobs', $msg );