X-Git-Url: http://www.git.stargrave.org/?a=blobdiff_plain;f=lib%2FPublicInbox%2FGit.pm;h=12f997dc147ec80278392aa7cf088ef59d30ce26;hb=cc37f7c9858d46638a0eea7333912f74c05cb708;hp=9197ea674a1808bc06aeb86d04d57a3ede2a224e;hpb=1b03467e0f7e790191cbbab51baef0300d71133a;p=public-inbox.git diff --git a/lib/PublicInbox/Git.pm b/lib/PublicInbox/Git.pm index 9197ea67..12f997dc 100644 --- a/lib/PublicInbox/Git.pm +++ b/lib/PublicInbox/Git.pm @@ -373,13 +373,11 @@ sub check { } sub _destroy { - my ($self, $rbuf, $in, $out, $pid, $err) = @_; - delete @$self{($rbuf, $in, $out)}; - delete $self->{$err} if $err; # `err_c' + my ($self, $pid, @rest) = @_; # rest = rbuf, in, out, err + my ($p) = delete @$self{($pid, @rest)}; # GitAsyncCat::event_step may delete {$pid} - my $p = delete($self->{$pid}) // return; - awaitpid($p) if $$ == $self->{"$pid.owner"}; + awaitpid($p) if defined($p) && $$ == $self->{"$pid.owner"}; } sub async_abort ($) { @@ -468,8 +466,8 @@ sub cleanup { async_wait_all($self); delete $self->{inflight}; delete $self->{inflight_c}; - _destroy($self, qw(rbuf in out pid)); - _destroy($self, qw(rbuf_c in_c out_c pid_c err_c)); + _destroy($self, qw(pid rbuf in out)); + _destroy($self, qw(pid_c rbuf_c in_c out_c err_c)); undef; }