File Coverage

blib/lib/Proc/JobQueue/Sort.pm

Criterion	Covered	Total	%
statement	28	32	87.5
branch	2	4	50.0
condition			n/a
subroutine	8	9	88.8
pod	1	5	20.0
total	39	50	78.0

package Proc::JobQueue::Sort;

# $Id: Sort.pm 13848 2009-07-23 21:34:00Z david $

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

use overload
	'""' => \&describe;

sub new
{
	my ($pkg, $opts, $config, $dest, @inputs) = @_;
	return $pkg->SUPER::new(
		config	=> $config,
		opts	=> $opts,
		dest	=> $dest,
		inputs	=> \@inputs,
		desc	=> "Sort to $dest",
	);
}

sub describe
{
	my ($job) = @_;
	if (@{$job->{inputs}} > 5) {
		return "Sort $job->{inputs}[0], $job->{inputs}[1] ... > $job->{dest}";
	} else {
		return "Sort @{$job->{inputs}} > $job->{dest}";
	}
}

sub command
{
	my ($job) = @_;
	my $mem = '';
	my $config = $job->{config};
	if ($config->{unix_sort_memory_buffer}) {
		$mem = "--buffer-size=$config->{unix_sort_memory_buffer}";
	}
	return "sort $mem -o $q_shell{$job->{dest}} @q_shell{@{$job->{inputs}}}";
}

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

sub failed
{
	my ($job) = @_;
	unlink($job->{dest});
}

1;

__END__