[sr-dev] git:master:48686943: core: receive - use kemi wrapper to execute top keng routes

Module: kamailio Branch: master Commit: 48686943aa37747a9a7581a5eb8c69098ce324d7 URL: https://github.com/kamailio/kamailio/commit/48686943aa37747a9a7581a5eb8c690… Author: Daniel-Constantin Mierla &lt;miconda(a)gmail.com&gt; Committer: Daniel-Constantin Mierla &lt;miconda(a)gmail.com&gt; Date: 2019-02-26T18:42:23+01:00 core: receive - use kemi wrapper to execute top keng routes - reset the select static buffer - GH #1829 --- Modified: src/core/receive.c --- Diff: https://github.com/kamailio/kamailio/commit/48686943aa37747a9a7581a5eb8c690… Patch: https://github.com/kamailio/kamailio/commit/48686943aa37747a9a7581a5eb8c690… --- diff --git a/src/core/receive.c b/src/core/receive.c index 19db2901a7..be12808ea7 100644 --- a/src/core/receive.c +++ b/src/core/receive.c @@ -326,11 +326,11 @@ int receive_msg(char *buf, unsigned int len, struct receive_info *rcv_info) } if(unlikely(cidlockset)) { rec_lock_set_get(ksr_route_locks_set, cidlockidx); - if(keng->froute(msg, REQUEST_ROUTE, NULL, NULL) < 0) + if(sr_kemi_route(keng, msg, REQUEST_ROUTE, NULL, NULL) < 0) LM_NOTICE("negative return code from engine function\n"); rec_lock_set_release(ksr_route_locks_set, cidlockidx); } else { - if(keng->froute(msg, REQUEST_ROUTE, NULL, NULL) < 0) + if(sr_kemi_route(keng, msg, REQUEST_ROUTE, NULL, NULL) < 0) LM_NOTICE("negative return code from engine function\n"); } } else { @@ -409,10 +409,10 @@ int receive_msg(char *buf, unsigned int len, struct receive_info *rcv_info) sr_kemi_act_ctx_set(&ctx); if(unlikely(cidlockset)) { rec_lock_set_get(ksr_route_locks_set, cidlockidx); - ret = keng->froute(msg, CORE_ONREPLY_ROUTE, NULL, NULL); + ret = sr_kemi_route(keng, msg, CORE_ONREPLY_ROUTE, NULL, NULL); rec_lock_set_release(ksr_route_locks_set, cidlockidx); } else { - ret = keng->froute(msg, CORE_ONREPLY_ROUTE, NULL, NULL); + ret = sr_kemi_route(keng, msg, CORE_ONREPLY_ROUTE, NULL, NULL); } sr_kemi_act_ctx_set(bctx); } else {