Differential D21532 Diff 51253 src/applications/repository/worker/commitchangeparser/PhabricatorRepositoryCommitChangeParserWorker.php
Changeset View
Changeset View
Standalone View
Standalone View
src/applications/repository/worker/commitchangeparser/PhabricatorRepositoryCommitChangeParserWorker.php
| Show First 20 Lines • Show All 93 Lines • ▼ Show 20 Lines | foreach (array_chunk($paths, 128) as $path_chunk) { | ||||
| foreach ($chunk_map as $row) { | foreach ($chunk_map as $row) { | ||||
| $result_map[$row['path']] = $row['id']; | $result_map[$row['path']] = $row['id']; | ||||
| } | } | ||||
| } | } | ||||
| return $result_map; | return $result_map; | ||||
| } | } | ||||
| protected function finishParse() { | protected function finishParse() { | ||||
| $commit = $this->commit; | $this->queueCommitTask('PhabricatorRepositoryCommitPublishWorker'); | ||||
| if ($this->shouldQueueFollowupTasks()) { | |||||
| $this->queueTask( | |||||
| 'PhabricatorRepositoryCommitPublishWorker', | |||||
| array( | |||||
| 'commitID' => $commit->getID(), | |||||
| )); | |||||
| } | |||||
| } | } | ||||
| private function writeCommitChanges( | private function writeCommitChanges( | ||||
| PhabricatorRepository $repository, | PhabricatorRepository $repository, | ||||
| PhabricatorRepositoryCommit $commit, | PhabricatorRepositoryCommit $commit, | ||||
| array $changes) { | array $changes) { | ||||
| $conn = $repository->establishConnection('w'); | $conn = $repository->establishConnection('w'); | ||||
| Show All 39 Lines | |||||