File Coverage

blib/lib/BeamerReveal/IPC/Run.pm

Criterion	Covered	Total	%
statement	12	40	30.0
branch	0	14	0.0
condition			n/a
subroutine	4	6	66.6
pod	1	2	50.0
total	17	62	27.4

# -*- cperl -*-
# ABSTRACT: IPC::Run


package BeamerReveal::IPC::Run;
our $VERSION = '20260208.1851'; # VERSION

use strict;
use warnings;

use IPC::Run qw(harness start pump finish);

use File::chdir;


sub run {
  my ( $cmd, $coreId, $indent, $dir, $errormessage ) = @_;
  my ( $out, $err );

  my $logger = $BeamerReveal::Log::logger;

  my $r;
  eval {
    if( defined $dir ) {
      local $CWD = $dir;
      $r = IPC::Run::run( $cmd, \undef, \$out, \$err );
    }
    else {
      $r = IPC::Run::run( $cmd, \undef, \$out, \$err );
    }
  };

  if ( !defined( $r ) ) {
    $logger->fatal( "Error: $@\n" );
  }
  else {
    if ( $r ) {
      $logger->log( $indent, "- $cmd->[0] run in thread no $coreId finished" );
    }
    else {
      $logger->fatal( $errormessage );
    }
  }
}

sub runsmart {
  my ( $cmd, $mode, $regexp, $subroutine, $coreId, $indent, $dir, $errormessage ) = @_;
  my ( $in, $out, $err ) = ( '', undef, undef );

  # the stream to read the progress info from is set by $mode
  my $progress = ( $mode == 2 ) ? \$err : \$out;

  # get the logger
  my $logger = $BeamerReveal::Log::logger;

  # run the process until finish
  local $CWD = $dir if defined( $dir );
  my $h = harness $cmd, \$in, \$out, \$err;
  start $h;
  while( $h->pumpable ) {
    pump $h;
    my @matches = $$progress =~ $regexp;
    if ( scalar @matches ) {
      $subroutine->( @matches );
      $$progress = '';
    }
  }
  finish $h or $logger->fatal( $errormessage );
}

1;

__END__