[sr-dev] git:master:1b14fdee: rtimer: support for execution of kemi callback functions

[Daniel-Constantin Mierla]

Module: kamailio
Branch: master
Commit: 1b14fdee7414d84b2c7181958bf29df3256299a7
URL: https://github.com/kamailio/kamailio/commit/1b14fdee7414d84b2c7181958bf29df3256299a7

Author: Daniel-Constantin Mierla <miconda at gmail.com>
Committer: Daniel-Constantin Mierla <miconda at gmail.com>
Date: 2017-10-29T09:06:52+01:00

rtimer: support for execution of kemi callback functions

---

Modified: src/modules/rtimer/rtimer_mod.c

---

Diff:  https://github.com/kamailio/kamailio/commit/1b14fdee7414d84b2c7181958bf29df3256299a7.diff
Patch: https://github.com/kamailio/kamailio/commit/1b14fdee7414d84b2c7181958bf29df3256299a7.patch

---

diff --git a/src/modules/rtimer/rtimer_mod.c b/src/modules/rtimer/rtimer_mod.c
index 41bac5c281..24b32ec329 100644
--- a/src/modules/rtimer/rtimer_mod.c
+++ b/src/modules/rtimer/rtimer_mod.c
@@ -40,6 +40,7 @@
 #include "../../core/script_cb.h"
 #include "../../core/parser/parse_param.h"
 #include "../../core/fmsg.h"
+#include "../../core/kemi.h"
 
 
 MODULE_VERSION
@@ -183,6 +184,8 @@ void stm_timer_exec(unsigned int ticks, void *param)
 	stm_timer_t *it;
 	stm_route_t *rt;
 	sip_msg_t *fmsg;
+	sr_kemi_eng_t *keng = NULL;
+	str evname = str_init("rtimer");
 
 	if(param==NULL)
 		return;
@@ -196,7 +199,15 @@ void stm_timer_exec(unsigned int ticks, void *param)
 		if (exec_pre_script_cb(fmsg, REQUEST_CB_TYPE)==0 )
 			continue; /* drop the request */
 		set_route_type(REQUEST_ROUTE);
-		run_top_route(main_rt.rlist[rt->route], fmsg, 0);
+		keng = sr_kemi_eng_get();
+		if(keng==NULL) {
+			run_top_route(main_rt.rlist[rt->route], fmsg, 0);
+		} else {
+			if(keng->froute(fmsg, EVENT_ROUTE, &rt->route_name, &evname)<0) {
+				LM_ERR("error running event route kemi callback [%.*s]\n",
+						rt->route_name.len, rt->route_name.s);
+			}
+		}
 		exec_post_script_cb(fmsg, REQUEST_CB_TYPE);
 		ksr_msg_env_reset();
 	}