Added cheks to avoid socket* calls to boolean

Author: allflame

composer.json

@@ -8,6 +8,7 @@
   },
   "require": {
     "php": ">=7.1",
+    "ext-sockets": "*",
     "apache/thrift": "0.11.*",
     "psr/log": "^1.0.2"
   },

src/Transport/TUDPTransport.php

@@ -29,16 +29,15 @@ public function isOpen(): bool
         return true;
     }
 
-    public function open()
+    public function open(): void
     {
     }
 
-    public function close()
+    public function close(): void
     {
         if (null === $this->socket) {
             return;
         }
-
         \socket_close($this->socket);
         $this->socket = null;
     }
@@ -48,28 +47,29 @@ public function read($len): string
         return '';
     }
 
-    public function write($buf)
+    public function write($buf): void
     {
         $this->buffer .= $buf;
     }
 
-    public function flush()
+    public function flush(): void
     {
+        parent::flush();
         if ('' === $this->buffer) {
             return;
         }
-
         $this->doWrite($this->buffer);
         $this->buffer = '';
     }
 
-    private function doWrite($buf)
+    private function doWrite($buf): void
     {
-        $socket = $this->getConnectedSocket();
-
+        if (null === ($socket = $this->connect())) {
+            return;
+        }
         $length = \strlen($buf);
         while (true) {
-            if (false === $result = @\socket_write($socket, $buf)) {
+            if (false === ($result = @\socket_write($socket, $buf))) {
                 break;
             }
             if ($result >= $length) {
@@ -80,16 +80,19 @@ private function doWrite($buf)
         }
     }
 
-    private function getConnectedSocket()
+    private function connect()
     {
-        if (null === $this->socket) {
-            if (false !== $socket = \socket_create(AF_INET, SOCK_DGRAM, SOL_UDP)) {
+        $count = 0;
+        while (false === \is_resource($this->socket) && $count < 5) {
+            if (false !== ($socket = \socket_create(AF_INET, SOCK_DGRAM, SOL_UDP))) {
                 @\socket_connect($socket, $this->host, $this->port);
+                $this->socket = $socket;
+                break;
             }
-
-            $this->socket = $socket;
+            $count++;
+            usleep(10);
         }
 
-        return $this->socket;
+        return $this->socket ?: null;
     }
 }