diff options
Diffstat (limited to 'lib/PublicInbox/WQWorker.pm')
| -rw-r--r-- | lib/PublicInbox/WQWorker.pm | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/lib/PublicInbox/WQWorker.pm b/lib/PublicInbox/WQWorker.pm index 3636321e..f7aa61c5 100644 --- a/lib/PublicInbox/WQWorker.pm +++ b/lib/PublicInbox/WQWorker.pm @@ -23,7 +23,7 @@ sub event_step { my ($self) = @_; my $n; do { - $n = $self->{wq}->recv_and_run($self->{sock}, 4096 * 33); + $n = $self->{wq}->recv_and_run($self->{sock}); } while ($n); return if !defined($n) && $! == EAGAIN; # likely warn "wq worker error: $!\n" if !defined($n) && $! != ECONNRESET; |