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 3248afd77e58022413eec33d6ef3ce9f926ebae1..07357e32106ac5ab7aaf3b3c029975ce624468ec 100644 (file)
--- 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;