public function Process::wait

Waits for the process to terminate.

The callback receives the type of output (out or err) and some bytes from the output in real-time while writing the standard input to the process. It allows to have feedback from the independent process during execution.

Parameters

mixed $callback A valid PHP callback:

Return value

int The exitcode of the process

Throws

\RuntimeException

File

drupal/core/vendor/symfony/process/Symfony/Component/Process/Process.php, line 316

Class

Process

Process is a thin wrapper around proc_* functions to ease start independent PHP processes.

Namespace

Code

public function wait($callback = null) {
  $this
    ->updateStatus();
  $callback = $this
    ->buildCallback($callback);
  while ($this->pipes || defined('PHP_WINDOWS_VERSION_BUILD') && $this->fileHandles) {
    if (defined('PHP_WINDOWS_VERSION_BUILD') && $this->fileHandles) {
      $this
        ->processFileHandles($callback, !$this->pipes);
    }
    if ($this->pipes) {
      $r = $this->pipes;
      $w = null;
      $e = null;
      $n = @stream_select($r, $w, $e, $this->timeout);
      if (false === $n) {
        $this->pipes = array();
        continue;
      }
      if (0 === $n) {
        proc_terminate($this->process);
        throw new \RuntimeException('The process timed out.');
      }
      foreach ($r as $pipe) {
        $type = array_search($pipe, $this->pipes);
        $data = fread($pipe, 8192);
        if (strlen($data) > 0) {

          // last exit code is output and caught to work around --enable-sigchild
          if (3 == $type) {
            $this->fallbackExitcode = (int) $data;
          }
          else {
            call_user_func($callback, $type == 1 ? self::OUT : self::ERR, $data);
          }
        }
        if (false === $data || feof($pipe)) {
          fclose($pipe);
          unset($this->pipes[$type]);
        }
      }
    }
  }
  $this
    ->updateStatus();
  if ($this->processInformation['signaled']) {
    throw new \RuntimeException(sprintf('The process stopped because of a "%s" signal.', $this->processInformation['stopsig']));
  }
  $time = 0;
  while ($this
    ->isRunning() && $time < 1000000) {
    $time += 1000;
    usleep(1000);
  }
  $exitcode = proc_close($this->process);
  if ($this->processInformation['signaled']) {
    throw new \RuntimeException(sprintf('The process stopped because of a "%s" signal.', $this->processInformation['stopsig']));
  }
  $this->exitcode = $this->processInformation['running'] ? $exitcode : $this->processInformation['exitcode'];
  if (-1 == $this->exitcode && null !== $this->fallbackExitcode) {
    $this->exitcode = $this->fallbackExitcode;
  }
  return $this->exitcode;
}