Merge pull request #63 from Martchus/tidy

Apply tidy 20250105

Author: okurz

lib/Mojo/IOLoop/ReadWriteProcess/Container.pm

@@ -129,8 +129,8 @@ sub start {
     $self->process->diag("Starting container");
     $self->process->diag("\tName: " . $self->name)   if defined $self->name;
     $self->process->diag("\tGroup: " . $self->group) if defined $self->group;
-    $self->cgroups->each(sub { $self->process->diag("CGroup: " . $_->_cgroup) }
-    );
+    $self->cgroups->each(
+      sub { $self->process->diag("CGroup: " . $_->_cgroup) });
   }
 
   local ($@, $!);

lib/Mojo/IOLoop/ReadWriteProcess/Session.pm

@@ -65,8 +65,10 @@ sub enable {
 sub _collect {
   my ($self, $pid, $status, $errno) = @_;
   my $p = $singleton->resolve($pid);
-  $p->emit('SIG_CHLD')->emit(collect_status => $pid => $status => $errno)
-    ->emit('collected')->emit('stop');
+  $p->emit('SIG_CHLD')
+    ->emit(collect_status => $pid => $status => $errno)
+    ->emit('collected')
+    ->emit('stop');
 }
 
 sub collect {

lib/Mojo/IOLoop/ReadWriteProcess/Shared/Semaphore.pm

@@ -41,10 +41,10 @@ sub acquire {
   my %args = @_ % 2 == 0 ? @_ : @_ == 1 && ref $_[0] eq 'HASH' ? %{$_[0]} : ();
 
   # Defaults
-  $args{'sem'}  = 0  unless defined($args{'sem'});
-  $args{'wait'} = 0  unless defined($args{'wait'});
+  $args{'sem'}  =  0 unless defined($args{'sem'});
+  $args{'wait'} =  0 unless defined($args{'wait'});
   $args{'max'}  = -1 unless defined($args{'max'});
-  $args{'undo'} = 0  unless defined($args{'undo'});
+  $args{'undo'} =  0 unless defined($args{'undo'});
   warn "[debug:$$] Acquire semaphore " . $self->key if DEBUG;
 
   my $sem   = $self->_sem;

t/01_run.t

@@ -297,7 +297,10 @@ subtest 'process(execute => /bin/true)' => sub {
   check_bin('/bin/true');
 
   is(
-    process(execute => '/bin/true')->quirkiness(1)->start()->wait_stop()
+    process(execute => '/bin/true')
+      ->quirkiness(1)
+      ->start()
+      ->wait_stop()
       ->exit_status(),
     0,
     'Simple exec of /bin/true return 0'
@@ -556,7 +559,9 @@ subtest 'process_args' => sub {
     ->start->wait_stop();
   is($p->read_all_stdout(), "0$/1$/2$/3$/", '1) Args given as arrayref.');
 
-  $p = Mojo::IOLoop::ReadWriteProcess->new($code)->args([(0 .. 3)])
+  $p
+    = Mojo::IOLoop::ReadWriteProcess->new($code)
+    ->args([(0 .. 3)])
     ->start->wait_stop();
   is($p->read_all_stdout(), "0$/1$/2$/3$/", '2) Args given as arrayref.');
 };
@@ -568,19 +573,27 @@ subtest 'process in process' => sub {
   my $p = process(
     sub {
       is(
-        process(execute => '/bin/true')->quirkiness(1)->start()->wait_stop()
+        process(execute => '/bin/true')
+          ->quirkiness(1)
+          ->start()
+          ->wait_stop()
           ->exit_status(),
         0,
         'process(execute) from process(code) -- retval check true'
       );
       is(
-        process(execute => '/bin/false')->quirkiness(1)->start()->wait_stop()
+        process(execute => '/bin/false')
+          ->quirkiness(1)
+          ->start()
+          ->wait_stop()
           ->exit_status(),
         1,
         'process(execute) from process(code) -- retval check false'
       );
       is(
-        process(sub { print 'sub-sub-process' })->start()->wait_stop()
+        process(sub { print 'sub-sub-process' })
+          ->start()
+          ->wait_stop()
           ->read_all_stdout,
         'sub-sub-process',
         'process(code) works from process(code)'
@@ -613,7 +626,10 @@ subtest 'SIG_CHLD handler in spawned process' => sub {
   # 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()
+    process(execute => 'perl')
+      ->args([$simple_rwp])
+      ->start()
+      ->wait_stop()
       ->exit_status(),
     0,
     'simple_rwp.pl exit with 0'

t/04_queues.t

@@ -173,8 +173,11 @@ subtest stress_test => sub {
 # Started as long as resources allows (maximum_processes of the main pool)
 # That requires then to subscribe for each process event's separately (manually)
   for (1 .. $proc) {
-    my $p = process(sub { shift; sleep 4; exit shift() })->set_pipes(0)
-      ->internal_pipes(0)->args($i);
+    my $p
+      = process(sub { shift; sleep 4; exit shift() })
+      ->set_pipes(0)
+      ->internal_pipes(0)
+      ->args($i);
     $p->once(
       stop => sub {
         $fired++;

t/data/simple_rwp.pl

@@ -4,6 +4,8 @@
 use Mojo::IOLoop::ReadWriteProcess 'process';
 
 # Not all systems have /bin/true, this is /usr/bin/true on osx for instance
-my $p = process(execute => 'command -v true || which true')->start()
+my $p
+  = process(execute => 'command -v true || which true')
+  ->start()
   ->wait_stop->read_all_stdout;
 exit process(execute => $p)->start()->wait_stop()->exit_status();