[sr-dev] git:master:c1cb68f6: core: execute onsend_route callback via kemi

[Daniel-Constantin Mierla]

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

Author: Daniel-Constantin Mierla <miconda at gmail.com>
Committer: Daniel-Constantin Mierla <miconda at gmail.com>
Date: 2016-04-15T09:00:53+02:00

core: execute onsend_route callback via kemi

---

Modified: onsend.h

---

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

---

diff --git a/onsend.h b/onsend.h
index 2ed68be..2f15663 100644
--- a/onsend.h
+++ b/onsend.h
@@ -13,8 +13,8 @@
  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  * GNU General Public License for more details.
  *
- * You should have received a copy of the GNU General Public License 
- * along with this program; if not, write to the Free Software 
+ * You should have received a copy of the GNU General Public License
+ * along with this program; if not, write to the Free Software
  * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA
  */
 /*!
@@ -34,6 +34,7 @@
 #include "route.h"
 #include "script_cb.h"
 #include "sr_compat.h"
+#include "kemi.h"
 
 struct onsend_info{
 	union sockaddr_union* to;       /* dest info */
@@ -58,10 +59,12 @@ static inline int run_onsend(struct sip_msg* orig_msg, struct dest_info* dst,
 	struct onsend_info onsnd_info = {0};
 	int ret;
 	struct run_act_ctx ra_ctx;
+	struct run_act_ctx *bctx;
 	int backup_route_type;
 	snd_flags_t fwd_snd_flags_bak;
 	snd_flags_t rpl_snd_flags_bak;
-	
+	sr_kemi_eng_t *keng = NULL;
+
 	ret=1;
 	if (onsend_rt.rlist[DEFAULT_RT]){
 		onsnd_info.to=&dst->to;
@@ -78,7 +81,17 @@ static inline int run_onsend(struct sip_msg* orig_msg, struct dest_info* dst,
 			rpl_snd_flags_bak=orig_msg->rpl_send_flags;
 			orig_msg->fwd_send_flags=dst->send_flags; /* intial value */
 			init_run_actions_ctx(&ra_ctx);
-			ret=run_actions(&ra_ctx, onsend_rt.rlist[DEFAULT_RT], orig_msg);
+
+			keng = sr_kemi_eng_get();
+			if(unlikely(keng!=NULL)) {
+				bctx = sr_kemi_act_ctx_get();
+				sr_kemi_act_ctx_set(&ra_ctx);
+				ret=keng->froute(orig_msg, ONSEND_ROUTE, NULL);
+				sr_kemi_act_ctx_set(bctx);
+			} else {
+				ret=run_actions(&ra_ctx, onsend_rt.rlist[DEFAULT_RT], orig_msg);
+			}
+
 			/* update dst send_flags */
 			dst->send_flags=orig_msg->fwd_send_flags;
 			/* restore orig_msg flags */