packet-dsi.c

   1 /* packet-dsi.c
   2  * Routines for dsi packet dissection
   3  * Copyright 2001, Randy McEoin <rmceoin@pe.com>
   4  *
   5  * $Id: packet-dsi.c,v 1.26 2003/04/15 05:45:02 guy Exp $
   6  *
   7  * Ethereal - Network traffic analyzer
   8  * By Gerald Combs <gerald@ethereal.com>
   9  * Copyright 1998 Gerald Combs
  10  *
  11  * Copied from packet-pop.c
  12  *
  13  * This program is free software; you can redistribute it and/or
  14  * modify it under the terms of the GNU General Public License
  15  * as published by the Free Software Foundation; either version 2
  16  * of the License, or (at your option) any later version.
  17  *
  18  * This program is distributed in the hope that it will be useful,
  19  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  20  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  21  * GNU General Public License for more details.
  22  *
  23  * You should have received a copy of the GNU General Public License
  24  * along with this program; if not, write to the Free Software
  25  * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
  26  */
  27
  28 #ifdef HAVE_CONFIG_H
  29 # include "config.h"
  30 #endif
  31
  32 #include <stdio.h>
  33
  34 #include <glib.h>
  35 #include <epan/packet.h>
  36
  37 #include "prefs.h"
  38 #include "packet-tcp.h"
  39 #include "packet-afp.h"
  40
  41 /* The information in this module (DSI) comes from:
  42
  43   AFP 2.1 & 2.2.pdf contained in AppleShare_IP_6.3_SDK
  44   available from http://www.apple.com
  45
  46   The netatalk source code by Wesley Craig & Adrian Sun
  47
  48  * What a Data Stream Interface packet looks like:
  49  * 0                               32
  50  * |-------------------------------|
  51  * |flags  |command| requestID     |
  52  * |-------------------------------|
  53  * |error code/enclosed data offset|
  54  * |-------------------------------|
  55  * |total data length              |
  56  * |-------------------------------|
  57  * |reserved field                 |
  58  * |-------------------------------|
  59  */
  60
  61 static int proto_dsi = -1;
  62 static int hf_dsi_flags = -1;
  63 static int hf_dsi_command = -1;
  64 static int hf_dsi_requestid = -1;
  65 static int hf_dsi_offset = -1;
  66 static int hf_dsi_error = -1;
  67 static int hf_dsi_length = -1;
  68 static int hf_dsi_reserved = -1;
  69
  70 static gint ett_dsi = -1;
  71
  72 static int hf_dsi_open_type     = -1;
  73 static int hf_dsi_open_len      = -1;
  74 static int hf_dsi_open_quantum  = -1;
  75 static int hf_dsi_open_option   = -1;
  76
  77 static int hf_dsi_attn_flag             = -1;
  78 static int hf_dsi_attn_flag_shutdown    = -1;
  79 static int hf_dsi_attn_flag_crash       = -1;
  80 static int hf_dsi_attn_flag_msg         = -1;
  81 static int hf_dsi_attn_flag_reconnect   = -1;
  82 static int hf_dsi_attn_flag_time        = -1;
  83 static int hf_dsi_attn_flag_bitmap      = -1;
  84
  85 static gint ett_dsi_open        = -1;
  86 static gint ett_dsi_attn        = -1;
  87 static gint ett_dsi_attn_flag   = -1;
  88
  89 static const value_string dsi_attn_flag_vals[] = {
  90   {0x0, "Reserved" },                                           /* 0000 */
  91   {0x1, "Reserved" },                                           /* 0001 */
  92   {0x2, "Server message" },                                     /* 0010 */
  93   {0x3, "Server notification, cf. extended bitmap" },           /* 0011 */
  94   {0x4, "Server is shutting down, internal error" },            /* 0100 */
  95   {0x8, "Server is shutting down" },                            /* 1000 */
  96   {0x9, "Server disconnects user" },                            /* 1001 */
  97   {0x10,"Server is shutting down, message" },                   /* 1010 */
  98   {0x11,"Server is shutting down, message,no reconnect"},       /* 1011 */
  99   {0,                   NULL } };
 100
 101 static const value_string dsi_open_type_vals[] = {
 102   {0,   "Server quantum" },
 103   {1,   "Attention quantum" },
 104   {0,                   NULL } };
 105
 106 /* status stuff same for asp and afp */
 107 static int hf_dsi_server_name = -1;
 108 static int hf_dsi_utf8_server_name_len = -1;
 109 static int hf_dsi_utf8_server_name = -1;
 110 static int hf_dsi_server_type = -1;
 111 static int hf_dsi_server_vers = -1;
 112 static int hf_dsi_server_uams = -1;
 113 static int hf_dsi_server_icon = -1;
 114 static int hf_dsi_server_directory = -1;
 115
 116 static int hf_dsi_server_flag = -1;
 117 static int hf_dsi_server_flag_copyfile = -1;
 118 static int hf_dsi_server_flag_passwd   = -1;
 119 static int hf_dsi_server_flag_no_save_passwd = -1;
 120 static int hf_dsi_server_flag_srv_msg   = -1;
 121 static int hf_dsi_server_flag_srv_sig   = -1;
 122 static int hf_dsi_server_flag_tcpip     = -1;
 123 static int hf_dsi_server_flag_notify    = -1;
 124 static int hf_dsi_server_flag_reconnect = -1;
 125 static int hf_dsi_server_flag_directory = -1;
 126 static int hf_dsi_server_flag_utf8_name = -1;
 127 static int hf_dsi_server_flag_fast_copy = -1;
 128 static int hf_dsi_server_signature      = -1;
 129
 130 static int hf_dsi_server_addr_len       = -1;
 131 static int hf_dsi_server_addr_type      = -1;
 132 static int hf_dsi_server_addr_value     = -1;
 133
 134 static gint ett_dsi_status = -1;
 135 static gint ett_dsi_uams   = -1;
 136 static gint ett_dsi_vers   = -1;
 137 static gint ett_dsi_addr   = -1;
 138 static gint ett_dsi_addr_line = -1;
 139 static gint ett_dsi_directory = -1;
 140 static gint ett_dsi_utf8_name = -1;
 141 static gint ett_dsi_status_server_flag = -1;
 142
 143 const value_string afp_server_addr_type_vals[] = {
 144   {1,   "IP address" },
 145   {2,   "IP+port address" },
 146   {3,   "DDP address" },
 147   {4,   "DNS name" },
 148   {5,   "IP+port ssh tunnel" },
 149   {0,                   NULL } };
 150
 151 /* end status stuff */
 152
 153 /* desegmentation of DSI */
 154 static gboolean dsi_desegment = TRUE;
 155
 156 static dissector_handle_t data_handle;
 157 static dissector_handle_t afp_handle;
 158
 159 #define TCP_PORT_DSI                    548
 160
 161 #define DSI_BLOCKSIZ            16
 162
 163 /* DSI flags */
 164 #define DSIFL_REQUEST    0x00
 165 #define DSIFL_REPLY      0x01
 166 #define DSIFL_MAX        0x01
 167
 168 /* DSI Commands */
 169 #define DSIFUNC_CLOSE   1       /* DSICloseSession */
 170 #define DSIFUNC_CMD     2       /* DSICommand */
 171 #define DSIFUNC_STAT    3       /* DSIGetStatus */
 172 #define DSIFUNC_OPEN    4       /* DSIOpenSession */
 173 #define DSIFUNC_TICKLE  5       /* DSITickle */
 174 #define DSIFUNC_WRITE   6       /* DSIWrite */
 175 #define DSIFUNC_ATTN    8       /* DSIAttention */
 176 #define DSIFUNC_MAX     8       /* largest command */
 177
 178 static const value_string flag_vals[] = {
 179   {DSIFL_REQUEST,       "Request" },
 180   {DSIFL_REPLY,         "Reply" },
 181   {0,                   NULL } };
 182
 183 static const value_string func_vals[] = {
 184   {DSIFUNC_CLOSE,       "CloseSession" },
 185   {DSIFUNC_CMD,         "Command" },
 186   {DSIFUNC_STAT,        "GetStatus" },
 187   {DSIFUNC_OPEN,        "OpenSession" },
 188   {DSIFUNC_TICKLE,      "Tickle" },
 189   {DSIFUNC_WRITE,       "Write" },
 190   {DSIFUNC_ATTN,        "Attention" },
 191   {0,                   NULL } };
 192
 193 static gint
 194 dissect_dsi_open_session(tvbuff_t *tvb, proto_tree *dsi_tree, gint offset)
 195 {
 196         proto_tree      *tree;
 197         proto_item      *ti;
 198         guint8          type;
 199         guint8          len;
 200
 201         ti = proto_tree_add_text(dsi_tree, tvb, offset, -1, "Open Session");
 202         tree = proto_item_add_subtree(ti, ett_dsi_open);
 203         type = tvb_get_guint8(tvb, offset);
 204         proto_tree_add_item(tree, hf_dsi_open_type, tvb, offset, 1, FALSE);
 205         offset++;
 206         len = tvb_get_guint8(tvb, offset);
 207         proto_tree_add_item(tree, hf_dsi_open_len, tvb, offset, 1, FALSE);
 208         offset++;
 209         if (type <= 1) {
 210                 proto_tree_add_item(tree, hf_dsi_open_quantum, tvb, offset, 4, FALSE);
 211         }
 212         else {
 213                 proto_tree_add_item(tree, hf_dsi_open_option, tvb, offset, len, FALSE);
 214         }
 215         offset += len;
 216         return offset;
 217 }
 218
 219 static gint
 220 dissect_dsi_attention(tvbuff_t *tvb, proto_tree *dsi_tree, gint offset)
 221 {
 222         proto_tree      *tree;
 223         proto_item      *ti;
 224         guint16         flag;
 225
 226         if (!tvb_reported_length_remaining(tvb,offset))
 227                 return offset;
 228
 229         flag = tvb_get_ntohs(tvb, offset);
 230         ti = proto_tree_add_text(dsi_tree, tvb, offset, -1, "Attention");
 231         tree = proto_item_add_subtree(ti, ett_dsi_attn);
 232
 233         ti = proto_tree_add_item(tree, hf_dsi_attn_flag, tvb, offset, 2, FALSE);
 234         tree = proto_item_add_subtree(ti, ett_dsi_attn_flag);
 235         proto_tree_add_item(tree, hf_dsi_attn_flag_shutdown, tvb, offset, 2, FALSE);
 236         proto_tree_add_item(tree, hf_dsi_attn_flag_crash, tvb, offset, 2, FALSE);
 237         proto_tree_add_item(tree, hf_dsi_attn_flag_msg, tvb, offset, 2, FALSE);
 238         proto_tree_add_item(tree, hf_dsi_attn_flag_reconnect, tvb, offset, 2, FALSE);
 239         /* FIXME */
 240         if ((flag & 0xf000) != 0x3000)
 241                 proto_tree_add_item(tree, hf_dsi_attn_flag_time, tvb, offset, 2, FALSE);
 242         else
 243                 proto_tree_add_item(tree, hf_dsi_attn_flag_bitmap, tvb, offset, 2, FALSE);
 244         offset += 2;
 245         return offset;
 246 }
 247
 248 /* -----------------------------
 249         from netatalk/etc/afpd/status.c
 250 */
 251 static gint
 252 dissect_dsi_reply_get_status(tvbuff_t *tvb, proto_tree *tree, gint offset)
 253 {
 254         proto_tree      *sub_tree;
 255         proto_item      *ti;
 256
 257         guint16 ofs;
 258         guint16 flag;
 259         guint16 sign_ofs = 0;
 260         guint16 adr_ofs = 0;
 261         guint16 dir_ofs = 0;
 262         guint16 utf_ofs = 0;
 263         guint8  nbe;
 264         guint8  len;
 265         guint8  i;
 266
 267         if (!tree)
 268                 return offset;
 269
 270         ti = proto_tree_add_text(tree, tvb, offset, -1, "Get Status");
 271         tree = proto_item_add_subtree(ti, ett_dsi_status);
 272
 273         ofs = tvb_get_ntohs(tvb, offset +AFPSTATUS_MACHOFF);
 274         proto_tree_add_text(tree, tvb, offset +AFPSTATUS_MACHOFF, 2, "Machine offset: %d", ofs);
 275
 276         ofs = tvb_get_ntohs(tvb, offset +AFPSTATUS_VERSOFF);
 277         proto_tree_add_text(tree, tvb, offset +AFPSTATUS_VERSOFF, 2, "Version offset: %d", ofs);
 278
 279         ofs = tvb_get_ntohs(tvb, offset +AFPSTATUS_UAMSOFF);
 280         proto_tree_add_text(tree, tvb, offset +AFPSTATUS_UAMSOFF, 2, "UAMS offset: %d", ofs);
 281
 282         ofs = tvb_get_ntohs(tvb, offset +AFPSTATUS_ICONOFF);
 283         proto_tree_add_text(tree, tvb, offset +AFPSTATUS_ICONOFF, 2, "Icon offset: %d", ofs);
 284
 285         ofs = offset +AFPSTATUS_FLAGOFF;
 286         ti = proto_tree_add_item(tree, hf_dsi_server_flag, tvb, ofs, 2, FALSE);
 287         sub_tree = proto_item_add_subtree(ti, ett_dsi_status_server_flag);
 288         proto_tree_add_item(sub_tree, hf_dsi_server_flag_copyfile      , tvb, ofs, 2, FALSE);
 289         proto_tree_add_item(sub_tree, hf_dsi_server_flag_passwd        , tvb, ofs, 2, FALSE);
 290         proto_tree_add_item(sub_tree, hf_dsi_server_flag_no_save_passwd, tvb, ofs, 2, FALSE);
 291         proto_tree_add_item(sub_tree, hf_dsi_server_flag_srv_msg       , tvb, ofs, 2, FALSE);
 292         proto_tree_add_item(sub_tree, hf_dsi_server_flag_srv_sig       , tvb, ofs, 2, FALSE);
 293         proto_tree_add_item(sub_tree, hf_dsi_server_flag_tcpip         , tvb, ofs, 2, FALSE);
 294         proto_tree_add_item(sub_tree, hf_dsi_server_flag_notify        , tvb, ofs, 2, FALSE);
 295         proto_tree_add_item(sub_tree, hf_dsi_server_flag_reconnect     , tvb, ofs, 2, FALSE);
 296         proto_tree_add_item(sub_tree, hf_dsi_server_flag_directory     , tvb, ofs, 2, FALSE);
 297         proto_tree_add_item(sub_tree, hf_dsi_server_flag_utf8_name     , tvb, ofs, 2, FALSE);
 298         proto_tree_add_item(sub_tree, hf_dsi_server_flag_fast_copy     , tvb, ofs, 2, FALSE);
 299
 300         proto_tree_add_item(tree, hf_dsi_server_name, tvb, offset +AFPSTATUS_PRELEN, 1, FALSE);
 301
 302         flag = tvb_get_ntohs(tvb, ofs);
 303         if ((flag & AFPSRVRINFO_SRVSIGNATURE)) {
 304                 ofs = offset +AFPSTATUS_PRELEN +tvb_get_guint8(tvb, offset +AFPSTATUS_PRELEN) +1;
 305                 if ((ofs & 1))
 306                         ofs++;
 307
 308                 sign_ofs = tvb_get_ntohs(tvb, ofs);
 309                 proto_tree_add_text(tree, tvb, ofs, 2, "Signature offset: %d", sign_ofs);
 310                 sign_ofs += offset;
 311
 312                 if ((flag & AFPSRVRINFO_TCPIP)) {
 313                         ofs += 2;
 314                         adr_ofs =  tvb_get_ntohs(tvb, ofs);
 315                         proto_tree_add_text(tree, tvb, ofs, 2, "Network address offset: %d", adr_ofs);
 316                         adr_ofs += offset;
 317                 }
 318
 319                 if ((flag & AFPSRVRINFO_SRVDIRECTORY)) {
 320                         ofs += 2;
 321                         dir_ofs =  tvb_get_ntohs(tvb, ofs);
 322                         proto_tree_add_text(tree, tvb, ofs, 2, "Directory services offset: %d", dir_ofs);
 323                         dir_ofs += offset;
 324                 }
 325                 if ((flag & AFPSRVRINFO_SRVUTF8)) {
 326                         ofs += 2;
 327                         utf_ofs =  tvb_get_ntohs(tvb, ofs);
 328                         proto_tree_add_text(tree, tvb, ofs, 2, "UTF8 server name offset: %d", utf_ofs);
 329                         utf_ofs += offset;
 330                 }
 331         }
 332
 333         ofs = offset +tvb_get_ntohs(tvb, offset +AFPSTATUS_MACHOFF);
 334         if (ofs)
 335                 proto_tree_add_item(tree, hf_dsi_server_type, tvb, ofs, 1, FALSE);
 336
 337         ofs = offset +tvb_get_ntohs(tvb, offset +AFPSTATUS_VERSOFF);
 338         if (ofs) {
 339                 nbe = tvb_get_guint8(tvb, ofs);
 340                 ti = proto_tree_add_text(tree, tvb, ofs, 1, "Version list: %d", nbe);
 341                 ofs++;
 342                 sub_tree = proto_item_add_subtree(ti, ett_dsi_vers);
 343                 for (i = 0; i < nbe; i++) {
 344                         len = tvb_get_guint8(tvb, ofs) +1;
 345                         proto_tree_add_item(sub_tree, hf_dsi_server_vers, tvb, ofs, 1, FALSE);
 346                         ofs += len;
 347                 }
 348         }
 349
 350         ofs = offset +tvb_get_ntohs(tvb, offset +AFPSTATUS_UAMSOFF);
 351         if (ofs) {
 352                 nbe = tvb_get_guint8(tvb, ofs);
 353                 ti = proto_tree_add_text(tree, tvb, ofs, 1, "UAMS list: %d", nbe);
 354                 ofs++;
 355                 sub_tree = proto_item_add_subtree(ti, ett_dsi_uams);
 356                 for (i = 0; i < nbe; i++) {
 357                         len = tvb_get_guint8(tvb, ofs) +1;
 358                         proto_tree_add_item(sub_tree, hf_dsi_server_uams, tvb, ofs, 1, FALSE);
 359                         ofs += len;
 360                 }
 361         }
 362
 363         ofs = offset +tvb_get_ntohs(tvb, offset +AFPSTATUS_ICONOFF);
 364         if (ofs)
 365                 proto_tree_add_item(tree, hf_dsi_server_icon, tvb, ofs, 256, FALSE);
 366
 367         if (sign_ofs) {
 368                 proto_tree_add_item(tree, hf_dsi_server_signature, tvb, sign_ofs, 16, FALSE);
 369         }
 370
 371         if (adr_ofs) {
 372                 proto_tree *adr_tree;
 373                 char *tmp;
 374                 const guint8 *ip;
 375                 guint16 net;
 376                 guint8  node;
 377                 guint16 port;
 378
 379                 ofs = adr_ofs;
 380                 nbe = tvb_get_guint8(tvb, ofs);
 381                 ti = proto_tree_add_text(tree, tvb, ofs, 1, "Address list: %d", nbe);
 382                 ofs++;
 383                 adr_tree = proto_item_add_subtree(ti, ett_dsi_addr);
 384                 for (i = 0; i < nbe; i++) {
 385                         guint8 type;
 386
 387                         len = tvb_get_guint8(tvb, ofs);
 388                         type =  tvb_get_guint8(tvb, ofs +1);
 389                         switch (type) {
 390                         case 1: /* IP */
 391                                 ip = tvb_get_ptr(tvb, ofs+2, 4);
 392                                 ti = proto_tree_add_text(adr_tree, tvb, ofs, len, "ip: %s", ip_to_str(ip));
 393                                 break;
 394                         case 2: /* IP + port */
 395                                 ip = tvb_get_ptr(tvb, ofs+2, 4);
 396                                 port = tvb_get_ntohs(tvb, ofs+6);
 397                                 ti = proto_tree_add_text(adr_tree, tvb, ofs, len, "ip %s:%d",ip_to_str(ip),port);
 398                                 break;
 399                         case 3: /* DDP, atalk_addr_to_str want host order not network */
 400                                 net  = tvb_get_ntohs(tvb, ofs+2);
 401                                 node = tvb_get_guint8(tvb, ofs +4);
 402                                 port = tvb_get_guint8(tvb, ofs +5);
 403                                 ti = proto_tree_add_text(adr_tree, tvb, ofs, len, "ddp: %u.%u:%u",
 404                                         net, node, port);
 405                                 break;
 406                         case 4: /* DNS */
 407                         case 5: /* SSH tunnel */
 408                                 if (len > 2) {
 409                                         tmp = g_malloc( len -1);
 410                                         tvb_memcpy(tvb, tmp, ofs +2, len -2);
 411                                         tmp[len -2] = 0;
 412                                         ti = proto_tree_add_text(adr_tree, tvb, ofs, len, "%s: %s",
 413                                                                 (type==4)?"dns":"ssh tunnel", tmp);
 414                                         g_free(tmp);
 415                                         break;
 416                                 }
 417                                 else {
 418                                         ti = proto_tree_add_text(adr_tree, tvb, ofs, len,"Malformed address type %d", type);
 419                                 }
 420                                 break;
 421                         default:
 422                                 ti = proto_tree_add_text(adr_tree, tvb, ofs, len,"Unknow type : %d", type);
 423                                 break;
 424                         }
 425                         len -= 2;
 426                         sub_tree = proto_item_add_subtree(ti,ett_dsi_addr_line);
 427                         proto_tree_add_item(sub_tree, hf_dsi_server_addr_len, tvb, ofs, 1, FALSE);
 428                         ofs++;
 429                         proto_tree_add_item(sub_tree, hf_dsi_server_addr_type, tvb, ofs, 1, FALSE);
 430                         ofs++;
 431                         proto_tree_add_item(sub_tree, hf_dsi_server_addr_value,tvb, ofs, len, FALSE);
 432                         ofs += len;
 433                 }
 434         }
 435
 436         if (dir_ofs) {
 437                 ofs = dir_ofs;
 438                 nbe = tvb_get_guint8(tvb, ofs);
 439                 ti = proto_tree_add_text(tree, tvb, ofs, 1, "Directory services list: %d", nbe);
 440                 ofs++;
 441                 sub_tree = proto_item_add_subtree(ti, ett_dsi_directory);
 442                 for (i = 0; i < nbe; i++) {
 443                         len = tvb_get_guint8(tvb, ofs) +1;
 444                         proto_tree_add_item(sub_tree, hf_dsi_server_directory, tvb, ofs, 1, FALSE);
 445                         ofs += len;
 446                 }
 447         }
 448         if (utf_ofs) {
 449                 guint16 ulen;
 450                 char *tmp = NULL;
 451
 452                 ofs = utf_ofs;
 453                 ulen = tvb_get_ntohs(tvb, ofs);
 454                 if(ulen) {
 455                         tmp = g_malloc( ulen);
 456                         tvb_memcpy(tvb, tmp, ofs +2, ulen);
 457                         tmp[ulen] = 0;
 458                 }
 459                 ti = proto_tree_add_text(tree, tvb, ofs, ulen +2, "UTF8 server name: %s", (tmp)?tmp:"");
 460                 if (tmp) {
 461                         g_free(tmp);
 462                 }
 463                 sub_tree = proto_item_add_subtree(ti, ett_dsi_utf8_name);
 464                 proto_tree_add_item( sub_tree, hf_dsi_utf8_server_name_len, tvb, ofs, 2,FALSE);
 465                 ofs += 2;
 466                 proto_tree_add_item(sub_tree, hf_dsi_utf8_server_name, tvb, ofs, ulen,FALSE);
 467         }
 468
 469         return offset;
 470 }
 471
 472 static void
 473 dissect_dsi_packet(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree)
 474 {
 475         proto_tree      *dsi_tree;
 476         proto_item      *ti;
 477         guint8          dsi_flags,dsi_command;
 478         guint16         dsi_requestid;
 479         gint32          dsi_code;
 480         guint32         dsi_length;
 481         guint32         dsi_reserved;
 482         struct          aspinfo aspinfo;
 483
 484         if (check_col(pinfo->cinfo, COL_PROTOCOL))
 485                 col_set_str(pinfo->cinfo, COL_PROTOCOL, "DSI");
 486         if (check_col(pinfo->cinfo, COL_INFO))
 487                 col_clear(pinfo->cinfo, COL_INFO);
 488
 489         dsi_flags = tvb_get_guint8(tvb, 0);
 490         dsi_command = tvb_get_guint8(tvb, 1);
 491         dsi_requestid = tvb_get_ntohs(tvb, 2);
 492         dsi_code = tvb_get_ntohl(tvb, 4);
 493         dsi_length = tvb_get_ntohl(tvb, 8);
 494         dsi_reserved = tvb_get_ntohl(tvb, 12);
 495
 496         if (check_col(pinfo->cinfo, COL_INFO)) {
 497                 col_add_fstr(pinfo->cinfo, COL_INFO, "%s %s (%u)",
 498                         val_to_str(dsi_flags, flag_vals,
 499                                    "Unknown flag (0x%02x)"),
 500                         val_to_str(dsi_command, func_vals,
 501                                    "Unknown function (0x%02x)"),
 502                         dsi_requestid);
 503         }
 504
 505
 506         if (tree) {
 507                 ti = proto_tree_add_item(tree, proto_dsi, tvb, 0, -1, FALSE);
 508                 dsi_tree = proto_item_add_subtree(ti, ett_dsi);
 509
 510                 proto_tree_add_uint(dsi_tree, hf_dsi_flags, tvb,
 511                         0, 1, dsi_flags);
 512                 proto_tree_add_uint(dsi_tree, hf_dsi_command, tvb,
 513                         1, 1, dsi_command);
 514                 proto_tree_add_uint(dsi_tree, hf_dsi_requestid, tvb,
 515                         2, 2, dsi_requestid);
 516                 switch (dsi_flags) {
 517
 518                 case DSIFL_REQUEST:
 519                         proto_tree_add_int(dsi_tree, hf_dsi_offset, tvb,
 520                                 4, 4, dsi_code);
 521                         break;
 522
 523                 case DSIFL_REPLY:
 524                         proto_tree_add_int(dsi_tree, hf_dsi_error, tvb,
 525                                 4, 4, dsi_code);
 526                         break;
 527                 }
 528                 proto_tree_add_uint_format(dsi_tree, hf_dsi_length, tvb,
 529                         8, 4, dsi_length,
 530                         "Length: %u bytes", dsi_length);
 531                 proto_tree_add_uint(dsi_tree, hf_dsi_reserved, tvb,
 532                         12, 4, dsi_reserved);
 533         }
 534         else
 535                 dsi_tree = tree;
 536         switch (dsi_command) {
 537         case DSIFUNC_OPEN:
 538                 if (tree) {
 539                         dissect_dsi_open_session(tvb, dsi_tree, DSI_BLOCKSIZ);
 540                 }
 541                 break;
 542         case DSIFUNC_ATTN:
 543                 if (tree) {
 544                         dissect_dsi_attention(tvb, dsi_tree, DSI_BLOCKSIZ);
 545                 }
 546                 break;
 547         case DSIFUNC_STAT:
 548                 if (tree && (dsi_flags == DSIFL_REPLY)) {
 549                         dissect_dsi_reply_get_status(tvb, dsi_tree, DSI_BLOCKSIZ);
 550                 }
 551                 break;
 552         case DSIFUNC_CMD:
 553         case DSIFUNC_WRITE:
 554                 {
 555                         tvbuff_t   *new_tvb;
 556                         int len = tvb_reported_length_remaining(tvb,DSI_BLOCKSIZ);
 557
 558                         aspinfo.reply = (dsi_flags == DSIFL_REPLY);
 559                         aspinfo.command = dsi_command;
 560                         aspinfo.seq = dsi_requestid;
 561                         aspinfo.code = dsi_code;
 562                         pinfo->private_data = &aspinfo;
 563                         proto_item_set_len(dsi_tree, DSI_BLOCKSIZ);
 564
 565                         new_tvb = tvb_new_subset(tvb, DSI_BLOCKSIZ,-1,len);
 566                         call_dissector(afp_handle, new_tvb, pinfo, tree);
 567                 }
 568                 break;
 569         default:
 570                 if (tree) {
 571                         call_dissector(data_handle,
 572                             tvb_new_subset(tvb, DSI_BLOCKSIZ, -1, -1),
 573                             pinfo, dsi_tree);
 574                 }
 575                 break;
 576         }
 577 }
 578
 579 static guint
 580 get_dsi_pdu_len(tvbuff_t *tvb, int offset)
 581 {
 582         guint32 plen;
 583
 584         /*
 585          * Get the length of the DSI packet.
 586          */
 587         plen = tvb_get_ntohl(tvb, offset+8);
 588
 589         /*
 590          * That length doesn't include the length of the header itself;
 591          * add that in.
 592          */
 593         return plen + 16;
 594 }
 595
 596 static void
 597 dissect_dsi(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree)
 598 {
 599         tcp_dissect_pdus(tvb, pinfo, tree, dsi_desegment, 12,
 600             get_dsi_pdu_len, dissect_dsi_packet);
 601 }
 602
 603 void
 604 proto_register_dsi(void)
 605 {
 606
 607   static hf_register_info hf[] = {
 608     { &hf_dsi_flags,
 609       { "Flags",            "dsi.flags",
 610         FT_UINT8, BASE_HEX, VALS(flag_vals), 0x0,
 611         "Indicates request or reply.", HFILL }},
 612
 613     { &hf_dsi_command,
 614       { "Command",          "dsi.command",
 615         FT_UINT8, BASE_DEC, VALS(func_vals), 0x0,
 616         "Represents a DSI command.", HFILL }},
 617
 618     { &hf_dsi_requestid,
 619       { "Request ID",       "dsi.requestid",
 620         FT_UINT16, BASE_DEC, NULL, 0x0,
 621         "Keeps track of which request this is.  Replies must match a Request.  IDs must be generated in sequential order.", HFILL }},
 622
 623     { &hf_dsi_offset,
 624       { "Data offset",      "dsi.data_offset",
 625         FT_INT32, BASE_DEC, NULL, 0x0,
 626         "Data offset", HFILL }},
 627
 628     { &hf_dsi_error,
 629       { "Error code",       "dsi.error_code",
 630         FT_INT32, BASE_DEC, VALS(asp_error_vals), 0x0,
 631         "Error code", HFILL }},
 632
 633     { &hf_dsi_length,
 634       { "Length",           "dsi.length",
 635         FT_UINT32, BASE_DEC, NULL, 0x0,
 636         "Total length of the data that follows the DSI header.", HFILL }},
 637
 638     { &hf_dsi_reserved,
 639       { "Reserved",         "dsi.reserved",
 640         FT_UINT32, BASE_HEX, NULL, 0x0,
 641         "Reserved for future use.  Should be set to zero.", HFILL }},
 642         /* asp , afp */
 643     { &hf_dsi_utf8_server_name_len,
 644       { "Length",          "dsi.utf8_server_name_len",
 645         FT_UINT16, BASE_DEC, NULL, 0x0,
 646         "UTF8 server name length.", HFILL }},
 647     { &hf_dsi_utf8_server_name,
 648       { "UTF8 Server name",         "dsi.utf8_server_name",
 649         FT_STRING, BASE_NONE, NULL, 0x0,
 650         "UTF8 Server name", HFILL }},
 651
 652     { &hf_dsi_server_name,
 653       { "Server name",         "dsi.server_name",
 654         FT_UINT_STRING, BASE_NONE, NULL, 0x0,
 655         "Server name", HFILL }},
 656
 657     { &hf_dsi_server_type,
 658       { "Server type",         "dsi.server_type",
 659         FT_UINT_STRING, BASE_NONE, NULL, 0x0,
 660         "Server type", HFILL }},
 661
 662     { &hf_dsi_server_vers,
 663       { "AFP version",         "dsi.server_vers",
 664         FT_UINT_STRING, BASE_NONE, NULL, 0x0,
 665         "AFP version", HFILL }},
 666
 667     { &hf_dsi_server_uams,
 668       { "UAM",         "dsi.server_uams",
 669         FT_UINT_STRING, BASE_NONE, NULL, 0x0,
 670         "UAM", HFILL }},
 671
 672     { &hf_dsi_server_icon,
 673       { "Icon bitmap",         "dsi.server_icon",
 674         FT_BYTES, BASE_HEX, NULL, 0x0,
 675         "Server icon bitmap", HFILL }},
 676
 677     { &hf_dsi_server_directory,
 678       { "Directory service",         "dsi.server_directory",
 679         FT_UINT_STRING, BASE_NONE, NULL, 0x0,
 680         "Server directory service", HFILL }},
 681
 682     { &hf_dsi_server_signature,
 683       { "Server signature",         "dsi.server_signature",
 684         FT_BYTES, BASE_HEX, NULL, 0x0,
 685         "Server signature", HFILL }},
 686
 687     { &hf_dsi_server_flag,
 688       { "Flag",         "dsi.server_flag",
 689         FT_UINT16, BASE_HEX, NULL, 0x0,
 690         "Server capabilities flag", HFILL }},
 691     { &hf_dsi_server_flag_copyfile,
 692       { "Support copyfile",      "dsi.server_flag.copyfile",
 693                 FT_BOOLEAN, 16, NULL, AFPSRVRINFO_COPY,
 694         "Server support copyfile", HFILL }},
 695     { &hf_dsi_server_flag_passwd,
 696       { "Support change password",      "dsi.server_flag.passwd",
 697                 FT_BOOLEAN, 16, NULL, AFPSRVRINFO_PASSWD,
 698         "Server support change password", HFILL }},
 699     { &hf_dsi_server_flag_no_save_passwd,
 700       { "Don't allow save password",      "dsi.server_flag.no_save_passwd",
 701                 FT_BOOLEAN, 16, NULL, AFPSRVRINFO_NOSAVEPASSWD,
 702         "Don't allow save password", HFILL }},
 703     { &hf_dsi_server_flag_srv_msg,
 704       { "Support server message",      "dsi.server_flag.srv_msg",
 705                 FT_BOOLEAN, 16, NULL, AFPSRVRINFO_SRVMSGS,
 706         "Support server message", HFILL }},
 707     { &hf_dsi_server_flag_srv_sig,
 708       { "Support server signature",      "dsi.server_flag.srv_sig",
 709                 FT_BOOLEAN, 16, NULL, AFPSRVRINFO_SRVSIGNATURE,
 710         "Support server signature", HFILL }},
 711     { &hf_dsi_server_flag_tcpip,
 712       { "Support TCP/IP",      "dsi.server_flag.tcpip",
 713                 FT_BOOLEAN, 16, NULL, AFPSRVRINFO_TCPIP,
 714         "Server support TCP/IP", HFILL }},
 715     { &hf_dsi_server_flag_notify,
 716       { "Support server notifications",      "dsi.server_flag.notify",
 717                 FT_BOOLEAN, 16, NULL, AFPSRVRINFO_SRVNOTIFY,
 718         "Server support notifications", HFILL }},
 719     { &hf_dsi_server_flag_reconnect,
 720       { "Support server reconnect",      "dsi.server_flag.reconnect",
 721                 FT_BOOLEAN, 16, NULL, AFPSRVRINFO_SRVRECONNECT,
 722         "Server support reconnect", HFILL }},
 723     { &hf_dsi_server_flag_directory,
 724       { "Support directory services",      "dsi.server_flag.directory",
 725                 FT_BOOLEAN, 16, NULL, AFPSRVRINFO_SRVDIRECTORY,
 726         "Server support directory services", HFILL }},
 727     { &hf_dsi_server_flag_utf8_name,
 728       { "Support UTF8 server name",      "dsi.server_flag.utf8_name",
 729                 FT_BOOLEAN, 16, NULL, AFPSRVRINFO_SRVUTF8,
 730         "Server support UTF8 server name", HFILL }},
 731     { &hf_dsi_server_flag_fast_copy,
 732       { "Support fast copy",      "dsi.server_flag.fast_copy",
 733                 FT_BOOLEAN, 16, NULL, AFPSRVRINFO_FASTBOZO,
 734         "Server support fast copy", HFILL }},
 735
 736
 737     { &hf_dsi_server_addr_len,
 738       { "Length",          "dsi.server_addr.len",
 739         FT_UINT8, BASE_DEC, NULL, 0x0,
 740         "Address length.", HFILL }},
 741
 742     { &hf_dsi_server_addr_type,
 743       { "Type",          "dsi.server_addr.type",
 744         FT_UINT8, BASE_DEC, VALS(afp_server_addr_type_vals), 0x0,
 745         "Address type.", HFILL }},
 746
 747     { &hf_dsi_server_addr_value,
 748       { "Value",          "dsi.server_addr.value",
 749         FT_BYTES, BASE_HEX, NULL, 0x0,
 750         "Address value", HFILL }},
 751
 752     { &hf_dsi_open_type,
 753       { "Flags",          "dsi.open_type",
 754         FT_UINT8, BASE_DEC, VALS(dsi_open_type_vals), 0x0,
 755         "Open session option type.", HFILL }},
 756
 757     { &hf_dsi_open_len,
 758       { "Length",          "dsi.open_len",
 759         FT_UINT8, BASE_DEC, NULL, 0x0,
 760         "Open session option len", HFILL }},
 761
 762     { &hf_dsi_open_quantum,
 763       { "Quantum",       "dsi.open_quantum",
 764         FT_UINT32, BASE_DEC, NULL, 0x0,
 765         "Server/Attention quantum", HFILL }},
 766
 767     { &hf_dsi_open_option,
 768       { "Option",          "dsi.open_option",
 769         FT_BYTES, BASE_HEX, NULL, 0x0,
 770         "Open session options (undecoded)", HFILL }},
 771
 772     { &hf_dsi_attn_flag,
 773       { "Flags",          "dsi.attn_flag",
 774         FT_UINT16, BASE_HEX, VALS(dsi_attn_flag_vals), 0xf000,
 775         "Server attention flag", HFILL }},
 776     { &hf_dsi_attn_flag_shutdown,
 777       { "Shutdown",      "dsi.attn_flag.shutdown",
 778                 FT_BOOLEAN, 16, NULL, 1<<15,
 779         "Attention flag, server is shutting down", HFILL }},
 780     { &hf_dsi_attn_flag_crash,
 781       { "Crash",      "dsi.attn_flag.crash",
 782                 FT_BOOLEAN, 16, NULL, 1<<14,
 783         "Attention flag, server crash bit", HFILL }},
 784     { &hf_dsi_attn_flag_msg,
 785       { "Message",      "dsi.attn_flag.msg",
 786                 FT_BOOLEAN, 16, NULL, 1<<13,
 787         "Attention flag, server message bit", HFILL }},
 788     { &hf_dsi_attn_flag_reconnect,
 789       { "Don't reconnect",      "dsi.attn_flag.reconnect",
 790                 FT_BOOLEAN, 16, NULL, 1<<12,
 791         "Attention flag, don't reconnect bit", HFILL }},
 792     { &hf_dsi_attn_flag_time,
 793      { "Minutes",          "dsi.attn_flag.time",
 794         FT_UINT16, BASE_DEC, NULL, 0xfff,
 795         "Number of minutes", HFILL }},
 796     { &hf_dsi_attn_flag_bitmap,
 797      { "Bitmap",          "dsi.attn_flag.time",
 798         FT_UINT16, BASE_HEX, NULL, 0xfff,
 799         "Attention extended bitmap", HFILL }},
 800
 801   };
 802
 803   static gint *ett[] = {
 804     &ett_dsi,
 805     &ett_dsi_open,
 806     &ett_dsi_attn,
 807     &ett_dsi_attn_flag,
 808     /* asp afp */
 809     &ett_dsi_status,
 810     &ett_dsi_status_server_flag,
 811     &ett_dsi_vers,
 812     &ett_dsi_uams,
 813     &ett_dsi_addr,
 814     &ett_dsi_addr_line,
 815     &ett_dsi_directory,
 816     &ett_dsi_utf8_name,
 817   };
 818   module_t *dsi_module;
 819
 820   proto_dsi = proto_register_protocol("Data Stream Interface", "DSI", "dsi");
 821   proto_register_field_array(proto_dsi, hf, array_length(hf));
 822   proto_register_subtree_array(ett, array_length(ett));
 823
 824   dsi_module = prefs_register_protocol(proto_dsi, NULL);
 825   prefs_register_bool_preference(dsi_module, "desegment",
 826     "Desegment all DSI messages spanning multiple TCP segments",
 827     "Whether the DSI dissector should desegment all messages spanning multiple TCP segments",
 828     &dsi_desegment);
 829 }
 830
 831 void
 832 proto_reg_handoff_dsi(void)
 833 {
 834   static dissector_handle_t dsi_handle;
 835
 836   dsi_handle = create_dissector_handle(dissect_dsi, proto_dsi);
 837   dissector_add("tcp.port", TCP_PORT_DSI, dsi_handle);
 838
 839   data_handle = find_dissector("data");
 840   afp_handle = find_dissector("afp");
 841 }