From b1e933f7efb2f1f1a36a525710e88d3a48a2a8eb Mon Sep 17 00:00:00 2001 From: MassimilianoPinto Date: Wed, 28 May 2014 18:36:52 +0200 Subject: [PATCH] Replication Lag in server diagnostics Replication Lag in server diagnostics --- server/core/server.c | 18 +++++++++++++++++- 1 file changed, 17 insertions(+), 1 deletion(-) diff --git a/server/core/server.c b/server/core/server.c index e822c1c1e..ff3e6745a 100644 --- a/server/core/server.c +++ b/server/core/server.c @@ -75,7 +75,7 @@ SERVER *server; server->server_string = NULL; server->node_id = -1; server->rlag = -1; - server->node_ts = -1; + server->node_ts = 0; spinlock_acquire(&server_spin); server->next = allServers; @@ -250,6 +250,14 @@ char *stat; if (ptr->server_string) dcb_printf(dcb, "\tServer Version:\t\t%s\n", ptr->server_string); dcb_printf(dcb, "\tNode Id: %d\n", ptr->node_id); + if (SERVER_IS_SLAVE(ptr)) { + if (ptr->rlag >= 0) { + dcb_printf(dcb, "\tSlave delay:\t\t%d\n", ptr->rlag); + } + } + if (ptr->node_ts > 0) { + dcb_printf(dcb, "\tLast Repl Heartbeat:\t%lu\n", ptr->node_ts); + } dcb_printf(dcb, "\tNumber of connections: %d\n", ptr->stats.n_connections); dcb_printf(dcb, "\tCurrent no. of conns: %d\n", ptr->stats.n_current); ptr = ptr->next; @@ -278,6 +286,14 @@ char *stat; if (server->server_string) dcb_printf(dcb, "\tServer Version:\t\t%s\n", server->server_string); dcb_printf(dcb, "\tNode Id: %d\n", server->node_id); + if (SERVER_IS_SLAVE(server)) { + if (server->rlag >= 0) { + dcb_printf(dcb, "\tSlave delay:\t\t%d\n", server->rlag); + } + } + if (server->node_ts > 0) { + dcb_printf(dcb, "\tLast Repl Heartbeat:\t%lu\n", server->node_ts); + } dcb_printf(dcb, "\tNumber of connections: %d\n", server->stats.n_connections); dcb_printf(dcb, "\tCurrent No. of conns: %d\n", server->stats.n_current); }