diff options
Diffstat (limited to 'lib/PublicInbox/IPC.pm')
| -rw-r--r-- | lib/PublicInbox/IPC.pm | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/lib/PublicInbox/IPC.pm b/lib/PublicInbox/IPC.pm index d5e37719..92f35189 100644 --- a/lib/PublicInbox/IPC.pm +++ b/lib/PublicInbox/IPC.pm @@ -245,10 +245,10 @@ sub recv_and_run { $n; } -sub wq_worker_loop ($) { - my ($self, $bcast_a) = @_; - my $wqw = PublicInbox::WQWorker->new($self); - PublicInbox::WQWorker->new($self, '-wq_bcast2'); +sub wq_worker_loop ($$) { + my ($self, $bcast2) = @_; + my $wqw = PublicInbox::WQWorker->new($self, $self->{-wq_s2}); + PublicInbox::WQWorker->new($self, $bcast2) if $bcast2; PublicInbox::DS->SetPostLoopCallback(sub { $wqw->{sock} }); PublicInbox::DS->EventLoop; PublicInbox::DS->Reset; @@ -339,8 +339,9 @@ sub wq_do { sub _wq_worker_start ($$$) { my ($self, $oldset, $fields) = @_; my ($bcast1, $bcast2); - socketpair($bcast1, $bcast2, AF_UNIX, $SEQPACKET, 0) or - die "socketpair: $!"; + $self->{-wq_no_bcast} or + socketpair($bcast1, $bcast2, AF_UNIX, $SEQPACKET, 0) or + die "socketpair: $!"; my $seed = rand(0xffffffff); my $pid = fork // die "fork: $!"; if ($pid == 0) { @@ -361,8 +362,7 @@ sub _wq_worker_start ($$$) { my $on_destroy = $self->ipc_atfork_child; local %SIG = %SIG; PublicInbox::DS::sig_setmask($oldset); - $self->{-wq_bcast2} = $bcast2; - wq_worker_loop($self); + wq_worker_loop($self, $bcast2); }; warn "worker $self->{-wq_ident} PID:$$ died: $@" if $@; undef $end; # trigger exit |