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

Daniel-Constantin Mierla miconda at gmail.com
Tue Feb 26 18:42:54 CET 2019


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

Author: Daniel-Constantin Mierla <miconda at gmail.com>
Committer: Daniel-Constantin Mierla <miconda at 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 {




More information about the sr-dev mailing list