From: Eric Wong <e@80x24.org>
Date: Wed, 28 Apr 2021 07:51:58 +0000 (+0000)
Subject: lei_p2q: add _lei_wq_eof callback
X-Git-Tag: v1.7.0~733
X-Git-Url: http://www.git.stargrave.org/?a=commitdiff_plain;h=30d74fc31fd98e335e08d09e5ab36e197bd2710c;p=public-inbox.git

lei_p2q: add _lei_wq_eof callback

This may help with some error diagnostics.
---

diff --git a/lib/PublicInbox/LeiP2q.pm b/lib/PublicInbox/LeiP2q.pm
index 3248afd7..07357e32 100644
--- a/lib/PublicInbox/LeiP2q.pm
+++ b/lib/PublicInbox/LeiP2q.pm
@@ -203,4 +203,10 @@ sub ipc_atfork_child {
 	$self->SUPER::ipc_atfork_child;
 }
 
+sub _lei_wq_eof { # EOF callback for main daemon
+	my ($lei) = @_;
+	my $p2q = delete $lei->{p2q} // return $lei->dclose;
+	$p2q->wq_wait_old($lei->can('wq_done_wait'), $lei);
+}
+
 1;