Skip to content

Commit

Permalink
Reset heartbeat miss counter (#135)
Browse files Browse the repository at this point in the history
- Fix #134
  • Loading branch information
gftea authored Jun 14, 2024
1 parent 03e05a3 commit 17d7107
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions amqprs/src/net/reader_handler.rs
Original file line number Diff line number Diff line change
Expand Up @@ -254,6 +254,7 @@ impl ReaderHandler {
res = self.stream.read_frame() => {
// any frame can be considered as heartbeat
expiration = time::Instant::now() + time::Duration::from_secs(max_interval);
heartbeat_miss = 0;
#[cfg(feature="traces")]
trace!("server heartbeat deadline is updated to {:?}", expiration);

Expand Down

0 comments on commit 17d7107

Please sign in to comment.