From 12775b5be53db1244b9cb32ae2ef90f105735e1b Mon Sep 17 00:00:00 2001 From: Eric Wong Date: Sun, 19 Sep 2021 12:50:21 +0000 Subject: ipc: allow disabling broadcast for wq_workers Since some lei worker classes only use a single worker, there's no sense in having broadcast for those cases. --- lib/PublicInbox/WQWorker.pm | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) (limited to 'lib/PublicInbox/WQWorker.pm') diff --git a/lib/PublicInbox/WQWorker.pm b/lib/PublicInbox/WQWorker.pm index f7aa61c5..48b901bb 100644 --- a/lib/PublicInbox/WQWorker.pm +++ b/lib/PublicInbox/WQWorker.pm @@ -11,11 +11,10 @@ use Errno qw(EAGAIN ECONNRESET); use IO::Handle (); # blocking sub new { - my ($cls, $wq, $field) = @_; - my $s2 = $wq->{$field // '-wq_s2'} // die "BUG: no {$field}"; - $s2->blocking(0); - my $self = bless { sock => $s2, wq => $wq }, $cls; - $self->SUPER::new($s2, EPOLLEXCLUSIVE|EPOLLIN|EPOLLET); + my ($cls, $wq, $sock) = @_; + $sock->blocking(0); + my $self = bless { sock => $sock, wq => $wq }, $cls; + $self->SUPER::new($sock, EPOLLEXCLUSIVE|EPOLLIN|EPOLLET); $self; } -- cgit v1.2.3-24-ge0c7