proxmox-mirrors/mirror_corosync
1
0
Fork 0
mirror of https://git.proxmox.com/git/mirror_corosync synced 2026-01-20 22:15:34 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Add some missing calls to increment the relevant stats.

Browse Source 
git-svn-id: http://svn.fedorahosted.org/svn/corosync/trunk@2519 fd59a12c-fef9-0310-b244-a6a79926bd2f
This commit is contained in:
Angus Salkeld 2009-10-12 21:56:23 +00:00
parent 4e6e33467d
commit 948ca19aa7
2 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
exec/coroipcs.c
View File

@ -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)) {

2
exec/totemsrp.c
View File

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