Compare commits
3 Commits
f67146aa13
...
3be12f7807
Author | SHA1 | Date | |
---|---|---|---|
3be12f7807 | |||
e86ee534ed | |||
ad9c445fe5 |
@ -93,7 +93,10 @@ impl NodeServer {
|
|||||||
|
|
||||||
let conn = if let Err(e) = conn {
|
let conn = if let Err(e) = conn {
|
||||||
println!("Error accepting TLS connection: {e}");
|
println!("Error accepting TLS connection: {e}");
|
||||||
if e.to_string().contains("HandshakeFailure") {
|
let attack_error_messages = ["handshake", "certificate", "quote"];
|
||||||
|
|
||||||
|
let err_str = e.to_string().to_lowercase();
|
||||||
|
if attack_error_messages.iter().any(|att_er_str| err_str.contains(att_er_str)) {
|
||||||
state.increase_net_attacks().await;
|
state.increase_net_attacks().await;
|
||||||
}
|
}
|
||||||
return;
|
return;
|
||||||
@ -197,6 +200,7 @@ impl Update for NodeServer {
|
|||||||
yield Ok(update.update);
|
yield Ok(update.update);
|
||||||
}
|
}
|
||||||
// TODO: check if disconnect client if too many connections are active
|
// TODO: check if disconnect client if too many connections are active
|
||||||
|
// Its tested and working
|
||||||
if tx.receiver_count() > 9 {
|
if tx.receiver_count() > 9 {
|
||||||
error_status = Status::internal("Already have too many clients. Connect to another server.");
|
error_status = Status::internal("Already have too many clients. Connect to another server.");
|
||||||
break;
|
break;
|
||||||
|
@ -55,7 +55,9 @@ pub async fn heartbeat(
|
|||||||
state.remove_inactive_nodes().await;
|
state.remove_inactive_nodes().await;
|
||||||
let connected_ips = state.get_connected_ips().await;
|
let connected_ips = state.get_connected_ips().await;
|
||||||
println!("Connected nodes ({}): {:?}", connected_ips.len(), connected_ips);
|
println!("Connected nodes ({}): {:?}", connected_ips.len(), connected_ips);
|
||||||
let _ = tx.send((state.get_my_ip().await, state.get_my_info().await).into());
|
let my_node_info = state.get_my_info().await;
|
||||||
|
my_node_info.save();
|
||||||
|
let _ = tx.send((state.get_my_ip().await, my_node_info).into());
|
||||||
if connected_ips.len() < NUM_CONNECTIONS {
|
if connected_ips.len() < NUM_CONNECTIONS {
|
||||||
if let Some(node_ip) = state.get_random_disconnected_ip().await {
|
if let Some(node_ip) = state.get_random_disconnected_ip().await {
|
||||||
println!("Dialing random node {}", node_ip);
|
println!("Dialing random node {}", node_ip);
|
||||||
|
Loading…
Reference in New Issue
Block a user