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

diff --git a/exec/coroipcs.c b/exec/coroipcs.c
index 29afa6f062129be9fba26f760fccfcb2e4749f4a..5d386a3836cefbe1c1b2cdf9179be9cbd295f3de 100644 (file)
--- 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 43431ed724bfdca1de655c14a2a41883a542a251..4329f0c97b51f263a4687eb8030d7d91373e7906 100644 (file)
--- 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);