From 93a4558dddbea78a51171b2bf92e37da3ffb40dd Mon Sep 17 00:00:00 2001 From: Krishnan Parthasarathi Date: Thu, 10 Jul 2014 12:49:53 +0530 Subject: client/rpc: Add ping and msgs stats This can be seen as below, ># cat $META/graphs/active/vol-client-0/private |grep ping_msgs_sent ping_msgs_sent = 2 ># cat $META/graphs/active/vol-client-0/private |grep "^msgs_sent" msgs_sent = 13 where $META is //.meta Change-Id: I2107ec2b045bac701377760635e18758adb943a3 Signed-off-by: Krishnan Parthasarathi Reviewed-on: http://review.gluster.org/8285 Tested-by: Gluster Build System Reviewed-by: Atin Mukherjee Reviewed-by: Anand Avati --- rpc/rpc-lib/src/rpc-clnt.c | 4 ++++ 1 file changed, 4 insertions(+) (limited to 'rpc/rpc-lib/src/rpc-clnt.c') diff --git a/rpc/rpc-lib/src/rpc-clnt.c b/rpc/rpc-lib/src/rpc-clnt.c index b831c537723..2ae2dfb71bf 100644 --- a/rpc/rpc-lib/src/rpc-clnt.c +++ b/rpc/rpc-lib/src/rpc-clnt.c @@ -527,6 +527,9 @@ rpc_clnt_connection_cleanup (rpc_clnt_connection_t *conn) conn->ping_started = 0; rpc_clnt_unref (clnt); } + /*reset rpc msgs stats*/ + conn->pingcnt = 0; + conn->msgcnt = 0; } pthread_mutex_unlock (&conn->lock); @@ -1565,6 +1568,7 @@ rpc_clnt_submit (struct rpc_clnt *rpc, rpc_clnt_prog_t *prog, if ((ret >= 0) && frame) { /* Save the frame in queue */ __save_frame (rpc, frame, rpcreq); + conn->msgcnt++; gf_log ("rpc-clnt", GF_LOG_TRACE, "submitted request " "(XID: 0x%x Program: %s, ProgVers: %d, " -- cgit