diff options
author | Eric Wong <e@yhbt.net> | 2020-07-01 21:06:17 +0000 |
---|---|---|
committer | Eric Wong <e@yhbt.net> | 2020-07-02 20:36:20 +0000 |
commit | 5adc4f2fccf0b32b92c4fbc96be38045de2d7e84 (patch) | |
tree | 09b3c1735cad4b343c4d338c1bfbbb101e78b476 /lib/PublicInbox/WatchMaildir.pm | |
parent | 3067c7501c92e45080297a6f0a38bf5f743cde5a (diff) | |
download | public-inbox-5adc4f2fccf0b32b92c4fbc96be38045de2d7e84.tar.gz |
To ensure reliable signal delivery in Perl, it seems we need to repeatedly signal processes which aren't using signalfd (or EVFILT_SIGNAL) with our event loop.
Diffstat (limited to 'lib/PublicInbox/WatchMaildir.pm')
-rw-r--r-- | lib/PublicInbox/WatchMaildir.pm | 27 |
1 files changed, 18 insertions, 9 deletions
diff --git a/lib/PublicInbox/WatchMaildir.pm b/lib/PublicInbox/WatchMaildir.pm index e3df8515..23b2e9f1 100644 --- a/lib/PublicInbox/WatchMaildir.pm +++ b/lib/PublicInbox/WatchMaildir.pm @@ -202,18 +202,27 @@ sub _try_path { } } +sub quit_done ($) { + my ($self) = @_; + return unless $self->{quit}; + + # don't have reliable wakeups, keep signalling + my $done = 1; + for (qw(idle_pids poll_pids)) { + my $pids = $self->{$_} or next; + for (keys %$pids) { + $done = undef if kill('QUIT', $_); + } + } + $done; +} + sub quit { my ($self) = @_; $self->{quit} = 1; %{$self->{opendirs}} = (); _done_for_now($self); - if (my $imap_pid = $self->{-imap_pid}) { - kill('QUIT', $imap_pid); - } - for (qw(idle_pids poll_pids)) { - my $pids = $self->{$_} or next; - kill('QUIT', $_) for (keys %$pids); - } + quit_done($self); if (my $idle_mic = $self->{idle_mic}) { eval { $idle_mic->done }; if ($@) { @@ -921,8 +930,8 @@ sub watch { [$self, $intvl, $urls]); } watch_fs_init($self) if $self->{mdre}; - PublicInbox::DS->SetPostLoopCallback(sub {}); - PublicInbox::DS->EventLoop until $self->{quit}; + PublicInbox::DS->SetPostLoopCallback(sub { !$self->quit_done }); + PublicInbox::DS->EventLoop; _done_for_now($self); } |