about summary refs log tree commit homepage
path: root/lib/PublicInbox/ExtSearchIdx.pm
diff options
context:
space:
mode:
authorEric Wong <e@80x24.org>2021-01-10 12:15:00 +0000
committerEric Wong <e@80x24.org>2021-01-12 03:51:42 +0000
commitb90e8d6e02852c47d0c08198d8c7afb5dbe008d7 (patch)
treeea3b399fba66acbd5b67bb5d1b983340ddcc17d3 /lib/PublicInbox/ExtSearchIdx.pm
parentf4cf089b427d07bedb80fcfbe79d84234ad92a75 (diff)
downloadpublic-inbox-b90e8d6e02852c47d0c08198d8c7afb5dbe008d7.tar.gz
This lets us call dwaitpid long before a process exits
and not have to wait around for it.

This is advantageous for lei where we can run dwaitpid on the
pager as soon as we spawn it, instead of waiting for a client
socket to go away on DESTROY.
Diffstat (limited to 'lib/PublicInbox/ExtSearchIdx.pm')
-rw-r--r--lib/PublicInbox/ExtSearchIdx.pm4
1 files changed, 2 insertions, 2 deletions
diff --git a/lib/PublicInbox/ExtSearchIdx.pm b/lib/PublicInbox/ExtSearchIdx.pm
index e6c21866..85959a95 100644
--- a/lib/PublicInbox/ExtSearchIdx.pm
+++ b/lib/PublicInbox/ExtSearchIdx.pm
@@ -1090,7 +1090,7 @@ sub eidx_watch { # public-inbox-extindex --watch main loop
         $pr->("performing initial scan ...\n") if $pr;
         my $sync = eidx_sync($self, $opt); # initial sync
         return if $sync->{quit};
-        my $oldset = PublicInbox::Sigfd::block_signals();
+        my $oldset = PublicInbox::DS::block_signals();
         local $self->{current_info} = '';
         my $cb = $SIG{__WARN__} || \&CORE::warn;
         local $SIG{__WARN__} = sub { $cb->($self->{current_info}, ': ', @_) };
@@ -1108,7 +1108,7 @@ sub eidx_watch { # public-inbox-extindex --watch main loop
         if (!$sigfd) {
                 # wake up every second to accept signals if we don't
                 # have signalfd or IO::KQueue:
-                PublicInbox::Sigfd::sig_setmask($oldset);
+                PublicInbox::DS::sig_setmask($oldset);
                 PublicInbox::DS->SetLoopTimeout(1000);
         }
         PublicInbox::DS->SetPostLoopCallback(sub { !$sync->{quit} });