Making use of the LimitConcurrentRequestsMiddleware by allowing half of the memory to be used by RequestBodyBufferMiddleware for buffering and the other half to be used for request parsing and handling

Author: WyriHaximus

src/Server.php

@@ -2,6 +2,7 @@
 
 namespace React\Http;
 
+use React\Http\Middleware\LimitConcurrentRequestsMiddleware;
 use React\Http\Middleware\RequestBodyBufferMiddleware;
 use React\Http\Middleware\RequestBodyParserMiddleware;
 use React\Socket\ServerInterface;
@@ -40,7 +41,10 @@ public function __construct($callback)
             throw new \InvalidArgumentException();
         }
 
+        $concurrentRequestsLimit = ceil(($this->iniLimit('memory_limit') / 2) / $this->iniLimit('post_max_size'));
+
         $this->streamingServer = new StreamingServer(new MiddlewareRunner(array(
+            new LimitConcurrentRequestsMiddleware($concurrentRequestsLimit),
             new RequestBodyBufferMiddleware(),
             new RequestBodyParserMiddleware(),
             $callback,
@@ -54,4 +58,24 @@ public function listen(ServerInterface $server)
     {
         $this->streamingServer->listen($server);
     }
+
+    private function iniLimit($iniSetting)
+    {
+        $size = ini_get($iniSetting);
+        $suffix = strtoupper(substr($size, -1));
+        if ($suffix === 'K') {
+            return substr($size, 0, -1) * 1024;
+        }
+        if ($suffix === 'M') {
+            return substr($size, 0, -1) * 1024 * 1024;
+        }
+        if ($suffix === 'G') {
+            return substr($size, 0, -1) * 1024 * 1024 * 1024;
+        }
+        if ($suffix === 'T') {
+            return substr($size, 0, -1) * 1024  * 1024 * 1024 * 1024;
+        }
+
+        return $size;
+    }
 }