diff options
author | Eric Wong <e@80x24.org> | 2023-01-25 10:18:33 +0000 |
---|---|---|
committer | Eric Wong <e@80x24.org> | 2023-01-26 02:18:12 +0000 |
commit | 3a709083fd01cbe0c1f679e73e40e44b0e5e3840 (patch) | |
tree | 0bfa586087d1c8f75e52b798f6b61cf9ec1a7dbd /lib/PublicInbox | |
parent | 24f55535e78be0f1fa394bcd1aebc8c027e937c7 (diff) | |
download | public-inbox-3a709083fd01cbe0c1f679e73e40e44b0e5e3840.tar.gz |
While most uses of ->DESTROY happens in a predictable order in long-lived daemons, process teardown on exit is chaotic and not subject to ordering guarantees, so we must keep both ends of a `git cat-file --batch*' pipe at the same level in the object hierarchy. Drop an old Carp import while I'm in the area.
Diffstat (limited to 'lib/PublicInbox')
-rw-r--r-- | lib/PublicInbox/Git.pm | 1 | ||||
-rw-r--r-- | lib/PublicInbox/ProcessPipe.pm | 6 |
2 files changed, 5 insertions, 2 deletions
diff --git a/lib/PublicInbox/Git.pm b/lib/PublicInbox/Git.pm index ff3ac40f..a3813bf2 100644 --- a/lib/PublicInbox/Git.pm +++ b/lib/PublicInbox/Git.pm @@ -156,6 +156,7 @@ sub _bidi_pipe { $self->{$err} = $fh; $rdr->{2} = $fh; } + # see lib/PublicInbox/ProcessPipe.pm for why we don't use that here my ($in_r, $p) = popen_rd(\@cmd, undef, $rdr); awaitpid($self->{$pid} = $p, undef); $self->{"$pid.owner"} = $$; diff --git a/lib/PublicInbox/ProcessPipe.pm b/lib/PublicInbox/ProcessPipe.pm index 068631c6..1bc792c4 100644 --- a/lib/PublicInbox/ProcessPipe.pm +++ b/lib/PublicInbox/ProcessPipe.pm @@ -1,10 +1,12 @@ # Copyright (C) all contributors <meta@public-inbox.org> # License: AGPL-3.0+ <https://www.gnu.org/licenses/agpl-3.0.txt> -# a tied handle for auto reaping of children tied to a pipe, see perltie(1) +# a tied handle for auto reaping of children tied to a read-only pipe, see perltie(1) +# DO NOT use this as-is for bidirectional pipes/sockets (e.g. in PublicInbox::Git), +# both ends of the pipe must be at the same level of the Perl object hierarchy +# to ensure orderly destruction. package PublicInbox::ProcessPipe; use v5.12; -use Carp qw(carp); use PublicInbox::DS qw(awaitpid); sub waitcb { # awaitpid callback |