typedef struct pktinfo {
        uintptr_t pkt_addr;             /* currently always NULL */
} pktinfo_t;

typedef struct csinfo {
        uintptr_t cs_addr;
	uint64_t cs_cid;
	pid_t cs_pid;
	zoneid_t cs_zoneid;
 } csinfo_t;

typedef struct ipinfo {
        uint8_t ip_ver;                 /* IP version (4, 6) */
        uint16_t ip_plength;            /* payload length */
        string ip_saddr;                /* source address */
        string ip_daddr;                /* destination address */
} ipinfo_t;

typedef struct sctpsinfo {
        uintptr_t sctps_addr;
        int sctps_num_raddrs;           /* number of remote addresses */
        uintptr_t sctps_raddrs;         /* pointer to first remote address */
        uint16_t sctps_lport;           /* local port */
        uint16_t sctps_rport;           /* remote port */
        string sctps_laddr;             /* local address, as a string */
        string sctps_raddr;             /* remote address, as a string */
        int32_t sctps_state;
} sctpsinfo_t;

typedef struct sctprinfo {
        uintptr_t sctpr_addr;
        int sctpr_state;
        string sctpr_raddr;
        string sctpr_laddr;
        int64_t sctpr_hb_expiry;        /* heartbeat retransmit time, msec */
        uint32_t sctpr_hb_interval;     /* heartbeat interval, msec */
        int sctpr_rto;                  /* round-trip timeout, ticks */
        int sctpr_rtt;                  /* smoothed avg round-trip time ticks */
        int sctpr_rtt_var;              /* variance of RTT */
        uint32_t sctpr_mss;             /* max packet size */
        uint32_t sctpr_cwnd;            /* congestion window */
        uint32_t sctpr_ssthresh;        /* threshold for congestion avoidance */
        uint32_t sctpr_suna;            /* sent and unacked */
        uint32_t sctpr_pba;             /* partial bytes acked */
        uint32_t sctpr_acked;           /* bytes acked */
        uintptr_t sctpr_next;           /* next remote address structure */
} sctprinfo_t;

typedef struct sctplsinfo {
        int32_t sctps_state;              /* SCTP state */
} sctplsinfo_t;

typedef struct sctpinfo {
        uint16_t sctp_sport;              /* source port */
        uint16_t sctp_dport;              /* destination port */
        uint16_t sctp_verify;             /* verification tag */
        uint16_t sctp_checksum;           /* headers + data checksum */
        sctp_chunk_hdr_t *sctp_chunk_hdr; /* generic sctp chunk header */ 
        sctp_hdr_t *sctp_hdr;             /* raw SCTP header */
} sctpinfo_t;

#!/usr/sbin/dtrace -s

#pragma D option quiet
#pragma D option switchrate=10

int last[int];

dtrace:::BEGIN
{
        printf(" %3s %12s  %-20s    %-20s\n", "CPU", "DELTA(us)", "OLD", "NEW");
        last = timestamp;
}

sctp:::state-change
/ last[args[1]->cs_cid] /
{
        this->elapsed = (timestamp - last[args[1]->cs_cid]) / 1000;
        printf(" %3d %12d  %-20s -> %-20s\n", cpu, this->elapsed,
            sctp_state_string[args[5]->sctps_state], sctp_state_string[args[3]->sctps_state]);
        last[args[1]->cs_cid] = timestamp;
}

sctp:::state-change
/ last[args[1]->cs_cid] == 0 /
{
        printf(" %3d %12s  %-20s -> %-20s\n", cpu, "-",
            sctp_state_string[args[5]->sctps_state],
            sctp_state_string[args[3]->sctps_state]);
        last[args[1]->cs_cid] = timestamp;
}

#!/usr/sbin/dtrace -s

#pragma D option quiet
#pragma D option switchrate=10hz

dtrace:::BEGIN
{
        printf(" %3s %15s:%-5s      %15s:%-5s\n", "CPU",
            "LADDR", "LPORT", "RADDR", "RPORT");
}

sctp:::send
{
        printf(" %3d %16s:%-5d -> %16s:%-5d\n", cpu,
            args[2]->ip_saddr, args[4]->sctp_sport,
            args[2]->ip_daddr, args[4]->sctp_dport);
}

sctp:::receive
{
        printf(" %3d %16s:%-5d <- %16s:%-5d\n", cpu,
            args[2]->ip_daddr, args[4]->sctp_dport,
            args[2]->ip_saddr, args[4]->sctp_sport);
}