--- /dev/null
+/*
+ * Copyright (c) 2006-2008 Apple Computer, Inc. All Rights Reserved.
+ *
+ * @APPLE_LICENSE_HEADER_START@
+ *
+ * This file contains Original Code and/or Modifications of Original Code
+ * as defined in and that are subject to the Apple Public Source License
+ * Version 2.0 (the 'License'). You may not use this file except in
+ * compliance with the License. Please obtain a copy of the License at
+ * http://www.opensource.apple.com/apsl/ and read it before using this
+ * file.
+ *
+ * The Original Code and all software distributed under the License are
+ * distributed on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER
+ * EXPRESS OR IMPLIED, AND APPLE HEREBY DISCLAIMS ALL SUCH WARRANTIES,
+ * INCLUDING WITHOUT LIMITATION, ANY WARRANTIES OF MERCHANTABILITY,
+ * FITNESS FOR A PARTICULAR PURPOSE, QUIET ENJOYMENT OR NON-INFRINGEMENT.
+ * Please see the License for the specific language governing rights and
+ * limitations under the License.
+ *
+ * @APPLE_LICENSE_HEADER_END@
+ */
+
+#pragma D depends_on library darwin.d
+#pragma D depends_on module mach_kernel
+#pragma D depends_on provider tcp
+
+/*
+ * TCP flags
+ */
+inline int TH_FIN = 0x01;
+#pragma D binding "1.0" TH_FIN
+inline int TH_SYN = 0x02;
+#pragma D binding "1.0" TH_SYN
+inline int TH_RST = 0x04;
+#pragma D binding "1.0" TH_RST
+inline int TH_PUSH = 0x08;
+#pragma D binding "1.0" TH_PUSH
+inline int TH_ACK = 0x10;
+#pragma D binding "1.0" TH_ACK
+inline int TH_URG = 0x20;
+#pragma D binding "1.0" TH_URG
+inline int TH_ECE = 0x40;
+#pragma D binding "1.0" TH_ECE
+inline int TH_CWR = 0x80;
+#pragma D binding "1.0" TH_CWR
+
+/*
+ * TCP states
+ */
+inline int TCPS_CLOSED = 0;
+#pragma D binding "1.0" TCPS_CLOSED
+inline int TCPS_LISTEN = 1;
+#pragma D binding "1.0" TCPS_LISTEN
+inline int TCPS_SYN_SENT = 2;
+#pragma D binding "1.0" TCPS_SYN_SENT
+inline int TCPS_SYN_RECEIVED = 3;
+#pragma D binding "1.0" TCPS_SYN_RECEIVED
+inline int TCPS_ESTABLISHED = 4;
+#pragma D binding "1.0" TCPS_ESTABLISHED
+inline int TCPS_CLOSE_WAIT = 5;
+#pragma D binding "1.0" TCPS_CLOSE_WAIT
+inline int TCPS_FIN_WAIT_1 = 6;
+#pragma D binding "1.0" TCPS_FIN_WAIT_1
+inline int TCPS_CLOSING = 7;
+#pragma D binding "1.0" TCPS_CLOSING
+inline int TCPS_LAST_ACK = 8;
+#pragma D binding "1.0" TCPS_LAST_ACK
+inline int TCPS_FIN_WAIT_2 = 9;
+#pragma D binding "1.0" TCPS_FIN_WAIT_2
+inline int TCPS_TIME_WAIT = 10;
+#pragma D binding "1.0" TCPS_TIME_WAIT
+
+/*
+ * TCP congestion control events
+ */
+inline int TCP_CC_CWND_INIT = 0;
+#pragma D binding "1.0" TCP_CC_CWND_INIT
+inline int TCP_CC_INSEQ_ACK_RCVD = 1;
+#pragma D binding "1.0" TCP_CC_INSEQ_ACK_RCVD
+inline int TCP_CC_ACK_RCVD = 2;
+#pragma D binding "1.0" TCP_CC_ACK_RCVD
+inline int TCP_CC_ENTER_FASTRECOVERY = 3;
+#pragma D binding "1.0" TCP_CC_ENTER_FASTRECOVERY
+inline int TCP_CC_IN_FASTRECOVERY = 4;
+#pragma D binding "1.0" TCP_CC_IN_FASTRECOVERY
+inline int TCP_CC_EXIT_FASTRECOVERY = 5;
+#pragma D binding "1.0" TCP_CC_EXIT_FASTRECOVERY
+inline int TCP_CC_PARTIAL_ACK = 6;
+#pragma D binding "1.0" TCP_CC_PARTIAL_ACK
+inline int TCP_CC_IDLE_TIMEOUT = 7;
+#pragma D binding "1.0" TCP_CC_IDLE_TIMEOUT
+inline int TCP_CC_REXMT_TIMEOUT = 8;
+#pragma D binding "1.0" TCP_CC_REXMT_TIMEOUT
+inline int TCP_CC_ECN_RCVD = 9;
+#pragma D binding "1.0" TCP_CC_ECN_RCVD
+inline int TCP_CC_BAD_REXMT_RECOVERY = 10;
+#pragma D binding "1.0" TCP_CC_BAD_REXMT_RECOVERY
+inline int TCP_CC_OUTPUT_ERROR = 11;
+#pragma D binding "1.0" TCP_CC_OUTPUT_ERROR
+inline int TCP_CC_CHANGE_ALGO = 12;
+#pragma D binding "1.0" TCP_CC_CHANGE_ALGO
+inline int TCP_CC_FLOW_CONTROL = 13;
+#pragma D binding "1.0" TCP_CC_FLOW_CONTROL
+inline int TCP_CC_SUSPEND = 14;
+#pragma D binding "1.0" TCP_CC_SUSPEND
+inline int TCP_CC_LIMITED_TRANSMIT = 15;
+#pragma D binding "1.0" TCP_CC_LIMITED_TRANSMIT
+inline int TCP_CC_EARLY_RETRANSMIT = 16;
+#pragma D binding "1.0" TCP_CC_EARLY_RETRANSMIT
+
+
+/*
+ * tcpinfo is the TCP header field
+ */
+typedef struct tcpinfo {
+ uint16_t tcp_sport; /* source port */
+ uint16_t tcp_dport; /* destination port */
+ uint32_t tcp_seq; /* sequence number */
+ uint32_t tcp_ack; /* acknowledgement number */
+ uint8_t tcp_offset; /* data offset, in bytes */
+ uint8_t tcp_flags; /* flags */
+ uint16_t tcp_window; /* window size */
+ uint16_t tcp_checksum; /* checksum */
+ uint16_t tcp_urgent; /* urgent data pointer */
+ struct tcphdr *tcp_hdr; /* raw TCP header */
+} tcpinfo_t;
+
+#pragma D binding "1.0" translator
+translator tcpinfo_t < struct tcphdr *T > {
+ tcp_sport = ntohs(T->th_sport);
+ tcp_dport = ntohs(T->th_dport);
+ tcp_seq = ntohl(T->th_seq);
+ tcp_ack = ntohl(T->th_ack);
+ tcp_offset = T->th_off << 2;
+ tcp_flags = T->th_flags;
+ tcp_window = ntohs(T->th_win);
+ tcp_checksum = ntohs(T->th_sum);
+ tcp_urgent = ntohs(T->th_urp);
+ tcp_hdr = T;
+};
+
+/*
+ * tcpsinfo contains stable TCP details from TCP control block
+ */
+typedef struct tcpsinfo {
+ int tcps_local; /* is delivered locally, boolean */
+ int tcps_active; /* active open, boolean */
+ string tcps_state; /* TCP state, as a string */
+ u_int t_flags; /* flags */
+ uint32_t rcv_nxt; /* receive next */
+ uint32_t rcv_adv; /* advertised window */
+ uint32_t rcv_wnd; /* receive window */
+ uint32_t snd_wnd; /* send window */
+ uint32_t snd_cwnd; /* congestion controlled window */
+ uint32_t snd_ssthresh; /* slow-start threshold */
+ uint32_t snd_una; /* send unacknowledged */
+ uint32_t snd_nxt; /* send next */
+ uint32_t snd_max; /* send max */
+ uint32_t snd_recover; /* send recover for NewReno */
+ int t_rxtcur; /* retransmit timeout in ms */
+ u_int t_maxseg; /* maximum segment size */
+ u_int t_rttbest; /* best rtt we have seen */
+ int rcv_numsacks; /* number of sack blocks present */
+ int snd_numholes; /* number of holes seen by sender */
+ struct tcpcb* tcpcb; /* Pointer to tcp control block */
+} tcpsinfo_t;
+
+#pragma D binding "1.0" translator
+translator tcpsinfo_t < struct tcpcb *T> {
+ tcps_local = 0; /* Not used */
+ tcps_active = 0;
+ tcps_state = T ?
+ T->t_state == TCPS_CLOSED ? "state-closed" :
+ T->t_state == TCPS_LISTEN ? "state-listen" :
+ T->t_state == TCPS_SYN_SENT ? "state-syn-sent" :
+ T->t_state == TCPS_SYN_RECEIVED ? "state-syn-received" :
+ T->t_state == TCPS_ESTABLISHED ? "state-established" :
+ T->t_state == TCPS_CLOSE_WAIT ? "state-close-wait" :
+ T->t_state == TCPS_FIN_WAIT_1 ? "state-fin-wait1" :
+ T->t_state == TCPS_CLOSING ? "state-closing" :
+ T->t_state == TCPS_LAST_ACK ? "state-last-ack" :
+ T->t_state == TCPS_FIN_WAIT_2 ? "state-fin-wait2" :
+ T->t_state == TCPS_TIME_WAIT ? "state-time-wait" :
+ "<unknown>" : "<null>";
+ t_flags = T->t_flags;
+ rcv_nxt = T->rcv_nxt;
+ rcv_adv = T->rcv_adv;
+ rcv_wnd = T->rcv_wnd;
+ snd_wnd = T->snd_wnd;
+ snd_cwnd = T->snd_cwnd;
+ snd_ssthresh = T->snd_ssthresh;
+ snd_una = T->snd_una;
+ snd_nxt = T->snd_nxt;
+ snd_max = T->snd_max;
+ snd_recover = T->snd_recover;
+ t_rxtcur = T->t_rxtcur;
+ t_maxseg = T->t_maxseg;
+ t_rttbest = T->t_rttbest;
+ rcv_numsacks = T->rcv_numsacks;
+ snd_numholes = T->snd_numholes;
+ tcpcb = T;
+};
+
+/*
+ * tcpnsinfo provides the new tcp state for state changes.
+ */
+typedef struct tcpnsinfo {
+ string tcps_state; /* TCP state, as a string */
+} tcpnsinfo_t;
+
+#pragma D binding "1.0" translator
+translator tcpnsinfo_t < int32_t I > {
+ tcps_state = I ?
+ I == TCPS_LISTEN ? "state-listen" :
+ I == TCPS_SYN_SENT ? "state-syn-sent" :
+ I == TCPS_SYN_RECEIVED ? "state-syn-received" :
+ I == TCPS_ESTABLISHED ? "state-established" :
+ I == TCPS_CLOSE_WAIT ? "state-close-wait" :
+ I == TCPS_FIN_WAIT_1 ? "state-fin-wait1" :
+ I == TCPS_CLOSING ? "state-closing" :
+ I == TCPS_LAST_ACK ? "state-last-ack" :
+ I == TCPS_FIN_WAIT_2 ? "state-fin-wait2" :
+ I == TCPS_TIME_WAIT ? "state-time-wait" :
+ "<unknown>" : "state-closed";
+};
+
+/*
+ * tcpccevent provides the congestion control event for TCP cc probes
+ */
+typedef struct tcpccevent {
+ string tcp_cc; /* TCP congestion control event, as a string */
+} tcpccevent_t;
+
+#pragma D binding "1.0" translator
+translator tcpccevent_t < int32_t I > {
+ tcp_cc = I ?
+ I == TCP_CC_INSEQ_ACK_RCVD ? "inseq-ack-rcvd" :
+ I == TCP_CC_ACK_RCVD ? "ack-rcvd" :
+ I == TCP_CC_ENTER_FASTRECOVERY ? "enter-fastrecovery" :
+ I == TCP_CC_EXIT_FASTRECOVERY ? "exit-fastrecovery" :
+ I == TCP_CC_PARTIAL_ACK ? "partial-ack" :
+ I == TCP_CC_IDLE_TIMEOUT ? "idle-timeout" :
+ I == TCP_CC_REXMT_TIMEOUT ? "rexmt-timeout" :
+ I == TCP_CC_ECN_RCVD ? "ecn-rcvd" :
+ I == TCP_CC_BAD_REXMT_RECOVERY ? "bad-rexmt" :
+ I == TCP_CC_OUTPUT_ERROR ? "output-error" :
+ I == TCP_CC_CHANGE_ALGO ? "change-algo" :
+ I == TCP_CC_FLOW_CONTROL ? "flow-control" :
+ I == TCP_CC_SUSPEND ? "suspend" :
+ I == TCP_CC_LIMITED_TRANSMIT ? "limited-transmit" :
+ I == TCP_CC_EARLY_RETRANSMIT ? "early-rexmt" :
+ "<unknown>" : "cwnd-init";
+};
projects / apple / xnu.git / blobdiff