[sr-dev] git:master: drouting: mi commands migrated to rpc

Module: sip-router Branch: master Commit: d4733ab7e27be0cf472db7157dcdbe6390e269b6 URL: http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=d4733ab… Author: Ovidiu Sas <osas(a)voipembedded.com> Committer: Ovidiu Sas <osas(a)voipembedded.com> Date: Mon Dec 17 13:04:42 2012 -0500 drouting: mi commands migrated to rpc --- modules_k/drouting/Makefile | 1 - modules_k/drouting/drouting.c | 57 ++++++++++++++++++----------------------- 2 files changed, 25 insertions(+), 33 deletions(-) diff --git a/modules_k/drouting/Makefile b/modules_k/drouting/Makefile index 61a0475..a92749e 100644 --- a/modules_k/drouting/Makefile +++ b/modules_k/drouting/Makefile @@ -11,6 +11,5 @@ DEFS+=-DKAMAILIO_MOD_INTERFACE SERLIBPATH=../../lib SER_LIBS+=$(SERLIBPATH)/srdb1/srdb1 SER_LIBS+=$(SERLIBPATH)/kcore/kcore -SER_LIBS+=$(SERLIBPATH)/kmi/kmi include ../../Makefile.modules diff --git a/modules_k/drouting/drouting.c b/modules_k/drouting/drouting.c index aa09ef4..43fd73e 100644 --- a/modules_k/drouting/drouting.c +++ b/modules_k/drouting/drouting.c @@ -46,7 +46,7 @@ #include "../../parser/parse_from.h" #include "../../parser/parse_uri.h" #include "../../dset.h" -#include "../../lib/kmi/mi.h" +#include "../../rpc_lookup.h" #include "dr_load.h" #include "prefix_tree.h" @@ -123,11 +123,6 @@ static int is_from_gw_2(struct sip_msg* msg, char* str1, char* str2); static int goes_to_gw_0(struct sip_msg* msg, char* f1, char* f2); static int goes_to_gw_1(struct sip_msg* msg, char* f1, char* f2); -static struct mi_root* dr_reload_cmd(struct mi_root *cmd_tree, void *param); - -#define RELOAD_MI_CMD "dr_reload" - - MODULE_VERSION /* @@ -177,28 +172,19 @@ static param_export_t params[] = { {0, 0, 0} }; - -/* - * Exported MI functions - */ -static mi_export_t mi_cmds[] = { - { RELOAD_MI_CMD, dr_reload_cmd, MI_NO_INPUT_FLAG, 0, 0 }, - { 0, 0, 0, 0, 0} -}; - - +static rpc_export_t rpc_methods[]; struct module_exports exports = { "drouting", DEFAULT_DLFLAGS, /* dlopen flags */ cmds, /* Exported functions */ params, /* Exported parameters */ - 0, /* exported statistics */ - mi_cmds, /* exported MI functions */ - 0, /* exported pseudo-variables */ + NULL, /* exported statistics */ + NULL, /* exported MI functions */ + NULL, /* exported pseudo-variables */ 0, /* additional processes */ dr_init, /* Module initialization function */ - (response_function) 0, + (response_function) NULL, (destroy_function) dr_exit, (child_init_function) dr_child_init /* per-child init function */ }; @@ -271,9 +257,8 @@ static int dr_init(void) LM_INFO("DRouting - initializing\n"); - if(register_mi_mod(exports.name, mi_cmds)!=0) - { - LM_ERR("failed to register MI commands\n"); + if (rpc_register_array(rpc_methods)!=0) { + LM_ERR("failed to register RPC commands\n"); return -1; } @@ -468,32 +453,40 @@ static int dr_exit(void) } +/* rpc function documentation */ +static const char *rpc_reload_doc[2] = { + "Write back to disk modified tables", 0 +}; -static struct mi_root* dr_reload_cmd(struct mi_root *cmd_tree, void *param) +/* rpc function implementations */ +static void rpc_reload(rpc_t *rpc, void *c) { int n; - LM_INFO("\"%s\" MI command received!\n",RELOAD_MI_CMD); + LM_INFO("RPC command received!\n"); /* init DB connection if needed */ if (db_hdl==NULL) { db_hdl=dr_dbf.init(&db_url); if(db_hdl==0 ) { - LM_CRIT("cannot initialize database connection\n"); - goto error; + rpc->printf(c, "cannot initialize database connection"); + return; } } if ( (n=dr_reload_data())!=0 ) { - LM_CRIT("failed to load routing data\n"); - goto error; + rpc->printf(c, "failed to load routing data"); + return; } - return init_mi_tree( 200, MI_OK_S, MI_OK_LEN); -error: - return init_mi_tree( 500, "Failed to reload",16); + rpc->printf(c, "relaad OK"); + return; } +static rpc_export_t rpc_methods[] = { + {"drouting.reload", rpc_reload, rpc_reload_doc, 0}, + {0, 0, 0, 0} +}; static inline int get_group_id(struct sip_uri *uri)