Module: kamailio Branch: master Commit: 3b915121d7e912a3edc609800bf5c336f35cbbde URL: https://github.com/kamailio/kamailio/commit/3b915121d7e912a3edc609800bf5c336...
Author: Stefan Mititelu stefan.mititelu@net2phone.com Committer: Daniel-Constantin Mierla miconda@gmail.com Date: 2025-04-11T13:37:55+02:00
dialog: use NULL for dmq response callback
---
Modified: src/modules/dialog/dlg_dmq.c Modified: src/modules/dialog/dlg_dmq.h
---
Diff: https://github.com/kamailio/kamailio/commit/3b915121d7e912a3edc609800bf5c336... Patch: https://github.com/kamailio/kamailio/commit/3b915121d7e912a3edc609800bf5c336...
---
diff --git a/src/modules/dialog/dlg_dmq.c b/src/modules/dialog/dlg_dmq.c index 6cd8d898762..669f9c97eef 100644 --- a/src/modules/dialog/dlg_dmq.c +++ b/src/modules/dialog/dlg_dmq.c @@ -33,7 +33,6 @@ static str dmq_500_rpl = str_init("Server Internal Error");
dmq_api_t dlg_dmqb; dmq_peer_t *dlg_dmq_peer = NULL; -dmq_resp_cback_t dlg_dmq_resp_callback = {&dlg_dmq_resp_callback_f, 0};
int dmq_send_all_dlgs(dmq_node_t *dmq_node); int dlg_dmq_request_sync(); @@ -82,12 +81,12 @@ int dlg_dmq_send(str *body, dmq_node_t *node) } if(node) { LM_DBG("sending dmq message ...\n"); - dlg_dmqb.send_message(dlg_dmq_peer, body, node, &dlg_dmq_resp_callback, - 1, &dlg_dmq_content_type); + dlg_dmqb.send_message( + dlg_dmq_peer, body, node, NULL, 1, &dlg_dmq_content_type); } else { LM_DBG("sending dmq broadcast...\n"); - dlg_dmqb.bcast_message(dlg_dmq_peer, body, 0, &dlg_dmq_resp_callback, 1, - &dlg_dmq_content_type); + dlg_dmqb.bcast_message( + dlg_dmq_peer, body, 0, NULL, 1, &dlg_dmq_content_type); } return 0; } @@ -684,14 +683,3 @@ int dmq_send_all_dlgs(dmq_node_t *dmq_node)
return 0; } - - -/** -* @brief dmq response callback -*/ -int dlg_dmq_resp_callback_f( - struct sip_msg *msg, int code, dmq_node_t *node, void *param) -{ - LM_DBG("dmq response callback triggered [%p %d %p]\n", msg, code, param); - return 0; -} diff --git a/src/modules/dialog/dlg_dmq.h b/src/modules/dialog/dlg_dmq.h index f545917b900..10caf81ba8a 100644 --- a/src/modules/dialog/dlg_dmq.h +++ b/src/modules/dialog/dlg_dmq.h @@ -33,7 +33,6 @@
extern dmq_api_t dlg_dmqb; extern dmq_peer_t *dlg_dmq_peer; -extern dmq_resp_cback_t dlg_dmq_resp_callback;
typedef enum { @@ -49,6 +48,4 @@ int dlg_dmq_handle_msg( struct sip_msg *msg, peer_reponse_t *resp, dmq_node_t *node); int dlg_dmq_replicate_action(dlg_dmq_action_t action, dlg_cell_t *dlg, int needlock, dmq_node_t *node); -int dlg_dmq_resp_callback_f( - struct sip_msg *msg, int code, dmq_node_t *node, void *param); #endif