From 9f60a069a8f57b0fa3d8aa596079b0669d3da6c7 Mon Sep 17 00:00:00 2001 From: Joscha Date: Mon, 14 Feb 2022 01:56:28 +0100 Subject: [PATCH] Fix server only replying after pings --- cove-server/src/conn.rs | 13 ++++++------- 1 file changed, 6 insertions(+), 7 deletions(-) diff --git a/cove-server/src/conn.rs b/cove-server/src/conn.rs index b2ea10b..91e9f1e 100644 --- a/cove-server/src/conn.rs +++ b/cove-server/src/conn.rs @@ -129,19 +129,18 @@ impl ConnMaintenance { let mut payload = [0u8; 8]; rand::thread_rng().fill(&mut payload); - // debug!("Sending first ping with payload {:?}", payload); tx.send(Message::Ping(payload.to_vec()))?; tokio::time::sleep(ping_delay).await; loop { - let last_payload = last_ping_payload.lock().await; - if (&payload as &[u8]) != (&last_payload as &[u8]) { - // warn!("Invalid ping payload, client probably dead"); - return Err(Error::NoPong); - } + { + let last_payload = last_ping_payload.lock().await; + if (&payload as &[u8]) != (&last_payload as &[u8]) { + return Err(Error::NoPong); + } + }; rand::thread_rng().fill(&mut payload); - // debug!("Sending ping with payload {:?}", payload); tx.send(Message::Ping(payload.to_vec()))?; tokio::time::sleep(ping_delay).await; }