Module: kamailio Branch: master Commit: d5d2bbd4fd6cad48bd0dcf8e577009f95ff3f53e URL: https://github.com/kamailio/kamailio/commit/d5d2bbd4fd6cad48bd0dcf8e577009f… Author: Daniel-Constantin Mierla <miconda(a)gmail.com> Committer: Daniel-Constantin Mierla <miconda(a)gmail.com> Date: 2017-05-08T07:59:56+02:00 log_custom: exported functions to kemi framework --- Modified: src/modules/log_custom/log_custom_mod.c --- Diff: https://github.com/kamailio/kamailio/commit/d5d2bbd4fd6cad48bd0dcf8e577009f… Patch: https://github.com/kamailio/kamailio/commit/d5d2bbd4fd6cad48bd0dcf8e577009f… --- diff --git a/src/modules/log_custom/log_custom_mod.c b/src/modules/log_custom/log_custom_mod.c index b0ecbd7..f88a783 100644 --- a/src/modules/log_custom/log_custom_mod.c +++ b/src/modules/log_custom/log_custom_mod.c @@ -32,6 +32,7 @@ #include "../../core/forward.h" #include "../../core/resolve.h" #include "../../core/udp_server.h" +#include "../../core/kemi.h" MODULE_VERSION @@ -71,52 +72,6 @@ struct module_exports exports = { child_init /* per child init function */ }; - -int mod_register(char *path, int *dlflags, void *p1, void *p2) -{ - str dest = {0}; - int ret = 0; - struct sip_uri next_hop, *u; - char *p; - - if(_km_log_engine_type==0 || _km_log_engine_data==0) - return 0; - - - if(strcasecmp(_km_log_engine_type, "udp")!=0) - return 0; - - dest.s = _km_log_engine_data; - dest.len = strlen(dest.s); - - init_dest_info(&_lc_udp_dst); - - u = &next_hop; - u->port_no = 5060; - u->host = dest; - p = dest.s; - /* detect ipv6 */ - p = memchr(p, ']', dest.len); - if (p) p++; - else p = dest.s; - p = memchr(p, ':', dest.len - (p - dest.s)); - if (p) { - u->host.len = p - dest.s; - p++; - u->port_no = str2s(p, dest.len - (p - dest.s), NULL); - } - - ret = sip_hostport2su(&_lc_udp_dst.to, &u->host, u->port_no, - &_lc_udp_dst.proto); - if(ret!=0) { - LM_ERR("failed to resolve [%.*s]\n", u->host.len, - ZSW(u->host.s)); - return -1;; - } - - return 0; -} - /** * init module function */ @@ -195,3 +150,79 @@ void _lc_core_log_udp(int lpriority, const char *format, ...) va_end(arglist); udp_send(&_lc_udp_dst, obuf, n); } + +int ki_log_udp(sip_msg_t *msg, str *txt) +{ + int ret; + + if(_lc_log_udp==0) + return 1; + + ret=udp_send(&_lc_udp_dst, txt->s, txt->len); + + if(ret==0) return 1; + + return ret; + +} + +/** + * + */ +/* clang-format off */ +static sr_kemi_t sr_kemi_log_custom_exports[] = { + { str_init("log_custom"), str_init("log_udp"), + SR_KEMIP_INT, ki_log_udp, + { 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) +{ + str dest = {0}; + int ret = 0; + struct sip_uri next_hop, *u; + char *p; + + if(_km_log_engine_type==0 || _km_log_engine_data==0) + return 0; + + + if(strcasecmp(_km_log_engine_type, "udp")!=0) + return 0; + + dest.s = _km_log_engine_data; + dest.len = strlen(dest.s); + + init_dest_info(&_lc_udp_dst); + + u = &next_hop; + u->port_no = 5060; + u->host = dest; + p = dest.s; + /* detect ipv6 */ + p = memchr(p, ']', dest.len); + if (p) p++; + else p = dest.s; + p = memchr(p, ':', dest.len - (p - dest.s)); + if (p) { + u->host.len = p - dest.s; + p++; + u->port_no = str2s(p, dest.len - (p - dest.s), NULL); + } + + ret = sip_hostport2su(&_lc_udp_dst.to, &u->host, u->port_no, + &_lc_udp_dst.proto); + if(ret!=0) { + LM_ERR("failed to resolve [%.*s]\n", u->host.len, + ZSW(u->host.s)); + return -1; + } + + sr_kemi_modules_add(sr_kemi_log_custom_exports); + return 0; +}