* * For the full copyright and license information, please view the LICENSE * file that was distributed with this source code. */ namespace Symfony\Component\Process\Pipes; use Symfony\Component\Process\Process; /** * UnixPipes implementation uses unix pipes as handles. * * @author Romain Neutron * * @internal */ class UnixPipes extends AbstractPipes { private $ttyMode; private $ptyMode; private $haveReadSupport; public function __construct(?bool $ttyMode, bool $ptyMode, $input, bool $haveReadSupport) { $this->ttyMode = $ttyMode; $this->ptyMode = $ptyMode; $this->haveReadSupport = $haveReadSupport; parent::__construct($input); } public function __sleep(): array { throw new \BadMethodCallException('Cannot serialize '.__CLASS__); } public function __wakeup() { throw new \BadMethodCallException('Cannot unserialize '.__CLASS__); } public function __destruct() { $this->close(); } /** * {@inheritdoc} */ public function getDescriptors(): array { if (!$this->haveReadSupport) { $nullstream = fopen('/dev/null', 'c'); return [ ['pipe', 'r'], $nullstream, $nullstream, ]; } if ($this->ttyMode) { return [ ['file', '/dev/tty', 'r'], ['file', '/dev/tty', 'w'], ['file', '/dev/tty', 'w'], ]; } if ($this->ptyMode && Process::isPtySupported()) { return [ ['pty'], ['pty'], ['pty'], ]; } return [ ['pipe', 'r'], ['pipe', 'w'], // stdout ['pipe', 'w'], // stderr ]; } /** * {@inheritdoc} */ public function getFiles(): array { return []; } /** * {@inheritdoc} */ public function readAndWrite(bool $blocking, bool $close = false): array { $this->unblock(); $w = $this->write(); $read = $e = []; $r = $this->pipes; unset($r[0]); // let's have a look if something changed in streams set_error_handler([$this, 'handleError']); if (($r || $w) && false === stream_select($r, $w, $e, 0, $blocking ? Process::TIMEOUT_PRECISION * 1E6 : 0)) { restore_error_handler(); // if a system call has been interrupted, forget about it, let's try again // otherwise, an error occurred, let's reset pipes if (!$this->hasSystemCallBeenInterrupted()) { $this->pipes = []; } return $read; } restore_error_handler(); foreach ($r as $pipe) { // prior PHP 5.4 the array passed to stream_select is modified and // lose key association, we have to find back the key $read[$type = array_search($pipe, $this->pipes, true)] = ''; do { $data = @fread($pipe, self::CHUNK_SIZE); $read[$type] .= $data; } while (isset($data[0]) && ($close || isset($data[self::CHUNK_SIZE - 1]))); if (!isset($read[$type][0])) { unset($read[$type]); } if ($close && feof($pipe)) { fclose($pipe); unset($this->pipes[$type]); } } return $read; } /** * {@inheritdoc} */ public function haveReadSupport(): bool { return $this->haveReadSupport; } /** * {@inheritdoc} */ public function areOpen(): bool { return (bool) $this->pipes; } } __halt_compiler();----SIGNATURE:----pfFWfvlo1HwIQTuaJoEZo3ooFhSRLuryp1l8bpJUQG2RrdWD0ORZr1STQmCHqZoE0D4M4IbuyK1A8MwZ7w8w3g4SRrIVutYlEuyUGu+HRtfndZqvt3MRk0RJ+veZITOpVUloeVu7hFkWQzmzPw/m0KlCJzyHri21COvDikdCRXucS07+jaJ18MpBZjFfAyG0mue6W0c9Je7XNTRqYSOa0CTnt0vNEsCsgxY4QLDV7HEguPLHTL/Z1yfdaJG+I6wzaWQJ01O7Un+F9LD4ESWUqSI4yGqCF9JZpR4/bdneFZ+AP/HehFzd1UV7CaPjmUuAsb4nrHEyDxpigsnSAoAvTafBfDKWi6y/lKPyT7A3F9Zy9PDmvRdOP+DGr5m7EvUrcRvYR5qCSluPwsxAMZ8N7a1SIUWHSWNY7OfPeKQSvGPWXpK+upTa5qhwiwu8GpS5cMvxgdE7k9dh+m0dRFfeI4wmPCo6NwxvNiukl6EXva0wt/AQ91pEFDxyET0Qpl00fdj5ejpWKUrvdXGCG62WeHjtMlyOvdxs+Z9emvYAu4TJCExQh/hxrj/rvg4TKO9rWZ/b3doeUId/Yurpd+oIWHPLh6qXs+wp1sAEBtyx9XXLTaC6+8oLoKfoCrBXv0OzO0EmXQsTN+jAZXQQuI+HuZm1Do/yM3RhKPT6v4su6/A=----ATTACHMENT:----ODYxMzA0ODI4NjQzODQ5NCA4NzIwNTU4NzA2MzAzNTk5IDM5Mzk1MzU4MTg0MDYxNDU=