Module: kamailio Branch: master Commit: 986094362b8ff384cc0378a7028425ea092609aa URL: https://github.com/kamailio/kamailio/commit/986094362b8ff384cc0378a7028425e… Author: Daniel-Constantin Mierla &lt;miconda(a)gmail.com&gt; Committer: Daniel-Constantin Mierla &lt;miconda(a)gmail.com&gt; Date: 2017-10-13T12:33:30+02:00 sipdump: implemented sipdump.enable rpc command --- Modified: src/modules/sipdump/sipdump_mod.c Modified: src/modules/sipdump/sipdump_write.c Modified: src/modules/sipdump/sipdump_write.h --- Diff: https://github.com/kamailio/kamailio/commit/986094362b8ff384cc0378a7028425e… Patch: https://github.com/kamailio/kamailio/commit/986094362b8ff384cc0378a7028425e… --- diff --git a/src/modules/sipdump/sipdump_mod.c b/src/modules/sipdump/sipdump_mod.c index 48a77ada76..e7ba0a69a5 100644 --- a/src/modules/sipdump/sipdump_mod.c +++ b/src/modules/sipdump/sipdump_mod.c @@ -94,6 +94,11 @@ struct module_exports exports = { */ static int mod_init(void) { + if(sipdump_rpc_init()<0) { + LM_ERR("failed to register rpc commands\n"); + return -1; + } + if(sipdump_file_init(&sipdump_folder, &sipdump_fprefix) < 0) { LM_ERR("cannot initialize storage file\n"); return -1; diff --git a/src/modules/sipdump/sipdump_write.c b/src/modules/sipdump/sipdump_write.c index 7d76715c7d..8d8c890721 100644 --- a/src/modules/sipdump/sipdump_write.c +++ b/src/modules/sipdump/sipdump_write.c @@ -27,6 +27,8 @@ #include "../../core/dprint.h" #include "../../core/ut.h" +#include "../../core/rpc.h" +#include "../../core/rpc_lookup.h" #include "sipdump_write.h" @@ -226,3 +228,63 @@ void sipdump_timer_exec(unsigned int ticks, void *param) shm_free(sdd); } } + +static const char *sipdump_rpc_enable_doc[2] = { + "Command to control sipdump enable value", 0}; + + +/* +* RPC command to control sipdump enable +*/ +static void sipdump_rpc_enable(rpc_t *rpc, void *ctx) +{ + int enval = -1; + int oval = 0; + int nval = 0; + + void *th; + + if(rpc->scan(ctx, "*d", &enval) != 1) { + enval = -1; + } + + if(rpc->add(ctx, "{", &th) < 0) { + rpc->fault(ctx, 500, "Internal error root reply"); + return; + } + + if(_sipdump_list) { + oval = _sipdump_list->enable; + if(enval==0 || enval==1) { + _sipdump_list->enable = enval; + nval = enval; + } else { + nval = oval; + } + } + + if(rpc->struct_add(th, "dd", "oldval", oval, "newval", nval) < 0) { + rpc->fault(ctx, 500, "Internal error reply structure"); + return; + } +} + +/* clang-format off */ +rpc_export_t sipdump_rpc_cmds[] = { + {"sipdump.enable", sipdump_rpc_enable, + sipdump_rpc_enable_doc, 0}, + {0, 0, 0, 0} +}; +/* clang-format on */ + +/** + * register RPC commands + */ +int sipdump_rpc_init(void) +{ + if(rpc_register_array(sipdump_rpc_cmds) != 0) { + LM_ERR("failed to register RPC commands\n"); + return -1; + } + return 0; +} \ No newline at end of file diff --git a/src/modules/sipdump/sipdump_write.h b/src/modules/sipdump/sipdump_write.h index e9d5de4131..611fd10fd9 100644 --- a/src/modules/sipdump/sipdump_write.h +++ b/src/modules/sipdump/sipdump_write.h @@ -51,4 +51,6 @@ int sipdump_file_init(str *folder, str *fprefix); int sipdump_enabled(void); +int sipdump_rpc_init(void); + #endif