Ensure we close the socket if there is an issue during handshake

Closes #17
criteo · Nov 16, 2018 · 37e9ca0 · 37e9ca0
1 parent a171f12
commit 37e9ca0
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/agent/src/main/java/com/criteo/hadoop/garmadon/agent/SocketAppender.java b/agent/src/main/java/com/criteo/hadoop/garmadon/agent/SocketAppender.java
@@ -94,6 +94,7 @@ public void establishConnection() {
                     connectionEstablished = true;
                     return;
                 } catch (IOException | ProtocolVersion.InvalidFrameException | ProtocolVersion.InvalidProtocolVersionException exception) {
+                    close();
                     waitBeforeRetry();
                 }
             }