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);