Module: kamailio Branch: master Commit: 0fd77b10b758d685b3ae27d0435e6b9d4bba82f5 URL: https://github.com/kamailio/kamailio/commit/0fd77b10b758d685b3ae27d0435e6b9d...
Author: Victor Seva linuxmaniac@torreviejawireless.org Committer: Victor Seva linuxmaniac@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/0fd77b10b758d685b3ae27d0435e6b9d... Patch: https://github.com/kamailio/kamailio/commit/0fd77b10b758d685b3ae27d0435e6b9d...
---
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)