lei_input: reduce IPC traffic with multiple inputs

No point in sending a command for every input when a
single one will do.  We'll also trigger LeiStore->done
sooner in the worker rather than later.

1 files changed, 1 insertions, 5 deletions

diff --git a/lib/PublicInbox/LeiImport.pm b/lib/PublicInbox/LeiImport.pm
index dbf655b6..d33143ef 100644
--- a/lib/PublicInbox/LeiImport.pm
+++ b/lib/PublicInbox/LeiImport.pm
@@ -39,8 +39,6 @@ sub import_done_wait { # dwaitpid callback
         my ($arg, $pid) = @_;
         my ($imp, $lei) = @$arg;
         $lei->child_error($?, 'non-fatal errors during import') if $?;
-        my $sto = delete $lei->{sto} // return $lei->fail('BUG: {sto} gone');
-        my $wait = $sto->ipc_do('done'); # PublicInbox::LeiStore::done
         $lei->dclose;
 }
 
@@ -52,9 +50,7 @@ sub import_done { # EOF callback for main daemon
 
 sub net_merge_complete { # callback used by LeiAuth
         my ($self) = @_;
-        for my $input (@{$self->{inputs}}) {
-                $self->wq_io_do('input_path_url', [], $input);
-        }
+        $self->wq_io_do('process_inputs');
         $self->wq_close(1);
 }