diff options
Diffstat (limited to 'lib/PublicInbox/LeiMirror.pm')
| -rw-r--r-- | lib/PublicInbox/LeiMirror.pm | 10 |
1 files changed, 2 insertions, 8 deletions
diff --git a/lib/PublicInbox/LeiMirror.pm b/lib/PublicInbox/LeiMirror.pm index d9c13f05..6bfa4b6f 100644 --- a/lib/PublicInbox/LeiMirror.pm +++ b/lib/PublicInbox/LeiMirror.pm @@ -11,7 +11,7 @@ use PublicInbox::Spawn qw(popen_rd spawn run_die); use File::Temp (); use Fcntl qw(SEEK_SET O_CREAT O_EXCL O_WRONLY); -sub do_finish_mirror { # dwaitpid callback +sub _wq_done_wait { # dwaitpid callback (via wq_eof) my ($arg, $pid) = @_; my ($mrr, $lei) = @$arg; my $f = "$mrr->{dst}/mirror.done"; @@ -28,12 +28,6 @@ sub do_finish_mirror { # dwaitpid callback $lei->dclose; } -sub _lei_wq_eof { # EOF callback for main daemon - my ($lei) = @_; - my $mrr = delete $lei->{wq1} or return $lei->fail; - $mrr->wq_wait_old(\&do_finish_mirror, $lei); -} - # for old installations without manifest.js.gz sub try_scrape { my ($self) = @_; @@ -176,7 +170,7 @@ sub index_cloned_inbox { PublicInbox::Admin::progress_prepare($opt, $lei->{2}); PublicInbox::Admin::index_inbox($ibx, undef, $opt); } - open my $x, '>', "$self->{dst}/mirror.done"; # for do_finish_mirror + open my $x, '>', "$self->{dst}/mirror.done"; # for _wq_done_wait } sub run_reap { |