feat(read_handler): log when max hearbeat missed

This can be useful when debugging if the limit was reached, otherwise there is no easy way to tell.
gftea · Oct 24, 2024 · 9395695 · 9395695
1 parent de3c858
commit 9395695
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/amqprs/src/net/reader_handler.rs b/amqprs/src/net/reader_handler.rs
@@ -261,7 +261,7 @@ impl ReaderHandler {
                     match res {
                         Ok((channel_id, frame)) => {
                             if let Err(err) = self.handle_frame(channel_id, frame).await {
-                                // notifiy network failure
+                                // notify network failure
                                 is_network_failure = true;
                                 #[cfg(feature="traces")]
                                 error!("socket will be closed due to error of handling frame, cause: {}", err);
@@ -275,7 +275,7 @@ impl ReaderHandler {
                             }
                         },
                         Err(err) => {
-                            // notifiy network failure
+                            // notify network failure
                             is_network_failure = true;
                             #[cfg(feature="traces")]
                             error!("socket will be closed due to failure of reading frame, cause: {}", err);
@@ -294,6 +294,8 @@ impl ReaderHandler {
                         error!("missing heartbeat from server for {}", self.amqp_connection);
                         heartbeat_miss += 1;
                         if heartbeat_miss >= MAX_HEARTBEAT_MISS {
+                            #[cfg(feature="traces")]
+                            error!("heartbeat was missed `{heartbeat_miss}` times in a row, closing connection");
                             // Shutdown connection due to heartbeat timeout
                             is_network_failure = true;
                             break;