From fdfa78dee1bca240b4fe14a7f8ccd56322222ef1 Mon Sep 17 00:00:00 2001 From: Oleksandr Vayda Date: Tue, 20 Apr 2021 23:44:45 +0200 Subject: [PATCH 1/2] arangodb-java-driver-384 "java.net.SocketException: Socket closed" when in a cluster mode + Docke... --- .../arangodb/internal/velocystream/VstCommunication.java | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/src/main/java/com/arangodb/internal/velocystream/VstCommunication.java b/src/main/java/com/arangodb/internal/velocystream/VstCommunication.java index 3fedb48a3..6808d85c1 100644 --- a/src/main/java/com/arangodb/internal/velocystream/VstCommunication.java +++ b/src/main/java/com/arangodb/internal/velocystream/VstCommunication.java @@ -92,6 +92,13 @@ protected synchronized C connect(final HostHandle hostHandle, final AccessType a tryAuthenticate(connection); } hostHandler.confirm(); + if (!connection.isOpen()) { + // see https://github.com/arangodb/arangodb-java-driver/issues/384 + connection.close(); + hostHandler.fail(); + host = hostHandler.get(hostHandle, accessType); + continue; + } return connection; } catch (final IOException e) { hostHandler.fail(); From 0727c398ed7fb3a93265cc07c6e190b348067ae2 Mon Sep 17 00:00:00 2001 From: Oleksandr Vayda Date: Thu, 29 Apr 2021 16:18:54 +0200 Subject: [PATCH 2/2] arangodb-java-driver-384 remove redundant "connection.close()" statement --- .../com/arangodb/internal/velocystream/VstCommunication.java | 1 - 1 file changed, 1 deletion(-) diff --git a/src/main/java/com/arangodb/internal/velocystream/VstCommunication.java b/src/main/java/com/arangodb/internal/velocystream/VstCommunication.java index 6808d85c1..720ac6f02 100644 --- a/src/main/java/com/arangodb/internal/velocystream/VstCommunication.java +++ b/src/main/java/com/arangodb/internal/velocystream/VstCommunication.java @@ -94,7 +94,6 @@ protected synchronized C connect(final HostHandle hostHandle, final AccessType a hostHandler.confirm(); if (!connection.isOpen()) { // see https://github.com/arangodb/arangodb-java-driver/issues/384 - connection.close(); hostHandler.fail(); host = hostHandler.get(hostHandle, accessType); continue;