Module: kamailio
Branch: master
Commit: 48686943aa37747a9a7581a5eb8c69098ce324d7
URL: 
https://github.com/kamailio/kamailio/commit/48686943aa37747a9a7581a5eb8c69098ce324d7

Author: Daniel-Constantin Mierla <mico...@gmail.com>
Committer: Daniel-Constantin Mierla <mico...@gmail.com>
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/48686943aa37747a9a7581a5eb8c69098ce324d7.diff
Patch: 
https://github.com/kamailio/kamailio/commit/48686943aa37747a9a7581a5eb8c69098ce324d7.patch

---

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 {


_______________________________________________
Kamailio (SER) - Development Mailing List
sr-dev@lists.kamailio.org
https://lists.kamailio.org/cgi-bin/mailman/listinfo/sr-dev

Reply via email to