ipc: wq_do => wq_io_do

[public-inbox.git] / lib / PublicInbox / LeiImport.pm

diff --git a/lib/PublicInbox/LeiImport.pm b/lib/PublicInbox/LeiImport.pm
index 4a9af8a75ed6d9a397a7357f79f148494c72e632..3a99570e3767c9b0ec9261f81d66fb2c16b0227a 100644 (file)
--- a/lib/PublicInbox/LeiImport.pm
+++ b/lib/PublicInbox/LeiImport.pm
@@ -26,7 +26,7 @@ sub call { # the main "lei import" method
        my ($cls, $lei, @argv) = @_;
        my $sto = $lei->_lei_store(1);
        $sto->write_prepare($lei);
-       $lei->{opt}->{flags} //= 1;
+       $lei->{opt}->{kw} //= 1;
        my $fmt = $lei->{opt}->{'format'};
        my $self = $lei->{imp} = bless {}, $cls;
        return $lei->fail('--format unspecified') if !$fmt;
@@ -44,9 +44,9 @@ sub call { # the main "lei import" method
        $self->wq_workers_start('lei_import', $j, $lei->oldset, {lei => $lei});
        my $op = delete $lei->{pkt_op_c};
        delete $lei->{pkt_op_p};
-       $self->wq_do('import_stdin', []) if $self->{0};
+       $self->wq_io_do('import_stdin', []) if $self->{0};
        for my $x (@argv) {
-               $self->wq_do('import_path_url', [], $x);
+               $self->wq_io_do('import_path_url', [], $x);
        }
        $self->wq_close(1);
        $lei->event_step_init; # wait for shutdowns
@@ -63,7 +63,7 @@ sub ipc_atfork_child {
 
 sub _import_fh {
        my ($lei, $fh, $x) = @_;
-       my $set_kw = $lei->{opt}->{flags};
+       my $set_kw = $lei->{opt}->{kw};
        my $fmt = $lei->{opt}->{'format'};
        eval {
                if ($fmt eq 'eml') {