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.

1 files changed, 4 insertions, 5 deletions

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;
 }