Module: kamailio
Branch: master
Commit: 48686943aa37747a9a7581a5eb8c69098ce324d7
URL:
https://github.com/kamailio/kamailio/commit/48686943aa37747a9a7581a5eb8c690…
Author: Daniel-Constantin Mierla <miconda(a)gmail.com>
Committer: Daniel-Constantin Mierla <miconda(a)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/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 {