times & readme
This commit is contained in:
@@ -824,7 +824,7 @@ pub async fn get_socket_address(
|
|||||||
|
|
||||||
for addr in addresses {
|
for addr in addresses {
|
||||||
println!("trying address : {}", addr);
|
println!("trying address : {}", addr);
|
||||||
if quick_ping(&addr, 5000, sd).await {
|
if quick_ping(&addr, 1000, sd).await {
|
||||||
return Ok(addr);
|
return Ok(addr);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -840,7 +840,7 @@ pub async fn get_socket_address(
|
|||||||
false,
|
false,
|
||||||
);
|
);
|
||||||
|
|
||||||
sleep(Duration::from_millis(5000)).await;
|
sleep(Duration::from_millis(1000)).await;
|
||||||
|
|
||||||
let maybe_entry = {
|
let maybe_entry = {
|
||||||
let guard = sd.messages_received_ref().lock().unwrap();
|
let guard = sd.messages_received_ref().lock().unwrap();
|
||||||
@@ -855,7 +855,7 @@ pub async fn get_socket_address(
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
if quick_ping(&addr, 15000, sd).await {
|
if quick_ping(&addr, 5000, sd).await {
|
||||||
return Ok(addr);
|
return Ok(addr);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user