Close incoming kademlia connections too!

Peergos · Sep 30, 2024 · 89f4ac5 · 89f4ac5
1 parent 7c67445
commit 89f4ac5
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/main/java/org/peergos/protocol/dht/KademliaEngine.java b/src/main/java/org/peergos/protocol/dht/KademliaEngine.java
@@ -198,6 +198,7 @@ public void receiveRequest(Dht.Message msg, PeerId source, Stream stream) {
             case PING: {break;} // Not used any more
             default: throw new IllegalStateException("Unknown message kademlia type: " + msg.getType());
         }
+        stream.getConnection().close();
     }
 
     public static boolean isPublic(Multiaddr addr) {