ipc: wq_do => wq_io_do

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

diff --git a/lib/PublicInbox/LeiMirror.pm b/lib/PublicInbox/LeiMirror.pm
index 13795a58c82d6eafb9f10eaffbe275e8dff19f01..5ba69287fdd50c5039a10e56b8796de1320f91c3 100644 (file)
--- a/lib/PublicInbox/LeiMirror.pm
+++ b/lib/PublicInbox/LeiMirror.pm
@@ -251,7 +251,7 @@ sub start_clone_url {
        die "TODO: non-HTTP/HTTPS clone of $self->{src} not supported, yet";
 }
 
-sub do_mirror { # via wq_do
+sub do_mirror { # via wq_io_do
        my ($self) = @_;
        my $lei = $self->{lei};
        eval {
@@ -290,7 +290,7 @@ sub start {
        $self->wq_workers_start('lei_mirror', 1, $lei->oldset, {lei => $lei});
        my $op = delete $lei->{pkt_op_c};
        delete $lei->{pkt_op_p};
-       $self->wq_do('do_mirror', []);
+       $self->wq_io_do('do_mirror', []);
        $self->wq_close(1);
        $lei->event_step_init; # wait for shutdowns
        if ($lei->{oneshot}) {