path: root/epan/dissectors/packet-rdt.c

/* packet-rdt.c
 *
 * Routines for RDT dissection
 * RDT = Real Data Transport
 *
 * Copyright 2005
 * Written by Martin Mathieson and Tom Marshall
 *
 * Wireshark - Network traffic analyzer
 * By Gerald Combs <gerald@wireshark.org>
 * Copyright 1998 Gerald Combs
 *
 * SPDX-License-Identifier: GPL-2.0-or-later
 */

/* Information sources:
 * helixcommunity.org sources, in particular
 * server/protocol/transport/rdt/pub/tngpkt.pm
 */

#include "config.h"

#include <epan/packet.h>
#include <epan/expert.h>
#include <epan/conversation.h>
#include <epan/prefs.h>
#include <epan/proto_data.h>
#include "packet-rdt.h"

static dissector_handle_t rdt_handle;

static int     proto_rdt;

/* Packet fields */
static int     hf_rdt_packet;

/* flags1: shared */
static int     hf_rdt_len_included;

/* flags1: data packet */
static int     hf_rdt_data_flags1;
static int     hf_rdt_data_need_reliable;
static int     hf_rdt_data_stream_id;
static int     hf_rdt_data_is_reliable;

/* flags2: data packet */
static int     hf_rdt_data_flags2;
static int     hf_rdt_data_backtoback;
static int     hf_rdt_data_slowdata;
static int     hf_rdt_data_asmrule;

/* flags1: asm action packet */
static int     hf_rdt_aact_flags;
static int     hf_rdt_aact_stream_id;

/* flags1: ack packet */
static int     hf_rdt_ack_flags;
static int     hf_rdt_ack_lost_high;

/* flags1: latency report packet */
static int     hf_rdt_latency_report_flags;

/* flags1: bandwidth report packet */
static int     hf_rdt_bandwidth_report_flags;

/* flags1: stream end packet */
static int     hf_rdt_stre_flags;
static int     hf_rdt_stre_need_reliable;
static int     hf_rdt_stre_stream_id;
static int     hf_rdt_stre_packet_sent;
static int     hf_rdt_stre_ext_flag;

/* static int     hf_rdt_rtt_request_flags; */
/* static int     hf_rdt_rtt_response_flags; */
/* static int     hf_rdt_congestion_flags; */
static int     hf_rdt_report_flags;
/* static int     hf_rdt_tirq_flags; */
static int     hf_rdt_tirp_flags;
static int     hf_rdt_bw_probing_flags;

/* Octets 1-2: sequence number or packet type */
static int     hf_rdt_sequence_number;
static int     hf_rdt_packet_type;

/* Only present if length_included */
static int     hf_rdt_packet_length;

/* General shared fields */
static int     hf_rdt_timestamp;
static int     hf_rdt_stream_id_ex;
static int     hf_rdt_asmrule_ex;
static int     hf_rdt_total_reliable;
static int     hf_rdt_data;

/* Special use fields */
static int     hf_rdt_aact_reliable_seqno;
static int     hf_rdt_brpt_interval;
static int     hf_rdt_brpt_bandwidth;
static int     hf_rdt_brpt_sequence;
static int     hf_rdt_rtrp_ts_sec;
static int     hf_rdt_rtrp_ts_usec;
static int     hf_rdt_cong_xmit_mult;
static int     hf_rdt_cong_recv_mult;
static int     hf_rdt_stre_seqno;
static int     hf_rdt_stre_dummy_flags1;
static int     hf_rdt_stre_dummy_type;
static int     hf_rdt_stre_reason_code;
static int     hf_rdt_lrpt_server_out_time;
static int     hf_rdt_tirq_request_rtt_info;
static int     hf_rdt_tirq_request_buffer_info;
static int     hf_rdt_tirq_request_time_msec;
static int     hf_rdt_tirp_has_rtt_info;
static int     hf_rdt_tirp_is_delayed;
static int     hf_rdt_tirp_has_buffer_info;
static int     hf_rdt_tirp_request_time_msec;
static int     hf_rdt_tirp_response_time_msec;
static int     hf_rdt_tirp_buffer_info;
static int     hf_rdt_tirp_buffer_info_count;
static int     hf_rdt_tirp_buffer_info_stream_id;
static int     hf_rdt_tirp_buffer_info_lowest_timestamp;
static int     hf_rdt_tirp_buffer_info_highest_timestamp;
static int     hf_rdt_tirp_buffer_info_bytes_buffered;
static int     hf_rdt_bwpp_seqno;
static int     hf_rdt_unk_flags1;

/* RDT setup fields */
static int     hf_rdt_setup;
static int     hf_rdt_setup_frame;
static int     hf_rdt_setup_method;
static int     hf_rdt_feature_level;

/* RDT fields defining a sub tree */
static int     ett_rdt;
static int     ett_rdt_packet;
static int     ett_rdt_setup;
static int     ett_rdt_data_flags1;
static int     ett_rdt_data_flags2;
static int     ett_rdt_aact_flags;
static int     ett_rdt_ack_flags;
static int     ett_rdt_latency_report_flags;
static int     ett_rdt_bandwidth_report_flags;
static int     ett_rdt_stre_flags;
static int     ett_rdt_rtt_request_flags;
static int     ett_rdt_rtt_response_flags;
static int     ett_rdt_congestion_flags;
static int     ett_rdt_report_flags;
static int     ett_rdt_tirq_flags;
static int     ett_rdt_tirp_flags;
static int     ett_rdt_tirp_buffer_info;
static int     ett_rdt_bw_probing_flags;

static expert_field ei_rdt_packet_length;

#define RDT_UDP_PORT        6970

void proto_register_rdt(void);
void proto_reg_handoff_rdt(void);

/* Parse individual packet types */
static unsigned dissect_rdt_data_packet(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree, unsigned offset);
static unsigned dissect_rdt_asm_action_packet(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree, unsigned offset);
static unsigned dissect_rdt_bandwidth_report_packet(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree, unsigned offset);
static unsigned dissect_rdt_ack_packet(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree, unsigned offset);
static unsigned dissect_rdt_rtt_request_packet(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree, unsigned offset);
static unsigned dissect_rdt_rtt_response_packet(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree, unsigned offset);
static unsigned dissect_rdt_congestion_packet(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree, unsigned offset);
static unsigned dissect_rdt_stream_end_packet(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree, unsigned offset);
static unsigned dissect_rdt_report_packet(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree, unsigned offset);
static unsigned dissect_rdt_latency_report_packet(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree, unsigned offset);
static unsigned dissect_rdt_transport_info_request_packet(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree, unsigned offset);
static unsigned dissect_rdt_transport_info_response_packet(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree, unsigned offset);
static unsigned dissect_rdt_bw_probing_packet(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree, unsigned offset);
static unsigned dissect_rdt_unknown_control(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree, unsigned offset);

static void show_setup_info(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree);

/* Preferences bool to control whether or not setup info should be shown */
static bool global_rdt_show_setup_info = true;

/* Packet types */
#define RDT_ASMACTIION_PACKET               0xff00
#define RDT_BANDWIDTHREPORT_PACKET          0xff01
#define RDT_ACK_PACKET                      0xff02
#define RDT_RTTREQUEST_PACKET               0xff03
#define RDT_RTTRESPONSE_PACKET              0xff04
#define RDT_CONGESTION_PACKET               0xff05
#define RDT_STREAMEND_PACKET                0xff06
#define RDT_REPORT_PACKET                   0xff07
#define RDT_LATENCYREPORT_PACKET            0xff08
#define RDT_TRANSPORTINFO_PACKET            0xff09
#define RDT_TRANSPORTINFORESPONSE_PACKET    0xff0a
#define RDT_BWPROBING_PACKET                0xff0b

static const value_string packet_type_vals[] =
{
    { RDT_ASMACTIION_PACKET,             "Asm action"  },
    { RDT_BANDWIDTHREPORT_PACKET,        "Bandwidth report"  },
    { RDT_ACK_PACKET,                    "Ack"  },
    { RDT_RTTREQUEST_PACKET,             "RTT request"  },
    { RDT_RTTRESPONSE_PACKET,            "RTT response"  },
    { RDT_CONGESTION_PACKET,             "Congestion"  },
    { RDT_STREAMEND_PACKET,              "Stream end" },
    { RDT_REPORT_PACKET,                 "Report" },
    { RDT_LATENCYREPORT_PACKET,          "Latency report" },
    { RDT_TRANSPORTINFO_PACKET,          "Transport info" },
    { RDT_TRANSPORTINFORESPONSE_PACKET,  "Transport info response" },
    { RDT_BWPROBING_PACKET,              "BW probing" },
    { 0, NULL }
};


/* Set up an RDT conversation */
void rdt_add_address(packet_info *pinfo,
                     address *addr, int port,
                     int other_port,
                     const char *setup_method,
                     int   rdt_feature_level)
{
    address null_addr;
    conversation_t* p_conv;
    struct _rdt_conversation_info *p_conv_data;

    /* If this isn't the first time this packet has been processed,
       we've already done this work, so we don't need to do it
      again. */
    if (pinfo->fd->visited)
    {
        return;
    }

    clear_address(&null_addr);

    /* Check if the ip address and port combination is not already registered
       as a conversation. */
    p_conv = find_conversation(pinfo->num, addr, &null_addr, CONVERSATION_UDP, port, other_port,
                               NO_ADDR_B | (!other_port ? NO_PORT_B : 0));

    /* If not, create a new conversation. */
    if ( !p_conv || p_conv->setup_frame != pinfo->num)
    {
        p_conv = conversation_new(pinfo->num, addr, &null_addr, CONVERSATION_UDP,
                                  (uint32_t)port, (uint32_t)other_port,
                                  NO_ADDR2 | (!other_port ? NO_PORT2 : 0));
    }

    /* Set dissector */
    conversation_set_dissector(p_conv, rdt_handle);

    /* Check if the conversation has data associated with it. */
    p_conv_data = (struct _rdt_conversation_info *)conversation_get_proto_data(p_conv, proto_rdt);

    /* If not, add a new data item. */
    if (!p_conv_data)
    {
        /* Create conversation data */
        p_conv_data = wmem_new(wmem_file_scope(), struct _rdt_conversation_info);
        conversation_add_proto_data(p_conv, proto_rdt, p_conv_data);
    }

    /* Update the conversation data. */
    (void) g_strlcpy(p_conv_data->method, setup_method, MAX_RDT_SETUP_METHOD_SIZE);
    p_conv_data->frame_number = pinfo->num;
    p_conv_data->feature_level = rdt_feature_level;
}



/****************************************************************************/
/* Main dissection function                                                 */
/****************************************************************************/
static int dissect_rdt(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree, void* data _U_)
{
    unsigned    previous_offset = 0;
    int         offset = 0;
    proto_item  *ti;
    proto_tree  *rdt_tree = NULL;
    proto_tree  *rdt_packet_tree;
    uint16_t    packet_type;

    /* Set/clear columns */
    col_set_str(pinfo->cinfo, COL_PROTOCOL, "RDT");
    col_clear(pinfo->cinfo, COL_INFO);

    /* Create RDT protocol tree */
    ti = proto_tree_add_item(tree, proto_rdt, tvb, offset, -1, ENC_NA);
    rdt_tree = proto_item_add_subtree(ti, ett_rdt);

    /* Conversation setup info */
    if (global_rdt_show_setup_info)
    {
        show_setup_info(tvb, pinfo, rdt_tree);
    }

    /* Parse all RDT packets found in the frame */
    while (offset != -1 && tvb_reported_length_remaining(tvb, offset))
    {
        /* Every packet type should have at least 3 bytes */
        tvb_ensure_bytes_exist(tvb, offset, 3);

        /* 2nd & 3rd bytes determine packet type */
        packet_type = tvb_get_ntohs(tvb, offset+1);

        /* Add a tree for the next individual packet */
        ti =  proto_tree_add_string_format(rdt_tree, hf_rdt_packet, tvb, offset, -1,
                                           "",
                                           "RDT packet (%s)",
                                           packet_type < 0xff00 ? "Data" :
                                               val_to_str_const(packet_type, packet_type_vals, "Unknown"));
        rdt_packet_tree = proto_item_add_subtree(ti, ett_rdt_packet);

        /* Dissect the details of the next packet in this frame */
        if (packet_type < 0xff00)
        {
            offset = dissect_rdt_data_packet(tvb, pinfo, rdt_packet_tree, offset);
        }
        else
        {
            switch (packet_type)
            {
            case RDT_ASMACTIION_PACKET:
                offset = dissect_rdt_asm_action_packet(tvb, pinfo, rdt_packet_tree, offset);
                break;
            case RDT_BANDWIDTHREPORT_PACKET:
                offset = dissect_rdt_bandwidth_report_packet(tvb, pinfo, rdt_packet_tree, offset);
                break;
            case RDT_ACK_PACKET:
                offset = dissect_rdt_ack_packet(tvb, pinfo, rdt_packet_tree, offset);
                break;
            case RDT_RTTREQUEST_PACKET:
                offset = dissect_rdt_rtt_request_packet(tvb, pinfo, rdt_packet_tree, offset);
                break;
            case RDT_RTTRESPONSE_PACKET:
                offset = dissect_rdt_rtt_response_packet(tvb, pinfo, rdt_packet_tree, offset);
                break;
            case RDT_CONGESTION_PACKET:
                offset = dissect_rdt_congestion_packet(tvb, pinfo, rdt_packet_tree, offset);
                break;
            case RDT_STREAMEND_PACKET:
                offset = dissect_rdt_stream_end_packet(tvb, pinfo, rdt_packet_tree, offset);
                break;
            case RDT_REPORT_PACKET:
                offset = dissect_rdt_report_packet(tvb, pinfo, rdt_packet_tree, offset);
                break;
            case RDT_LATENCYREPORT_PACKET:
                offset = dissect_rdt_latency_report_packet(tvb, pinfo, rdt_packet_tree, offset);
                break;
            case RDT_TRANSPORTINFO_PACKET:
                offset = dissect_rdt_transport_info_request_packet(tvb, pinfo, rdt_packet_tree, offset);
                break;
            case RDT_TRANSPORTINFORESPONSE_PACKET:
                offset = dissect_rdt_transport_info_response_packet(tvb, pinfo, rdt_packet_tree, offset);
                break;
            case RDT_BWPROBING_PACKET:
                offset = dissect_rdt_bw_probing_packet(tvb, pinfo, rdt_packet_tree, offset);
                break;

            default:
                /* Unknown control packet */
                offset = dissect_rdt_unknown_control(tvb, pinfo, rdt_packet_tree, offset);
                break;
            }
        }

        /* Select correct number of bytes for the tree showing this packet */
        if (offset != -1)
        {
            proto_item_set_len(rdt_packet_tree, offset-previous_offset);
        }
        previous_offset = offset;
    }

    return tvb_captured_length(tvb);
}



/************************************************/
/* Functions to dissect individual packet types */
/************************************************/

/* Dissect a data packet */
unsigned dissect_rdt_data_packet(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree, unsigned offset)
{
    unsigned    start_offset = offset;
    uint16_t    packet_length;
    uint8_t     flags1;
    uint8_t     length_included_flag;
    uint8_t     need_reliable_flag;
    uint16_t    stream_id;
    uint16_t    sequence_number;
    uint8_t     is_reliable_flag;
    uint8_t     flags2;
    uint32_t    timestamp;
    uint16_t    asm_rule_number;
    uint8_t     back_to_back;
    uint8_t     slow_data;
    proto_tree  *flags_tree1;
    proto_tree  *flags_tree2;
    proto_item  *ti;

    /* Flags in first byte */
    flags1 = tvb_get_uint8(tvb, offset);
    length_included_flag = (flags1 & 0x80) >> 7;
    need_reliable_flag = (flags1 & 0x40) >> 6;
    stream_id = (flags1 & 0x3e) >> 1;
    is_reliable_flag = flags1 & 0x01;

    /* Create subtree for flags1 fields */
    ti =  proto_tree_add_string_format(tree, hf_rdt_data_flags1, tvb, offset, 1,
            "",
            "Length-included=%u, need-reliable=%u, stream-id=%u, is-reliable=%u",
            length_included_flag,
            need_reliable_flag,
            stream_id,
            is_reliable_flag);
    flags_tree1 = proto_item_add_subtree(ti, ett_rdt_data_flags1);

    proto_tree_add_item(flags_tree1, hf_rdt_len_included, tvb, offset, 1, ENC_BIG_ENDIAN);
    proto_tree_add_item(flags_tree1, hf_rdt_data_need_reliable, tvb, offset, 1, ENC_BIG_ENDIAN);
    proto_tree_add_item(flags_tree1, hf_rdt_data_stream_id, tvb, offset, 1, ENC_BIG_ENDIAN);
    proto_tree_add_item(flags_tree1, hf_rdt_data_is_reliable, tvb, offset, 1, ENC_BIG_ENDIAN);
    offset++;

    /* Sequence number */
    sequence_number = tvb_get_ntohs(tvb, offset);
    proto_tree_add_item(tree, hf_rdt_sequence_number, tvb, offset, 2, ENC_BIG_ENDIAN);
    offset += 2;

    /* Length field is optional */
    if (length_included_flag)
    {
        packet_length = tvb_get_ntohs(tvb, offset);
        proto_tree_add_item(tree, hf_rdt_packet_length, tvb, offset, 2, ENC_BIG_ENDIAN);
        offset += 2;

        /* Check that there are as many bytes as reported */
        tvb_ensure_bytes_exist(tvb, start_offset, packet_length);
    }
    else
    {
        packet_length = tvb_captured_length_remaining(tvb, start_offset);
    }

    /* More flags */
    flags2 = tvb_get_uint8(tvb, offset);
    back_to_back = (flags2 & 0x80) >> 7;
    slow_data = (flags2 & 0x40) >> 6;
    asm_rule_number = flags2 & 0x3f;


    /* Create subtree for flags2 fields */
    ti =  proto_tree_add_string_format(tree, hf_rdt_data_flags2, tvb, offset, 1,
            "",
            "Back-to-back=%u, slow-data=%u, asm-rule=%u",
            back_to_back,
            slow_data,
            asm_rule_number);

    /* Create subtree for flags and add fields */
    flags_tree2 = proto_item_add_subtree(ti, ett_rdt_data_flags2);

    proto_tree_add_item(flags_tree2, hf_rdt_data_backtoback, tvb, offset, 1, ENC_BIG_ENDIAN);
    proto_tree_add_item(flags_tree2, hf_rdt_data_slowdata, tvb, offset, 1, ENC_BIG_ENDIAN);
    proto_tree_add_item(flags_tree2, hf_rdt_data_asmrule, tvb, offset, 1, ENC_BIG_ENDIAN);
    offset++;

    /* Timestamp */
    timestamp = tvb_get_ntohl(tvb, offset);
    proto_tree_add_item(tree, hf_rdt_timestamp, tvb, offset, 4, ENC_BIG_ENDIAN);
    offset += 4;

    /* Stream ID expansion */
    if (stream_id == 31)
    {
        stream_id = tvb_get_ntohs(tvb, offset);
        proto_tree_add_item(tree, hf_rdt_stream_id_ex, tvb, offset, 2, ENC_BIG_ENDIAN);
        offset += 2;
    }

    /* Total reliable */
    if (need_reliable_flag)
    {
        proto_tree_add_item(tree, hf_rdt_total_reliable, tvb, offset, 2, ENC_BIG_ENDIAN);
        offset += 2;
    }

    /* Asm rule number */
    if (asm_rule_number == 63)
    {
        asm_rule_number = tvb_get_ntohs(tvb, offset);
        proto_tree_add_item(tree, hf_rdt_asmrule_ex, tvb, offset, 2, ENC_BIG_ENDIAN);
        offset += 2;
    }

    col_append_fstr(pinfo->cinfo, COL_INFO,
                    "DATA: stream-id=%02u asm-rule=%02u seq=%05u ts=%05u  ",
                    stream_id, asm_rule_number, sequence_number, timestamp);

    /* The remaining data is unparsed. */
    proto_tree_add_item(tree, hf_rdt_data, tvb, offset, -1, ENC_NA);
    offset += tvb_captured_length_remaining(tvb, offset);

    if (packet_length < (offset - start_offset) ||
        packet_length > tvb_reported_length_remaining(tvb, start_offset))
    {
        proto_tree_add_expert(tree, pinfo, &ei_rdt_packet_length, tvb, 0, 0);
        packet_length = tvb_captured_length_remaining(tvb, start_offset);
    }

    return start_offset + packet_length;
}

/* Dissect an asm-action packet */
unsigned dissect_rdt_asm_action_packet(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree, unsigned offset)
{
    unsigned    start_offset = offset;
    uint16_t    packet_length;
    uint8_t     flags1;
    uint8_t     length_included_flag;
    uint16_t    stream_id;
    uint16_t    rel_seqno;
    proto_tree  *flags_tree;
    proto_item  *ti;

    /* Flags in first byte */
    flags1 = tvb_get_uint8(tvb, offset);
    length_included_flag = (flags1 & 0x80) >> 7;
    stream_id = (flags1 & 0x7c) >> 2;

    /* Create subtree for flags fields */
    proto_tree_add_item(tree, proto_rdt, tvb, offset, -1, ENC_NA);
    ti =  proto_tree_add_string_format(tree, hf_rdt_aact_flags, tvb, offset, 1,
            "",
            "Length-included=%u, stream_id=%u",
            length_included_flag,
            stream_id);
    flags_tree = proto_item_add_subtree(ti, ett_rdt_aact_flags);

    proto_tree_add_item(flags_tree, hf_rdt_len_included, tvb, offset, 1, ENC_BIG_ENDIAN);
    proto_tree_add_item(flags_tree, hf_rdt_aact_stream_id, tvb, offset, 1, ENC_BIG_ENDIAN);
    offset++;

    /* Packet type */
    proto_tree_add_item(tree, hf_rdt_packet_type, tvb, offset, 2, ENC_BIG_ENDIAN);
    offset += 2;

    rel_seqno = tvb_get_ntohs(tvb, offset);
    proto_tree_add_item(tree, hf_rdt_aact_reliable_seqno, tvb, offset, 2, ENC_BIG_ENDIAN);
    offset += 2;

    /* Length field is optional */
    if (length_included_flag)
    {
        packet_length = tvb_get_ntohs(tvb, offset);
        proto_tree_add_item(tree, hf_rdt_packet_length, tvb, offset, 2, ENC_BIG_ENDIAN);
        offset += 2;

        /* Check that there are as many bytes as reported */
        tvb_ensure_bytes_exist(tvb, start_offset, packet_length);
    }
    else
    {
        packet_length = tvb_captured_length_remaining(tvb, start_offset);
    }

    /* Stream ID expansion */
    if (stream_id == 31)
    {
        stream_id = tvb_get_ntohs(tvb, offset);
        proto_tree_add_item(tree, hf_rdt_stream_id_ex, tvb, offset, 2, ENC_BIG_ENDIAN);
        offset += 2;
    }

    col_append_fstr(pinfo->cinfo, COL_INFO,
                    "ASM-ACTION: stream-id=%02u rel-seqno=%05u  ",
                    stream_id, rel_seqno);

    /* The remaining data is unparsed. */
    proto_tree_add_item(tree, hf_rdt_data, tvb, offset, -1, ENC_NA);

    if (packet_length < (offset - start_offset) ||
        packet_length > tvb_reported_length_remaining(tvb, start_offset))
    {
        proto_tree_add_expert(tree, pinfo, &ei_rdt_packet_length, tvb, 0, 0);
        packet_length = tvb_captured_length_remaining(tvb, start_offset);
    }

    return start_offset + packet_length;
}

/* Dissect an bandwidth-report packet */
unsigned dissect_rdt_bandwidth_report_packet(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree, unsigned offset)
{
    unsigned    start_offset = offset;
    uint16_t    packet_length;
    uint8_t     flags1;
    uint8_t     length_included_flag;
    proto_tree  *flags_tree;
    proto_item  *ti;

    /* Flags in first byte */
    flags1 = tvb_get_uint8(tvb, offset);
    length_included_flag = (flags1 & 0x80) >> 7;

    /* Create subtree for flags fields */
    ti =  proto_tree_add_string_format(tree, hf_rdt_bandwidth_report_flags, tvb, offset, 1,
            "",
            "Length-included=%u",
            length_included_flag);
    flags_tree = proto_item_add_subtree(ti, ett_rdt_bandwidth_report_flags);

    proto_tree_add_item(flags_tree, hf_rdt_len_included, tvb, offset, 1, ENC_BIG_ENDIAN);
    offset++;

    /* Packet type */
    proto_tree_add_item(tree, hf_rdt_packet_type, tvb, offset, 2, ENC_BIG_ENDIAN);
    offset += 2;

    /* Length field is optional */
    if (length_included_flag)
    {
        packet_length = tvb_get_ntohs(tvb, offset);
        proto_tree_add_item(tree, hf_rdt_packet_length, tvb, offset, 2, ENC_BIG_ENDIAN);
        offset += 2;

        /* Check that there are as many bytes as reported */
        tvb_ensure_bytes_exist(tvb, start_offset, packet_length);
    }
    else
    {
        packet_length = tvb_captured_length_remaining(tvb, start_offset);
    }

    proto_tree_add_item(tree, hf_rdt_brpt_interval, tvb, offset, 2, ENC_BIG_ENDIAN);
    offset += 2;
    proto_tree_add_item(tree, hf_rdt_brpt_bandwidth, tvb, offset, 4, ENC_BIG_ENDIAN);
    offset += 4;
    proto_tree_add_item(tree, hf_rdt_brpt_sequence, tvb, offset, 1, ENC_BIG_ENDIAN);
    offset += 1;

    col_append_str(pinfo->cinfo, COL_INFO, "BANDWIDTH-REPORT:  ");

    if (packet_length < (offset - start_offset) ||
        packet_length > tvb_reported_length_remaining(tvb, start_offset))
    {
        proto_tree_add_expert(tree, pinfo, &ei_rdt_packet_length, tvb, 0, 0);
        packet_length = tvb_captured_length_remaining(tvb, start_offset);
    }

    return start_offset + packet_length;
}

/* Dissect an ack packet */
unsigned dissect_rdt_ack_packet(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree, unsigned offset)
{
    unsigned    start_offset = offset;
    uint16_t    packet_length;
    uint8_t     flags1;
    uint8_t     length_included_flag;
    uint8_t     lost_high_flag;
    proto_tree  *flags_tree;
    proto_item  *ti;

    /* Flags in first byte */
    flags1 = tvb_get_uint8(tvb, offset);
    length_included_flag = (flags1 & 0x80) >> 7;
    lost_high_flag = (flags1 & 0x40) >> 6;

    /* Create subtree for flags fields */
    ti =  proto_tree_add_string_format(tree, hf_rdt_ack_flags, tvb, offset, 1,
            "",
            "Length-included=%u, lost-high=%u",
            length_included_flag,
            lost_high_flag);
    flags_tree = proto_item_add_subtree(ti, ett_rdt_ack_flags);

    proto_tree_add_item(flags_tree, hf_rdt_len_included, tvb, offset, 1, ENC_BIG_ENDIAN);
    proto_tree_add_item(flags_tree, hf_rdt_ack_lost_high, tvb, offset, 1, ENC_BIG_ENDIAN);
    offset++;

    /* Packet type */
    proto_tree_add_item(tree, hf_rdt_packet_type, tvb, offset, 2, ENC_BIG_ENDIAN);
    offset += 2;

    /* Length field is optional */
    if (length_included_flag)
    {
        packet_length = tvb_get_ntohs(tvb, offset);
        proto_tree_add_item(tree, hf_rdt_packet_length, tvb, offset, 2, ENC_BIG_ENDIAN);
        offset += 2;

        /* Check that there are as many bytes as reported */
        tvb_ensure_bytes_exist(tvb, start_offset, packet_length);
    }
    else
    {
        packet_length = tvb_captured_length_remaining(tvb, start_offset);
    }

    /* XXX: The remaining data is unparsed. */
    proto_tree_add_item(tree, hf_rdt_data, tvb, offset, -1, ENC_NA);

    col_append_fstr(pinfo->cinfo, COL_INFO, "ACK: lh=%u  ", lost_high_flag);

    if (packet_length < (offset - start_offset) ||
        packet_length > tvb_reported_length_remaining(tvb, start_offset))
    {
        proto_tree_add_expert(tree, pinfo, &ei_rdt_packet_length, tvb, 0, 0);
        packet_length = tvb_captured_length_remaining(tvb, start_offset);
    }

    return start_offset + packet_length;
}

/* Dissect an att-request packet */
unsigned dissect_rdt_rtt_request_packet(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree, unsigned offset)
{
    /* Flags in first byte */
    offset++;

    /* Packet type */
    proto_tree_add_item(tree, hf_rdt_packet_type, tvb, offset, 2, ENC_BIG_ENDIAN);
    offset += 2;

    col_append_str(pinfo->cinfo, COL_INFO, "RTT-REQUEST:  ");

    return offset;
}

/* Dissect an att-response packet */
unsigned dissect_rdt_rtt_response_packet(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree, unsigned offset)
{
    /* Flags in first byte */
    offset++;

    /* Packet type */
    proto_tree_add_item(tree, hf_rdt_packet_type, tvb, offset, 2, ENC_BIG_ENDIAN);
    offset += 2;

    proto_tree_add_item(tree, hf_rdt_rtrp_ts_sec, tvb, offset, 4, ENC_BIG_ENDIAN);
    offset += 4;
    proto_tree_add_item(tree, hf_rdt_rtrp_ts_usec, tvb, offset, 4, ENC_BIG_ENDIAN);
    offset += 4;

    col_append_str(pinfo->cinfo, COL_INFO, "RTT-RESPONSE:  ");

    return offset;
}

/* Dissect an congestion packet */
unsigned dissect_rdt_congestion_packet(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree, unsigned offset)
{
    /* Flags in first byte */
    offset++;

    /* Packet type */
    proto_tree_add_item(tree, hf_rdt_packet_type, tvb, offset, 2, ENC_BIG_ENDIAN);
    offset += 2;

    proto_tree_add_item(tree, hf_rdt_cong_xmit_mult, tvb, offset, 4, ENC_BIG_ENDIAN);
    offset += 4;
    proto_tree_add_item(tree, hf_rdt_cong_recv_mult, tvb, offset, 4, ENC_BIG_ENDIAN);
    offset += 4;

    col_append_str(pinfo->cinfo, COL_INFO, "CONGESTION:  ");

    return offset;
}

/* Dissect an stream-end packet */
unsigned dissect_rdt_stream_end_packet(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree, unsigned offset)
{
    uint8_t     flags1;
    uint8_t     need_reliable;
    uint16_t    stream_id;
    uint8_t     packet_sent;
    uint8_t     ext_flag;
    proto_tree  *flags_tree;
    proto_item  *ti;

    /* Flags in first byte */
    flags1 = tvb_get_uint8(tvb, offset);
    need_reliable = (flags1 & 0x80) >> 7;
    stream_id = (flags1 & 0x7c) >> 2;
    packet_sent = (flags1 & 0x2) >> 1;
    ext_flag = flags1 & 0x1;

    /* Create subtree for flags fields */
    ti =  proto_tree_add_string_format(tree, hf_rdt_stre_flags, tvb, offset, 1,
            "",
            "Need-reliable=%u, stream-id=%u, packet-sent=%u, ext-flag=%u",
            need_reliable,
            stream_id,
            packet_sent,
            ext_flag);
    flags_tree = proto_item_add_subtree(ti, ett_rdt_stre_flags);

    proto_tree_add_item(flags_tree, hf_rdt_stre_need_reliable, tvb, offset, 1, ENC_BIG_ENDIAN);
    proto_tree_add_item(flags_tree, hf_rdt_stre_stream_id, tvb, offset, 1, ENC_BIG_ENDIAN);
    proto_tree_add_item(flags_tree, hf_rdt_stre_packet_sent, tvb, offset, 1, ENC_BIG_ENDIAN);
    proto_tree_add_item(flags_tree, hf_rdt_stre_ext_flag, tvb, offset, 1, ENC_BIG_ENDIAN);
    offset++;

    /* Packet type */
    proto_tree_add_item(tree, hf_rdt_packet_type, tvb, offset, 2, ENC_BIG_ENDIAN);
    offset += 2;

    proto_tree_add_item(tree, hf_rdt_stre_seqno, tvb, offset, 2, ENC_BIG_ENDIAN);
    offset += 2;
    proto_tree_add_item(tree, hf_rdt_timestamp, tvb, offset, 4, ENC_BIG_ENDIAN);
    offset += 4;

    /* Stream ID expansion */
    if (stream_id == 31)
    {
        stream_id = tvb_get_ntohs(tvb, offset);
        proto_tree_add_item(tree, hf_rdt_stream_id_ex, tvb, offset, 2, ENC_BIG_ENDIAN);
        offset += 2;
    }

    /* Total reliable */
    if (need_reliable)
    {
        proto_tree_add_item(tree, hf_rdt_total_reliable, tvb, offset, 2, ENC_BIG_ENDIAN);
        offset += 2;
    }

    if (ext_flag)
    {
        proto_tree_add_item(tree, hf_rdt_stre_dummy_flags1, tvb, offset, 1, ENC_BIG_ENDIAN);
        offset += 1;
        proto_tree_add_item(tree, hf_rdt_stre_dummy_type, tvb, offset, 2, ENC_BIG_ENDIAN);
        offset += 2;
        proto_tree_add_item(tree, hf_rdt_stre_reason_code, tvb, offset, 4, ENC_BIG_ENDIAN);
        offset += 4;
        /* XXX: Remainder is reason_text */
        offset += tvb_captured_length_remaining(tvb, offset);
    }

    col_append_fstr(pinfo->cinfo, COL_INFO, "STREAM-END: stream-id=%02u  ", stream_id);

    return offset;
}

/* Dissect an report packet */
unsigned dissect_rdt_report_packet(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree, unsigned offset)
{
    unsigned    start_offset = offset;
    uint16_t    packet_length;
    uint8_t     flags1;
    uint8_t     length_included_flag;
    proto_tree  *flags_tree;
    proto_item  *ti;

    /* Flags in first byte */
    flags1 = tvb_get_uint8(tvb, offset);
    length_included_flag = (flags1 & 0x80) >> 7;

    /* Create subtree for flags fields */
    ti =  proto_tree_add_string_format(tree, hf_rdt_report_flags, tvb, offset, 1,
            "",
            "Length-included=%u",
            length_included_flag);
    flags_tree = proto_item_add_subtree(ti, ett_rdt_report_flags);

    proto_tree_add_item(flags_tree, hf_rdt_len_included, tvb, offset, 1, ENC_BIG_ENDIAN);
    offset++;

    /* Packet type */
    proto_tree_add_item(tree, hf_rdt_packet_type, tvb, offset, 2, ENC_BIG_ENDIAN);
    offset += 2;

    /* Length field is optional */
    if (length_included_flag)
    {
        packet_length = tvb_get_ntohs(tvb, offset);
        proto_tree_add_item(tree, hf_rdt_packet_length, tvb, offset, 2, ENC_BIG_ENDIAN);
        offset += 2;

        /* Check that there are as many bytes as reported */
        tvb_ensure_bytes_exist(tvb, start_offset, packet_length);
    }
    else
    {
        packet_length = tvb_captured_length_remaining(tvb, start_offset);
    }

    col_append_str(pinfo->cinfo, COL_INFO, "REPORT:  ");

    /* The remaining data is unparsed. */
    proto_tree_add_item(tree, hf_rdt_data, tvb, offset, -1, ENC_NA);

    if (packet_length < (offset - start_offset) ||
        packet_length > tvb_reported_length_remaining(tvb, start_offset))
    {
        proto_tree_add_expert(tree, pinfo, &ei_rdt_packet_length, tvb, 0, 0);
        packet_length = tvb_captured_length_remaining(tvb, start_offset);
    }

    return start_offset + packet_length;
}

/* Dissect an latency-report packet */
unsigned dissect_rdt_latency_report_packet(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree, unsigned offset)
{
    unsigned    start_offset = offset;
    uint16_t    packet_length;
    uint8_t     flags1;
    uint8_t     length_included_flag;
    uint32_t    server_out_time;
    proto_tree  *flags_tree;
    proto_item  *ti;

    /* Flags in first byte */
    flags1 = tvb_get_uint8(tvb, offset);
    length_included_flag = (flags1 & 0x80) >> 7;

    /* Create subtree for flags fields */
    ti =  proto_tree_add_string_format(tree, hf_rdt_latency_report_flags, tvb, offset, 1,
            "",
            "Length-included=%u",
            length_included_flag);
    flags_tree = proto_item_add_subtree(ti, ett_rdt_latency_report_flags);

    proto_tree_add_item(flags_tree, hf_rdt_len_included, tvb, offset, 1, ENC_BIG_ENDIAN);
    offset++;

    /* Packet type */
    proto_tree_add_item(tree, hf_rdt_packet_type, tvb, offset, 2, ENC_BIG_ENDIAN);
    offset += 2;

    /* Length field is optional */
    if (length_included_flag)
    {
        packet_length = tvb_get_ntohs(tvb, offset);
        proto_tree_add_item(tree, hf_rdt_packet_length, tvb, offset, 2, ENC_BIG_ENDIAN);
        offset += 2;

        /* Check that there are as many bytes as reported */
        tvb_ensure_bytes_exist(tvb, start_offset, packet_length);
    }
    else
    {
        packet_length = tvb_captured_length_remaining(tvb, start_offset);
    }

    server_out_time = tvb_get_ntohl(tvb, offset);
    proto_tree_add_item(tree, hf_rdt_lrpt_server_out_time, tvb, offset, 4, ENC_BIG_ENDIAN);
    offset += 4;

    col_append_fstr(pinfo->cinfo, COL_INFO, "LATENCY-REPORT: t=%u  ", server_out_time);

    if (packet_length < (offset - start_offset) ||
        packet_length > tvb_reported_length_remaining(tvb, start_offset))
    {
        proto_tree_add_expert(tree, pinfo, &ei_rdt_packet_length, tvb, 0, 0);
        packet_length = tvb_captured_length_remaining(tvb, start_offset);
    }

    return start_offset + packet_length;
}

/* Dissect a transport-info packet */
unsigned dissect_rdt_transport_info_request_packet(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree, unsigned offset)
{
    uint8_t     flags1;
    uint8_t     request_rtt_info_flag;
    uint8_t     request_buffer_info_flag;
    proto_tree  *flags_tree;
    proto_item  *ti;

    /* Flags in first byte */
    flags1 = tvb_get_uint8(tvb, offset);
    request_rtt_info_flag = (flags1 & 0x2) >> 1;
    request_buffer_info_flag = (flags1 & 0x01);

    /* Create subtree for flags fields */
    ti =  proto_tree_add_string_format(tree, hf_rdt_ack_flags, tvb, offset, 1,
            "",
            "Request-rtt-info=%u, request-buffer-info=%u",
            request_rtt_info_flag,
            request_buffer_info_flag);
    flags_tree = proto_item_add_subtree(ti, ett_rdt_tirq_flags);

    proto_tree_add_item(flags_tree, hf_rdt_tirq_request_rtt_info, tvb, offset, 1, ENC_BIG_ENDIAN);
    proto_tree_add_item(flags_tree, hf_rdt_tirq_request_buffer_info, tvb, offset, 1, ENC_BIG_ENDIAN);
    offset++;

    /* Packet type */
    proto_tree_add_item(tree, hf_rdt_packet_type, tvb, offset, 2, ENC_BIG_ENDIAN);
    offset += 2;

    if (request_rtt_info_flag)
    {
        proto_tree_add_item(tree, hf_rdt_tirq_request_time_msec, tvb, offset, 4, ENC_BIG_ENDIAN);
        offset += 4;
    }

    col_append_str(pinfo->cinfo, COL_INFO, "TRANSPORT-INFO-REQUEST:  ");

    return offset;
}

/* Dissect an transport-info-response packet */
unsigned dissect_rdt_transport_info_response_packet(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree, unsigned offset)
{
    uint8_t     flags1;
    uint8_t     has_rtt_info;
    uint8_t     is_delayed;
    uint8_t     has_buffer_info;
    proto_tree  *flags_tree;
    proto_item  *ti;

    /* Flags in first byte */
    flags1 = tvb_get_uint8(tvb, offset);
    has_rtt_info = (flags1 & 0x4) >> 2;
    is_delayed = (flags1 & 0x2) >> 1;
    has_buffer_info = (flags1 & 0x1);

    /* Create subtree for flags fields */
    ti =  proto_tree_add_string_format(tree, hf_rdt_tirp_flags, tvb, offset, 1,
            "",
            "Has-rtt-info=%u, is-delayed=%u, has-buffer-info=%u",
            has_rtt_info,
            is_delayed,
            has_buffer_info);
    flags_tree = proto_item_add_subtree(ti, ett_rdt_tirp_flags);

    proto_tree_add_item(flags_tree, hf_rdt_tirp_has_rtt_info, tvb, offset, 1, ENC_BIG_ENDIAN);
    proto_tree_add_item(flags_tree, hf_rdt_tirp_is_delayed, tvb, offset, 1, ENC_BIG_ENDIAN);
    proto_tree_add_item(flags_tree, hf_rdt_tirp_has_buffer_info, tvb, offset, 1, ENC_BIG_ENDIAN);
    offset++;

    /* Packet type */
    proto_tree_add_item(tree, hf_rdt_packet_type, tvb, offset, 2, ENC_BIG_ENDIAN);
    offset += 2;

    /* RTT info */
    if (has_rtt_info)
    {
        proto_tree_add_item(tree, hf_rdt_tirp_request_time_msec, tvb, offset, 4, ENC_BIG_ENDIAN);
        offset += 4;

        if (is_delayed)
        {
            proto_tree_add_item(tree, hf_rdt_tirp_response_time_msec, tvb, offset, 4, ENC_BIG_ENDIAN);
            offset += 4;
        }
    }

    /* Buffer info */
    if (has_buffer_info)
    {
        uint16_t n;

        /* Read number of buffers */
        uint16_t buffer_info_count = tvb_get_ntohs(tvb, offset);
        proto_tree_add_item(tree, hf_rdt_tirp_buffer_info_count, tvb, offset, 2, ENC_BIG_ENDIAN);
        offset += 2;

        for (n=0; n < buffer_info_count; n++)
        {
            proto_tree  *buffer_info_tree;
            proto_item  *ti2;

            /* Each buffer info in a new subtree */
            ti2 =  proto_tree_add_string_format(tree, hf_rdt_tirp_buffer_info, tvb, offset, 14,
                                               "",
                                               "Buffer info %u",
                                               n+1);
            buffer_info_tree = proto_item_add_subtree(ti2, ett_rdt_tirp_buffer_info);

            /* Read individual buffer info */
            proto_tree_add_item(buffer_info_tree, hf_rdt_tirp_buffer_info_stream_id, tvb, offset, 2, ENC_BIG_ENDIAN);
            offset += 2;
            proto_tree_add_item(buffer_info_tree, hf_rdt_tirp_buffer_info_lowest_timestamp, tvb, offset, 4, ENC_BIG_ENDIAN);
            offset += 4;
            proto_tree_add_item(buffer_info_tree, hf_rdt_tirp_buffer_info_highest_timestamp, tvb, offset, 4, ENC_BIG_ENDIAN);
            offset += 4;
            proto_tree_add_item(buffer_info_tree, hf_rdt_tirp_buffer_info_bytes_buffered, tvb, offset, 4, ENC_BIG_ENDIAN);
            offset += 4;
        }
    }

    /* Report what is left */
    offset += tvb_captured_length_remaining(tvb, offset);

    col_append_str(pinfo->cinfo, COL_INFO, "RESPONSE:  ");

    return offset;
}

/* Dissect a bw-probing packet */
unsigned dissect_rdt_bw_probing_packet(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree, unsigned offset)
{
    unsigned    start_offset = offset;
    uint16_t    packet_length;
    uint8_t     flags1;
    uint8_t     length_included_flag;
    proto_tree  *flags_tree;
    proto_item  *ti;

    /* Flags in first byte */
    flags1 = tvb_get_uint8(tvb, offset);
    length_included_flag = (flags1 & 0x80) >> 7;

    /* Create subtree for flags fields */
    ti =  proto_tree_add_string_format(tree, hf_rdt_bw_probing_flags, tvb, offset, 1,
            "",
            "Length-included=%u",
            length_included_flag);
    flags_tree = proto_item_add_subtree(ti, ett_rdt_bw_probing_flags);

    proto_tree_add_item(flags_tree, hf_rdt_len_included, tvb, offset, 1, ENC_BIG_ENDIAN);
    offset++;

    /* Packet type */
    proto_tree_add_item(tree, hf_rdt_packet_type, tvb, offset, 2, ENC_BIG_ENDIAN);
    offset += 2;

    /* Length field is optional */
    if (length_included_flag)
    {
        packet_length = tvb_get_ntohs(tvb, offset);
        proto_tree_add_item(tree, hf_rdt_packet_length, tvb, offset, 2, ENC_BIG_ENDIAN);
        offset += 2;

        /* Check that there are as many bytes as reported */
        tvb_ensure_bytes_exist(tvb, start_offset, packet_length);
    }
    else
    {
        packet_length = tvb_captured_length_remaining(tvb, start_offset);
    }

    proto_tree_add_item(tree, hf_rdt_bwpp_seqno, tvb, offset, 1, ENC_BIG_ENDIAN);
    offset += 1;
    proto_tree_add_item(tree, hf_rdt_timestamp, tvb, offset, 1, ENC_BIG_ENDIAN);
    offset += 4;

    col_append_str(pinfo->cinfo, COL_INFO, "BW-PROBING:  ");

    if (packet_length < (offset - start_offset) ||
        packet_length > tvb_reported_length_remaining(tvb, start_offset))
    {
        proto_tree_add_expert(tree, pinfo, &ei_rdt_packet_length, tvb, 0, 0);
        packet_length = tvb_captured_length_remaining(tvb, start_offset);
    }

    return start_offset + packet_length;
}

/* Dissect an unknown control packet */
unsigned dissect_rdt_unknown_control(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree, unsigned offset)
{
    /* Flags in first byte */
    proto_tree_add_item(tree, hf_rdt_unk_flags1, tvb, offset, 1, ENC_BIG_ENDIAN);
    offset++;

    /* Packet type */
    proto_tree_add_item(tree, hf_rdt_packet_type, tvb, offset, 2, ENC_BIG_ENDIAN);
    offset += 2;

    /* The remaining data is unparsed. */
    proto_tree_add_item(tree, hf_rdt_data, tvb, offset, -1, ENC_NA);
    offset += tvb_captured_length_remaining(tvb, offset);

    col_append_str(pinfo->cinfo, COL_INFO, "UNKNOWN-CTL:  ");

    return offset;
}

/* Look for conversation info and display any setup info found */
static void show_setup_info(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree)
{
    /* Conversation and current data */
    conversation_t *p_conv;
    struct _rdt_conversation_info *p_conv_data;

    /* Use existing packet info if available */
    p_conv_data = (struct _rdt_conversation_info *)p_get_proto_data(wmem_file_scope(), pinfo, proto_rdt, 0);

    if (!p_conv_data)
    {
        /* First time, get info from conversation */
        p_conv = find_conversation(pinfo->num, &pinfo->net_dst, &pinfo->net_src,
                                   conversation_pt_to_conversation_type(pinfo->ptype),
                                   pinfo->destport, pinfo->srcport, NO_ADDR_B);
        if (p_conv)
        {
            /* Create space for conversation info */
            struct _rdt_conversation_info *p_conv_packet_data;
            p_conv_data = (struct _rdt_conversation_info *)conversation_get_proto_data(p_conv, proto_rdt);

            if (p_conv_data)
            {
                /* Save this conversation info into packet info */
                p_conv_packet_data = wmem_new(wmem_file_scope(), struct _rdt_conversation_info);
                (void) g_strlcpy(p_conv_packet_data->method, p_conv_data->method, MAX_RDT_SETUP_METHOD_SIZE);
                p_conv_packet_data->frame_number = p_conv_data->frame_number;
                p_conv_packet_data->feature_level = p_conv_data->feature_level;
                p_add_proto_data(wmem_file_scope(), pinfo, proto_rdt, 0, p_conv_packet_data);
            }
        }
    }

    /* Create setup info subtree with summary info. */
    if (p_conv_data)
    {
        proto_tree *rdt_setup_tree;
        proto_item *ti =  proto_tree_add_string_format(tree, hf_rdt_setup, tvb, 0, 0,
                                                       "",
                                                       "Stream setup by %s (frame %u), feature level %d",
                                                       p_conv_data->method,
                                                       p_conv_data->frame_number,
                                                       p_conv_data->feature_level);
        proto_item_set_generated(ti);
        rdt_setup_tree = proto_item_add_subtree(ti, ett_rdt_setup);
        if (rdt_setup_tree)
        {
            /* Add details into subtree */
            proto_item* item = proto_tree_add_uint(rdt_setup_tree, hf_rdt_setup_frame,
                                                   tvb, 0, 0, p_conv_data->frame_number);
            proto_item_set_generated(item);
            item = proto_tree_add_string(rdt_setup_tree, hf_rdt_setup_method,
                                         tvb, 0, 0, p_conv_data->method);
            proto_item_set_generated(item);
            item = proto_tree_add_int(rdt_setup_tree, hf_rdt_feature_level,
                                      tvb, 0, 0, p_conv_data->feature_level);
            proto_item_set_generated(item);
        }
    }
}


void proto_register_rdt(void)
{
    static hf_register_info hf[] =
    {
        {
            &hf_rdt_packet,
            {
                "RDT packet",
                "rdt.packet",
                FT_STRING,
                BASE_NONE,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_data_flags1,
            {
                "RDT data flags 1",
                "rdt.data-flags1",
                FT_STRING,
                BASE_NONE,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_len_included,
            {
                "Length included",
                "rdt.length-included",
                FT_UINT8,
                BASE_DEC,
                NULL,
                0x80,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_data_need_reliable,
            {
                "Need reliable",
                "rdt.need-reliable",
                FT_UINT8,
                BASE_DEC,
                NULL,
                0x40,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_data_stream_id,
            {
                "Stream ID",
                "rdt.stream-id",
                FT_UINT8,
                BASE_DEC,
                NULL,
                0x3e,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_data_is_reliable,
            {
                "Is reliable",
                "rdt.is-reliable",
                FT_UINT8,
                BASE_DEC,
                NULL,
                0x01,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_data_flags2,
            {
                "RDT data flags 2",
                "rdt.data-flags2",
                FT_STRING,
                BASE_NONE,
                NULL,
                0x0,
                "RDT data flags2", HFILL
            }
        },
        {
            &hf_rdt_data_backtoback,
            {
                "Back-to-back",
                "rdt.back-to-back",
                FT_UINT8,
                BASE_DEC,
                NULL,
                0x80,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_data_slowdata,
            {
                "Slow data",
                "rdt.slow-data",
                FT_UINT8,
                BASE_DEC,
                NULL,
                0x40,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_data_asmrule,
            {
                "asm rule",
                "rdt.asm-rule",
                FT_UINT8,
                BASE_DEC,
                NULL,
                0x3f,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_aact_flags,
            {
                "RDT asm-action flags 1",
                "rdt.aact-flags",
                FT_STRING,
                BASE_NONE,
                NULL,
                0x0,
                "RDT aact flags", HFILL
            }
        },
        {
            &hf_rdt_aact_stream_id,
            {
                "Stream ID",
                "rdt.stream-id",
                FT_UINT8,
                BASE_DEC,
                NULL,
                0x7c,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_sequence_number,
            {
                "Sequence number",
                "rdt.sequence-number",
                FT_UINT16,
                BASE_DEC,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_packet_type,
            {
                "Packet type",
                "rdt.packet-type",
                FT_UINT16,
                BASE_HEX,
                VALS(packet_type_vals),
                0x0,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_ack_flags,
            {
                "RDT ack flags",
                "rdt.ack-flags",
                FT_STRING,
                BASE_NONE,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_ack_lost_high,
            {
                "Lost high",
                "rdt.lost-high",
                FT_UINT8,
                BASE_DEC,
                NULL,
                0x40,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_latency_report_flags,
            {
                "RDT latency report flags",
                "rdt.latency-report-flags",
                FT_STRING,
                BASE_NONE,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_bandwidth_report_flags,
            {
                "RDT bandwidth report flags",
                "rdt.bandwidth-report-flags",
                FT_STRING,
                BASE_NONE,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_stre_flags,
            {
                "RDT stream end flags",
                "rdt.stream-end-flags",
                FT_STRING,
                BASE_NONE,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
#if 0
        {
            &hf_rdt_rtt_request_flags,
            {
                "RDT rtt request flags",
                "rdt.rtt-request-flags",
                FT_STRING,
                BASE_NONE,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
#endif
#if 0
        {
            &hf_rdt_rtt_response_flags,
            {
                "RDT rtt response flags",
                "rdt.rtt-response-flags",
                FT_STRING,
                BASE_NONE,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
#endif
#if 0
        {
            &hf_rdt_congestion_flags,
            {
                "RDT congestion flags",
                "rdt.congestion-flags",
                FT_STRING,
                BASE_NONE,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
#endif
        {
            &hf_rdt_report_flags,
            {
                "RDT report flags",
                "rdt.report-flags",
                FT_STRING,
                BASE_NONE,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
#if 0
        {
            &hf_rdt_tirq_flags,
            {
                "RDT transport info request flags",
                "rdt.transport-info-request-flags",
                FT_STRING,
                BASE_NONE,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
#endif
        {
            &hf_rdt_tirp_flags,
            {
                "RDT transport info response flags",
                "rdt.transport-info-response-flags",
                FT_STRING,
                BASE_NONE,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_bw_probing_flags,
            {
                "RDT bw probing flags",
                "rdt.bw-probing-flags",
                FT_STRING,
                BASE_NONE,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_packet_length,
            {
                "Packet length",
                "rdt.packet-length",
                FT_UINT16,
                BASE_DEC,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_timestamp,
            {
                "Timestamp",
                "rdt.timestamp",
                FT_UINT32,
                BASE_DEC,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_stream_id_ex,
            {
                "Stream-id expansion",
                "rdt.stream-id-expansion",
                FT_UINT16,
                BASE_DEC,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_asmrule_ex,
            {
                "Asm rule expansion",
                "rdt.asm-rule-expansion",
                FT_UINT16,
                BASE_DEC,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_total_reliable,
            {
                "Total reliable",
                "rdt.total-reliable",
                FT_UINT16,
                BASE_DEC,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_data,
            {
                "Data",
                "rdt.data",
                FT_NONE,
                BASE_NONE,
                NULL,
                0x0,
               NULL, HFILL
            }
        },
        {
            &hf_rdt_aact_reliable_seqno,
            {
                "Reliable sequence number",
                "rdt.reliable-seq-no",
                FT_UINT16,
                BASE_DEC,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_brpt_interval,
            {
                "Bandwidth report interval",
                "rdt.bwid-report-interval",
                FT_UINT16,
                BASE_DEC,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_brpt_bandwidth,
            {
                "Bandwidth report bandwidth",
                "rdt.bwid-report-bandwidth",
                FT_UINT32,
                BASE_DEC,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_brpt_sequence,
            {
                "Bandwidth report sequence",
                "rdt.bwid-report-sequence",
                FT_UINT16,
                BASE_DEC,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_rtrp_ts_sec,
            {
                "Round trip response timestamp seconds",
                "rdt.rtrp-ts-sec",
                FT_UINT32,
                BASE_DEC,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_rtrp_ts_usec,
            {
                "Round trip response timestamp microseconds",
                "rdt.rtrp-ts-usec",
                FT_UINT32,
                BASE_DEC,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_cong_xmit_mult,
            {
                "Congestion transmit multiplier",
                "rdt.cong-xmit-mult",
                FT_UINT32,
                BASE_DEC,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_cong_recv_mult,
            {
                "Congestion receive multiplier",
                "rdt.cong-recv-mult",
                FT_UINT32,
                BASE_DEC,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_stre_need_reliable,
            {
                "Need reliable",
                "rdt.stre-need-reliable",
                FT_UINT8,
                BASE_DEC,
                NULL,
                0x80,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_stre_stream_id,
            {
                "Stream id",
                "rdt.stre-stream-id",
                FT_UINT8,
                BASE_DEC,
                NULL,
                0x7c,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_stre_packet_sent,
            {
                "Packet sent",
                "rdt.stre-packet-sent",
                FT_UINT8,
                BASE_DEC,
                NULL,
                0x02,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_stre_ext_flag,
            {
                "Ext flag",
                "rdt.stre-ext-flag",
                FT_UINT8,
                BASE_DEC,
                NULL,
                0x01,
                NULL, HFILL
            }
        },

        {
            &hf_rdt_stre_seqno,
            {
                "Stream end sequence number",
                "rdt.stre-seqno",
                FT_UINT16,
                BASE_DEC,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_stre_dummy_flags1,
            {
                "Stream end reason dummy flags1",
                "rdt.stre-reason-dummy-flags1",
                FT_UINT8,
                BASE_HEX,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_stre_dummy_type,
            {
                "Stream end reason dummy type",
                "rdt.stre-reason-dummy-type",
                FT_UINT16,
                BASE_HEX,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_stre_reason_code,
            {
                "Stream end reason code",
                "rdt.stre-reason-code",
                FT_UINT32,
                BASE_HEX,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_lrpt_server_out_time,
            {
                "Latency report server out time",
                "rdt.lrpt-server-out-time",
                FT_UINT32,
                BASE_DEC,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_tirq_request_rtt_info,
            {
                "Transport info request rtt info flag",
                "rdt.tirq-request-rtt-info",
                FT_UINT8,
                BASE_DEC,
                NULL,
                0x2,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_tirq_request_buffer_info,
            {
                "Transport info request buffer info flag",
                "rdt.tirq-request-buffer-info",
                FT_UINT8,
                BASE_DEC,
                NULL,
                0x1,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_tirq_request_time_msec,
            {
                "Transport info request time msec",
                "rdt.tirq-request-time-msec",
                FT_UINT32,
                BASE_DEC,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_tirp_has_rtt_info,
            {
                "Transport info response has rtt info flag",
                "rdt.tirp-has-rtt-info",
                FT_UINT8,
                BASE_DEC,
                NULL,
                0x4,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_tirp_is_delayed,
            {
                "Transport info response is delayed",
                "rdt.tirp-is-delayed",
                FT_UINT8,
                BASE_DEC,
                NULL,
                0x2,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_tirp_has_buffer_info,
            {
                "Transport info response has buffer info",
                "rdt.tirp-has-buffer-info",
                FT_UINT8,
                BASE_DEC,
                NULL,
                0x1,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_tirp_request_time_msec,
            {
                "Transport info request time msec",
                "rdt.tirp-request-time-msec",
                FT_UINT32,
                BASE_DEC,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_tirp_response_time_msec,
            {
                "Transport info response time msec",
                "rdt.tirp-response-time-msec",
                FT_UINT32,
                BASE_DEC,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_tirp_buffer_info_count,
            {
                "Transport info buffer into count",
                "rdt.tirp-buffer-info-count",
                FT_UINT16,
                BASE_DEC,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_tirp_buffer_info,
            {
                "RDT buffer info",
                "rdt.tirp-buffer-info",
                FT_STRING,
                BASE_NONE,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_tirp_buffer_info_stream_id,
            {
                "Buffer info stream-id",
                "rdt.tirp-buffer-info-stream-id",
                FT_UINT16,
                BASE_DEC,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_tirp_buffer_info_lowest_timestamp,
            {
                "Lowest timestamp",
                "rdt.tirp-buffer-info-lowest-timestamp",
                FT_UINT32,
                BASE_DEC,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_tirp_buffer_info_highest_timestamp,
            {
                "Highest timestamp",
                "rdt.tirp-buffer-info-highest-timestamp",
                FT_UINT32,
                BASE_DEC,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_tirp_buffer_info_bytes_buffered,
            {
                "Bytes buffered",
                "rdt.tirp-buffer-info-bytes-buffered",
                FT_UINT32,
                BASE_DEC,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_bwpp_seqno,
            {
                "Bandwidth probing packet seqno",
                "rdt.bwpp-seqno",
                FT_UINT8,
                BASE_DEC,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_unk_flags1,
            {
                "Unknown packet flags",
                "rdt.unk-flags1",
                FT_UINT8,
                BASE_DEC,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
        {
            &hf_rdt_setup,
            {
                "Stream setup",
                "rdt.setup",
                FT_STRING,
                BASE_NONE,
                NULL,
                0x0,
                "Stream setup, method and frame number", HFILL
            }
        },
        {
            &hf_rdt_setup_frame,
            {
                "Setup frame",
                "rdt.setup-frame",
                FT_FRAMENUM,
                BASE_NONE,
                NULL,
                0x0,
                "Frame that set up this stream", HFILL
            }
        },
        {
            &hf_rdt_setup_method,
            {
                "Setup Method",
                "rdt.setup-method",
                FT_STRING,
                BASE_NONE,
                NULL,
                0x0,
                "Method used to set up this stream", HFILL
            }
        },
        {
            &hf_rdt_feature_level,
            {
                "RDT feature level",
                "rdt.feature-level",
                FT_INT32,
                BASE_DEC,
                NULL,
                0x0,
                NULL, HFILL
            }
        },
    };

    static int *ett[] =
    {
        &ett_rdt,
        &ett_rdt_packet,
        &ett_rdt_setup,
        &ett_rdt_data_flags1,
        &ett_rdt_data_flags2,
        &ett_rdt_aact_flags,
        &ett_rdt_ack_flags,
        &ett_rdt_latency_report_flags,
        &ett_rdt_bandwidth_report_flags,
        &ett_rdt_stre_flags,
        &ett_rdt_rtt_request_flags,
        &ett_rdt_rtt_response_flags,
        &ett_rdt_congestion_flags,
        &ett_rdt_report_flags,
        &ett_rdt_tirq_flags,
        &ett_rdt_tirp_flags,
        &ett_rdt_tirp_buffer_info,
        &ett_rdt_bw_probing_flags
    };

    static ei_register_info ei[] = {
        { &ei_rdt_packet_length, { "rdt.invalid_packet_length", PI_MALFORMED, PI_ERROR, "Packet length invalid", EXPFILL }},
    };

    module_t *rdt_module;
    expert_module_t* expert_rdt;

    /* Register protocol and fields */
    proto_rdt = proto_register_protocol("Real Data Transport", "RDT", "rdt");
    proto_register_field_array(proto_rdt, hf, array_length(hf));
    proto_register_subtree_array(ett, array_length(ett));
    expert_rdt = expert_register_protocol(proto_rdt);
    expert_register_field_array(expert_rdt, ei, array_length(ei));
    rdt_handle = register_dissector("rdt", dissect_rdt, proto_rdt);

    /* Preference settings */
    rdt_module = prefs_register_protocol(proto_rdt, NULL);
    prefs_register_bool_preference(rdt_module, "show_setup_info",
                                   "Show stream setup information",
                                   "Where available, show which protocol and frame caused "
                                   "this RDT stream to be created",
                                   &global_rdt_show_setup_info);

    prefs_register_obsolete_preference(rdt_module, "register_udp_port");
}

void proto_reg_handoff_rdt(void)
{
    dissector_add_uint_with_preference("udp.port", RDT_UDP_PORT, rdt_handle);
}

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