diff options
Diffstat (limited to 'lib/PublicInbox/LeiImportKw.pm')
-rw-r--r-- | lib/PublicInbox/LeiImportKw.pm | 8 |
1 files changed, 1 insertions, 7 deletions
diff --git a/lib/PublicInbox/LeiImportKw.pm b/lib/PublicInbox/LeiImportKw.pm index 21c93515..c35c5c26 100644 --- a/lib/PublicInbox/LeiImportKw.pm +++ b/lib/PublicInbox/LeiImportKw.pm @@ -46,17 +46,11 @@ sub ck_update_kw { # via wq_io_do $self->{sto}->wq_do('set_eml_vmd', undef, { kw => $kw }, \@docids); } -sub ikw_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 $ikw = delete $lei->{ikw} or return $lei->fail; $lei->sto_done_request($ikw->{lei_sock}); - $ikw->wq_wait_old(\&ikw_done_wait, $lei); + $ikw->wq_wait_old($lei->can('wq_done_wait'), $lei); } 1; |