add socket close after processing has stopped

teragrep · Sep 13, 2022 · bf1a7ec · bf1a7ec
1 parent 5985cdf
commit bf1a7ec
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/src/main/java/com/teragrep/rlp_03/SocketProcessor.java b/src/main/java/com/teragrep/rlp_03/SocketProcessor.java
@@ -170,7 +170,10 @@ public void run() {
             for (Thread thread : messageSelectorThreadList) {
                 thread.join();
             }
-        } catch (InterruptedException e) {
+
+            serverSocket.close();
+        } catch (InterruptedException | IOException e) {
+            // FIXME
             e.printStackTrace();
         }
     }