Add retry connection.

Author: Moln

.gitattributes

@@ -0,0 +1,8 @@
+/.coveralls.yml export-ignore
+/.gitattributes export-ignore
+/.github/ export-ignore
+/.gitignore export-ignore
+/.travis.yml export-ignore
+/.travis/ export-ignore
+/phpunit.xml export-ignore
+/tests/ export-ignore

src/MySQLReplication/BinLog/BinLogServerInfo.php

@@ -17,6 +17,7 @@ public static function parsePackage(string $data, string $version): BinLogServer
     {
         $i = 0;
         $length = strlen($data);
+        $serverInfo = [];
         $serverInfo['protocol_version'] = ord($data[$i]);
         ++$i;
 

src/MySQLReplication/MySQLReplicationFactory.php

@@ -163,7 +163,9 @@ public function run(): void
                     }
                 } catch (\Throwable $e) {
                     $this->logger->warning("[MysqlReplication] Connect error:" . $e->getMessage(), ['exception' => $e]);
-                    $this->socket->close();
+                    if (method_exists($this->socket, 'close')) {
+                        $this->socket->close();
+                    }
                     sleep(1);
                     continue;
                 }
@@ -175,7 +177,10 @@ public function run(): void
                 }
             } catch (SocketException $e) {
                 $this->logger->warning("[MysqlReplication] Connection lost: " . $e->getMessage(), ['exception' => $e]);
-                $this->socket->close();
+
+                if (method_exists($this->socket, 'close')) {
+                    $this->socket->close();
+                }
             }
         }
     }

src/MySQLReplication/Socket/Socket.php

@@ -12,7 +12,7 @@ public function __destruct()
         $this->close();
     }
 
-    public function close()
+    public function close(): void
     {
         if ($this->isConnected()) {
             socket_shutdown($this->socket);