PHPFastCGI / FastCGIDaemon

src/Driver/Userland/UserlandDaemonFactory.php

Spacing +1 added lines, -1 removed lines

@@ -31,7 +31,7 @@
         $socket = fopen('php://fd/'.$fd, 'r');
 
         if (false === $socket) {
-            throw new \RuntimeException('Could not open ' . $fd);
+            throw new \RuntimeException('Could not open '.$fd);
         }
 
         return $this->createDaemonFromStreamSocket($kernel, $options, $socket);

src/Command/DaemonRunCommand.php

Spacing +10 added lines, -10 removed lines

@@ -46,21 +46,21 @@ 
         $this->driverContainer = $driverContainer;
         $this->daemon          = null;
 
-        $name        = $name        ?: self::DEFAULT_NAME;
+        $name        = $name ?: self::DEFAULT_NAME;
         $description = $description ?: self::DEFAULT_DESCRIPTION;
 
         parent::__construct($name);
 
         $this
             ->setDescription($description)
-            ->addOption('port',          null, InputOption::VALUE_OPTIONAL, 'TCP port to listen on (if not present, daemon will listen on FCGI_LISTENSOCK_FILENO)')
-            ->addOption('host',          null, InputOption::VALUE_OPTIONAL, 'TCP host to listen on')
-            ->addOption('fd',            null, InputOption::VALUE_OPTIONAL, 'File descriptor to listen on - defaults to FCGI_LISTENSOCK_FILENO', DaemonInterface::FCGI_LISTENSOCK_FILENO)
+            ->addOption('port', null, InputOption::VALUE_OPTIONAL, 'TCP port to listen on (if not present, daemon will listen on FCGI_LISTENSOCK_FILENO)')
+            ->addOption('host', null, InputOption::VALUE_OPTIONAL, 'TCP host to listen on')
+            ->addOption('fd', null, InputOption::VALUE_OPTIONAL, 'File descriptor to listen on - defaults to FCGI_LISTENSOCK_FILENO', DaemonInterface::FCGI_LISTENSOCK_FILENO)
             ->addOption('request-limit', null, InputOption::VALUE_OPTIONAL, 'The maximum number of requests to handle before shutting down')
-            ->addOption('memory-limit',  null, InputOption::VALUE_OPTIONAL, 'The memory limit on the daemon instance before shutting down')
-            ->addOption('time-limit',    null, InputOption::VALUE_OPTIONAL, 'The time limit on the daemon in seconds before shutting down')
-            ->addOption('auto-shutdown', null, InputOption::VALUE_NONE,     'Perform a graceful shutdown after receiving a 5XX HTTP status code')
-            ->addOption('driver',        null, InputOption::VALUE_OPTIONAL, 'The implementation of the FastCGI protocol to use', 'userland');
+            ->addOption('memory-limit', null, InputOption::VALUE_OPTIONAL, 'The memory limit on the daemon instance before shutting down')
+            ->addOption('time-limit', null, InputOption::VALUE_OPTIONAL, 'The time limit on the daemon in seconds before shutting down')
+            ->addOption('auto-shutdown', null, InputOption::VALUE_NONE, 'Perform a graceful shutdown after receiving a 5XX HTTP status code')
+            ->addOption('driver', null, InputOption::VALUE_OPTIONAL, 'The implementation of the FastCGI protocol to use', 'userland');
     }
 
     /**
@@ -77,8 +77,8 @@ 
         $logger = new ConsoleLogger($output);
 
         $requestLimit = $input->getOption('request-limit') ?: DaemonOptions::NO_LIMIT;
-        $memoryLimit  = $input->getOption('memory-limit')  ?: DaemonOptions::NO_LIMIT;
-        $timeLimit    = $input->getOption('time-limit')    ?: DaemonOptions::NO_LIMIT;
+        $memoryLimit  = $input->getOption('memory-limit') ?: DaemonOptions::NO_LIMIT;
+        $timeLimit    = $input->getOption('time-limit') ?: DaemonOptions::NO_LIMIT;
         $autoShutdown = $input->getOption('auto-shutdown');
 
         return new DaemonOptions([

src/Driver/Userland/Connection/StreamSocketConnectionPool.php

Spacing +1 added lines, -1 removed lines

@@ -135,7 +135,7 @@
             $readSockets = [];
         } else {
             $res = [];
-            foreach($read as $socket) {
+            foreach ($read as $socket) {
                 $res[array_search($socket, $readSockets)] = $socket;
             }
             $readSockets = $res;

src/Http/Request.php

Spacing +4 added lines, -4 removed lines

@@ -51,7 +51,7 @@ 
             $this->params[strtoupper($name)] = $value;
         }
 
-        $this->stdin  = $stdin;
+        $this->stdin = $stdin;
 
         rewind($this->stdin);
     }
@@ -150,7 +150,7 @@ 
 
         while (!feof($stream)) {
             $getContent = $fieldName && !$inHeader;
-            $buffer = stream_get_line($stream, static::$bufferSize,  "\n" . ($getContent ? '--'.$boundary : ''));
+            $buffer = stream_get_line($stream, static::$bufferSize, "\n".($getContent ? '--'.$boundary : ''));
             $buffer = trim($buffer, "\r");
 
             // Find the empty line between headers and body
@@ -162,7 +162,7 @@ 
 
             if ($getContent) {
                 if ($fieldType === 'data') {
-                    $post .= (isset($post[0]) ? '&' : '') . $fieldName . "=" . urlencode($buffer);
+                    $post .= (isset($post[0]) ? '&' : '').$fieldName."=".urlencode($buffer);
                 } elseif ($fieldType === 'file' && $filename) {
                     $tmpPath = @tempnam($this->getUploadDir(), 'fastcgi_upload');
                     $err = file_put_contents($tmpPath, $buffer);
@@ -295,7 +295,7 @@ 
                 }
 
                 $trimmedMatch = trim($part, '[]');
-                if ($i === $count -1) {
+                if ($i === $count - 1) {
                     $current[$trimmedMatch] = $data;
                 } else {
                     $current = &$current[$trimmedMatch];

Doc Comments +3 added lines

@@ -153,6 +153,9 @@
         return $post ?: [];
     }
 
+    /**
+     * @param resource $stream
+     */
     private function parseMultipartFormData($stream, string $boundary): array {
         $post = "";
         $files = [];

src/DaemonTrait.php

Spacing +4 added lines, -4 removed lines

@@ -83,7 +83,7 @@ 
         if ($this->autoShutdown) {
             foreach ($statusCodes as $statusCode) {
                 if ($statusCode >= 500 && $statusCode < 600) {
-                    $this->flagShutdown('Automatic shutdown following status code: ' . $statusCode);
+                    $this->flagShutdown('Automatic shutdown following status code: '.$statusCode);
                     break;
                 }
             }
@@ -98,13 +98,13 @@ 
      */
     private function installSignalHandlers(): void
     {
-        declare (ticks = 1);
+        declare(ticks=1);
 
-        pcntl_signal(SIGINT, function () {
+        pcntl_signal(SIGINT, function() {
             throw new ShutdownException('Daemon shutdown requested (received SIGINT)');
         });
 
-        pcntl_signal(SIGALRM, function () {
+        pcntl_signal(SIGALRM, function() {
             throw new ShutdownException('Daemon time limit reached (received SIGALRM)');
         });
     }