Garmelon/euphoxide
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Fix connection not checking pings

Browse source
This commit is contained in:
Joscha 2023-01-24 18:11:41 +01:00
parent dfacc05749
commit 2719ab3301
1 changed files with 2 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

2
src/conn.rs
View file

@ -517,11 +517,13 @@ impl Conn {
// Send new ws ping // Send new ws ping
let ws_payload = now.unix_timestamp_nanos().to_be_bytes().to_vec(); let ws_payload = now.unix_timestamp_nanos().to_be_bytes().to_vec();
self.last_ws_ping_payload = Some(ws_payload.clone()); self.last_ws_ping_payload = Some(ws_payload.clone());
self.last_ws_ping_replied_to = false;
self.ws.send(tungstenite::Message::Ping(ws_payload)).await?; self.ws.send(tungstenite::Message::Ping(ws_payload)).await?;
// Send new euph ping // Send new euph ping
let euph_payload = Time::new(now); let euph_payload = Time::new(now);
self.last_euph_ping_payload = Some(euph_payload); self.last_euph_ping_payload = Some(euph_payload);
self.last_euph_ping_replied_to = false;
let (tx, _) = oneshot::channel(); let (tx, _) = oneshot::channel();
self.send_cmd(Ping { time: euph_payload }.into(), tx) self.send_cmd(Ping { time: euph_payload }.into(), tx)
.await?; .await?;