File Coverage

blib/lib/Proc/JobQueue/RemoteDependencyJob.pm

Criterion	Covered	Total	%
statement	16	18	88.8
branch			n/a
condition			n/a
subroutine	6	6	100.0
pod			n/a
total	22	24	91.6

package Proc::JobQueue::RemoteDependencyJob;

use strict;
use warnings;
use Scalar::Util qw(blessed);
use Callback;
use Proc::JobQueue::Job;
use RPC::ToWorker;
require Proc::JobQueue::Job;
use Carp qw(confess);

our @ISA = qw(Proc::JobQueue::Job);

sub create
{
	my ($pkg, %params) = @_;

	my $job = $pkg->SUPER::new(
		local_data		=> undef,
		data			=> undef,
		chdir			=> undef,
		prequel			=> '',
		when_done		=> undef,
		all_done		=> undef,
		%params,
	);
	return $job;
}

sub new
{
	my ($pkg, $dependency_graph, $preload, $func, %params) = @_;

	my $data = delete $params{args};
	my $whendone = delete $params{whendone};

	return $pkg->create(
		dependency_graph	=> $dependency_graph,
		preload			=> $preload,
		eval			=> "$func(\@\$data)",
		desc			=> "RPC call to $func",
		data			=> $data,
		when_done		=> $whendone,
		%params,
	);
}

sub startup
{
	my ($job) = @_;
	$job->{on_start}->($job, $job->{dependency_graph}) if $job->{on_start};
	do_remote_job(
		data		=> $job->{data},
		desc		=> $job->{desc},
		host		=> $job->{host},
		eval		=> $job->{eval},
		chdir		=> $job->{chdir},
		prequel		=> $job->{prequel},
		preload		=> $job->{preload},
		prefix		=> $job->{prefix},
		when_done	=> sub {
			if ($job->{when_done}) {
				$job->{when_done}(@_);
			} else {
				$job->finished(0);
			}
		},
		all_done	=> $job->{all_done},
		local_data	=> $job->{local_data} || {
			dependency_graph	=> $job->{dependency_graph},
			master_job		=> $job,
			job_queue		=> $job->queue(),
		},
	);
}

1;

__END__