]> Sergey Matveev's repositories - public-inbox.git/blob - lib/PublicInbox/AutoReap.pm
imap+nntp: share COMPRESS implementation
[public-inbox.git] / lib / PublicInbox / AutoReap.pm
1 # Copyright (C) all contributors <meta@public-inbox.org>
2 # License: AGPL-3.0+ <https://www.gnu.org/licenses/agpl-3.0.txt>
3
4 # automatically kill + reap children when this goes out-of-scope
5 package PublicInbox::AutoReap;
6 use v5.10.1;
7 use strict;
8
9 sub new {
10         my (undef, $pid, $cb) = @_;
11         bless { pid => $pid, cb => $cb, owner => $$ }, __PACKAGE__
12 }
13
14 sub kill {
15         my ($self, $sig) = @_;
16         CORE::kill($sig // 'TERM', $self->{pid});
17 }
18
19 sub join {
20         my ($self, $sig) = @_;
21         my $pid = delete $self->{pid} or return;
22         $self->{cb}->() if defined $self->{cb};
23         CORE::kill($sig, $pid) if defined $sig;
24         my $ret = waitpid($pid, 0) // die "waitpid($pid): $!";
25         $ret == $pid or die "BUG: waitpid($pid) != $ret";
26 }
27
28 sub DESTROY {
29         my ($self) = @_;
30         return if $self->{owner} != $$;
31         $self->join('TERM');
32 }
33
34 1;