about summary refs log tree commit homepage
path: root/lib/PublicInbox/LeiOverview.pm
diff options
context:
space:
mode:
authorEric Wong <e@80x24.org>2021-02-02 22:11:33 -1000
committerEric Wong <e@80x24.org>2021-02-04 01:37:09 +0000
commite223568cc22cb125dd3671989ba49eb575c424b3 (patch)
tree20c65cf95ff9b75ec64f7c57b415943c954a8fc5 /lib/PublicInbox/LeiOverview.pm
parentcff308df82cda8370e98c0c9c6a3704209362a60 (diff)
downloadpublic-inbox-e223568cc22cb125dd3671989ba49eb575c424b3.tar.gz
lei2mail doesn't need stdin anymore, so we can use the [0] slot
for the $not_done keepalive purposes.
Diffstat (limited to 'lib/PublicInbox/LeiOverview.pm')
-rw-r--r--lib/PublicInbox/LeiOverview.pm8
1 files changed, 4 insertions, 4 deletions
diff --git a/lib/PublicInbox/LeiOverview.pm b/lib/PublicInbox/LeiOverview.pm
index 52da225d..88034ada 100644
--- a/lib/PublicInbox/LeiOverview.pm
+++ b/lib/PublicInbox/LeiOverview.pm
@@ -217,13 +217,13 @@ sub ovv_each_smsg_cb { # runs in wq worker usually
                 };
         } elsif ($l2m && $l2m->{-wq_s1}) {
                 my ($lei_ipc, @io) = $lei->atfork_parent_wq($l2m);
-                # $io[-1] becomes a notification pipe that triggers EOF
+                # $io[0] becomes a notification pipe that triggers EOF
                 # in this wq worker when all outstanding ->write_mail
                 # calls are complete
-                pipe($l2m->{each_smsg_done}, $io[$#io + 1]) or die "pipe: $!";
-                fcntl($io[-1], 1031, 4096) if $^O eq 'linux'; # F_SETPIPE_SZ
+                $io[0] = undef;
+                pipe($l2m->{each_smsg_done}, $io[0]) or die "pipe: $!";
+                fcntl($io[0], 1031, 4096) if $^O eq 'linux'; # F_SETPIPE_SZ
                 delete @$lei_ipc{qw(l2m opt mset_opt cmd)};
-                $lei_ipc->{each_smsg_not_done} = $#io;
                 my $git = $ibxish->git; # (LeiXSearch|Inbox|ExtSearch)->git
                 $self->{git} = $git;
                 my $git_dir = $git->{git_dir};