LBRYFoundation/lbry-globe-java
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Fix starting DHT discovery

Browse source
This commit is contained in:
Ben van Hartingsveldt 2025-07-13 16:01:18 +02:00
parent 364866d905
commit 25e4f24ae9
No known key found for this signature in database
GPG key ID: 261AA214130CE7AB
1 changed files with 10 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
src/main/java/com/lbry/globe/thread/DHTNodeFinderThread.java
View file

@ -144,17 +144,19 @@ public class DHTNodeFinderThread implements Runnable{
} }
private void handleIncomingMessages(){ private void handleIncomingMessages(){
while(DHT.getSocket().isBound()){ new Thread(() -> {
while(this.incoming.peek()!=null){ while(DHT.getSocket().isBound()){
UDP.Packet receiverPacket = this.incoming.poll(); while(this.incoming.peek()!=null){
byte[] receivingBytes = receiverPacket.getData(); UDP.Packet receiverPacket = this.incoming.poll();
byte[] receivingBytes = receiverPacket.getData();
DHT.Message<?> message = DHT.Message.fromBencode(receivingBytes); DHT.Message<?> message = DHT.Message.fromBencode(receivingBytes);
if(message.getType()==DHT.Message.TYPE_REQUEST){ if(message.getType()==DHT.Message.TYPE_REQUEST){
System.out.println("Incoming request"); System.out.println("Incoming request");
}
} }
} }
} },"DHT Incoming").start();
} }
} }