Changeset 3fb49bc for examples/tracedump

Timestamp:

09/06/04 13:25:39 (18 years ago)

Author:

Sam Jansen <stj2@…>

Branches:

4.0.1-hotfixes, cachetimestamps, develop, dpdk-ndag, etsilive, getfragoff, help, libtrace4, master, ndag_format, pfring, rc-4.0.1, rc-4.0.2, rc-4.0.3, rc-4.0.4, ringdecrementfix, ringperformance, ringtimestampfixes

Children:

70892e3

Parents:

53de8c0

Message:

SCTP decoding updated a lot.

File:

• examples/tracedump/ip_132.cc (modified) (6 diffs)

examples/tracedump/ip_132.cc

@@ -4 +4 @@
 #include <map>
 #include "tracedump.h"
+
+#include <sys/socket.h>
 #include <netinet/in.h>
+#include <arpa/inet.h>
 #include <assert.h>
 
@@ -23 +26 @@
     uint8_t type;
     uint8_t flags;
+    uint16_t length;
+} __attribute__((__packed__));
+
+struct sctp_data
+{
+    uint32_t tsn;
+    uint16_t stream_id;
+    uint16_t stream_seqno;
+    uint32_t payload_proto_id;
+} __attribute__((__packed__));
+
+// The following works for INIT and INIT ACK packets
+struct sctp_init_ack
+{
+    uint32_t init_tag;
+    uint32_t rcv_wnd_credit;
+    uint16_t outbound_streams;
+    uint16_t inbound_streams;
+    uint32_t init_tsn;
+} __attribute__((__packed__));
+
+struct sctp_sack
+{
+    uint32_t tsn_ack;
+    uint32_t a_wnd;
+    uint16_t num_gap_blocks;
+    uint16_t num_dup_tsns;
+} __attribute__((__packed__));
+
+struct sctp_var_param_hdr
+{
+    uint16_t type;
     uint16_t length;
 } __attribute__((__packed__));
@@ -54 +89 @@
 }
 
+static void parse_options(char *offset, int vlen)
+{
+    while(vlen > 0) {
+        struct sctp_var_param_hdr *ph = (struct sctp_var_param_hdr *)(offset);
+        char *data = (char *)(ph + 1);
+
+        switch(ntohs(ph->type)) {
+            case 5:
+            {
+                struct in_addr *ia = (struct in_addr *)data;
+                printf(" SCTP: Option IP address %s\n", inet_ntoa(*ia));
+            }
+            break;
+            case 6:
+            {
+                printf(" SCTP: Option IPv6 address (TODO)\n");
+            }
+            break;
+            case 7:
+            {
+                printf(" SCTP: Option State cookie\n");
+                /* // Prolly don't want to print this out :)
+                for(int i = 0; i < ntohs(ph->length) - 8; i++)
+                    printf("%02x", data[i]);
+                printf("'\n");*/
+            }
+            break;
+            case 9:
+            {
+                printf(" SCTP: Option Cookie preservative (TODO)\n");
+            }
+            break;
+            case 11:
+            {
+                printf(" SCTP: Option Host name %s\n", data);
+            }
+            break;
+            case 12:
+            {
+                uint16_t *p = (uint16_t *)data;
+                int len = ntohs(ph->length) - 
+                    sizeof(struct sctp_var_param_hdr);
+                
+                printf(" SCTP: Option Supported address types ");
+                
+                while(len) {
+                    printf("%hu ", ntohs(*p));
+                    p++;
+                    len -= sizeof(*p);
+                }
+                printf("\n");
+            }
+            break;
+            default:
+                printf(" SCTP: Option Unknown type=%hu len=%hu\n", 
+                        ntohs(ph->type), ntohs(ph->length));
+        }
+
+        vlen -= ntohs(ph->length);
+        offset += ntohs(ph->length);
+    }
+}
+
 extern "C"
 void decode(int link_type,char *packet,int len)
@@ -60 +158 @@
     struct sctp_chunk_hdr *chunk;
     int chunk_num = 1;
-    
+
     if(len < (signed)sizeof(struct sctp_common_hdr)) {
-        printf("SCTP: packet too short!\n");
+        printf(" SCTP: packet too short!\n");
         return;
     }
@@ -68 +166 @@
     hdr = (struct sctp_common_hdr *)packet;
 
-    printf("SCTP: Header Src port %u Dst port %u\n",
-            ntohs(hdr->src_port), ntohs(hdr->dst_port));
-    printf("SCTP: Verification tag %u Checksum %u\n",
+    printf(" SCTP: Header Src port %hu Dst port %hu Tag %u Csum %u\n",
+            ntohs(hdr->src_port), ntohs(hdr->dst_port),
             ntohl(hdr->verification_tag), ntohl(hdr->checksum));
 
@@ -81 +178 @@
         chunk->length = ntohs(chunk->length);
 
-        printf("SCTP: Chunk %d Type %s Flags %u Len %u\n",
+        printf(" SCTP: Chunk %d Type %s Flags %u Len %u\n",
             chunk_num++,
             sctp_type_to_str(chunk->type), chunk->flags, chunk->length);
 
-        //packet += sizeof(struct sctp_chunk_hdr);
-        //len -= sizeof(struct sctp_chunk_hdr);
-
         if(chunk->length == 0) {
-            printf("SCTP: Invalid chunk length, aborting.\n");
+            printf(" SCTP: Invalid chunk length, aborting.\n\n");
+            break;
+        }
+
+        switch(chunk->type) {
+            case 0: // DATA
+            {
+                struct sctp_data *data = (struct sctp_data *)(chunk + 1);
+
+                printf(" SCTP: TSN %u Stream ID %hu Stream Seqno %hu "
+                        "Payload ID %u\n",
+                        ntohl(data->tsn), ntohs(data->stream_id),
+                        ntohs(data->stream_seqno),
+                        ntohl(data->payload_proto_id));
+            }
+            break;
+            case 1: // INIT and 
+            case 2: // INIT ACK packets have the same structure
+            {
+                // INIT ACK
+                struct sctp_init_ack *ack = (struct sctp_init_ack *)
+                    (chunk + 1);
+                
+                printf(" SCTP: Tag %u Credit %u Outbound %hu Inbound %hu "
+                        "TSN %u\n",
+                        ntohl(ack->init_tag),
+                        ntohl(ack->rcv_wnd_credit),
+                        ntohs(ack->outbound_streams),
+                        ntohs(ack->inbound_streams),
+                        ntohl(ack->init_tsn));
+
+                int vlen = chunk->length - (sizeof(struct sctp_init_ack) +
+                        sizeof(struct sctp_chunk_hdr) +
+                        sizeof(struct sctp_common_hdr)
+                        );
+                parse_options((char *)(ack + 1), vlen);
+
+            }
+            break;
+            case 3: // SACK
+            {
+                struct sctp_sack *sack = (struct sctp_sack *)(chunk + 1);
+                int i;
+
+                printf(" SCTP: Ack %u Wnd %u\n", ntohl(sack->tsn_ack),
+                        ntohl(sack->a_wnd));
+
+                for(i = 0; i < ntohs(sack->num_gap_blocks); i++) {
+                    uint16_t *p = (uint16_t *)(sack + 1);
+                    p += i * 2;
+
+                    printf(" SCTP: Gap ACK Start %hu End %hu\n",
+                            ntohs(*p), ntohs(*(p + 1)));
+                }
+                for(i = 0; i < ntohs(sack->num_dup_tsns); i++) {
+                    uint32_t *p = (uint32_t *)(sack + 1);
+                    p += ntohs(sack->num_gap_blocks) + i;
+
+                    printf(" SCTP: Duplicatate TSN %u\n", ntohl(*p));
+                }
+            }
             break;
         }