For other commands generating long responses, we generally want
to yield to another client after emitting 100 . However,
XOVER-based responses already query 200 lines worth of responses
at a time, so we were sending 20000 lines before yielding to
other clients. This may help avoid timeouts for some clients.
+ eval { $cb->(\$beg, \$lim) };
} until (($err = $@) || $self->{closed} ||
} until (($err = $@) || $self->{closed} ||
- ++$beg > $end || !--$lim || $self->{write_buf_size});
+ ++$beg > $end || --$lim < 0 ||
+ $self->{write_buf_size});
if ($err || $self->{closed}) {
$self->{long_res} = undef;
if ($err || $self->{closed}) {
$self->{long_res} = undef;
update_idle_time($self);
$self->watch_read(1);
}
update_idle_time($self);
$self->watch_read(1);
}
- } elsif (!$lim || $self->{write_buf_size}) {
+ } elsif ($lim < 0 || $self->{write_buf_size}) {
# no recursion, schedule another call ASAP
# but only after all pending writes are done
update_idle_time($self);
# no recursion, schedule another call ASAP
# but only after all pending writes are done
update_idle_time($self);
more($self, $xhdr ? r221 : r225);
my $off = 0;
long_response($self, $beg, $end, sub {
more($self, $xhdr ? r221 : r225);
my $off = 0;
long_response($self, $beg, $end, sub {
my $res = $srch->query_xover($beg, $end, $off);
my $msgs = $res->{msgs};
my $nr = scalar @$msgs or return;
$off += $nr;
my $res = $srch->query_xover($beg, $end, $off);
my $msgs = $res->{msgs};
my $nr = scalar @$msgs or return;
$off += $nr;
my $tmp = '';
foreach my $s (@$msgs) {
$tmp .= $s->num . ' ' . $s->$field . "\r\n";
my $tmp = '';
foreach my $s (@$msgs) {
$tmp .= $s->num . ' ' . $s->$field . "\r\n";
my $srch = $self->{ng}->search;
my $off = 0;
long_response($self, $beg, $end, sub {
my $srch = $self->{ng}->search;
my $off = 0;
long_response($self, $beg, $end, sub {
my $res = $srch->query_xover($beg, $end, $off);
my $msgs = $res->{msgs};
my $nr = scalar @$msgs or return;
$off += $nr;
my $res = $srch->query_xover($beg, $end, $off);
my $msgs = $res->{msgs};
my $nr = scalar @$msgs or return;
$off += $nr;
# OVERVIEW.FMT
more($self, join("\r\n", map {
# OVERVIEW.FMT
more($self, join("\r\n", map {