]> Sergey Matveev's repositories - public-inbox.git/commitdiff
daemon: use sigprocmask when respawning workers
authorEric Wong <e@80x24.org>
Sun, 24 Nov 2019 00:22:29 +0000 (00:22 +0000)
committerEric Wong <e@80x24.org>
Sun, 24 Nov 2019 21:35:18 +0000 (21:35 +0000)
We need to block signals in workers during respawns
until they're ready to receive signals.

lib/PublicInbox/Daemon.pm

index e830a98faac9987fecf5f7d927a480cf1326b229..90f111370e9a23b1a740adc7e486add82d977f44 100644 (file)
@@ -19,7 +19,7 @@ require PublicInbox::EvCleanup;
 require PublicInbox::Listener;
 require PublicInbox::ParentPipe;
 my @CMD;
-my ($set_user, $oldset);
+my ($set_user, $oldset, $newset);
 my (@cfg_listen, $stdout, $stderr, $group, $user, $pid_file, $daemonize);
 my $worker_processes = 1;
 my @listeners;
@@ -77,7 +77,7 @@ sub accept_tls_opt ($) {
 sub daemon_prepare ($) {
        my ($default_listen) = @_;
        $oldset = POSIX::SigSet->new();
-       my $newset = POSIX::SigSet->new();
+       $newset = POSIX::SigSet->new();
        $newset->fillset or die "fillset: $!";
        sigprocmask(SIG_SETMASK, $newset, $oldset) or die "sigprocmask: $!";
        @CMD = ($0, @ARGV);
@@ -536,6 +536,7 @@ sub master_loop {
                        }
                        $n = $worker_processes;
                }
+               sigprocmask(SIG_SETMASK, $newset) or die "sigprocmask: $!";
                foreach my $i ($n..($worker_processes - 1)) {
                        my $pid = fork;
                        if (!defined $pid) {
@@ -548,6 +549,7 @@ sub master_loop {
                                $pids{$pid} = $i;
                        }
                }
+               sigprocmask(SIG_SETMASK, $oldset) or die "sigprocmask: $!";
                # just wait on signal events here:
                sysread($r, my $buf, 8);
        }