Module: kamailio
Branch: master
Commit: 0fd77b10b758d685b3ae27d0435e6b9d4bba82f5
URL: 
https://github.com/kamailio/kamailio/commit/0fd77b10b758d685b3ae27d0435e6b9d4bba82f5

Author: Victor Seva <linuxman...@torreviejawireless.org>
Committer: Victor Seva <linuxman...@torreviejawireless.org>
Date: 2024-12-12T16:05:51+01:00

mqueue: add fixup_free* to exported functions

---

Modified: src/modules/mqueue/mqueue_mod.c

---

Diff:  
https://github.com/kamailio/kamailio/commit/0fd77b10b758d685b3ae27d0435e6b9d4bba82f5.diff
Patch: 
https://github.com/kamailio/kamailio/commit/0fd77b10b758d685b3ae27d0435e6b9d4bba82f5.patch

---

diff --git a/src/modules/mqueue/mqueue_mod.c b/src/modules/mqueue/mqueue_mod.c
index 035b66015ff..f100091844e 100644
--- a/src/modules/mqueue/mqueue_mod.c
+++ b/src/modules/mqueue/mqueue_mod.c
@@ -52,6 +52,7 @@ static int w_mq_pv_free(struct sip_msg *msg, char *mq, char 
*str2);
 int mq_param(modparam_t type, void *val);
 int mq_param_name(modparam_t type, void *val);
 static int fixup_mq_add(void **param, int param_no);
+static int fixup_free_mq_add(void **param, int param_no);
 static int bind_mq(mq_api_t *api);
 
 static int mqueue_rpc_init(void);
@@ -72,13 +73,13 @@ static pv_export_t mod_pvs[] = {
 
 static cmd_export_t cmds[] = {
        {"mq_fetch", (cmd_function)w_mq_fetch, 1,
-               fixup_spve_null, 0, ANY_ROUTE},
+               fixup_spve_null, fixup_free_spve_null, ANY_ROUTE},
        {"mq_add", (cmd_function)w_mq_add, 3,
-               fixup_mq_add, 0, ANY_ROUTE},
+               fixup_mq_add, fixup_free_mq_add, ANY_ROUTE},
        {"mq_pv_free", (cmd_function)w_mq_pv_free, 1,
-               fixup_spve_null, 0, ANY_ROUTE},
+               fixup_spve_null, fixup_free_spve_null, ANY_ROUTE},
        {"mq_size", (cmd_function)w_mq_size, 1,
-               fixup_spve_null, 0, ANY_ROUTE},
+               fixup_spve_null, fixup_free_spve_null, ANY_ROUTE},
        {"bind_mq", (cmd_function)bind_mq, 1, 0, 0, ANY_ROUTE},
        {0, 0, 0, 0, 0, 0}
 };
@@ -312,6 +313,16 @@ static int fixup_mq_add(void **param, int param_no)
        return E_UNSPEC;
 }
 
+static int fixup_free_mq_add(void **param, int param_no)
+{
+       if(param_no == 1 || param_no == 2 || param_no == 3) {
+               return fixup_free_spve_null(param, 1);
+       }
+
+       LM_ERR("invalid parameter number %d\n", param_no);
+       return E_UNSPEC;
+}
+
 static int bind_mq(mq_api_t *api)
 {
        if(!api)

_______________________________________________
Kamailio - Development Mailing List -- sr-dev@lists.kamailio.org
To unsubscribe send an email to sr-dev-le...@lists.kamailio.org
Important: keep the mailing list in the recipients, do not reply only to the 
sender!

Reply via email to