Added INIT ACK parsing.

Author: MaximProshin

src/spindump_analyze_sctp.c

@@ -178,8 +178,15 @@ spindump_analyze_process_sctp(struct spindump_analyze* state,
       //
 
       if (connection != 0) {
+      
+        struct spindump_sctp_chunk_init_ack sctp_chunk_init_ack;
+        spindump_protocols_sctp_chunk_init_ack_parse(
+          packet->contents + sctpHeaderPosition + spindump_sctp_packet_header_length, 
+	  &sctp_chunk_init_ack);
 
-        spindump_analyze_process_pakstats(state,connection,1,packet,ipPacketLength,ecnFlags);
+        connection->u.sctp.side2Vtag = sctp_chunk_init_ack.initiateTag;
+	
+	spindump_analyze_process_pakstats(state,connection,1,packet,ipPacketLength,ecnFlags);
         *p_connection = connection;
 
       } else {

src/spindump_analyze_sctp_parser.c

@@ -44,6 +44,8 @@
 //  |                          Chunk Value                          |
 //  |                                                               |
 //  +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
+//
+// TODO: Maksim Proshin: add checks on params length
 void
 spindump_protocols_sctp_chunk_header_parse(const unsigned char* header,
                                      struct spindump_sctp_chunk_header* decoded){
@@ -54,6 +56,7 @@ spindump_protocols_sctp_chunk_header_parse(const unsigned char* header,
 }
 
 // TODO: Maksim Proshin: add INIT chunk description and function description
+// TODO: Maksim Proshin: add checks on params length
 void
 spindump_protocols_sctp_chunk_init_parse(const unsigned char* header,
                                      struct spindump_sctp_chunk_init* decoded){
@@ -67,3 +70,19 @@ spindump_protocols_sctp_chunk_init_parse(const unsigned char* header,
   spindump_decode2byteint(decoded->inStreams,header,pos);            // Num of Inbound Streams
   spindump_decode4byteint(decoded->initTsn,header,pos);              // Initial TSN
 }
+
+// TODO: Maksim Proshin: add INIT ACK chunk description and function description
+// TODO: Maksim Proshin: add checks on params length
+void
+spindump_protocols_sctp_chunk_init_ack_parse(const unsigned char* header,
+                                     struct spindump_sctp_chunk_init_ack* decoded){
+  unsigned int pos = 0;
+  spindump_decodebyte(decoded->header.ch_type,header,pos);           // Chunk Type
+  spindump_decodebyte(decoded->header.ch_flags,header,pos);          // Chunk Flags
+  spindump_decode2byteint(decoded->header.ch_length,header,pos);     // Chunk Length
+  spindump_decode4byteint(decoded->initiateTag,header,pos);          // Initiate Tag
+  spindump_decode4byteint(decoded->arwnd,header,pos);                // Advertised Receiver Window
+  spindump_decode2byteint(decoded->outStreams,header,pos);           // Num of Outbound Streams
+  spindump_decode2byteint(decoded->inStreams,header,pos);            // Num of Inbound Streams
+  spindump_decode4byteint(decoded->initTsn,header,pos);              // Initial TSN
+}

src/spindump_analyze_sctp_parser.h

@@ -38,4 +38,8 @@ void
 spindump_protocols_sctp_chunk_init_parse(const unsigned char* header,
                                          struct spindump_sctp_chunk_init* decoded);
 
+void
+spindump_protocols_sctp_chunk_init_ack_parse(const unsigned char* header,
+                                             struct spindump_sctp_chunk_init_ack* decoded);
+
 #endif // SPINDUMP_ANALYZE_SCTP_PARSER_H

src/spindump_connections_new.c

@@ -429,7 +429,7 @@ spindump_connections_newconnection_sctp(const spindump_address* side1address,
   connection->u.sctp.side1peerPort = side1port;
   connection->u.sctp.side2peerPort = side2port;
   connection->u.sctp.side1Vtag = side1Vtag;  // VTag from INIT chunk
-  connection->u.sctp.side2Vtag = 0;  // VTag from INIT ACK chunk
+  connection->u.sctp.side2Vtag = 0;  // VTag from INIT ACK chunk will be stored here
   spindump_connections_newconnection_addtoaggregates(connection,table);
 
   spindump_debugf("created a new SCTP connection %u", connection->id);

src/spindump_protocols.h

@@ -730,6 +730,7 @@ struct spindump_sctp_chunk_header {
   uint8_t ch_type;       // Chunk Type
   uint8_t ch_flags;      // Chunk Flags
   uint16_t ch_length;    // Chunk Length
+  // Chunk Value follows
 };