[sr-dev] git:master:7b691e97: dispatcher: ds select and next functions exported to kemi

Module: kamailio Branch: master Commit: 7b691e9712fc4b4333698c4538c8209c32eba901 URL: https://github.com/kamailio/kamailio/commit/7b691e9712fc4b4333698c4538c8209… Author: Daniel-Constantin Mierla <miconda(a)gmail.com> Committer: Daniel-Constantin Mierla <miconda(a)gmail.com> Date: 2017-04-05T13:37:24+02:00 dispatcher: ds select and next functions exported to kemi --- Modified: src/modules/dispatcher/dispatcher.c --- Diff: https://github.com/kamailio/kamailio/commit/7b691e9712fc4b4333698c4538c8209… Patch: https://github.com/kamailio/kamailio/commit/7b691e9712fc4b4333698c4538c8209… --- diff --git a/src/modules/dispatcher/dispatcher.c b/src/modules/dispatcher/dispatcher.c index d0399e0..545d49b 100644 --- a/src/modules/dispatcher/dispatcher.c +++ b/src/modules/dispatcher/dispatcher.c @@ -51,6 +51,7 @@ #include "../../core/mod_fix.h" #include "../../core/rpc.h" #include "../../core/rpc_lookup.h" +#include "../../core/kemi.h" #include "ds_ht.h" #include "dispatch.h" @@ -1004,6 +1005,137 @@ void ds_ping_reply_codes_update(str *gname, str *name) ds_parse_reply_codes(); } +/* KEMI wrappers */ +/** + * + */ +static int ki_ds_select(sip_msg_t *msg, int set, int alg) +{ + return ds_select_dst_limit(msg, set, alg, 0xffff /* limit number of dst*/, + 2 /*set no dst/uri*/); +} + +/** + * + */ +static int ki_ds_select_limit(sip_msg_t *msg, int set, int alg, int limit) +{ + return ds_select_dst_limit(msg, set, alg, limit /* limit number of dst*/, + 2 /*set no dst/uri*/); +} + +/** + * + */ +static int ki_ds_select_dst(sip_msg_t *msg, int set, int alg) +{ + return ds_select_dst_limit(msg, set, alg, 0xffff /* limit number of dst*/, + 0 /*set dst uri*/); +} + +/** + * + */ +static int ki_ds_select_dst_limit(sip_msg_t *msg, int set, int alg, int limit) +{ + return ds_select_dst_limit(msg, set, alg, limit /* limit number of dst*/, + 0 /*set dst uri*/); +} + +/** + * + */ +static int ki_ds_select_domain(sip_msg_t *msg, int set, int alg) +{ + return ds_select_dst_limit(msg, set, alg, 0xffff /* limit number of dst*/, + 1 /*set host port*/); +} + +/** + * + */ +static int ki_ds_select_domain_limit(sip_msg_t *msg, int set, int alg, int limit) +{ + return ds_select_dst_limit(msg, set, alg, limit /* limit number of dst*/, + 1 /*set host port*/); +} + +/** + * + */ +static int ki_ds_next_dst(sip_msg_t *msg) +{ + return ds_next_dst(msg, 0 /*set dst uri*/); +} + +/** + * + */ +static int ki_ds_next_domain(sip_msg_t *msg) +{ + return ds_next_dst(msg, 1 /*set host port*/); +} + + +/** + * + */ +/* clang-format off */ +static sr_kemi_t sr_kemi_dispatcher_exports[] = { + { str_init("dispatcher"), str_init("ds_select"), + SR_KEMIP_INT, ki_ds_select, + { SR_KEMIP_INT, SR_KEMIP_INT, SR_KEMIP_NONE, + SR_KEMIP_NONE, SR_KEMIP_NONE, SR_KEMIP_NONE } + }, + { str_init("dispatcher"), str_init("ds_select_limit"), + SR_KEMIP_INT, ki_ds_select_limit, + { SR_KEMIP_INT, SR_KEMIP_INT, SR_KEMIP_INT, + SR_KEMIP_NONE, SR_KEMIP_NONE, SR_KEMIP_NONE } + }, + { str_init("dispatcher"), str_init("ds_select_domain"), + SR_KEMIP_INT, ki_ds_select_domain, + { SR_KEMIP_INT, SR_KEMIP_INT, SR_KEMIP_NONE, + SR_KEMIP_NONE, SR_KEMIP_NONE, SR_KEMIP_NONE } + }, + { str_init("dispatcher"), str_init("ds_select_domain_limit"), + SR_KEMIP_INT, ki_ds_select_domain_limit, + { SR_KEMIP_INT, SR_KEMIP_INT, SR_KEMIP_INT, + SR_KEMIP_NONE, SR_KEMIP_NONE, SR_KEMIP_NONE } + }, + { str_init("dispatcher"), str_init("ds_next_domain"), + SR_KEMIP_INT, ki_ds_next_domain, + { SR_KEMIP_NONE, SR_KEMIP_NONE, SR_KEMIP_NONE, + SR_KEMIP_NONE, SR_KEMIP_NONE, SR_KEMIP_NONE } + }, + { str_init("dispatcher"), str_init("ds_select_dst"), + SR_KEMIP_INT, ki_ds_select_dst, + { SR_KEMIP_INT, SR_KEMIP_INT, SR_KEMIP_NONE, + SR_KEMIP_NONE, SR_KEMIP_NONE, SR_KEMIP_NONE } + }, + { str_init("dispatcher"), str_init("ds_select_dst_limit"), + SR_KEMIP_INT, ki_ds_select_dst_limit, + { SR_KEMIP_INT, SR_KEMIP_INT, SR_KEMIP_INT, + SR_KEMIP_NONE, SR_KEMIP_NONE, SR_KEMIP_NONE } + }, + { str_init("dispatcher"), str_init("ds_next_dst"), + SR_KEMIP_INT, ki_ds_next_dst, + { SR_KEMIP_NONE, 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_dispatcher_exports); + return 0; +} + /*** RPC implementation ***/ static const char *dispatcher_rpc_reload_doc[2] = {