This commit is contained in:
@@ -252,8 +252,9 @@ public class ArcNetProvider implements NetProvider{
|
|||||||
public void discoverServers(Cons<Host> callback, Runnable done){
|
public void discoverServers(Cons<Host> callback, Runnable done){
|
||||||
Seq<InetAddress> foundAddresses = new Seq<>();
|
Seq<InetAddress> foundAddresses = new Seq<>();
|
||||||
long time = Time.millis();
|
long time = Time.millis();
|
||||||
|
|
||||||
client.discoverHosts(port, multicastGroup, multicastPort, 3000, packet -> {
|
client.discoverHosts(port, multicastGroup, multicastPort, 3000, packet -> {
|
||||||
Core.app.post(() -> {
|
synchronized(foundAddresses){
|
||||||
try{
|
try{
|
||||||
if(foundAddresses.contains(address -> address.equals(packet.getAddress()) || (isLocal(address) && isLocal(packet.getAddress())))){
|
if(foundAddresses.contains(address -> address.equals(packet.getAddress()) || (isLocal(address) && isLocal(packet.getAddress())))){
|
||||||
return;
|
return;
|
||||||
@@ -266,7 +267,7 @@ public class ArcNetProvider implements NetProvider{
|
|||||||
//don't crash when there's an error pinging a a server or parsing data
|
//don't crash when there's an error pinging a a server or parsing data
|
||||||
e.printStackTrace();
|
e.printStackTrace();
|
||||||
}
|
}
|
||||||
});
|
}
|
||||||
}, () -> Core.app.post(done));
|
}, () -> Core.app.post(done));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user