ben/handbrake-cluster-webui
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Update database with rip progress

Browse Source 
Changes the status to RUNNING when the task is queued in Gearman, and
updates the progress information each time gearman reports a status
update.
This commit is contained in:
Ben Roberts
2010-06-08 21:23:42 +01:00
parent 41e09ff440
commit 6b0017c5b8
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
run-jobs.php
View File

@@ -40,6 +40,9 @@ function gearman_created_callback($gearman_task) {
$main = HandBrakeCluster_Main::instance(); $main = HandBrakeCluster_Main::instance();
$log = $main->log(); $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()); $log->info("Job successfully queued with Gearman", $gearman_task->unique());
} }
@@ -53,13 +56,13 @@ function gearman_data_callback($gearman_task) {
function gearman_status_callback($gearman_task) { function gearman_status_callback($gearman_task) {
$main = HandBrakeCluster_Main::instance(); $main = HandBrakeCluster_Main::instance();
$log = $main->log(); $log = $main->log();
$job = HandBrakeCluster_Job::fromId($gearman_task->unique()); $job = HandBrakeCluster_Job::fromId($gearman_task->unique());
$status = $job->currentStatus(); $status = $job->currentStatus();
$rip_progress = $gearman_task->taskNumerator() / $gearman_task->taskDenominator(); $rip_progress = $gearman_task->taskNumerator() / $gearman_task->taskDenominator();
if ($rip_progress > $status->ripProgress() + 0.1) { if ($rip_progress > $status->ripProgress() + 0.1) {
$status->updateRipProgress(); $status->updateRipProgress($rip_progress);
} }
} }
@@ -87,4 +90,4 @@ function gearman_fail_callback($gearman_task) {
?> ?>