[PATCH 04/11] lei_p2q: add _lei_wq_eof callback

[Eric Wong]

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;
--
unsubscribe: one-click, see List-Unsubscribe header
archive: https://public-inbox.org/meta/