5 * This program is free software; you can redistribute it and/or modify
6 * it under the terms of the GNU General Public License as published by
7 * the Free Software Foundation; either version 2 of the License, or
8 * (at your option) any later version.
10 * This program is distributed in the hope that it will be useful,
11 * but WITHOUT ANY WARRANTY; without even the implied warranty of
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13 * GNU General Public License for more details.
15 * You should have received a copy of the GNU General Public License along
16 * with this program; if not, write to the Free Software Foundation, Inc.,
17 * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
18 * http://www.gnu.org/copyleft/gpl.html
21 * @defgroup JobQueue JobQueue
25 * Class to both describe a background job and handle jobs.
26 * The queue aspects of this class are now deprecated.
42 /** @var Array Additional queue metadata */
43 public $metadata = array();
45 /*-------------------------------------------------------------------------
47 *------------------------------------------------------------------------*/
51 * @return boolean success
53 abstract public function run();
55 /*-------------------------------------------------------------------------
57 *------------------------------------------------------------------------*/
60 * Create the appropriate object to handle a specific job
62 * @param $command String: Job command
63 * @param $title Title: Associated title
64 * @param $params Array|bool: Job parameters
65 * @param $id Int: Job identifier
69 public static function factory( $command, Title
$title, $params = false, $id = 0 ) {
71 if( isset( $wgJobClasses[$command] ) ) {
72 $class = $wgJobClasses[$command];
73 return new $class( $title, $params, $id );
75 throw new MWException( "Invalid job command `{$command}`" );
79 * Batch-insert a group of jobs into the queue.
80 * This will be wrapped in a transaction with a forced commit.
82 * This may add duplicate at insert time, but they will be
83 * removed later on, when the first one is popped.
85 * @param $jobs array of Job objects
88 public static function batchInsert( $jobs ) {
89 return JobQueueGroup
::singleton()->push( $jobs );
93 * Insert a group of jobs into the queue.
95 * Same as batchInsert() but does not commit and can thus
96 * be rolled-back as part of a larger transaction. However,
97 * large batches of jobs can cause slave lag.
99 * @param $jobs array of Job objects
102 public static function safeBatchInsert( $jobs ) {
103 return JobQueueGroup
::singleton()->push( $jobs, JobQueue
::QoS_Atomic
);
107 * Pop a job of a certain type. This tries less hard than pop() to
108 * actually find a job; it may be adversely affected by concurrent job
111 * @param $type string
115 public static function pop_type( $type ) {
116 return JobQueueGroup
::singleton()->get( $type )->pop();
120 * Pop a job off the front of the queue.
121 * This is subject to $wgJobTypesExcludedFromDefaultQueue.
123 * @return Job or false if there's no jobs
126 public static function pop() {
127 return JobQueueGroup
::singleton()->pop();
130 /*-------------------------------------------------------------------------
131 * Non-static functions
132 *------------------------------------------------------------------------*/
137 * @param $params array|bool
140 public function __construct( $command, $title, $params = false, $id = 0 ) {
141 $this->command
= $command;
142 $this->title
= $title;
143 $this->params
= $params;
146 $this->removeDuplicates
= false; // expensive jobs may set this to true
150 * @return integer May be 0 for jobs stored outside the DB
152 public function getId() {
159 public function getType() {
160 return $this->command
;
166 public function getTitle() {
173 public function getParams() {
174 return $this->params
;
180 public function ignoreDuplicates() {
181 return $this->removeDuplicates
;
185 * Subclasses may need to override this to make duplication detection work
187 * @return Array Map of key/values
189 public function getDeduplicationInfo() {
191 'type' => $this->getType(),
192 'namespace' => $this->getTitle()->getNamespace(),
193 'title' => $this->getTitle()->getDBkey(),
194 'params' => $this->getParams()
196 // Identical jobs with different "root" jobs should count as duplicates
197 if ( is_array( $info['params'] ) ) {
198 unset( $info['params']['rootJobSignature'] );
199 unset( $info['params']['rootJobTimestamp'] );
205 * @param $key string A key that identifies the task
208 public static function newRootJobParams( $key ) {
210 'rootJobSignature' => sha1( $key ),
211 'rootJobTimestamp' => wfTimestampNow()
218 public function getRootJobParams() {
220 'rootJobSignature' => isset( $this->params
['rootJobSignature'] )
221 ?
$this->params
['rootJobSignature']
223 'rootJobTimestamp' => isset( $this->params
['rootJobTimestamp'] )
224 ?
$this->params
['rootJobTimestamp']
230 * Insert a single job into the queue.
231 * @return bool true on success
234 public function insert() {
235 return JobQueueGroup
::singleton()->push( $this );
241 public function toString() {
243 if ( $this->params
) {
244 foreach ( $this->params
as $key => $value ) {
245 if ( $paramString != '' ) {
249 if ( is_array( $value ) ) {
250 $value = "array(" . count( $value ) . ")";
251 } else if ( is_object( $value ) && !method_exists( $value, '__toString' ) ) {
252 $value = "object(" . get_class( $value ) . ")";
255 $paramString .= "$key=$value";
259 if ( is_object( $this->title
) ) {
260 $s = "{$this->command} " . $this->title
->getPrefixedDBkey();
261 if ( $paramString !== '' ) {
262 $s .= ' ' . $paramString;
266 return "{$this->command} $paramString";
270 protected function setLastError( $error ) {
271 $this->error
= $error;
274 public function getLastError() {