Changeset View
Changeset View
Standalone View
Standalone View
src/infrastructure/storage/lisk/PhabricatorQueryIterator.php
Show All 19 Lines | final class PhabricatorQueryIterator extends PhutilBufferedIterator { | ||||
protected function loadPage() { | protected function loadPage() { | ||||
if (!$this->pager) { | if (!$this->pager) { | ||||
return array(); | return array(); | ||||
} | } | ||||
$pager = clone $this->pager; | $pager = clone $this->pager; | ||||
$query = clone $this->query; | $query = clone $this->query; | ||||
$query->setDisableOverheating(true); | |||||
$results = $query->executeWithCursorPager($pager); | $results = $query->executeWithCursorPager($pager); | ||||
// If we got less than a full page of results, this was the last set of | // If we got less than a full page of results, this was the last set of | ||||
// results. Throw away the pager so we end iteration. | // results. Throw away the pager so we end iteration. | ||||
if (!$pager->getHasMoreResults()) { | if (!$pager->getHasMoreResults()) { | ||||
$this->pager = null; | $this->pager = null; | ||||
} else { | } else { | ||||
$this->pager->setAfterID($pager->getNextPageID()); | $this->pager->setAfterID($pager->getNextPageID()); | ||||
} | } | ||||
return $results; | return $results; | ||||
} | } | ||||
} | } |