/**
* @see JobQueue::doBatchPush()
- * @param array $jobs
+ * @param IJobSpecification[] $jobs
* @param int $flags
* @throws DBError|Exception
* @return void
* This function should *not* be called outside of JobQueueDB
*
* @param IDatabase $dbw
- * @param array $jobs
+ * @param IJobSpecification[] $jobs
* @param int $flags
* @param string $method
* @throws DBError
}
if ( $flags & self::QOS_ATOMIC ) {
- $dbw->begin( $method ); // wrap all the job additions in one transaction
+ $dbw->startAtomic( $method ); // wrap all the job additions in one transaction
}
try {
// Strip out any duplicate jobs that are already in the queue...
throw $e;
}
if ( $flags & self::QOS_ATOMIC ) {
- $dbw->commit( $method );
+ $dbw->endAtomic( $method );
}
return;