Fix an issue with infinite timeout setting.

JAVA-5856

Author: vbabanin

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

@@ -237,14 +237,9 @@ public void openAsync(final OperationContext operationContext, final AsyncComple
                         socketChannel, () -> initializeTslChannel(handler, socketChannel));
 
                 int connectTimeoutMs = getSettings().getConnectTimeout(TimeUnit.MILLISECONDS);
-
-                group.getTimeoutExecutor().schedule(() -> {
-                    boolean markedTimedOut = socketRegistration.markConnectionEstablishmentTimedOut();
-                    if (markedTimedOut) {
-                        closeAndTimeout(handler, socketChannel);
-                    }
-                }, connectTimeoutMs, TimeUnit.MILLISECONDS);
-
+                if (connectTimeoutMs > 0) {
+                    scheduleTimeoutInterruption(handler, socketRegistration, socketChannel, connectTimeoutMs);
+                }
                 selectorMonitor.register(socketRegistration);
             } catch (IOException e) {
                 handler.failed(new MongoSocketOpenException("Exception opening socket", getServerAddress(), e));
@@ -253,6 +248,18 @@ public void openAsync(final OperationContext operationContext, final AsyncComple
             }
         }
 
+        private void scheduleTimeoutInterruption(final AsyncCompletionHandler<Void> handler,
+                                                 final SelectorMonitor.SocketRegistration socketRegistration,
+                                                 final SocketChannel socketChannel,
+                                                 final int connectTimeoutMs) {
+            group.getTimeoutExecutor().schedule(() -> {
+                boolean markedTimedOut = socketRegistration.markConnectionEstablishmentTimedOut();
+                if (markedTimedOut) {
+                    closeAndTimeout(handler, socketChannel);
+                }
+            }, connectTimeoutMs, TimeUnit.MILLISECONDS);
+        }
+
         private void closeAndTimeout(final AsyncCompletionHandler<Void> handler, final SocketChannel socketChannel) {
             // We check if this stream was closed before timeout exception.
             boolean streamClosed = isClosed();