about summary refs log tree commit homepage
path: root/lib/PublicInbox/LeiMirror.pm
diff options
context:
space:
mode:
Diffstat (limited to 'lib/PublicInbox/LeiMirror.pm')
-rw-r--r--lib/PublicInbox/LeiMirror.pm4
1 files changed, 2 insertions, 2 deletions
diff --git a/lib/PublicInbox/LeiMirror.pm b/lib/PublicInbox/LeiMirror.pm
index 50ab4c85..db97b98c 100644
--- a/lib/PublicInbox/LeiMirror.pm
+++ b/lib/PublicInbox/LeiMirror.pm
@@ -26,7 +26,7 @@ sub do_finish_mirror { # dwaitpid callback
 
 sub _lei_wq_eof { # EOF callback for main daemon
         my ($lei) = @_;
-        my $mrr = delete $lei->{mrr} or return;
+        my $mrr = delete $lei->{wq1} or return $lei->fail;
         $mrr->wq_wait_old(\&do_finish_mirror, $lei);
 }
 
@@ -283,7 +283,7 @@ sub start {
         require PublicInbox::Admin;
         require PublicInbox::InboxWritable;
         my ($op, $ops) = $lei->workers_start($self, 'lei_mirror', 1);
-        $lei->{mrr} = $self;
+        $lei->{wq1} = $self;
         $self->wq_io_do('do_mirror', []);
         $self->wq_close(1);
         $op->op_wait_event($ops);