spacebar/rust-nex
6
0
Fork 0
Code Issues Pull requests Projects Releases Packages 50 Wiki Activity Actions

V0 #1

Closed
RusticMaple wants to merge 105 commits from v0 into main
pull from: v0
merge into: spacebar:main
Conversation 0 Commits 105 Files changed 159 +6 -1
1 changed files with 6 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files
Showing only changes of commit 449ce0c0ba - Show all commits

add closing a connection if it becomes unreliable/doesnt ack a packet 5 times

Prev Next
Maple Nebel 2025-11-08 13:41:41 +00:00
commit 449ce0c0ba

7
prudpv1/src/prudp/socket.rs
View file

@ -7,7 +7,7 @@ use crate::prudp::packet::{PRUDPV1Header, PRUDPV1Packet, TypesFlags};
use rnex_core::prudp::virtual_port::VirtualPort;
use rnex_core::prudp::socket_addr::PRUDPSockAddr;
use async_trait::async_trait;
use log::info;
use log::{info, warn};
use log::error;
use rc4::StreamCipher;
use v_byte_helpers::ReadExtensions;
@ -347,6 +347,11 @@ impl<T: CryptoHandler> InternalSocket<T> {
}
for (send_time, packet) in &conn.unacknowleged_packets{
if *send_time < (Instant::now() - Duration::from_millis(3000)){
warn!("failed to resend packet 5 times and never got response, destroying connection");
conn.close_connection().await;
break;
}
if *send_time < (Instant::now() - Duration::from_millis(500)){
info!("unacknowledged packet sat arround for more than 500 ms, resending");
conn.send_raw_packet(packet).await;