teascade/teanet-rust
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Speed up connecting

Browse Source
This commit is contained in:
Sofia 2026-08-15 01:00:10 +03:00
parent c75e0e40c7
commit 30ef3ab779
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/connections.rs
View File

@ -100,7 +100,9 @@ impl<T: std::fmt::Debug + Clone + Serialize + DeserializeOwned + Send + Sync + '
if let Some(_) = &self.udp.socket { if let Some(_) = &self.udp.socket {
for (addr, conn) in &mut self.connections { for (addr, conn) in &mut self.connections {
let interval = if conn.last_sent_ping > conn.last_recv_pong { let interval = if conn.last_sent_ping > conn.last_recv_pong
&& conn.state == ConnectionState::Connected
{
self.config.max_ping_interval self.config.max_ping_interval
} else { } else {
self.config.ping_interval self.config.ping_interval
@ -309,6 +311,8 @@ impl<T: std::fmt::Debug + Clone + Serialize + DeserializeOwned + Send + Sync + '
if conn.state == ConnectionState::ConnectingNearlyReady if conn.state == ConnectionState::ConnectingNearlyReady
|| conn.state == ConnectionState::ReceivingConnection || conn.state == ConnectionState::ReceivingConnection
{ {
// Workaround to make the first ping after connecting to be instantaneous
conn.last_recv_pong = Instant::now();
conn.state = ConnectionState::Connected; conn.state = ConnectionState::Connected;
messages.push(PeerMessage::NewConnection(conn.clone())); messages.push(PeerMessage::NewConnection(conn.clone()));
} }