nexmon – Rev 1

Subversion Repositories:
Rev:
/* voip_calls_dlg.c
 * VoIP calls summary addition for Wireshark
 *
 * Copyright 2004, Ericsson , Spain
 * By Francisco Alcoba <francisco.alcoba@ericsson.com>
 *
 * based on h323_calls_dlg.c
 * Copyright 2004, Iskratel, Ltd, Kranj
 * By Miha Jemec <m.jemec@iskratel.si>
 *
 * H323, RTP and Graph Support
 * By Alejandro Vaquero, alejandro.vaquero@verso.com
 * Copyright 2005, Verso Technologies Inc.
 *
 * Wireshark - Network traffic analyzer
 * By Gerald Combs <gerald@wireshark.org>
 * Copyright 1998 Gerald Combs
 *
 * This program is free software; you can redistribute it and/or
 * modify it under the terms of the GNU General Public License
 * as published by the Free Software Foundation; either version 2
 * of the License, or (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * 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
 * Foundation,  Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
 */

#include "config.h"

#include <string.h>

#include <epan/packet.h>
#include <epan/stat_tap_ui.h>
#include <epan/addr_resolv.h>
#include <epan/dissectors/packet-h225.h>
#include <epan/dissectors/packet-h248.h>

#include <wsutil/str_util.h>

#include "../../globals.h"

#include "ui/voip_calls.h"

#include "ui/gtk/graph_analysis.h"
#include "ui/gtk/voip_calls_dlg.h"
#include "ui/gtk/gui_stat_menu.h"
#include "ui/gtk/dlg_utils.h"
#include "ui/gtk/gui_utils.h"
#include "ui/gtk/gtkglobals.h"
#include "ui/gtk/stock_icons.h"

#ifdef HAVE_LIBPORTAUDIO
#include "ui/tap-rtp-analysis.h"
#include "ui/gtk/rtp_player.h"
#endif /* HAVE_LIBPORTAUDIO */

#include "ui/gtk/old-gtk-compat.h"

void register_tap_listener_voip_calls_dlg(void);

/****************************************************************************/
/* pointer to the one and only dialog window */
static GtkWidget *voip_calls_dlg = NULL;

static GtkListStore *list_store  = NULL;
static GtkTreeIter list_iter;
static GtkWidget *list           = NULL;

static GtkWidget *top_label      = NULL;
static GtkWidget *status_label   = NULL;

/*static GtkWidet *bt_unselect   = NULL;*/
static GtkWidget *bt_filter      = NULL;
static GtkWidget *bt_graph       = NULL;
#ifdef HAVE_LIBPORTAUDIO
static GtkWidget *bt_player      = NULL;
#endif /* HAVE_LIBPORTAUDIO */

static guint32 calls_nb = 0;     /* number of displayed calls */
static guint32 calls_ns = 0;     /* number of selected calls */

static graph_analysis_data_t *graph_analysis_data = NULL;

enum
{
        CALL_COL_START_TIME,
        CALL_COL_STOP_TIME,
        CALL_COL_INITIAL_SPEAKER,
        CALL_COL_FROM,
        CALL_COL_TO,
        CALL_COL_PROTOCOL,
        CALL_COL_PACKETS,
        CALL_COL_STATE,
        CALL_COL_COMMENTS,
        CALL_COL_DATA,
        NUM_COLS /* The number of columns */
};

/* functions for tap_listeners in voip_calls.c */
static void voip_calls_dlg_reset(void *ptr);
static gboolean voip_calls_dlg_packet(void *ptr, packet_info *pinfo, epan_dissect_t *edt, const void *data);
static void voip_calls_dlg_draw(void *ptr);


/****************************************************************************/
/**
 * Retrieves a constant reference to the unique info structure of the voip_calls tap listener.
 * The user should not modify the data pointed to.
 */
static voip_calls_tapinfo_t*
voip_calls_get_info(void)
{
        /* the one and only global voip_calls_tapinfo_t structure */
        static voip_calls_tapinfo_t the_tapinfo_struct =
        {
                voip_calls_dlg_reset, voip_calls_dlg_packet, voip_calls_dlg_draw, NULL,
                0, NULL, {0}, 0, NULL, 0, 0, 0, NULL, NULL,
                0, NULL, /* rtp */
                0, 0, FALSE, /* rtp evt */
                NULL, 0, /* sdp */
                0, 0, 0, 0, /* mtp3 */
                NULL, /* h245 */
                NULL, NULL, 0, 0, 0, /* q931 */
                0, 0, H225_OTHER, FALSE, /* h225 */
                0, /* SIP */
                0, 0, 0, /* actrace */
                FLOW_ALL, /* flow show option */
                0 };
        if (!the_tapinfo_struct.session) {
                the_tapinfo_struct.session = cfile.epan;
        }
        if (!the_tapinfo_struct.callsinfos) {
                /* not initialized yet */
                the_tapinfo_struct.callsinfos = g_queue_new();
        }
        return &the_tapinfo_struct;
}

/****************************************************************************/
static gboolean have_voip_calls_tap_listeners = FALSE;

static void
voip_calls_dlg_remove_tap_listeners(voip_calls_tapinfo_t* tap_id_base)
{
        voip_calls_remove_all_tap_listeners(tap_id_base);

        have_voip_calls_tap_listeners = FALSE;
}

/****************************************************************************/
/* CALLBACKS                                                                */
/****************************************************************************/
static void
voip_calls_on_destroy(GObject *object _U_, gpointer user_data _U_)
{
        /* remove_tap_listeners */
        voip_calls_dlg_remove_tap_listeners(voip_calls_get_info());

        /* Clean up memory used by calls tap */
        voip_calls_dlg_reset(NULL);

        /* Note that we no longer have a "VoIP Calls" dialog box. */
        voip_calls_dlg = NULL;

        /* Clean up graph analysis memory */
        g_free(graph_analysis_data);
        graph_analysis_data = NULL;
}

/****************************************************************************/
static void
voip_calls_on_unselect(GtkButton *button _U_, gpointer user_data _U_)
{
        /*gtk_widget_set_sensitive(bt_unselect, FALSE);*/
        gtk_widget_set_sensitive(bt_filter, FALSE);
        gtk_widget_set_sensitive(bt_graph, FALSE);
#ifdef HAVE_LIBPORTAUDIO
        gtk_widget_set_sensitive(bt_player, FALSE);
#endif /* HAVE_LIBPORTAUDIO */
}

/****************************************************************************/
static void
voip_calls_on_filter(GtkButton *button _U_, gpointer user_data _U_)
{
        gchar *filter_string;
        GString *filter_string_fwd;
        const gchar *filter_prepend;
        gboolean is_first = TRUE;
        GList* lista;
        GList* listb;
        voip_calls_info_t *listinfo;
        seq_analysis_item_t *gai;
        size_t filter_length;
        size_t max_filter_length = 2048; /* What's this based on ? */
        int pos;
        char *addr_str, *guid_str;

        const sip_calls_info_t *sipinfo;
        const isup_calls_info_t *isupinfo;
        const h323_calls_info_t *h323info;
        const h245_address_t *h245_add = NULL;
        const gcp_ctx_t* ctx;

        filter_string = g_strdup(gtk_entry_get_text(GTK_ENTRY(main_display_filter_widget)));
        filter_length = strlen(filter_string);
        pos = (int)filter_length;       /* we assume the filter won't be more than 2^31-1 octets long */
        g_strstrip(filter_string);

        if (strlen(filter_string) > 0)
                filter_prepend = " or ";
        else
                filter_prepend = "";
        g_free(filter_string);

        filter_string_fwd = g_string_new(filter_prepend);

        /* look in the Graph and get all the frame_num for this call */
        g_string_append_printf(filter_string_fwd, "(");

        /* Build a new filter based on frame numbers */
        lista = g_queue_peek_nth_link(voip_calls_get_info()->callsinfos, 0);
        while (lista) {
                listinfo = (voip_calls_info_t *)lista->data;
                if (listinfo->selected) {
                        listb = g_queue_peek_nth_link(voip_calls_get_info()->graph_analysis->items, 0);
                        while (listb) {
                                gai = (seq_analysis_item_t *)listb->data;
                                if (gai->conv_num == listinfo->call_num) {
                                        g_string_append_printf(filter_string_fwd, "%sframe.number == %u", is_first?"":" or ", gai->frame_number);
                                        is_first = FALSE;
                                }
                                listb = g_list_next(listb);
                        }
                }
                lista = g_list_next(lista);
        }

        g_string_append_printf(filter_string_fwd, ")");
        filter_length += filter_string_fwd->len;

        if (filter_length < max_filter_length) {
                gtk_editable_insert_text(GTK_EDITABLE(main_display_filter_widget), filter_string_fwd->str, -1, &pos);
        } else {
                g_string_free(filter_string_fwd, TRUE);
                filter_string_fwd = g_string_new(filter_prepend);

                g_string_append_printf(filter_string_fwd, "(");
                is_first = TRUE;
                /* Build a new filter based on protocol fields */
                lista = g_queue_peek_nth_link(voip_calls_get_info()->callsinfos, 0);
                while (lista) {
                        listinfo = (voip_calls_info_t *)lista->data;
                        if (listinfo->selected) {
                                if (!is_first)
                                        g_string_append_printf(filter_string_fwd, " or ");
                                switch (listinfo->protocol) {
                                case VOIP_SIP:
                                        sipinfo = (sip_calls_info_t *)listinfo->prot_info;
                                        g_string_append_printf(filter_string_fwd,
                                                "(sip.Call-ID == \"%s\")",
                                                sipinfo->call_identifier
                                        );
                                        break;
                                case VOIP_ISUP:
                                        isupinfo = (isup_calls_info_t *)listinfo->prot_info;
                                        g_string_append_printf(filter_string_fwd,
                                                "(isup.cic == %i and frame.number >= %i and frame.number <= %i and mtp3.network_indicator == %i and ((mtp3.dpc == %i) and (mtp3.opc == %i)) or ((mtp3.dpc == %i) and (mtp3.opc == %i)))",
                                                isupinfo->cic, listinfo->start_fd->num,
                                                listinfo->stop_fd->num,
                                                isupinfo->ni, isupinfo->dpc, isupinfo->opc,
                                                isupinfo->opc, isupinfo->dpc
                                        );
                                        break;
                                case VOIP_H323:
                                        h323info = (h323_calls_info_t *)listinfo->prot_info;
                                        guid_str = guid_to_str(NULL, &h323info->guid[0]);
                                        g_string_append_printf(filter_string_fwd,
                                                "((h225.guid == %s || q931.call_ref == %x:%x || q931.call_ref == %x:%x)",
                                                guid_str,
                                                (guint8) (h323info->q931_crv & 0x00ff),
                                                (guint8)((h323info->q931_crv & 0xff00)>>8),
                                                (guint8) (h323info->q931_crv2 & 0x00ff),
                                                (guint8)((h323info->q931_crv2 & 0xff00)>>8));
                                        listb = g_list_first(h323info->h245_list);
                                        wmem_free(NULL, guid_str);
                                        while (listb) {
                                                h245_add = (h245_address_t *)listb->data;
                                                addr_str = (char*)address_to_str(NULL, &h245_add->h245_address);
                                                g_string_append_printf(filter_string_fwd,
                                                        " || (ip.addr == %s && tcp.port == %d && h245)",
                                                        addr_str, h245_add->h245_port);
                                                listb = g_list_next(listb);
                                                wmem_free(NULL, addr_str);
                                        }
                                        g_string_append_printf(filter_string_fwd, ")");
                                        break;
                                case TEL_H248:
                                        ctx = (gcp_ctx_t *)listinfo->prot_info;
                                        g_string_append_printf(filter_string_fwd,
                                                "(h248.ctx == 0x%x)", ctx->id);
                                        break;
                                default:
                                        /* placeholder to assure valid display filter expression */
                                        g_string_append_printf(filter_string_fwd,
                                                "(frame)");
                                        break;
                                }
                                is_first = FALSE;
                        }
                        lista = g_list_next(lista);
                }

                g_string_append_printf(filter_string_fwd, ")");
                gtk_editable_insert_text(GTK_EDITABLE(main_display_filter_widget), filter_string_fwd->str, -1, &pos);
        }

        g_string_free(filter_string_fwd, TRUE);
}

/****************************************************************************/
static void
voip_calls_on_select_all(GtkButton *button _U_, gpointer user_data _U_)
{
        GtkTreeSelection *selection = gtk_tree_view_get_selection(GTK_TREE_VIEW(list));
        gtk_tree_selection_select_all(selection);
}

/****************************************************************************/
static void
on_graph_bt_clicked(GtkButton *button _U_, gpointer user_data _U_)
{
        seq_analysis_item_t *gai;
        GList* lista;
        GList* listb;
        voip_calls_info_t *listinfo;
        voip_calls_tapinfo_t *tapinfo = voip_calls_get_info();

        if(!tapinfo->graph_analysis){
                return;
        }
        sequence_analysis_list_sort(tapinfo->graph_analysis);

        /* reset the "display" parameter in graph analysis */
        listb = g_queue_peek_nth_link(tapinfo->graph_analysis->items, 0);
        while (listb) {
                gai = (seq_analysis_item_t *)listb->data;
                gai->display = FALSE;
                listb = g_list_next(listb);
        }

        /* set the display for selected calls */
        lista = g_queue_peek_nth_link(tapinfo->callsinfos, 0);
        while (lista) {
                listinfo = (voip_calls_info_t *)lista->data;
                if (listinfo->selected) {
                        listb = g_queue_peek_nth_link(tapinfo->graph_analysis->items, 0);
                        while (listb) {
                                gai = (seq_analysis_item_t *)listb->data;
                                if (gai->conv_num == listinfo->call_num) {
                                        gai->display = TRUE;
                                }
                                listb = g_list_next(listb);
                        }
                }
                lista = g_list_next(lista);
        }

        /* create or refresh the graph windows */
        if (graph_analysis_data->dlg.window == NULL)
                graph_analysis_create(graph_analysis_data);  /* create the window */
        else
                graph_analysis_update(graph_analysis_data);  /* refresh it */
}

/****************************************************************************/
static void
on_flow_bt_clicked(GtkButton *button, gpointer user_data)
{
        on_graph_bt_clicked(button,user_data);
}

/****************************************************************************/
#ifdef HAVE_LIBPORTAUDIO
static void
on_player_bt_clicked(GtkButton *button _U_, gpointer user_data _U_)
{
        rtp_player_init(voip_calls_get_info());
}
#endif /* HAVE_LIBPORTAUDIO */

/****************************************************************************/
/* when the user selects a row in the calls list */
static gboolean
voip_calls_mark_selected(GtkTreeModel *model, GtkTreePath *path _U_, GtkTreeIter *iter, gpointer data)
{
        GtkTreeSelection *selection = (GtkTreeSelection *)data;
        voip_calls_info_t* strinfo;

        gtk_tree_model_get(model, iter, CALL_COL_DATA, &strinfo, -1);
        strinfo->selected = gtk_tree_selection_iter_is_selected(selection, iter);
        /* VOIP_CALLS_DEBUG("selected call %u (%s), frame %u: %d", strinfo->call_num, strinfo->call_id, strinfo->start_fd->num, strinfo->selected); */

        return FALSE;
}

static void
voip_calls_on_select_row_cb(GtkTreeSelection *selection, gpointer data _U_)
{
        gchar label_text[80];

        gtk_tree_model_foreach(GTK_TREE_MODEL(list_store), voip_calls_mark_selected, selection);

        calls_ns = gtk_tree_selection_count_selected_rows(selection);

        g_snprintf(label_text, 80,
                        "Detected %u VoIP %s. Selected %u %s.",
                        calls_nb,
                        plurality(calls_nb, "Call", "Calls"),
                        calls_ns,
                        plurality(calls_ns, "Call", "Calls"));
        gtk_label_set_text(GTK_LABEL(top_label), label_text);

        gtk_widget_set_sensitive(bt_filter, calls_ns ? TRUE : FALSE);
        gtk_widget_set_sensitive(bt_graph, calls_ns ? TRUE : FALSE);
#ifdef HAVE_LIBPORTAUDIO
        gtk_widget_set_sensitive(bt_player, calls_ns ? TRUE : FALSE);
#endif /* HAVE_LIBPORTAUDIO */
}

/****************************************************************************/
/* Tree view constructors                                                   */
/****************************************************************************/
/* append a line to list */
static void
add_to_list_store(voip_calls_info_t* strinfo)
{
        gchar field[NUM_COLS][50];
        isup_calls_info_t *isupinfo;
        h323_calls_info_t *h323info;
        gboolean flag = FALSE;
        char* addr_str = address_to_display(NULL, &(strinfo->initial_speaker));

        g_snprintf(field[CALL_COL_INITIAL_SPEAKER], 30, "%s", addr_str);
        g_snprintf(field[CALL_COL_FROM],            50, "%s", strinfo->from_identity);
        g_snprintf(field[CALL_COL_TO],              50, "%s", strinfo->to_identity);
        g_snprintf(field[CALL_COL_PROTOCOL],        15, "%s",
                   ((strinfo->protocol==VOIP_COMMON)&&strinfo->protocol_name)?
                       strinfo->protocol_name:voip_protocol_name[strinfo->protocol]);
        g_snprintf(field[CALL_COL_STATE],           15, "%s", voip_call_state_name[strinfo->call_state]);
        wmem_free(NULL, addr_str);

        /* Add comments based on the protocol */
        switch (strinfo->protocol) {
                case VOIP_ISUP:
                        isupinfo = (isup_calls_info_t *)strinfo->prot_info;
                        g_snprintf(field[CALL_COL_COMMENTS],30, "%i-%i -> %i-%i", isupinfo->ni, isupinfo->opc,
                                isupinfo->ni, isupinfo->dpc);
                        break;
                case VOIP_H323:
                        h323info = (h323_calls_info_t *)strinfo->prot_info;
                        if (strinfo->call_state == VOIP_CALL_SETUP)
                                flag = h323info->is_faststart_Setup;
                        else
                                if ((h323info->is_faststart_Setup == TRUE) && (h323info->is_faststart_Proc == TRUE))
                                        flag = TRUE;
                        g_snprintf(field[CALL_COL_COMMENTS],35, "Tunneling: %s  Fast Start: %s",
                                   (h323info->is_h245Tunneling==TRUE?"ON":"OFF"),
                                   (flag==TRUE?"ON":"OFF"));
                        break;
                case VOIP_COMMON:
                        field[CALL_COL_COMMENTS][0]='\0';
                        if (strinfo->call_comment)
                                g_snprintf(field[CALL_COL_COMMENTS],30, "%s", strinfo->call_comment);
                        break;
                default:
                        field[CALL_COL_COMMENTS][0]='\0';
                        if (strinfo->call_comment)
                                g_snprintf(field[CALL_COL_COMMENTS],30, "%s", strinfo->call_comment);
        }

        /* Acquire an iterator */
        gtk_list_store_append(list_store, &list_iter);

        /* Fill the new row */
        gtk_list_store_set(list_store, &list_iter,
                           CALL_COL_START_TIME,       nstime_to_sec(&strinfo->start_rel_ts),
                           CALL_COL_STOP_TIME,        nstime_to_sec(&strinfo->stop_rel_ts),
                           CALL_COL_INITIAL_SPEAKER,  &field[CALL_COL_INITIAL_SPEAKER][0],
                           CALL_COL_FROM,             &field[CALL_COL_FROM][0],
                           CALL_COL_TO,               &field[CALL_COL_TO][0],
                           CALL_COL_PROTOCOL,         &field[CALL_COL_PROTOCOL][0],
                           CALL_COL_PACKETS,          strinfo->npackets,
                           CALL_COL_STATE,            &field[CALL_COL_STATE][0],
                           CALL_COL_COMMENTS,         &field[CALL_COL_COMMENTS][0],
                           CALL_COL_DATA,             strinfo,
                           -1);

        calls_nb += 1;
}

/****************************************************************************/
/* Create list view */
static void
create_list_view(void)
{
        GtkTreeViewColumn *column;
        GtkCellRenderer   *renderer;
        GtkTreeSortable   *sortable;
        GtkTreeView       *list_view;
        GtkTreeSelection  *selection;

        /* Create the store */
        list_store = gtk_list_store_new(NUM_COLS,       /* Total number of columns XXX */
                                        G_TYPE_DOUBLE,  /* Start Time */
                                        G_TYPE_DOUBLE,  /* Stop Time */
                                        G_TYPE_STRING,  /* Initial Speaker */
                                        G_TYPE_STRING,  /* From */
                                        G_TYPE_STRING,  /* To */
                                        G_TYPE_STRING,  /* Protocol */
                                        G_TYPE_UINT,    /* Packets */
                                        G_TYPE_STRING,  /* State */
                                        G_TYPE_STRING,  /* Comments */
                                        G_TYPE_POINTER  /* Data */
                                       );

        /* Create a view */
        list = gtk_tree_view_new_with_model(GTK_TREE_MODEL(list_store));

        /* The view now holds a reference.  We can get rid of our own reference */
        g_object_unref(G_OBJECT(list_store));

        list_view = GTK_TREE_VIEW(list);
        sortable = GTK_TREE_SORTABLE(list_store);

        /* Speed up the list display */
        gtk_tree_view_set_fixed_height_mode(list_view, TRUE);

        /* Setup the sortable columns */
        gtk_tree_sortable_set_sort_column_id(sortable, CALL_COL_START_TIME, GTK_SORT_ASCENDING);
        gtk_tree_view_set_headers_clickable(list_view, FALSE);

        /* Start Time */
        renderer = gtk_cell_renderer_text_new();
        g_object_set(G_OBJECT(renderer), "xalign", 1.0, NULL);  /* right align  */
        g_object_set(G_OBJECT(renderer), "xpad", 10, NULL);
        column = gtk_tree_view_column_new_with_attributes("Start Time", renderer,
                "text", CALL_COL_START_TIME,
                NULL);
        gtk_tree_view_column_set_sort_column_id(column, CALL_COL_START_TIME);
        gtk_tree_view_column_set_resizable(column, TRUE);
        gtk_tree_view_column_set_sizing(column, GTK_TREE_VIEW_COLUMN_FIXED);
        gtk_tree_view_column_set_min_width(column, 60);
        gtk_tree_view_column_set_fixed_width(column, 100);
        /* Add the column to the view. */
        gtk_tree_view_append_column(list_view, column);

        /* Stop Time */
        renderer = gtk_cell_renderer_text_new();
        g_object_set(G_OBJECT(renderer), "xalign", 1.0, NULL);  /* right align  */
        g_object_set(G_OBJECT(renderer), "xpad", 10, NULL);
        column = gtk_tree_view_column_new_with_attributes("Stop Time", renderer,
                "text", CALL_COL_STOP_TIME,
                NULL);
        gtk_tree_view_column_set_sort_column_id(column, CALL_COL_STOP_TIME);
        gtk_tree_view_column_set_resizable(column, TRUE);
        gtk_tree_view_column_set_sizing(column, GTK_TREE_VIEW_COLUMN_FIXED);
        gtk_tree_view_column_set_min_width(column, 60);
        gtk_tree_view_column_set_fixed_width(column, 100);
        gtk_tree_view_append_column(list_view, column);

        /* Initial Speaker */
        renderer = gtk_cell_renderer_text_new();
        column = gtk_tree_view_column_new_with_attributes("Initial Speaker", renderer,
                "text", CALL_COL_INITIAL_SPEAKER,
                NULL);
        gtk_tree_view_column_set_sort_column_id(column, CALL_COL_INITIAL_SPEAKER);
        gtk_tree_view_column_set_resizable(column, TRUE);
        gtk_tree_view_column_set_sizing(column, GTK_TREE_VIEW_COLUMN_FIXED);
        gtk_tree_view_column_set_min_width(column, 80);
        gtk_tree_view_column_set_fixed_width(column, 120);
        gtk_tree_view_append_column(list_view, column);

        /* From */
        renderer = gtk_cell_renderer_text_new();
        column = gtk_tree_view_column_new_with_attributes("From", renderer,
                "text", CALL_COL_FROM,
                NULL);
        gtk_tree_view_column_set_sort_column_id(column, CALL_COL_FROM);
        gtk_tree_view_column_set_resizable(column, TRUE);
        gtk_tree_view_column_set_sizing(column, GTK_TREE_VIEW_COLUMN_FIXED);
        gtk_tree_view_column_set_min_width(column, 130);
        gtk_tree_view_column_set_fixed_width(column, 140);
        gtk_tree_view_append_column(list_view, column);

        /* To */
        renderer = gtk_cell_renderer_text_new();
        column = gtk_tree_view_column_new_with_attributes("To", renderer,
                "text", CALL_COL_TO,
                NULL);
        gtk_tree_view_column_set_sort_column_id(column, CALL_COL_TO);
        gtk_tree_view_column_set_resizable(column, TRUE);
        gtk_tree_view_column_set_sizing(column, GTK_TREE_VIEW_COLUMN_FIXED);
        gtk_tree_view_column_set_min_width(column, 130);
        gtk_tree_view_column_set_fixed_width(column, 140);
        gtk_tree_view_append_column(list_view, column);

        /* Protocol */
        renderer = gtk_cell_renderer_text_new();
        column = gtk_tree_view_column_new_with_attributes("Protocol", renderer,
                "text", CALL_COL_PROTOCOL,
                NULL);
        gtk_tree_view_column_set_sort_column_id(column, CALL_COL_PROTOCOL);
        gtk_tree_view_column_set_resizable(column, TRUE);
        gtk_tree_view_column_set_sizing(column, GTK_TREE_VIEW_COLUMN_FIXED);
        gtk_tree_view_column_set_min_width(column, 50);
        gtk_tree_view_column_set_fixed_width(column, 80);
        gtk_tree_view_append_column(list_view, column);

        /* Packets */
        renderer = gtk_cell_renderer_text_new();
        g_object_set(G_OBJECT(renderer), "xalign", 1.0, NULL);  /* right align numbers */
        g_object_set(G_OBJECT(renderer), "xpad", 10, NULL);
        column = gtk_tree_view_column_new_with_attributes("Packets", renderer,
                "text", CALL_COL_PACKETS,
                NULL);
        gtk_tree_view_column_set_sort_column_id(column, CALL_COL_PACKETS);
        gtk_tree_view_column_set_resizable(column, TRUE);
        gtk_tree_view_column_set_sizing(column, GTK_TREE_VIEW_COLUMN_FIXED);
        gtk_tree_view_column_set_min_width(column, 70);
        gtk_tree_view_column_set_fixed_width(column, 80);
        gtk_tree_view_append_column(list_view, column);

        /* State */
        renderer = gtk_cell_renderer_text_new();
        column = gtk_tree_view_column_new_with_attributes("State", renderer,
                "text", CALL_COL_STATE,
                NULL);
        gtk_tree_view_column_set_sort_column_id(column, CALL_COL_STATE);
        gtk_tree_view_column_set_resizable(column, TRUE);
        gtk_tree_view_column_set_sizing(column, GTK_TREE_VIEW_COLUMN_FIXED);
        gtk_tree_view_column_set_min_width(column, 60);
        gtk_tree_view_column_set_fixed_width(column, 80);
        gtk_tree_view_append_column(list_view, column);

        /* Comments */
        renderer = gtk_cell_renderer_text_new();
        column = gtk_tree_view_column_new_with_attributes("Comments", renderer,
                "text", CALL_COL_COMMENTS,
                NULL);
        gtk_tree_view_column_set_sort_column_id(column, CALL_COL_COMMENTS);
        gtk_tree_view_column_set_resizable(column, TRUE);
        gtk_tree_view_column_set_sizing(column, GTK_TREE_VIEW_COLUMN_FIXED);
        gtk_tree_view_column_set_min_width(column, 100);
        gtk_tree_view_column_set_fixed_width(column, 140);
        gtk_tree_view_append_column(list_view, column);

        /* Now enable the sorting of each column */
        gtk_tree_view_set_rules_hint(list_view, TRUE);
        gtk_tree_view_set_headers_clickable(list_view, TRUE);

        /* Setup the selection handler */
        selection = gtk_tree_view_get_selection(list_view);
        gtk_tree_selection_set_mode(selection, GTK_SELECTION_MULTIPLE);

        g_signal_connect(G_OBJECT(selection), "changed", /* select_row */
                         G_CALLBACK(voip_calls_on_select_row_cb),
                         NULL);

}

/****************************************************************************/
/* INTERFACE                                                                */
/****************************************************************************/
static void
voip_calls_dlg_create(void)
{
        GtkWidget *voip_calls_dlg_w;
        GtkWidget *main_vb;
        GtkWidget *scrolledwindow;
        GtkWidget *hbuttonbox;
        GtkWidget *bt_close;
        GtkWidget *bt_select_all;
        gchar *title_name_ptr;
        gchar *win_name;

        title_name_ptr = cf_get_display_name(&cfile);
        win_name = g_strdup_printf("%s - VoIP Calls", title_name_ptr);
        g_free(title_name_ptr);
        voip_calls_dlg_w = dlg_window_new(win_name);  /* transient_for top_level */
        gtk_window_set_destroy_with_parent(GTK_WINDOW(voip_calls_dlg_w), TRUE);

        gtk_window_set_default_size(GTK_WINDOW(voip_calls_dlg_w), 1000, 350);

        main_vb = ws_gtk_box_new(GTK_ORIENTATION_VERTICAL, 0, FALSE);
        gtk_container_add(GTK_CONTAINER(voip_calls_dlg_w), main_vb);
        gtk_container_set_border_width(GTK_CONTAINER (main_vb), 12);

        top_label = gtk_label_new("Detected 0 VoIP Calls. Selected 0 Calls.");
        gtk_box_pack_start(GTK_BOX (main_vb), top_label, FALSE, FALSE, 8);

        scrolledwindow = scrolled_window_new(NULL, NULL);
        gtk_box_pack_start(GTK_BOX (main_vb), scrolledwindow, TRUE, TRUE, 0);

        create_list_view();
        gtk_container_add(GTK_CONTAINER(scrolledwindow), list);
        gtk_widget_show(voip_calls_dlg_w);

        status_label = gtk_label_new("Total: Calls: 0   Start packets: 0   Completed calls: 0   Rejected calls: 0");
        gtk_box_pack_start(GTK_BOX(main_vb), status_label, FALSE, FALSE, 8);

        /* button row */
        hbuttonbox = gtk_button_box_new(GTK_ORIENTATION_HORIZONTAL);
        gtk_box_pack_start(GTK_BOX(main_vb), hbuttonbox, FALSE, FALSE, 0);
        gtk_button_box_set_layout(GTK_BUTTON_BOX (hbuttonbox), GTK_BUTTONBOX_SPREAD);
        gtk_box_set_spacing(GTK_BOX(hbuttonbox), 30);

        /*bt_unselect = gtk_button_new_with_label ("Unselect");
        gtk_container_add (GTK_CONTAINER (hbuttonbox), bt_unselect);
        gtk_widget_set_tooltip_text (bt_unselect, "Unselect this conversation");*/

        bt_filter = ws_gtk_button_new_from_stock(WIRESHARK_STOCK_PREPARE_FILTER);
        gtk_container_add(GTK_CONTAINER(hbuttonbox), bt_filter);
        gtk_widget_set_tooltip_text(bt_filter, "Prepare a display filter of the selected conversation");

        bt_graph = ws_gtk_button_new_from_stock(WIRESHARK_STOCK_VOIP_FLOW);
        gtk_container_add(GTK_CONTAINER(hbuttonbox), bt_graph);
        gtk_widget_show(bt_graph);
        g_signal_connect(bt_graph, "clicked", G_CALLBACK(on_flow_bt_clicked), NULL);
        gtk_widget_set_tooltip_text(bt_graph, "Show a flow graph of the selected calls.");

#ifdef HAVE_LIBPORTAUDIO
        bt_player = ws_gtk_button_new_from_stock(WIRESHARK_STOCK_AUDIO_PLAYER);
        gtk_container_add(GTK_CONTAINER(hbuttonbox), bt_player);
        gtk_widget_show(bt_player);
        g_signal_connect(bt_player, "clicked", G_CALLBACK(on_player_bt_clicked), NULL);
        gtk_widget_set_tooltip_text(bt_player, "Launch the RTP player to listen the selected calls.");
#endif /* HAVE_LIBPORTAUDIO */

        bt_select_all = ws_gtk_button_new_from_stock(GTK_STOCK_SELECT_ALL);
        gtk_container_add(GTK_CONTAINER(hbuttonbox), bt_select_all);
        gtk_widget_set_can_default(bt_select_all, TRUE);
        gtk_widget_set_tooltip_text(bt_select_all, "Select all the calls");

        bt_close = ws_gtk_button_new_from_stock(GTK_STOCK_CLOSE);
        gtk_container_add(GTK_CONTAINER (hbuttonbox), bt_close);
        gtk_widget_set_can_default(bt_close, TRUE);
        gtk_widget_set_tooltip_text(bt_close, "Close this dialog");

        /*g_signal_connect(bt_unselect, "clicked", G_CALLBACK(voip_calls_on_unselect), NULL);*/
        g_signal_connect(bt_filter, "clicked", G_CALLBACK(voip_calls_on_filter), NULL);

        window_set_cancel_button(voip_calls_dlg_w, bt_close, window_cancel_button_cb);

        g_signal_connect(voip_calls_dlg_w, "delete_event", G_CALLBACK(window_delete_event_cb), NULL);
        g_signal_connect(voip_calls_dlg_w, "destroy", G_CALLBACK(voip_calls_on_destroy), NULL);
        g_signal_connect(bt_select_all, "clicked", G_CALLBACK(voip_calls_on_select_all), NULL);

        gtk_widget_show_all(voip_calls_dlg_w);
        window_present(voip_calls_dlg_w);

        voip_calls_on_unselect(NULL, NULL);

        voip_calls_dlg = voip_calls_dlg_w;

        g_free(win_name);
}


/****************************************************************************/
/* PUBLIC                                                                   */
/****************************************************************************/

/****************************************************************************/
/* update the contents of the list view */
/* list: pointer to list of voip_calls_info_t* */
void
voip_calls_dlg_update(GList *listx)
{
        /* GtkTreeView       *list_view; */
        GtkTreeSortable   *sortable;
        gchar label_text[256];

        /* list_view = GTK_TREE_VIEW(list); */
        sortable = GTK_TREE_SORTABLE(list_store);
        if (voip_calls_dlg != NULL) {
                calls_nb = 0;
                calls_ns = 0;
                gtk_list_store_clear(list_store);

                g_snprintf(label_text, sizeof(label_text),
                        "Total: Calls: %u   Start packets: %u   Completed calls: %u   Rejected calls: %u",
                        g_queue_get_length(voip_calls_get_info()->callsinfos),
                        voip_calls_get_info()->start_packets,
                        voip_calls_get_info()->completed_calls,
                        voip_calls_get_info()->rejected_calls);
                gtk_label_set_text(GTK_LABEL(status_label), label_text);

                /* Disable the re-ordering */
                gtk_tree_sortable_set_sort_column_id(sortable, GTK_TREE_SORTABLE_UNSORTED_SORT_COLUMN_ID, GTK_SORT_ASCENDING);


                listx = g_list_first(listx);
                while (listx) {
                        add_to_list_store((voip_calls_info_t*)(listx->data));
                        listx = g_list_next(listx);
                }
                /* Enable the re-ordering */
                gtk_tree_sortable_set_sort_column_id(sortable, CALL_COL_START_TIME, GTK_SORT_ASCENDING);


                g_snprintf(label_text, sizeof(label_text),
                        "Detected %u VoIP %s. Selected %u %s.",
                        calls_nb,
                        plurality(calls_nb, "Call", "Calls"),
                        calls_ns,
                        plurality(calls_ns, "Call", "Calls"));
                gtk_label_set_text(GTK_LABEL(top_label), label_text);
        }
}

/****************************************************************************/
/* per-packet function for tap listeners */
#ifdef HAVE_LIBPORTAUDIO
gboolean
voip_calls_dlg_packet(void *ptr _U_, packet_info *pinfo, epan_dissect_t *edt _U_, const void *data) {
        /* add this RTP for future listening using the RTP Player*/
        const struct _rtp_info *rtp_info = (const struct _rtp_info *)data;
        add_rtp_packet(rtp_info, pinfo);
        return TRUE;
}
#else
gboolean
voip_calls_dlg_packet(void *ptr _U_, packet_info *pinfo _U_, epan_dissect_t *edt _U_, const void *data _U_) {
        /* add this RTP for future listening using the RTP Player*/
        return FALSE;
}
#endif

/****************************************************************************/
/* draw function for tap listeners to keep the window up to date */
void
voip_calls_dlg_draw(void *ptr _U_)
{
        if (voip_calls_get_info()->redraw) {
                voip_calls_dlg_update(g_queue_peek_nth_link(voip_calls_get_info()->callsinfos, 0));
        }
}

/****************************************************************************/
/* reset function for tap listeners to clear window, if necessary */
void
voip_calls_dlg_reset(void *ptr _U_)
{
        /* Clear gtk list store */
        if (graph_analysis_data) {
                gtk_list_store_clear(list_store);
        }

#ifdef HAVE_LIBPORTAUDIO
        /* reset the RTP player */
        reset_rtp_player();
#endif

        /* Clean up memory used by calls tap */
        voip_calls_reset_all_taps(voip_calls_get_info());
        sequence_analysis_list_free(voip_calls_get_info()->graph_analysis);

        /* close the graph window if open */
        if (graph_analysis_data && graph_analysis_data->dlg.window != NULL) {
                window_cancel_button_cb(NULL, graph_analysis_data->dlg.window);
                graph_analysis_data->dlg.window = NULL;
        }
}

/****************************************************************************/
/* init function for tap */
static void
voip_calls_dlg_init_taps(const char *dummy _U_, void* userdata _U_)
{
        voip_calls_tapinfo_t* tap_id_base = voip_calls_get_info();
        if(NULL == tap_id_base->graph_analysis) {
                tap_id_base->graph_analysis = sequence_analysis_info_new();
        }
        tap_id_base->session = cfile.epan;

#ifdef HAVE_LIBPORTAUDIO
        /* reset the RTP player */
        reset_rtp_player();
#endif

        /* Clean up memory used by calls tap */
        voip_calls_reset_all_taps(tap_id_base);
        sequence_analysis_list_free(tap_id_base->graph_analysis);

        if (graph_analysis_data == NULL) {
                /* init the Graph Analysys */
                graph_analysis_data = graph_analysis_init(voip_calls_get_info()->graph_analysis);
        }

        /* Register the tap listeners */
        if (!have_voip_calls_tap_listeners) {
                voip_calls_init_all_taps(tap_id_base);
                have_voip_calls_tap_listeners = TRUE;
        }

        /* create dialog box if necessary */
        if (voip_calls_dlg == NULL) {
                voip_calls_dlg_create();
        } else {
                /* There's already a dialog box; reactivate it. */
                reactivate_window(voip_calls_dlg);
        }

        voip_calls_get_info()->redraw = 1;
        voip_calls_dlg_draw(NULL);
        voip_calls_get_info()->redraw = 0;

        /* Scan for VoIP calls calls (redissect all packets) */
        cf_retap_packets(&cfile);
        gdk_window_raise(gtk_widget_get_window(voip_calls_dlg));
        /* Tap listener will be removed and cleaned up in voip_calls_on_destroy */
}


/****************************************************************************/
/* entry point when called via the GTK menu */
void
voip_calls_launch(GtkAction *action _U_, gpointer user_data _U_)
{
        voip_calls_get_info()->fs_option = FLOW_ONLY_INVITES;
        voip_calls_dlg_init_taps("", NULL);
}

/****************************************************************************/
/* entry point when called via the GTK menu */
void
voip_flows_launch(GtkAction *action _U_, gpointer user_data _U_)
{
        voip_calls_get_info()->fs_option = FLOW_ALL;
        voip_calls_dlg_init_taps("", NULL);
}

/****************************************************************************/
static stat_tap_ui voip_calls_ui = {
        REGISTER_STAT_GROUP_GENERIC,
        NULL,
        "voip,calls",
        voip_calls_dlg_init_taps,
        0,
        NULL
};

void
register_tap_listener_voip_calls_dlg(void)
{
        register_stat_tap_ui(&voip_calls_ui, NULL);
}

/*
 * Editor modelines  -  https://www.wireshark.org/tools/modelines.html
 *
 * Local variables:
 * c-basic-offset: 8
 * tab-width: 8
 * indent-tabs-mode: t
 * End:
 *
 * vi: set shiftwidth=8 tabstop=8 noexpandtab:
 * :indentSize=8:tabSize=8:noTabs=false:
 */