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

Remove queue

Browse source
This commit is contained in:
Ben van Hartingsveldt 2025-07-13 17:56:33 +02:00
parent db65cd2355
commit 6fd1a3f426
No known key found for this signature in database
GPG key ID: 261AA214130CE7AB
1 changed files with 0 additions and 21 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -11,7 +11,6 @@ import com.lbry.globe.util.UDP;
import java.io.IOException; import java.io.IOException;
import java.net.*; import java.net.*;
import java.util.*; import java.util.*;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.Executors; import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
@ -31,8 +30,6 @@ public class DHTNodeFinderThread implements Runnable{
"s2.lbry.network:4444", "s2.lbry.network:4444",
}; };
private final Queue<UDP.Packet> incoming = new ConcurrentLinkedQueue<>();
@Override @Override
public void run(){ public void run(){
for(String bootstrap : DHTNodeFinderThread.BOOTSTRAP){ for(String bootstrap : DHTNodeFinderThread.BOOTSTRAP){
@ -42,7 +39,6 @@ public class DHTNodeFinderThread implements Runnable{
this.startSender(); this.startSender();
this.startReceiver(); this.startReceiver();
this.handleIncomingMessages();
} }
private void startSender(){ private void startSender(){
@ -129,7 +125,6 @@ public class DHTNodeFinderThread implements Runnable{
while(DHT.getSocket().isBound()) { while(DHT.getSocket().isBound()) {
try { try {
UDP.Packet receiverPacket = UDP.receive(DHT.getSocket()); UDP.Packet receiverPacket = UDP.receive(DHT.getSocket());
DHTNodeFinderThread.this.incoming.add(receiverPacket);
byte[] receivingBytes = receiverPacket.getData(); byte[] receivingBytes = receiverPacket.getData();
@ -143,20 +138,4 @@ public class DHTNodeFinderThread implements Runnable{
},"DHT Receiver").start(); },"DHT Receiver").start();
} }
private void handleIncomingMessages(){
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 Incoming").start();
}
} }