Improve error messages when accepting connections with errno/errstr

Author: clue

src/TcpServer.php

@@ -213,7 +213,28 @@ public function resume()
         $this->loop->addReadStream($this->master, function ($master) use ($that) {
             $newSocket = @\stream_socket_accept($master, 0);
             if (false === $newSocket) {
-                $that->emit('error', array(new \RuntimeException('Error accepting new connection')));
+                // Match errstr from PHP's warning message.
+                // stream_socket_accept(): accept failed: Connection timed out
+                $error = \error_get_last();
+                $errstr = \preg_replace('#.*: #', '', $error['message']);
+
+                // Go through list of possible error constants to find matching errno.
+                // @codeCoverageIgnoreStart
+                $errno = 0;
+                if (\function_exists('socket_strerror')) {
+                    foreach (\get_defined_constants(false) as $name => $value) {
+                        if (\strpos($name, 'SOCKET_E') === 0 && \socket_strerror($value) === $errstr) {
+                            $errno = $value;
+                            break;
+                        }
+                    }
+                }
+                // @codeCoverageIgnoreEnd
+
+                $that->emit('error', array(new \RuntimeException(
+                    'Unable to accept new connection: ' . $errstr,
+                    $errno
+                )));
 
                 return;
             }

tests/TcpServerTest.php

@@ -287,7 +287,10 @@ public function testEmitsErrorWhenAcceptListenerFails()
 
         $server = new TcpServer(0, $loop);
 
-        $server->on('error', $this->expectCallableOnceWith($this->isInstanceOf('RuntimeException')));
+        $exception = null;
+        $server->on('error', function ($e) use (&$exception) {
+            $exception = $e;
+        });
 
         $this->assertNotNull($listener);
         $socket = stream_socket_server('tcp://127.0.0.1:0');
@@ -297,6 +300,23 @@ public function testEmitsErrorWhenAcceptListenerFails()
         $time = microtime(true) - $time;
 
         $this->assertLessThan(1, $time);
+
+        $this->assertInstanceOf('RuntimeException', $exception);
+        assert($exception instanceof \RuntimeException);
+        $this->assertStringStartsWith('Unable to accept new connection: ', $exception->getMessage());
+
+        return $exception;
+    }
+
+    /**
+     * @param \RuntimeException $e
+     * @requires extension sockets
+     * @depends testEmitsErrorWhenAcceptListenerFails
+     */
+    public function testEmitsTimeoutErrorWhenAcceptListenerFails(\RuntimeException $exception)
+    {
+        $this->assertEquals('Unable to accept new connection: ' . socket_strerror(SOCKET_ETIMEDOUT), $exception->getMessage());
+        $this->assertEquals(SOCKET_ETIMEDOUT, $exception->getCode());
     }
 
     public function testListenOnBusyPortThrows()