]> Sergey Matveev's repositories - public-inbox.git/blobdiff - lib/PublicInbox/Qspawn.pm
qspawn: drop {psgi_env} deref
[public-inbox.git] / lib / PublicInbox / Qspawn.pm
index 5d3ec30926cdb5be848c0a38df738428af4ecbc9..779b703a0f270cf81196279c7f616a6b7c7283ac 100644 (file)
 # processes such as git-apply(1).
 
 package PublicInbox::Qspawn;
-use strict;
-use v5.10.1;
+use v5.12;
 use PublicInbox::Spawn qw(popen_rd);
 use PublicInbox::GzipFilter;
+use Scalar::Util qw(blessed);
 
 # n.b.: we get EAGAIN with public-inbox-httpd, and EINTR on other PSGI servers
 use Errno qw(EAGAIN EINTR);
@@ -201,7 +201,7 @@ sub rd_hdr ($) {
        my $total_rd = 0;
        my $hdr_buf = $self->{hdr_buf};
        my ($ph_cb, $ph_arg) = @{$self->{parse_hdr}};
-       do {
+       until (defined($ret)) {
                my $r = sysread($self->{rpipe}, $$hdr_buf, 4096,
                                length($$hdr_buf));
                if (defined($r)) {
@@ -212,7 +212,6 @@ sub rd_hdr ($) {
                                $ret = [ 500, [], [ "Internal error\n" ] ];
                        } elsif (!defined($ret) && !$r) {
                                my $cmd = $self->{cmd} // [ '(?)' ];
-                               my $env = $self->{psgi_env};
                                warn <<EOM;
 EOF parsing headers from @$cmd ($self->{psgi_env}->{REQUEST_URI})
 EOM
@@ -225,7 +224,7 @@ EOM
                        warn "error reading header: $!";
                        $ret = [ 500, [], [ "Internal error\n" ] ];
                }
-       } until (defined $ret);
+       }
        delete $self->{parse_hdr}; # done parsing headers
        $ret;
 }
@@ -235,8 +234,9 @@ sub psgi_return_init_cb { # this may be PublicInbox::HTTPD::Async {cb}
        my $r = rd_hdr($self) or return;
        my $env = $self->{psgi_env};
        my $filter;
-       if (ref($r) eq 'ARRAY' && Scalar::Util::blessed($r->[2]) &&
-                       $r->[2]->can('attach')) {
+
+       # this is for RepoAtom since that can fire after parse_cgi_headers
+       if (ref($r) eq 'ARRAY' && blessed($r->[2]) && $r->[2]->can('attach')) {
                $filter = pop @$r;
        }
        $filter //= delete($env->{'qspawn.filter'}) // (ref($r) eq 'ARRAY' ?
@@ -332,8 +332,7 @@ sub psgi_return {
 }
 
 package PublicInbox::Qspawn::Limiter;
-use strict;
-use warnings;
+use v5.12;
 
 sub new {
        my ($class, $max) = @_;