sr-dev April 2016

sr-dev@lists.kamailio.org

23 participants
430 discussions

git:master:6f268b5a: erlang: fix register server process with the local name server epmd

by Seudin Kasumovic

Module: kamailio Branch: master Commit: 6f268b5a9d0bd07e689c401cb7221bb0f2c5f8be URL: https://github.com/kamailio/kamailio/commit/6f268b5a9d0bd07e689c401cb7221bb… Author: Seudin Kasumovic <seudin.kasumovic(a)gmail.com> Committer: Seudin Kasumovic <seudin.kasumovic(a)gmail.com> Date: 2016-04-13T08:44:09+02:00 erlang: fix register server process with the local name server epmd - use correct alive name when number of C nodes greater then 1 - fix error check on register server process --- Modified: modules/erlang/cnode.c Modified: modules/erlang/epmd.c Modified: modules/erlang/epmd.h Modified: modules/erlang/erl_helpers.c --- Diff: https://github.com/kamailio/kamailio/commit/6f268b5a9d0bd07e689c401cb7221bb… Patch: https://github.com/kamailio/kamailio/commit/6f268b5a9d0bd07e689c401cb7221bb… --- diff --git a/modules/erlang/cnode.c b/modules/erlang/cnode.c index f0f6e03..1e9b5d6 100644 --- a/modules/erlang/cnode.c +++ b/modules/erlang/cnode.c @@ -226,7 +226,7 @@ int init_cnode_sockets(int cnode_id) io_handler_ins(phandler); /* start epmd handler - publish Kamailo C node */ - if (epmd_init((epmd_handler_t*)phandler) < 0 ) { + if (epmd_init((epmd_handler_t*)phandler, &alivename) < 0 ) { return -1; } diff --git a/modules/erlang/epmd.c b/modules/erlang/epmd.c index 3a47e0f..43889aa 100644 --- a/modules/erlang/epmd.c +++ b/modules/erlang/epmd.c @@ -39,9 +39,9 @@ /** * \brief Initialize EPMD handler */ -int epmd_init(epmd_handler_t *epmd) +int epmd_init(epmd_handler_t *epmd, str *alivename) { - epmd->sockfd = erl_init_node(&epmd->ec, &cnode_alivename, &cnode_host, &cookie); + epmd->sockfd = erl_init_node(&epmd->ec, alivename, &cnode_host, &cookie); epmd->handle_f = handle_epmd; epmd->wait_tmo_f = NULL; epmd->destroy_f = NULL; diff --git a/modules/erlang/epmd.h b/modules/erlang/epmd.h index d5d4507..09b3eb5 100644 --- a/modules/erlang/epmd.h +++ b/modules/erlang/epmd.h @@ -55,7 +55,7 @@ typedef struct epmd_handler_s } epmd_handler_t; -int epmd_init(epmd_handler_t *epmd); +int epmd_init(epmd_handler_t *epmd, str *alivename); int handle_epmd(handler_common_t *phandler); #endif /* EPMD_H_ */ diff --git a/modules/erlang/erl_helpers.c b/modules/erlang/erl_helpers.c index cc43e92..f702a8b 100644 --- a/modules/erlang/erl_helpers.c +++ b/modules/erlang/erl_helpers.c @@ -307,9 +307,9 @@ int erl_init_node(ei_cnode *ec, const str *alivename, const str *hostname, const sockaddr2ip_addr(&ip, addr); /* publish */ - if ((epmdfd = ei_publish_tmo(ec, port, timeout_ms)) == -1) { + if ((epmdfd = ei_publish_tmo(ec, port, timeout_ms)) < 0) { - LM_ERR("Failed to publish port %u to epmd, check is epmd started\n", port); + LM_DBG("Failed publish %s:%u[%u] as %s: %s (%d)\n",ip_addr2strz(&ip),port,listen_fd,nodename, strerror(erl_errno), epmdfd); erl_close_socket(listen_fd); return -1;

8 years, 8 months

Kamailio 5.0 - Routing blocks in embedded scripting languages - Lua

by Daniel-Constantin Mierla

Hello, based on some of the plans for Kamailio 5.0 (https://www.kamailio.org/wiki/devel/kamailio-5.0-design), I started the implementation for the support to allow writing the active routing logic at runtime (respectively what are now the routing blocks) in other embedded languages than the native kamailio.cfg interpreter. Of course, besides a lot more extensive set of functions and expressions coming with the well established scripting languages, this way will allow reloading the logic without kamailio restart. I already committed the foundation for it, currently the request_route{} and reply_route{} can be implemented in Lua, relying on app_lua module. Lua was selected for first experiments given that I have some past experience with it, but other languages such as Perl, Python will hopefully follow soon, once the framework gets to a stable design. I wrote some initial docuentation on the wiki: - https://www.kamailio.org/wiki/devel/config-engines Would be helpful if people with experience on the other supported embedded languages will join the effort to design the framework to suit those languages, as well as other developers and community members to start exporting C functions. Also, there are some other things to decide on, listed in the to-do section, where suggestions/assistance are appreciated: - https://www.kamailio.org/wiki/devel/config-engines#to-do Many of them probably will be approached during the planned IRC devel meeting next week: - https://www.kamailio.org/wiki/devel/irc-meetings/2016a Any feedback is welcome! Cheers, Daniel -- Daniel-Constantin Mierla http://www.asipto.com http://twitter.com/#!/miconda - http://www.linkedin.com/in/miconda Kamailio World Conference, Berlin, May 18-20, 2016 - http://www.kamailioworld.com

8 years, 8 months

git:master:48855141: Merge pull request #565 from kamailio/sd_journal_send_xavp

by Camille Oudot

Module: kamailio Branch: master Commit: 4885514109c5b08e928623211444a2426944123d URL: https://github.com/kamailio/kamailio/commit/4885514109c5b08e928623211444a24… Author: Camille Oudot <camille.oudot(a)orange.com> Committer: Camille Oudot <camille.oudot(a)orange.com> Date: 2016-04-12T14:55:55+02:00 Merge pull request #565 from kamailio/sd_journal_send_xavp new function in log_systemd module to log structured events --- Added: modules/log_systemd/journal_send.c Added: modules/log_systemd/journal_send.h Modified: modules/log_systemd/README Modified: modules/log_systemd/doc/log_systemd_admin.xml Modified: modules/log_systemd/log_systemd_mod.c --- Diff: https://github.com/kamailio/kamailio/commit/4885514109c5b08e928623211444a24… Patch: https://github.com/kamailio/kamailio/commit/4885514109c5b08e928623211444a24…

8 years, 8 months

git:master:2dbcd56c: log_systemd: refresh README

by Camille Oudot

Module: kamailio Branch: master Commit: 2dbcd56c69db94543c355d936f486d2f525855e5 URL: https://github.com/kamailio/kamailio/commit/2dbcd56c69db94543c355d936f486d2… Author: Camille Oudot <camille.oudot(a)orange.com> Committer: Camille Oudot <camille.oudot(a)orange.com> Date: 2016-04-12T13:47:12+02:00 log_systemd: refresh README --- Modified: modules/log_systemd/README --- Diff: https://github.com/kamailio/kamailio/commit/2dbcd56c69db94543c355d936f486d2… Patch: https://github.com/kamailio/kamailio/commit/2dbcd56c69db94543c355d936f486d2… --- diff --git a/modules/log_systemd/README b/modules/log_systemd/README index 36b2b5c..9453ec0 100644 --- a/modules/log_systemd/README +++ b/modules/log_systemd/README @@ -27,11 +27,13 @@ Daniel-Constantin Mierla 4. Functions 4.1. sd_journal_print(level, text) + 4.2. sd_journal_send_xavp(name) List of Examples 1.1. Core Logging Replacement with Systemd 1.2. sd_journal_print usage + 1.3. sd_journal_send_xavp usage Chapter 1. Admin Guide @@ -47,6 +49,7 @@ Chapter 1. Admin Guide 4. Functions 4.1. sd_journal_print(level, text) + 4.2. sd_journal_send_xavp(name) 1. Overview @@ -88,6 +91,7 @@ loadmodule "log_systemd.so" 4. Functions 4.1. sd_journal_print(level, text) + 4.2. sd_journal_send_xavp(name) 4.1. sd_journal_print(level, text) @@ -104,3 +108,38 @@ loadmodule "log_systemd.so" ... sd_journal_print("LOG_INFO", "R-URI is $ru\n"); ... + +4.2. sd_journal_send_xavp(name) + + Creates a structured log event in journald. + + The sd_journal_send_xavp(name) function sends a log event in journald, + based on the fields provided in the xavp whose root name is specified + as parameter. This function is a wrapper for journald's + sd_journal_send() function, and allows to specify as many custom fields + as desired (see sd_journal_send(3)). + + The xavp given as parameter must contain child AVPs with names + conforming to journald's field name policy (only uppercase letters, + numbers and underscore), otherwise they will be discarded by journald. + + Some field name have a default meaning for journald: + * MESSAGE: the human-readable message string for this entry. + * PRIORTTY: integer priority value between 0 ("emerg") and 7 + ("debug") + * (...) (see systemd.journald-fields(7)) + + This function can be used from ANY_ROUTE. + + Example 1.3. sd_journal_send_xavp usage +request_route { + $xavp(event=>MESSAGE) = $rm + " request logged with journald"; + $xavp(event[0]=>SIP_MESSAGE) = $mb; +# don't forget the '[0]', otherwise kamailio will create and +# stack new AVPs (see pseudovariable documentation) over the previous one + $xavp(event[0]=>SIP_CALL_ID) = $ci; + $xavp(event[0]=>SIP_SRC_PORT) = $sp; + $xavp(event[0]=>PRIORITY) = 6; + sd_journal_send_xavp("event"); +(...) +}

8 years, 8 months

git:master:af869eec: log_systemd: new function `sd_journal_send_xavp`

by Camille Oudot

Module: kamailio Branch: master Commit: af869eec1cdba097a70101130c8ee3e6de3aff42 URL: https://github.com/kamailio/kamailio/commit/af869eec1cdba097a70101130c8ee3e… Author: Camille Oudot <camille.oudot(a)orange.com> Committer: Camille Oudot <camille.oudot(a)orange.com> Date: 2016-04-12T13:47:12+02:00 log_systemd: new function `sd_journal_send_xavp` creates a structured log event in journald --- Added: modules/log_systemd/journal_send.c Added: modules/log_systemd/journal_send.h Modified: modules/log_systemd/doc/log_systemd_admin.xml Modified: modules/log_systemd/log_systemd_mod.c --- Diff: https://github.com/kamailio/kamailio/commit/af869eec1cdba097a70101130c8ee3e… Patch: https://github.com/kamailio/kamailio/commit/af869eec1cdba097a70101130c8ee3e…

8 years, 8 months

[kamailio/kamailio] new function in log_systemd function to log structured events (#565)

by Camille Oudot

Journald can store arbitrary **KEY=>values[]** properties for each log event. The `sd_journal_send_xavp()` function is a binding on journald's `sd_journal_sendv()` function, that allows pushing structured events in journald, using the fields from a xavp. (use `journald --output json-pretty` to see all the fields for the events in the journal) You can view, comment on, or merge this pull request online at: https://github.com/kamailio/kamailio/pull/565 -- Commit Summary -- * log_systemd: new function `sd_journal_send_xavp` * log_systemd: refresh README -- File Changes -- M modules/log_systemd/README (39) M modules/log_systemd/doc/log_systemd_admin.xml (56) A modules/log_systemd/journal_send.c (123) A modules/log_systemd/journal_send.h (31) M modules/log_systemd/log_systemd_mod.c (16) -- Patch Links -- https://github.com/kamailio/kamailio/pull/565.patch https://github.com/kamailio/kamailio/pull/565.diff --- You are receiving this because you are subscribed to this thread. Reply to this email directly or view it on GitHub: https://github.com/kamailio/kamailio/pull/565

8 years, 8 months

git:master:44d41c44: app_lua: option to silently try to run a lua function

by Daniel-Constantin Mierla

Module: kamailio Branch: master Commit: 44d41c446e8f42c1ca008e8f37396da61c1f181b URL: https://github.com/kamailio/kamailio/commit/44d41c446e8f42c1ca008e8f37396da… Author: Daniel-Constantin Mierla <miconda(a)gmail.com> Committer: Daniel-Constantin Mierla <miconda(a)gmail.com> Date: 2016-04-12T14:43:52+02:00 app_lua: option to silently try to run a lua function - if lua function not found, do not write error message - some routing blocks are optional (e.g., reply_route{}) and their equivalent may not be defined --- Modified: modules/app_lua/app_lua_api.c Modified: modules/app_lua/app_lua_api.h Modified: modules/app_lua/app_lua_mod.c --- Diff: https://github.com/kamailio/kamailio/commit/44d41c446e8f42c1ca008e8f37396da… Patch: https://github.com/kamailio/kamailio/commit/44d41c446e8f42c1ca008e8f37396da… --- diff --git a/modules/app_lua/app_lua_api.c b/modules/app_lua/app_lua_api.c index ee3a0f1..5a603df 100644 --- a/modules/app_lua/app_lua_api.c +++ b/modules/app_lua/app_lua_api.c @@ -621,8 +621,8 @@ int app_lua_runstring(struct sip_msg *msg, char *script) /** * */ -int app_lua_run(struct sip_msg *msg, char *func, char *p1, char *p2, - char *p3) +int app_lua_run_ex(sip_msg_t *msg, char *func, char *p1, char *p2, + char *p3, int emode) { int n; int ret; @@ -648,13 +648,17 @@ int app_lua_run(struct sip_msg *msg, char *func, char *p1, char *p2, lua_getglobal(_sr_L_env.LL, func); if(!lua_isfunction(_sr_L_env.LL, -1)) { - LM_ERR("no such function [%s] in lua scripts\n", func); - LM_ERR("top stack type [%d - %s]\n", + if(emode) { + LM_ERR("no such function [%s] in lua scripts\n", func); + LM_ERR("top stack type [%d - %s]\n", lua_type(_sr_L_env.LL, -1), lua_typename(_sr_L_env.LL,lua_type(_sr_L_env.LL, -1))); - txt = (char*)lua_tostring(_sr_L_env.LL, -1); - LM_ERR("error from Lua: %s\n", (txt)?txt:"unknown"); - return -1; + txt = (char*)lua_tostring(_sr_L_env.LL, -1); + LM_ERR("error from Lua: %s\n", (txt)?txt:"unknown"); + return -1; + } else { + return 1; + } } n = 0; if(p1!=NULL) @@ -687,6 +691,15 @@ int app_lua_run(struct sip_msg *msg, char *func, char *p1, char *p2, return 1; } +/** + * + */ +int app_lua_run(sip_msg_t *msg, char *func, char *p1, char *p2, + char *p3) +{ + return app_lua_run_ex(msg, func, p1, p2, p3, 1); +} + void app_lua_dump_stack(lua_State *L) { int i; diff --git a/modules/app_lua/app_lua_api.h b/modules/app_lua/app_lua_api.h index dea48b0..4182184 100644 --- a/modules/app_lua/app_lua_api.h +++ b/modules/app_lua/app_lua_api.h @@ -72,8 +72,10 @@ int sr_lua_reload_module(unsigned int reload); int app_lua_dostring(struct sip_msg *msg, char *script); int app_lua_dofile(struct sip_msg *msg, char *script); int app_lua_runstring(struct sip_msg *msg, char *script); -int app_lua_run(struct sip_msg *msg, char *func, char *p1, char *p2, +int app_lua_run(sip_msg_t *msg, char *func, char *p1, char *p2, char *p3); +int app_lua_run_ex(sip_msg_t *msg, char *func, char *p1, char *p2, + char *p3, int emode); #define SRLUA_FALSE 0 #define SRLUA_TRUE 1 diff --git a/modules/app_lua/app_lua_mod.c b/modules/app_lua/app_lua_mod.c index 693d2c8..11134ea 100644 --- a/modules/app_lua/app_lua_mod.c +++ b/modules/app_lua/app_lua_mod.c @@ -112,9 +112,9 @@ int sr_kemi_config_engine_lua(sip_msg_t *msg, int rtype, str *rname) int ret; if(rtype==REQUEST_ROUTE) { - ret = app_lua_run(msg, "ksr_request_route", NULL, NULL, NULL); + ret = app_lua_run_ex(msg, "ksr_request_route", NULL, NULL, NULL, 1); } else if(rtype==CORE_ONREPLY_ROUTE) { - ret = app_lua_run(msg, "ksr_reply_route", NULL, NULL, NULL); + ret = app_lua_run_ex(msg, "ksr_reply_route", NULL, NULL, NULL, 0); } else { if(rname!=NULL) { LM_ERR("route type %d with name [%.*s] not implemented\n",

8 years, 8 months

git:master:41359ef2: core: kemi - skip "native" and "default" config engines names

by Daniel-Constantin Mierla

Module: kamailio Branch: master Commit: 41359ef2f2e106548b39d5b21b625a72a5c5bb60 URL: https://github.com/kamailio/kamailio/commit/41359ef2f2e106548b39d5b21b625a7… Author: Daniel-Constantin Mierla <miconda(a)gmail.com> Committer: Daniel-Constantin Mierla <miconda(a)gmail.com> Date: 2016-04-12T14:18:19+02:00 core: kemi - skip "native" and "default" config engines names - reserved for the existing kamailio.cfg interpreter --- Modified: kemi.c Modified: kemi.h --- Diff: https://github.com/kamailio/kamailio/commit/41359ef2f2e106548b39d5b21b625a7… Patch: https://github.com/kamailio/kamailio/commit/41359ef2f2e106548b39d5b21b625a7… --- diff --git a/kemi.c b/kemi.c index 22f55c0..76a67e1 100644 --- a/kemi.c +++ b/kemi.c @@ -187,6 +187,9 @@ int sr_kemi_eng_register(str *ename, sr_kemi_eng_route_f froute) _sr_kemi_eng_list[_sr_kemi_eng_list_size].froute = froute; _sr_kemi_eng_list_size++; + LM_DBG("registered config routing enginge [%.*s]", + ename->len, ename->s); + return 0; } @@ -197,6 +200,14 @@ int sr_kemi_eng_set(str *ename, str *cpath) { int i; + /* skip native and default */ + if(ename->len==6 && strncasecmp(ename->s, "native", 6)==0) { + return 0; + } + if(ename->len==7 && strncasecmp(ename->s, "default", 7)==0) { + return 0; + } + for(i=0; i<_sr_kemi_eng_list_size; i++) { if(_sr_kemi_eng_list[i].ename.len==ename->len && strncasecmp(_sr_kemi_eng_list[i].ename.s, ename->s, @@ -209,6 +220,27 @@ int sr_kemi_eng_set(str *ename, str *cpath) return -1; } +/** + * + */ +int sr_kemi_eng_setz(char *ename, char *cpath) +{ + str sname; + str spath; + + sname.s = ename; + sname.len = strlen(ename); + + if(cpath!=0) { + spath.s = cpath; + spath.len = strlen(cpath); + return sr_kemi_eng_set(&sname, &spath); + } else { + return sr_kemi_eng_set(&sname, NULL); + } +} + + sr_kemi_eng_t* sr_kemi_eng_get(void) { return _sr_kemi_eng; diff --git a/kemi.h b/kemi.h index c0087c6..19e328b 100644 --- a/kemi.h +++ b/kemi.h @@ -100,6 +100,7 @@ typedef struct sr_kemi_eng { int sr_kemi_eng_register(str *ename, sr_kemi_eng_route_f froute); int sr_kemi_eng_set(str *ename, str *cpath); +int sr_kemi_eng_setz(char *ename, char *cpath); sr_kemi_eng_t* sr_kemi_eng_get(void); #endif

8 years, 8 months

git:master:6500dda7: app_lua: implemented alternative config file interpreting engine

by Daniel-Constantin Mierla

Module: kamailio Branch: master Commit: 6500dda7ac1729c1ddf0600de2c1b679f74fba6f URL: https://github.com/kamailio/kamailio/commit/6500dda7ac1729c1ddf0600de2c1b67… Author: Daniel-Constantin Mierla <miconda(a)gmail.com> Committer: Daniel-Constantin Mierla <miconda(a)gmail.com> Date: 2016-04-12T14:16:44+02:00 app_lua: implemented alternative config file interpreting engine - can be used to execute routing logic for SIP requests and responses by using next statement in kamailio.cfg: cfgengine="lua" --- Modified: modules/app_lua/app_lua_mod.c --- Diff: https://github.com/kamailio/kamailio/commit/6500dda7ac1729c1ddf0600de2c1b67… Patch: https://github.com/kamailio/kamailio/commit/6500dda7ac1729c1ddf0600de2c1b67… --- diff --git a/modules/app_lua/app_lua_mod.c b/modules/app_lua/app_lua_mod.c index 3bd1289..693d2c8 100644 --- a/modules/app_lua/app_lua_mod.c +++ b/modules/app_lua/app_lua_mod.c @@ -29,6 +29,7 @@ #include "../../mod_fix.h" #include "../../rpc.h" #include "../../rpc_lookup.h" +#include "../../kemi.h" #include "app_lua_api.h" @@ -103,9 +104,49 @@ struct module_exports exports = { child_init /* per child init function */ }; +/** + * + */ +int sr_kemi_config_engine_lua(sip_msg_t *msg, int rtype, str *rname) +{ + int ret; + + if(rtype==REQUEST_ROUTE) { + ret = app_lua_run(msg, "ksr_request_route", NULL, NULL, NULL); + } else if(rtype==CORE_ONREPLY_ROUTE) { + ret = app_lua_run(msg, "ksr_reply_route", NULL, NULL, NULL); + } else { + if(rname!=NULL) { + LM_ERR("route type %d with name [%.*s] not implemented\n", + rtype, rname->len, rname->s); + } else { + LM_ERR("route type %d with no name not implemented\n", + rtype); + } + } + + if(rname!=NULL) { + LM_DBG("execution of route type %d with name [%.*s] returned %d\n", + rtype, rname->len, rname->s, ret); + } else { + LM_DBG("execution of route type %d with no name returned %d\n", + rtype, ret); + } + + return 1; +} + +/** + * + */ int mod_register(char *path, int *dlflags, void *p1, void *p2) { + str ename = str_init("lua"); + *dlflags = RTLD_NOW | RTLD_GLOBAL; + + sr_kemi_eng_register(&ename, sr_kemi_config_engine_lua); + return 0; }

8 years, 8 months

git:master:ab2ca4c9: core: ability to run alternative request_route and reply_route handlers

by Daniel-Constantin Mierla

Module: kamailio Branch: master Commit: ab2ca4c9145a537136ea81a21bf257af50bfd18d URL: https://github.com/kamailio/kamailio/commit/ab2ca4c9145a537136ea81a21bf257a… Author: Daniel-Constantin Mierla <miconda(a)gmail.com> Committer: Daniel-Constantin Mierla <miconda(a)gmail.com> Date: 2016-04-12T14:14:15+02:00 core: ability to run alternative request_route and reply_route handlers - they can be offered by the embedded interpreters - at this moment app_lua can execute functions from the script loaded with param 'load': - instead of request_route it executes ksr_request_route() - instead of reply_route it executes ksr_reply_route() --- Modified: receive.c --- Diff: https://github.com/kamailio/kamailio/commit/ab2ca4c9145a537136ea81a21bf257a… Patch: https://github.com/kamailio/kamailio/commit/ab2ca4c9145a537136ea81a21bf257a… --- diff --git a/receive.c b/receive.c index 0904de1..67c7df0 100644 --- a/receive.c +++ b/receive.c @@ -54,6 +54,7 @@ #include "tcp_options.h" /* for access to tcp_accept_aliases*/ #include "cfg/cfg.h" #include "core_stats.h" +#include "kemi.h" #ifdef DEBUG_DMALLOC #include <mem/dmalloc.h> @@ -125,6 +126,7 @@ int receive_msg(char* buf, unsigned int len, struct receive_info* rcv_info) #endif str inb; sr_net_info_t netinfo; + sr_kemi_eng_t *keng = NULL; if(sr_event_enabled(SREV_NET_DATA_RECV)) { if(sip_check_fline(buf, len)==0) { @@ -237,9 +239,20 @@ int receive_msg(char* buf, unsigned int len, struct receive_info* rcv_info) set_route_type(REQUEST_ROUTE); /* exec the routing script */ - if (run_top_route(main_rt.rlist[DEFAULT_RT], msg, 0)<0){ - LM_WARN("error while trying script\n"); - goto error_req; + if(unlikely(main_rt.rlist[DEFAULT_RT]==NULL)) { + keng = sr_kemi_eng_get(); + if(keng==NULL) { + LM_ERR("no config routing engine registered\n"); + goto error_req; + } + if(keng->froute(msg, REQUEST_ROUTE, NULL)<0) { + LM_NOTICE("negative return code from engine function\n"); + } + } else { + if (run_top_route(main_rt.rlist[DEFAULT_RT], msg, 0)<0){ + LM_WARN("error while trying script\n"); + goto error_req; + } } #ifdef STATS @@ -283,7 +296,15 @@ int receive_msg(char* buf, unsigned int len, struct receive_info* rcv_info) /* exec the onreply routing script */ if (onreply_rt.rlist[DEFAULT_RT]){ set_route_type(CORE_ONREPLY_ROUTE); - ret=run_top_route(onreply_rt.rlist[DEFAULT_RT], msg, &ctx); + ret = 1; + if(unlikely(main_rt.rlist[DEFAULT_RT]==NULL)) { + keng = sr_kemi_eng_get(); + if(keng!=NULL) { + ret = keng->froute(msg, REQUEST_ROUTE, NULL); + } + } else { + ret=run_top_route(onreply_rt.rlist[DEFAULT_RT], msg, &ctx); + } #ifndef NO_ONREPLY_ROUTE_ERROR if (unlikely(ret<0)){ LM_WARN("error while trying onreply script\n");

8 years, 8 months

← Newer
1
...
27
28
29
30
31
32
33
...
43
Older →

Jump to page:

2024

2023

2022

2021

2020

2019

2018

2017

2016

2015

2014

2013

2012

2011

2010

2009

2008

sr-dev April 2016