Ben Roberts
6b0017c5b8
Changes the status to RUNNING when the task is queued in Gearman, and updates the progress information each time gearman reports a status update.
94 lines
2.7 KiB
PHP
94 lines
2.7 KiB
PHP
<?php
|
|
|
|
require 'HandBrakeCluster/Main.class.php';
|
|
try {
|
|
$main = HandBrakeCluster_Main::instance();
|
|
$config = $main->config();
|
|
$log = $main->log();
|
|
|
|
$gearman = new GearmanClient();
|
|
$gearman->addServers($config->get('rips.job_servers'));
|
|
$gearman->setCreatedCallback("gearman_created_callback");
|
|
$gearman->setDataCallback("gearman_data_callback");
|
|
$gearman->setStatusCallback("gearman_status_callback");
|
|
$gearman->setCompleteCallback("gearman_complete_callback");
|
|
$gearman->setFailCallback("gearman_fail_callback");
|
|
|
|
// Retrieve a list of Created jobs
|
|
$jobs = HandBrakeCluster_Job::allWithStatus(HandBrakeCluster_JobStatus::CREATED);
|
|
|
|
foreach ($jobs as $job) {
|
|
// Enqueue the job using gearman
|
|
$job->queue($gearman);
|
|
}
|
|
|
|
// Start the job queue
|
|
$result = $gearman->runTasks();
|
|
if (!$result) {
|
|
$log->error($gearman->error());
|
|
die($gearman->error());
|
|
}
|
|
|
|
$log->info("Job queue completed");
|
|
|
|
} catch (HandBrakeCluster_Exception $e) {
|
|
die("Uncaught Exception (" . get_class($e) . "): " . $e->getMessage() . "\n");
|
|
}
|
|
|
|
|
|
function gearman_created_callback($gearman_task) {
|
|
$main = HandBrakeCluster_Main::instance();
|
|
$log = $main->log();
|
|
|
|
$job = HandBrakeCluster_Job::fromId($gearman_task->unique());
|
|
$job->updateStatus(HandBrakeCluster_JobStatus::RUNNING);
|
|
|
|
$log->info("Job successfully queued with Gearman", $gearman_task->unique());
|
|
}
|
|
|
|
function gearman_data_callback($gearman_task) {
|
|
$main = HandBrakeCluster_Main::instance();
|
|
$log = $main->log();
|
|
|
|
$log->debug("Got some data from gearman", $gearman_task->unique());
|
|
}
|
|
|
|
function gearman_status_callback($gearman_task) {
|
|
$main = HandBrakeCluster_Main::instance();
|
|
$log = $main->log();
|
|
|
|
$job = HandBrakeCluster_Job::fromId($gearman_task->unique());
|
|
$status = $job->currentStatus();
|
|
|
|
$rip_progress = $gearman_task->taskNumerator() / $gearman_task->taskDenominator();
|
|
if ($rip_progress > $status->ripProgress() + 0.1) {
|
|
$status->updateRipProgress($rip_progress);
|
|
}
|
|
}
|
|
|
|
function gearman_complete_callback($gearman_task) {
|
|
$main = HandBrakeCluster_Main::instance();
|
|
$log = $main->log();
|
|
|
|
$job = HandBrakeCluster_Job::fromId($gearman_task->unique());
|
|
$job->updateStatus(HandBrakeCluster_JobStatus::COMPLETE);
|
|
|
|
$log->info("Job Complete", $job->id());
|
|
}
|
|
|
|
function gearman_fail_callback($gearman_task) {
|
|
$main = HandBrakeCluster_Main::instance();
|
|
$log = $main->log();
|
|
|
|
$job = HandBrakeCluster_Job::fromId($gearman_task->unique());
|
|
$job->updateStatus(HandBrakeCluster_JobStatus::FAILED);
|
|
|
|
$log->info("Job Failed", $job->id());
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
?>
|