From 948ca19aa7b5bc634cdc8b7cb5ba93aeff65cf09 Mon Sep 17 00:00:00 2001
From: Angus Salkeld <asalkeld@redhat.com>
Date: Mon, 12 Oct 2009 21:56:23 +0000
Subject: [PATCH] Add some missing calls to increment the relevant stats.

git-svn-id: http://svn.fedorahosted.org/svn/corosync/trunk@2519 fd59a12c-fef9-0310-b244-a6a79926bd2f
---
 exec/coroipcs.c | 4 ++++
 exec/totemsrp.c | 2 ++
 2 files changed, 6 insertions(+)

diff --git a/exec/coroipcs.c b/exec/coroipcs.c
index 29afa6f0..5d386a38 100644
--- a/exec/coroipcs.c
+++ b/exec/coroipcs.c
@@ -1063,6 +1063,7 @@ int coroipcs_response_send (void *conn, const void *msg, size_t mlen)
 retry_semop:
 	res = semop (conn_info->semid, &sop, 1);
 	if ((res == -1) && (errno == EINTR || errno == EAGAIN)) {
+		stats_api->stats_increment_value (conn_info->stats_handle, "sem_retry_count");
 		goto retry_semop;
 	} else
 	if ((res == -1) && (errno == EINVAL || errno == EIDRM)) {
@@ -1102,12 +1103,14 @@ int coroipcs_response_iov_send (void *conn, const struct iovec *iov, unsigned in
 retry_semop:
 	res = semop (conn_info->semid, &sop, 1);
 	if ((res == -1) && (errno == EINTR || errno == EAGAIN)) {
+		api->stats_increment_value (conn_info->stats_handle, "sem_retry_count");
 		goto retry_semop;
 	} else
 	if ((res == -1) && (errno == EINVAL || errno == EIDRM)) {
 		return (0);
 	}
 #endif
+	stats_api->stats_increment_value (conn_info->stats_handle, "responses");
 	return (0);
 }
 
@@ -1179,6 +1182,7 @@ static void msg_send (void *conn, const struct iovec *iov, unsigned int iov_len,
 retry_semop:
 	res = semop (conn_info->semid, &sop, 1);
 	if ((res == -1) && (errno == EINTR || errno == EAGAIN)) {
+		stats_api->stats_increment_value (conn_info->stats_handle, "sem_retry_count");
 		goto retry_semop;
 	} else
 	if ((res == -1) && (errno == EINVAL || errno == EIDRM)) {
diff --git a/exec/totemsrp.c b/exec/totemsrp.c
index 43431ed7..4329f0c9 100644
--- a/exec/totemsrp.c
+++ b/exec/totemsrp.c
@@ -2787,6 +2787,8 @@ static int memb_state_commit_token_send_recovery (
 	memcpy (instance->orf_token_retransmit, commit_token, commit_token_size);
 	instance->orf_token_retransmit_size = commit_token_size;
 
+	instance->stats->memb_commit_token_tx++;
+
 	totemrrp_token_send (instance->totemrrp_context,
 		commit_token,
 		commit_token_size);