command = $command; $this->cwd = $cwd ?? ""; foreach ($env as $key => $value) { if (\is_array($value)) { throw new \Error("\$env cannot accept array values"); } $this->env[(string) $key] = (string) $value; } $this->options = $options; } /** * Stops the process if it is still running. */ public function __destruct() { if (\getmypid() === $this->oid) { $this->kill(); // Will only terminate if the process is still running. } Loop::cancel($this->watcher); if (\is_resource($this->stdin)) { \fclose($this->stdin); } if (\is_resource($this->stdout)) { \fclose($this->stdout); } if (\is_resource($this->stderr)) { \fclose($this->stderr); } } /** * Resets process values. */ public function __clone() { $this->process = null; $this->deferred = null; $this->watcher = null; $this->pid = 0; $this->oid = 0; $this->stdin = null; $this->stdout = null; $this->stderr = null; } /** * @throws \Amp\Process\ProcessException If starting the process fails. * @throws \Amp\Process\StatusError If the process is already running. * * @return \AsyncInterop\Promise Succeeds with exit code of the process or fails if the process is killed. */ public function execute(): Promise { if ($this->deferred !== null) { throw new StatusError("The process has already been started"); } $this->deferred = $deferred = new Deferred; $fd = [ ["pipe", "r"], // stdin ["pipe", "w"], // stdout ["pipe", "w"], // stderr ["pipe", "w"], // exit code pipe ]; $nd = \strncasecmp(\PHP_OS, "WIN", 3) === 0 ? "NUL" : "/dev/null"; $command = \sprintf('(%s) 3>%s; code=$?; echo $code >&3; exit $code', $this->command, $nd); $this->process = @\proc_open($command, $fd, $pipes, $this->cwd ?: null, $this->env ?: null, $this->options); if (!\is_resource($this->process)) { $message = "Could not start process"; if ($error = \error_get_last()) { $message .= \sprintf(" Errno: %d; %s", $error["type"], $error["message"]); } throw new ProcessException($message); } $this->oid = \getmypid(); $status = \proc_get_status($this->process); if (!$status) { \proc_close($this->process); $this->process = null; throw new ProcessException("Could not get process status"); } $this->pid = $status["pid"]; foreach ($pipes as $pipe) { \stream_set_blocking($pipe, false); } $this->stdin = $stdin = $pipes[0]; $this->stdout = $pipes[1]; $this->stderr = $pipes[2]; $stream = $pipes[3]; $process = &$this->process; $this->watcher = Loop::onReadable($stream, static function ($watcher, $resource) use ( $process, $deferred, $stdin ) { Loop::cancel($watcher); try { try { if (!\is_resource($resource) || \feof($resource)) { throw new ProcessException("Process ended unexpectedly"); } $code = \rtrim(@\fread($resource, 3)); // Single byte written as string if (!\strlen($code) || !\is_numeric($code)) { throw new ProcessException("Process ended without providing a status code"); } } finally { if (\is_resource($resource)) { \fclose($resource); } if (\is_resource($process)) { \proc_close($process); } if (\is_resource($stdin)) { \fclose($stdin); } } } catch (\Throwable $exception) { $deferred->fail($exception); return; } $deferred->resolve((int) $code); }); return $deferred->promise(); } /** * {@inheritdoc} */ public function kill() { if (\is_resource($this->process)) { // Forcefully kill the process using SIGKILL. \proc_terminate($this->process, 9); // "Detach" from the process and let it die asynchronously. $this->process = null; Loop::cancel($this->watcher); $this->deferred->fail(new ProcessException("The process was killed")); } } /** * Sends the given signal to the process. * * @param int $signo Signal number to send to process. * * @throws \Amp\Process\StatusError If the process is not running. */ public function signal(int $signo) { if (!$this->isRunning()) { throw new StatusError("The process is not running"); } \proc_terminate($this->process, $signo); } /** * Returns the PID of the child process. Value is only meaningful if PHP was not compiled with --enable-sigchild. * * @return int * * @throws \Amp\Process\StatusError */ public function getPid(): int { if ($this->pid === 0) { throw new StatusError("The process has not been started"); } return $this->pid; } /** * Returns the command to execute. * * @return string The command to execute. */ public function getCommand(): string { return $this->command; } /** * Gets the current working directory. * * @return string The current working directory an empty string if inherited from the current PHP process. */ public function getWorkingDirectory(): string { if ($this->cwd === "") { return \getcwd() ?: ""; } return $this->cwd; } /** * Gets the environment variables array. * * @return string[] Array of environment variables. */ public function getEnv(): array { return $this->env; } /** * Gets the options to pass to proc_open(). * * @return mixed[] Array of options. */ public function getOptions(): array { return $this->options; } /** * Determines if the process is still running. * * @return bool */ public function isRunning(): bool { return \is_resource($this->process); } /** * Gets the process input stream (STDIN). * * @return resource * * @throws \Amp\Process\StatusError If the process is not running. */ public function getStdin() { if ($this->stdin === null) { throw new StatusError("The process has not been started"); } return $this->stdin; } /** * Gets the process output stream (STDOUT). * * @return resource * * @throws \Amp\Process\StatusError If the process is not running. */ public function getStdout() { if ($this->stdout === null) { throw new StatusError("The process has not been started"); } return $this->stdout; } /** * Gets the process error stream (STDERR). * * @return resource * * @throws \Amp\Process\StatusError If the process is not running. */ public function getStderr() { if ($this->stderr === null) { throw new StatusError("The process has not been started"); } return $this->stderr; } }