Differential D19816 Diff 47330 src/applications/diffusion/protocol/DiffusionCommandEngine.php

Changeset View

Standalone View

Show First 20 Lines • Show All 129 Lines • ▼ Show 20 Lines	public function newFuture() {
if ($this->getPassthru()) {		if ($this->getPassthru()) {
$future = newv('PhutilExecPassthru', $argv);		$future = newv('PhutilExecPassthru', $argv);
} else {		} else {
$future = newv('ExecFuture', $argv);		$future = newv('ExecFuture', $argv);
}		}

$future->setEnv($env);		$future->setEnv($env);

// See T13108. By default, don't let any cluster command run indefinitely		// See T13108. By default, don't let any cluster command run indefinitely
		amckinleyUnsubmitted Not Done Inline Actions Maybe make this "See T13108 and PHI885."? amckinley: Maybe make this "See T13108 and PHI885."?
// to try to avoid cases where `git fetch` hangs for some reason and we're		// to try to avoid cases where `git fetch` hangs for some reason and we're
// left sitting with a held lock forever.		// left sitting with a held lock forever.
$future->setTimeout(phutil_units('15 minutes in seconds'));		$repository = $this->getRepository();
		$future->setTimeout($repository->getCopyTimeLimit());

return $future;		return $future;
}		}

private function newCommandArgv() {		private function newCommandArgv() {
$argv = $this->argv;		$argv = $this->argv;
$pattern = $argv[0];		$pattern = $argv[0];
$argv = array_slice($argv, 1);		$argv = array_slice($argv, 1);
▲ Show 20 Lines • Show All 154 Lines • Show Last 20 Lines