diff options
author | Eric Wong <e@80x24.org> | 2023-10-23 19:35:17 +0000 |
---|---|---|
committer | Eric Wong <e@80x24.org> | 2023-10-23 19:58:27 +0000 |
commit | 35de8fdcbf290e25cae479ad2afdf6f13836d5d8 (patch) | |
tree | 767a7d969623db44d959e147c08c656761e0fa2c /lib/PublicInbox/XapHelper.pm | |
parent | 7a957421b338873f02fe86189ad388602b3bdc36 (diff) | |
download | public-inbox-35de8fdcbf290e25cae479ad2afdf6f13836d5d8.tar.gz |
We can't force EBADF with high-level I/O wrappers like we can in C, so instead we quiet Perl itself.
Diffstat (limited to 'lib/PublicInbox/XapHelper.pm')
-rw-r--r-- | lib/PublicInbox/XapHelper.pm | 23 |
1 files changed, 13 insertions, 10 deletions
diff --git a/lib/PublicInbox/XapHelper.pm b/lib/PublicInbox/XapHelper.pm index eea10a44..55080abf 100644 --- a/lib/PublicInbox/XapHelper.pm +++ b/lib/PublicInbox/XapHelper.pm @@ -17,7 +17,7 @@ use autodie qw(open getsockopt); use POSIX qw(:signal_h); use Fcntl qw(LOCK_UN LOCK_EX); my $X = \%PublicInbox::Search::X; -our (%SRCH, %WORKERS, $alive, $nworker, $workerset, $in); +our (%SRCH, %WORKERS, $nworker, $workerset, $in); our $stderr = \*STDERR; # only short options for portability in C++ implementation @@ -179,7 +179,11 @@ sub recv_loop { local $SIG{TERM} = sub { undef $in }; while (defined($in)) { PublicInbox::DS::sig_setmask($workerset); - my @fds = $PublicInbox::IPC::recv_cmd->($in, $rbuf, 4096*33); + my @fds = do { # we undef $in in SIG{TERM} + no strict 'refs'; + no warnings 'uninitialized'; + $PublicInbox::IPC::recv_cmd->($in, $rbuf, 4096*33) + }; scalar(@fds) or exit(66); # EX_NOINPUT die "recvmsg: $!" if !defined($fds[0]); PublicInbox::DS::block_signals(); @@ -201,11 +205,11 @@ sub reap_worker { # awaitpid CB my ($pid, $nr) = @_; delete $WORKERS{$nr}; if (($? >> 8) == 66) { # EX_NOINPUT - $alive = undef; + undef $in; } elsif ($?) { warn "worker[$nr] died \$?=$?\n"; } - PublicInbox::DS::requeue(\&start_workers) if $alive; + PublicInbox::DS::requeue(\&start_workers) if $in; } sub start_worker ($) { @@ -230,27 +234,26 @@ sub start_worker ($) { sub start_workers { for my $nr (grep { !defined($WORKERS{$_}) } (0..($nworker - 1))) { - start_worker($nr) if $alive; + start_worker($nr) if $in; } } sub do_sigttou { - if ($alive && $nworker > 1) { + if ($in && $nworker > 1) { --$nworker; my @nr = grep { $_ >= $nworker } keys %WORKERS; kill('TERM', @WORKERS{@nr}); } } -sub xh_alive { $alive || scalar(keys %WORKERS) } +sub xh_alive { $in || scalar(keys %WORKERS) } sub start (@) { my (@argv) = @_; - my $c = getsockopt($in = \*STDIN, SOL_SOCKET, SO_TYPE); + my $c = getsockopt(local $in = \*STDIN, SOL_SOCKET, SO_TYPE); unpack('i', $c) == SOCK_SEQPACKET or die 'stdin is not SOCK_SEQPACKET'; local (%SRCH, %WORKERS); - local $alive = 1; PublicInbox::Search::load_xapian(); $GLP->getoptionsfromarray(\@argv, my $opt = { j => 1 }, 'j=i') or die 'bad args'; @@ -268,7 +271,7 @@ sub start (@) { } my $sig = { TTIN => sub { - if ($alive) { + if ($in) { ++$nworker; PublicInbox::DS::requeue(\&start_workers) } |