lei_p2q: add _lei_wq_eof callback

This may help with some error diagnostics.

1 files changed, 6 insertions, 0 deletions

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;