Add failing tests to reproduce the issue, #40

tests/Integration/AsyncRequestsTest.php

@@ -0,0 +1,143 @@
+<?php declare(strict_types=1);
+
+namespace hollodotme\FastCGI\Tests\Integration;
+
+use hollodotme\FastCGI\Client;
+use hollodotme\FastCGI\Exceptions\ConnectException;
+use hollodotme\FastCGI\Exceptions\ReadFailedException;
+use hollodotme\FastCGI\Exceptions\TimedoutException;
+use hollodotme\FastCGI\Exceptions\WriteFailedException;
+use hollodotme\FastCGI\Interfaces\ProvidesResponseData;
+use hollodotme\FastCGI\Requests\PostRequest;
+use hollodotme\FastCGI\SocketConnections\NetworkSocket;
+use hollodotme\FastCGI\SocketConnections\UnixDomainSocket;
+use hollodotme\FastCGI\Tests\Traits\SocketDataProviding;
+use PHPUnit\Framework\ExpectationFailedException;
+use PHPUnit\Framework\TestCase;
+use SebastianBergmann\RecursionContext\InvalidArgumentException;
+use Throwable;
+use function http_build_query;
+use function parse_ini_file;
+use function range;
+
+final class AsyncRequestsTest extends TestCase
+{
+	use SocketDataProviding;
+
+	/**
+	 * @throws ExpectationFailedException
+	 * @throws InvalidArgumentException
+	 * @throws Throwable
+	 * @throws ConnectException
+	 * @throws ReadFailedException
+	 * @throws TimedoutException
+	 * @throws WriteFailedException
+	 */
+	public function testAsyncRequestsWillRespondIfRequestsExceedPhpFpmMaxChildrenSettingOnNetworkSocket() : void
+	{
+		$maxChildren = $this->getMaxChildrenSettingFromNetworkSocket();
+		$limit       = $maxChildren + 5;
+
+		$this->assertTrue( $limit > 5 );
+
+		$client          = $this->getClientWithNetworkSocket();
+		$results         = [];
+		$expectedResults = range( 0, $limit - 1 );
+
+		$request = new PostRequest( __DIR__ . '/Workers/worker.php', '' );
+		$request->addResponseCallbacks(
+			static function ( ProvidesResponseData $response ) use ( &$results )
+			{
+				$results[] = $response->getBody();
+			}
+		);
+
+		for ( $i = 0; $i < $limit; $i++ )
+		{
+			$request->setContent( http_build_query( ['test-key' => $i] ) );
+
+			$client->sendAsyncRequest( $request );
+		}
+
+		$client->waitForResponses();
+
+		$this->assertEquals( $expectedResults, $results );
+	}
+
+	private function getMaxChildrenSettingFromNetworkSocket() : int
+	{
+		$iniSettings = parse_ini_file(
+			__DIR__ . '/../../.docker/php/network-socket.pool.conf',
+			true
+		);
+
+		return (int)$iniSettings['network']['pm.max_children'];
+	}
+
+	private function getClientWithNetworkSocket() : Client
+	{
+		$networkSocket = new NetworkSocket(
+			$this->getNetworkSocketHost(),
+			$this->getNetworkSocketPort()
+		);
+
+		return new Client( $networkSocket );
+	}
+
+	/**
+	 * @throws ConnectException
+	 * @throws ExpectationFailedException
+	 * @throws InvalidArgumentException
+	 * @throws ReadFailedException
+	 * @throws Throwable
+	 * @throws TimedoutException
+	 * @throws WriteFailedException
+	 */
+	public function testAsyncRequestsWillRespondIfRequestsExceedPhpFpmMaxChildrenSettingOnUnixDomainSocket() : void
+	{
+		$maxChildren = $this->getMaxChildrenSettingFromUnixDomainSocket();
+		$limit       = $maxChildren + 5;
+
+		$this->assertTrue( $limit > 5 );
+
+		$client          = $this->getClientWithUnixDomainSocket();
+		$results         = [];
+		$expectedResults = range( 0, $limit - 1 );
+
+		$request = new PostRequest( __DIR__ . '/Workers/worker.php', '' );
+		$request->addResponseCallbacks(
+			static function ( ProvidesResponseData $response ) use ( &$results )
+			{
+				$results[] = $response->getBody();
+			}
+		);
+
+		for ( $i = 0; $i < $limit; $i++ )
+		{
+			$request->setContent( http_build_query( ['test-key' => $i] ) );
+
+			$client->sendAsyncRequest( $request );
+		}
+
+		$client->waitForResponses();
+
+		$this->assertEquals( $expectedResults, $results );
+	}
+
+	private function getMaxChildrenSettingFromUnixDomainSocket() : int
+	{
+		$iniSettings = parse_ini_file(
+			__DIR__ . '/../../.docker/php/unix-domain-socket.pool.conf',
+			true
+		);
+
+		return (int)$iniSettings['uds']['pm.max_children'];
+	}
+
+	private function getClientWithUnixDomainSocket() : Client
+	{
+		$unixDomainSocket = new UnixDomainSocket( $this->getUnixDomainSocket() );
+
+		return new Client( $unixDomainSocket );
+	}
+}