Module: kamailio Branch: master Commit: a9ef7fe010492710e0a81a4505337accb5e1fea6 URL: https://github.com/kamailio/kamailio/commit/a9ef7fe010492710e0a81a4505337ac… Author: Daniel-Constantin Mierla &lt;miconda(a)gmail.com&gt; Committer: Daniel-Constantin Mierla &lt;miconda(a)gmail.com&gt; Date: 2017-11-23T18:55:07+01:00 ndb_redis: exported redis_cmd() and redis_free() to kemi framework --- Modified: src/modules/ndb_redis/ndb_redis_mod.c --- Diff: https://github.com/kamailio/kamailio/commit/a9ef7fe010492710e0a81a4505337ac… Patch: https://github.com/kamailio/kamailio/commit/a9ef7fe010492710e0a81a4505337ac… --- diff --git a/src/modules/ndb_redis/ndb_redis_mod.c b/src/modules/ndb_redis/ndb_redis_mod.c index d5462bb1c8..64f2b46897 100644 --- a/src/modules/ndb_redis/ndb_redis_mod.c +++ b/src/modules/ndb_redis/ndb_redis_mod.c @@ -35,6 +35,7 @@ #include "../../core/dprint.h" #include "../../core/mod_fix.h" #include "../../core/trim.h" +#include "../../core/kemi.h" #include "redis_client.h" #include "api.h" @@ -922,3 +923,88 @@ int bind_ndb_redis(ndb_redis_api_t *api) return 0; } +/** + * + */ +static int ki_redis_cmd(sip_msg_t *msg, str *srv, str *rcmd, str *sres) +{ + return redisc_exec(srv, sres, rcmd); +} + +/** + * + */ +static int ki_redis_cmd_p1(sip_msg_t *msg, str *srv, str *rcmd, str *p1, + str *sres) +{ + return redisc_exec(srv, sres, rcmd, p1->s); +} + +/** + * + */ +static int ki_redis_cmd_p2(sip_msg_t *msg, str *srv, str *rcmd, str *p1, + str *p2, str *sres) +{ + return redisc_exec(srv, sres, rcmd, p1->s, p2->s); +} + +/** + * + */ +static int ki_redis_cmd_p3(sip_msg_t *msg, str *srv, str *rcmd, str *p1, + str *p2, str *p3, str *sres) +{ + return redisc_exec(srv, sres, rcmd, p1->s, p2->s, p3->s); +} + +/** + * + */ +static int ki_redis_free_reply(sip_msg_t *msg, str *name) +{ + if(redisc_free_reply(name)<0) + return -1; + + return 1; +} +/** + * + */ +/* clang-format off */ +static sr_kemi_t sr_kemi_ndb_redis_exports[] = { + { str_init("ndb_redis"), str_init("redis_cmd"), + SR_KEMIP_INT, ki_redis_cmd, + { SR_KEMIP_STR, SR_KEMIP_STR, SR_KEMIP_STR, + SR_KEMIP_NONE, SR_KEMIP_NONE, SR_KEMIP_NONE } + }, + { str_init("ndb_redis"), str_init("redis_cmd_p1"), + SR_KEMIP_INT, ki_redis_cmd_p1, + { SR_KEMIP_STR, SR_KEMIP_STR, SR_KEMIP_STR, + SR_KEMIP_STR, SR_KEMIP_NONE, SR_KEMIP_NONE } + }, + { str_init("ndb_redis"), str_init("redis_cmd_p2"), + SR_KEMIP_INT, ki_redis_cmd_p2, + { SR_KEMIP_STR, SR_KEMIP_STR, SR_KEMIP_STR, + SR_KEMIP_STR, SR_KEMIP_STR, SR_KEMIP_NONE } + }, + { str_init("ndb_redis"), str_init("redis_cmd_p3"), + SR_KEMIP_INT, ki_redis_cmd_p3, + { SR_KEMIP_STR, SR_KEMIP_STR, SR_KEMIP_STR, + SR_KEMIP_STR, SR_KEMIP_STR, SR_KEMIP_STR } + }, + { str_init("ndb_redis"), str_init("redis_free"), + SR_KEMIP_INT, ki_redis_free_reply, + { SR_KEMIP_STR, SR_KEMIP_NONE, SR_KEMIP_NONE, + SR_KEMIP_NONE, SR_KEMIP_NONE, SR_KEMIP_NONE } + }, + + { {0, 0}, {0, 0}, 0, NULL, { 0, 0, 0, 0, 0, 0 } } +}; +/* clang-format on */ + +int mod_register(char *path, int *dlflags, void *p1, void *p2) +{ + sr_kemi_modules_add(sr_kemi_ndb_redis_exports); + return 0; +} \ No newline at end of file