]> Sergey Matveev's repositories - public-inbox.git/blobdiff - lib/PublicInbox/WQWorker.pm
www_stream: extra link to mirroring information in the footer
[public-inbox.git] / lib / PublicInbox / WQWorker.pm
index 3636321e901eab5b365922331ee819767d8777b8..f7aa61c555705d2c0c476f8526844ea28830b134 100644 (file)
@@ -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;