Changeset View
Changeset View
Standalone View
Standalone View
src/hardpoint/ArcanistHardpointEngine.php
Show First 20 Lines • Show All 109 Lines • ▼ Show 20 Lines | private function startRequest(ArcanistHardpointRequest $request) { | ||||
if (!$objects) { | if (!$objects) { | ||||
return; | return; | ||||
} | } | ||||
$any_object = head($objects); | $any_object = head($objects); | ||||
$list = $object->getHardpointList(); | $list = $object->getHardpointList(); | ||||
$definition = $list->getHardpointDefinition($any_object, $hardpoint); | $definition = $list->getHardpointDefinition($any_object, $hardpoint); | ||||
$is_vector = ($definition->isVectorHardpoint()); | $is_vector = $definition->isVectorHardpoint(); | ||||
if ($is_vector) { | 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); | ||||
▲ Show 20 Lines • Show All 60 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