lei: share common *done_wait callbacks

[public-inbox.git] / lib / PublicInbox / LEI.pm

diff --git a/lib/PublicInbox/LEI.pm b/lib/PublicInbox/LEI.pm
index 8fa8994488e12ae82ca22503bbfad095ae4ca0eb..2e1aa2469559ba49fbee00d827ab3017474c3cb0 100644 (file)
--- a/lib/PublicInbox/LEI.pm
+++ b/lib/PublicInbox/LEI.pm
@@ -1211,4 +1211,11 @@ sub DESTROY {
        $? = $err if $err; # preserve ->fail or ->x_it code
 }
 
+sub wq_done_wait { # dwaitpid callback
+       my ($arg, $pid) = @_;
+       my ($wq, $lei, $e) = @$arg;
+       $? and $lei->child_error($?, $e ? "$e errors during $lei->{cmd}" : ());
+       $lei->dclose;
+}
+
 1;