1 /*
2 * Copyright (c) 2018-2023 Apple Inc. All rights reserved.
3 *
4 * @APPLE_OSREFERENCE_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. The rights granted to you under the License
10 * may not be used to create, or enable the creation or redistribution of,
11 * unlawful or unlicensed copies of an Apple operating system, or to
12 * circumvent, violate, or enable the circumvention or violation of, any
13 * terms of an Apple operating system software license agreement.
14 *
15 * Please obtain a copy of the License at
16 * http://www.opensource.apple.com/apsl/ and read it before using this file.
17 *
18 * The Original Code and all software distributed under the License are
19 * distributed on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER
20 * EXPRESS OR IMPLIED, AND APPLE HEREBY DISCLAIMS ALL SUCH WARRANTIES,
21 * INCLUDING WITHOUT LIMITATION, ANY WARRANTIES OF MERCHANTABILITY,
22 * FITNESS FOR A PARTICULAR PURPOSE, QUIET ENJOYMENT OR NON-INFRINGEMENT.
23 * Please see the License for the specific language governing rights and
24 * limitations under the License.
25 *
26 * @APPLE_OSREFERENCE_LICENSE_HEADER_END@
27 */
28
29
30 #ifndef _NETINET_TCP_LOG_H_
31 #define _NETINET_TCP_LOG_H_
32
33 #ifdef PRIVATE
34
35 #define TCP_ENABLE_FLAG_LIST \
36 X(TLEF_CONNECTION, 0x00000001, connection) \
37 X(TLEF_RTT, 0x00000002, rtt) \
38 X(TLEF_KEEP_ALIVE, 0x00000004, ka) \
39 X(TLEF_LOG, 0x00000008, log) \
40 X(TLEF_DST_LOOPBACK, 0x00000010, loop) \
41 X(TLEF_DST_LOCAL, 0x00000020, local) \
42 X(TLEF_DST_GW, 0x00000040, gw) \
43 X(TLEF_THF_SYN, 0x00000100, syn) \
44 X(TLEF_THF_FIN, 0x00000200, fin) \
45 X(TLEF_THF_RST, 0x00000400, rst) \
46 X(TLEF_DROP_NECP, 0x00001000, dropnecp) \
47 X(TLEF_DROP_PCB, 0x00002000, droppcb) \
48 X(TLEF_DROP_PKT, 0x00004000, droppkt) \
49 X(TLEF_FSW_FLOW, 0x00008000, fswflow) \
50 X(TLEF_STATE, 0x00010000, state) \
51 X(TLEF_SYN_RXMT, 0x00020000, synrxmt) \
52 X(TLEF_OUTPUT, 0x00040000, output) \
53 X(TLEF_BIND, 0x00080000, bind)
54
55 /*
56 * Flag values for tcp_log_enabled
57 */
58 enum {
59 #define X(name, value, ...) name = value,
60 TCP_ENABLE_FLAG_LIST
61 #undef X
62 };
63
64 #endif /* PRIVATE */
65
66 #ifdef BSD_KERNEL_PRIVATE
67
68 #include <sys/param.h>
69 #include <sys/systm.h>
70
71 #include <netinet/in.h>
72 #include <netinet/in_systm.h>
73 #include <netinet/in_pcb.h>
74 #include <netinet6/in6_pcb.h>
75
76 #include <netinet/tcp.h>
77 #include <netinet/tcp_var.h>
78 #include <netinet6/tcp6_var.h>
79
80 #include <netinet/inp_log.h>
81
82 #include <net/net_log_common.h>
83
84 #include <os/log.h>
85
86 #include <stdbool.h>
87
88 extern os_log_t tcp_mpkl_log_object;
89 extern uint32_t tcp_log_enable_flags;
90 extern uint16_t tcp_log_port;
91
92 #define TLEF_MASK_DST (TLEF_DST_LOOPBACK | TLEF_DST_LOCAL | TLEF_DST_GW)
93
94 extern void tcp_log_connection_summary(struct tcpcb *tp);
95 extern void tcp_log_th_flags(void *hdr, struct tcphdr *th, struct tcpcb *tp, bool outgoing, struct ifnet *ifp);
96 extern void tcp_log_connection(struct tcpcb *tp, const char *event, int error);
97 extern void tcp_log_listen(struct tcpcb *tp, int error);
98 extern void tcp_log_drop_pcb(void *hdr, struct tcphdr *th, struct tcpcb *tp, bool outgoing, const char *reason);
99 extern void tcp_log_drop_pkt(void *hdr, struct tcphdr *th, struct ifnet *ifp, const char *reason);
100 extern void tcp_log_rtt_info(const char *func_name, int line_no, struct tcpcb *tp);
101 extern void tcp_log_rt_rtt(const char *func_name, int line_no, struct tcpcb *tp, struct rtentry *rt);
102 extern void tcp_log_rtt_change(const char *func_name, int line_no, struct tcpcb *tp, int old_srtt, int old_rttvar);
103 extern void tcp_log_keepalive(const char *func_name, int line_no, struct tcpcb *tp, int32_t idle_time);
104 extern void tcp_log_message(const char *func_name, int line_no, struct tcpcb *tp, const char *format, ...) __printflike(4, 5);
105 extern void tcp_log_fsw_flow(const char *func_name, int line_no, struct tcpcb *tp, const char *format, ...) __printflike(4, 5);
106 extern void tcp_log_state_change(struct tcpcb *tp, int new_state);
107 extern void tcp_log_output(const char *func_name, int line_no, struct tcpcb *tp, const char *format, ...) __printflike(4, 5);
108 extern void tcp_log_bind(struct inpcb *inp, const char *event, int error);
109
110 static inline bool
tcp_is_log_enabled(struct tcpcb * tp,uint32_t req_flags)111 tcp_is_log_enabled(struct tcpcb *tp, uint32_t req_flags)
112 {
113 struct inpcb *inp;
114
115 if (tp == NULL || tp->t_inpcb == NULL) {
116 return false;
117 }
118 inp = tp->t_inpcb;
119 if (tcp_log_port > 0 &&
120 ntohs(inp->inp_lport) != tcp_log_port &&
121 ntohs(tp->t_inpcb->inp_fport) != tcp_log_port) {
122 return false;
123 }
124
125 /*
126 * First find out the kind of destination
127 */
128 if (inp->inp_log_flags == 0) {
129 if (tp->t_inpcb->inp_vflag & INP_IPV6) {
130 if (IN6_IS_ADDR_LOOPBACK(&tp->t_inpcb->in6p_laddr) ||
131 IN6_IS_ADDR_LOOPBACK(&tp->t_inpcb->in6p_faddr)) {
132 inp->inp_log_flags |= TLEF_DST_LOOPBACK;
133 }
134 } else {
135 if (ntohl(tp->t_inpcb->inp_laddr.s_addr) == INADDR_LOOPBACK ||
136 ntohl(tp->t_inpcb->inp_faddr.s_addr) == INADDR_LOOPBACK) {
137 inp->inp_log_flags |= TLEF_DST_LOOPBACK;
138 }
139 }
140 if (inp->inp_log_flags == 0) {
141 if (tp->t_flags & TF_LOCAL) {
142 inp->inp_log_flags |= TLEF_DST_LOCAL;
143 } else {
144 inp->inp_log_flags |= TLEF_DST_GW;
145 }
146 }
147 }
148 /*
149 * Check separately the destination flags that are per TCP connection
150 * and the other functional flags that are global
151 */
152 return (inp->inp_log_flags & tcp_log_enable_flags & TLEF_MASK_DST) &&
153 (tcp_log_enable_flags & (req_flags & ~TLEF_MASK_DST));
154 }
155
156 #define TCP_LOG_RTT_INFO(tp) if (tcp_is_log_enabled(tp, TLEF_RTT)) \
157 tcp_log_rtt_info(__func__, __LINE__, (tp))
158
159 #define TCP_LOG_RTM_RTT(tp, rt) if (tcp_is_log_enabled(tp, TLEF_RTT)) \
160 tcp_log_rt_rtt(__func__, __LINE__, (tp), (rt))
161
162 #define TCP_LOG_RTT_CHANGE(tp, old_srtt, old_rttvar) if (tcp_is_log_enabled(tp, TLEF_RTT)) \
163 tcp_log_rtt_change(__func__, __LINE__, (tp), (old_srtt), (old_rttvar))
164
165 #define TCP_LOG_KEEP_ALIVE(tp, idle_time) if (tcp_is_log_enabled(tp, TLEF_KEEP_ALIVE)) \
166 tcp_log_keepalive(__func__, __LINE__, (tp), (idle_time))
167
168 #define TCP_LOG_CONNECT(tp, outgoing, error) if (tcp_is_log_enabled(tp, TLEF_CONNECTION)) \
169 tcp_log_connection((tp), __unsafe_forge_null_terminated(const char *, ((outgoing) ? "connect outgoing" : "connect incoming")), (error))
170
171 #define TCP_LOG_CONNECTED(tp, error) if (tcp_is_log_enabled(tp, TLEF_CONNECTION)) \
172 tcp_log_connection((tp), "connected", (error))
173
174 #define TCP_LOG_LISTEN(tp, error) if (tcp_is_log_enabled(tp, TLEF_CONNECTION)) \
175 tcp_log_listen((tp), (error))
176
177 #define TCP_LOG_ACCEPT(tp, error) if (tcp_is_log_enabled(tp, TLEF_CONNECTION)) \
178 tcp_log_connection((tp), "accept", (error))
179
180 #define TCP_LOG_CONNECTION_SUMMARY(tp) if (tcp_is_log_enabled(tp, TLEF_CONNECTION)) \
181 tcp_log_connection_summary((tp))
182
183 #define TCP_LOG_DROP_NECP(hdr, th, tp, outgoing) if (tcp_is_log_enabled(tp, TLEF_DROP_NECP)) \
184 tcp_log_drop_pcb((hdr), (th), (tp), (outgoing), "NECP")
185
186 #define TCP_LOG_DROP_PCB(hdr, th, tp, outgoing, reason) if (tcp_is_log_enabled(tp, TLEF_DROP_PCB)) \
187 tcp_log_drop_pcb((hdr), (th), (tp), (outgoing), reason)
188
189 #define TCP_LOG_TH_FLAGS(hdr, th, tp, outgoing, ifp) \
190 if ((th) != NULL && ((th)->th_flags & (TH_SYN|TH_FIN|TH_RST))) \
191 tcp_log_th_flags((hdr), (th), (tp), (outgoing), (ifp))
192
193 #define TCP_LOG_DROP_PKT(hdr, th, ifp, reason) \
194 if ((th) != NULL && ((th->th_flags) & (TH_SYN|TH_FIN|TH_RST)) && \
195 (tcp_log_enable_flags & TLEF_DROP_PKT)) \
196 tcp_log_drop_pkt((hdr), (th), (ifp), (reason))
197
198 #define TCP_LOG_FSW_FLOW(tp, format, ...) if (tcp_is_log_enabled(tp, TLEF_FSW_FLOW)) \
199 tcp_log_fsw_flow(__func__, __LINE__, (tp), format, ##__VA_ARGS__)
200
201 #define TCP_LOG(tp, format, ...) if (tcp_is_log_enabled(tp, TLEF_LOG)) \
202 tcp_log_message(__func__, __LINE__, tp, format, ## __VA_ARGS__)
203
204 #define TCP_LOG_STATE(tp, new_state) if (tcp_is_log_enabled(tp, TLEF_STATE)) \
205 tcp_log_state_change((tp), (new_state))
206
207 #define TCP_LOG_OUTPUT(tp, format, ...) if (tcp_is_log_enabled(tp, TLEF_OUTPUT)) \
208 tcp_log_output(__func__, __LINE__, tp, format, ## __VA_ARGS__)
209
210 #define TCP_LOG_BIND(tp, error) if (tcp_is_log_enabled(tp, TLEF_BIND)) \
211 tcp_log_connection((tp), "bind", (error))
212
213 #endif /* BSD_KERNEL_PRIVATE */
214
215 #endif /* _NETINET_TCP_LOG_H_ */
216