diff options
author | Eric Wong <e@80x24.org> | 2021-08-17 08:52:40 +0000 |
---|---|---|
committer | Eric Wong <e@80x24.org> | 2021-08-18 11:41:32 +0000 |
commit | 77d030df1d292a99291371b3649cff3657fd93c8 (patch) | |
tree | 583787a92ed70ea9a4a0f559174ccd53cb4821f2 /lib/PublicInbox/IPC.pm | |
parent | 29dd03ae81565f1430a39969b5b5d01dac68071c (diff) | |
download | public-inbox-77d030df1d292a99291371b3649cff3657fd93c8.tar.gz |
We no longer rely on IO::FDPass, so there's no longer a reason to limit this internally.
Diffstat (limited to 'lib/PublicInbox/IPC.pm')
-rw-r--r-- | lib/PublicInbox/IPC.pm | 5 |
1 files changed, 0 insertions, 5 deletions
diff --git a/lib/PublicInbox/IPC.pm b/lib/PublicInbox/IPC.pm index d909dc1c..9efe551b 100644 --- a/lib/PublicInbox/IPC.pm +++ b/lib/PublicInbox/IPC.pm @@ -20,7 +20,6 @@ use Socket qw(AF_UNIX MSG_EOR SOCK_STREAM); my $MY_MAX_ARG_STRLEN = 4096 * 33; # extra 4K for serialization my $SEQPACKET = eval { Socket::SOCK_SEQPACKET() }; # portable enough? our @EXPORT_OK = qw(ipc_freeze ipc_thaw); -my $WQ_MAX_WORKERS = 4096; my ($enc, $dec); # ->imports at BEGIN turns sereal_*_with_object into custom ops on 5.14+ # and eliminate method call overhead @@ -354,7 +353,6 @@ sub wq_workers_start { die "socketpair: $!"; $self->ipc_atfork_prepare; $nr_workers //= $self->{-wq_nr_workers}; - $nr_workers = $WQ_MAX_WORKERS if $nr_workers > $WQ_MAX_WORKERS; my $sigset = $oldset // PublicInbox::DS::block_signals(); $self->{-wq_workers} = {}; $self->{-wq_ident} = $ident; @@ -367,7 +365,6 @@ sub wq_worker_incr { # SIGTTIN handler my ($self, $oldset, $fields) = @_; $self->{-wq_s2} or return; die "-wq_nr_workers locked" if defined $self->{-wq_nr_workers}; - return if wq_workers($self) >= $WQ_MAX_WORKERS; $self->ipc_atfork_prepare; my $sigset = $oldset // PublicInbox::DS::block_signals(); _wq_worker_start($self, $sigset, $fields); @@ -443,8 +440,6 @@ sub wq_kill { kill($sig // 'TERM', keys %$workers); } -sub WQ_MAX_WORKERS { $WQ_MAX_WORKERS } - sub DESTROY { my ($self) = @_; my $ppid = $self->{-wq_ppid}; |