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
89 public static function batchInsert( $jobs ) {
90 return JobQueueGroup
::singleton()->push( $jobs );
94 * Insert a group of jobs into the queue.
96 * Same as batchInsert() but does not commit and can thus
97 * be rolled-back as part of a larger transaction. However,
98 * large batches of jobs can cause slave lag.
100 * @param $jobs array of Job objects
104 public static function safeBatchInsert( $jobs ) {
105 return JobQueueGroup
::singleton()->push( $jobs, JobQueue
::QoS_Atomic
);
109 * Pop a job of a certain type. This tries less hard than pop() to
110 * actually find a job; it may be adversely affected by concurrent job
113 * @param $type string
117 public static function pop_type( $type ) {
118 return JobQueueGroup
::singleton()->get( $type )->pop();
122 * Pop a job off the front of the queue.
123 * This is subject to $wgJobTypesExcludedFromDefaultQueue.
125 * @return Job or false if there's no jobs
128 public static function pop() {
129 return JobQueueGroup
::singleton()->pop();
132 /*-------------------------------------------------------------------------
133 * Non-static functions
134 *------------------------------------------------------------------------*/
139 * @param $params array|bool
142 public function __construct( $command, $title, $params = false, $id = 0 ) {
143 $this->command
= $command;
144 $this->title
= $title;
145 $this->params
= $params;
148 $this->removeDuplicates
= false; // expensive jobs may set this to true
152 * @return integer May be 0 for jobs stored outside the DB
154 public function getId() {
161 public function getType() {
162 return $this->command
;
168 public function getTitle() {
175 public function getParams() {
176 return $this->params
;
182 public function ignoreDuplicates() {
183 return $this->removeDuplicates
;
187 * Subclasses may need to override this to make duplication detection work
189 * @return Array Map of key/values
191 public function getDeduplicationInfo() {
193 'type' => $this->getType(),
194 'namespace' => $this->getTitle()->getNamespace(),
195 'title' => $this->getTitle()->getDBkey(),
196 'params' => $this->getParams()
198 // Identical jobs with different "root" jobs should count as duplicates
199 if ( is_array( $info['params'] ) ) {
200 unset( $info['params']['rootJobSignature'] );
201 unset( $info['params']['rootJobTimestamp'] );
207 * @param $key string A key that identifies the task
210 public static function newRootJobParams( $key ) {
212 'rootJobSignature' => sha1( $key ),
213 'rootJobTimestamp' => wfTimestampNow()
220 public function getRootJobParams() {
222 'rootJobSignature' => isset( $this->params
['rootJobSignature'] )
223 ?
$this->params
['rootJobSignature']
225 'rootJobTimestamp' => isset( $this->params
['rootJobTimestamp'] )
226 ?
$this->params
['rootJobTimestamp']
232 * Insert a single job into the queue.
233 * @return bool true on success
236 public function insert() {
237 return JobQueueGroup
::singleton()->push( $this );
243 public function toString() {
245 if ( $this->params
) {
246 foreach ( $this->params
as $key => $value ) {
247 if ( $paramString != '' ) {
250 if ( is_array( $value ) ) {
251 $value = "array(" . count( $value ) . ")";
252 } elseif ( is_object( $value ) && !method_exists( $value, '__toString' ) ) {
253 $value = "object(" . get_class( $value ) . ")";
255 $value = (string)$value;
256 if ( mb_strlen( $value ) > 1024 ) {
257 $value = "string(" . mb_strlen( $value ) . ")";
260 $paramString .= "$key=$value";
264 if ( is_object( $this->title
) ) {
265 $s = "{$this->command} " . $this->title
->getPrefixedDBkey();
266 if ( $paramString !== '' ) {
267 $s .= ' ' . $paramString;
271 return "{$this->command} $paramString";
275 protected function setLastError( $error ) {
276 $this->error
= $error;
279 public function getLastError() {