From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: X-Spam-Checker-Version: SpamAssassin 3.4.2 (2018-09-13) on dcvr.yhbt.net X-Spam-Level: X-Spam-ASN: X-Spam-Status: No, score=-4.0 required=3.0 tests=ALL_TRUSTED,BAYES_00 shortcircuit=no autolearn=ham autolearn_force=no version=3.4.2 Received: from localhost (dcvr.yhbt.net [127.0.0.1]) by dcvr.yhbt.net (Postfix) with ESMTP id A8C961FA17 for ; Wed, 28 Apr 2021 07:52:05 +0000 (UTC) From: Eric Wong To: meta@public-inbox.org Subject: [PATCH 04/11] lei_p2q: add _lei_wq_eof callback Date: Wed, 28 Apr 2021 07:51:58 +0000 Message-Id: <20210428075205.19440-5-e@80x24.org> In-Reply-To: <20210428075205.19440-1-e@80x24.org> References: <20210428075205.19440-1-e@80x24.org> MIME-Version: 1.0 Content-Transfer-Encoding: 8bit List-Id: 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;