File Coverage

blib/lib/Seshat/Parallel.pm

Criterion	Covered	Total	%
statement	9	34	26.4
branch	0	6	0.0
condition			n/a
subroutine	3	7	42.8
pod			n/a
total	12	47	25.5

package Seshat::Parallel;

use strict;
use vars qw($VERSION @ISA @EXPORT @EXPORT_OK);
use Data::Dumper;

require Exporter;
require AutoLoader;
require Seshat;


@ISA = qw(Exporter AutoLoader);
# Items to export into callers namespace by default. Note: do not export
# names by default without a very good reason. Use EXPORT_OK instead.
# Do not simply export all your public functions/methods/constants.
@EXPORT = qw(

);
$VERSION = '1.01';

sub new {
        my ($classname,$files) = @_;
        my $self = {};
	foreach (@$files) {
		$self->{files}->{$_} = Seshat->new($_);
	}
        $self->{NAME} = "Seshat::Parallel";
        bless ($self,$classname);
        return $self;
}
sub write {
	my ($self, $string, $flag) = @_;
	foreach ( keys %{$self->{files}} ) {
		my $lh = $self->{files}->{$_};
		my $res = $lh->write($string,$flag);
		warn "$@" unless $res;
	}
}
sub register {
	my ($self, $filename) = @_;
	if (! exists $self->{files}->{$filename}) {
		$self->{files}->{$filename} = Seshat->new($filename);
	} else {
		$@ = "The requested file is already in queue";
		return undef;
	}
	return 1;
}
sub unregister {
	my ($self, $filename) = @_;
	if (exists $self->{files}->{$filename}) {
		delete $self->{files}->{$filename};
	} else {
		$@ = "The requested file is not in queue";
		return undef;
	}
	return 1;
}

1;
__END__