danog/process
1
0
Fork 0
mirror of https://github.com/danog/process.git synced 2024-11-30 04:39:04 +01:00
Code Issues Projects Releases Wiki Activity

Close unnecessary file descriptors in child process

Browse Source
This commit is contained in:
Aaron Piotrowski 2019-01-23 12:44:43 -06:00
parent e7e28219da
commit bc9c2209ad
No known key found for this signature in database
GPG Key ID: ADD1EF783EDE9EEB
1 changed files with 23 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
lib/Internal/Posix/Runner.php
View File

@ -24,6 +24,9 @@ final class Runner implements ProcessRunner
["pipe", "w"], // exit code pipe
];
/** @var string|null */
private static $fdPath;
public static function onProcessEndExtraDataPipeReadable($watcher, $stream, Handle $handle)
{
Loop::cancel($watcher);
@ -82,7 +85,7 @@ final class Runner implements ProcessRunner
);
$handle = new Handle;
$handle->proc = @\proc_open($command, self::FD_SPEC, $pipes, $cwd ?: null, $env ?: null, $options);
$handle->proc = @\proc_open($command, $this->generateFds(), $pipes, $cwd ?: null, $env ?: null, $options);
if (!\is_resource($handle->proc)) {
$message = "Could not start process";
@ -127,6 +130,25 @@ final class Runner implements ProcessRunner
return $handle;
}
private function generateFds(): array
{
if (self::$fdPath === null) {
self::$fdPath = \file_exists("/dev/fd") ? "/dev/fd" : "/proc/self/fd";
}
$fds = @\scandir(self::$fdPath, \SCANDIR_SORT_NONE);
if ($fds === false) {
throw new ProcessException("Unable to list open file descriptors");
}
$fds = \array_filter($fds, function (string $path): bool {
return $path !== "." && $path !== "..";
});
return \array_merge(self::FD_SPEC, \array_fill(4, \count($fds) - 4, ["file", "/dev/null", "r"]));
}
/** @inheritdoc */
public function join(ProcessHandle $handle): Promise
{