]> git.saurik.com Git - apple/xnu.git/blame - bsd/dev/dtrace/scripts/tcp.d
xnu-7195.101.1.tar.gz
[apple/xnu.git] / bsd / dev / dtrace / scripts / tcp.d
CommitLineData
39236c6e
A
1/*
2 * Copyright (c) 2006-2008 Apple Computer, Inc. All Rights Reserved.
3 *
4 * @APPLE_LICENSE_HEADER_START@
5 *
6 * This file contains Original Code and/or Modifications of Original Code
7 * as defined in and that are subject to the Apple Public Source License
8 * Version 2.0 (the 'License'). You may not use this file except in
9 * compliance with the License. Please obtain a copy of the License at
10 * http://www.opensource.apple.com/apsl/ and read it before using this
11 * file.
12 *
13 * The Original Code and all software distributed under the License are
14 * distributed on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER
15 * EXPRESS OR IMPLIED, AND APPLE HEREBY DISCLAIMS ALL SUCH WARRANTIES,
16 * INCLUDING WITHOUT LIMITATION, ANY WARRANTIES OF MERCHANTABILITY,
17 * FITNESS FOR A PARTICULAR PURPOSE, QUIET ENJOYMENT OR NON-INFRINGEMENT.
18 * Please see the License for the specific language governing rights and
19 * limitations under the License.
20 *
21 * @APPLE_LICENSE_HEADER_END@
22 */
23
24#pragma D depends_on library darwin.d
25#pragma D depends_on module mach_kernel
26#pragma D depends_on provider tcp
27
28/*
29 * TCP flags
30 */
31inline int TH_FIN = 0x01;
32#pragma D binding "1.0" TH_FIN
33inline int TH_SYN = 0x02;
34#pragma D binding "1.0" TH_SYN
35inline int TH_RST = 0x04;
36#pragma D binding "1.0" TH_RST
37inline int TH_PUSH = 0x08;
38#pragma D binding "1.0" TH_PUSH
39inline int TH_ACK = 0x10;
40#pragma D binding "1.0" TH_ACK
41inline int TH_URG = 0x20;
42#pragma D binding "1.0" TH_URG
43inline int TH_ECE = 0x40;
44#pragma D binding "1.0" TH_ECE
45inline int TH_CWR = 0x80;
46#pragma D binding "1.0" TH_CWR
47
48/*
49 * TCP states
50 */
51inline int TCPS_CLOSED = 0;
52#pragma D binding "1.0" TCPS_CLOSED
53inline int TCPS_LISTEN = 1;
54#pragma D binding "1.0" TCPS_LISTEN
55inline int TCPS_SYN_SENT = 2;
56#pragma D binding "1.0" TCPS_SYN_SENT
57inline int TCPS_SYN_RECEIVED = 3;
58#pragma D binding "1.0" TCPS_SYN_RECEIVED
59inline int TCPS_ESTABLISHED = 4;
60#pragma D binding "1.0" TCPS_ESTABLISHED
61inline int TCPS_CLOSE_WAIT = 5;
62#pragma D binding "1.0" TCPS_CLOSE_WAIT
63inline int TCPS_FIN_WAIT_1 = 6;
64#pragma D binding "1.0" TCPS_FIN_WAIT_1
65inline int TCPS_CLOSING = 7;
66#pragma D binding "1.0" TCPS_CLOSING
67inline int TCPS_LAST_ACK = 8;
68#pragma D binding "1.0" TCPS_LAST_ACK
69inline int TCPS_FIN_WAIT_2 = 9;
70#pragma D binding "1.0" TCPS_FIN_WAIT_2
71inline int TCPS_TIME_WAIT = 10;
72#pragma D binding "1.0" TCPS_TIME_WAIT
73
74/*
75 * TCP congestion control events
76 */
77inline int TCP_CC_CWND_INIT = 0;
78#pragma D binding "1.0" TCP_CC_CWND_INIT
79inline int TCP_CC_INSEQ_ACK_RCVD = 1;
80#pragma D binding "1.0" TCP_CC_INSEQ_ACK_RCVD
81inline int TCP_CC_ACK_RCVD = 2;
82#pragma D binding "1.0" TCP_CC_ACK_RCVD
83inline int TCP_CC_ENTER_FASTRECOVERY = 3;
84#pragma D binding "1.0" TCP_CC_ENTER_FASTRECOVERY
85inline int TCP_CC_IN_FASTRECOVERY = 4;
86#pragma D binding "1.0" TCP_CC_IN_FASTRECOVERY
87inline int TCP_CC_EXIT_FASTRECOVERY = 5;
88#pragma D binding "1.0" TCP_CC_EXIT_FASTRECOVERY
89inline int TCP_CC_PARTIAL_ACK = 6;
90#pragma D binding "1.0" TCP_CC_PARTIAL_ACK
91inline int TCP_CC_IDLE_TIMEOUT = 7;
92#pragma D binding "1.0" TCP_CC_IDLE_TIMEOUT
93inline int TCP_CC_REXMT_TIMEOUT = 8;
94#pragma D binding "1.0" TCP_CC_REXMT_TIMEOUT
95inline int TCP_CC_ECN_RCVD = 9;
96#pragma D binding "1.0" TCP_CC_ECN_RCVD
97inline int TCP_CC_BAD_REXMT_RECOVERY = 10;
98#pragma D binding "1.0" TCP_CC_BAD_REXMT_RECOVERY
99inline int TCP_CC_OUTPUT_ERROR = 11;
100#pragma D binding "1.0" TCP_CC_OUTPUT_ERROR
101inline int TCP_CC_CHANGE_ALGO = 12;
102#pragma D binding "1.0" TCP_CC_CHANGE_ALGO
103inline int TCP_CC_FLOW_CONTROL = 13;
104#pragma D binding "1.0" TCP_CC_FLOW_CONTROL
105inline int TCP_CC_SUSPEND = 14;
106#pragma D binding "1.0" TCP_CC_SUSPEND
107inline int TCP_CC_LIMITED_TRANSMIT = 15;
108#pragma D binding "1.0" TCP_CC_LIMITED_TRANSMIT
109inline int TCP_CC_EARLY_RETRANSMIT = 16;
110#pragma D binding "1.0" TCP_CC_EARLY_RETRANSMIT
111
112
113/*
114 * tcpinfo is the TCP header field
115 */
116typedef struct tcpinfo {
117 uint16_t tcp_sport; /* source port */
118 uint16_t tcp_dport; /* destination port */
119 uint32_t tcp_seq; /* sequence number */
120 uint32_t tcp_ack; /* acknowledgement number */
121 uint8_t tcp_offset; /* data offset, in bytes */
122 uint8_t tcp_flags; /* flags */
123 uint16_t tcp_window; /* window size */
124 uint16_t tcp_checksum; /* checksum */
125 uint16_t tcp_urgent; /* urgent data pointer */
126 struct tcphdr *tcp_hdr; /* raw TCP header */
127} tcpinfo_t;
128
129#pragma D binding "1.0" translator
130translator tcpinfo_t < struct tcphdr *T > {
131 tcp_sport = ntohs(T->th_sport);
132 tcp_dport = ntohs(T->th_dport);
133 tcp_seq = ntohl(T->th_seq);
134 tcp_ack = ntohl(T->th_ack);
135 tcp_offset = T->th_off << 2;
136 tcp_flags = T->th_flags;
137 tcp_window = ntohs(T->th_win);
138 tcp_checksum = ntohs(T->th_sum);
139 tcp_urgent = ntohs(T->th_urp);
140 tcp_hdr = T;
141};
142
143/*
144 * tcpsinfo contains stable TCP details from TCP control block
145 */
146typedef struct tcpsinfo {
147 int tcps_local; /* is delivered locally, boolean */
148 int tcps_active; /* active open, boolean */
149 string tcps_state; /* TCP state, as a string */
150 u_int t_flags; /* flags */
151 uint32_t rcv_nxt; /* receive next */
152 uint32_t rcv_adv; /* advertised window */
153 uint32_t rcv_wnd; /* receive window */
154 uint32_t snd_wnd; /* send window */
155 uint32_t snd_cwnd; /* congestion controlled window */
156 uint32_t snd_ssthresh; /* slow-start threshold */
157 uint32_t snd_una; /* send unacknowledged */
158 uint32_t snd_nxt; /* send next */
159 uint32_t snd_max; /* send max */
160 uint32_t snd_recover; /* send recover for NewReno */
161 int t_rxtcur; /* retransmit timeout in ms */
162 u_int t_maxseg; /* maximum segment size */
163 u_int t_rttbest; /* best rtt we have seen */
164 int rcv_numsacks; /* number of sack blocks present */
165 int snd_numholes; /* number of holes seen by sender */
166 struct tcpcb* tcpcb; /* Pointer to tcp control block */
167} tcpsinfo_t;
168
169#pragma D binding "1.0" translator
170translator tcpsinfo_t < struct tcpcb *T> {
171 tcps_local = 0; /* Not used */
172 tcps_active = 0;
173 tcps_state = T ?
174 T->t_state == TCPS_CLOSED ? "state-closed" :
175 T->t_state == TCPS_LISTEN ? "state-listen" :
176 T->t_state == TCPS_SYN_SENT ? "state-syn-sent" :
177 T->t_state == TCPS_SYN_RECEIVED ? "state-syn-received" :
178 T->t_state == TCPS_ESTABLISHED ? "state-established" :
179 T->t_state == TCPS_CLOSE_WAIT ? "state-close-wait" :
180 T->t_state == TCPS_FIN_WAIT_1 ? "state-fin-wait1" :
181 T->t_state == TCPS_CLOSING ? "state-closing" :
182 T->t_state == TCPS_LAST_ACK ? "state-last-ack" :
183 T->t_state == TCPS_FIN_WAIT_2 ? "state-fin-wait2" :
184 T->t_state == TCPS_TIME_WAIT ? "state-time-wait" :
185 "<unknown>" : "<null>";
186 t_flags = T->t_flags;
187 rcv_nxt = T->rcv_nxt;
188 rcv_adv = T->rcv_adv;
189 rcv_wnd = T->rcv_wnd;
190 snd_wnd = T->snd_wnd;
191 snd_cwnd = T->snd_cwnd;
192 snd_ssthresh = T->snd_ssthresh;
193 snd_una = T->snd_una;
194 snd_nxt = T->snd_nxt;
195 snd_max = T->snd_max;
196 snd_recover = T->snd_recover;
197 t_rxtcur = T->t_rxtcur;
198 t_maxseg = T->t_maxseg;
199 t_rttbest = T->t_rttbest;
200 rcv_numsacks = T->rcv_numsacks;
201 snd_numholes = T->snd_numholes;
202 tcpcb = T;
203};
204
205/*
206 * tcpnsinfo provides the new tcp state for state changes.
207 */
208typedef struct tcpnsinfo {
209 string tcps_state; /* TCP state, as a string */
210} tcpnsinfo_t;
211
212#pragma D binding "1.0" translator
213translator tcpnsinfo_t < int32_t I > {
214 tcps_state = I ?
215 I == TCPS_LISTEN ? "state-listen" :
216 I == TCPS_SYN_SENT ? "state-syn-sent" :
217 I == TCPS_SYN_RECEIVED ? "state-syn-received" :
218 I == TCPS_ESTABLISHED ? "state-established" :
219 I == TCPS_CLOSE_WAIT ? "state-close-wait" :
220 I == TCPS_FIN_WAIT_1 ? "state-fin-wait1" :
221 I == TCPS_CLOSING ? "state-closing" :
222 I == TCPS_LAST_ACK ? "state-last-ack" :
223 I == TCPS_FIN_WAIT_2 ? "state-fin-wait2" :
224 I == TCPS_TIME_WAIT ? "state-time-wait" :
225 "<unknown>" : "state-closed";
226};
227
228/*
229 * tcpccevent provides the congestion control event for TCP cc probes
230 */
231typedef struct tcpccevent {
232 string tcp_cc; /* TCP congestion control event, as a string */
233} tcpccevent_t;
234
235#pragma D binding "1.0" translator
236translator tcpccevent_t < int32_t I > {
237 tcp_cc = I ?
238 I == TCP_CC_INSEQ_ACK_RCVD ? "inseq-ack-rcvd" :
239 I == TCP_CC_ACK_RCVD ? "ack-rcvd" :
240 I == TCP_CC_ENTER_FASTRECOVERY ? "enter-fastrecovery" :
241 I == TCP_CC_EXIT_FASTRECOVERY ? "exit-fastrecovery" :
242 I == TCP_CC_PARTIAL_ACK ? "partial-ack" :
243 I == TCP_CC_IDLE_TIMEOUT ? "idle-timeout" :
244 I == TCP_CC_REXMT_TIMEOUT ? "rexmt-timeout" :
245 I == TCP_CC_ECN_RCVD ? "ecn-rcvd" :
246 I == TCP_CC_BAD_REXMT_RECOVERY ? "bad-rexmt" :
247 I == TCP_CC_OUTPUT_ERROR ? "output-error" :
248 I == TCP_CC_CHANGE_ALGO ? "change-algo" :
249 I == TCP_CC_FLOW_CONTROL ? "flow-control" :
250 I == TCP_CC_SUSPEND ? "suspend" :
251 I == TCP_CC_LIMITED_TRANSMIT ? "limited-transmit" :
252 I == TCP_CC_EARLY_RETRANSMIT ? "early-rexmt" :
253 "<unknown>" : "cwnd-init";
254};