Changeset View
Changeset View
Standalone View
Standalone View
src/infrastructure/daemon/workers/PhabricatorTriggerDaemon.php
| Show First 20 Lines • Show All 424 Lines • ▼ Show 20 Lines | if (!$this->nuanceSources) { | ||||
| $this->nuanceSources = array_reverse($sources); | $this->nuanceSources = array_reverse($sources); | ||||
| } | } | ||||
| // If we don't have any cursors, move to the next source and generate its | // If we don't have any cursors, move to the next source and generate its | ||||
| // cursors. | // cursors. | ||||
| if (!$this->nuanceCursors) { | if (!$this->nuanceCursors) { | ||||
| $source = array_pop($this->nuanceSources); | $source = array_pop($this->nuanceSources); | ||||
| $cursors = $source->getImportCursors(); | |||||
| $definition = $source->getDefinition() | |||||
| ->setViewer($this->getViewer()) | |||||
| ->setSource($source); | |||||
| $cursors = $definition->getImportCursors(); | |||||
| $this->nuanceCursors = array_reverse($cursors); | $this->nuanceCursors = array_reverse($cursors); | ||||
| } | } | ||||
| // Update the next cursor. | // Update the next cursor. | ||||
| $cursor = array_pop($this->nuanceCursors); | $cursor = array_pop($this->nuanceCursors); | ||||
| if ($cursor) { | if ($cursor) { | ||||
| $more_data = $cursor->importFromSource(); | $more_data = $cursor->importFromSource(); | ||||
| if ($more_data) { | if ($more_data) { | ||||
| Show All 12 Lines | |||||