X-Git-Url: http://www.git.stargrave.org/?a=blobdiff_plain;f=lib%2FPublicInbox%2FParentPipe.pm;h=538b5632c623851aebaed6662238ac3406a9b220;hb=823dbcacf7829fd0f42748ae7712a76fa4c64a76;hp=6ef51c1adbd536527abe71598b899d9783d06220;hpb=7344d5bb292a29b52b574dfb09542e3290430afd;p=public-inbox.git diff --git a/lib/PublicInbox/ParentPipe.pm b/lib/PublicInbox/ParentPipe.pm index 6ef51c1a..538b5632 100644 --- a/lib/PublicInbox/ParentPipe.pm +++ b/lib/PublicInbox/ParentPipe.pm @@ -1,24 +1,23 @@ -# Copyright (C) 2016-2018 all contributors +# Copyright (C) 2016-2020 all contributors # License: AGPL-3.0+ # only for PublicInbox::Daemon, allows worker processes to be # notified if the master process dies. package PublicInbox::ParentPipe; use strict; -use warnings; -use base qw(PublicInbox::DS); -use fields qw(cb); +use parent qw(PublicInbox::DS); use PublicInbox::Syscall qw(EPOLLIN EPOLLONESHOT); sub new ($$$) { my ($class, $pipe, $worker_quit) = @_; - my $self = fields::new($class); + my $self = bless { cb => $worker_quit }, $class; $self->SUPER::new($pipe, EPOLLIN|EPOLLONESHOT); - $self->{cb} = $worker_quit; - $self; } # master process died, time to call worker_quit ourselves -sub event_step { $_[0]->{cb}->($_[0]) } +sub event_step { + $_[0]->close; # PublicInbox::DS::close + $_[0]->{cb}->(); +} 1;