diff options
author | Eric Wong <e@80x24.org> | 2019-05-03 10:34:08 +0000 |
---|---|---|
committer | Eric Wong <e@80x24.org> | 2019-05-04 23:20:03 +0000 |
commit | cd50d183273c105a7f08b1875ba6f7a51d9f8e9a (patch) | |
tree | de841ba448d2d3ed1d5e457fb5d015b6157e15d0 /lib/PublicInbox/Daemon.pm | |
parent | 48cd028855eb40557275a7e914da5cb3f847006c (diff) | |
download | public-inbox-cd50d183273c105a7f08b1875ba6f7a51d9f8e9a.tar.gz |
These modules are unmaintained upstream at the moment, but I'll be able to help with the intended maintainer once/if CPAN ownership is transferred. OTOH, we've been waiting for that transfer for several years, now... Changes I intend to make: * EPOLLEXCLUSIVE for Linux * remove unused fields wasting memory * kqueue bugfixes e.g. https://rt.cpan.org/Ticket/Display.html?id=116615 * accept4 support And some lower priority experiments: * switch to EV_ONESHOT / EPOLLONESHOT (incompatible changes) * nginx-style buffering to tmpfile instead of string array * sendfile off tmpfile buffers * io_uring maybe?
Diffstat (limited to 'lib/PublicInbox/Daemon.pm')
-rw-r--r-- | lib/PublicInbox/Daemon.pm | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/lib/PublicInbox/Daemon.pm b/lib/PublicInbox/Daemon.pm index 48051f48..68ba9876 100644 --- a/lib/PublicInbox/Daemon.pm +++ b/lib/PublicInbox/Daemon.pm @@ -12,7 +12,7 @@ use Cwd qw/abs_path/; use Time::HiRes qw(clock_gettime CLOCK_MONOTONIC); STDOUT->autoflush(1); STDERR->autoflush(1); -require Danga::Socket; +require PublicInbox::DS; require POSIX; require PublicInbox::Listener; require PublicInbox::ParentPipe; @@ -172,14 +172,14 @@ sub worker_quit { # killing again terminates immediately: exit unless @listeners; - $_->close foreach @listeners; # call Danga::Socket::close + $_->close foreach @listeners; # call PublicInbox::DS::close @listeners = (); $reason->close if ref($reason) eq 'PublicInbox::ParentPipe'; my $proc_name; my $warn = 0; # drop idle connections and try to quit gracefully - Danga::Socket->SetPostLoopCallback(sub { + PublicInbox::DS->SetPostLoopCallback(sub { my ($dmap, undef) = @_; my $n = 0; my $now = clock_gettime(CLOCK_MONOTONIC); @@ -486,7 +486,7 @@ sub daemon_loop ($$) { PublicInbox::Listener->new($_, $post_accept) } @listeners; PublicInbox::EvCleanup::enable(); - Danga::Socket->EventLoop; + PublicInbox::DS->EventLoop; $parent_pipe = undef; } |