Module: sip-router Branch: master Commit: 82a03cb5af01c1275bc9a1664643cf3645c4b87a URL: http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=82a03cb… Author: Ovidiu Sas &lt;osas(a)voipembedded.com&gt; Committer: Ovidiu Sas &lt;osas(a)voipembedded.com&gt; Date: Mon Dec 17 12:01:49 2012 -0500 modules_k/db_text: new rpc command 'db_text.dump' - allows forcing a write back to disk for modified tables --- modules_k/db_text/dbtext.c | 27 +++++++++++++++++++++++++++ 1 files changed, 27 insertions(+), 0 deletions(-) diff --git a/modules_k/db_text/dbtext.c b/modules_k/db_text/dbtext.c index 633dbb3..187b28f 100644 --- a/modules_k/db_text/dbtext.c +++ b/modules_k/db_text/dbtext.c @@ -34,6 +34,7 @@ #include "../../sr_module.h" #include "../../lib/srdb1/db.h" +#include "../../rpc_lookup.h" #include "dbtext.h" #include "dbt_lib.h" #include "dbt_api.h" @@ -67,6 +68,7 @@ static param_export_t params[] = { {0, 0, 0} }; +static rpc_export_t rpc_methods[]; struct module_exports exports = { "db_text", @@ -85,6 +87,11 @@ struct module_exports exports = { int mod_register(char *path, int *dlflags, void *p1, void *p2) { + if (rpc_register_array(rpc_methods)!=0) { + LM_ERR("failed to register RPC commands\n"); + return -1; + } + if(db_api_init()<0) return -1; return 0; @@ -127,3 +134,23 @@ int dbt_bind_api(db_func_t *dbb) return 0; } +/* rpc function documentation */ +static const char *rpc_dump_doc[2] = { + "Write back to disk modified tables", 0 +}; + +/* rpc function implementations */ +static void rpc_dump(rpc_t *rpc, void *c) { + if (0!=dbt_cache_print(0)) + rpc->printf(c, "Dump failed"); + else + rpc->printf(c, "Dump OK"); + + return; +} + +static rpc_export_t rpc_methods[] = { + {"db_text.dump", rpc_dump, rpc_dump_doc, 0}, + {0, 0, 0, 0} +}; +