[sr-dev] git:master:727b5c5f: dmq: use core fixup helper functions directly

[Daniel-Constantin Mierla]

Module: kamailio
Branch: master
Commit: 727b5c5fed1e0972b80f005a801089a4afa2f114
URL: https://github.com/kamailio/kamailio/commit/727b5c5fed1e0972b80f005a801089a4afa2f114

Author: Daniel-Constantin Mierla <miconda at gmail.com>
Committer: Daniel-Constantin Mierla <miconda at gmail.com>
Date: 2017-12-05T12:10:24+01:00

dmq: use core fixup helper functions directly

---

Modified: src/modules/dmq/dmq.c

---

Diff:  https://github.com/kamailio/kamailio/commit/727b5c5fed1e0972b80f005a801089a4afa2f114.diff
Patch: https://github.com/kamailio/kamailio/commit/727b5c5fed1e0972b80f005a801089a4afa2f114.patch

---

diff --git a/src/modules/dmq/dmq.c b/src/modules/dmq/dmq.c
index f06111f830..b01e4604df 100644
--- a/src/modules/dmq/dmq.c
+++ b/src/modules/dmq/dmq.c
@@ -85,24 +85,22 @@ dmq_peer_t* dmq_notification_peer = NULL;
 static int mod_init(void);
 static int child_init(int);
 static void destroy(void);
-static int handle_dmq_fixup(void** param, int param_no);
-static int send_dmq_fixup(void** param, int param_no);
-static int bcast_dmq_fixup(void** param, int param_no);
 
 static cmd_export_t cmds[] = {
-	{"dmq_handle_message",  (cmd_function)dmq_handle_message, 0, handle_dmq_fixup, 0,
-		REQUEST_ROUTE},
-	{"dmq_send_message", (cmd_function)cfg_dmq_send_message, 4, send_dmq_fixup, 0,
-		ANY_ROUTE},
-        {"dmq_bcast_message", (cmd_function)cfg_dmq_bcast_message, 3, bcast_dmq_fixup, 0,
-                ANY_ROUTE},
-	{"dmq_t_replicate",  (cmd_function)cfg_dmq_t_replicate, 0, 0, 0,
-		REQUEST_ROUTE},
-        {"dmq_t_replicate",  (cmd_function)cfg_dmq_t_replicate, 1, fixup_spve_null, 0,
-                REQUEST_ROUTE},
-        {"dmq_is_from_node",  (cmd_function)cfg_dmq_is_from_node, 0, 0, 0,
-                REQUEST_ROUTE},
-        {"bind_dmq",        (cmd_function)bind_dmq,       0, 0,              0},
+	{"dmq_handle_message", (cmd_function)dmq_handle_message, 0,
+		0, 0, REQUEST_ROUTE},
+	{"dmq_send_message", (cmd_function)cfg_dmq_send_message, 4,
+		fixup_spve_all, 0, ANY_ROUTE},
+	{"dmq_bcast_message", (cmd_function)cfg_dmq_bcast_message, 3,
+		fixup_spve_all, 0, ANY_ROUTE},
+	{"dmq_t_replicate", (cmd_function)cfg_dmq_t_replicate, 0,
+		0, 0, REQUEST_ROUTE},
+	{"dmq_t_replicate", (cmd_function)cfg_dmq_t_replicate, 1,
+		fixup_spve_null, 0, REQUEST_ROUTE},
+	{"dmq_is_from_node", (cmd_function)cfg_dmq_is_from_node, 0,
+		0, 0, REQUEST_ROUTE},
+	{"bind_dmq", (cmd_function)bind_dmq, 0,
+		0, 0, 0},
 	{0, 0, 0, 0, 0, 0}
 };
 
@@ -329,21 +327,6 @@ static void destroy(void) {
 	}
 }
 
-static int handle_dmq_fixup(void** param, int param_no)
-{
- 	return 0;
-}
-
-static int send_dmq_fixup(void** param, int param_no)
-{
-	return fixup_spve_null(param, 1);
-}
-
-static int bcast_dmq_fixup(void** param, int param_no)
-{
-        return fixup_spve_null(param, 1);
-}
-
 static void dmq_rpc_list_nodes(rpc_t *rpc, void *c)
 {
 	void *h;