PhabricatorRepositoryCommitChangeParserWorker.php
No OneTemporary
Actions

Size

2 KB

Referenced Files

None

Subscribers

None

PhabricatorRepositoryCommitChangeParserWorker.php
View Options

	<?php

	abstract class PhabricatorRepositoryCommitChangeParserWorker
	extends PhabricatorRepositoryCommitParserWorker {

	public function getRequiredLeaseTime() {
	// It can take a very long time to parse commits; some commits in the
	// Facebook repository affect many millions of paths. Acquire 24h leases.
	return 60 * 60 * 24;
	}

	public static function lookupOrCreatePaths(array $paths) {
	$repository = new PhabricatorRepository();
	$conn_w = $repository->establishConnection('w');

	$result_map = self::lookupPaths($paths);

	$missing_paths = array_fill_keys($paths, true);
	$missing_paths = array_diff_key($missing_paths, $result_map);
	$missing_paths = array_keys($missing_paths);

	if ($missing_paths) {
	foreach (array_chunk($missing_paths, 128) as $path_chunk) {
	$sql = array();
	foreach ($path_chunk as $path) {
	$sql[] = qsprintf($conn_w, '(%s, %s)', $path, md5($path));
	}
	queryfx(
	$conn_w,
	'INSERT IGNORE INTO %T (path, pathHash) VALUES %Q',
	PhabricatorRepository::TABLE_PATH,
	implode(', ', $sql));
	}
	$result_map += self::lookupPaths($missing_paths);
	}

	return $result_map;
	}

	private static function lookupPaths(array $paths) {
	$repository = new PhabricatorRepository();
	$conn_w = $repository->establishConnection('w');

	$result_map = array();
	foreach (array_chunk($paths, 128) as $path_chunk) {
	$chunk_map = queryfx_all(
	$conn_w,
	'SELECT path, id FROM %T WHERE pathHash IN (%Ls)',
	PhabricatorRepository::TABLE_PATH,
	array_map('md5', $path_chunk));
	foreach ($chunk_map as $row) {
	$result_map[$row['path']] = $row['id'];
	}
	}
	return $result_map;
	}

	protected function finishParse() {
	$commit = $this->commit;

	id(new PhabricatorSearchIndexer())
	->indexDocumentByPHID($commit->getPHID());

	PhabricatorOwnersPackagePathValidator::updateOwnersPackagePaths($commit);
	if ($this->shouldQueueFollowupTasks()) {
	PhabricatorWorker::scheduleTask(
	'PhabricatorRepositoryCommitOwnersWorker',
	array(
	'commitID' => $commit->getID(),
	));
	}
	}

	}

File Metadata

Mime Type: text/x-php
Expires: Fri, Nov 21, 2:04 PM (21 h, 48 m)
Storage Engine: blob
Storage Format: Raw Data
Storage Handle: 352954
Default Alt Text: PhabricatorRepositoryCommitChangeParserWorker.php (2 KB)

PhabricatorRepositoryCommitChangeParserWorker.phpNo OneTemporaryActions

PhabricatorRepositoryCommitChangeParserWorker.phpView Options

File Metadata

Event Timeline

PhabricatorRepositoryCommitChangeParserWorker.php
No OneTemporary
Actions

PhabricatorRepositoryCommitChangeParserWorker.php
View Options