close the socket when the connection is disconnected.

tmtm · Dec 12, 2021 · 68c0710 · 68c0710
1 parent 95160b3
commit 68c0710
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/lib/mysql/protocol.rb b/lib/mysql/protocol.rb
@@ -460,6 +460,7 @@ def read
         raise EOFError unless ret && ret.length == len
         data.concat ret
       rescue EOFError
+        @socket.close rescue nil
         raise ClientError::ServerGoneError, 'MySQL server has gone away'
       rescue Errno::ETIMEDOUT
         raise ClientError, "read timeout"
@@ -524,6 +525,7 @@ def write(data)
         @socket.sync = true
         @socket.flush
       rescue Errno::EPIPE
+        @socket.close rescue nil
         raise ClientError::ServerGoneError, 'MySQL server has gone away'
       rescue Errno::ETIMEDOUT
         raise ClientError, "write timeout"