GNUsocial/gnu-social
4
0
Fork 1
Code Issues Releases Wiki Activity

adaptive filtering requests

Browse Source
This commit is contained in:
Evan Prodromou 2012-03-21 12:01:27 -04:00
parent d942072a6c
commit f6ae47c4fb
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
lib/filteringnoticestream.php
View File

@ -72,6 +72,7 @@ abstract class FilteringNoticeStream extends NoticeStream
$results = null; $results = null;
do { do {
common_debug(get_class($this) . ": ($offset, $limit) fetching $askFor notices starting at $startAt");
$raw = $this->upstream->getNotices($startAt, $askFor, $sinceId, $maxId); $raw = $this->upstream->getNotices($startAt, $askFor, $sinceId, $maxId);
@ -100,7 +101,14 @@ abstract class FilteringNoticeStream extends NoticeStream
// XXX: make these smarter; factor hit rate into $askFor // XXX: make these smarter; factor hit rate into $askFor
$startAt += $askFor; $startAt += $askFor;
$askFor = max($total - count($filtered), NOTICES_PER_PAGE);
$hits = count($filtered);
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); } while (count($filtered) < $total && $results !== 0);