From e73644b7358ab9c2b4d10319df0f6eb253666607 Mon Sep 17 00:00:00 2001 From: Frauk Date: Tue, 19 Nov 2024 15:58:39 +0000 Subject: [PATCH] restart websocket at first missing keepalive --- src/websocket/mod.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/websocket/mod.rs b/src/websocket/mod.rs index 888222f49..62bb6a807 100644 --- a/src/websocket/mod.rs +++ b/src/websocket/mod.rs @@ -201,7 +201,7 @@ impl SignalWebSocketProcess { futures::select! { _ = ka_interval.tick().fuse() => { use prost::Message; - if self.outgoing_keep_alive_set.len() > 6 { + if self.outgoing_keep_alive_set.len() > 0 { tracing::warn!("Websocket will be closed due to failed keepalives."); if let Err(e) = self.ws.close(reqwest_websocket::CloseCode::Away, None).await { tracing::debug!("Could not close WebSocket: {:?}", e);