X-Git-Url: http://www.git.stargrave.org/?a=blobdiff_plain;f=lib%2FPublicInbox%2FLeiMirror.pm;h=5ba69287fdd50c5039a10e56b8796de1320f91c3;hb=757652fd1ad6843c984610263a2a0b336c974111;hp=13795a58c82d6eafb9f10eaffbe275e8dff19f01;hpb=2d610f0e645fd2b01bf9108b2d06022ab730815c;p=public-inbox.git diff --git a/lib/PublicInbox/LeiMirror.pm b/lib/PublicInbox/LeiMirror.pm index 13795a58..5ba69287 100644 --- 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}) {