]> Sergey Matveev's repositories - public-inbox.git/blobdiff - lib/PublicInbox/SpawnPP.pm
imap+nntp: share COMPRESS implementation
[public-inbox.git] / lib / PublicInbox / SpawnPP.pm
index 401cb78de083ebf294ddec7847294d849d1c1142..6d7e2c34ec9046111056b350084c947dbaa070e0 100644 (file)
@@ -16,46 +16,59 @@ sub pi_fork_exec ($$$$$$$) {
        $set->fillset or die "fillset failed: $!";
        sigprocmask(SIG_SETMASK, $set, $old) or die "can't block signals: $!";
        my $syserr;
+       pipe(my ($r, $w));
        my $pid = fork;
        unless (defined $pid) { # compat with Inline::C version
                $syserr = $!;
                $pid = -1;
        }
        if ($pid == 0) {
+               close $r;
+               $SIG{__DIE__} = sub {
+                       warn(@_);
+                       syswrite($w, my $num = $! + 0);
+                       _exit(1);
+               };
                for my $child_fd (0..$#$redir) {
                        my $parent_fd = $redir->[$child_fd];
                        next if $parent_fd == $child_fd;
                        dup2($parent_fd, $child_fd) or
-                               die "dup2($parent_fd, $child_fd): $!\n";
+                               die "dup2($parent_fd, $child_fd): $!";
                }
                if ($pgid >= 0 && !defined(setpgid(0, $pgid))) {
-                       warn "setpgid: $!";
-                       _exit(1);
+                       die "setpgid(0, $pgid): $!";
+               }
+               for (keys %SIG) {
+                       $SIG{$_} = 'DEFAULT' if substr($_, 0, 1) ne '_';
                }
-               $SIG{$_} = 'DEFAULT' for keys %SIG;
                if ($cd ne '') {
                        chdir $cd or die "chdir $cd: $!";
                }
                while (@$rlim) {
                        my ($r, $soft, $hard) = splice(@$rlim, 0, 3);
                        BSD::Resource::setrlimit($r, $soft, $hard) or
-                         warn "failed to set $r=[$soft,$hard]\n";
+                               die "setrlimit($r=[$soft,$hard]: $!)";
                }
                $old->delset(POSIX::SIGCHLD) or die "delset SIGCHLD: $!";
                sigprocmask(SIG_SETMASK, $old) or die "SETMASK: ~SIGCHLD: $!";
+               $cmd->[0] = $f;
                if ($ENV{MOD_PERL}) {
-                       exec which('env'), '-i', @$env, @$cmd;
-                       die "exec env -i ... $cmd->[0] failed: $!\n";
+                       @$cmd = (which('env'), '-i', @$env, @$cmd);
                } else {
-                       local %ENV = map { split(/=/, $_, 2) } @$env;
-                       my @cmd = @$cmd;
-                       $cmd[0] = $f;
-                       exec @cmd;
-                       die "exec $cmd->[0] failed: $!\n";
+                       %ENV = map { split(/=/, $_, 2) } @$env;
                }
+               undef $r;
+               exec { $f } @$cmd;
+               die "exec @$cmd failed: $!";
        }
+       close $w;
        sigprocmask(SIG_SETMASK, $old) or die "can't unblock signals: $!";
-       $! = $syserr;
+       if (my $cerrnum = do { local $/, <$r> }) {
+               $pid = -1;
+               $! = $cerrnum;
+       } else {
+               $! = $syserr;
+       }
        $pid;
 }