about summary refs log tree commit homepage
path: root/lib/PublicInbox/LeiImport.pm
diff options
context:
space:
mode:
authorEric Wong <e@80x24.org>2021-11-02 18:14:44 +0000
committerEric Wong <e@80x24.org>2021-11-02 19:06:51 +0000
commit0054246c2d03fcc91bc899da5ef41a68f505e542 (patch)
treebaef8664897ebca298398be291a0f45eff8e3c61 /lib/PublicInbox/LeiImport.pm
parent85d75a409a15a3b114299838e30ad608c799c7e5 (diff)
downloadpublic-inbox-0054246c2d03fcc91bc899da5ef41a68f505e542.tar.gz
lei: simplify common LeiInput users with ->wq1_start
This method replaces a common pattern of starting workers,
preparing internal auth ops, and asynchronous waiting of
command completion.

It also adds missing LeiAuth support to rediff and rm
which rarely need auth.
Diffstat (limited to 'lib/PublicInbox/LeiImport.pm')
-rw-r--r--lib/PublicInbox/LeiImport.pm7
1 files changed, 1 insertions, 6 deletions
diff --git a/lib/PublicInbox/LeiImport.pm b/lib/PublicInbox/LeiImport.pm
index d8f39fdf..bbc0634e 100644
--- a/lib/PublicInbox/LeiImport.pm
+++ b/lib/PublicInbox/LeiImport.pm
@@ -102,14 +102,9 @@ sub do_import_index ($$@) {
         }
         ($lei->{opt}->{'new-only'} && (!$net || !$net->{imap_order})) and
                 warn "# --new-only is only for IMAP\n";
-        my $ops = {};
-        $lei->{auth}->op_merge($ops, $self, $lei) if $lei->{auth};
         $lei->{-eml_noisy} = 1;
-        (my $op_c, $ops) = $lei->workers_start($self, $j, $ops);
-        $lei->{wq1} = $self;
         $lei->{-err_type} = 'non-fatal';
-        net_merge_all_done($self) unless $lei->{auth};
-        $lei->wait_wq_events($op_c, $ops);
+        $lei->wq1_start($self, $j);
 }
 
 sub lei_import { # the main "lei import" method