File Coverage

blib/lib/Proc/JobQueue/BackgroundQueue.pm

Criterion	Covered	Total	%
statement	31	41	75.6
branch	4	10	40.0
condition			n/a
subroutine	6	6	100.0
pod	1	2	50.0
total	42	59	71.1

package Proc::JobQueue::BackgroundQueue;

use strict;
use warnings;
use Carp qw(confess);
use Time::HiRes qw(sleep);
require Proc::JobQueue;

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

our $debug = $Proc::JobQueue::debug;

sub new
{
	my ($pkg, %params) = @_;
	my $queue = $pkg->SUPER::new(sleeptime => 2, %params);
}

sub finish
{
	my $queue = shift;
	for(;;) {
		$queue->checkjobs();
		return if $queue->startmore();

		my $running = 0;
		my $queued = keys %{$queue->{queue}};
		for my $host (@{$queue->{hosts}}) {
			my $hr = $queue->{status}{$host};
			$running += keys %{$hr->{running}};
			$queued += keys %{$hr->{queue}};
		}

		if ($debug > 2) {
			print STDERR "Finish loop top: $running running, $queued queued\n";
			for my $host (@{$queue->{hosts}}) {
				my $hr = $queue->{status}{$host};
				print "running: " . join(", ", map { $_ . ": " . $hr->{running}{$_}{desc} } keys %{$hr->{running}} ) . "\n" if $running;
				print "queued: " . join(", ", map { $_ . ": " . $hr->{running}{$_}{desc} } keys %{$hr->{queue}} ) . "\n" if $queued;
			}
		}

		print "Jobs are waiting to be run, but none are running\n" unless $running;
		sleep($queue->{sleeptime});
	}
}

1;

__END__