From 48686943aa37747a9a7581a5eb8c69098ce324d7 Mon Sep 17 00:00:00 2001 From: Daniel-Constantin Mierla Date: Tue, 26 Feb 2019 18:22:38 +0100 Subject: [PATCH] core: receive - use kemi wrapper to execute top keng routes - reset the select static buffer - GH #1829 --- src/core/receive.c | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/core/receive.c b/src/core/receive.c index 19db2901a73..be12808ea7d 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 {