File Coverage

blib/lib/Parallel/Workers/Transaction.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 Parallel::Workers::Transaction;

use warnings;
use strict;
use Carp;
use Data::Dumper;
use threads::shared;
use Parallel::Workers::Shared;

our (@ISA, @EXPORT, @EXPORT_OK);
@ISA = qw(Exporter);

@EXPORT = qw(TRANSACTION_CONT TRANSACTION_TERM);
@EXPORT_OK = ();

use constant TRANSACTION_CONT=>"CONT";
use constant TRANSACTION_TERM=>"TERM";


# Module implementation here
# init the transaction for n workers
# error=>TRANSACTION_CONT, enable=>1, type => SCALAR,check => 0, regex=> undef
sub new {
    my $class:shared = shift;
    my %args = @_;

    my $this={
              error =>(defined $args{error})?$args{error}:TRANSACTION_CONT,
              enable=>(defined $args{enable})?$args{enable}:1,
              type  =>(defined $args{type})?$args{type}:"SCALAR",
              check =>$args{check},
              regex =>$args{regex}
             };


    bless $this, $class;
    return $this;
}


sub check{
  my $this=shift;
  my ($tid, $result)=@_;

  return TRANSACTION_CONT unless $this->{enable};

  return $this->{error} unless ($this->{type} eq ref(\$result));

  if (defined $this->{regex}){
    my $reg=qr/$this->{regex}/;
#    my $reg=qr/$this->{regex}/;
#    print "INFO:regex detected".$this->{regex}."\n" unless defined $result || $result=~ $reg ;
    return $this->{error} unless defined $result ;
    return $this->{error} unless $result=~ $this->{regex} ;
}

  if (defined $this->{check}){
   return $this->{error} unless $result=$this->{check};
  }

  return TRANSACTION_CONT;
}



1; # Magic true value required at end of module
__END__