Improve error reporting

Author: clue

src/Factory.php

@@ -5,6 +5,7 @@
 use React\EventLoop\LoopInterface;
 use React\Datagram\Socket as DatagramSocket;
 use BadMethodCallException;
+use RuntimeException;
 
 class Factory
 {
@@ -19,7 +20,10 @@ public function __construct(LoopInterface $loop)
 
     public function createSender()
     {
-        $stream = stream_socket_server('udp://0.0.0.0:0', $errno, $errstr, STREAM_SERVER_BIND);
+        $stream = @stream_socket_server('udp://0.0.0.0:0', $errno, $errstr, STREAM_SERVER_BIND);
+        if ($stream === false) {
+            throw new RuntimeException('Unable to create sending socket: ' . $errstr, $errno);
+        }
 
         return new DatagramSocket($this->loop, $stream);
     }
@@ -32,20 +36,32 @@ public function createReceiver($address)
 
         $parts = parse_url('udp://' . $address);
 
-        $stream = stream_socket_server('udp://0.0.0.0:' . $parts['port'], $errno, $errstr, STREAM_SERVER_BIND);
+        $stream = @stream_socket_server('udp://0.0.0.0:' . $parts['port'], $errno, $errstr, STREAM_SERVER_BIND);
+        if ($stream === false) {
+            throw new RuntimeException('Unable to create receiving socket: ' . $errstr, $errno);
+        }
 
         $socket = socket_import_stream($stream);
+        if ($stream === false) {
+            throw new RuntimeException('Unable to access underlying socket resource');
+        }
 
         // allow multiple processes to bind to the same address
-        socket_set_option($socket, SOL_SOCKET, SO_REUSEADDR, 1);
+        $ret = socket_set_option($socket, SOL_SOCKET, SO_REUSEADDR, 1);
+        if ($ret === false) {
+            throw new RuntimeException('Unable to enable SO_REUSEADDR');
+        }
 
         // join multicast group and bind to port
-        socket_set_option(
+        $ret = socket_set_option(
             $socket,
             IPPROTO_IP,
             MCAST_JOIN_GROUP,
             array('group' => $parts['host'], 'interface' => 0)
         );
+        if ($ret === false) {
+            throw new RuntimeException('Unable to join multicast group');
+        }
 
         return new DatagramSocket($this->loop, $stream);
     }