gravityview / GravityView

vendor/symfony/process/Exception/ProcessFailedException.php

Indentation +31 added lines, -31 removed lines

@@ -20,35 +20,35 @@
  */
 class ProcessFailedException extends RuntimeException
 {
-    private $process;
-
-    public function __construct(Process $process)
-    {
-        if ($process->isSuccessful()) {
-            throw new InvalidArgumentException('Expected a failed process, but the given process was successful.');
-        }
-
-        $error = sprintf('The command "%s" failed.'."\n\nExit Code: %s(%s)\n\nWorking directory: %s",
-            $process->getCommandLine(),
-            $process->getExitCode(),
-            $process->getExitCodeText(),
-            $process->getWorkingDirectory()
-        );
-
-        if (!$process->isOutputDisabled()) {
-            $error .= sprintf("\n\nOutput:\n================\n%s\n\nError Output:\n================\n%s",
-                $process->getOutput(),
-                $process->getErrorOutput()
-            );
-        }
-
-        parent::__construct($error);
-
-        $this->process = $process;
-    }
-
-    public function getProcess()
-    {
-        return $this->process;
-    }
+	private $process;
+
+	public function __construct(Process $process)
+	{
+		if ($process->isSuccessful()) {
+			throw new InvalidArgumentException('Expected a failed process, but the given process was successful.');
+		}
+
+		$error = sprintf('The command "%s" failed.'."\n\nExit Code: %s(%s)\n\nWorking directory: %s",
+			$process->getCommandLine(),
+			$process->getExitCode(),
+			$process->getExitCodeText(),
+			$process->getWorkingDirectory()
+		);
+
+		if (!$process->isOutputDisabled()) {
+			$error .= sprintf("\n\nOutput:\n================\n%s\n\nError Output:\n================\n%s",
+				$process->getOutput(),
+				$process->getErrorOutput()
+			);
+		}
+
+		parent::__construct($error);
+
+		$this->process = $process;
+	}
+
+	public function getProcess()
+	{
+		return $this->process;
+	}
 }

Spacing +7 added lines, -7 removed lines

@@ -22,27 +22,27 @@
 {
     private $process;
 
-    public function __construct(Process $process)
+    public function __construct( Process $process )
     {
-        if ($process->isSuccessful()) {
-            throw new InvalidArgumentException('Expected a failed process, but the given process was successful.');
+        if ( $process->isSuccessful() ) {
+            throw new InvalidArgumentException( 'Expected a failed process, but the given process was successful.' );
         }
 
-        $error = sprintf('The command "%s" failed.'."\n\nExit Code: %s(%s)\n\nWorking directory: %s",
+        $error = sprintf( 'The command "%s" failed.' . "\n\nExit Code: %s(%s)\n\nWorking directory: %s",
             $process->getCommandLine(),
             $process->getExitCode(),
             $process->getExitCodeText(),
             $process->getWorkingDirectory()
         );
 
-        if (!$process->isOutputDisabled()) {
-            $error .= sprintf("\n\nOutput:\n================\n%s\n\nError Output:\n================\n%s",
+        if ( ! $process->isOutputDisabled() ) {
+            $error .= sprintf( "\n\nOutput:\n================\n%s\n\nError Output:\n================\n%s",
                 $process->getOutput(),
                 $process->getErrorOutput()
             );
         }
 
-        parent::__construct($error);
+        parent::__construct( $error );
 
         $this->process = $process;
     }

Braces +3 added lines, -6 removed lines

@@ -18,12 +18,10 @@ 
  *
  * @author Johannes M. Schmitt <schmittjoh@gmail.com>
  */
-class ProcessFailedException extends RuntimeException
-{
+class ProcessFailedException extends RuntimeException {
     private $process;
 
-    public function __construct(Process $process)
-    {
+    public function __construct(Process $process) {
         if ($process->isSuccessful()) {
             throw new InvalidArgumentException('Expected a failed process, but the given process was successful.');
         }
@@ -47,8 +45,7 @@ 
         $this->process = $process;
     }
 
-    public function getProcess()
-    {
+    public function getProcess() {
         return $this->process;
     }
 }

vendor/symfony/process/Exception/RuntimeException.php

Braces +1 added lines, -2 removed lines

@@ -16,6 +16,5 @@
  *
  * @author Johannes M. Schmitt <schmittjoh@gmail.com>
  */
-class RuntimeException extends \RuntimeException implements ExceptionInterface
-{
+class RuntimeException extends \RuntimeException implements ExceptionInterface {
 }

vendor/symfony/process/Exception/ProcessSignaledException.php

Indentation +14 added lines, -14 removed lines

@@ -20,22 +20,22 @@
  */
 final class ProcessSignaledException extends RuntimeException
 {
-    private $process;
+	private $process;
 
-    public function __construct(Process $process)
-    {
-        $this->process = $process;
+	public function __construct(Process $process)
+	{
+		$this->process = $process;
 
-        parent::__construct(sprintf('The process has been signaled with signal "%s".', $process->getTermSignal()));
-    }
+		parent::__construct(sprintf('The process has been signaled with signal "%s".', $process->getTermSignal()));
+	}
 
-    public function getProcess(): Process
-    {
-        return $this->process;
-    }
+	public function getProcess(): Process
+	{
+		return $this->process;
+	}
 
-    public function getSignal(): int
-    {
-        return $this->getProcess()->getTermSignal();
-    }
+	public function getSignal(): int
+	{
+		return $this->getProcess()->getTermSignal();
+	}
 }

Spacing +2 added lines, -2 removed lines

@@ -22,11 +22,11 @@
 {
     private $process;
 
-    public function __construct(Process $process)
+    public function __construct( Process $process )
     {
         $this->process = $process;
 
-        parent::__construct(sprintf('The process has been signaled with signal "%s".', $process->getTermSignal()));
+        parent::__construct( sprintf( 'The process has been signaled with signal "%s".', $process->getTermSignal() ) );
     }
 
     public function getProcess(): Process

Braces +2 added lines, -4 removed lines

@@ -18,12 +18,10 @@
  *
  * @author Sullivan Senechal <soullivaneuh@gmail.com>
  */
-final class ProcessSignaledException extends RuntimeException
-{
+final class ProcessSignaledException extends RuntimeException {
     private $process;
 
-    public function __construct(Process $process)
-    {
+    public function __construct(Process $process) {
         $this->process = $process;
 
         parent::__construct(sprintf('The process has been signaled with signal "%s".', $process->getTermSignal()));

vendor/symfony/process/Exception/LogicException.php

Braces +1 added lines, -2 removed lines

@@ -16,6 +16,5 @@
  *
  * @author Romain Neutron <imprec@gmail.com>
  */
-class LogicException extends \LogicException implements ExceptionInterface
-{
+class LogicException extends \LogicException implements ExceptionInterface {
 }

vendor/symfony/process/ProcessUtils.php

Indentation +41 added lines, -41 removed lines

@@ -22,48 +22,48 @@
  */
 class ProcessUtils
 {
-    /**
-     * This class should not be instantiated.
-     */
-    private function __construct()
-    {
-    }
+	/**
+	 * This class should not be instantiated.
+	 */
+	private function __construct()
+	{
+	}
 
-    /**
-     * Validates and normalizes a Process input.
-     *
-     * @param string $caller The name of method call that validates the input
-     * @param mixed  $input  The input to validate
-     *
-     * @return mixed The validated input
-     *
-     * @throws InvalidArgumentException In case the input is not valid
-     */
-    public static function validateInput(string $caller, $input)
-    {
-        if (null !== $input) {
-            if (\is_resource($input)) {
-                return $input;
-            }
-            if (\is_string($input)) {
-                return $input;
-            }
-            if (is_scalar($input)) {
-                return (string) $input;
-            }
-            if ($input instanceof Process) {
-                return $input->getIterator($input::ITER_SKIP_ERR);
-            }
-            if ($input instanceof \Iterator) {
-                return $input;
-            }
-            if ($input instanceof \Traversable) {
-                return new \IteratorIterator($input);
-            }
+	/**
+	 * Validates and normalizes a Process input.
+	 *
+	 * @param string $caller The name of method call that validates the input
+	 * @param mixed  $input  The input to validate
+	 *
+	 * @return mixed The validated input
+	 *
+	 * @throws InvalidArgumentException In case the input is not valid
+	 */
+	public static function validateInput(string $caller, $input)
+	{
+		if (null !== $input) {
+			if (\is_resource($input)) {
+				return $input;
+			}
+			if (\is_string($input)) {
+				return $input;
+			}
+			if (is_scalar($input)) {
+				return (string) $input;
+			}
+			if ($input instanceof Process) {
+				return $input->getIterator($input::ITER_SKIP_ERR);
+			}
+			if ($input instanceof \Iterator) {
+				return $input;
+			}
+			if ($input instanceof \Traversable) {
+				return new \IteratorIterator($input);
+			}
 
-            throw new InvalidArgumentException(sprintf('"%s" only accepts strings, Traversable objects or stream resources.', $caller));
-        }
+			throw new InvalidArgumentException(sprintf('"%s" only accepts strings, Traversable objects or stream resources.', $caller));
+		}
 
-        return $input;
-    }
+		return $input;
+	}
 }

Spacing +12 added lines, -12 removed lines

@@ -39,29 +39,29 @@
      *
      * @throws InvalidArgumentException In case the input is not valid
      */
-    public static function validateInput(string $caller, $input)
+    public static function validateInput( string $caller, $input )
     {
-        if (null !== $input) {
-            if (\is_resource($input)) {
+        if ( null !== $input ) {
+            if ( \is_resource( $input ) ) {
                 return $input;
             }
-            if (\is_string($input)) {
+            if ( \is_string( $input ) ) {
                 return $input;
             }
-            if (is_scalar($input)) {
-                return (string) $input;
+            if ( is_scalar( $input ) ) {
+                return (string)$input;
             }
-            if ($input instanceof Process) {
-                return $input->getIterator($input::ITER_SKIP_ERR);
+            if ( $input instanceof Process ) {
+                return $input->getIterator( $input::ITER_SKIP_ERR );
             }
-            if ($input instanceof \Iterator) {
+            if ( $input instanceof \Iterator ) {
                 return $input;
             }
-            if ($input instanceof \Traversable) {
-                return new \IteratorIterator($input);
+            if ( $input instanceof \Traversable ) {
+                return new \IteratorIterator( $input );
             }
 
-            throw new InvalidArgumentException(sprintf('"%s" only accepts strings, Traversable objects or stream resources.', $caller));
+            throw new InvalidArgumentException( sprintf( '"%s" only accepts strings, Traversable objects or stream resources.', $caller ) );
         }
 
         return $input;

Braces +3 added lines, -6 removed lines

@@ -20,13 +20,11 @@ 
  *
  * @author Martin Hasoň <martin.hason@gmail.com>
  */
-class ProcessUtils
-{
+class ProcessUtils {
     /**
      * This class should not be instantiated.
      */
-    private function __construct()
-    {
+    private function __construct() {
     }
 
     /**
@@ -39,8 +37,7 @@ 
      *
      * @throws InvalidArgumentException In case the input is not valid
      */
-    public static function validateInput(string $caller, $input)
-    {
+    public static function validateInput(string $caller, $input) {
         if (null !== $input) {
             if (\is_resource($input)) {
                 return $input;

vendor/symfony/process/Pipes/PipesInterface.php

Indentation +38 added lines, -38 removed lines

@@ -20,42 +20,42 @@
  */
 interface PipesInterface
 {
-    public const CHUNK_SIZE = 16384;
-
-    /**
-     * Returns an array of descriptors for the use of proc_open.
-     */
-    public function getDescriptors(): array;
-
-    /**
-     * Returns an array of filenames indexed by their related stream in case these pipes use temporary files.
-     *
-     * @return string[]
-     */
-    public function getFiles(): array;
-
-    /**
-     * Reads data in file handles and pipes.
-     *
-     * @param bool $blocking Whether to use blocking calls or not
-     * @param bool $close    Whether to close pipes if they've reached EOF
-     *
-     * @return string[] An array of read data indexed by their fd
-     */
-    public function readAndWrite(bool $blocking, bool $close = false): array;
-
-    /**
-     * Returns if the current state has open file handles or pipes.
-     */
-    public function areOpen(): bool;
-
-    /**
-     * Returns if pipes are able to read output.
-     */
-    public function haveReadSupport(): bool;
-
-    /**
-     * Closes file handles and pipes.
-     */
-    public function close();
+	public const CHUNK_SIZE = 16384;
+
+	/**
+	 * Returns an array of descriptors for the use of proc_open.
+	 */
+	public function getDescriptors(): array;
+
+	/**
+	 * Returns an array of filenames indexed by their related stream in case these pipes use temporary files.
+	 *
+	 * @return string[]
+	 */
+	public function getFiles(): array;
+
+	/**
+	 * Reads data in file handles and pipes.
+	 *
+	 * @param bool $blocking Whether to use blocking calls or not
+	 * @param bool $close    Whether to close pipes if they've reached EOF
+	 *
+	 * @return string[] An array of read data indexed by their fd
+	 */
+	public function readAndWrite(bool $blocking, bool $close = false): array;
+
+	/**
+	 * Returns if the current state has open file handles or pipes.
+	 */
+	public function areOpen(): bool;
+
+	/**
+	 * Returns if pipes are able to read output.
+	 */
+	public function haveReadSupport(): bool;
+
+	/**
+	 * Closes file handles and pipes.
+	 */
+	public function close();
 }

Spacing +1 added lines, -1 removed lines

@@ -42,7 +42,7 @@
      *
      * @return string[] An array of read data indexed by their fd
      */
-    public function readAndWrite(bool $blocking, bool $close = false): array;
+    public function readAndWrite( bool $blocking, bool $close = false ): array;
 
     /**
      * Returns if the current state has open file handles or pipes.

Braces +1 added lines, -2 removed lines

@@ -18,8 +18,7 @@
  *
  * @internal
  */
-interface PipesInterface
-{
+interface PipesInterface {
     public const CHUNK_SIZE = 16384;
 
     /**

vendor/symfony/process/Pipes/AbstractPipes.php

Indentation +155 added lines, -155 removed lines

@@ -20,159 +20,159 @@
  */
 abstract class AbstractPipes implements PipesInterface
 {
-    public $pipes = [];
-
-    private $inputBuffer = '';
-    private $input;
-    private $blocked = true;
-    private $lastError;
-
-    /**
-     * @param resource|string|int|float|bool|\Iterator|null $input
-     */
-    public function __construct($input)
-    {
-        if (\is_resource($input) || $input instanceof \Iterator) {
-            $this->input = $input;
-        } elseif (\is_string($input)) {
-            $this->inputBuffer = $input;
-        } else {
-            $this->inputBuffer = (string) $input;
-        }
-    }
-
-    /**
-     * {@inheritdoc}
-     */
-    public function close()
-    {
-        foreach ($this->pipes as $pipe) {
-            fclose($pipe);
-        }
-        $this->pipes = [];
-    }
-
-    /**
-     * Returns true if a system call has been interrupted.
-     */
-    protected function hasSystemCallBeenInterrupted(): bool
-    {
-        $lastError = $this->lastError;
-        $this->lastError = null;
-
-        // stream_select returns false when the `select` system call is interrupted by an incoming signal
-        return null !== $lastError && false !== stripos($lastError, 'interrupted system call');
-    }
-
-    /**
-     * Unblocks streams.
-     */
-    protected function unblock()
-    {
-        if (!$this->blocked) {
-            return;
-        }
-
-        foreach ($this->pipes as $pipe) {
-            stream_set_blocking($pipe, 0);
-        }
-        if (\is_resource($this->input)) {
-            stream_set_blocking($this->input, 0);
-        }
-
-        $this->blocked = false;
-    }
-
-    /**
-     * Writes input to stdin.
-     *
-     * @throws InvalidArgumentException When an input iterator yields a non supported value
-     */
-    protected function write(): ?array
-    {
-        if (!isset($this->pipes[0])) {
-            return null;
-        }
-        $input = $this->input;
-
-        if ($input instanceof \Iterator) {
-            if (!$input->valid()) {
-                $input = null;
-            } elseif (\is_resource($input = $input->current())) {
-                stream_set_blocking($input, 0);
-            } elseif (!isset($this->inputBuffer[0])) {
-                if (!\is_string($input)) {
-                    if (!is_scalar($input)) {
-                        throw new InvalidArgumentException(sprintf('"%s" yielded a value of type "%s", but only scalars and stream resources are supported.', get_debug_type($this->input), get_debug_type($input)));
-                    }
-                    $input = (string) $input;
-                }
-                $this->inputBuffer = $input;
-                $this->input->next();
-                $input = null;
-            } else {
-                $input = null;
-            }
-        }
-
-        $r = $e = [];
-        $w = [$this->pipes[0]];
-
-        // let's have a look if something changed in streams
-        if (false === @stream_select($r, $w, $e, 0, 0)) {
-            return null;
-        }
-
-        foreach ($w as $stdin) {
-            if (isset($this->inputBuffer[0])) {
-                $written = fwrite($stdin, $this->inputBuffer);
-                $this->inputBuffer = substr($this->inputBuffer, $written);
-                if (isset($this->inputBuffer[0])) {
-                    return [$this->pipes[0]];
-                }
-            }
-
-            if ($input) {
-                for (;;) {
-                    $data = fread($input, self::CHUNK_SIZE);
-                    if (!isset($data[0])) {
-                        break;
-                    }
-                    $written = fwrite($stdin, $data);
-                    $data = substr($data, $written);
-                    if (isset($data[0])) {
-                        $this->inputBuffer = $data;
-
-                        return [$this->pipes[0]];
-                    }
-                }
-                if (feof($input)) {
-                    if ($this->input instanceof \Iterator) {
-                        $this->input->next();
-                    } else {
-                        $this->input = null;
-                    }
-                }
-            }
-        }
-
-        // no input to read on resource, buffer is empty
-        if (!isset($this->inputBuffer[0]) && !($this->input instanceof \Iterator ? $this->input->valid() : $this->input)) {
-            $this->input = null;
-            fclose($this->pipes[0]);
-            unset($this->pipes[0]);
-        } elseif (!$w) {
-            return [$this->pipes[0]];
-        }
-
-        return null;
-    }
-
-    /**
-     * @internal
-     */
-    public function handleError(int $type, string $msg)
-    {
-        $this->lastError = $msg;
-    }
+	public $pipes = [];
+
+	private $inputBuffer = '';
+	private $input;
+	private $blocked = true;
+	private $lastError;
+
+	/**
+	 * @param resource|string|int|float|bool|\Iterator|null $input
+	 */
+	public function __construct($input)
+	{
+		if (\is_resource($input) || $input instanceof \Iterator) {
+			$this->input = $input;
+		} elseif (\is_string($input)) {
+			$this->inputBuffer = $input;
+		} else {
+			$this->inputBuffer = (string) $input;
+		}
+	}
+
+	/**
+	 * {@inheritdoc}
+	 */
+	public function close()
+	{
+		foreach ($this->pipes as $pipe) {
+			fclose($pipe);
+		}
+		$this->pipes = [];
+	}
+
+	/**
+	 * Returns true if a system call has been interrupted.
+	 */
+	protected function hasSystemCallBeenInterrupted(): bool
+	{
+		$lastError = $this->lastError;
+		$this->lastError = null;
+
+		// stream_select returns false when the `select` system call is interrupted by an incoming signal
+		return null !== $lastError && false !== stripos($lastError, 'interrupted system call');
+	}
+
+	/**
+	 * Unblocks streams.
+	 */
+	protected function unblock()
+	{
+		if (!$this->blocked) {
+			return;
+		}
+
+		foreach ($this->pipes as $pipe) {
+			stream_set_blocking($pipe, 0);
+		}
+		if (\is_resource($this->input)) {
+			stream_set_blocking($this->input, 0);
+		}
+
+		$this->blocked = false;
+	}
+
+	/**
+	 * Writes input to stdin.
+	 *
+	 * @throws InvalidArgumentException When an input iterator yields a non supported value
+	 */
+	protected function write(): ?array
+	{
+		if (!isset($this->pipes[0])) {
+			return null;
+		}
+		$input = $this->input;
+
+		if ($input instanceof \Iterator) {
+			if (!$input->valid()) {
+				$input = null;
+			} elseif (\is_resource($input = $input->current())) {
+				stream_set_blocking($input, 0);
+			} elseif (!isset($this->inputBuffer[0])) {
+				if (!\is_string($input)) {
+					if (!is_scalar($input)) {
+						throw new InvalidArgumentException(sprintf('"%s" yielded a value of type "%s", but only scalars and stream resources are supported.', get_debug_type($this->input), get_debug_type($input)));
+					}
+					$input = (string) $input;
+				}
+				$this->inputBuffer = $input;
+				$this->input->next();
+				$input = null;
+			} else {
+				$input = null;
+			}
+		}
+
+		$r = $e = [];
+		$w = [$this->pipes[0]];
+
+		// let's have a look if something changed in streams
+		if (false === @stream_select($r, $w, $e, 0, 0)) {
+			return null;
+		}
+
+		foreach ($w as $stdin) {
+			if (isset($this->inputBuffer[0])) {
+				$written = fwrite($stdin, $this->inputBuffer);
+				$this->inputBuffer = substr($this->inputBuffer, $written);
+				if (isset($this->inputBuffer[0])) {
+					return [$this->pipes[0]];
+				}
+			}
+
+			if ($input) {
+				for (;;) {
+					$data = fread($input, self::CHUNK_SIZE);
+					if (!isset($data[0])) {
+						break;
+					}
+					$written = fwrite($stdin, $data);
+					$data = substr($data, $written);
+					if (isset($data[0])) {
+						$this->inputBuffer = $data;
+
+						return [$this->pipes[0]];
+					}
+				}
+				if (feof($input)) {
+					if ($this->input instanceof \Iterator) {
+						$this->input->next();
+					} else {
+						$this->input = null;
+					}
+				}
+			}
+		}
+
+		// no input to read on resource, buffer is empty
+		if (!isset($this->inputBuffer[0]) && !($this->input instanceof \Iterator ? $this->input->valid() : $this->input)) {
+			$this->input = null;
+			fclose($this->pipes[0]);
+			unset($this->pipes[0]);
+		} elseif (!$w) {
+			return [$this->pipes[0]];
+		}
+
+		return null;
+	}
+
+	/**
+	 * @internal
+	 */
+	public function handleError(int $type, string $msg)
+	{
+		$this->lastError = $msg;
+	}
 }

Spacing +49 added lines, -49 removed lines

@@ -20,7 +20,7 @@ 
  */
 abstract class AbstractPipes implements PipesInterface
 {
-    public $pipes = [];
+    public $pipes = [ ];
 
     private $inputBuffer = '';
     private $input;
@@ -30,14 +30,14 @@ 
     /**
      * @param resource|string|int|float|bool|\Iterator|null $input
      */
-    public function __construct($input)
+    public function __construct( $input )
     {
-        if (\is_resource($input) || $input instanceof \Iterator) {
+        if ( \is_resource( $input ) || $input instanceof \Iterator ) {
             $this->input = $input;
-        } elseif (\is_string($input)) {
+        } elseif ( \is_string( $input ) ) {
             $this->inputBuffer = $input;
         } else {
-            $this->inputBuffer = (string) $input;
+            $this->inputBuffer = (string)$input;
         }
     }
 
@@ -46,10 +46,10 @@ 
      */
     public function close()
     {
-        foreach ($this->pipes as $pipe) {
-            fclose($pipe);
+        foreach ( $this->pipes as $pipe ) {
+            fclose( $pipe );
         }
-        $this->pipes = [];
+        $this->pipes = [ ];
     }
 
     /**
@@ -61,7 +61,7 @@ 
         $this->lastError = null;
 
         // stream_select returns false when the `select` system call is interrupted by an incoming signal
-        return null !== $lastError && false !== stripos($lastError, 'interrupted system call');
+        return null !== $lastError && false !== stripos( $lastError, 'interrupted system call' );
     }
 
     /**
@@ -69,15 +69,15 @@ 
      */
     protected function unblock()
     {
-        if (!$this->blocked) {
+        if ( ! $this->blocked ) {
             return;
         }
 
-        foreach ($this->pipes as $pipe) {
-            stream_set_blocking($pipe, 0);
+        foreach ( $this->pipes as $pipe ) {
+            stream_set_blocking( $pipe, 0 );
         }
-        if (\is_resource($this->input)) {
-            stream_set_blocking($this->input, 0);
+        if ( \is_resource( $this->input ) ) {
+            stream_set_blocking( $this->input, 0 );
         }
 
         $this->blocked = false;
@@ -90,22 +90,22 @@ 
      */
     protected function write(): ?array
     {
-        if (!isset($this->pipes[0])) {
+        if ( ! isset( $this->pipes[ 0 ] ) ) {
             return null;
         }
         $input = $this->input;
 
-        if ($input instanceof \Iterator) {
-            if (!$input->valid()) {
+        if ( $input instanceof \Iterator ) {
+            if ( ! $input->valid() ) {
                 $input = null;
-            } elseif (\is_resource($input = $input->current())) {
-                stream_set_blocking($input, 0);
-            } elseif (!isset($this->inputBuffer[0])) {
-                if (!\is_string($input)) {
-                    if (!is_scalar($input)) {
-                        throw new InvalidArgumentException(sprintf('"%s" yielded a value of type "%s", but only scalars and stream resources are supported.', get_debug_type($this->input), get_debug_type($input)));
+            } elseif ( \is_resource( $input = $input->current() ) ) {
+                stream_set_blocking( $input, 0 );
+            } elseif ( ! isset( $this->inputBuffer[ 0 ] ) ) {
+                if ( ! \is_string( $input ) ) {
+                    if ( ! is_scalar( $input ) ) {
+                        throw new InvalidArgumentException( sprintf( '"%s" yielded a value of type "%s", but only scalars and stream resources are supported.', get_debug_type( $this->input ), get_debug_type( $input ) ) );
                     }
-                    $input = (string) $input;
+                    $input = (string)$input;
                 }
                 $this->inputBuffer = $input;
                 $this->input->next();
@@ -115,39 +115,39 @@ 
             }
         }
 
-        $r = $e = [];
-        $w = [$this->pipes[0]];
+        $r = $e = [ ];
+        $w = [ $this->pipes[ 0 ] ];
 
         // let's have a look if something changed in streams
-        if (false === @stream_select($r, $w, $e, 0, 0)) {
+        if ( false === @stream_select( $r, $w, $e, 0, 0 ) ) {
             return null;
         }
 
-        foreach ($w as $stdin) {
-            if (isset($this->inputBuffer[0])) {
-                $written = fwrite($stdin, $this->inputBuffer);
-                $this->inputBuffer = substr($this->inputBuffer, $written);
-                if (isset($this->inputBuffer[0])) {
-                    return [$this->pipes[0]];
+        foreach ( $w as $stdin ) {
+            if ( isset( $this->inputBuffer[ 0 ] ) ) {
+                $written = fwrite( $stdin, $this->inputBuffer );
+                $this->inputBuffer = substr( $this->inputBuffer, $written );
+                if ( isset( $this->inputBuffer[ 0 ] ) ) {
+                    return [ $this->pipes[ 0 ] ];
                 }
             }
 
-            if ($input) {
-                for (;;) {
-                    $data = fread($input, self::CHUNK_SIZE);
-                    if (!isset($data[0])) {
+            if ( $input ) {
+                for ( ;; ) {
+                    $data = fread( $input, self::CHUNK_SIZE );
+                    if ( ! isset( $data[ 0 ] ) ) {
                         break;
                     }
-                    $written = fwrite($stdin, $data);
-                    $data = substr($data, $written);
-                    if (isset($data[0])) {
+                    $written = fwrite( $stdin, $data );
+                    $data = substr( $data, $written );
+                    if ( isset( $data[ 0 ] ) ) {
                         $this->inputBuffer = $data;
 
-                        return [$this->pipes[0]];
+                        return [ $this->pipes[ 0 ] ];
                     }
                 }
-                if (feof($input)) {
-                    if ($this->input instanceof \Iterator) {
+                if ( feof( $input ) ) {
+                    if ( $this->input instanceof \Iterator ) {
                         $this->input->next();
                     } else {
                         $this->input = null;
@@ -157,12 +157,12 @@ 
         }
 
         // no input to read on resource, buffer is empty
-        if (!isset($this->inputBuffer[0]) && !($this->input instanceof \Iterator ? $this->input->valid() : $this->input)) {
+        if ( ! isset( $this->inputBuffer[ 0 ] ) && ! ( $this->input instanceof \Iterator ? $this->input->valid() : $this->input ) ) {
             $this->input = null;
-            fclose($this->pipes[0]);
-            unset($this->pipes[0]);
-        } elseif (!$w) {
-            return [$this->pipes[0]];
+            fclose( $this->pipes[ 0 ] );
+            unset( $this->pipes[ 0 ] );
+        } elseif ( ! $w ) {
+            return [ $this->pipes[ 0 ] ];
         }
 
         return null;
@@ -171,7 +171,7 @@ 
     /**
      * @internal
      */
-    public function handleError(int $type, string $msg)
+    public function handleError( int $type, string $msg )
     {
         $this->lastError = $msg;
     }

Braces +5 added lines, -10 removed lines

@@ -18,8 +18,7 @@ 
  *
  * @internal
  */
-abstract class AbstractPipes implements PipesInterface
-{
+abstract class AbstractPipes implements PipesInterface {
     public $pipes = [];
 
     private $inputBuffer = '';
@@ -30,8 +29,7 @@ 
     /**
      * @param resource|string|int|float|bool|\Iterator|null $input
      */
-    public function __construct($input)
-    {
+    public function __construct($input) {
         if (\is_resource($input) || $input instanceof \Iterator) {
             $this->input = $input;
         } elseif (\is_string($input)) {
@@ -44,8 +42,7 @@ 
     /**
      * {@inheritdoc}
      */
-    public function close()
-    {
+    public function close() {
         foreach ($this->pipes as $pipe) {
             fclose($pipe);
         }
@@ -67,8 +64,7 @@ 
     /**
      * Unblocks streams.
      */
-    protected function unblock()
-    {
+    protected function unblock() {
         if (!$this->blocked) {
             return;
         }
@@ -171,8 +167,7 @@ 
     /**
      * @internal
      */
-    public function handleError(int $type, string $msg)
-    {
+    public function handleError(int $type, string $msg) {
         $this->lastError = $msg;
     }
 }

vendor/symfony/process/Pipes/UnixPipes.php

Indentation +141 added lines, -141 removed lines

@@ -22,145 +22,145 @@
  */
 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);
-    }
-
-    /**
-     * @return array
-     */
-    public function __sleep()
-    {
-        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;
-    }
+	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);
+	}
+
+	/**
+	 * @return array
+	 */
+	public function __sleep()
+	{
+		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;
+	}
 }

Spacing +37 added lines, -37 removed lines

@@ -26,13 +26,13 @@ 
     private $ptyMode;
     private $haveReadSupport;
 
-    public function __construct(?bool $ttyMode, bool $ptyMode, $input, bool $haveReadSupport)
+    public function __construct( ?bool $ttyMode, bool $ptyMode, $input, bool $haveReadSupport )
     {
         $this->ttyMode = $ttyMode;
         $this->ptyMode = $ptyMode;
         $this->haveReadSupport = $haveReadSupport;
 
-        parent::__construct($input);
+        parent::__construct( $input );
     }
 
     /**
@@ -40,12 +40,12 @@ 
      */
     public function __sleep()
     {
-        throw new \BadMethodCallException('Cannot serialize '.__CLASS__);
+        throw new \BadMethodCallException( 'Cannot serialize ' . __CLASS__ );
     }
 
     public function __wakeup()
     {
-        throw new \BadMethodCallException('Cannot unserialize '.__CLASS__);
+        throw new \BadMethodCallException( 'Cannot unserialize ' . __CLASS__ );
     }
 
     public function __destruct()
@@ -58,36 +58,36 @@ 
      */
     public function getDescriptors(): array
     {
-        if (!$this->haveReadSupport) {
-            $nullstream = fopen('/dev/null', 'c');
+        if ( ! $this->haveReadSupport ) {
+            $nullstream = fopen( '/dev/null', 'c' );
 
             return [
-                ['pipe', 'r'],
+                [ 'pipe', 'r' ],
                 $nullstream,
                 $nullstream,
             ];
         }
 
-        if ($this->ttyMode) {
+        if ( $this->ttyMode ) {
             return [
-                ['file', '/dev/tty', 'r'],
-                ['file', '/dev/tty', 'w'],
-                ['file', '/dev/tty', 'w'],
+                [ 'file', '/dev/tty', 'r' ],
+                [ 'file', '/dev/tty', 'w' ],
+                [ 'file', '/dev/tty', 'w' ],
             ];
         }
 
-        if ($this->ptyMode && Process::isPtySupported()) {
+        if ( $this->ptyMode && Process::isPtySupported() ) {
             return [
-                ['pty'],
-                ['pty'],
-                ['pty'],
+                [ 'pty' ],
+                [ 'pty' ],
+                [ 'pty' ],
             ];
         }
 
         return [
-            ['pipe', 'r'],
-            ['pipe', 'w'], // stdout
-            ['pipe', 'w'], // stderr
+            [ 'pipe', 'r' ],
+            [ 'pipe', 'w' ], // stdout
+            [ 'pipe', 'w' ], // stderr
         ];
     }
 
@@ -96,52 +96,52 @@ 
      */
     public function getFiles(): array
     {
-        return [];
+        return [ ];
     }
 
     /**
      * {@inheritdoc}
      */
-    public function readAndWrite(bool $blocking, bool $close = false): array
+    public function readAndWrite( bool $blocking, bool $close = false ): array
     {
         $this->unblock();
         $w = $this->write();
 
-        $read = $e = [];
+        $read = $e = [ ];
         $r = $this->pipes;
-        unset($r[0]);
+        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)) {
+        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 = [];
+            if ( ! $this->hasSystemCallBeenInterrupted() ) {
+                $this->pipes = [ ];
             }
 
             return $read;
         }
         restore_error_handler();
 
-        foreach ($r as $pipe) {
+        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)] = '';
+            $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])));
+                $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 ( ! isset( $read[ $type ][ 0 ] ) ) {
+                unset( $read[ $type ] );
             }
 
-            if ($close && feof($pipe)) {
-                fclose($pipe);
-                unset($this->pipes[$type]);
+            if ( $close && feof( $pipe ) ) {
+                fclose( $pipe );
+                unset( $this->pipes[ $type ] );
             }
         }
 
@@ -161,6 +161,6 @@ 
      */
     public function areOpen(): bool
     {
-        return (bool) $this->pipes;
+        return (bool)$this->pipes;
     }
 }

Braces +5 added lines, -10 removed lines

@@ -20,14 +20,12 @@ 
  *
  * @internal
  */
-class UnixPipes extends AbstractPipes
-{
+class UnixPipes extends AbstractPipes {
     private $ttyMode;
     private $ptyMode;
     private $haveReadSupport;
 
-    public function __construct(?bool $ttyMode, bool $ptyMode, $input, bool $haveReadSupport)
-    {
+    public function __construct(?bool $ttyMode, bool $ptyMode, $input, bool $haveReadSupport) {
         $this->ttyMode = $ttyMode;
         $this->ptyMode = $ptyMode;
         $this->haveReadSupport = $haveReadSupport;
@@ -38,18 +36,15 @@ 
     /**
      * @return array
      */
-    public function __sleep()
-    {
+    public function __sleep() {
         throw new \BadMethodCallException('Cannot serialize '.__CLASS__);
     }
 
-    public function __wakeup()
-    {
+    public function __wakeup() {
         throw new \BadMethodCallException('Cannot unserialize '.__CLASS__);
     }
 
-    public function __destruct()
-    {
+    public function __destruct() {
         $this->close();
     }
 

vendor/symfony/process/Pipes/WindowsPipes.php

Indentation +178 added lines, -178 removed lines

@@ -26,182 +26,182 @@
  */
 class WindowsPipes extends AbstractPipes
 {
-    private $files = [];
-    private $fileHandles = [];
-    private $lockHandles = [];
-    private $readBytes = [
-        Process::STDOUT => 0,
-        Process::STDERR => 0,
-    ];
-    private $haveReadSupport;
-
-    public function __construct($input, bool $haveReadSupport)
-    {
-        $this->haveReadSupport = $haveReadSupport;
-
-        if ($this->haveReadSupport) {
-            // Fix for PHP bug #51800: reading from STDOUT pipe hangs forever on Windows if the output is too big.
-            // Workaround for this problem is to use temporary files instead of pipes on Windows platform.
-            //
-            // @see https://bugs.php.net/51800
-            $pipes = [
-                Process::STDOUT => Process::OUT,
-                Process::STDERR => Process::ERR,
-            ];
-            $tmpDir = sys_get_temp_dir();
-            $lastError = 'unknown reason';
-            set_error_handler(function ($type, $msg) use (&$lastError) { $lastError = $msg; });
-            for ($i = 0;; ++$i) {
-                foreach ($pipes as $pipe => $name) {
-                    $file = sprintf('%s\\sf_proc_%02X.%s', $tmpDir, $i, $name);
-
-                    if (!$h = fopen($file.'.lock', 'w')) {
-                        if (file_exists($file.'.lock')) {
-                            continue 2;
-                        }
-                        restore_error_handler();
-                        throw new RuntimeException('A temporary file could not be opened to write the process output: '.$lastError);
-                    }
-                    if (!flock($h, \LOCK_EX | \LOCK_NB)) {
-                        continue 2;
-                    }
-                    if (isset($this->lockHandles[$pipe])) {
-                        flock($this->lockHandles[$pipe], \LOCK_UN);
-                        fclose($this->lockHandles[$pipe]);
-                    }
-                    $this->lockHandles[$pipe] = $h;
-
-                    if (!($h = fopen($file, 'w')) || !fclose($h) || !$h = fopen($file, 'r')) {
-                        flock($this->lockHandles[$pipe], \LOCK_UN);
-                        fclose($this->lockHandles[$pipe]);
-                        unset($this->lockHandles[$pipe]);
-                        continue 2;
-                    }
-                    $this->fileHandles[$pipe] = $h;
-                    $this->files[$pipe] = $file;
-                }
-                break;
-            }
-            restore_error_handler();
-        }
-
-        parent::__construct($input);
-    }
-
-    /**
-     * @return array
-     */
-    public function __sleep()
-    {
-        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('NUL', 'c');
-
-            return [
-                ['pipe', 'r'],
-                $nullstream,
-                $nullstream,
-            ];
-        }
-
-        // We're not using pipe on Windows platform as it hangs (https://bugs.php.net/51800)
-        // We're not using file handles as it can produce corrupted output https://bugs.php.net/65650
-        // So we redirect output within the commandline and pass the nul device to the process
-        return [
-            ['pipe', 'r'],
-            ['file', 'NUL', 'w'],
-            ['file', 'NUL', 'w'],
-        ];
-    }
-
-    /**
-     * {@inheritdoc}
-     */
-    public function getFiles(): array
-    {
-        return $this->files;
-    }
-
-    /**
-     * {@inheritdoc}
-     */
-    public function readAndWrite(bool $blocking, bool $close = false): array
-    {
-        $this->unblock();
-        $w = $this->write();
-        $read = $r = $e = [];
-
-        if ($blocking) {
-            if ($w) {
-                @stream_select($r, $w, $e, 0, Process::TIMEOUT_PRECISION * 1E6);
-            } elseif ($this->fileHandles) {
-                usleep(Process::TIMEOUT_PRECISION * 1E6);
-            }
-        }
-        foreach ($this->fileHandles as $type => $fileHandle) {
-            $data = stream_get_contents($fileHandle, -1, $this->readBytes[$type]);
-
-            if (isset($data[0])) {
-                $this->readBytes[$type] += \strlen($data);
-                $read[$type] = $data;
-            }
-            if ($close) {
-                ftruncate($fileHandle, 0);
-                fclose($fileHandle);
-                flock($this->lockHandles[$type], \LOCK_UN);
-                fclose($this->lockHandles[$type]);
-                unset($this->fileHandles[$type], $this->lockHandles[$type]);
-            }
-        }
-
-        return $read;
-    }
-
-    /**
-     * {@inheritdoc}
-     */
-    public function haveReadSupport(): bool
-    {
-        return $this->haveReadSupport;
-    }
-
-    /**
-     * {@inheritdoc}
-     */
-    public function areOpen(): bool
-    {
-        return $this->pipes && $this->fileHandles;
-    }
-
-    /**
-     * {@inheritdoc}
-     */
-    public function close()
-    {
-        parent::close();
-        foreach ($this->fileHandles as $type => $handle) {
-            ftruncate($handle, 0);
-            fclose($handle);
-            flock($this->lockHandles[$type], \LOCK_UN);
-            fclose($this->lockHandles[$type]);
-        }
-        $this->fileHandles = $this->lockHandles = [];
-    }
+	private $files = [];
+	private $fileHandles = [];
+	private $lockHandles = [];
+	private $readBytes = [
+		Process::STDOUT => 0,
+		Process::STDERR => 0,
+	];
+	private $haveReadSupport;
+
+	public function __construct($input, bool $haveReadSupport)
+	{
+		$this->haveReadSupport = $haveReadSupport;
+
+		if ($this->haveReadSupport) {
+			// Fix for PHP bug #51800: reading from STDOUT pipe hangs forever on Windows if the output is too big.
+			// Workaround for this problem is to use temporary files instead of pipes on Windows platform.
+			//
+			// @see https://bugs.php.net/51800
+			$pipes = [
+				Process::STDOUT => Process::OUT,
+				Process::STDERR => Process::ERR,
+			];
+			$tmpDir = sys_get_temp_dir();
+			$lastError = 'unknown reason';
+			set_error_handler(function ($type, $msg) use (&$lastError) { $lastError = $msg; });
+			for ($i = 0;; ++$i) {
+				foreach ($pipes as $pipe => $name) {
+					$file = sprintf('%s\\sf_proc_%02X.%s', $tmpDir, $i, $name);
+
+					if (!$h = fopen($file.'.lock', 'w')) {
+						if (file_exists($file.'.lock')) {
+							continue 2;
+						}
+						restore_error_handler();
+						throw new RuntimeException('A temporary file could not be opened to write the process output: '.$lastError);
+					}
+					if (!flock($h, \LOCK_EX | \LOCK_NB)) {
+						continue 2;
+					}
+					if (isset($this->lockHandles[$pipe])) {
+						flock($this->lockHandles[$pipe], \LOCK_UN);
+						fclose($this->lockHandles[$pipe]);
+					}
+					$this->lockHandles[$pipe] = $h;
+
+					if (!($h = fopen($file, 'w')) || !fclose($h) || !$h = fopen($file, 'r')) {
+						flock($this->lockHandles[$pipe], \LOCK_UN);
+						fclose($this->lockHandles[$pipe]);
+						unset($this->lockHandles[$pipe]);
+						continue 2;
+					}
+					$this->fileHandles[$pipe] = $h;
+					$this->files[$pipe] = $file;
+				}
+				break;
+			}
+			restore_error_handler();
+		}
+
+		parent::__construct($input);
+	}
+
+	/**
+	 * @return array
+	 */
+	public function __sleep()
+	{
+		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('NUL', 'c');
+
+			return [
+				['pipe', 'r'],
+				$nullstream,
+				$nullstream,
+			];
+		}
+
+		// We're not using pipe on Windows platform as it hangs (https://bugs.php.net/51800)
+		// We're not using file handles as it can produce corrupted output https://bugs.php.net/65650
+		// So we redirect output within the commandline and pass the nul device to the process
+		return [
+			['pipe', 'r'],
+			['file', 'NUL', 'w'],
+			['file', 'NUL', 'w'],
+		];
+	}
+
+	/**
+	 * {@inheritdoc}
+	 */
+	public function getFiles(): array
+	{
+		return $this->files;
+	}
+
+	/**
+	 * {@inheritdoc}
+	 */
+	public function readAndWrite(bool $blocking, bool $close = false): array
+	{
+		$this->unblock();
+		$w = $this->write();
+		$read = $r = $e = [];
+
+		if ($blocking) {
+			if ($w) {
+				@stream_select($r, $w, $e, 0, Process::TIMEOUT_PRECISION * 1E6);
+			} elseif ($this->fileHandles) {
+				usleep(Process::TIMEOUT_PRECISION * 1E6);
+			}
+		}
+		foreach ($this->fileHandles as $type => $fileHandle) {
+			$data = stream_get_contents($fileHandle, -1, $this->readBytes[$type]);
+
+			if (isset($data[0])) {
+				$this->readBytes[$type] += \strlen($data);
+				$read[$type] = $data;
+			}
+			if ($close) {
+				ftruncate($fileHandle, 0);
+				fclose($fileHandle);
+				flock($this->lockHandles[$type], \LOCK_UN);
+				fclose($this->lockHandles[$type]);
+				unset($this->fileHandles[$type], $this->lockHandles[$type]);
+			}
+		}
+
+		return $read;
+	}
+
+	/**
+	 * {@inheritdoc}
+	 */
+	public function haveReadSupport(): bool
+	{
+		return $this->haveReadSupport;
+	}
+
+	/**
+	 * {@inheritdoc}
+	 */
+	public function areOpen(): bool
+	{
+		return $this->pipes && $this->fileHandles;
+	}
+
+	/**
+	 * {@inheritdoc}
+	 */
+	public function close()
+	{
+		parent::close();
+		foreach ($this->fileHandles as $type => $handle) {
+			ftruncate($handle, 0);
+			fclose($handle);
+			flock($this->lockHandles[$type], \LOCK_UN);
+			fclose($this->lockHandles[$type]);
+		}
+		$this->fileHandles = $this->lockHandles = [];
+	}
 }

Spacing +56 added lines, -56 removed lines

@@ -26,20 +26,20 @@ 
  */
 class WindowsPipes extends AbstractPipes
 {
-    private $files = [];
-    private $fileHandles = [];
-    private $lockHandles = [];
+    private $files = [ ];
+    private $fileHandles = [ ];
+    private $lockHandles = [ ];
     private $readBytes = [
         Process::STDOUT => 0,
         Process::STDERR => 0,
     ];
     private $haveReadSupport;
 
-    public function __construct($input, bool $haveReadSupport)
+    public function __construct( $input, bool $haveReadSupport )
     {
         $this->haveReadSupport = $haveReadSupport;
 
-        if ($this->haveReadSupport) {
+        if ( $this->haveReadSupport ) {
             // Fix for PHP bug #51800: reading from STDOUT pipe hangs forever on Windows if the output is too big.
             // Workaround for this problem is to use temporary files instead of pipes on Windows platform.
             //
@@ -50,42 +50,42 @@ 
             ];
             $tmpDir = sys_get_temp_dir();
             $lastError = 'unknown reason';
-            set_error_handler(function ($type, $msg) use (&$lastError) { $lastError = $msg; });
-            for ($i = 0;; ++$i) {
-                foreach ($pipes as $pipe => $name) {
-                    $file = sprintf('%s\\sf_proc_%02X.%s', $tmpDir, $i, $name);
+            set_error_handler( function( $type, $msg ) use ( &$lastError ) { $lastError = $msg; });
+            for ( $i = 0; ; ++$i ) {
+                foreach ( $pipes as $pipe => $name ) {
+                    $file = sprintf( '%s\\sf_proc_%02X.%s', $tmpDir, $i, $name );
 
-                    if (!$h = fopen($file.'.lock', 'w')) {
-                        if (file_exists($file.'.lock')) {
+                    if ( ! $h = fopen( $file . '.lock', 'w' ) ) {
+                        if ( file_exists( $file . '.lock' ) ) {
                             continue 2;
                         }
                         restore_error_handler();
-                        throw new RuntimeException('A temporary file could not be opened to write the process output: '.$lastError);
+                        throw new RuntimeException( 'A temporary file could not be opened to write the process output: ' . $lastError );
                     }
-                    if (!flock($h, \LOCK_EX | \LOCK_NB)) {
+                    if ( ! flock( $h, \LOCK_EX | \LOCK_NB ) ) {
                         continue 2;
                     }
-                    if (isset($this->lockHandles[$pipe])) {
-                        flock($this->lockHandles[$pipe], \LOCK_UN);
-                        fclose($this->lockHandles[$pipe]);
+                    if ( isset( $this->lockHandles[ $pipe ] ) ) {
+                        flock( $this->lockHandles[ $pipe ], \LOCK_UN );
+                        fclose( $this->lockHandles[ $pipe ] );
                     }
-                    $this->lockHandles[$pipe] = $h;
+                    $this->lockHandles[ $pipe ] = $h;
 
-                    if (!($h = fopen($file, 'w')) || !fclose($h) || !$h = fopen($file, 'r')) {
-                        flock($this->lockHandles[$pipe], \LOCK_UN);
-                        fclose($this->lockHandles[$pipe]);
-                        unset($this->lockHandles[$pipe]);
+                    if ( ! ( $h = fopen( $file, 'w' ) ) || ! fclose( $h ) || ! $h = fopen( $file, 'r' ) ) {
+                        flock( $this->lockHandles[ $pipe ], \LOCK_UN );
+                        fclose( $this->lockHandles[ $pipe ] );
+                        unset( $this->lockHandles[ $pipe ] );
                         continue 2;
                     }
-                    $this->fileHandles[$pipe] = $h;
-                    $this->files[$pipe] = $file;
+                    $this->fileHandles[ $pipe ] = $h;
+                    $this->files[ $pipe ] = $file;
                 }
                 break;
             }
             restore_error_handler();
         }
 
-        parent::__construct($input);
+        parent::__construct( $input );
     }
 
     /**
@@ -93,12 +93,12 @@ 
      */
     public function __sleep()
     {
-        throw new \BadMethodCallException('Cannot serialize '.__CLASS__);
+        throw new \BadMethodCallException( 'Cannot serialize ' . __CLASS__ );
     }
 
     public function __wakeup()
     {
-        throw new \BadMethodCallException('Cannot unserialize '.__CLASS__);
+        throw new \BadMethodCallException( 'Cannot unserialize ' . __CLASS__ );
     }
 
     public function __destruct()
@@ -111,11 +111,11 @@ 
      */
     public function getDescriptors(): array
     {
-        if (!$this->haveReadSupport) {
-            $nullstream = fopen('NUL', 'c');
+        if ( ! $this->haveReadSupport ) {
+            $nullstream = fopen( 'NUL', 'c' );
 
             return [
-                ['pipe', 'r'],
+                [ 'pipe', 'r' ],
                 $nullstream,
                 $nullstream,
             ];
@@ -125,9 +125,9 @@ 
         // We're not using file handles as it can produce corrupted output https://bugs.php.net/65650
         // So we redirect output within the commandline and pass the nul device to the process
         return [
-            ['pipe', 'r'],
-            ['file', 'NUL', 'w'],
-            ['file', 'NUL', 'w'],
+            [ 'pipe', 'r' ],
+            [ 'file', 'NUL', 'w' ],
+            [ 'file', 'NUL', 'w' ],
         ];
     }
 
@@ -142,32 +142,32 @@ 
     /**
      * {@inheritdoc}
      */
-    public function readAndWrite(bool $blocking, bool $close = false): array
+    public function readAndWrite( bool $blocking, bool $close = false ): array
     {
         $this->unblock();
         $w = $this->write();
-        $read = $r = $e = [];
+        $read = $r = $e = [ ];
 
-        if ($blocking) {
-            if ($w) {
-                @stream_select($r, $w, $e, 0, Process::TIMEOUT_PRECISION * 1E6);
-            } elseif ($this->fileHandles) {
-                usleep(Process::TIMEOUT_PRECISION * 1E6);
+        if ( $blocking ) {
+            if ( $w ) {
+                @stream_select( $r, $w, $e, 0, Process::TIMEOUT_PRECISION * 1E6 );
+            } elseif ( $this->fileHandles ) {
+                usleep( Process::TIMEOUT_PRECISION * 1E6 );
             }
         }
-        foreach ($this->fileHandles as $type => $fileHandle) {
-            $data = stream_get_contents($fileHandle, -1, $this->readBytes[$type]);
+        foreach ( $this->fileHandles as $type => $fileHandle ) {
+            $data = stream_get_contents( $fileHandle, -1, $this->readBytes[ $type ] );
 
-            if (isset($data[0])) {
-                $this->readBytes[$type] += \strlen($data);
-                $read[$type] = $data;
+            if ( isset( $data[ 0 ] ) ) {
+                $this->readBytes[ $type ] += \strlen( $data );
+                $read[ $type ] = $data;
             }
-            if ($close) {
-                ftruncate($fileHandle, 0);
-                fclose($fileHandle);
-                flock($this->lockHandles[$type], \LOCK_UN);
-                fclose($this->lockHandles[$type]);
-                unset($this->fileHandles[$type], $this->lockHandles[$type]);
+            if ( $close ) {
+                ftruncate( $fileHandle, 0 );
+                fclose( $fileHandle );
+                flock( $this->lockHandles[ $type ], \LOCK_UN );
+                fclose( $this->lockHandles[ $type ] );
+                unset( $this->fileHandles[ $type ], $this->lockHandles[ $type ] );
             }
         }
 
@@ -196,12 +196,12 @@ 
     public function close()
     {
         parent::close();
-        foreach ($this->fileHandles as $type => $handle) {
-            ftruncate($handle, 0);
-            fclose($handle);
-            flock($this->lockHandles[$type], \LOCK_UN);
-            fclose($this->lockHandles[$type]);
+        foreach ( $this->fileHandles as $type => $handle ) {
+            ftruncate( $handle, 0 );
+            fclose( $handle );
+            flock( $this->lockHandles[ $type ], \LOCK_UN );
+            fclose( $this->lockHandles[ $type ] );
         }
-        $this->fileHandles = $this->lockHandles = [];
+        $this->fileHandles = $this->lockHandles = [ ];
     }
 }

Braces +6 added lines, -12 removed lines

@@ -24,8 +24,7 @@ 
  *
  * @internal
  */
-class WindowsPipes extends AbstractPipes
-{
+class WindowsPipes extends AbstractPipes {
     private $files = [];
     private $fileHandles = [];
     private $lockHandles = [];
@@ -35,8 +34,7 @@ 
     ];
     private $haveReadSupport;
 
-    public function __construct($input, bool $haveReadSupport)
-    {
+    public function __construct($input, bool $haveReadSupport) {
         $this->haveReadSupport = $haveReadSupport;
 
         if ($this->haveReadSupport) {
@@ -91,18 +89,15 @@ 
     /**
      * @return array
      */
-    public function __sleep()
-    {
+    public function __sleep() {
         throw new \BadMethodCallException('Cannot serialize '.__CLASS__);
     }
 
-    public function __wakeup()
-    {
+    public function __wakeup() {
         throw new \BadMethodCallException('Cannot unserialize '.__CLASS__);
     }
 
-    public function __destruct()
-    {
+    public function __destruct() {
         $this->close();
     }
 
@@ -193,8 +188,7 @@ 
     /**
      * {@inheritdoc}
      */
-    public function close()
-    {
+    public function close() {
         parent::close();
         foreach ($this->fileHandles as $type => $handle) {
             ftruncate($handle, 0);