Blame view

sources/3rdparty/symfony/process/Symfony/Component/Process/Tests/PipeStdinInStdoutStdErrStreamSelect.php 1.51 KB
6d9380f96   Cédric Dupont   Update sources OC...
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
  <?php
  
  define('ERR_SELECT_FAILED', 1);
  define('ERR_TIMEOUT', 2);
  define('ERR_READ_FAILED', 3);
  define('ERR_WRITE_FAILED', 4);
  
  $read = array(STDIN);
  $write = array(STDOUT, STDERR);
  
  stream_set_blocking(STDIN, 0);
  stream_set_blocking(STDOUT, 0);
  stream_set_blocking(STDERR, 0);
  
  $out = $err = '';
  while ($read || $write) {
      $r = $read;
      $w = $write;
      $e = null;
      $n = stream_select($r, $w, $e, 5);
  
      if (false === $n) {
          die(ERR_SELECT_FAILED);
      } elseif ($n < 1) {
          die(ERR_TIMEOUT);
      }
  
      if (in_array(STDOUT, $w) && strlen($out) > 0) {
           $written = fwrite(STDOUT, (binary) $out, 32768);
           if (false === $written) {
               die(ERR_WRITE_FAILED);
           }
           $out = (binary) substr($out, $written);
      }
      if (null === $read && strlen($out) < 1) {
          $write = array_diff($write, array(STDOUT));
      }
  
      if (in_array(STDERR, $w) && strlen($err) > 0) {
           $written = fwrite(STDERR, (binary) $err, 32768);
           if (false === $written) {
               die(ERR_WRITE_FAILED);
           }
           $err = (binary) substr($err, $written);
      }
      if (null === $read && strlen($err) < 1) {
          $write = array_diff($write, array(STDERR));
      }
  
      if ($r) {
          $str = fread(STDIN, 32768);
          if (false !== $str) {
              $out .= $str;
              $err .= $str;
          }
          if (false === $str || feof(STDIN)) {
              $read = null;
              if (!feof(STDIN)) {
                  die(ERR_READ_FAILED);
              }
          }
      }
  }