tcp_usrreq.c revision 1.177 1 1.177 rmind /* $NetBSD: tcp_usrreq.c,v 1.177 2014/05/22 00:28:32 rmind Exp $ */
2 1.40 itojun
3 1.40 itojun /*
4 1.40 itojun * Copyright (C) 1995, 1996, 1997, and 1998 WIDE Project.
5 1.40 itojun * All rights reserved.
6 1.71 itojun *
7 1.40 itojun * Redistribution and use in source and binary forms, with or without
8 1.40 itojun * modification, are permitted provided that the following conditions
9 1.40 itojun * are met:
10 1.40 itojun * 1. Redistributions of source code must retain the above copyright
11 1.40 itojun * notice, this list of conditions and the following disclaimer.
12 1.40 itojun * 2. Redistributions in binary form must reproduce the above copyright
13 1.40 itojun * notice, this list of conditions and the following disclaimer in the
14 1.40 itojun * documentation and/or other materials provided with the distribution.
15 1.40 itojun * 3. Neither the name of the project nor the names of its contributors
16 1.40 itojun * may be used to endorse or promote products derived from this software
17 1.40 itojun * without specific prior written permission.
18 1.71 itojun *
19 1.40 itojun * THIS SOFTWARE IS PROVIDED BY THE PROJECT AND CONTRIBUTORS ``AS IS'' AND
20 1.40 itojun * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
21 1.40 itojun * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
22 1.40 itojun * ARE DISCLAIMED. IN NO EVENT SHALL THE PROJECT OR CONTRIBUTORS BE LIABLE
23 1.40 itojun * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
24 1.40 itojun * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
25 1.40 itojun * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
26 1.40 itojun * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
27 1.40 itojun * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
28 1.40 itojun * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
29 1.40 itojun * SUCH DAMAGE.
30 1.40 itojun */
31 1.34 thorpej
32 1.34 thorpej /*-
33 1.120 rpaulo * Copyright (c) 1997, 1998, 2005, 2006 The NetBSD Foundation, Inc.
34 1.34 thorpej * All rights reserved.
35 1.34 thorpej *
36 1.34 thorpej * This code is derived from software contributed to The NetBSD Foundation
37 1.34 thorpej * by Jason R. Thorpe and Kevin M. Lahey of the Numerical Aerospace Simulation
38 1.34 thorpej * Facility, NASA Ames Research Center.
39 1.95 mycroft * This code is derived from software contributed to The NetBSD Foundation
40 1.95 mycroft * by Charles M. Hannum.
41 1.120 rpaulo * This code is derived from software contributed to The NetBSD Foundation
42 1.120 rpaulo * by Rui Paulo.
43 1.34 thorpej *
44 1.34 thorpej * Redistribution and use in source and binary forms, with or without
45 1.34 thorpej * modification, are permitted provided that the following conditions
46 1.34 thorpej * are met:
47 1.34 thorpej * 1. Redistributions of source code must retain the above copyright
48 1.34 thorpej * notice, this list of conditions and the following disclaimer.
49 1.34 thorpej * 2. Redistributions in binary form must reproduce the above copyright
50 1.34 thorpej * notice, this list of conditions and the following disclaimer in the
51 1.34 thorpej * documentation and/or other materials provided with the distribution.
52 1.34 thorpej *
53 1.34 thorpej * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
54 1.34 thorpej * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
55 1.34 thorpej * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
56 1.34 thorpej * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
57 1.34 thorpej * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
58 1.34 thorpej * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
59 1.34 thorpej * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
60 1.34 thorpej * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
61 1.34 thorpej * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
62 1.34 thorpej * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
63 1.34 thorpej * POSSIBILITY OF SUCH DAMAGE.
64 1.34 thorpej */
65 1.10 cgd
66 1.1 cgd /*
67 1.33 thorpej * Copyright (c) 1982, 1986, 1988, 1993, 1995
68 1.9 mycroft * The Regents of the University of California. All rights reserved.
69 1.1 cgd *
70 1.1 cgd * Redistribution and use in source and binary forms, with or without
71 1.1 cgd * modification, are permitted provided that the following conditions
72 1.1 cgd * are met:
73 1.1 cgd * 1. Redistributions of source code must retain the above copyright
74 1.1 cgd * notice, this list of conditions and the following disclaimer.
75 1.1 cgd * 2. Redistributions in binary form must reproduce the above copyright
76 1.1 cgd * notice, this list of conditions and the following disclaimer in the
77 1.1 cgd * documentation and/or other materials provided with the distribution.
78 1.82 agc * 3. Neither the name of the University nor the names of its contributors
79 1.1 cgd * may be used to endorse or promote products derived from this software
80 1.1 cgd * without specific prior written permission.
81 1.1 cgd *
82 1.1 cgd * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
83 1.1 cgd * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
84 1.1 cgd * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
85 1.1 cgd * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
86 1.1 cgd * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
87 1.1 cgd * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
88 1.1 cgd * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
89 1.1 cgd * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
90 1.1 cgd * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
91 1.1 cgd * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
92 1.1 cgd * SUCH DAMAGE.
93 1.1 cgd *
94 1.33 thorpej * @(#)tcp_usrreq.c 8.5 (Berkeley) 6/21/95
95 1.1 cgd */
96 1.67 lukem
97 1.173 rmind /*
98 1.173 rmind * TCP protocol interface to socket abstraction.
99 1.173 rmind */
100 1.173 rmind
101 1.67 lukem #include <sys/cdefs.h>
102 1.177 rmind __KERNEL_RCSID(0, "$NetBSD: tcp_usrreq.c,v 1.177 2014/05/22 00:28:32 rmind Exp $");
103 1.1 cgd
104 1.40 itojun #include "opt_inet.h"
105 1.42 thorpej #include "opt_ipsec.h"
106 1.63 abs #include "opt_tcp_debug.h"
107 1.77 martin #include "opt_mbuftrace.h"
108 1.162 tls
109 1.5 mycroft #include <sys/param.h>
110 1.5 mycroft #include <sys/systm.h>
111 1.13 glass #include <sys/kernel.h>
112 1.5 mycroft #include <sys/malloc.h>
113 1.5 mycroft #include <sys/mbuf.h>
114 1.5 mycroft #include <sys/socket.h>
115 1.5 mycroft #include <sys/socketvar.h>
116 1.5 mycroft #include <sys/protosw.h>
117 1.5 mycroft #include <sys/errno.h>
118 1.5 mycroft #include <sys/stat.h>
119 1.20 christos #include <sys/proc.h>
120 1.40 itojun #include <sys/domain.h>
121 1.20 christos #include <sys/sysctl.h>
122 1.117 elad #include <sys/kauth.h>
123 1.149 pooka #include <sys/uidinfo.h>
124 1.1 cgd
125 1.5 mycroft #include <net/if.h>
126 1.5 mycroft #include <net/route.h>
127 1.1 cgd
128 1.5 mycroft #include <netinet/in.h>
129 1.5 mycroft #include <netinet/in_systm.h>
130 1.14 cgd #include <netinet/in_var.h>
131 1.5 mycroft #include <netinet/ip.h>
132 1.5 mycroft #include <netinet/in_pcb.h>
133 1.5 mycroft #include <netinet/ip_var.h>
134 1.108 yamt #include <netinet/in_offload.h>
135 1.40 itojun
136 1.40 itojun #ifdef INET6
137 1.40 itojun #ifndef INET
138 1.40 itojun #include <netinet/in.h>
139 1.40 itojun #endif
140 1.40 itojun #include <netinet/ip6.h>
141 1.40 itojun #include <netinet6/in6_pcb.h>
142 1.40 itojun #include <netinet6/ip6_var.h>
143 1.135 christos #include <netinet6/scope6_var.h>
144 1.40 itojun #endif
145 1.40 itojun
146 1.5 mycroft #include <netinet/tcp.h>
147 1.5 mycroft #include <netinet/tcp_fsm.h>
148 1.5 mycroft #include <netinet/tcp_seq.h>
149 1.5 mycroft #include <netinet/tcp_timer.h>
150 1.5 mycroft #include <netinet/tcp_var.h>
151 1.142 thorpej #include <netinet/tcp_private.h>
152 1.124 rpaulo #include <netinet/tcp_congctl.h>
153 1.5 mycroft #include <netinet/tcpip.h>
154 1.5 mycroft #include <netinet/tcp_debug.h>
155 1.159 dyoung #include <netinet/tcp_vtw.h>
156 1.26 thorpej
157 1.68 lukem #include "opt_tcp_space.h"
158 1.1 cgd
159 1.1 cgd /*
160 1.1 cgd * Process a TCP user request for TCP tb. If this is a send request
161 1.1 cgd * then m is the mbuf chain of send data. If this is a timer expiration
162 1.1 cgd * (called from the software clock routine), then timertype tells which timer.
163 1.1 cgd */
164 1.172 rmind static int
165 1.172 rmind tcp_usrreq(struct socket *so, int req, struct mbuf *m, struct mbuf *nam,
166 1.172 rmind struct mbuf *control, struct lwp *l)
167 1.79 darrenr {
168 1.49 augustss struct inpcb *inp;
169 1.40 itojun #ifdef INET6
170 1.49 augustss struct in6pcb *in6p;
171 1.40 itojun #endif
172 1.49 augustss struct tcpcb *tp = NULL;
173 1.1 cgd int s;
174 1.1 cgd int error = 0;
175 1.74 simonb #ifdef TCP_DEBUG
176 1.74 simonb int ostate = 0;
177 1.74 simonb #endif
178 1.40 itojun int family; /* family of the socket */
179 1.40 itojun
180 1.173 rmind KASSERT(req != PRU_ATTACH);
181 1.173 rmind KASSERT(req != PRU_DETACH);
182 1.173 rmind
183 1.40 itojun family = so->so_proto->pr_domain->dom_family;
184 1.1 cgd
185 1.40 itojun if (req == PRU_CONTROL) {
186 1.40 itojun switch (family) {
187 1.56 itojun #ifdef INET
188 1.40 itojun case PF_INET:
189 1.131 christos return (in_control(so, (long)m, (void *)nam,
190 1.119 ad (struct ifnet *)control, l));
191 1.56 itojun #endif
192 1.40 itojun #ifdef INET6
193 1.40 itojun case PF_INET6:
194 1.131 christos return (in6_control(so, (long)m, (void *)nam,
195 1.119 ad (struct ifnet *)control, l));
196 1.40 itojun #endif
197 1.40 itojun default:
198 1.40 itojun return EAFNOSUPPORT;
199 1.40 itojun }
200 1.45 thorpej }
201 1.45 thorpej
202 1.123 tls s = splsoftnet();
203 1.123 tls
204 1.46 thorpej if (req == PRU_PURGEIF) {
205 1.144 ad mutex_enter(softnet_lock);
206 1.54 enami switch (family) {
207 1.56 itojun #ifdef INET
208 1.54 enami case PF_INET:
209 1.62 itojun in_pcbpurgeif0(&tcbtable, (struct ifnet *)control);
210 1.54 enami in_purgeif((struct ifnet *)control);
211 1.54 enami in_pcbpurgeif(&tcbtable, (struct ifnet *)control);
212 1.55 enami break;
213 1.56 itojun #endif
214 1.46 thorpej #ifdef INET6
215 1.54 enami case PF_INET6:
216 1.83 itojun in6_pcbpurgeif0(&tcbtable, (struct ifnet *)control);
217 1.54 enami in6_purgeif((struct ifnet *)control);
218 1.83 itojun in6_pcbpurgeif(&tcbtable, (struct ifnet *)control);
219 1.55 enami break;
220 1.46 thorpej #endif
221 1.54 enami default:
222 1.144 ad mutex_exit(softnet_lock);
223 1.123 tls splx(s);
224 1.54 enami return (EAFNOSUPPORT);
225 1.54 enami }
226 1.144 ad mutex_exit(softnet_lock);
227 1.123 tls splx(s);
228 1.45 thorpej return (0);
229 1.40 itojun }
230 1.22 mycroft
231 1.173 rmind KASSERT(solocked(so));
232 1.144 ad
233 1.40 itojun switch (family) {
234 1.56 itojun #ifdef INET
235 1.40 itojun case PF_INET:
236 1.40 itojun inp = sotoinpcb(so);
237 1.40 itojun #ifdef INET6
238 1.40 itojun in6p = NULL;
239 1.40 itojun #endif
240 1.40 itojun break;
241 1.56 itojun #endif
242 1.40 itojun #ifdef INET6
243 1.40 itojun case PF_INET6:
244 1.40 itojun inp = NULL;
245 1.40 itojun in6p = sotoin6pcb(so);
246 1.40 itojun break;
247 1.40 itojun #endif
248 1.40 itojun default:
249 1.40 itojun splx(s);
250 1.40 itojun return EAFNOSUPPORT;
251 1.40 itojun }
252 1.173 rmind KASSERT(!control || (req == PRU_SEND || req == PRU_SENDOOB));
253 1.177 rmind #ifdef INET6
254 1.177 rmind /* XXX: KASSERT((inp != NULL) ^ (in6p != NULL)); */
255 1.177 rmind #endif
256 1.1 cgd /*
257 1.1 cgd * When a TCP is attached to a socket, then there will be
258 1.1 cgd * a (struct inpcb) pointed at by the socket, and this
259 1.1 cgd * structure will point at a subsidary (struct tcpcb).
260 1.1 cgd */
261 1.173 rmind if ((inp == NULL
262 1.163 christos #ifdef INET6
263 1.173 rmind && in6p == NULL
264 1.40 itojun #endif
265 1.173 rmind ) && req != PRU_SENSE)
266 1.40 itojun {
267 1.22 mycroft error = EINVAL;
268 1.22 mycroft goto release;
269 1.1 cgd }
270 1.56 itojun #ifdef INET
271 1.1 cgd if (inp) {
272 1.1 cgd tp = intotcpcb(inp);
273 1.1 cgd /* WHAT IF TP IS 0? */
274 1.1 cgd #ifdef KPROF
275 1.1 cgd tcp_acounts[tp->t_state][req]++;
276 1.1 cgd #endif
277 1.74 simonb #ifdef TCP_DEBUG
278 1.1 cgd ostate = tp->t_state;
279 1.74 simonb #endif
280 1.40 itojun }
281 1.56 itojun #endif
282 1.40 itojun #ifdef INET6
283 1.56 itojun if (in6p) {
284 1.40 itojun tp = in6totcpcb(in6p);
285 1.40 itojun /* WHAT IF TP IS 0? */
286 1.40 itojun #ifdef KPROF
287 1.40 itojun tcp_acounts[tp->t_state][req]++;
288 1.40 itojun #endif
289 1.74 simonb #ifdef TCP_DEBUG
290 1.40 itojun ostate = tp->t_state;
291 1.74 simonb #endif
292 1.40 itojun }
293 1.40 itojun #endif
294 1.22 mycroft
295 1.1 cgd switch (req) {
296 1.1 cgd
297 1.1 cgd /*
298 1.1 cgd * Give the socket an address.
299 1.1 cgd */
300 1.1 cgd case PRU_BIND:
301 1.40 itojun switch (family) {
302 1.56 itojun #ifdef INET
303 1.40 itojun case PF_INET:
304 1.119 ad error = in_pcbbind(inp, nam, l);
305 1.40 itojun break;
306 1.56 itojun #endif
307 1.40 itojun #ifdef INET6
308 1.40 itojun case PF_INET6:
309 1.119 ad error = in6_pcbbind(in6p, nam, l);
310 1.58 itojun if (!error) {
311 1.58 itojun /* mapped addr case */
312 1.58 itojun if (IN6_IS_ADDR_V4MAPPED(&in6p->in6p_laddr))
313 1.58 itojun tp->t_family = AF_INET;
314 1.58 itojun else
315 1.58 itojun tp->t_family = AF_INET6;
316 1.58 itojun }
317 1.40 itojun break;
318 1.40 itojun #endif
319 1.40 itojun }
320 1.1 cgd break;
321 1.1 cgd
322 1.1 cgd /*
323 1.1 cgd * Prepare to accept connections.
324 1.1 cgd */
325 1.1 cgd case PRU_LISTEN:
326 1.56 itojun #ifdef INET
327 1.40 itojun if (inp && inp->inp_lport == 0) {
328 1.150 dyoung error = in_pcbbind(inp, NULL, l);
329 1.22 mycroft if (error)
330 1.22 mycroft break;
331 1.22 mycroft }
332 1.56 itojun #endif
333 1.40 itojun #ifdef INET6
334 1.56 itojun if (in6p && in6p->in6p_lport == 0) {
335 1.154 elad error = in6_pcbbind(in6p, NULL, l);
336 1.40 itojun if (error)
337 1.40 itojun break;
338 1.40 itojun }
339 1.40 itojun #endif
340 1.22 mycroft tp->t_state = TCPS_LISTEN;
341 1.1 cgd break;
342 1.1 cgd
343 1.1 cgd /*
344 1.1 cgd * Initiate connection to peer.
345 1.1 cgd * Create a template for use in transmissions on this connection.
346 1.1 cgd * Enter SYN_SENT state, and mark socket as connecting.
347 1.1 cgd * Start keep-alive timer, and seed output sequence space.
348 1.1 cgd * Send initial segment on connection.
349 1.1 cgd */
350 1.1 cgd case PRU_CONNECT:
351 1.56 itojun #ifdef INET
352 1.40 itojun if (inp) {
353 1.40 itojun if (inp->inp_lport == 0) {
354 1.150 dyoung error = in_pcbbind(inp, NULL, l);
355 1.40 itojun if (error)
356 1.40 itojun break;
357 1.40 itojun }
358 1.119 ad error = in_pcbconnect(inp, nam, l);
359 1.40 itojun }
360 1.56 itojun #endif
361 1.40 itojun #ifdef INET6
362 1.56 itojun if (in6p) {
363 1.40 itojun if (in6p->in6p_lport == 0) {
364 1.154 elad error = in6_pcbbind(in6p, NULL, l);
365 1.40 itojun if (error)
366 1.40 itojun break;
367 1.40 itojun }
368 1.119 ad error = in6_pcbconnect(in6p, nam, l);
369 1.58 itojun if (!error) {
370 1.58 itojun /* mapped addr case */
371 1.58 itojun if (IN6_IS_ADDR_V4MAPPED(&in6p->in6p_faddr))
372 1.58 itojun tp->t_family = AF_INET;
373 1.58 itojun else
374 1.58 itojun tp->t_family = AF_INET6;
375 1.58 itojun }
376 1.1 cgd }
377 1.40 itojun #endif
378 1.1 cgd if (error)
379 1.1 cgd break;
380 1.1 cgd tp->t_template = tcp_template(tp);
381 1.1 cgd if (tp->t_template == 0) {
382 1.56 itojun #ifdef INET
383 1.40 itojun if (inp)
384 1.40 itojun in_pcbdisconnect(inp);
385 1.56 itojun #endif
386 1.40 itojun #ifdef INET6
387 1.56 itojun if (in6p)
388 1.40 itojun in6_pcbdisconnect(in6p);
389 1.40 itojun #endif
390 1.1 cgd error = ENOBUFS;
391 1.1 cgd break;
392 1.1 cgd }
393 1.136 rmind /*
394 1.138 rmind * Compute window scaling to request.
395 1.138 rmind * XXX: This should be moved to tcp_output().
396 1.136 rmind */
397 1.9 mycroft while (tp->request_r_scale < TCP_MAX_WINSHIFT &&
398 1.138 rmind (TCP_MAXWIN << tp->request_r_scale) < sb_max)
399 1.9 mycroft tp->request_r_scale++;
400 1.1 cgd soisconnecting(so);
401 1.142 thorpej TCP_STATINC(TCP_STAT_CONNATTEMPT);
402 1.1 cgd tp->t_state = TCPS_SYN_SENT;
403 1.132 christos TCP_TIMER_ARM(tp, TCPT_KEEP, tp->t_keepinit);
404 1.61 thorpej tp->iss = tcp_new_iss(tp, 0);
405 1.1 cgd tcp_sendseqinit(tp);
406 1.1 cgd error = tcp_output(tp);
407 1.1 cgd break;
408 1.1 cgd
409 1.1 cgd /*
410 1.1 cgd * Create a TCP connection between two sockets.
411 1.1 cgd */
412 1.1 cgd case PRU_CONNECT2:
413 1.1 cgd error = EOPNOTSUPP;
414 1.1 cgd break;
415 1.1 cgd
416 1.1 cgd /*
417 1.1 cgd * Initiate disconnect from peer.
418 1.1 cgd * If connection never passed embryonic stage, just drop;
419 1.1 cgd * else if don't need to let data drain, then can just drop anyways,
420 1.1 cgd * else have to begin TCP shutdown process: mark socket disconnecting,
421 1.1 cgd * drain unread data, state switch to reflect user close, and
422 1.1 cgd * send segment (e.g. FIN) to peer. Socket will be really disconnected
423 1.1 cgd * when peer sends FIN and acks ours.
424 1.1 cgd *
425 1.1 cgd * SHOULD IMPLEMENT LATER PRU_CONNECT VIA REALLOC TCPCB.
426 1.1 cgd */
427 1.1 cgd case PRU_DISCONNECT:
428 1.1 cgd tp = tcp_disconnect(tp);
429 1.1 cgd break;
430 1.1 cgd
431 1.1 cgd /*
432 1.1 cgd * Accept a connection. Essentially all the work is
433 1.1 cgd * done at higher levels; just return the address
434 1.1 cgd * of the peer, storing through addr.
435 1.1 cgd */
436 1.8 mycroft case PRU_ACCEPT:
437 1.56 itojun #ifdef INET
438 1.40 itojun if (inp)
439 1.40 itojun in_setpeeraddr(inp, nam);
440 1.56 itojun #endif
441 1.40 itojun #ifdef INET6
442 1.56 itojun if (in6p)
443 1.40 itojun in6_setpeeraddr(in6p, nam);
444 1.40 itojun #endif
445 1.1 cgd break;
446 1.1 cgd
447 1.1 cgd /*
448 1.1 cgd * Mark the connection as being incapable of further output.
449 1.1 cgd */
450 1.1 cgd case PRU_SHUTDOWN:
451 1.1 cgd socantsendmore(so);
452 1.1 cgd tp = tcp_usrclosed(tp);
453 1.1 cgd if (tp)
454 1.1 cgd error = tcp_output(tp);
455 1.1 cgd break;
456 1.1 cgd
457 1.1 cgd /*
458 1.1 cgd * After a receive, possibly send window update to peer.
459 1.1 cgd */
460 1.1 cgd case PRU_RCVD:
461 1.60 itojun /*
462 1.60 itojun * soreceive() calls this function when a user receives
463 1.60 itojun * ancillary data on a listening socket. We don't call
464 1.60 itojun * tcp_output in such a case, since there is no header
465 1.60 itojun * template for a listening socket and hence the kernel
466 1.60 itojun * will panic.
467 1.60 itojun */
468 1.60 itojun if ((so->so_state & (SS_ISCONNECTED|SS_ISCONNECTING)) != 0)
469 1.60 itojun (void) tcp_output(tp);
470 1.1 cgd break;
471 1.1 cgd
472 1.1 cgd /*
473 1.1 cgd * Do a send by putting data in output queue and updating urgent
474 1.1 cgd * marker if URG set. Possibly send more data.
475 1.1 cgd */
476 1.1 cgd case PRU_SEND:
477 1.23 mycroft if (control && control->m_len) {
478 1.23 mycroft m_freem(control);
479 1.23 mycroft m_freem(m);
480 1.23 mycroft error = EINVAL;
481 1.23 mycroft break;
482 1.23 mycroft }
483 1.73 thorpej sbappendstream(&so->so_snd, m);
484 1.1 cgd error = tcp_output(tp);
485 1.1 cgd break;
486 1.1 cgd
487 1.1 cgd /*
488 1.1 cgd * Abort the TCP.
489 1.1 cgd */
490 1.1 cgd case PRU_ABORT:
491 1.1 cgd tp = tcp_drop(tp, ECONNABORTED);
492 1.1 cgd break;
493 1.1 cgd
494 1.1 cgd case PRU_SENSE:
495 1.22 mycroft /*
496 1.22 mycroft * stat: don't bother with a blocksize.
497 1.22 mycroft */
498 1.22 mycroft splx(s);
499 1.1 cgd return (0);
500 1.1 cgd
501 1.1 cgd case PRU_RCVOOB:
502 1.23 mycroft if (control && control->m_len) {
503 1.23 mycroft m_freem(control);
504 1.23 mycroft m_freem(m);
505 1.23 mycroft error = EINVAL;
506 1.23 mycroft break;
507 1.23 mycroft }
508 1.1 cgd if ((so->so_oobmark == 0 &&
509 1.1 cgd (so->so_state & SS_RCVATMARK) == 0) ||
510 1.1 cgd so->so_options & SO_OOBINLINE ||
511 1.1 cgd tp->t_oobflags & TCPOOB_HADDATA) {
512 1.1 cgd error = EINVAL;
513 1.1 cgd break;
514 1.1 cgd }
515 1.1 cgd if ((tp->t_oobflags & TCPOOB_HAVEDATA) == 0) {
516 1.1 cgd error = EWOULDBLOCK;
517 1.1 cgd break;
518 1.1 cgd }
519 1.1 cgd m->m_len = 1;
520 1.131 christos *mtod(m, char *) = tp->t_iobc;
521 1.14 cgd if (((long)nam & MSG_PEEK) == 0)
522 1.1 cgd tp->t_oobflags ^= (TCPOOB_HAVEDATA | TCPOOB_HADDATA);
523 1.1 cgd break;
524 1.1 cgd
525 1.1 cgd case PRU_SENDOOB:
526 1.1 cgd if (sbspace(&so->so_snd) < -512) {
527 1.1 cgd m_freem(m);
528 1.1 cgd error = ENOBUFS;
529 1.1 cgd break;
530 1.1 cgd }
531 1.1 cgd /*
532 1.1 cgd * According to RFC961 (Assigned Protocols),
533 1.1 cgd * the urgent pointer points to the last octet
534 1.1 cgd * of urgent data. We continue, however,
535 1.1 cgd * to consider it to indicate the first octet
536 1.1 cgd * of data past the urgent section.
537 1.1 cgd * Otherwise, snd_up should be one lower.
538 1.1 cgd */
539 1.73 thorpej sbappendstream(&so->so_snd, m);
540 1.1 cgd tp->snd_up = tp->snd_una + so->so_snd.sb_cc;
541 1.1 cgd tp->t_force = 1;
542 1.1 cgd error = tcp_output(tp);
543 1.1 cgd tp->t_force = 0;
544 1.1 cgd break;
545 1.1 cgd
546 1.1 cgd case PRU_SOCKADDR:
547 1.56 itojun #ifdef INET
548 1.40 itojun if (inp)
549 1.40 itojun in_setsockaddr(inp, nam);
550 1.56 itojun #endif
551 1.40 itojun #ifdef INET6
552 1.56 itojun if (in6p)
553 1.40 itojun in6_setsockaddr(in6p, nam);
554 1.40 itojun #endif
555 1.1 cgd break;
556 1.1 cgd
557 1.1 cgd case PRU_PEERADDR:
558 1.56 itojun #ifdef INET
559 1.40 itojun if (inp)
560 1.40 itojun in_setpeeraddr(inp, nam);
561 1.56 itojun #endif
562 1.40 itojun #ifdef INET6
563 1.56 itojun if (in6p)
564 1.40 itojun in6_setpeeraddr(in6p, nam);
565 1.40 itojun #endif
566 1.1 cgd break;
567 1.1 cgd
568 1.1 cgd default:
569 1.1 cgd panic("tcp_usrreq");
570 1.1 cgd }
571 1.63 abs #ifdef TCP_DEBUG
572 1.1 cgd if (tp && (so->so_options & SO_DEBUG))
573 1.40 itojun tcp_trace(TA_USER, ostate, tp, NULL, req);
574 1.63 abs #endif
575 1.22 mycroft
576 1.22 mycroft release:
577 1.1 cgd splx(s);
578 1.1 cgd return (error);
579 1.1 cgd }
580 1.1 cgd
581 1.132 christos static void
582 1.132 christos change_keepalive(struct socket *so, struct tcpcb *tp)
583 1.132 christos {
584 1.132 christos tp->t_maxidle = tp->t_keepcnt * tp->t_keepintvl;
585 1.132 christos TCP_TIMER_DISARM(tp, TCPT_KEEP);
586 1.132 christos TCP_TIMER_DISARM(tp, TCPT_2MSL);
587 1.132 christos
588 1.132 christos if (tp->t_state == TCPS_SYN_RECEIVED ||
589 1.132 christos tp->t_state == TCPS_SYN_SENT) {
590 1.132 christos TCP_TIMER_ARM(tp, TCPT_KEEP, tp->t_keepinit);
591 1.132 christos } else if (so->so_options & SO_KEEPALIVE &&
592 1.132 christos tp->t_state <= TCPS_CLOSE_WAIT) {
593 1.132 christos TCP_TIMER_ARM(tp, TCPT_KEEP, tp->t_keepintvl);
594 1.132 christos } else {
595 1.132 christos TCP_TIMER_ARM(tp, TCPT_KEEP, tp->t_keepidle);
596 1.132 christos }
597 1.132 christos
598 1.132 christos if ((tp->t_state == TCPS_FIN_WAIT_2) && (tp->t_maxidle > 0))
599 1.132 christos TCP_TIMER_ARM(tp, TCPT_2MSL, tp->t_maxidle);
600 1.132 christos }
601 1.132 christos
602 1.132 christos
603 1.6 mycroft int
604 1.147 plunky tcp_ctloutput(int op, struct socket *so, struct sockopt *sopt)
605 1.1 cgd {
606 1.9 mycroft int error = 0, s;
607 1.9 mycroft struct inpcb *inp;
608 1.40 itojun #ifdef INET6
609 1.49 augustss struct in6pcb *in6p;
610 1.40 itojun #endif
611 1.49 augustss struct tcpcb *tp;
612 1.132 christos u_int ui;
613 1.40 itojun int family; /* family of the socket */
614 1.147 plunky int level, optname, optval;
615 1.147 plunky
616 1.147 plunky level = sopt->sopt_level;
617 1.147 plunky optname = sopt->sopt_name;
618 1.40 itojun
619 1.40 itojun family = so->so_proto->pr_domain->dom_family;
620 1.1 cgd
621 1.16 mycroft s = splsoftnet();
622 1.40 itojun switch (family) {
623 1.56 itojun #ifdef INET
624 1.40 itojun case PF_INET:
625 1.40 itojun inp = sotoinpcb(so);
626 1.40 itojun #ifdef INET6
627 1.40 itojun in6p = NULL;
628 1.40 itojun #endif
629 1.40 itojun break;
630 1.56 itojun #endif
631 1.40 itojun #ifdef INET6
632 1.40 itojun case PF_INET6:
633 1.40 itojun inp = NULL;
634 1.40 itojun in6p = sotoin6pcb(so);
635 1.40 itojun break;
636 1.40 itojun #endif
637 1.40 itojun default:
638 1.40 itojun splx(s);
639 1.129 yamt panic("%s: af %d", __func__, family);
640 1.40 itojun }
641 1.40 itojun #ifndef INET6
642 1.40 itojun if (inp == NULL)
643 1.40 itojun #else
644 1.40 itojun if (inp == NULL && in6p == NULL)
645 1.40 itojun #endif
646 1.40 itojun {
647 1.9 mycroft splx(s);
648 1.9 mycroft return (ECONNRESET);
649 1.9 mycroft }
650 1.9 mycroft if (level != IPPROTO_TCP) {
651 1.40 itojun switch (family) {
652 1.56 itojun #ifdef INET
653 1.40 itojun case PF_INET:
654 1.147 plunky error = ip_ctloutput(op, so, sopt);
655 1.40 itojun break;
656 1.56 itojun #endif
657 1.40 itojun #ifdef INET6
658 1.40 itojun case PF_INET6:
659 1.147 plunky error = ip6_ctloutput(op, so, sopt);
660 1.40 itojun break;
661 1.40 itojun #endif
662 1.40 itojun }
663 1.9 mycroft splx(s);
664 1.9 mycroft return (error);
665 1.9 mycroft }
666 1.40 itojun if (inp)
667 1.40 itojun tp = intotcpcb(inp);
668 1.40 itojun #ifdef INET6
669 1.40 itojun else if (in6p)
670 1.40 itojun tp = in6totcpcb(in6p);
671 1.40 itojun #endif
672 1.40 itojun else
673 1.40 itojun tp = NULL;
674 1.1 cgd
675 1.1 cgd switch (op) {
676 1.1 cgd case PRCO_SETOPT:
677 1.1 cgd switch (optname) {
678 1.90 jonathan #ifdef TCP_SIGNATURE
679 1.90 jonathan case TCP_MD5SIG:
680 1.147 plunky error = sockopt_getint(sopt, &optval);
681 1.90 jonathan if (error)
682 1.90 jonathan break;
683 1.147 plunky if (optval > 0)
684 1.90 jonathan tp->t_flags |= TF_SIGNATURE;
685 1.91 itojun else
686 1.90 jonathan tp->t_flags &= ~TF_SIGNATURE;
687 1.90 jonathan break;
688 1.90 jonathan #endif /* TCP_SIGNATURE */
689 1.90 jonathan
690 1.1 cgd case TCP_NODELAY:
691 1.147 plunky error = sockopt_getint(sopt, &optval);
692 1.147 plunky if (error)
693 1.147 plunky break;
694 1.147 plunky if (optval)
695 1.1 cgd tp->t_flags |= TF_NODELAY;
696 1.1 cgd else
697 1.1 cgd tp->t_flags &= ~TF_NODELAY;
698 1.1 cgd break;
699 1.1 cgd
700 1.9 mycroft case TCP_MAXSEG:
701 1.147 plunky error = sockopt_getint(sopt, &optval);
702 1.147 plunky if (error)
703 1.147 plunky break;
704 1.147 plunky if (optval > 0 && optval <= tp->t_peermss)
705 1.147 plunky tp->t_peermss = optval; /* limit on send size */
706 1.9 mycroft else
707 1.9 mycroft error = EINVAL;
708 1.9 mycroft break;
709 1.124 rpaulo #ifdef notyet
710 1.124 rpaulo case TCP_CONGCTL:
711 1.147 plunky /* XXX string overflow XXX */
712 1.147 plunky error = tcp_congctl_select(tp, sopt->sopt_data);
713 1.147 plunky break;
714 1.124 rpaulo #endif
715 1.9 mycroft
716 1.132 christos case TCP_KEEPIDLE:
717 1.147 plunky error = sockopt_get(sopt, &ui, sizeof(ui));
718 1.147 plunky if (error)
719 1.147 plunky break;
720 1.147 plunky if (ui > 0) {
721 1.132 christos tp->t_keepidle = ui;
722 1.132 christos change_keepalive(so, tp);
723 1.132 christos } else
724 1.132 christos error = EINVAL;
725 1.132 christos break;
726 1.132 christos
727 1.132 christos case TCP_KEEPINTVL:
728 1.147 plunky error = sockopt_get(sopt, &ui, sizeof(ui));
729 1.147 plunky if (error)
730 1.147 plunky break;
731 1.147 plunky if (ui > 0) {
732 1.132 christos tp->t_keepintvl = ui;
733 1.132 christos change_keepalive(so, tp);
734 1.132 christos } else
735 1.132 christos error = EINVAL;
736 1.132 christos break;
737 1.132 christos
738 1.132 christos case TCP_KEEPCNT:
739 1.147 plunky error = sockopt_get(sopt, &ui, sizeof(ui));
740 1.147 plunky if (error)
741 1.147 plunky break;
742 1.147 plunky if (ui > 0) {
743 1.132 christos tp->t_keepcnt = ui;
744 1.132 christos change_keepalive(so, tp);
745 1.132 christos } else
746 1.132 christos error = EINVAL;
747 1.132 christos break;
748 1.132 christos
749 1.132 christos case TCP_KEEPINIT:
750 1.147 plunky error = sockopt_get(sopt, &ui, sizeof(ui));
751 1.147 plunky if (error)
752 1.147 plunky break;
753 1.147 plunky if (ui > 0) {
754 1.132 christos tp->t_keepinit = ui;
755 1.132 christos change_keepalive(so, tp);
756 1.132 christos } else
757 1.132 christos error = EINVAL;
758 1.132 christos break;
759 1.132 christos
760 1.1 cgd default:
761 1.9 mycroft error = ENOPROTOOPT;
762 1.1 cgd break;
763 1.1 cgd }
764 1.1 cgd break;
765 1.1 cgd
766 1.1 cgd case PRCO_GETOPT:
767 1.1 cgd switch (optname) {
768 1.90 jonathan #ifdef TCP_SIGNATURE
769 1.90 jonathan case TCP_MD5SIG:
770 1.147 plunky optval = (tp->t_flags & TF_SIGNATURE) ? 1 : 0;
771 1.147 plunky error = sockopt_set(sopt, &optval, sizeof(optval));
772 1.90 jonathan break;
773 1.90 jonathan #endif
774 1.1 cgd case TCP_NODELAY:
775 1.147 plunky optval = tp->t_flags & TF_NODELAY;
776 1.147 plunky error = sockopt_set(sopt, &optval, sizeof(optval));
777 1.1 cgd break;
778 1.1 cgd case TCP_MAXSEG:
779 1.147 plunky optval = tp->t_peermss;
780 1.147 plunky error = sockopt_set(sopt, &optval, sizeof(optval));
781 1.1 cgd break;
782 1.124 rpaulo #ifdef notyet
783 1.124 rpaulo case TCP_CONGCTL:
784 1.124 rpaulo break;
785 1.124 rpaulo #endif
786 1.1 cgd default:
787 1.9 mycroft error = ENOPROTOOPT;
788 1.1 cgd break;
789 1.1 cgd }
790 1.1 cgd break;
791 1.1 cgd }
792 1.9 mycroft splx(s);
793 1.1 cgd return (error);
794 1.1 cgd }
795 1.1 cgd
796 1.11 mycroft #ifndef TCP_SENDSPACE
797 1.84 tls #define TCP_SENDSPACE 1024*32
798 1.11 mycroft #endif
799 1.25 thorpej int tcp_sendspace = TCP_SENDSPACE;
800 1.11 mycroft #ifndef TCP_RECVSPACE
801 1.84 tls #define TCP_RECVSPACE 1024*32
802 1.11 mycroft #endif
803 1.25 thorpej int tcp_recvspace = TCP_RECVSPACE;
804 1.1 cgd
805 1.1 cgd /*
806 1.173 rmind * tcp_attach: attach TCP protocol to socket, allocating internet protocol
807 1.173 rmind * control block, TCP control block, buffer space and entering LISTEN state
808 1.173 rmind * if to accept connections.
809 1.1 cgd */
810 1.173 rmind static int
811 1.173 rmind tcp_attach(struct socket *so, int proto)
812 1.1 cgd {
813 1.49 augustss struct tcpcb *tp;
814 1.1 cgd struct inpcb *inp;
815 1.40 itojun #ifdef INET6
816 1.40 itojun struct in6pcb *in6p;
817 1.40 itojun #endif
818 1.173 rmind int s, error, family;
819 1.173 rmind
820 1.173 rmind /* Assign the lock (must happen even if we will error out). */
821 1.173 rmind s = splsoftnet();
822 1.173 rmind sosetlock(so);
823 1.173 rmind KASSERT(solocked(so));
824 1.40 itojun
825 1.40 itojun family = so->so_proto->pr_domain->dom_family;
826 1.173 rmind switch (family) {
827 1.173 rmind #ifdef INET
828 1.173 rmind case PF_INET:
829 1.173 rmind inp = sotoinpcb(so);
830 1.173 rmind #ifdef INET6
831 1.173 rmind in6p = NULL;
832 1.173 rmind #endif
833 1.173 rmind break;
834 1.173 rmind #endif
835 1.173 rmind #ifdef INET6
836 1.173 rmind case PF_INET6:
837 1.173 rmind inp = NULL;
838 1.173 rmind in6p = sotoin6pcb(so);
839 1.173 rmind break;
840 1.173 rmind #endif
841 1.173 rmind default:
842 1.173 rmind error = EAFNOSUPPORT;
843 1.173 rmind goto out;
844 1.173 rmind }
845 1.173 rmind
846 1.173 rmind KASSERT(inp == NULL);
847 1.173 rmind #ifdef INET6
848 1.173 rmind KASSERT(in6p == NULL);
849 1.173 rmind #endif
850 1.1 cgd
851 1.75 matt #ifdef MBUFTRACE
852 1.130 yamt so->so_mowner = &tcp_sock_mowner;
853 1.130 yamt so->so_rcv.sb_mowner = &tcp_sock_rx_mowner;
854 1.130 yamt so->so_snd.sb_mowner = &tcp_sock_tx_mowner;
855 1.75 matt #endif
856 1.1 cgd if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) {
857 1.1 cgd error = soreserve(so, tcp_sendspace, tcp_recvspace);
858 1.1 cgd if (error)
859 1.173 rmind goto out;
860 1.1 cgd }
861 1.136 rmind
862 1.136 rmind so->so_rcv.sb_flags |= SB_AUTOSIZE;
863 1.136 rmind so->so_snd.sb_flags |= SB_AUTOSIZE;
864 1.136 rmind
865 1.40 itojun switch (family) {
866 1.56 itojun #ifdef INET
867 1.40 itojun case PF_INET:
868 1.40 itojun error = in_pcballoc(so, &tcbtable);
869 1.40 itojun if (error)
870 1.173 rmind goto out;
871 1.40 itojun inp = sotoinpcb(so);
872 1.40 itojun #ifdef INET6
873 1.40 itojun in6p = NULL;
874 1.40 itojun #endif
875 1.40 itojun break;
876 1.56 itojun #endif
877 1.40 itojun #ifdef INET6
878 1.40 itojun case PF_INET6:
879 1.83 itojun error = in6_pcballoc(so, &tcbtable);
880 1.40 itojun if (error)
881 1.173 rmind goto out;
882 1.40 itojun inp = NULL;
883 1.40 itojun in6p = sotoin6pcb(so);
884 1.40 itojun break;
885 1.40 itojun #endif
886 1.40 itojun default:
887 1.173 rmind error = EAFNOSUPPORT;
888 1.173 rmind goto out;
889 1.40 itojun }
890 1.40 itojun if (inp)
891 1.40 itojun tp = tcp_newtcpcb(family, (void *)inp);
892 1.40 itojun #ifdef INET6
893 1.40 itojun else if (in6p)
894 1.40 itojun tp = tcp_newtcpcb(family, (void *)in6p);
895 1.40 itojun #endif
896 1.41 itojun else
897 1.41 itojun tp = NULL;
898 1.40 itojun
899 1.173 rmind if (tp == NULL) {
900 1.1 cgd int nofd = so->so_state & SS_NOFDREF; /* XXX */
901 1.1 cgd
902 1.1 cgd so->so_state &= ~SS_NOFDREF; /* don't free the socket yet */
903 1.56 itojun #ifdef INET
904 1.40 itojun if (inp)
905 1.40 itojun in_pcbdetach(inp);
906 1.56 itojun #endif
907 1.40 itojun #ifdef INET6
908 1.56 itojun if (in6p)
909 1.40 itojun in6_pcbdetach(in6p);
910 1.40 itojun #endif
911 1.1 cgd so->so_state |= nofd;
912 1.173 rmind error = ENOBUFS;
913 1.173 rmind goto out;
914 1.1 cgd }
915 1.1 cgd tp->t_state = TCPS_CLOSED;
916 1.173 rmind if ((so->so_options & SO_LINGER) && so->so_linger == 0) {
917 1.173 rmind so->so_linger = TCP_LINGERTIME;
918 1.173 rmind }
919 1.173 rmind out:
920 1.173 rmind KASSERT(solocked(so));
921 1.173 rmind splx(s);
922 1.173 rmind return error;
923 1.173 rmind }
924 1.173 rmind
925 1.173 rmind static void
926 1.173 rmind tcp_detach(struct socket *so)
927 1.173 rmind {
928 1.173 rmind struct inpcb *inp;
929 1.173 rmind #ifdef INET6
930 1.173 rmind struct in6pcb *in6p;
931 1.173 rmind #endif
932 1.173 rmind struct tcpcb *tp = NULL;
933 1.173 rmind int s, family;
934 1.173 rmind
935 1.173 rmind KASSERT(solocked(so));
936 1.173 rmind
937 1.173 rmind s = splsoftnet();
938 1.173 rmind family = so->so_proto->pr_domain->dom_family;
939 1.173 rmind switch (family) {
940 1.173 rmind #ifdef INET
941 1.173 rmind case PF_INET:
942 1.173 rmind inp = sotoinpcb(so);
943 1.173 rmind tp = intotcpcb(inp);
944 1.173 rmind break;
945 1.173 rmind #endif
946 1.173 rmind #ifdef INET6
947 1.173 rmind case PF_INET6:
948 1.173 rmind in6p = sotoin6pcb(so);
949 1.173 rmind tp = in6totcpcb(in6p);
950 1.173 rmind break;
951 1.173 rmind #endif
952 1.173 rmind default:
953 1.173 rmind splx(s);
954 1.173 rmind return;
955 1.173 rmind }
956 1.173 rmind KASSERT(tp != NULL);
957 1.173 rmind (void)tcp_disconnect(tp);
958 1.173 rmind splx(s);
959 1.1 cgd }
960 1.1 cgd
961 1.1 cgd /*
962 1.1 cgd * Initiate (or continue) disconnect.
963 1.1 cgd * If embryonic state, just send reset (once).
964 1.1 cgd * If in ``let data drain'' option and linger null, just drop.
965 1.1 cgd * Otherwise (hard), mark socket disconnecting and drop
966 1.1 cgd * current input data; switch states based on user close, and
967 1.1 cgd * send segment to peer (with FIN).
968 1.1 cgd */
969 1.1 cgd struct tcpcb *
970 1.94 perry tcp_disconnect(struct tcpcb *tp)
971 1.1 cgd {
972 1.40 itojun struct socket *so;
973 1.40 itojun
974 1.40 itojun if (tp->t_inpcb)
975 1.40 itojun so = tp->t_inpcb->inp_socket;
976 1.40 itojun #ifdef INET6
977 1.40 itojun else if (tp->t_in6pcb)
978 1.40 itojun so = tp->t_in6pcb->in6p_socket;
979 1.40 itojun #endif
980 1.40 itojun else
981 1.40 itojun so = NULL;
982 1.1 cgd
983 1.12 mycroft if (TCPS_HAVEESTABLISHED(tp->t_state) == 0)
984 1.1 cgd tp = tcp_close(tp);
985 1.1 cgd else if ((so->so_options & SO_LINGER) && so->so_linger == 0)
986 1.1 cgd tp = tcp_drop(tp, 0);
987 1.1 cgd else {
988 1.1 cgd soisdisconnecting(so);
989 1.1 cgd sbflush(&so->so_rcv);
990 1.1 cgd tp = tcp_usrclosed(tp);
991 1.1 cgd if (tp)
992 1.1 cgd (void) tcp_output(tp);
993 1.1 cgd }
994 1.1 cgd return (tp);
995 1.1 cgd }
996 1.1 cgd
997 1.1 cgd /*
998 1.1 cgd * User issued close, and wish to trail through shutdown states:
999 1.1 cgd * if never received SYN, just forget it. If got a SYN from peer,
1000 1.1 cgd * but haven't sent FIN, then go to FIN_WAIT_1 state to send peer a FIN.
1001 1.1 cgd * If already got a FIN from peer, then almost done; go to LAST_ACK
1002 1.1 cgd * state. In all other cases, have already sent FIN to peer (e.g.
1003 1.1 cgd * after PRU_SHUTDOWN), and just have to play tedious game waiting
1004 1.1 cgd * for peer to send FIN or not respond to keep-alives, etc.
1005 1.1 cgd * We can let the user exit from the close as soon as the FIN is acked.
1006 1.1 cgd */
1007 1.1 cgd struct tcpcb *
1008 1.94 perry tcp_usrclosed(struct tcpcb *tp)
1009 1.1 cgd {
1010 1.1 cgd
1011 1.1 cgd switch (tp->t_state) {
1012 1.1 cgd
1013 1.1 cgd case TCPS_CLOSED:
1014 1.1 cgd case TCPS_LISTEN:
1015 1.1 cgd case TCPS_SYN_SENT:
1016 1.1 cgd tp->t_state = TCPS_CLOSED;
1017 1.1 cgd tp = tcp_close(tp);
1018 1.1 cgd break;
1019 1.1 cgd
1020 1.1 cgd case TCPS_SYN_RECEIVED:
1021 1.1 cgd case TCPS_ESTABLISHED:
1022 1.1 cgd tp->t_state = TCPS_FIN_WAIT_1;
1023 1.1 cgd break;
1024 1.1 cgd
1025 1.1 cgd case TCPS_CLOSE_WAIT:
1026 1.1 cgd tp->t_state = TCPS_LAST_ACK;
1027 1.1 cgd break;
1028 1.1 cgd }
1029 1.18 mycroft if (tp && tp->t_state >= TCPS_FIN_WAIT_2) {
1030 1.40 itojun struct socket *so;
1031 1.40 itojun if (tp->t_inpcb)
1032 1.40 itojun so = tp->t_inpcb->inp_socket;
1033 1.40 itojun #ifdef INET6
1034 1.40 itojun else if (tp->t_in6pcb)
1035 1.40 itojun so = tp->t_in6pcb->in6p_socket;
1036 1.40 itojun #endif
1037 1.40 itojun else
1038 1.40 itojun so = NULL;
1039 1.115 christos if (so)
1040 1.115 christos soisdisconnected(so);
1041 1.19 mycroft /*
1042 1.19 mycroft * If we are in FIN_WAIT_2, we arrived here because the
1043 1.19 mycroft * application did a shutdown of the send side. Like the
1044 1.19 mycroft * case of a transition from FIN_WAIT_1 to FIN_WAIT_2 after
1045 1.19 mycroft * a full close, we start a timer to make sure sockets are
1046 1.19 mycroft * not left in FIN_WAIT_2 forever.
1047 1.19 mycroft */
1048 1.132 christos if ((tp->t_state == TCPS_FIN_WAIT_2) && (tp->t_maxidle > 0))
1049 1.132 christos TCP_TIMER_ARM(tp, TCPT_2MSL, tp->t_maxidle);
1050 1.159 dyoung else if (tp->t_state == TCPS_TIME_WAIT
1051 1.159 dyoung && ((tp->t_inpcb
1052 1.159 dyoung && (tcp4_vtw_enable & 1)
1053 1.159 dyoung && vtw_add(AF_INET, tp))
1054 1.159 dyoung ||
1055 1.159 dyoung (tp->t_in6pcb
1056 1.159 dyoung && (tcp6_vtw_enable & 1)
1057 1.159 dyoung && vtw_add(AF_INET6, tp)))) {
1058 1.159 dyoung tp = 0;
1059 1.159 dyoung }
1060 1.18 mycroft }
1061 1.1 cgd return (tp);
1062 1.17 thorpej }
1063 1.17 thorpej
1064 1.86 atatat /*
1065 1.86 atatat * sysctl helper routine for net.inet.ip.mssdflt. it can't be less
1066 1.86 atatat * than 32.
1067 1.86 atatat */
1068 1.86 atatat static int
1069 1.86 atatat sysctl_net_inet_tcp_mssdflt(SYSCTLFN_ARGS)
1070 1.86 atatat {
1071 1.86 atatat int error, mssdflt;
1072 1.86 atatat struct sysctlnode node;
1073 1.86 atatat
1074 1.86 atatat mssdflt = tcp_mssdflt;
1075 1.86 atatat node = *rnode;
1076 1.86 atatat node.sysctl_data = &mssdflt;
1077 1.86 atatat error = sysctl_lookup(SYSCTLFN_CALL(&node));
1078 1.86 atatat if (error || newp == NULL)
1079 1.86 atatat return (error);
1080 1.86 atatat
1081 1.86 atatat if (mssdflt < 32)
1082 1.86 atatat return (EINVAL);
1083 1.86 atatat tcp_mssdflt = mssdflt;
1084 1.86 atatat
1085 1.170 kefren mutex_enter(softnet_lock);
1086 1.170 kefren tcp_tcpcb_template();
1087 1.170 kefren mutex_exit(softnet_lock);
1088 1.170 kefren
1089 1.86 atatat return (0);
1090 1.86 atatat }
1091 1.36 matt
1092 1.17 thorpej /*
1093 1.170 kefren * sysctl helper for TCP CB template update
1094 1.170 kefren */
1095 1.170 kefren static int
1096 1.170 kefren sysctl_update_tcpcb_template(SYSCTLFN_ARGS)
1097 1.170 kefren {
1098 1.170 kefren int t, error;
1099 1.170 kefren struct sysctlnode node;
1100 1.170 kefren
1101 1.170 kefren /* follow procedures in sysctl(9) manpage */
1102 1.170 kefren t = *(int *)rnode->sysctl_data;
1103 1.170 kefren node = *rnode;
1104 1.170 kefren node.sysctl_data = &t;
1105 1.170 kefren error = sysctl_lookup(SYSCTLFN_CALL(&node));
1106 1.170 kefren if (error || newp == NULL)
1107 1.170 kefren return error;
1108 1.170 kefren
1109 1.170 kefren if (t < 0)
1110 1.170 kefren return EINVAL;
1111 1.170 kefren
1112 1.170 kefren *(int *)rnode->sysctl_data = t;
1113 1.170 kefren
1114 1.170 kefren mutex_enter(softnet_lock);
1115 1.170 kefren tcp_tcpcb_template();
1116 1.170 kefren mutex_exit(softnet_lock);
1117 1.170 kefren
1118 1.170 kefren return 0;
1119 1.170 kefren }
1120 1.170 kefren
1121 1.170 kefren /*
1122 1.86 atatat * sysctl helper routine for setting port related values under
1123 1.86 atatat * net.inet.ip and net.inet6.ip6. does basic range checking and does
1124 1.86 atatat * additional checks for each type. this code has placed in
1125 1.86 atatat * tcp_input.c since INET and INET6 both use the same tcp code.
1126 1.86 atatat *
1127 1.86 atatat * this helper is not static so that both inet and inet6 can use it.
1128 1.17 thorpej */
1129 1.17 thorpej int
1130 1.86 atatat sysctl_net_inet_ip_ports(SYSCTLFN_ARGS)
1131 1.86 atatat {
1132 1.86 atatat int error, tmp;
1133 1.86 atatat int apmin, apmax;
1134 1.86 atatat #ifndef IPNOPRIVPORTS
1135 1.86 atatat int lpmin, lpmax;
1136 1.86 atatat #endif /* IPNOPRIVPORTS */
1137 1.86 atatat struct sysctlnode node;
1138 1.86 atatat
1139 1.86 atatat if (namelen != 0)
1140 1.86 atatat return (EINVAL);
1141 1.86 atatat
1142 1.86 atatat switch (name[-3]) {
1143 1.86 atatat #ifdef INET
1144 1.86 atatat case PF_INET:
1145 1.86 atatat apmin = anonportmin;
1146 1.86 atatat apmax = anonportmax;
1147 1.86 atatat #ifndef IPNOPRIVPORTS
1148 1.86 atatat lpmin = lowportmin;
1149 1.86 atatat lpmax = lowportmax;
1150 1.86 atatat #endif /* IPNOPRIVPORTS */
1151 1.86 atatat break;
1152 1.86 atatat #endif /* INET */
1153 1.86 atatat #ifdef INET6
1154 1.86 atatat case PF_INET6:
1155 1.86 atatat apmin = ip6_anonportmin;
1156 1.86 atatat apmax = ip6_anonportmax;
1157 1.86 atatat #ifndef IPNOPRIVPORTS
1158 1.86 atatat lpmin = ip6_lowportmin;
1159 1.86 atatat lpmax = ip6_lowportmax;
1160 1.86 atatat #endif /* IPNOPRIVPORTS */
1161 1.86 atatat break;
1162 1.86 atatat #endif /* INET6 */
1163 1.86 atatat default:
1164 1.86 atatat return (EINVAL);
1165 1.86 atatat }
1166 1.86 atatat
1167 1.86 atatat /*
1168 1.86 atatat * insert temporary copy into node, perform lookup on
1169 1.86 atatat * temporary, then restore pointer
1170 1.86 atatat */
1171 1.86 atatat node = *rnode;
1172 1.86 atatat tmp = *(int*)rnode->sysctl_data;
1173 1.86 atatat node.sysctl_data = &tmp;
1174 1.86 atatat error = sysctl_lookup(SYSCTLFN_CALL(&node));
1175 1.86 atatat if (error || newp == NULL)
1176 1.86 atatat return (error);
1177 1.86 atatat
1178 1.86 atatat /*
1179 1.86 atatat * simple port range check
1180 1.86 atatat */
1181 1.86 atatat if (tmp < 0 || tmp > 65535)
1182 1.86 atatat return (EINVAL);
1183 1.86 atatat
1184 1.86 atatat /*
1185 1.86 atatat * per-node range checks
1186 1.86 atatat */
1187 1.86 atatat switch (rnode->sysctl_num) {
1188 1.86 atatat case IPCTL_ANONPORTMIN:
1189 1.151 yamt case IPV6CTL_ANONPORTMIN:
1190 1.86 atatat if (tmp >= apmax)
1191 1.86 atatat return (EINVAL);
1192 1.86 atatat #ifndef IPNOPRIVPORTS
1193 1.86 atatat if (tmp < IPPORT_RESERVED)
1194 1.86 atatat return (EINVAL);
1195 1.86 atatat #endif /* IPNOPRIVPORTS */
1196 1.86 atatat break;
1197 1.86 atatat
1198 1.86 atatat case IPCTL_ANONPORTMAX:
1199 1.151 yamt case IPV6CTL_ANONPORTMAX:
1200 1.86 atatat if (apmin >= tmp)
1201 1.86 atatat return (EINVAL);
1202 1.86 atatat #ifndef IPNOPRIVPORTS
1203 1.86 atatat if (tmp < IPPORT_RESERVED)
1204 1.86 atatat return (EINVAL);
1205 1.86 atatat #endif /* IPNOPRIVPORTS */
1206 1.86 atatat break;
1207 1.86 atatat
1208 1.86 atatat #ifndef IPNOPRIVPORTS
1209 1.86 atatat case IPCTL_LOWPORTMIN:
1210 1.151 yamt case IPV6CTL_LOWPORTMIN:
1211 1.86 atatat if (tmp >= lpmax ||
1212 1.86 atatat tmp > IPPORT_RESERVEDMAX ||
1213 1.86 atatat tmp < IPPORT_RESERVEDMIN)
1214 1.86 atatat return (EINVAL);
1215 1.86 atatat break;
1216 1.86 atatat
1217 1.86 atatat case IPCTL_LOWPORTMAX:
1218 1.151 yamt case IPV6CTL_LOWPORTMAX:
1219 1.86 atatat if (lpmin >= tmp ||
1220 1.86 atatat tmp > IPPORT_RESERVEDMAX ||
1221 1.86 atatat tmp < IPPORT_RESERVEDMIN)
1222 1.86 atatat return (EINVAL);
1223 1.86 atatat break;
1224 1.86 atatat #endif /* IPNOPRIVPORTS */
1225 1.86 atatat
1226 1.86 atatat default:
1227 1.86 atatat return (EINVAL);
1228 1.86 atatat }
1229 1.86 atatat
1230 1.86 atatat *(int*)rnode->sysctl_data = tmp;
1231 1.86 atatat
1232 1.86 atatat return (0);
1233 1.86 atatat }
1234 1.86 atatat
1235 1.133 christos static inline int
1236 1.133 christos copyout_uid(struct socket *sockp, void *oldp, size_t *oldlenp)
1237 1.133 christos {
1238 1.168 christos if (oldp) {
1239 1.168 christos size_t sz;
1240 1.168 christos uid_t uid;
1241 1.168 christos int error;
1242 1.168 christos
1243 1.168 christos if (sockp->so_cred == NULL)
1244 1.168 christos return EPERM;
1245 1.133 christos
1246 1.168 christos uid = kauth_cred_geteuid(sockp->so_cred);
1247 1.133 christos sz = MIN(sizeof(uid), *oldlenp);
1248 1.168 christos if ((error = copyout(&uid, oldp, sz)) != 0)
1249 1.133 christos return error;
1250 1.133 christos }
1251 1.168 christos *oldlenp = sizeof(uid_t);
1252 1.133 christos return 0;
1253 1.133 christos }
1254 1.133 christos
1255 1.133 christos static inline int
1256 1.133 christos inet4_ident_core(struct in_addr raddr, u_int rport,
1257 1.133 christos struct in_addr laddr, u_int lport,
1258 1.133 christos void *oldp, size_t *oldlenp,
1259 1.133 christos struct lwp *l, int dodrop)
1260 1.133 christos {
1261 1.133 christos struct inpcb *inp;
1262 1.133 christos struct socket *sockp;
1263 1.133 christos
1264 1.159 dyoung inp = in_pcblookup_connect(&tcbtable, raddr, rport, laddr, lport, 0);
1265 1.133 christos
1266 1.133 christos if (inp == NULL || (sockp = inp->inp_socket) == NULL)
1267 1.133 christos return ESRCH;
1268 1.133 christos
1269 1.133 christos if (dodrop) {
1270 1.133 christos struct tcpcb *tp;
1271 1.153 elad int error;
1272 1.133 christos
1273 1.133 christos if (inp == NULL || (tp = intotcpcb(inp)) == NULL ||
1274 1.133 christos (inp->inp_socket->so_options & SO_ACCEPTCONN) != 0)
1275 1.133 christos return ESRCH;
1276 1.153 elad
1277 1.153 elad error = kauth_authorize_network(l->l_cred, KAUTH_NETWORK_SOCKET,
1278 1.153 elad KAUTH_REQ_NETWORK_SOCKET_DROP, inp->inp_socket, tp, NULL);
1279 1.153 elad if (error)
1280 1.153 elad return (error);
1281 1.133 christos
1282 1.133 christos (void)tcp_drop(tp, ECONNABORTED);
1283 1.133 christos return 0;
1284 1.133 christos }
1285 1.133 christos else
1286 1.133 christos return copyout_uid(sockp, oldp, oldlenp);
1287 1.133 christos }
1288 1.133 christos
1289 1.134 xtraeme #ifdef INET6
1290 1.133 christos static inline int
1291 1.133 christos inet6_ident_core(struct in6_addr *raddr, u_int rport,
1292 1.133 christos struct in6_addr *laddr, u_int lport,
1293 1.133 christos void *oldp, size_t *oldlenp,
1294 1.133 christos struct lwp *l, int dodrop)
1295 1.133 christos {
1296 1.133 christos struct in6pcb *in6p;
1297 1.133 christos struct socket *sockp;
1298 1.133 christos
1299 1.159 dyoung in6p = in6_pcblookup_connect(&tcbtable, raddr, rport, laddr, lport, 0, 0);
1300 1.133 christos
1301 1.133 christos if (in6p == NULL || (sockp = in6p->in6p_socket) == NULL)
1302 1.133 christos return ESRCH;
1303 1.133 christos
1304 1.133 christos if (dodrop) {
1305 1.133 christos struct tcpcb *tp;
1306 1.153 elad int error;
1307 1.133 christos
1308 1.133 christos if (in6p == NULL || (tp = in6totcpcb(in6p)) == NULL ||
1309 1.133 christos (in6p->in6p_socket->so_options & SO_ACCEPTCONN) != 0)
1310 1.133 christos return ESRCH;
1311 1.133 christos
1312 1.153 elad error = kauth_authorize_network(l->l_cred, KAUTH_NETWORK_SOCKET,
1313 1.153 elad KAUTH_REQ_NETWORK_SOCKET_DROP, in6p->in6p_socket, tp, NULL);
1314 1.153 elad if (error)
1315 1.153 elad return (error);
1316 1.133 christos
1317 1.133 christos (void)tcp_drop(tp, ECONNABORTED);
1318 1.133 christos return 0;
1319 1.133 christos }
1320 1.133 christos else
1321 1.133 christos return copyout_uid(sockp, oldp, oldlenp);
1322 1.133 christos }
1323 1.134 xtraeme #endif
1324 1.133 christos
1325 1.133 christos /*
1326 1.133 christos * sysctl helper routine for the net.inet.tcp.drop and
1327 1.133 christos * net.inet6.tcp6.drop nodes.
1328 1.133 christos */
1329 1.133 christos #define sysctl_net_inet_tcp_drop sysctl_net_inet_tcp_ident
1330 1.133 christos
1331 1.133 christos /*
1332 1.86 atatat * sysctl helper routine for the net.inet.tcp.ident and
1333 1.86 atatat * net.inet6.tcp6.ident nodes. contains backwards compat code for the
1334 1.86 atatat * old way of looking up the ident information for ipv4 which involves
1335 1.86 atatat * stuffing the port/addr pairs into the mib lookup.
1336 1.86 atatat */
1337 1.86 atatat static int
1338 1.86 atatat sysctl_net_inet_tcp_ident(SYSCTLFN_ARGS)
1339 1.86 atatat {
1340 1.86 atatat #ifdef INET
1341 1.86 atatat struct sockaddr_in *si4[2];
1342 1.86 atatat #endif /* INET */
1343 1.86 atatat #ifdef INET6
1344 1.86 atatat struct sockaddr_in6 *si6[2];
1345 1.86 atatat #endif /* INET6 */
1346 1.86 atatat struct sockaddr_storage sa[2];
1347 1.148 matt int error, pf, dodrop;
1348 1.86 atatat
1349 1.133 christos dodrop = name[-1] == TCPCTL_DROP;
1350 1.133 christos if (dodrop) {
1351 1.133 christos if (oldp != NULL || *oldlenp != 0)
1352 1.133 christos return EINVAL;
1353 1.133 christos if (newp == NULL)
1354 1.133 christos return EPERM;
1355 1.133 christos if (newlen < sizeof(sa))
1356 1.133 christos return ENOMEM;
1357 1.133 christos }
1358 1.86 atatat if (namelen != 4 && namelen != 0)
1359 1.133 christos return EINVAL;
1360 1.86 atatat if (name[-2] != IPPROTO_TCP)
1361 1.133 christos return EINVAL;
1362 1.86 atatat pf = name[-3];
1363 1.86 atatat
1364 1.86 atatat /* old style lookup, ipv4 only */
1365 1.86 atatat if (namelen == 4) {
1366 1.86 atatat #ifdef INET
1367 1.88 atatat struct in_addr laddr, raddr;
1368 1.88 atatat u_int lport, rport;
1369 1.88 atatat
1370 1.86 atatat if (pf != PF_INET)
1371 1.133 christos return EPROTONOSUPPORT;
1372 1.86 atatat raddr.s_addr = (uint32_t)name[0];
1373 1.86 atatat rport = (u_int)name[1];
1374 1.86 atatat laddr.s_addr = (uint32_t)name[2];
1375 1.86 atatat lport = (u_int)name[3];
1376 1.133 christos
1377 1.148 matt mutex_enter(softnet_lock);
1378 1.133 christos error = inet4_ident_core(raddr, rport, laddr, lport,
1379 1.133 christos oldp, oldlenp, l, dodrop);
1380 1.148 matt mutex_exit(softnet_lock);
1381 1.133 christos return error;
1382 1.86 atatat #else /* INET */
1383 1.133 christos return EINVAL;
1384 1.86 atatat #endif /* INET */
1385 1.86 atatat }
1386 1.86 atatat
1387 1.86 atatat if (newp == NULL || newlen != sizeof(sa))
1388 1.133 christos return EINVAL;
1389 1.86 atatat error = copyin(newp, &sa, newlen);
1390 1.86 atatat if (error)
1391 1.133 christos return error;
1392 1.86 atatat
1393 1.86 atatat /*
1394 1.86 atatat * requested families must match
1395 1.86 atatat */
1396 1.86 atatat if (pf != sa[0].ss_family || sa[0].ss_family != sa[1].ss_family)
1397 1.133 christos return EINVAL;
1398 1.86 atatat
1399 1.86 atatat switch (pf) {
1400 1.135 christos #ifdef INET6
1401 1.135 christos case PF_INET6:
1402 1.135 christos si6[0] = (struct sockaddr_in6*)&sa[0];
1403 1.135 christos si6[1] = (struct sockaddr_in6*)&sa[1];
1404 1.135 christos if (si6[0]->sin6_len != sizeof(*si6[0]) ||
1405 1.135 christos si6[1]->sin6_len != sizeof(*si6[1]))
1406 1.135 christos return EINVAL;
1407 1.135 christos
1408 1.135 christos if (!IN6_IS_ADDR_V4MAPPED(&si6[0]->sin6_addr) &&
1409 1.135 christos !IN6_IS_ADDR_V4MAPPED(&si6[1]->sin6_addr)) {
1410 1.135 christos error = sa6_embedscope(si6[0], ip6_use_defzone);
1411 1.135 christos if (error)
1412 1.135 christos return error;
1413 1.135 christos error = sa6_embedscope(si6[1], ip6_use_defzone);
1414 1.135 christos if (error)
1415 1.135 christos return error;
1416 1.135 christos
1417 1.148 matt mutex_enter(softnet_lock);
1418 1.135 christos error = inet6_ident_core(&si6[0]->sin6_addr,
1419 1.135 christos si6[0]->sin6_port, &si6[1]->sin6_addr,
1420 1.135 christos si6[1]->sin6_port, oldp, oldlenp, l, dodrop);
1421 1.148 matt mutex_exit(softnet_lock);
1422 1.135 christos return error;
1423 1.135 christos }
1424 1.135 christos
1425 1.135 christos if (IN6_IS_ADDR_V4MAPPED(&si6[0]->sin6_addr) !=
1426 1.135 christos IN6_IS_ADDR_V4MAPPED(&si6[1]->sin6_addr))
1427 1.135 christos return EINVAL;
1428 1.135 christos
1429 1.135 christos in6_sin6_2_sin_in_sock((struct sockaddr *)&sa[0]);
1430 1.135 christos in6_sin6_2_sin_in_sock((struct sockaddr *)&sa[1]);
1431 1.135 christos /*FALLTHROUGH*/
1432 1.135 christos #endif /* INET6 */
1433 1.86 atatat #ifdef INET
1434 1.133 christos case PF_INET:
1435 1.86 atatat si4[0] = (struct sockaddr_in*)&sa[0];
1436 1.86 atatat si4[1] = (struct sockaddr_in*)&sa[1];
1437 1.86 atatat if (si4[0]->sin_len != sizeof(*si4[0]) ||
1438 1.135 christos si4[0]->sin_len != sizeof(*si4[1]))
1439 1.133 christos return EINVAL;
1440 1.133 christos
1441 1.148 matt mutex_enter(softnet_lock);
1442 1.133 christos error = inet4_ident_core(si4[0]->sin_addr, si4[0]->sin_port,
1443 1.133 christos si4[1]->sin_addr, si4[1]->sin_port,
1444 1.133 christos oldp, oldlenp, l, dodrop);
1445 1.148 matt mutex_exit(softnet_lock);
1446 1.133 christos return error;
1447 1.86 atatat #endif /* INET */
1448 1.133 christos default:
1449 1.133 christos return EPROTONOSUPPORT;
1450 1.86 atatat }
1451 1.76 christos }
1452 1.76 christos
1453 1.86 atatat /*
1454 1.97 atatat * sysctl helper for the inet and inet6 pcblists. handles tcp/udp and
1455 1.97 atatat * inet/inet6, as well as raw pcbs for each. specifically not
1456 1.97 atatat * declared static so that raw sockets and udp/udp6 can use it as
1457 1.97 atatat * well.
1458 1.97 atatat */
1459 1.97 atatat int
1460 1.97 atatat sysctl_inpcblist(SYSCTLFN_ARGS)
1461 1.97 atatat {
1462 1.97 atatat #ifdef INET
1463 1.97 atatat struct sockaddr_in *in;
1464 1.104 christos const struct inpcb *inp;
1465 1.97 atatat #endif
1466 1.97 atatat #ifdef INET6
1467 1.97 atatat struct sockaddr_in6 *in6;
1468 1.104 christos const struct in6pcb *in6p;
1469 1.97 atatat #endif
1470 1.104 christos struct inpcbtable *pcbtbl = __UNCONST(rnode->sysctl_data);
1471 1.104 christos const struct inpcb_hdr *inph;
1472 1.97 atatat struct tcpcb *tp;
1473 1.97 atatat struct kinfo_pcb pcb;
1474 1.97 atatat char *dp;
1475 1.97 atatat size_t len, needed, elem_size, out_size;
1476 1.97 atatat int error, elem_count, pf, proto, pf2;
1477 1.97 atatat
1478 1.97 atatat if (namelen != 4)
1479 1.97 atatat return (EINVAL);
1480 1.97 atatat
1481 1.114 christos if (oldp != NULL) {
1482 1.114 christos len = *oldlenp;
1483 1.114 christos elem_size = name[2];
1484 1.114 christos elem_count = name[3];
1485 1.114 christos if (elem_size != sizeof(pcb))
1486 1.114 christos return EINVAL;
1487 1.114 christos } else {
1488 1.114 christos len = 0;
1489 1.114 christos elem_count = INT_MAX;
1490 1.114 christos elem_size = sizeof(pcb);
1491 1.114 christos }
1492 1.97 atatat error = 0;
1493 1.97 atatat dp = oldp;
1494 1.114 christos out_size = elem_size;
1495 1.97 atatat needed = 0;
1496 1.97 atatat
1497 1.97 atatat if (namelen == 1 && name[0] == CTL_QUERY)
1498 1.105 atatat return (sysctl_query(SYSCTLFN_CALL(rnode)));
1499 1.97 atatat
1500 1.97 atatat if (name - oname != 4)
1501 1.97 atatat return (EINVAL);
1502 1.97 atatat
1503 1.97 atatat pf = oname[1];
1504 1.97 atatat proto = oname[2];
1505 1.116 christos pf2 = (oldp != NULL) ? pf : 0;
1506 1.97 atatat
1507 1.148 matt mutex_enter(softnet_lock);
1508 1.148 matt
1509 1.169 christos TAILQ_FOREACH(inph, &pcbtbl->inpt_queue, inph_queue) {
1510 1.99 atatat #ifdef INET
1511 1.104 christos inp = (const struct inpcb *)inph;
1512 1.99 atatat #endif
1513 1.99 atatat #ifdef INET6
1514 1.104 christos in6p = (const struct in6pcb *)inph;
1515 1.99 atatat #endif
1516 1.97 atatat
1517 1.99 atatat if (inph->inph_af != pf)
1518 1.97 atatat continue;
1519 1.97 atatat
1520 1.125 elad if (kauth_authorize_network(l->l_cred, KAUTH_NETWORK_SOCKET,
1521 1.125 elad KAUTH_REQ_NETWORK_SOCKET_CANSEE, inph->inph_socket, NULL,
1522 1.125 elad NULL) != 0)
1523 1.111 elad continue;
1524 1.111 elad
1525 1.97 atatat memset(&pcb, 0, sizeof(pcb));
1526 1.97 atatat
1527 1.97 atatat pcb.ki_family = pf;
1528 1.97 atatat pcb.ki_type = proto;
1529 1.97 atatat
1530 1.97 atatat switch (pf2) {
1531 1.97 atatat case 0:
1532 1.97 atatat /* just probing for size */
1533 1.97 atatat break;
1534 1.97 atatat #ifdef INET
1535 1.97 atatat case PF_INET:
1536 1.97 atatat pcb.ki_family = inp->inp_socket->so_proto->
1537 1.97 atatat pr_domain->dom_family;
1538 1.97 atatat pcb.ki_type = inp->inp_socket->so_proto->
1539 1.97 atatat pr_type;
1540 1.97 atatat pcb.ki_protocol = inp->inp_socket->so_proto->
1541 1.97 atatat pr_protocol;
1542 1.97 atatat pcb.ki_pflags = inp->inp_flags;
1543 1.97 atatat
1544 1.97 atatat pcb.ki_sostate = inp->inp_socket->so_state;
1545 1.97 atatat pcb.ki_prstate = inp->inp_state;
1546 1.97 atatat if (proto == IPPROTO_TCP) {
1547 1.97 atatat tp = intotcpcb(inp);
1548 1.97 atatat pcb.ki_tstate = tp->t_state;
1549 1.97 atatat pcb.ki_tflags = tp->t_flags;
1550 1.97 atatat }
1551 1.97 atatat
1552 1.97 atatat pcb.ki_pcbaddr = PTRTOUINT64(inp);
1553 1.97 atatat pcb.ki_ppcbaddr = PTRTOUINT64(inp->inp_ppcb);
1554 1.97 atatat pcb.ki_sockaddr = PTRTOUINT64(inp->inp_socket);
1555 1.97 atatat
1556 1.97 atatat pcb.ki_rcvq = inp->inp_socket->so_rcv.sb_cc;
1557 1.97 atatat pcb.ki_sndq = inp->inp_socket->so_snd.sb_cc;
1558 1.97 atatat
1559 1.97 atatat in = satosin(&pcb.ki_src);
1560 1.97 atatat in->sin_len = sizeof(*in);
1561 1.97 atatat in->sin_family = pf;
1562 1.97 atatat in->sin_port = inp->inp_lport;
1563 1.97 atatat in->sin_addr = inp->inp_laddr;
1564 1.97 atatat if (pcb.ki_prstate >= INP_CONNECTED) {
1565 1.97 atatat in = satosin(&pcb.ki_dst);
1566 1.97 atatat in->sin_len = sizeof(*in);
1567 1.97 atatat in->sin_family = pf;
1568 1.97 atatat in->sin_port = inp->inp_fport;
1569 1.97 atatat in->sin_addr = inp->inp_faddr;
1570 1.97 atatat }
1571 1.97 atatat break;
1572 1.97 atatat #endif
1573 1.97 atatat #ifdef INET6
1574 1.97 atatat case PF_INET6:
1575 1.97 atatat pcb.ki_family = in6p->in6p_socket->so_proto->
1576 1.97 atatat pr_domain->dom_family;
1577 1.97 atatat pcb.ki_type = in6p->in6p_socket->so_proto->pr_type;
1578 1.97 atatat pcb.ki_protocol = in6p->in6p_socket->so_proto->
1579 1.97 atatat pr_protocol;
1580 1.97 atatat pcb.ki_pflags = in6p->in6p_flags;
1581 1.97 atatat
1582 1.97 atatat pcb.ki_sostate = in6p->in6p_socket->so_state;
1583 1.97 atatat pcb.ki_prstate = in6p->in6p_state;
1584 1.97 atatat if (proto == IPPROTO_TCP) {
1585 1.97 atatat tp = in6totcpcb(in6p);
1586 1.97 atatat pcb.ki_tstate = tp->t_state;
1587 1.97 atatat pcb.ki_tflags = tp->t_flags;
1588 1.97 atatat }
1589 1.97 atatat
1590 1.97 atatat pcb.ki_pcbaddr = PTRTOUINT64(in6p);
1591 1.97 atatat pcb.ki_ppcbaddr = PTRTOUINT64(in6p->in6p_ppcb);
1592 1.97 atatat pcb.ki_sockaddr = PTRTOUINT64(in6p->in6p_socket);
1593 1.97 atatat
1594 1.97 atatat pcb.ki_rcvq = in6p->in6p_socket->so_rcv.sb_cc;
1595 1.97 atatat pcb.ki_sndq = in6p->in6p_socket->so_snd.sb_cc;
1596 1.97 atatat
1597 1.97 atatat in6 = satosin6(&pcb.ki_src);
1598 1.97 atatat in6->sin6_len = sizeof(*in6);
1599 1.97 atatat in6->sin6_family = pf;
1600 1.97 atatat in6->sin6_port = in6p->in6p_lport;
1601 1.97 atatat in6->sin6_flowinfo = in6p->in6p_flowinfo;
1602 1.97 atatat in6->sin6_addr = in6p->in6p_laddr;
1603 1.97 atatat in6->sin6_scope_id = 0; /* XXX? */
1604 1.97 atatat
1605 1.97 atatat if (pcb.ki_prstate >= IN6P_CONNECTED) {
1606 1.97 atatat in6 = satosin6(&pcb.ki_dst);
1607 1.97 atatat in6->sin6_len = sizeof(*in6);
1608 1.97 atatat in6->sin6_family = pf;
1609 1.97 atatat in6->sin6_port = in6p->in6p_fport;
1610 1.97 atatat in6->sin6_flowinfo = in6p->in6p_flowinfo;
1611 1.97 atatat in6->sin6_addr = in6p->in6p_faddr;
1612 1.97 atatat in6->sin6_scope_id = 0; /* XXX? */
1613 1.97 atatat }
1614 1.97 atatat break;
1615 1.97 atatat #endif
1616 1.97 atatat }
1617 1.97 atatat
1618 1.97 atatat if (len >= elem_size && elem_count > 0) {
1619 1.97 atatat error = copyout(&pcb, dp, out_size);
1620 1.155 rmind if (error) {
1621 1.155 rmind mutex_exit(softnet_lock);
1622 1.97 atatat return (error);
1623 1.155 rmind }
1624 1.97 atatat dp += elem_size;
1625 1.97 atatat len -= elem_size;
1626 1.97 atatat }
1627 1.152 mrg needed += elem_size;
1628 1.152 mrg if (elem_count > 0 && elem_count != INT_MAX)
1629 1.152 mrg elem_count--;
1630 1.97 atatat }
1631 1.97 atatat
1632 1.97 atatat *oldlenp = needed;
1633 1.97 atatat if (oldp == NULL)
1634 1.97 atatat *oldlenp += PCB_SLOP * sizeof(struct kinfo_pcb);
1635 1.97 atatat
1636 1.148 matt mutex_exit(softnet_lock);
1637 1.148 matt
1638 1.97 atatat return (error);
1639 1.97 atatat }
1640 1.97 atatat
1641 1.124 rpaulo static int
1642 1.124 rpaulo sysctl_tcp_congctl(SYSCTLFN_ARGS)
1643 1.124 rpaulo {
1644 1.124 rpaulo struct sysctlnode node;
1645 1.148 matt int error;
1646 1.124 rpaulo char newname[TCPCC_MAXLEN];
1647 1.124 rpaulo
1648 1.124 rpaulo strlcpy(newname, tcp_congctl_global_name, sizeof(newname) - 1);
1649 1.124 rpaulo
1650 1.124 rpaulo node = *rnode;
1651 1.124 rpaulo node.sysctl_data = newname;
1652 1.124 rpaulo node.sysctl_size = sizeof(newname);
1653 1.124 rpaulo
1654 1.124 rpaulo error = sysctl_lookup(SYSCTLFN_CALL(&node));
1655 1.124 rpaulo
1656 1.124 rpaulo if (error ||
1657 1.124 rpaulo newp == NULL ||
1658 1.124 rpaulo strncmp(newname, tcp_congctl_global_name, sizeof(newname)) == 0)
1659 1.124 rpaulo return error;
1660 1.124 rpaulo
1661 1.148 matt mutex_enter(softnet_lock);
1662 1.148 matt error = tcp_congctl_select(NULL, newname);
1663 1.148 matt mutex_exit(softnet_lock);
1664 1.148 matt
1665 1.124 rpaulo return error;
1666 1.124 rpaulo }
1667 1.124 rpaulo
1668 1.132 christos static int
1669 1.166 christos sysctl_tcp_init_win(SYSCTLFN_ARGS)
1670 1.166 christos {
1671 1.166 christos int error;
1672 1.166 christos u_int iw;
1673 1.166 christos struct sysctlnode node;
1674 1.166 christos
1675 1.166 christos iw = *(u_int *)rnode->sysctl_data;
1676 1.166 christos node = *rnode;
1677 1.166 christos node.sysctl_data = &iw;
1678 1.166 christos node.sysctl_size = sizeof(iw);
1679 1.166 christos error = sysctl_lookup(SYSCTLFN_CALL(&node));
1680 1.166 christos if (error || newp == NULL)
1681 1.166 christos return error;
1682 1.166 christos
1683 1.166 christos if (iw >= __arraycount(tcp_init_win_max))
1684 1.166 christos return EINVAL;
1685 1.166 christos *(u_int *)rnode->sysctl_data = iw;
1686 1.166 christos return 0;
1687 1.166 christos }
1688 1.166 christos
1689 1.166 christos static int
1690 1.132 christos sysctl_tcp_keep(SYSCTLFN_ARGS)
1691 1.132 christos {
1692 1.132 christos int error;
1693 1.132 christos u_int tmp;
1694 1.132 christos struct sysctlnode node;
1695 1.132 christos
1696 1.132 christos node = *rnode;
1697 1.132 christos tmp = *(u_int *)rnode->sysctl_data;
1698 1.132 christos node.sysctl_data = &tmp;
1699 1.132 christos
1700 1.132 christos error = sysctl_lookup(SYSCTLFN_CALL(&node));
1701 1.132 christos if (error || newp == NULL)
1702 1.132 christos return error;
1703 1.132 christos
1704 1.148 matt mutex_enter(softnet_lock);
1705 1.148 matt
1706 1.132 christos *(u_int *)rnode->sysctl_data = tmp;
1707 1.132 christos tcp_tcpcb_template(); /* update the template */
1708 1.148 matt
1709 1.148 matt mutex_exit(softnet_lock);
1710 1.132 christos return 0;
1711 1.132 christos }
1712 1.132 christos
1713 1.142 thorpej static int
1714 1.142 thorpej sysctl_net_inet_tcp_stats(SYSCTLFN_ARGS)
1715 1.142 thorpej {
1716 1.142 thorpej
1717 1.146 thorpej return (NETSTAT_SYSCTL(tcpstat_percpu, TCP_NSTATS));
1718 1.142 thorpej }
1719 1.132 christos
1720 1.97 atatat /*
1721 1.86 atatat * this (second stage) setup routine is a replacement for tcp_sysctl()
1722 1.86 atatat * (which is currently used for ipv4 and ipv6)
1723 1.86 atatat */
1724 1.86 atatat static void
1725 1.87 atatat sysctl_net_inet_tcp_setup2(struct sysctllog **clog, int pf, const char *pfname,
1726 1.87 atatat const char *tcpname)
1727 1.86 atatat {
1728 1.128 rpaulo const struct sysctlnode *sack_node;
1729 1.127 yamt const struct sysctlnode *abc_node;
1730 1.128 rpaulo const struct sysctlnode *ecn_node;
1731 1.128 rpaulo const struct sysctlnode *congctl_node;
1732 1.159 dyoung const struct sysctlnode *mslt_node;
1733 1.159 dyoung const struct sysctlnode *vtw_node;
1734 1.109 rpaulo #ifdef TCP_DEBUG
1735 1.109 rpaulo extern struct tcp_debug tcp_debug[TCP_NDEBUG];
1736 1.109 rpaulo extern int tcp_debx;
1737 1.109 rpaulo #endif
1738 1.76 christos
1739 1.87 atatat sysctl_createv(clog, 0, NULL, NULL,
1740 1.87 atatat CTLFLAG_PERMANENT,
1741 1.86 atatat CTLTYPE_NODE, pfname, NULL,
1742 1.86 atatat NULL, 0, NULL, 0,
1743 1.86 atatat CTL_NET, pf, CTL_EOL);
1744 1.87 atatat sysctl_createv(clog, 0, NULL, NULL,
1745 1.87 atatat CTLFLAG_PERMANENT,
1746 1.92 atatat CTLTYPE_NODE, tcpname,
1747 1.92 atatat SYSCTL_DESCR("TCP related settings"),
1748 1.86 atatat NULL, 0, NULL, 0,
1749 1.86 atatat CTL_NET, pf, IPPROTO_TCP, CTL_EOL);
1750 1.86 atatat
1751 1.87 atatat sysctl_createv(clog, 0, NULL, NULL,
1752 1.87 atatat CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
1753 1.92 atatat CTLTYPE_INT, "rfc1323",
1754 1.92 atatat SYSCTL_DESCR("Enable RFC1323 TCP extensions"),
1755 1.170 kefren sysctl_update_tcpcb_template, 0, &tcp_do_rfc1323, 0,
1756 1.86 atatat CTL_NET, pf, IPPROTO_TCP, TCPCTL_RFC1323, CTL_EOL);
1757 1.87 atatat sysctl_createv(clog, 0, NULL, NULL,
1758 1.87 atatat CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
1759 1.92 atatat CTLTYPE_INT, "sendspace",
1760 1.92 atatat SYSCTL_DESCR("Default TCP send buffer size"),
1761 1.86 atatat NULL, 0, &tcp_sendspace, 0,
1762 1.86 atatat CTL_NET, pf, IPPROTO_TCP, TCPCTL_SENDSPACE, CTL_EOL);
1763 1.87 atatat sysctl_createv(clog, 0, NULL, NULL,
1764 1.87 atatat CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
1765 1.92 atatat CTLTYPE_INT, "recvspace",
1766 1.92 atatat SYSCTL_DESCR("Default TCP receive buffer size"),
1767 1.86 atatat NULL, 0, &tcp_recvspace, 0,
1768 1.86 atatat CTL_NET, pf, IPPROTO_TCP, TCPCTL_RECVSPACE, CTL_EOL);
1769 1.87 atatat sysctl_createv(clog, 0, NULL, NULL,
1770 1.87 atatat CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
1771 1.92 atatat CTLTYPE_INT, "mssdflt",
1772 1.92 atatat SYSCTL_DESCR("Default maximum segment size"),
1773 1.86 atatat sysctl_net_inet_tcp_mssdflt, 0, &tcp_mssdflt, 0,
1774 1.86 atatat CTL_NET, pf, IPPROTO_TCP, TCPCTL_MSSDFLT, CTL_EOL);
1775 1.87 atatat sysctl_createv(clog, 0, NULL, NULL,
1776 1.87 atatat CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
1777 1.136 rmind CTLTYPE_INT, "minmss",
1778 1.136 rmind SYSCTL_DESCR("Lower limit for TCP maximum segment size"),
1779 1.136 rmind NULL, 0, &tcp_minmss, 0,
1780 1.136 rmind CTL_NET, pf, IPPROTO_TCP, CTL_CREATE, CTL_EOL);
1781 1.136 rmind sysctl_createv(clog, 0, NULL, NULL,
1782 1.136 rmind CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
1783 1.156 darran CTLTYPE_INT, "msl",
1784 1.156 darran SYSCTL_DESCR("Maximum Segment Life"),
1785 1.156 darran NULL, 0, &tcp_msl, 0,
1786 1.156 darran CTL_NET, pf, IPPROTO_TCP, TCPCTL_MSL, CTL_EOL);
1787 1.156 darran sysctl_createv(clog, 0, NULL, NULL,
1788 1.156 darran CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
1789 1.92 atatat CTLTYPE_INT, "syn_cache_limit",
1790 1.92 atatat SYSCTL_DESCR("Maximum number of entries in the TCP "
1791 1.92 atatat "compressed state engine"),
1792 1.86 atatat NULL, 0, &tcp_syn_cache_limit, 0,
1793 1.86 atatat CTL_NET, pf, IPPROTO_TCP, TCPCTL_SYN_CACHE_LIMIT,
1794 1.86 atatat CTL_EOL);
1795 1.87 atatat sysctl_createv(clog, 0, NULL, NULL,
1796 1.87 atatat CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
1797 1.92 atatat CTLTYPE_INT, "syn_bucket_limit",
1798 1.92 atatat SYSCTL_DESCR("Maximum number of entries per hash "
1799 1.92 atatat "bucket in the TCP compressed state "
1800 1.92 atatat "engine"),
1801 1.86 atatat NULL, 0, &tcp_syn_bucket_limit, 0,
1802 1.86 atatat CTL_NET, pf, IPPROTO_TCP, TCPCTL_SYN_BUCKET_LIMIT,
1803 1.86 atatat CTL_EOL);
1804 1.86 atatat #if 0 /* obsoleted */
1805 1.87 atatat sysctl_createv(clog, 0, NULL, NULL,
1806 1.87 atatat CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
1807 1.92 atatat CTLTYPE_INT, "syn_cache_interval",
1808 1.92 atatat SYSCTL_DESCR("TCP compressed state engine's timer interval"),
1809 1.86 atatat NULL, 0, &tcp_syn_cache_interval, 0,
1810 1.86 atatat CTL_NET, pf, IPPROTO_TCP, TCPCTL_SYN_CACHE_INTER,
1811 1.86 atatat CTL_EOL);
1812 1.86 atatat #endif
1813 1.87 atatat sysctl_createv(clog, 0, NULL, NULL,
1814 1.87 atatat CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
1815 1.92 atatat CTLTYPE_INT, "init_win",
1816 1.92 atatat SYSCTL_DESCR("Initial TCP congestion window"),
1817 1.166 christos sysctl_tcp_init_win, 0, &tcp_init_win, 0,
1818 1.86 atatat CTL_NET, pf, IPPROTO_TCP, TCPCTL_INIT_WIN, CTL_EOL);
1819 1.87 atatat sysctl_createv(clog, 0, NULL, NULL,
1820 1.87 atatat CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
1821 1.92 atatat CTLTYPE_INT, "mss_ifmtu",
1822 1.92 atatat SYSCTL_DESCR("Use interface MTU for calculating MSS"),
1823 1.86 atatat NULL, 0, &tcp_mss_ifmtu, 0,
1824 1.86 atatat CTL_NET, pf, IPPROTO_TCP, TCPCTL_MSS_IFMTU, CTL_EOL);
1825 1.102 kurahone sysctl_createv(clog, 0, NULL, &sack_node,
1826 1.102 kurahone CTLFLAG_PERMANENT,
1827 1.102 kurahone CTLTYPE_NODE, "sack",
1828 1.102 kurahone SYSCTL_DESCR("RFC2018 Selective ACKnowledgement tunables"),
1829 1.102 kurahone NULL, 0, NULL, 0,
1830 1.86 atatat CTL_NET, pf, IPPROTO_TCP, TCPCTL_SACK, CTL_EOL);
1831 1.128 rpaulo
1832 1.128 rpaulo /* Congctl subtree */
1833 1.128 rpaulo sysctl_createv(clog, 0, NULL, &congctl_node,
1834 1.124 rpaulo CTLFLAG_PERMANENT,
1835 1.124 rpaulo CTLTYPE_NODE, "congctl",
1836 1.124 rpaulo SYSCTL_DESCR("TCP Congestion Control"),
1837 1.128 rpaulo NULL, 0, NULL, 0,
1838 1.124 rpaulo CTL_NET, pf, IPPROTO_TCP, CTL_CREATE, CTL_EOL);
1839 1.128 rpaulo sysctl_createv(clog, 0, &congctl_node, NULL,
1840 1.124 rpaulo CTLFLAG_PERMANENT,
1841 1.124 rpaulo CTLTYPE_STRING, "available",
1842 1.124 rpaulo SYSCTL_DESCR("Available Congestion Control Mechanisms"),
1843 1.165 dsl NULL, 0, tcp_congctl_avail, 0, CTL_CREATE, CTL_EOL);
1844 1.128 rpaulo sysctl_createv(clog, 0, &congctl_node, NULL,
1845 1.124 rpaulo CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
1846 1.124 rpaulo CTLTYPE_STRING, "selected",
1847 1.124 rpaulo SYSCTL_DESCR("Selected Congestion Control Mechanism"),
1848 1.124 rpaulo sysctl_tcp_congctl, 0, NULL, TCPCC_MAXLEN,
1849 1.124 rpaulo CTL_CREATE, CTL_EOL);
1850 1.124 rpaulo
1851 1.87 atatat sysctl_createv(clog, 0, NULL, NULL,
1852 1.87 atatat CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
1853 1.92 atatat CTLTYPE_INT, "win_scale",
1854 1.92 atatat SYSCTL_DESCR("Use RFC1323 window scale options"),
1855 1.170 kefren sysctl_update_tcpcb_template, 0, &tcp_do_win_scale, 0,
1856 1.86 atatat CTL_NET, pf, IPPROTO_TCP, TCPCTL_WSCALE, CTL_EOL);
1857 1.87 atatat sysctl_createv(clog, 0, NULL, NULL,
1858 1.87 atatat CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
1859 1.92 atatat CTLTYPE_INT, "timestamps",
1860 1.92 atatat SYSCTL_DESCR("Use RFC1323 time stamp options"),
1861 1.170 kefren sysctl_update_tcpcb_template, 0, &tcp_do_timestamps, 0,
1862 1.86 atatat CTL_NET, pf, IPPROTO_TCP, TCPCTL_TSTAMP, CTL_EOL);
1863 1.87 atatat sysctl_createv(clog, 0, NULL, NULL,
1864 1.87 atatat CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
1865 1.92 atatat CTLTYPE_INT, "compat_42",
1866 1.92 atatat SYSCTL_DESCR("Enable workarounds for 4.2BSD TCP bugs"),
1867 1.86 atatat NULL, 0, &tcp_compat_42, 0,
1868 1.86 atatat CTL_NET, pf, IPPROTO_TCP, TCPCTL_COMPAT_42, CTL_EOL);
1869 1.87 atatat sysctl_createv(clog, 0, NULL, NULL,
1870 1.87 atatat CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
1871 1.92 atatat CTLTYPE_INT, "cwm",
1872 1.92 atatat SYSCTL_DESCR("Hughes/Touch/Heidemann Congestion Window "
1873 1.92 atatat "Monitoring"),
1874 1.86 atatat NULL, 0, &tcp_cwm, 0,
1875 1.86 atatat CTL_NET, pf, IPPROTO_TCP, TCPCTL_CWM, CTL_EOL);
1876 1.87 atatat sysctl_createv(clog, 0, NULL, NULL,
1877 1.87 atatat CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
1878 1.92 atatat CTLTYPE_INT, "cwm_burstsize",
1879 1.92 atatat SYSCTL_DESCR("Congestion Window Monitoring allowed "
1880 1.92 atatat "burst count in packets"),
1881 1.86 atatat NULL, 0, &tcp_cwm_burstsize, 0,
1882 1.86 atatat CTL_NET, pf, IPPROTO_TCP, TCPCTL_CWM_BURSTSIZE,
1883 1.86 atatat CTL_EOL);
1884 1.87 atatat sysctl_createv(clog, 0, NULL, NULL,
1885 1.87 atatat CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
1886 1.92 atatat CTLTYPE_INT, "ack_on_push",
1887 1.92 atatat SYSCTL_DESCR("Immediately return ACK when PSH is "
1888 1.92 atatat "received"),
1889 1.86 atatat NULL, 0, &tcp_ack_on_push, 0,
1890 1.86 atatat CTL_NET, pf, IPPROTO_TCP, TCPCTL_ACK_ON_PUSH, CTL_EOL);
1891 1.87 atatat sysctl_createv(clog, 0, NULL, NULL,
1892 1.87 atatat CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
1893 1.92 atatat CTLTYPE_INT, "keepidle",
1894 1.92 atatat SYSCTL_DESCR("Allowed connection idle ticks before a "
1895 1.92 atatat "keepalive probe is sent"),
1896 1.132 christos sysctl_tcp_keep, 0, &tcp_keepidle, 0,
1897 1.86 atatat CTL_NET, pf, IPPROTO_TCP, TCPCTL_KEEPIDLE, CTL_EOL);
1898 1.87 atatat sysctl_createv(clog, 0, NULL, NULL,
1899 1.87 atatat CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
1900 1.92 atatat CTLTYPE_INT, "keepintvl",
1901 1.92 atatat SYSCTL_DESCR("Ticks before next keepalive probe is sent"),
1902 1.132 christos sysctl_tcp_keep, 0, &tcp_keepintvl, 0,
1903 1.86 atatat CTL_NET, pf, IPPROTO_TCP, TCPCTL_KEEPINTVL, CTL_EOL);
1904 1.87 atatat sysctl_createv(clog, 0, NULL, NULL,
1905 1.87 atatat CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
1906 1.92 atatat CTLTYPE_INT, "keepcnt",
1907 1.92 atatat SYSCTL_DESCR("Number of keepalive probes to send"),
1908 1.132 christos sysctl_tcp_keep, 0, &tcp_keepcnt, 0,
1909 1.86 atatat CTL_NET, pf, IPPROTO_TCP, TCPCTL_KEEPCNT, CTL_EOL);
1910 1.87 atatat sysctl_createv(clog, 0, NULL, NULL,
1911 1.87 atatat CTLFLAG_PERMANENT|CTLFLAG_IMMEDIATE,
1912 1.92 atatat CTLTYPE_INT, "slowhz",
1913 1.92 atatat SYSCTL_DESCR("Keepalive ticks per second"),
1914 1.86 atatat NULL, PR_SLOWHZ, NULL, 0,
1915 1.86 atatat CTL_NET, pf, IPPROTO_TCP, TCPCTL_SLOWHZ, CTL_EOL);
1916 1.87 atatat sysctl_createv(clog, 0, NULL, NULL,
1917 1.87 atatat CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
1918 1.92 atatat CTLTYPE_INT, "log_refused",
1919 1.92 atatat SYSCTL_DESCR("Log refused TCP connections"),
1920 1.86 atatat NULL, 0, &tcp_log_refused, 0,
1921 1.86 atatat CTL_NET, pf, IPPROTO_TCP, TCPCTL_LOG_REFUSED, CTL_EOL);
1922 1.86 atatat #if 0 /* obsoleted */
1923 1.87 atatat sysctl_createv(clog, 0, NULL, NULL,
1924 1.87 atatat CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
1925 1.86 atatat CTLTYPE_INT, "rstratelimit", NULL,
1926 1.86 atatat NULL, 0, &tcp_rst_ratelim, 0,
1927 1.86 atatat CTL_NET, pf, IPPROTO_TCP, TCPCTL_RSTRATELIMIT, CTL_EOL);
1928 1.86 atatat #endif
1929 1.87 atatat sysctl_createv(clog, 0, NULL, NULL,
1930 1.87 atatat CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
1931 1.92 atatat CTLTYPE_INT, "rstppslimit",
1932 1.92 atatat SYSCTL_DESCR("Maximum number of RST packets to send "
1933 1.92 atatat "per second"),
1934 1.86 atatat NULL, 0, &tcp_rst_ppslim, 0,
1935 1.86 atatat CTL_NET, pf, IPPROTO_TCP, TCPCTL_RSTPPSLIMIT, CTL_EOL);
1936 1.87 atatat sysctl_createv(clog, 0, NULL, NULL,
1937 1.87 atatat CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
1938 1.92 atatat CTLTYPE_INT, "delack_ticks",
1939 1.92 atatat SYSCTL_DESCR("Number of ticks to delay sending an ACK"),
1940 1.86 atatat NULL, 0, &tcp_delack_ticks, 0,
1941 1.86 atatat CTL_NET, pf, IPPROTO_TCP, TCPCTL_DELACK_TICKS, CTL_EOL);
1942 1.87 atatat sysctl_createv(clog, 0, NULL, NULL,
1943 1.87 atatat CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
1944 1.92 atatat CTLTYPE_INT, "init_win_local",
1945 1.92 atatat SYSCTL_DESCR("Initial TCP window size (in segments)"),
1946 1.166 christos sysctl_tcp_init_win, 0, &tcp_init_win_local, 0,
1947 1.86 atatat CTL_NET, pf, IPPROTO_TCP, TCPCTL_INIT_WIN_LOCAL,
1948 1.86 atatat CTL_EOL);
1949 1.87 atatat sysctl_createv(clog, 0, NULL, NULL,
1950 1.87 atatat CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
1951 1.92 atatat CTLTYPE_STRUCT, "ident",
1952 1.92 atatat SYSCTL_DESCR("RFC1413 Identification Protocol lookups"),
1953 1.86 atatat sysctl_net_inet_tcp_ident, 0, NULL, sizeof(uid_t),
1954 1.86 atatat CTL_NET, pf, IPPROTO_TCP, TCPCTL_IDENT, CTL_EOL);
1955 1.93 thorpej sysctl_createv(clog, 0, NULL, NULL,
1956 1.93 thorpej CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
1957 1.93 thorpej CTLTYPE_INT, "do_loopback_cksum",
1958 1.93 thorpej SYSCTL_DESCR("Perform TCP checksum on loopback"),
1959 1.93 thorpej NULL, 0, &tcp_do_loopback_cksum, 0,
1960 1.93 thorpej CTL_NET, pf, IPPROTO_TCP, TCPCTL_LOOPBACKCKSUM,
1961 1.93 thorpej CTL_EOL);
1962 1.97 atatat sysctl_createv(clog, 0, NULL, NULL,
1963 1.97 atatat CTLFLAG_PERMANENT,
1964 1.100 atatat CTLTYPE_STRUCT, "pcblist",
1965 1.97 atatat SYSCTL_DESCR("TCP protocol control block list"),
1966 1.97 atatat sysctl_inpcblist, 0, &tcbtable, 0,
1967 1.97 atatat CTL_NET, pf, IPPROTO_TCP, CTL_CREATE,
1968 1.97 atatat CTL_EOL);
1969 1.132 christos sysctl_createv(clog, 0, NULL, NULL,
1970 1.132 christos CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
1971 1.132 christos CTLTYPE_INT, "keepinit",
1972 1.132 christos SYSCTL_DESCR("Ticks before initial tcp connection times out"),
1973 1.132 christos sysctl_tcp_keep, 0, &tcp_keepinit, 0,
1974 1.132 christos CTL_NET, pf, IPPROTO_TCP, CTL_CREATE, CTL_EOL);
1975 1.102 kurahone
1976 1.136 rmind /* TCP socket buffers auto-sizing nodes */
1977 1.136 rmind sysctl_createv(clog, 0, NULL, NULL,
1978 1.136 rmind CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
1979 1.136 rmind CTLTYPE_INT, "recvbuf_auto",
1980 1.136 rmind SYSCTL_DESCR("Enable automatic receive "
1981 1.136 rmind "buffer sizing (experimental)"),
1982 1.136 rmind NULL, 0, &tcp_do_autorcvbuf, 0,
1983 1.136 rmind CTL_NET, pf, IPPROTO_TCP, CTL_CREATE, CTL_EOL);
1984 1.136 rmind sysctl_createv(clog, 0, NULL, NULL,
1985 1.136 rmind CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
1986 1.136 rmind CTLTYPE_INT, "recvbuf_inc",
1987 1.136 rmind SYSCTL_DESCR("Incrementor step size of "
1988 1.136 rmind "automatic receive buffer"),
1989 1.136 rmind NULL, 0, &tcp_autorcvbuf_inc, 0,
1990 1.136 rmind CTL_NET, pf, IPPROTO_TCP, CTL_CREATE, CTL_EOL);
1991 1.136 rmind sysctl_createv(clog, 0, NULL, NULL,
1992 1.136 rmind CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
1993 1.136 rmind CTLTYPE_INT, "recvbuf_max",
1994 1.136 rmind SYSCTL_DESCR("Max size of automatic receive buffer"),
1995 1.136 rmind NULL, 0, &tcp_autorcvbuf_max, 0,
1996 1.136 rmind CTL_NET, pf, IPPROTO_TCP, CTL_CREATE, CTL_EOL);
1997 1.136 rmind
1998 1.136 rmind sysctl_createv(clog, 0, NULL, NULL,
1999 1.136 rmind CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
2000 1.136 rmind CTLTYPE_INT, "sendbuf_auto",
2001 1.136 rmind SYSCTL_DESCR("Enable automatic send "
2002 1.136 rmind "buffer sizing (experimental)"),
2003 1.136 rmind NULL, 0, &tcp_do_autosndbuf, 0,
2004 1.136 rmind CTL_NET, pf, IPPROTO_TCP, CTL_CREATE, CTL_EOL);
2005 1.136 rmind sysctl_createv(clog, 0, NULL, NULL,
2006 1.136 rmind CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
2007 1.136 rmind CTLTYPE_INT, "sendbuf_inc",
2008 1.136 rmind SYSCTL_DESCR("Incrementor step size of "
2009 1.136 rmind "automatic send buffer"),
2010 1.136 rmind NULL, 0, &tcp_autosndbuf_inc, 0,
2011 1.136 rmind CTL_NET, pf, IPPROTO_TCP, CTL_CREATE, CTL_EOL);
2012 1.136 rmind sysctl_createv(clog, 0, NULL, NULL,
2013 1.136 rmind CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
2014 1.136 rmind CTLTYPE_INT, "sendbuf_max",
2015 1.136 rmind SYSCTL_DESCR("Max size of automatic send buffer"),
2016 1.136 rmind NULL, 0, &tcp_autosndbuf_max, 0,
2017 1.136 rmind CTL_NET, pf, IPPROTO_TCP, CTL_CREATE, CTL_EOL);
2018 1.136 rmind
2019 1.128 rpaulo /* ECN subtree */
2020 1.128 rpaulo sysctl_createv(clog, 0, NULL, &ecn_node,
2021 1.128 rpaulo CTLFLAG_PERMANENT,
2022 1.128 rpaulo CTLTYPE_NODE, "ecn",
2023 1.128 rpaulo SYSCTL_DESCR("RFC3168 Explicit Congestion Notification"),
2024 1.128 rpaulo NULL, 0, NULL, 0,
2025 1.128 rpaulo CTL_NET, pf, IPPROTO_TCP, CTL_CREATE, CTL_EOL);
2026 1.128 rpaulo sysctl_createv(clog, 0, &ecn_node, NULL,
2027 1.120 rpaulo CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
2028 1.120 rpaulo CTLTYPE_INT, "enable",
2029 1.120 rpaulo SYSCTL_DESCR("Enable TCP Explicit Congestion "
2030 1.120 rpaulo "Notification"),
2031 1.128 rpaulo NULL, 0, &tcp_do_ecn, 0, CTL_CREATE, CTL_EOL);
2032 1.128 rpaulo sysctl_createv(clog, 0, &ecn_node, NULL,
2033 1.120 rpaulo CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
2034 1.120 rpaulo CTLTYPE_INT, "maxretries",
2035 1.120 rpaulo SYSCTL_DESCR("Number of times to retry ECN setup "
2036 1.120 rpaulo "before disabling ECN on the connection"),
2037 1.128 rpaulo NULL, 0, &tcp_ecn_maxretries, 0, CTL_CREATE, CTL_EOL);
2038 1.128 rpaulo
2039 1.102 kurahone /* SACK gets it's own little subtree. */
2040 1.102 kurahone sysctl_createv(clog, 0, NULL, &sack_node,
2041 1.102 kurahone CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
2042 1.102 kurahone CTLTYPE_INT, "enable",
2043 1.102 kurahone SYSCTL_DESCR("Enable RFC2018 Selective ACKnowledgement"),
2044 1.102 kurahone NULL, 0, &tcp_do_sack, 0,
2045 1.102 kurahone CTL_NET, pf, IPPROTO_TCP, TCPCTL_SACK, CTL_CREATE, CTL_EOL);
2046 1.102 kurahone sysctl_createv(clog, 0, NULL, &sack_node,
2047 1.102 kurahone CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
2048 1.102 kurahone CTLTYPE_INT, "maxholes",
2049 1.102 kurahone SYSCTL_DESCR("Maximum number of TCP SACK holes allowed per connection"),
2050 1.102 kurahone NULL, 0, &tcp_sack_tp_maxholes, 0,
2051 1.102 kurahone CTL_NET, pf, IPPROTO_TCP, TCPCTL_SACK, CTL_CREATE, CTL_EOL);
2052 1.102 kurahone sysctl_createv(clog, 0, NULL, &sack_node,
2053 1.102 kurahone CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
2054 1.102 kurahone CTLTYPE_INT, "globalmaxholes",
2055 1.102 kurahone SYSCTL_DESCR("Global maximum number of TCP SACK holes"),
2056 1.102 kurahone NULL, 0, &tcp_sack_globalmaxholes, 0,
2057 1.102 kurahone CTL_NET, pf, IPPROTO_TCP, TCPCTL_SACK, CTL_CREATE, CTL_EOL);
2058 1.102 kurahone sysctl_createv(clog, 0, NULL, &sack_node,
2059 1.102 kurahone CTLFLAG_PERMANENT,
2060 1.102 kurahone CTLTYPE_INT, "globalholes",
2061 1.102 kurahone SYSCTL_DESCR("Global number of TCP SACK holes"),
2062 1.102 kurahone NULL, 0, &tcp_sack_globalholes, 0,
2063 1.102 kurahone CTL_NET, pf, IPPROTO_TCP, TCPCTL_SACK, CTL_CREATE, CTL_EOL);
2064 1.107 elad
2065 1.107 elad sysctl_createv(clog, 0, NULL, NULL,
2066 1.107 elad CTLFLAG_PERMANENT,
2067 1.107 elad CTLTYPE_STRUCT, "stats",
2068 1.107 elad SYSCTL_DESCR("TCP statistics"),
2069 1.142 thorpej sysctl_net_inet_tcp_stats, 0, NULL, 0,
2070 1.107 elad CTL_NET, pf, IPPROTO_TCP, TCPCTL_STATS,
2071 1.107 elad CTL_EOL);
2072 1.159 dyoung sysctl_createv(clog, 0, NULL, NULL,
2073 1.159 dyoung CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
2074 1.159 dyoung CTLTYPE_INT, "local_by_rtt",
2075 1.159 dyoung SYSCTL_DESCR("Use RTT estimator to decide which hosts "
2076 1.159 dyoung "are local"),
2077 1.159 dyoung NULL, 0, &tcp_rttlocal, 0,
2078 1.159 dyoung CTL_NET, pf, IPPROTO_TCP, CTL_CREATE, CTL_EOL);
2079 1.109 rpaulo #ifdef TCP_DEBUG
2080 1.109 rpaulo sysctl_createv(clog, 0, NULL, NULL,
2081 1.109 rpaulo CTLFLAG_PERMANENT,
2082 1.109 rpaulo CTLTYPE_STRUCT, "debug",
2083 1.109 rpaulo SYSCTL_DESCR("TCP sockets debug information"),
2084 1.109 rpaulo NULL, 0, &tcp_debug, sizeof(tcp_debug),
2085 1.109 rpaulo CTL_NET, pf, IPPROTO_TCP, TCPCTL_DEBUG,
2086 1.109 rpaulo CTL_EOL);
2087 1.109 rpaulo sysctl_createv(clog, 0, NULL, NULL,
2088 1.109 rpaulo CTLFLAG_PERMANENT,
2089 1.109 rpaulo CTLTYPE_INT, "debx",
2090 1.110 rpaulo SYSCTL_DESCR("Number of TCP debug sockets messages"),
2091 1.109 rpaulo NULL, 0, &tcp_debx, sizeof(tcp_debx),
2092 1.109 rpaulo CTL_NET, pf, IPPROTO_TCP, TCPCTL_DEBX,
2093 1.109 rpaulo CTL_EOL);
2094 1.109 rpaulo #endif
2095 1.133 christos sysctl_createv(clog, 0, NULL, NULL,
2096 1.133 christos CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
2097 1.133 christos CTLTYPE_STRUCT, "drop",
2098 1.133 christos SYSCTL_DESCR("TCP drop connection"),
2099 1.133 christos sysctl_net_inet_tcp_drop, 0, NULL, 0,
2100 1.133 christos CTL_NET, pf, IPPROTO_TCP, TCPCTL_DROP, CTL_EOL);
2101 1.126 rpaulo sysctl_createv(clog, 0, NULL, NULL,
2102 1.126 rpaulo CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
2103 1.126 rpaulo CTLTYPE_INT, "iss_hash",
2104 1.126 rpaulo SYSCTL_DESCR("Enable RFC 1948 ISS by cryptographic "
2105 1.126 rpaulo "hash computation"),
2106 1.126 rpaulo NULL, 0, &tcp_do_rfc1948, sizeof(tcp_do_rfc1948),
2107 1.126 rpaulo CTL_NET, pf, IPPROTO_TCP, CTL_CREATE,
2108 1.126 rpaulo CTL_EOL);
2109 1.109 rpaulo
2110 1.127 yamt /* ABC subtree */
2111 1.127 yamt
2112 1.127 yamt sysctl_createv(clog, 0, NULL, &abc_node,
2113 1.127 yamt CTLFLAG_PERMANENT, CTLTYPE_NODE, "abc",
2114 1.127 yamt SYSCTL_DESCR("RFC3465 Appropriate Byte Counting (ABC)"),
2115 1.127 yamt NULL, 0, NULL, 0,
2116 1.127 yamt CTL_NET, pf, IPPROTO_TCP, CTL_CREATE, CTL_EOL);
2117 1.127 yamt sysctl_createv(clog, 0, &abc_node, NULL,
2118 1.127 yamt CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
2119 1.127 yamt CTLTYPE_INT, "enable",
2120 1.127 yamt SYSCTL_DESCR("Enable RFC3465 Appropriate Byte Counting"),
2121 1.127 yamt NULL, 0, &tcp_do_abc, 0, CTL_CREATE, CTL_EOL);
2122 1.127 yamt sysctl_createv(clog, 0, &abc_node, NULL,
2123 1.127 yamt CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
2124 1.127 yamt CTLTYPE_INT, "aggressive",
2125 1.127 yamt SYSCTL_DESCR("1: L=2*SMSS 0: L=1*SMSS"),
2126 1.127 yamt NULL, 0, &tcp_abc_aggressive, 0, CTL_CREATE, CTL_EOL);
2127 1.159 dyoung
2128 1.159 dyoung /* MSL tuning subtree */
2129 1.159 dyoung
2130 1.159 dyoung sysctl_createv(clog, 0, NULL, &mslt_node,
2131 1.159 dyoung CTLFLAG_PERMANENT, CTLTYPE_NODE, "mslt",
2132 1.159 dyoung SYSCTL_DESCR("MSL Tuning for TIME_WAIT truncation"),
2133 1.159 dyoung NULL, 0, NULL, 0,
2134 1.159 dyoung CTL_NET, pf, IPPROTO_TCP, CTL_CREATE, CTL_EOL);
2135 1.159 dyoung sysctl_createv(clog, 0, &mslt_node, NULL,
2136 1.159 dyoung CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
2137 1.159 dyoung CTLTYPE_INT, "enable",
2138 1.159 dyoung SYSCTL_DESCR("Enable TIME_WAIT truncation"),
2139 1.159 dyoung NULL, 0, &tcp_msl_enable, 0, CTL_CREATE, CTL_EOL);
2140 1.159 dyoung sysctl_createv(clog, 0, &mslt_node, NULL,
2141 1.159 dyoung CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
2142 1.159 dyoung CTLTYPE_INT, "loopback",
2143 1.159 dyoung SYSCTL_DESCR("MSL value to use for loopback connections"),
2144 1.159 dyoung NULL, 0, &tcp_msl_loop, 0, CTL_CREATE, CTL_EOL);
2145 1.159 dyoung sysctl_createv(clog, 0, &mslt_node, NULL,
2146 1.159 dyoung CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
2147 1.159 dyoung CTLTYPE_INT, "local",
2148 1.159 dyoung SYSCTL_DESCR("MSL value to use for local connections"),
2149 1.159 dyoung NULL, 0, &tcp_msl_local, 0, CTL_CREATE, CTL_EOL);
2150 1.159 dyoung sysctl_createv(clog, 0, &mslt_node, NULL,
2151 1.159 dyoung CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
2152 1.159 dyoung CTLTYPE_INT, "remote",
2153 1.159 dyoung SYSCTL_DESCR("MSL value to use for remote connections"),
2154 1.159 dyoung NULL, 0, &tcp_msl_remote, 0, CTL_CREATE, CTL_EOL);
2155 1.159 dyoung sysctl_createv(clog, 0, &mslt_node, NULL,
2156 1.159 dyoung CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
2157 1.159 dyoung CTLTYPE_INT, "remote_threshold",
2158 1.159 dyoung SYSCTL_DESCR("RTT estimate value to promote local to remote"),
2159 1.159 dyoung NULL, 0, &tcp_msl_remote_threshold, 0, CTL_CREATE, CTL_EOL);
2160 1.159 dyoung
2161 1.159 dyoung /* vestigial TIME_WAIT tuning subtree */
2162 1.159 dyoung
2163 1.159 dyoung sysctl_createv(clog, 0, NULL, &vtw_node,
2164 1.159 dyoung CTLFLAG_PERMANENT, CTLTYPE_NODE, "vtw",
2165 1.159 dyoung SYSCTL_DESCR("Tuning for Vestigial TIME_WAIT"),
2166 1.159 dyoung NULL, 0, NULL, 0,
2167 1.159 dyoung CTL_NET, pf, IPPROTO_TCP, CTL_CREATE, CTL_EOL);
2168 1.159 dyoung sysctl_createv(clog, 0, &vtw_node, NULL,
2169 1.159 dyoung CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
2170 1.159 dyoung CTLTYPE_INT, "enable",
2171 1.159 dyoung SYSCTL_DESCR("Enable Vestigial TIME_WAIT"),
2172 1.160 dyoung sysctl_tcp_vtw_enable, 0,
2173 1.159 dyoung (pf == AF_INET) ? &tcp4_vtw_enable : &tcp6_vtw_enable,
2174 1.159 dyoung 0, CTL_CREATE, CTL_EOL);
2175 1.159 dyoung sysctl_createv(clog, 0, &vtw_node, NULL,
2176 1.159 dyoung CTLFLAG_PERMANENT|CTLFLAG_READONLY,
2177 1.159 dyoung CTLTYPE_INT, "entries",
2178 1.159 dyoung SYSCTL_DESCR("Maximum number of vestigial TIME_WAIT entries"),
2179 1.159 dyoung NULL, 0, &tcp_vtw_entries, 0, CTL_CREATE, CTL_EOL);
2180 1.86 atatat }
2181 1.86 atatat
2182 1.157 pooka void
2183 1.157 pooka tcp_usrreq_init(void)
2184 1.76 christos {
2185 1.76 christos
2186 1.157 pooka #ifdef INET
2187 1.157 pooka sysctl_net_inet_tcp_setup2(NULL, PF_INET, "inet", "tcp");
2188 1.157 pooka #endif
2189 1.86 atatat #ifdef INET6
2190 1.157 pooka sysctl_net_inet_tcp_setup2(NULL, PF_INET6, "inet6", "tcp6");
2191 1.157 pooka #endif
2192 1.1 cgd }
2193 1.172 rmind
2194 1.174 rmind PR_WRAP_USRREQS(tcp)
2195 1.174 rmind #define tcp_attach tcp_attach_wrapper
2196 1.174 rmind #define tcp_detach tcp_detach_wrapper
2197 1.172 rmind #define tcp_usrreq tcp_usrreq_wrapper
2198 1.172 rmind
2199 1.172 rmind const struct pr_usrreqs tcp_usrreqs = {
2200 1.173 rmind .pr_attach = tcp_attach,
2201 1.173 rmind .pr_detach = tcp_detach,
2202 1.172 rmind .pr_generic = tcp_usrreq,
2203 1.172 rmind };
2204