about summary refs log tree commit homepage
path: root/lib/PublicInbox/LeiXSearch.pm
diff options
context:
space:
mode:
authorEric Wong <e@80x24.org>2023-11-15 09:21:44 +0000
committerEric Wong <e@80x24.org>2023-11-16 10:56:53 +0000
commit72e0fcd979719f62bce89a029875e15a4cb497bb (patch)
tree9bf0501ee02fdf41a76f282f212563937a7fc0a9 /lib/PublicInbox/LeiXSearch.pm
parent2c472f1f571ae55155c78bcbc4d420d06266ba63 (diff)
downloadpublic-inbox-72e0fcd979719f62bce89a029875e15a4cb497bb.tar.gz
We've always forced LeiToMail to only have one process for v2
outputs anyways since v2 has its own sharding and IPC.  Thus we
can use the single LeiToMail process directly to avoid extra IPC
overhead.
Diffstat (limited to 'lib/PublicInbox/LeiXSearch.pm')
-rw-r--r--lib/PublicInbox/LeiXSearch.pm6
1 files changed, 1 insertions, 5 deletions
diff --git a/lib/PublicInbox/LeiXSearch.pm b/lib/PublicInbox/LeiXSearch.pm
index 7eda6f9e..5e36c11a 100644
--- a/lib/PublicInbox/LeiXSearch.pm
+++ b/lib/PublicInbox/LeiXSearch.pm
@@ -391,11 +391,6 @@ sub query_done { # EOF callback for main daemon
         ($lei->{opt}->{'mail-sync'} && !$lei->{sto}) and
                 warn "BUG: {sto} missing with --mail-sync";
         $lei->sto_done_request;
-        my $nr_w = delete($lei->{-nr_write}) // 0;
-        if (my $v2w = delete $lei->{v2w}) {
-                $nr_w = $v2w->wq_do('done'); # may die
-                $v2w->wq_close;
-        }
         $lei->{ovv}->ovv_end($lei);
         if ($l2m) { # close() calls LeiToMail reap_compress
                 if (my $out = delete $lei->{old_1}) {
@@ -413,6 +408,7 @@ Error closing $lei->{ovv}->{dst}: \$!=$! \$?=$?
                         delete $l2m->{mbl}; # drop dotlock
                 }
         }
+        my $nr_w = delete($lei->{-nr_write}) // 0;
         my $nr_dup = (delete($lei->{-nr_seen}) // 0) - $nr_w;
         if ($lei->{-progress}) {
                 my $tot = $lei->{-mset_total} // 0;