Mercurial > hg > freeDiameter
diff libfdcore/p_sr.c @ 1113:eb4ce68b6e5c
Added calls to remaining hooks
author | Sebastien Decugis <sdecugis@freediameter.net> |
---|---|
date | Mon, 13 May 2013 19:17:13 +0800 |
parents | a731051d2e83 |
children | 79dd22145f52 |
line wrap: on
line diff
--- a/libfdcore/p_sr.c Mon May 13 18:50:26 2013 +0800 +++ b/libfdcore/p_sr.c Mon May 13 19:17:13 2013 +0800 @@ -118,7 +118,7 @@ /* If the callback did not dispose of the message, do it now */ if (ed->request) { - //fd_msg_log(FD_MSG_LOG_DROPPED, ed->request, "Expiration period completed without an answer, and the expiry callback did not dispose of the message."); + fd_hook_call(HOOK_MESSAGE_DROPPED, ed->request, NULL, "Expiration period completed without an answer, and the expiry callback did not dispose of the message.", fd_msg_pmdl_get(ed->request)); CHECK_FCT_DO( fd_msg_free(ed->request), /* ignore */ ); } @@ -322,15 +322,19 @@ if (hdr) hdr->msg_flags |= CMD_FLAG_RETRANSMIT; + fd_hook_call(HOOK_MESSAGE_FAILOVER, sr->req, (struct fd_peer *)srlist->srs.o, NULL, fd_msg_pmdl_get(sr->req)); + /* Requeue for sending to another peer */ CHECK_FCT_DO( ret = fd_fifo_post(fd_g_outgoing, &sr->req), { - //fd_msg_log( FD_MSG_LOG_DROPPED, sr->req, "Internal error: error while requeuing during failover: %s", strerror(ret) ); + char buf[256]; + snprintf(buf, sizeof(buf), "Internal error: error while requeuing during failover: %s", strerror(ret)); + fd_hook_call(HOOK_MESSAGE_DROPPED, sr->req, NULL, buf, fd_msg_pmdl_get(sr->req)); CHECK_FCT_DO(fd_msg_free(sr->req), /* What can we do more? */) }); } else { /* Just free the request. */ - //fd_msg_log( FD_MSG_LOG_DROPPED, sr->req, "Sent & unanswered local message discarded during failover." ); + /* fd_hook_call(HOOK_MESSAGE_DROPPED, sr->req, NULL, "Sent & unanswered local message discarded during failover.", fd_msg_pmdl_get(sr->req)); */ CHECK_FCT_DO(fd_msg_free(sr->req), /* Ignore */); } free(sr);