快速部署的KMS服务
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
 
 
 

61 lines
2.0 KiB

<?php
require_once 'Logger.php';
class Process {
private $process;
public int $pid = -1;
public mixed $stdin = null;
public mixed $stdout = null; // only capture enabled
public mixed $stderr = null; // only capture enabled
public function __construct(array $command, bool $capture = false, array $env = array()) {
$desc = array(
0 => array('pipe', 'r') // stdin
);
if ($capture) {
$desc[1] = array('pipe', 'w'); // stdout
$desc[2] = array('pipe', 'w'); // stderr
}
logging::debug('Process command -> `' . implode(' ', $command) . '`');
$this->process = proc_open($command, $desc, $pipes, null, $env); // start process
if (is_resource($this->process)) { // process start success
$this->pid = proc_get_status($this->process)['pid'];
$this->stdin = $pipes[0];
if ($capture) { // add capture pipes
$this->stdout = $pipes[1];
$this->stderr = $pipes[2];
}
}
}
private function getCapture(mixed $stream): string { // read data from target stream
return ($stream == null) ? '' : stream_get_contents($stream);
}
public function getStdout(): string { // fetch data from stdout pipe
return $this->getCapture($this->stdout);
}
public function getStderr(): string { // fetch data from stderr pipe
return $this->getCapture($this->stderr);
}
public function signal(int $signal): void { // send signal to sub process
proc_terminate($this->process, $signal);
}
public function status(): array { // get process status
return proc_get_status($this->process);
}
public function isAlive(): bool { // whether sub process still running
return $this->status()['running'];
}
public function quit(): int {
fclose($this->stdout); // close pipe before proc_close (prevent deadlock)
fclose($this->stderr);
return proc_close($this->process); // return status code
}
}