diff --git a/src/peers.c b/src/peers.c
index 2678774..309ebae 100644
--- a/src/peers.c
+++ b/src/peers.c
@@ -1820,6 +1820,7 @@
 		}
 		else if (msg_head[1] == PEER_MSG_CTRL_HEARTBEAT) {
 			peer->reconnect = tick_add(now_ms, MS_TO_TICKS(PEER_RECONNECT_TIMEOUT));
+			peer->rx_hbt++;
 		}
 	}
 	else if (msg_head[0] == PEER_MSG_CLASS_STICKTABLE) {
@@ -2372,6 +2373,7 @@
 							goto out;
 						goto switchstate;
 					}
+					curpeer->tx_hbt++;
 				}
 				/* we get here when a peer_recv_msg() returns 0 in reql */
 				repl = peer_send_msgs(appctx, curpeer);
@@ -3095,7 +3097,7 @@
 	struct shared_table *st;
 
 	addr_to_str(&peer->addr, pn, sizeof pn);
-	chunk_appendf(msg, "  %p: id=%s(%s) addr=%s:%d status=%s reconnect=%s confirm=%u\n",
+	chunk_appendf(msg, "  %p: id=%s(%s) addr=%s:%d status=%s reconnect=%s confirm=%u tx_hbt=%u rx_hbt=%u\n",
 	              peer, peer->id,
 	              peer->local ? "local" : "remote",
 	              pn, get_host_port(&peer->addr),
@@ -3104,7 +3106,7 @@
 			             tick_is_expired(peer->reconnect, now_ms) ? "<PAST>" :
 			                     human_time(TICKS_TO_MS(peer->reconnect - now_ms),
 			                     TICKS_TO_MS(1000)) : "<NEVER>",
-	              peer->confirm);
+	              peer->confirm, peer->tx_hbt, peer->rx_hbt);
 
 	chunk_appendf(&trash, "        flags=0x%x", peer->flags);