[sr-dev] git:master:c1ca9f58: modules/ims_dialog: end all active calls

Module: kamailio Branch: master Commit: c1ca9f58c12962c8b1dee715facc47248fd852ca URL: https://github.com/kamailio/kamailio/commit/c1ca9f58c12962c8b1dee715facc472… Author: jaybeepee &lt;jason.penton(a)gmail.com&gt; Committer: jaybeepee &lt;jason.penton(a)gmail.com&gt; Date: 2016-03-29T15:49:14+02:00 modules/ims_dialog: end all active calls --- Modified: modules/ims_dialog/ims_dialog.c --- Diff: https://github.com/kamailio/kamailio/commit/c1ca9f58c12962c8b1dee715facc472… Patch: https://github.com/kamailio/kamailio/commit/c1ca9f58c12962c8b1dee715facc472… --- diff --git a/modules/ims_dialog/ims_dialog.c b/modules/ims_dialog/ims_dialog.c index 8fc37e7..299e6d6 100644 --- a/modules/ims_dialog/ims_dialog.c +++ b/modules/ims_dialog/ims_dialog.c @@ -921,9 +921,9 @@ 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_end_all_active_dlg_doc[2] = { + "End all ACTIVE dialogs", 0 +}; /* Wrapper for terminating dialog from API - from other modules */ static void rpc_end_dlg_entry_id(rpc_t *rpc, void *c) { @@ -957,10 +957,55 @@ static void rpc_end_dlg_entry_id(rpc_t *rpc, void *c) { } +static void rpc_end_all_active_dlg (rpc_t *rpc, void *c) +{ + struct dlg_cell * dlg = NULL, + * dlg_to_term = NULL; + dlg_entry_t entry; + + unsigned int i_count = 0, + h_index = 0; + + str rpc_extra_hdrs = {0,0}; + str dfl_rpc_extra_hdrs = {"Reason: mi_terminated\r\n",23}; + str reason = {"mi_terminated", 12}; + + + if (!d_table) + { + rpc->fault(c, 500, "Dialog hash table not initialized"); + return; + } + if (!d_table->size) return; + + rpc_extra_hdrs = dfl_rpc_extra_hdrs; + LM_DBG("Setting reason to [%.*s] and extra headers to [%.*s]\n", + reason.len, reason.s, rpc_extra_hdrs.len, rpc_extra_hdrs.s); + + for (h_index = 0 ; h_index < d_table->size; h_index++) + { + entry = d_table->entries[h_index]; + dlg_to_term = entry.first; + for (; dlg_to_term;) + { + dlg = dlg_to_term->next ; + if (dlg_to_term->state == DLG_STATE_CONFIRMED) + { + unref_dlg(dlg_to_term, 1); + rpc_extra_hdrs = dfl_rpc_extra_hdrs; + dlg_terminate(dlg_to_term, NULL, &reason/*reason*/, 2, &rpc_extra_hdrs); + i_count++; + } + dlg_to_term = dlg; + } + } + LM_DBG("Terminated %d active dialogs from rpc call",i_count); +} static rpc_export_t rpc_methods[] = { {"dlg2.list", rpc_print_dlgs, rpc_print_dlgs_doc, 0}, {"dlg2.end_dlg", rpc_end_dlg_entry_id, rpc_end_dlg_entry_id_doc, 0}, + {"dlg2.end_all_active_dlg", rpc_end_all_active_dlg, rpc_end_all_active_dlg_doc, 0}, {0, 0, 0, 0} };