Differential D21532 Diff 51259 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 |