diff options
| author | Eric Wong <e@80x24.org> | 2023-10-07 21:24:08 +0000 |
|---|---|---|
| committer | Eric Wong <e@80x24.org> | 2023-10-08 18:54:47 +0000 |
| commit | 1661ff8e21f3cb1df1a3fc00d917f404f4eae734 (patch) | |
| tree | bd2d06840b241b5f4546688fa07b1bf7790f4222 /lib/PublicInbox/Qspawn.pm | |
| parent | 27423677034478018a202e5ddff02c5d2e0de061 (diff) | |
| download | public-inbox-1661ff8e21f3cb1df1a3fc00d917f404f4eae734.tar.gz | |
Since we deal with pipes (of either direction) and bidirectional stream sockets for this class, it's better to remove the `Pipe' from the name and replace it with `IO' to communicate that it works for any form of IO::Handle-like object tied to a process.
Diffstat (limited to 'lib/PublicInbox/Qspawn.pm')
| -rw-r--r-- | lib/PublicInbox/Qspawn.pm | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/lib/PublicInbox/Qspawn.pm b/lib/PublicInbox/Qspawn.pm index 5e4fd5cb..ea7ae647 100644 --- a/lib/PublicInbox/Qspawn.pm +++ b/lib/PublicInbox/Qspawn.pm @@ -124,7 +124,7 @@ sub finish ($;$) { # we can safely finalize if pipe was closed before, or if # {_err} is defined by waitpid_err. Deleting {rpipe} will - # trigger PublicInbox::ProcessPipe::DESTROY -> waitpid_err, + # trigger PublicInbox::ProcessIO::DESTROY -> waitpid_err, # but it may not fire right away if inside the event loop. my $closed_before = !delete($self->{rpipe}); finalize($self) if $closed_before || defined($self->{_err}); @@ -251,7 +251,7 @@ sub psgi_return_init_cb { # this may be PublicInbox::HTTPD::Async {cb} if (ref($r) ne 'ARRAY' || scalar(@$r) == 3) { # error if ($async) { # calls rpipe->close && ->event_step $async->close; # PublicInbox::HTTPD::Async::close - } else { # generic PSGI, use PublicInbox::ProcessPipe::CLOSE + } else { # generic PSGI, use PublicInbox::ProcessIO::CLOSE delete($self->{rpipe})->close; event_step($self); } |