Skip to content

Commit 25e4f24

Browse files
committed
Fix starting DHT discovery
1 parent 364866d commit 25e4f24

File tree

1 file changed

+11
-9
lines changed

1 file changed

+11
-9
lines changed

src/main/java/com/lbry/globe/thread/DHTNodeFinderThread.java

Lines changed: 11 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -144,17 +144,19 @@ private void startReceiver(){
144144
}
145145

146146
private void handleIncomingMessages(){
147-
while(DHT.getSocket().isBound()){
148-
while(this.incoming.peek()!=null){
149-
UDP.Packet receiverPacket = this.incoming.poll();
150-
byte[] receivingBytes = receiverPacket.getData();
151-
152-
DHT.Message<?> message = DHT.Message.fromBencode(receivingBytes);
153-
if(message.getType()==DHT.Message.TYPE_REQUEST){
154-
System.out.println("Incoming request");
147+
new Thread(() -> {
148+
while(DHT.getSocket().isBound()){
149+
while(this.incoming.peek()!=null){
150+
UDP.Packet receiverPacket = this.incoming.poll();
151+
byte[] receivingBytes = receiverPacket.getData();
152+
153+
DHT.Message<?> message = DHT.Message.fromBencode(receivingBytes);
154+
if(message.getType()==DHT.Message.TYPE_REQUEST){
155+
System.out.println("Incoming request");
156+
}
155157
}
156158
}
157-
}
159+
},"DHT Incoming").start();
158160
}
159161

160162
}

0 commit comments

Comments
 (0)