From 25e4f24ae9995b1e3e42ecc3263dc47099e60abd Mon Sep 17 00:00:00 2001 From: Ben van Hartingsveldt Date: Sun, 13 Jul 2025 16:01:18 +0200 Subject: [PATCH] Fix starting DHT discovery --- .../lbry/globe/thread/DHTNodeFinderThread.java | 18 ++++++++++-------- 1 file changed, 10 insertions(+), 8 deletions(-) diff --git a/src/main/java/com/lbry/globe/thread/DHTNodeFinderThread.java b/src/main/java/com/lbry/globe/thread/DHTNodeFinderThread.java index a338462..feee06f 100644 --- a/src/main/java/com/lbry/globe/thread/DHTNodeFinderThread.java +++ b/src/main/java/com/lbry/globe/thread/DHTNodeFinderThread.java @@ -144,17 +144,19 @@ public class DHTNodeFinderThread implements Runnable{ } private void handleIncomingMessages(){ - while(DHT.getSocket().isBound()){ - while(this.incoming.peek()!=null){ - UDP.Packet receiverPacket = this.incoming.poll(); - byte[] receivingBytes = receiverPacket.getData(); + new Thread(() -> { + while(DHT.getSocket().isBound()){ + while(this.incoming.peek()!=null){ + UDP.Packet receiverPacket = this.incoming.poll(); + byte[] receivingBytes = receiverPacket.getData(); - DHT.Message message = DHT.Message.fromBencode(receivingBytes); - if(message.getType()==DHT.Message.TYPE_REQUEST){ - System.out.println("Incoming request"); + DHT.Message message = DHT.Message.fromBencode(receivingBytes); + if(message.getType()==DHT.Message.TYPE_REQUEST){ + System.out.println("Incoming request"); + } } } - } + },"DHT Incoming").start(); } }