/* packet-gdsdb.c

 * Routines for Firebird/Interbase dissection

 * Copyright 2007, Moshe van der Sterre <moshevds@gmail.com>

 *

 * Firebird home: http://www.firebirdsql.org

 * Source: http://sourceforge.net/projects/firebird/

 * https://firebirdsql.org/file/documentation/html/en/firebirddocs/wireprotocol/firebird-wire-protocol.html

 *

 * Wireshark - Network traffic analyzer

 * By Gerald Combs <gerald@wireshark.org>

 * Copyright 1998 Gerald Combs

 *

 * SPDX-License-Identifier: GPL-2.0-or-later

 */

#include "config.h"

#include <epan/packet.h>

#include <epan/expert.h>

#include <wsutil/ws_roundup.h>

void proto_register_gdsdb(void);

void proto_reg_handoff_gdsdb(void);

static dissector_handle_t gdsdb_handle;

/* IANA-registered port */

#define TCP_PORT  3050

static int proto_gdsdb;

static int ett_gdsdb;

static int hf_gdsdb_opcode;

/* static int ett_gdsdb_opcode; */

/* gdsdb_dummy */

/* gdsdb_connect */

static int hf_gdsdb_connect_operation;

static int hf_gdsdb_connect_version;

static int hf_gdsdb_connect_client;

static int hf_gdsdb_connect_filename;

static int hf_gdsdb_connect_count;

static int hf_gdsdb_connect_userid;

static int hf_gdsdb_connect_pref;

static int ett_gdsdb_connect_pref;

static int hf_gdsdb_connect_pref_version;

static int hf_gdsdb_connect_pref_architecture;

static int hf_gdsdb_connect_pref_mintype;

static int hf_gdsdb_connect_pref_maxtype;

static int hf_gdsdb_connect_pref_weight;

/* gdsdb_accept */

static int hf_gdsdb_accept_version;

static int hf_gdsdb_accept_architecture;

static int hf_gdsdb_accept_proto_min_type;

/* gdsdb_request */

static int hf_gdsdb_request_type;

static int hf_gdsdb_request_object;

static int hf_gdsdb_request_partner;

/* gdsdb_attach */

static int hf_gdsdb_attach_database_object_id;

static int hf_gdsdb_attach_database_path;

static int hf_gdsdb_attach_database_param_buf;

/* gdsdb_compile */

static int hf_gdsdb_compile_database;

static int hf_gdsdb_compile_blr;

/* gdsdb_receive */

static int hf_gdsdb_receive_request;

static int hf_gdsdb_receive_incarnation;

static int hf_gdsdb_receive_transaction;

static int hf_gdsdb_receive_msgnr;

static int hf_gdsdb_receive_messages;

static int hf_gdsdb_receive_direction;

static int hf_gdsdb_receive_offset;

/* gdsdb_send */

static int hf_gdsdb_send_request;

static int hf_gdsdb_send_incarnation;

static int hf_gdsdb_send_transaction;

static int hf_gdsdb_send_msgnr;

static int hf_gdsdb_send_messages;

/* gdsdb_response */

static int hf_gdsdb_response_object;

static int hf_gdsdb_response_blobid;

static int hf_gdsdb_response_datasize;

static int hf_gdsdb_response_data;

/* gdsdb_status_vector */

static int hf_gdsdb_status_vector_arg;

static int hf_gdsdb_status_vector_error_code;

static int hf_gdsdb_status_vector_number;

static int hf_gdsdb_status_vector_string;

static int hf_gdsdb_status_vector_sql_state;

/* gdsdb_transact */

static int hf_gdsdb_transact_database;

static int hf_gdsdb_transact_transaction;

#if 0

static int hf_gdsdb_transact_messages;

#endif

/* gdsdb_transact_response */

static int hf_gdsdb_transactresponse_messages;

/* gdsdb_open_blob2 */

static int hf_gdsdb_openblob2_bpb;

/* gdsdb_open_blob */

static int hf_gdsdb_openblob_transaction;

static int hf_gdsdb_openblob_id;

#if 0

/* gdsdb_segment */

static int hf_gdsdb_segment_blob;

static int hf_gdsdb_segment_length;

static int hf_gdsdb_segment_segment;

/* gdsdb_seek_blob */

static int hf_gdsdb_seekblob_blob;

static int hf_gdsdb_seekblob_mode;

#endif

/* gdsdb_reconnect */

static int hf_gdsdb_reconnect_handle;

static int hf_gdsdb_reconnect_database_size;

static int hf_gdsdb_reconnect_database;

/* gdsdb_info & gdsdb_service_start */

static int hf_gdsdb_info_object;

static int hf_gdsdb_info_incarnation;

static int hf_gdsdb_info_items;

static int hf_gdsdb_info_recv_items;

static int hf_gdsdb_info_buffer_length;

/* gdsdb_release */

static int hf_gdsdb_release_object;

#if 0

/* gdsdb_prepare2 */

static int hf_gdsdb_prepare2_transaction;

/* gdsdb_event & gdsdb_cancel_events */

static int hf_gdsdb_event_database;

static int hf_gdsdb_event_items;

static int hf_gdsdb_event_ast;

static int hf_gdsdb_event_arg;

static int hf_gdsdb_event_rid;

/* gdsdb_ddl */

static int hf_gdsdb_ddl_database;

static int hf_gdsdb_ddl_transaction;

static int hf_gdsdb_ddl_blr;

/* gdsdb_slice */

static int hf_gdsdb_slice_transaction;

static int hf_gdsdb_slice_id;

static int hf_gdsdb_slice_sdl;

static int hf_gdsdb_slice_parameters;

/* gdsdb_slice_response */

static int hf_gdsdb_sliceresponse_length;

#endif

/* gdsdb_execute */

static int hf_gdsdb_execute_statement;

static int hf_gdsdb_execute_transaction;

static int hf_gdsdb_execute_message_number;

static int hf_gdsdb_execute_messages;

#if 0

/* gdsdb_execute2 */

static int hf_gdsdb_execute_outblr;

static int hf_gdsdb_execute_outmsgnr;

/* gdsdb_exec_immediate2 */

static int hf_gdsdb_prepare2_blr;

static int hf_gdsdb_prepare2_number;

static int hf_gdsdb_prepare2_messages;

static int hf_gdsdb_prepare2_outblr;

static int hf_gdsdb_prepare2_outmsgnr;

#endif

/* gdsdb_prepare */

static int hf_gdsdb_prepare_transaction;

static int hf_gdsdb_prepare_statement;

static int hf_gdsdb_prepare_dialect;

static int hf_gdsdb_prepare_querystr;

static int hf_gdsdb_prepare_bufferlength;

#if 0

/* gdsdb_fetch */

static int hf_gdsdb_fetch_statement;

static int hf_gdsdb_fetch_message_number;

static int hf_gdsdb_fetch_messages;

#endif

/* gdsdb_fetch_response */

static int hf_gdsdb_fetchresponse_status;

static int hf_gdsdb_fetchresponse_messages;

/* gdsdb_free_statement */

static int hf_gdsdb_free_statement;

static int hf_gdsdb_free_option;

#if 0

/* gdsdb_insert */

static int hf_gdsdb_insert_statement;

static int hf_gdsdb_insert_message_number;

static int hf_gdsdb_insert_messages;

/* gdsdb_cursor */

static int hf_gdsdb_cursor_statement;

static int hf_gdsdb_cursor_type;

/* gdsdb_sql_response */

static int hf_gdsdb_sqlresponse_messages;

#endif

static expert_field ei_gdsdb_invalid_length;

enum

{

  op_void                   = 0,

  op_connect                = 1,

  op_exit                   = 2,

  op_accept                 = 3,

  op_reject                 = 4,

  op_protocol               = 5,

  op_disconnect             = 6,

  op_credit                 = 7,

  op_continuation           = 8,

  op_response               = 9,

  op_open_file              = 10,

  op_create_file            = 11,

  op_close_file             = 12,

  op_read_page              = 13,

  op_write_page             = 14,

  op_lock                   = 15,

  op_convert_lock           = 16,

  op_release_lock           = 17,

  op_blocking               = 18,

  op_attach                 = 19,

  op_create                 = 20,

  op_detach                 = 21,

  op_compile                = 22,

  op_start                  = 23,

  op_start_and_send         = 24,

  op_send                   = 25,

  op_receive                = 26,

  op_unwind                 = 27,

  op_release                = 28,

  op_transaction            = 29,

  op_commit                 = 30,

  op_rollback               = 31,

  op_prepare                = 32,

  op_reconnect              = 33,

  op_create_blob            = 34,

  op_open_blob              = 35,

  op_get_segment            = 36,

  op_put_segment            = 37,

  op_cancel_blob            = 38,

  op_close_blob             = 39,

  op_info_database          = 40,

  op_info_request           = 41,

  op_info_transaction       = 42,

  op_info_blob              = 43,

  op_batch_segments         = 44,

  op_mgr_set_affinity       = 45,

  op_mgr_clear_affinity     = 46,

  op_mgr_report             = 47,

  op_que_events             = 48,

  op_cancel_events          = 49,

  op_commit_retaining       = 50,

  op_prepare2               = 51,

  op_event                  = 52,

  op_connect_request        = 53,

  op_aux_connect            = 54,

  op_ddl                    = 55,

  op_open_blob2             = 56,

  op_create_blob2           = 57,

  op_get_slice              = 58,

  op_put_slice              = 59,

  op_slice                  = 60,

  op_seek_blob              = 61,

  op_allocate_statement     = 62,

  op_execute                = 63,

  op_exec_immediate         = 64,

  op_fetch                  = 65,

  op_fetch_response         = 66,

  op_free_statement         = 67,

  op_prepare_statement      = 68,

  op_set_cursor             = 69,

  op_info_sql               = 70,

  op_dummy                  = 71,

  op_response_piggyback     = 72,

  op_start_and_receive      = 73,

  op_start_send_and_receive = 74,

  op_exec_immediate2        = 75,

  op_execute2               = 76,

  op_insert                 = 77,

  op_sql_response           = 78,

  op_transact               = 79,

  op_transact_response      = 80,

  op_drop_database          = 81,

  op_service_attach         = 82,

  op_service_detach         = 83,

  op_service_info           = 84,

  op_service_start          = 85,

  op_rollback_retaining     = 86,

  op_update_account_info    = 87,

  op_authenticate_user      = 88,

  op_partial                = 89,

  op_trusted_auth           = 90,

  op_cancel                 = 91,

  op_max

};

static const value_string gdsdb_opcode[] = {

  { op_void,                   "Void" },

  { op_connect,                "Connect" },

  { op_exit,                   "Exit" },

  { op_accept,                 "Accept" },

  { op_reject,                 "Reject" },

  { op_protocol,               "Protocol" },

  { op_disconnect,             "Disconnect" },

  { op_credit,                 "Credit" },

  { op_continuation,           "Continuation" },

  { op_response,               "Response" },

  { op_open_file,              "Open file" },

  { op_create_file,            "Create file" },

  { op_close_file,             "Close file" },

  { op_read_page,              "Read page" },

  { op_write_page,             "Write page" },

  { op_lock,                   "Lock" },

  { op_convert_lock,           "Convert lock" },

  { op_release_lock,           "Release lock" },

  { op_blocking,               "Blocking" },

  { op_attach,                 "Attach" },

  { op_create,                 "Create" },

  { op_detach,                 "Detach" },

  { op_compile,                "Compile" },

  { op_start,                  "Start" },

  { op_start_and_send,         "Start and send" },

  { op_send,                   "Send" },

  { op_receive,                "Receive" },

  { op_unwind,                 "Unwind" },

  { op_release,                "Release" },

  { op_transaction,            "Transaction" },

  { op_commit,                 "Commit" },

  { op_rollback,               "Rollback" },

  { op_prepare,                "Prepare" },

  { op_reconnect,              "Reconnect" },

  { op_create_blob,            "Create blob" },

  { op_open_blob,              "Open blob" },

  { op_get_segment,            "Get segment" },

  { op_put_segment,            "Put segment" },

  { op_cancel_blob,            "Cancel blob" },

  { op_close_blob,             "Close blob" },

  { op_info_database,          "Info database" },

  { op_info_request,           "Info request" },

  { op_info_transaction,       "Info transaction" },

  { op_info_blob,              "Info blob" },

  { op_batch_segments,         "Batch segments" },

  { op_mgr_set_affinity,       "Mgr set affinity" },

  { op_mgr_clear_affinity,     "Mgr clear affinity" },

  { op_mgr_report,             "Mgr report" },

  { op_que_events,             "Que events" },

  { op_cancel_events,          "Cancel events" },

  { op_commit_retaining,       "Commit retaining" },

  { op_prepare2,               "Prepare 2" },

  { op_event,                  "Event" },

  { op_connect_request,        "Connect request" },

  { op_aux_connect,            "Aux connect" },

  { op_ddl,                    "DDl" },

  { op_open_blob2,             "Open blob 2" },

  { op_create_blob2,           "Create blob 2" },

  { op_get_slice,              "Get slice" },

  { op_put_slice,              "Put slice" },

  { op_slice,                  "Slice" },

  { op_seek_blob,              "Seek blob" },

  { op_allocate_statement,     "Allocate statement" },

  { op_execute,                "Execute" },

  { op_exec_immediate,         "Exec immediate" },

  { op_fetch,                  "Fetch" },

  { op_fetch_response,         "Fetch response" },

  { op_free_statement,         "Free statement" },

  { op_prepare_statement,      "Prepare statement" },

  { op_set_cursor,             "Set cursor" },

  { op_info_sql,               "Info sql" },

  { op_dummy,                  "Dummy" },

  { op_response_piggyback,     "Response piggyback" },

  { op_start_and_receive,      "Start and receive" },

  { op_start_send_and_receive, "Start send and receive" },

  { op_exec_immediate2,        "Exec immediate 2" },

  { op_execute2,               "Execute 2" },

  { op_insert,                 "Insert" },

  { op_sql_response,           "Sql response" },

  { op_transact,               "Transact" },

  { op_transact_response,      "Transact response" },

  { op_drop_database,          "Drop database" },

  { op_service_attach,         "Service attach" },

  { op_service_detach,         "Service detach" },

  { op_service_info,           "Service info" },

  { op_service_start,          "Service start" },

  { op_rollback_retaining,     "Rollback retaining" },

  { op_update_account_info,    "update_account_info" },

  { op_authenticate_user,      "authenticate_user" },

  { op_partial,                "partial" },

  { op_trusted_auth,           "trusted_auth" },

  { op_cancel,                 "cancel" },

  { 0, NULL }

};

static value_string_ext gdsdb_opcode_ext = VALUE_STRING_EXT_INIT(gdsdb_opcode);

static const value_string gdsdb_architectures[] = {

  {  1, "Generic" },

  {  2, "Apollo" },

  {  3, "Sun" },

  {  4, "Vms" },

  {  5, "Ultrix" },

  {  6, "Alliant" },

  {  7, "MS-Dos" },

  {  8, "Sun 4" },

  {  9, "Sun 386" },

  { 10, "HP-UX" },

  { 11, "HP MPE/xl" },

  { 12, "Mac" },

  { 13, "Mac aux" },

  { 14, "rt" },

  { 15, "mips Ultrix" },

  { 16, "HP-UX 68k" },

  { 17, "Xenix" },

  { 18, "Aviion" },

  { 19, "SGI" },

  { 20, "Apollo_dn10k" },

  { 21, "Cray" },

  { 22, "Imp" },

  { 23, "Delta" },

  { 24, "SCO" },

  { 25, "Next" },

  { 26, "Next 386" },

  { 27, "m88k" },

  { 28, "UnixWare" },

  { 29, "Intel 32" },

  { 30, "Epson" },

  { 31, "Decosf" },

  { 32, "Ncr3000" },

  { 33, "NT PPC" },

  { 34, "DG x86" },

  { 35, "SCO ev" },

  { 36, "Linux" },

  { 37, "FreeBSD"  },

  { 38, "NetBSD" },

  { 39, "Darwin PPC" },

  { 0, NULL }

};

enum

{

  arg_end = 0,

  arg_gds = 1,

  arg_string = 2,

  arg_cstring = 3,

  arg_number = 4,

  arg_interpreted = 5,

  arg_vms = 6,

  arg_unix = 7,

  arg_domain = 8,

  arg_dos = 9,

  arg_mpexl = 10,

  arg_mpexl_ipc = 11,

  arg_next_mach = 15,

  arg_netware = 16,

  arg_win32 = 17,

  arg_warning = 18,

  arg_sql_state = 19

};

static const value_string gdsdb_arg_types[] = {

  {  arg_end,  "end of argument list" },

  {  arg_gds,  "generic DSRI" },

  {  arg_string,  "string argument" },

  {  arg_cstring,  "count & string argument" },

  {  arg_number,  "numeric argument" },

  {  arg_interpreted,  "interpreted status code" },

  {  arg_vms,  "VAX/VMS status code" },

  {  arg_unix,  "UNIX error code" },

  {  arg_domain,  "Apollo/Domain error code" },

  {  arg_dos,  "MSDOS/OS2 error code" },

  {  arg_mpexl, "HP MPE/XL error code" },

  {  arg_mpexl_ipc, "HP MPE/XL IPC error code" },

  {  arg_next_mach, "NeXT/Mach error code" },

  {  arg_netware, "NetWare error code" },

  {  arg_win32, "Win32 error code" },

  {  arg_warning, "warning argument" },

  {  arg_sql_state, "SQLSTATE" },

  { 0, NULL }

};

static const value_string gdsdb_response_status_vals[] = {

  { 0, "success" },

  { 100, "end of cursor" },

  { 0, NULL }

};

static int dword_align(int length)

{

  return WS_ROUNDUP_4(length);

}

static int add_uint_string(proto_tree *tree, int hf_string, tvbuff_t *tvb, int offset)

{

  proto_item* ti;

  int length;

  ti = proto_tree_add_item(tree, hf_string, tvb,

            offset, 4, ENC_ASCII|ENC_BIG_ENDIAN);

  length = dword_align(tvb_get_ntohl(tvb, offset))+4;

  proto_item_set_len(ti, length);

  int ret_offset = offset + length;

  if (length < 4 || ret_offset < offset) {

    expert_add_info_format(NULL, ti, &ei_gdsdb_invalid_length, "Invalid length: %d", length);

    return tvb_reported_length(tvb);

  }

  return ret_offset;

}

static int add_byte_array(proto_tree *tree, int hf_len, int hf_byte, tvbuff_t *tvb, int offset)

{

  proto_item* ti;

  uint32_t length;

  proto_tree_add_item_ret_uint(tree, hf_len, tvb,

            offset, 4, ENC_BIG_ENDIAN, &length);

  offset += 4;

  if (length > 0)

  {

    ti = proto_tree_add_item(tree, hf_byte, tvb,

            offset, length, ENC_NA);

    length = dword_align(length);

    proto_item_set_len(ti, length);

  }

  return offset + length;

}

static int

gdsdb_dummy(tvbuff_t *tvb, packet_info *pinfo _U_, proto_tree *tree _U_, int offset _U_)

{

  /* Ignore data */

  return tvb_reported_length(tvb);

}

static int

gdsdb_connect(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree, int offset)

{

  int count, file_size, total_length = 16;

  int i, length = tvb_reported_length_remaining(tvb, offset);

  proto_item *ti;

  proto_tree *pref_tree;

  /* Calculate if we need more data */

  if (length < total_length)

    return -1;

  file_size = tvb_get_ntohl(tvb, offset+12);

  total_length += 4+dword_align(file_size);

  if (length < total_length+4)

    return -1;

  count = tvb_get_ntohl(tvb, offset+total_length-4);

  if (count < 0 || count > 255) {

    /* This is a 32-bit integer on the wire but as a count of

     * the number of supported protocol versions to follow, it

     * should never have the high bytes set. */

    expert_add_info(pinfo, NULL, &ei_gdsdb_invalid_length);

    return tvb_reported_length(tvb);

  }

  total_length += (4+(count*20));

  if (length < total_length)

    return -1;

  proto_tree_add_item(tree, hf_gdsdb_connect_operation, tvb,

              offset, 4, ENC_BIG_ENDIAN);

  offset += 4;

  proto_tree_add_item(tree, hf_gdsdb_connect_version, tvb,

              offset, 4, ENC_BIG_ENDIAN);

  offset += 4;

  proto_tree_add_item(tree, hf_gdsdb_connect_client, tvb,

              offset, 4, ENC_BIG_ENDIAN);

  offset += 4;

  offset = add_uint_string(tree, hf_gdsdb_connect_filename, tvb, offset);

  proto_tree_add_item(tree, hf_gdsdb_connect_count, tvb,

              offset, 4, ENC_BIG_ENDIAN);

  offset += 4;

  col_append_fstr(pinfo->cinfo, COL_INFO, ": %s", tvb_format_text(pinfo->pool, tvb, offset+4, tvb_get_ntohl(tvb, offset)));

  offset = add_uint_string(tree, hf_gdsdb_connect_userid, tvb, offset);

  for(i=0;i<count;i++){

    ti = proto_tree_add_item(tree, hf_gdsdb_connect_pref, tvb, offset, 20, ENC_NA);

    pref_tree = proto_item_add_subtree(ti, ett_gdsdb_connect_pref);

    proto_tree_add_item(pref_tree, hf_gdsdb_connect_pref_version,

            tvb, offset, 4, ENC_BIG_ENDIAN);

    offset += 4;

    proto_tree_add_item(pref_tree, hf_gdsdb_connect_pref_architecture,

            tvb, offset, 4, ENC_BIG_ENDIAN);

    offset += 4;

    proto_tree_add_item(pref_tree, hf_gdsdb_connect_pref_mintype,

            tvb, offset, 4, ENC_BIG_ENDIAN);

    offset += 4;

    proto_tree_add_item(pref_tree, hf_gdsdb_connect_pref_maxtype,

            tvb, offset, 4, ENC_BIG_ENDIAN);

    offset += 4;

    proto_tree_add_item(pref_tree, hf_gdsdb_connect_pref_weight,

            tvb, offset, 4, ENC_BIG_ENDIAN);

    offset += 4;

  }

  return offset;

}

static int

gdsdb_accept(tvbuff_t *tvb, packet_info *pinfo _U_, proto_tree *tree, int offset)

{

  /* Calculate if we need more data */

  if (tvb_reported_length_remaining(tvb, offset) < 12) {

    return -1;

  }

  proto_tree_add_item(tree, hf_gdsdb_accept_version, tvb,

              offset, 4, ENC_BIG_ENDIAN);

  offset += 4;

  proto_tree_add_item(tree, hf_gdsdb_accept_architecture, tvb,

              offset, 4, ENC_BIG_ENDIAN);

  offset += 4;

  proto_tree_add_item(tree, hf_gdsdb_accept_proto_min_type, tvb,

              offset, 4, ENC_BIG_ENDIAN);

  offset += 4;

  return offset;

}

static int

gdsdb_request(tvbuff_t *tvb, packet_info *pinfo _U_, proto_tree *tree, int offset)

{

  /* Calculate if we need more data */

  if (tvb_reported_length_remaining(tvb, offset) < 16) {

    return -1;

  }

  proto_tree_add_item(tree, hf_gdsdb_request_type, tvb, offset, 4, ENC_BIG_ENDIAN);

  offset += 4;

  proto_tree_add_item(tree, hf_gdsdb_request_object, tvb, offset, 4, ENC_BIG_ENDIAN);

  offset += 4;

  proto_tree_add_item(tree, hf_gdsdb_request_partner, tvb, offset, 8, ENC_BIG_ENDIAN);

  offset += 8;

  return offset;

}

static int

gdsdb_attach(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree, int offset)

{

  int total_length = 12;

  int size, length = tvb_reported_length_remaining(tvb, offset);

  /* Calculate if we need more data */

  if (length < total_length) {

    return -1;

  }

  size = tvb_get_ntohl(tvb, offset+4);

  total_length += dword_align(size);

  if (length < total_length)

    return -1;

  size = tvb_get_ntohl(tvb, offset+total_length-4);

  total_length += dword_align(size);

  if (length < total_length)

    return -1;

  proto_tree_add_item(tree, hf_gdsdb_attach_database_object_id, tvb, offset, 4, ENC_BIG_ENDIAN);

  offset += 4;

  col_append_fstr(pinfo->cinfo, COL_INFO, ": %s", tvb_format_text(pinfo->pool, tvb, offset+4, tvb_get_ntohl(tvb, offset)));

  offset = add_uint_string(tree, hf_gdsdb_attach_database_path, tvb, offset);

  offset = add_uint_string(tree, hf_gdsdb_attach_database_param_buf, tvb, offset);

  return offset;

}

static int

gdsdb_compile(tvbuff_t *tvb, packet_info *pinfo _U_, proto_tree *tree, int offset)

{

  int total_length = 8;

  int size, length = tvb_reported_length_remaining(tvb, offset);

  /* Calculate if we need more data */

  if (length < total_length) {

    return -1;

  }

  size = tvb_get_ntohl(tvb, offset+4);

  total_length += dword_align(size);

  if (length < total_length)

    return -1;

  proto_tree_add_item(tree, hf_gdsdb_compile_database, tvb, offset, 4, ENC_BIG_ENDIAN);

  offset += 4;

  offset = add_uint_string(tree, hf_gdsdb_compile_blr, tvb, offset);

  return offset;

}

static int

gdsdb_receive(tvbuff_t *tvb, packet_info *pinfo _U_, proto_tree *tree, int offset)

{

  /* Calculate if we need more data */

  if (tvb_reported_length_remaining(tvb, offset) < 20) {

    return -1;

  }

  proto_tree_add_item(tree, hf_gdsdb_receive_request, tvb,

              offset, 4, ENC_BIG_ENDIAN);

  offset += 4;

  proto_tree_add_item(tree, hf_gdsdb_receive_incarnation, tvb,

              offset, 4, ENC_BIG_ENDIAN);

  offset += 4;

  proto_tree_add_item(tree, hf_gdsdb_receive_transaction, tvb,

              offset, 4, ENC_BIG_ENDIAN);

  offset += 4;

  proto_tree_add_item(tree, hf_gdsdb_receive_msgnr, tvb,

              offset, 4, ENC_BIG_ENDIAN);

  offset += 4;

  proto_tree_add_item(tree, hf_gdsdb_receive_messages, tvb,

              offset, 4, ENC_BIG_ENDIAN);

  offset += 4;

  while (tvb_reported_length_remaining(tvb, offset) >= 12) {

    proto_tree_add_item(tree, hf_gdsdb_receive_direction,

            tvb, offset, 4, ENC_BIG_ENDIAN);

    offset += 4;

    proto_tree_add_item(tree, hf_gdsdb_receive_offset,

             tvb, offset, 8, ENC_BIG_ENDIAN);

    offset += 8;

  }

  return offset;

}

static int

gdsdb_send(tvbuff_t *tvb, packet_info *pinfo _U_, proto_tree *tree, int offset)

{

  /* Calculate if we need more data */

  if (tvb_reported_length_remaining(tvb, offset) < 20) {

    return -1;

  }

  proto_tree_add_item(tree, hf_gdsdb_send_request, tvb,

              offset, 4, ENC_BIG_ENDIAN);

  offset += 4;

  proto_tree_add_item(tree, hf_gdsdb_send_incarnation, tvb,

              offset, 4, ENC_BIG_ENDIAN);

  offset += 4;

  proto_tree_add_item(tree, hf_gdsdb_send_transaction, tvb,

              offset, 4, ENC_BIG_ENDIAN);

  offset += 4;

  proto_tree_add_item(tree, hf_gdsdb_send_msgnr, tvb,

              offset, 4, ENC_BIG_ENDIAN);

  offset += 4;

  proto_tree_add_item(tree, hf_gdsdb_send_messages, tvb,

              offset, 4, ENC_BIG_ENDIAN);

  offset += 4;

  return offset;

}

static int

gdsdb_status_vector(proto_tree *tree, tvbuff_t *tvb, int offset)

{

  uint32_t arg;

  while (tvb_reported_length_remaining(tvb, offset) >= 4)

  {

    proto_tree_add_item_ret_uint(tree, hf_gdsdb_status_vector_arg, tvb,

              offset, 4, ENC_BIG_ENDIAN, &arg);

    offset += 4;

    if (arg == 0)

      break;

    switch(arg)

    {

    case arg_gds:

    default:

      proto_tree_add_item(tree, hf_gdsdb_status_vector_error_code, tvb,

              offset, 4, ENC_BIG_ENDIAN);

      offset += 4;

      break;

    case arg_number:

      proto_tree_add_item(tree, hf_gdsdb_status_vector_number, tvb,

              offset, 4, ENC_BIG_ENDIAN);

      offset += 4;

      break;

    case arg_string:

    case arg_interpreted:

      offset = add_uint_string(tree, hf_gdsdb_status_vector_string, tvb, offset);

      break;

    case arg_sql_state:

      offset = add_uint_string(tree, hf_gdsdb_status_vector_sql_state, tvb, offset);

      break;

    }

  }

  return offset;

}

static int

gdsdb_response(tvbuff_t *tvb, packet_info *pinfo _U_, proto_tree *tree, int offset)

{

  int total_length = 16;

  int length = tvb_reported_length_remaining(tvb, offset);

  /* Calculate if we need more data */

  if (length < total_length) {

    return -1;

  }

  total_length += dword_align(tvb_get_ntohl(tvb, offset+12));

  if (length < total_length) {

    return -1;

  }

  proto_tree_add_item(tree, hf_gdsdb_response_object, tvb,

              offset, 4, ENC_BIG_ENDIAN);

  offset += 4;

  proto_tree_add_item(tree, hf_gdsdb_response_blobid, tvb,

              offset, 8, ENC_BIG_ENDIAN);

  offset += 8;

  offset = add_byte_array(tree, hf_gdsdb_response_datasize, hf_gdsdb_response_data, tvb, offset);

  return gdsdb_status_vector(tree, tvb, offset);

}

static int

gdsdb_transact(tvbuff_t *tvb, packet_info *pinfo _U_, proto_tree *tree, int offset)

{

  /* Calculate if we need more data */

  if (tvb_reported_length_remaining(tvb, offset) < 8) {

    return -1;

  }

  proto_tree_add_item(tree, hf_gdsdb_transact_database, tvb,

              offset, 4, ENC_BIG_ENDIAN);

  offset += 4;

  proto_tree_add_item(tree, hf_gdsdb_transact_transaction, tvb,

              offset, 4, ENC_BIG_ENDIAN);

  offset += 4;

  return offset;

}

static int

gdsdb_transact_response(tvbuff_t *tvb, packet_info *pinfo _U_, proto_tree *tree, int offset)

{

  /* Calculate if we need more data */

  if (tvb_reported_length_remaining(tvb, offset) < 4) {

    return -1;

  }

  proto_tree_add_item(tree, hf_gdsdb_transactresponse_messages,

            tvb, offset, 4, ENC_BIG_ENDIAN);

  offset += 4;

  return offset;

}

static int

gdsdb_open_blob2(tvbuff_t *tvb, packet_info *pinfo _U_, proto_tree *tree, int offset)

{

  int total_length = 12;

  int length = tvb_reported_length_remaining(tvb, offset);

  /* Calculate if we need more data */

  if (length < total_length) {

    return -1;

  }

  total_length += dword_align(tvb_get_ntohl(tvb, offset));

  if (length < total_length) {

    return -1;

  }

  offset = add_uint_string(tree, hf_gdsdb_openblob2_bpb, tvb, offset);

  proto_tree_add_item(tree, hf_gdsdb_openblob_transaction, tvb,

              offset, 4, ENC_BIG_ENDIAN);

  offset += 4;

  proto_tree_add_item(tree, hf_gdsdb_openblob_id, tvb, offset,

                8, ENC_BIG_ENDIAN);

  offset += 8;

  return offset;

}

static int

gdsdb_open_blob(tvbuff_t *tvb, packet_info *pinfo _U_, proto_tree *tree, int offset)

{

  /* Calculate if we need more data */

  if (tvb_reported_length_remaining(tvb, offset) < 8) {

    return -1;

  }

  proto_tree_add_item(tree, hf_gdsdb_openblob_transaction, tvb,

              offset, 4, ENC_BIG_ENDIAN);

  offset += 4;

  proto_tree_add_item(tree, hf_gdsdb_openblob_id, tvb, offset,

                8, ENC_BIG_ENDIAN);

  offset += 8;

  return offset;

}

static int

gdsdb_segment(tvbuff_t *tvb, packet_info *pinfo _U_, proto_tree *tree, int offset)

{

  /* Calculate if we need more data */

  if (tvb_reported_length_remaining(tvb, offset) < 12)

    return -1;

  if (tree) {

/* hf_gdsdb_segment_blob */

/* hf_gdsdb_segment_length */

/* add_uint_string(hf_gdsdb_segment_segment )*/

  }

  return tvb_reported_length(tvb);

}

static int

gdsdb_seek_blob(tvbuff_t *tvb, packet_info *pinfo _U_, proto_tree *tree, int offset)

{

  /* Calculate if we need more data */

  if (tvb_reported_length_remaining(tvb, offset) < 12)

    return -1;

  if (tree) {

/* hf_gdsdb_seekblob_blob */

/* hf_gdsdb_seekblob_mode */

  }

  return tvb_reported_length(tvb);

}

static int

gdsdb_reconnect(tvbuff_t *tvb, packet_info *pinfo _U_, proto_tree *tree, int offset)

{

  int total_length = 8;

  int length = tvb_reported_length_remaining(tvb, offset);

  /* Calculate if we need more data */

  if (length < total_length) {

    return -1;

  }

  total_length += dword_align(tvb_get_ntohl(tvb, offset+4));

  if (length < total_length) {

    return -1;

  }

  proto_tree_add_item(tree, hf_gdsdb_reconnect_handle, tvb, offset,

                4, ENC_BIG_ENDIAN);

  offset += 4;

  offset = add_byte_array(tree, hf_gdsdb_reconnect_database_size, hf_gdsdb_reconnect_database, tvb, offset);

  return offset;

}

static int

gdsdb_info(tvbuff_t *tvb, packet_info *pinfo _U_, proto_tree *tree, int offset)

{

  unsigned opcode;

  int total_length = 16;

  int length = tvb_reported_length_remaining(tvb, offset);

  /* Calculate if we need more data */

  if (length < total_length) {

    return -1;

  }

  opcode = tvb_get_ntohl(tvb, offset-4);

  total_length += dword_align(tvb_get_ntohl(tvb, offset+8));

  if (length < total_length) {

    return -1;

  }

  if(opcode == op_service_info) {

    total_length += dword_align(tvb_get_ntohl(tvb, offset+total_length-8));

    if (length < total_length) {

      return -1;

    }

  }

  proto_tree_add_item(tree, hf_gdsdb_info_object, tvb, offset,

                4, ENC_BIG_ENDIAN);

  offset += 4;

  proto_tree_add_item(tree, hf_gdsdb_info_incarnation, tvb,

              offset, 4, ENC_BIG_ENDIAN);

  offset += 4;

  offset = add_uint_string(tree, hf_gdsdb_info_items, tvb, offset);

  if(opcode == op_service_info) {

    offset = add_uint_string(tree, hf_gdsdb_info_recv_items, tvb, offset);

  }

  proto_tree_add_item(tree, hf_gdsdb_info_buffer_length, tvb,

              offset, 4, ENC_BIG_ENDIAN);