Handle interrupts: Socket.connect is interruptible in a virtual thread (#1203)

JAVA-5138

Author: stIncMale

driver-core/src/main/com/mongodb/internal/connection/SocketStream.java

@@ -45,6 +45,7 @@
 import static com.mongodb.assertions.Assertions.notNull;
 import static com.mongodb.internal.connection.SocketStreamHelper.configureSocket;
 import static com.mongodb.internal.connection.SslHelper.configureSslSocket;
+import static com.mongodb.internal.thread.InterruptionUtil.translateInterruptedException;
 import static java.util.concurrent.TimeUnit.MILLISECONDS;
 
 /**
@@ -79,7 +80,8 @@ public void open() {
             inputStream = socket.getInputStream();
         } catch (IOException e) {
             close();
-            throw new MongoSocketOpenException("Exception opening socket", getAddress(), e);
+            throw translateInterruptedException(e, "Interrupted while connecting")
+                    .orElseThrow(() -> new MongoSocketOpenException("Exception opening socket", getAddress(), e));
         }
     }
 
@@ -240,7 +242,7 @@ public void close() {
             if (socket != null) {
                 socket.close();
             }
-        } catch (IOException e) {
+        } catch (IOException | RuntimeException e) {
             // ignore
         }
     }

driver-core/src/main/com/mongodb/internal/connection/SocksSocket.java

@@ -105,7 +105,11 @@ public void connect(final SocketAddress endpoint, final int timeoutMs) throws IO
              * 1. Enforces self-closing under RFC 1928 if METHOD is X'FF'.
              * 2. Handles all other errors during connection, distinct from external closures.
              */
-            close();
+            try {
+                close();
+            } catch (Exception closeException) {
+                socketException.addSuppressed(closeException);
+            }
             throw socketException;
         }
     }