diff options
Diffstat (limited to 'lib/PublicInbox/LeiPmdir.pm')
| -rw-r--r-- | lib/PublicInbox/LeiPmdir.pm | 13 |
1 files changed, 2 insertions, 11 deletions
diff --git a/lib/PublicInbox/LeiPmdir.pm b/lib/PublicInbox/LeiPmdir.pm index 23bccb4f..d4aa0212 100644 --- a/lib/PublicInbox/LeiPmdir.pm +++ b/lib/PublicInbox/LeiPmdir.pm @@ -1,4 +1,4 @@ -# Copyright (C) 2021 all contributors <meta@public-inbox.org> +# Copyright (C) all contributors <meta@public-inbox.org> # License: AGPL-3.0+ <https://www.gnu.org/licenses/agpl-3.0.txt> # WQ worker for dealing with parallel Maildir reads; @@ -47,17 +47,8 @@ sub mdir_iter { # via wq_io_do $self->{ipt}->pmdir_cb($f, $fl, @args); } -sub pmd_done_wait { - my ($arg, $pid) = @_; - my ($self, $lei) = @$arg; - $lei->can('wq_done_wait')->($arg, $pid); -} - sub _lei_wq_eof { # EOF callback for main lei daemon - my ($lei) = @_; - my $pmd = delete $lei->{pmd} or return $lei->fail; - $lei->sto_done_request($pmd->{lei_sock}); - $pmd->wq_wait_old(\&pmd_done_wait, $lei); + $_[0]->wq_eof('pmd'); } 1; |