Differential D13153 Diff 31804 src/applications/repository/daemon/PhabricatorRepositoryPullLocalDaemon.php
Changeset View
Changeset View
Standalone View
Standalone View
src/applications/repository/daemon/PhabricatorRepositoryPullLocalDaemon.php
| Show First 20 Lines • Show All 67 Lines • ▼ Show 20 Lines | protected function run() { | ||||
| $retry_after = array(); | $retry_after = array(); | ||||
| $min_sleep = 15; | $min_sleep = 15; | ||||
| $max_futures = 4; | $max_futures = 4; | ||||
| $futures = array(); | $futures = array(); | ||||
| $queue = array(); | $queue = array(); | ||||
| while (!$this->shouldExit()) { | while (!$this->shouldExit()) { | ||||
| PhabricatorCaches::destroyRequestCache(); | |||||
| $pullable = $this->loadPullableRepositories($include, $exclude); | $pullable = $this->loadPullableRepositories($include, $exclude); | ||||
| // If any repositories have the NEEDS_UPDATE flag set, pull them | // If any repositories have the NEEDS_UPDATE flag set, pull them | ||||
| // as soon as possible. | // as soon as possible. | ||||
| $need_update_messages = $this->loadRepositoryUpdateMessages(true); | $need_update_messages = $this->loadRepositoryUpdateMessages(true); | ||||
| foreach ($need_update_messages as $message) { | foreach ($need_update_messages as $message) { | ||||
| $repo = idx($pullable, $message->getRepositoryID()); | $repo = idx($pullable, $message->getRepositoryID()); | ||||
| if (!$repo) { | if (!$repo) { | ||||
| ▲ Show 20 Lines • Show All 348 Lines • Show Last 20 Lines | |||||