From: Evan Prodromou Date: Wed, 21 Mar 2012 16:21:36 +0000 (-0400) Subject: Don't fetch more than needed if exhausted X-Git-Url: https://git.mxchange.org/?a=commitdiff_plain;h=0d8dd9078c040a600a0f8d99320b606362467b51;p=quix0rs-gnu-social.git Don't fetch more than needed if exhausted --- diff --git a/lib/filteringnoticestream.php b/lib/filteringnoticestream.php index 119f71e404..eb51076b7c 100644 --- a/lib/filteringnoticestream.php +++ b/lib/filteringnoticestream.php @@ -70,9 +70,11 @@ abstract class FilteringNoticeStream extends NoticeStream // or we get nothing from upstream. $results = null; + $round = 0; do { - common_debug(get_class($this) . ": ($offset, $limit) fetching $askFor notices starting at $startAt"); + + common_debug(get_class($this) . ": ($offset, $limit) Round $round: fetching $askFor notices starting at $startAt"); $raw = $this->upstream->getNotices($startAt, $askFor, $sinceId, $maxId); @@ -101,13 +103,17 @@ abstract class FilteringNoticeStream extends NoticeStream $hits = count($filtered); + $lastAsk = $askFor; + if ($hits === 0) { $askFor = max(min(2 * $askFor, NOTICES_PER_PAGE * 50), NOTICES_PER_PAGE); } else { $askFor = max(min((($total - $hits)*$startAt)/$hits, NOTICES_PER_PAGE * 50), NOTICES_PER_PAGE); } - } while (count($filtered) < $total && $results !== 0); + common_debug(get_class($this) . ": ($offset, $limit) Round $round hits is $hits, results = $results."); + + } while (count($filtered) < $total && $results >= $lastAsk); return new ArrayWrapper(array_slice($filtered, $offset, $limit)); }