tidy

Author: cfconrad

t/01_run.t

@@ -614,17 +614,23 @@ subtest 'execute exeption handling' => sub {
 };
 
 subtest 'SIG_CHLD handler in spawned process' => sub {
-  my $simple_rwp = "$FindBin::Bin/data/simple_rwp.pl";
+  my $simple_rwp      = "$FindBin::Bin/data/simple_rwp.pl";
   my $sigchld_handler = "$FindBin::Bin/data/sigchld_handler.pl";
 
   # use `perl <script>` here, as Github ci action place the used perl executable
   # somewhere like /opt/hostedtoolcache/perl/<version>/<arch>/bin/perl so
   # /usr/bin/perl wouldn't have all needed dependencies
-  is( process(execute => 'perl')->args([$simple_rwp])->start()->wait_stop()->exit_status(), 0, 'simple_rwp.pl exit with 0');
+  is(
+    process(execute => 'perl')->args([$simple_rwp])->start()->wait_stop()
+      ->exit_status(),
+    0,
+    'simple_rwp.pl exit with 0'
+  );
 
   my $p = process(execute => $sigchld_handler);
-  is( $p->start()->wait_stop()->exit_status(), 0, 'sigchld_handler.pl exit with 0');
-  like( $p->read_all_stdout, qr/SIG_CHLD/, "SIG_CHLD handler was executed");
+  is($p->start()->wait_stop()->exit_status(),
+    0, 'sigchld_handler.pl exit with 0');
+  like($p->read_all_stdout, qr/SIG_CHLD/, "SIG_CHLD handler was executed");
 };
 
 done_testing;

t/02_parallel_error_check.t

@@ -10,16 +10,16 @@ use lib ("$FindBin::Bin/lib", "../lib", "lib");
 use Mojo::IOLoop::ReadWriteProcess qw(parallel batch process pool);
 
 sub check_error {
-    my ($c, $nproc) = @_;
-    my ($package, $filename, $line) = caller;
-    my $msg = "$package, $filename:$line";
-    my @errors = $c->error;
-    is scalar(@errors), $nproc , "$msg check error nr";
-
-    for my $e (@errors) {
-        is (scalar(@$e) , 0 , "$msg errors are zero");
-        is (join("", @$e), "", "$msg errors are empty");
-    } 
+  my ($c, $nproc) = @_;
+  my ($package, $filename, $line) = caller;
+  my $msg    = "$package, $filename:$line";
+  my @errors = $c->error;
+  is scalar(@errors), $nproc, "$msg check error nr";
+
+  for my $e (@errors) {
+    is(scalar(@$e),   0,  "$msg errors are zero");
+    is(join("", @$e), "", "$msg errors are empty");
+  }
 }
 
 subtest parallel => sub {
@@ -92,7 +92,7 @@ subtest batch => sub {
     separate_err => 0,
     set_pipes    => 1
   );
-  $n_proc ++;
+  $n_proc++;
   $c->start();
   check_error $c, $n_proc;
   is $c->last->getline, "Hello world 3\n";
@@ -102,7 +102,7 @@ subtest batch => sub {
 
   my $result;
   $c->add(code => sub { return 40 + 2 }, separate_err => 0, set_pipes => 0);
-  $n_proc ++;
+  $n_proc++;
   check_error $c, $n_proc;
   $c->last->on(
     stop => sub {

t/data/sigchld_handler.pl

@@ -5,8 +5,8 @@
 
 my $collected_pid = -1;
 $SIG{CHLD} = sub {
-    $collected_pid = waitpid(-1, 0);
-    print "SIG_CHLD $collected_pid exit:" . ( $?>>8) . "\n";
+  $collected_pid = waitpid(-1, 0);
+  print "SIG_CHLD $collected_pid exit:" . ($? >> 8) . "\n";
 };
 
 my $pid = fork();
@@ -15,6 +15,6 @@
   exit 0;
 }
 print "Forked child is $pid\n";
-sleep 0.1 while($collected_pid != $pid);
+sleep 0.1 while ($collected_pid != $pid);
 print "Exit graceful\n";
 exit 0;