From 30d74fc31fd98e335e08d09e5ab36e197bd2710c Mon Sep 17 00:00:00 2001
From: Eric Wong <e@80x24.org>
Date: Wed, 28 Apr 2021 07:51:58 +0000
Subject: lei_p2q: add _lei_wq_eof callback

This may help with some error diagnostics.
---
 lib/PublicInbox/LeiP2q.pm | 6 ++++++
 1 file changed, 6 insertions(+)

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;
-- 
cgit v1.2.3-24-ge0c7