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 2c7cbf2bc96bb8bac87cdce6ed4b8cb5a4df3638..3a99570e3767c9b0ec9261f81d66fb2c16b0227a 100644 (file)
--- a/lib/PublicInbox/LeiImport.pm
+++ b/lib/PublicInbox/LeiImport.pm
@@ -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