File Coverage

lib/Rex/Fork/Task.pm

Criterion	Covered	Total	%
statement	26	26	100.0
branch	4	4	100.0
condition	1	3	33.3
subroutine	6	6	100.0
pod	0	3	0.0
total	37	42	88.1

#
# (c) Jan Gehring
#

package Rex::Fork::Task;

use v5.12.5;
use warnings;
use POSIX ":sys_wait_h";

our $VERSION = '1.14.3'; # VERSION

sub new {
  my $that  = shift;
  my $proto = ref($that) || $that;
  my $self  = {@_};

  bless( $self, $proto );

  $self->{'running'} = 0;

  return $self;
}

sub start {
  my ($self) = @_;

  $self->{'running'} = 1;
  $self->{pid}       = fork;

  if ( !$self->{pid} ) {
    $self->{coderef}->($self);
    $self->{'running'} = 0;
    exit();
  }
}

sub wait {
  my ($self) = @_;
  my $rpid = waitpid( $self->{pid}, &WNOHANG );
  if ( $rpid == -1 ) { $self->{'running'} = 0; }

  return $rpid;
}

1;