File Coverage

blib/lib/Proc/JobQueue/Move.pm

Criterion	Covered	Total	%
statement	27	29	93.1
branch	1	4	25.0
condition	2	6	33.3
subroutine	10	10	100.0
pod	3	6	50.0
total	43	55	78.1

package Proc::JobQueue::Move;

# $Id: Move.pm 13853 2009-07-24 00:59:44Z david $

use strict;
use warnings;
require Proc::JobQueue;
require Proc::JobQueue::Job;
our @ISA = qw(Proc::JobQueue::Job);
use Tie::Function::Examples qw(%q_shell);
use Proc::JobQueue qw(my_hostname is_remote_host);

my %destinations;
my $copies_running = 0;

my $debug = $Proc::JobQueue::debug;

sub new
{
	my ($pkg, $opts, $config, $from_file, $to_file, $to_host, $from_host) = @_;
	$pkg->SUPER::new(
		from_host	=> $from_host || my_hostname(),
		config		=> $config,
		opts		=> $opts,
		from		=> $from_file,
		to		=> $to_file,
		to_host		=> $to_host || my_hostname(),
		desc		=> "move to $to_host:$to_file",
		priority	=> 10,
	);
}

sub command
{
	my ($job) = @_;
	if (is_remote_host($job->{to_host})) {
		my $compress = $job->{config}{compress_network_copies} ? "-C" : "";
		return "scp -q -o StrictHostKeyChecking=no -o BatchMode=yes $compress $q_shell{$job->{from}} $q_shell{$job->{to_host}}:$q_shell{$job->{to}} && rm $q_shell{$job->{from}}";
	} else {
		# maybe it's on another filesystem
		return "mv $q_shell{$job->{from}} $q_shell{$job->{to}}";
	}
}

sub runnable
{
	my ($job) = @_;
	return ! $destinations{$job->{to_host}};
}

sub start
{
	my $job = shift;
	$job->SUPER::start(@_);
	$destinations{$job->{to_host}} = 1;
}

sub finished
{
	my $job = shift;
	$destinations{$job->{to_host}} = 0;
	$job->SUPER::finished(@_);
}

sub success
{
	my ($job) = @_;
	unlink($job->{from});
}

1;

__END__