From 0cbe0c767e3eae0dd9158c357836d1cc4d5ce950 Mon Sep 17 00:00:00 2001 From: Bastian Gruber Date: Sun, 21 May 2023 14:46:10 +0200 Subject: [PATCH] Bugfixing heartbeat --- problem_06/src/heartbeat.rs | 8 ++++---- problem_06/src/server.rs | 1 + 2 files changed, 5 insertions(+), 4 deletions(-) diff --git a/problem_06/src/heartbeat.rs b/problem_06/src/heartbeat.rs index aa1b12f..9a4245c 100644 --- a/problem_06/src/heartbeat.rs +++ b/problem_06/src/heartbeat.rs @@ -1,8 +1,7 @@ -use std::time::Duration; - -use tokio::sync::mpsc; - use crate::frame::ServerFrames; +use std::time::Duration; +use tokio::sync::mpsc; +use tracing::debug; pub(crate) struct Heartbeat { is_running: bool, @@ -34,6 +33,7 @@ impl Heartbeat { interval.tick().await; loop { + debug!("Heartbeat"); interval.tick().await; let _ = self.message.send(ServerFrames::Heartbeat); } diff --git a/problem_06/src/server.rs b/problem_06/src/server.rs index f69304e..bff9827 100644 --- a/problem_06/src/server.rs +++ b/problem_06/src/server.rs @@ -145,6 +145,7 @@ impl Handler { } message = receive_message.recv() => { + debug!(?message); match message { Some(message) => { let _ = self.connection.write_frame(message).await;