Changeset View
Changeset View
Standalone View
Standalone View
src/hardpoint/ArcanistHardpointEngine.php
Show First 20 Lines • Show All 120 Lines • ▼ Show 20 Lines | if ($is_vector) { | ||||
foreach ($objects as $object) { | foreach ($objects as $object) { | ||||
$object->attachHardpoint($hardpoint, array()); | $object->attachHardpoint($hardpoint, array()); | ||||
} | } | ||||
} | } | ||||
$request->setHardpointDefinition($definition); | $request->setHardpointDefinition($definition); | ||||
foreach ($load as $query_key => $object_map) { | foreach ($load as $query_key => $object_map) { | ||||
$query = id(clone $queries[$query_key]); | $query = (clone $queries[$query_key]); | ||||
$task = $request->newTask() | $task = $request->newTask() | ||||
->setQuery($query) | ->setQuery($query) | ||||
->setObjects($object_map); | ->setObjects($object_map); | ||||
} | } | ||||
} | } | ||||
public function waitForRequests(array $wait_requests) { | public function waitForRequests(array $wait_requests) { | ||||
▲ Show 20 Lines • Show All 49 Lines • ▼ Show 20 Lines | final class ArcanistHardpointEngine | ||||
private function updateFutures() { | private function updateFutures() { | ||||
$iterator = $this->futureIterator; | $iterator = $this->futureIterator; | ||||
$is_rewind = false; | $is_rewind = false; | ||||
$wait_futures = $this->waitFutures; | $wait_futures = $this->waitFutures; | ||||
if ($wait_futures) { | if ($wait_futures) { | ||||
if (!$this->futureIterator) { | if (!$this->futureIterator) { | ||||
$iterator = id(new FutureIterator(array())) | $iterator = (new FutureIterator(array())) | ||||
->limit(32); | ->limit(32); | ||||
foreach ($wait_futures as $wait_future) { | foreach ($wait_futures as $wait_future) { | ||||
$iterator->addFuture($wait_future); | $iterator->addFuture($wait_future); | ||||
} | } | ||||
$is_rewind = true; | $is_rewind = true; | ||||
$this->futureIterator = $iterator; | $this->futureIterator = $iterator; | ||||
} else { | } else { | ||||
foreach ($wait_futures as $wait_future) { | foreach ($wait_futures as $wait_future) { | ||||
Show All 35 Lines |
Content licensed under Creative Commons Attribution-ShareAlike 4.0 (CC-BY-SA) unless otherwise noted; code licensed under Apache 2.0 or other open source licenses. · CC BY-SA 4.0 · Apache 2.0