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/LeiTag.pm b/lib/PublicInbox/LeiTag.pm
index 8b012b16..d572a84a 100644
--- a/lib/PublicInbox/LeiTag.pm
+++ b/lib/PublicInbox/LeiTag.pm
@@ -73,8 +73,6 @@ sub tag_done_wait { # dwaitpid callback
         my ($arg, $pid) = @_;
         my ($tag, $lei) = @$arg;
         $lei->child_error($?, 'non-fatal errors during tag') if $?;
-        my $sto = delete $lei->{sto};
-        my $wait = $sto->ipc_do('done') if $sto; # PublicInbox::LeiStore::done
         $lei->dclose;
 }
 
@@ -86,9 +84,7 @@ sub tag_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);
 }