File Coverage

blib/lib/Proc/JobQueue/DependencyTask.pm

Criterion	Covered	Total	%
statement	33	42	78.5
branch	4	14	28.5
condition	4	13	30.7
subroutine	8	9	88.8
pod	0	3	0.0
total	49	81	60.4

package Proc::JobQueue::DependencyTask;

use strict;
use warnings;
use Callback;
use Scalar::Util qw(blessed);
use Carp qw(confess);

sub new
{
	my ($pkg, %params) = @_;
	my ($cpkg, $file, $line) = caller;
	confess "A function is required" unless $params{func};
	$params{args} ||= [];
	my $task = bless {
		desc		=> $params{desc} || "no desc, called from $file:$line",
		trace		=> "$file:$line",
		errors		=> $params{errors} || sub { print STDERR @_ },
		%params,
	}, $pkg;
	$task->set_cb($params{func}, $params{args});
	return $task;
}

sub set_cb
{
	my ($task, $func, $args) = @_;

	if (blessed($func) && $func->isa('Callback')) {
		$task->{cb} = $func;
	} else {
		$task->{cb} = Callback->new($func, @$args);
	}
}

sub run_dependency_task
{
	my ($task, $dependency_graph) = @_;

	my ($code, @more);
	eval {
		($code, @more) = $task->{cb}->call($task, $dependency_graph);
	};
	if ($@) {
		$task->{errors}->("----------------------- FAILURE\nTask $task->{desc} failed: $@\n");
		$dependency_graph->stuck_dependency($task, "call failed: $@");
		return 0;
	}

	if ($code eq 'done') {
		$dependency_graph->remove_dependency($task);
		return 1;
	} elsif ($code eq 'keep' || $code eq 'ignore') {
		# nada
	} elsif ($code eq 'requeue') {
		$task->set_cb(@more) if @more;
		$dependency_graph->unlock($task);
	} else {
		die "bad return code from $task->{desc}";
	}
 	return 0;
}

1;

__END__