aleph1.co.uk Git - yaffs-website/blob - vendor/symfony/process/Pipes/UnixPipes.php

   1 <?php
   2
   3 /*
   4  * This file is part of the Symfony package.
   5  *
   6  * (c) Fabien Potencier <fabien@symfony.com>
   7  *
   8  * For the full copyright and license information, please view the LICENSE
   9  * file that was distributed with this source code.
  10  */
  11
  12 namespace Symfony\Component\Process\Pipes;
  13
  14 use Symfony\Component\Process\Process;
  15
  16 /**
  17  * UnixPipes implementation uses unix pipes as handles.
  18  *
  19  * @author Romain Neutron <imprec@gmail.com>
  20  *
  21  * @internal
  22  */
  23 class UnixPipes extends AbstractPipes
  24 {
  25     private $ttyMode;
  26     private $ptyMode;
  27     private $haveReadSupport;
  28
  29     public function __construct($ttyMode, $ptyMode, $input, $haveReadSupport)
  30     {
  31         $this->ttyMode = (bool) $ttyMode;
  32         $this->ptyMode = (bool) $ptyMode;
  33         $this->haveReadSupport = (bool) $haveReadSupport;
  34
  35         parent::__construct($input);
  36     }
  37
  38     public function __destruct()
  39     {
  40         $this->close();
  41     }
  42
  43     /**
  44      * {@inheritdoc}
  45      */
  46     public function getDescriptors()
  47     {
  48         if (!$this->haveReadSupport) {
  49             $nullstream = fopen('/dev/null', 'c');
  50
  51             return array(
  52                 array('pipe', 'r'),
  53                 $nullstream,
  54                 $nullstream,
  55             );
  56         }
  57
  58         if ($this->ttyMode) {
  59             return array(
  60                 array('file', '/dev/tty', 'r'),
  61                 array('file', '/dev/tty', 'w'),
  62                 array('file', '/dev/tty', 'w'),
  63             );
  64         }
  65
  66         if ($this->ptyMode && Process::isPtySupported()) {
  67             return array(
  68                 array('pty'),
  69                 array('pty'),
  70                 array('pty'),
  71             );
  72         }
  73
  74         return array(
  75             array('pipe', 'r'),
  76             array('pipe', 'w'), // stdout
  77             array('pipe', 'w'), // stderr
  78         );
  79     }
  80
  81     /**
  82      * {@inheritdoc}
  83      */
  84     public function getFiles()
  85     {
  86         return array();
  87     }
  88
  89     /**
  90      * {@inheritdoc}
  91      */
  92     public function readAndWrite($blocking, $close = false)
  93     {
  94         $this->unblock();
  95         $w = $this->write();
  96
  97         $read = $e = array();
  98         $r = $this->pipes;
  99         unset($r[0]);
 100
 101         // let's have a look if something changed in streams
 102         set_error_handler(array($this, 'handleError'));
 103         if (($r || $w) && false === stream_select($r, $w, $e, 0, $blocking ? Process::TIMEOUT_PRECISION * 1E6 : 0)) {
 104             restore_error_handler();
 105             // if a system call has been interrupted, forget about it, let's try again
 106             // otherwise, an error occurred, let's reset pipes
 107             if (!$this->hasSystemCallBeenInterrupted()) {
 108                 $this->pipes = array();
 109             }
 110
 111             return $read;
 112         }
 113         restore_error_handler();
 114
 115         foreach ($r as $pipe) {
 116             // prior PHP 5.4 the array passed to stream_select is modified and
 117             // lose key association, we have to find back the key
 118             $read[$type = array_search($pipe, $this->pipes, true)] = '';
 119
 120             do {
 121                 $data = fread($pipe, self::CHUNK_SIZE);
 122                 $read[$type] .= $data;
 123             } while (isset($data[0]) && ($close || isset($data[self::CHUNK_SIZE - 1])));
 124
 125             if (!isset($read[$type][0])) {
 126                 unset($read[$type]);
 127             }
 128
 129             if ($close && feof($pipe)) {
 130                 fclose($pipe);
 131                 unset($this->pipes[$type]);
 132             }
 133         }
 134
 135         return $read;
 136     }
 137
 138     /**
 139      * {@inheritdoc}
 140      */
 141     public function haveReadSupport()
 142     {
 143         return $this->haveReadSupport;
 144     }
 145
 146     /**
 147      * {@inheritdoc}
 148      */
 149     public function areOpen()
 150     {
 151         return (bool) $this->pipes;
 152     }
 153 }