/*
* 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
/*
* 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 sack_enable; /* is sack enabled */
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;
sack_enable = T->sack_enable;
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" :
"<unknown>" : "cwnd-init";
};