X-Git-Url: http://www.git.stargrave.org/?a=blobdiff_plain;f=lib%2FPublicInbox%2FLeiIndex.pm;h=b3f3e1a0c51ae68f7f948754a3243083ca8680d8;hb=refs%2Fheads%2Fmaster;hp=4be0c649b5cebe8df3d1a4fc336cd4364a9ebdd6;hpb=10b523eb017162240b1ac3647f8dcbbf2be348a7;p=public-inbox.git diff --git a/lib/PublicInbox/LeiIndex.pm b/lib/PublicInbox/LeiIndex.pm index 4be0c649..b3f3e1a0 100644 --- a/lib/PublicInbox/LeiIndex.pm +++ b/lib/PublicInbox/LeiIndex.pm @@ -16,12 +16,12 @@ sub input_eml_cb { # used by input_maildir_cb and input_net_cb if (my $all_vmd = $self->{all_vmd}) { @$vmd{keys %$all_vmd} = values %$all_vmd; } - $self->{lei}->{sto}->ipc_do('index_eml_only', $eml, $vmd, $xoids); + $self->{lei}->{sto}->wq_do('index_eml_only', $eml, $vmd, $xoids); } sub input_fh { # overrides PublicInbox::LeiInput::input_fh my ($self, $ifmt, $fh, $input, @args) = @_; - $self->{lei}->child_error(1<<8, <{lei}->child_error(0, <can($m); } -*_complete_import = \&PublicInbox::LeiImport::_complete_import; +*_complete_index = \&PublicInbox::LeiImport::_complete_import; *ipc_atfork_child = \&PublicInbox::LeiInput::input_only_atfork_child; *net_merge_all_done = \&PublicInbox::LeiInput::input_only_net_merge_all_done; -# the following works even when LeiAuth is lazy-loaded -*net_merge_all = \&PublicInbox::LeiAuth::net_merge_all; 1;