git:master:72b15ef9: dialog: new rpc function to terminate by sip ids - sr-dev

1 Apr 2016

Module: kamailio
Branch: master
Commit: 72b15ef953bf76f2b4ed9d44886ec6040b04a8b6
URL: https://github.com/kamailio/kamailio/commit/72b15ef953bf76f2b4ed9d44886ec604...
Author: Yasin CANER yasin.caner@netgsm.com.tr
Committer: Daniel-Constantin Mierla miconda@gmail.com
Date: 2016-04-01T09:52:55+02:00
dialog: new rpc function to terminate by sip ids
- end established dialog by matching callid, from and to tags
---
Modified: modules/dialog/dialog.c
---
Diff:  https://github.com/kamailio/kamailio/commit/72b15ef953bf76f2b4ed9d44886ec604...
Patch: https://github.com/kamailio/kamailio/commit/72b15ef953bf76f2b4ed9d44886ec604...
---

diff --git a/modules/dialog/dialog.c b/modules/dialog/dialog.c
index 553715d..db6c3ff 100644
--- a/modules/dialog/dialog.c
+++ b/modules/dialog/dialog.c
@@ -1698,6 +1698,9 @@ static const char *rpc_print_dlg_ctx_doc[2] = {
 static const char *rpc_end_dlg_entry_id_doc[2] = {
    "End a given dialog based on [h_entry] [h_id]", 0
 };
+static const char *rpc_dlg_terminate_dlg_doc[2] = {
+        "End a given dialog based on callid", 0
+};
 static const char *rpc_profile_get_size_doc[2] = {
    "Returns the number of dialogs belonging to a profile", 0
 };
@@ -1722,6 +1725,47 @@ static void rpc_print_dlg(rpc_t *rpc, void *c) {
 static void rpc_print_dlg_ctx(rpc_t *rpc, void *c) {
    internal_rpc_print_single_dlg(rpc, c, 1);
 }
+
+static void rpc_dlg_terminate_dlg(rpc_t *rpc,void *c){
+	str callid = {NULL,0};
+	str ftag = {NULL,0};
+	str ttag = {NULL,0};
+
+	dlg_cell_t * dlg = NULL;
+	unsigned int dir;
+	int ret=0;
+	dir = 0;
+
+
+	if(rpc->scan(c, ".S.S.S", &callid,&ftag,&ttag)<3) {
+		LM_ERR("Unable to read the parameters dlg_terminate_dlg \n" );
+		rpc->fault(c, 400, "Need a Callid ,from tag ,to tag");
+		return;
+	}
+
+	dlg=get_dlg(&callid, &ftag, &ttag, &dir);
+
+	if(dlg==NULL) {
+		LM_ERR("Couldnt find callid in dialog '%.*s' \n",callid.len, callid.s);
+		rpc->fault(c, 500, "Couldnt find callid in dialog");
+		return;
+	}
+
+	LM_DBG("Dialog is found with callid  for terminate rpc '%.*s' \n",
+			callid.len, callid.s);
+
+	ret=dlg_bye_all(dlg, NULL);
+
+	LM_DBG("Dialog bye return code %d \n",ret);
+
+	if(ret>=0) {
+        LM_WARN("Dialog is terminated callid: '%.*s' \n",
+        		callid.len, callid.s);
+        dlg_release(dlg);
+    }
+}
+
+
 static void rpc_end_dlg_entry_id(rpc_t *rpc, void *c) {
    unsigned int h_entry, h_id;
    dlg_cell_t * dlg = NULL;
@@ -1812,5 +1856,6 @@ static rpc_export_t rpc_methods[] = {
    {"dlg.profile_get_size", rpc_profile_get_size, rpc_profile_get_size_doc, 0},
    {"dlg.profile_list", rpc_profile_print_dlgs, rpc_profile_print_dlgs_doc, RET_ARRAY},
    {"dlg.bridge_dlg", rpc_dlg_bridge, rpc_dlg_bridge_doc, 0},
+	{"dlg.terminate_dlg", rpc_dlg_terminate_dlg, rpc_dlg_terminate_dlg_doc, 0},
    {0, 0, 0, 0}
 };

    