Now available: The Design and Implementation of the FreeBSD Operating System (Second Edition)
[ source navigation ] [ diff markup ] [ identifier search ] [ freetext search ] [ file search ] [ list types ] [ track identifier ]
FreeBSD/Linux Kernel Cross Reference
sys/netinet/tcp_usrreq.c
Version:
- FREEBSD - FREEBSD-13-STABLE - FREEBSD-13-0 - FREEBSD-12-STABLE - FREEBSD-12-0 - FREEBSD-11-STABLE - FREEBSD-11-0 - FREEBSD-10-STABLE - FREEBSD-10-0 - FREEBSD-9-STABLE - FREEBSD-9-0 - FREEBSD-8-STABLE - FREEBSD-8-0 - FREEBSD-7-STABLE - FREEBSD-7-0 - FREEBSD-6-STABLE - FREEBSD-6-0 - FREEBSD-5-STABLE - FREEBSD-5-0 - FREEBSD-4-STABLE - FREEBSD-3-STABLE - FREEBSD22 - l41 - OPENBSD - linux-2.6 - MK84 - PLAN9 - xnu-8792
SearchContext: - none - 3 - 10
SearchContext: - none - 3 - 10
1 /*- 2 * Copyright (c) 1982, 1986, 1988, 1993 3 * The Regents of the University of California. 4 * Copyright (c) 2006-2007 Robert N. M. Watson 5 * Copyright (c) 2010-2011 Juniper Networks, Inc. 6 * All rights reserved. 7 * 8 * Portions of this software were developed by Robert N. M. Watson under 9 * contract to Juniper Networks, Inc. 10 * 11 * Redistribution and use in source and binary forms, with or without 12 * modification, are permitted provided that the following conditions 13 * are met: 14 * 1. Redistributions of source code must retain the above copyright 15 * notice, this list of conditions and the following disclaimer. 16 * 2. Redistributions in binary form must reproduce the above copyright 17 * notice, this list of conditions and the following disclaimer in the 18 * documentation and/or other materials provided with the distribution. 19 * 4. Neither the name of the University nor the names of its contributors 20 * may be used to endorse or promote products derived from this software 21 * without specific prior written permission. 22 * 23 * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND 24 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 25 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 26 * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE 27 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 28 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS 29 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 30 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 31 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY 32 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 33 * SUCH DAMAGE. 34 * 35 * From: @(#)tcp_usrreq.c 8.2 (Berkeley) 1/3/94 36 */ 37 38 #include <sys/cdefs.h> 39 __FBSDID("$FreeBSD$"); 40 41 #include "opt_ddb.h" 42 #include "opt_inet.h" 43 #include "opt_inet6.h" 44 #include "opt_tcpdebug.h" 45 46 #include <sys/param.h> 47 #include <sys/systm.h> 48 #include <sys/limits.h> 49 #include <sys/malloc.h> 50 #include <sys/kernel.h> 51 #include <sys/sysctl.h> 52 #include <sys/mbuf.h> 53 #ifdef INET6 54 #include <sys/domain.h> 55 #endif /* INET6 */ 56 #include <sys/socket.h> 57 #include <sys/socketvar.h> 58 #include <sys/protosw.h> 59 #include <sys/proc.h> 60 #include <sys/jail.h> 61 62 #ifdef DDB 63 #include <ddb/ddb.h> 64 #endif 65 66 #include <net/if.h> 67 #include <net/route.h> 68 #include <net/vnet.h> 69 70 #include <netinet/cc.h> 71 #include <netinet/in.h> 72 #include <netinet/in_pcb.h> 73 #include <netinet/in_systm.h> 74 #include <netinet/in_var.h> 75 #include <netinet/ip_var.h> 76 #ifdef INET6 77 #include <netinet/ip6.h> 78 #include <netinet6/in6_pcb.h> 79 #include <netinet6/ip6_var.h> 80 #include <netinet6/scope6_var.h> 81 #endif 82 #include <netinet/tcp_fsm.h> 83 #include <netinet/tcp_seq.h> 84 #include <netinet/tcp_timer.h> 85 #include <netinet/tcp_var.h> 86 #include <netinet/tcpip.h> 87 #ifdef TCPDEBUG 88 #include <netinet/tcp_debug.h> 89 #endif 90 #ifdef TCP_OFFLOAD 91 #include <netinet/tcp_offload.h> 92 #endif 93 94 /* 95 * TCP protocol interface to socket abstraction. 96 */ 97 static int tcp_attach(struct socket *); 98 #ifdef INET 99 static int tcp_connect(struct tcpcb *, struct sockaddr *, 100 struct thread *td); 101 #endif /* INET */ 102 #ifdef INET6 103 static int tcp6_connect(struct tcpcb *, struct sockaddr *, 104 struct thread *td); 105 #endif /* INET6 */ 106 static void tcp_disconnect(struct tcpcb *); 107 static void tcp_usrclosed(struct tcpcb *); 108 static void tcp_fill_info(struct tcpcb *, struct tcp_info *); 109 110 #ifdef TCPDEBUG 111 #define TCPDEBUG0 int ostate = 0 112 #define TCPDEBUG1() ostate = tp ? tp->t_state : 0 113 #define TCPDEBUG2(req) if (tp && (so->so_options & SO_DEBUG)) \ 114 tcp_trace(TA_USER, ostate, tp, 0, 0, req) 115 #else 116 #define TCPDEBUG0 117 #define TCPDEBUG1() 118 #define TCPDEBUG2(req) 119 #endif 120 121 /* 122 * TCP attaches to socket via pru_attach(), reserving space, 123 * and an internet control block. 124 */ 125 static int 126 tcp_usr_attach(struct socket *so, int proto, struct thread *td) 127 { 128 struct inpcb *inp; 129 struct tcpcb *tp = NULL; 130 int error; 131 TCPDEBUG0; 132 133 inp = sotoinpcb(so); 134 KASSERT(inp == NULL, ("tcp_usr_attach: inp != NULL")); 135 TCPDEBUG1(); 136 137 error = tcp_attach(so); 138 if (error) 139 goto out; 140 141 if ((so->so_options & SO_LINGER) && so->so_linger == 0) 142 so->so_linger = TCP_LINGERTIME; 143 144 inp = sotoinpcb(so); 145 tp = intotcpcb(inp); 146 out: 147 TCPDEBUG2(PRU_ATTACH); 148 return error; 149 } 150 151 /* 152 * tcp_detach is called when the socket layer loses its final reference 153 * to the socket, be it a file descriptor reference, a reference from TCP, 154 * etc. At this point, there is only one case in which we will keep around 155 * inpcb state: time wait. 156 * 157 * This function can probably be re-absorbed back into tcp_usr_detach() now 158 * that there is a single detach path. 159 */ 160 static void 161 tcp_detach(struct socket *so, struct inpcb *inp) 162 { 163 struct tcpcb *tp; 164 165 INP_INFO_WLOCK_ASSERT(&V_tcbinfo); 166 INP_WLOCK_ASSERT(inp); 167 168 KASSERT(so->so_pcb == inp, ("tcp_detach: so_pcb != inp")); 169 KASSERT(inp->inp_socket == so, ("tcp_detach: inp_socket != so")); 170 171 tp = intotcpcb(inp); 172 173 if (inp->inp_flags & INP_TIMEWAIT) { 174 /* 175 * There are two cases to handle: one in which the time wait 176 * state is being discarded (INP_DROPPED), and one in which 177 * this connection will remain in timewait. In the former, 178 * it is time to discard all state (except tcptw, which has 179 * already been discarded by the timewait close code, which 180 * should be further up the call stack somewhere). In the 181 * latter case, we detach from the socket, but leave the pcb 182 * present until timewait ends. 183 * 184 * XXXRW: Would it be cleaner to free the tcptw here? 185 */ 186 if (inp->inp_flags & INP_DROPPED) { 187 KASSERT(tp == NULL, ("tcp_detach: INP_TIMEWAIT && " 188 "INP_DROPPED && tp != NULL")); 189 in_pcbdetach(inp); 190 in_pcbfree(inp); 191 } else { 192 in_pcbdetach(inp); 193 INP_WUNLOCK(inp); 194 } 195 } else { 196 /* 197 * If the connection is not in timewait, we consider two 198 * two conditions: one in which no further processing is 199 * necessary (dropped || embryonic), and one in which TCP is 200 * not yet done, but no longer requires the socket, so the 201 * pcb will persist for the time being. 202 * 203 * XXXRW: Does the second case still occur? 204 */ 205 if (inp->inp_flags & INP_DROPPED || 206 tp->t_state < TCPS_SYN_SENT) { 207 tcp_discardcb(tp); 208 in_pcbdetach(inp); 209 in_pcbfree(inp); 210 } else { 211 in_pcbdetach(inp); 212 INP_WUNLOCK(inp); 213 } 214 } 215 } 216 217 /* 218 * pru_detach() detaches the TCP protocol from the socket. 219 * If the protocol state is non-embryonic, then can't 220 * do this directly: have to initiate a pru_disconnect(), 221 * which may finish later; embryonic TCB's can just 222 * be discarded here. 223 */ 224 static void 225 tcp_usr_detach(struct socket *so) 226 { 227 struct inpcb *inp; 228 229 inp = sotoinpcb(so); 230 KASSERT(inp != NULL, ("tcp_usr_detach: inp == NULL")); 231 INP_INFO_WLOCK(&V_tcbinfo); 232 INP_WLOCK(inp); 233 KASSERT(inp->inp_socket != NULL, 234 ("tcp_usr_detach: inp_socket == NULL")); 235 tcp_detach(so, inp); 236 INP_INFO_WUNLOCK(&V_tcbinfo); 237 } 238 239 #ifdef INET 240 /* 241 * Give the socket an address. 242 */ 243 static int 244 tcp_usr_bind(struct socket *so, struct sockaddr *nam, struct thread *td) 245 { 246 int error = 0; 247 struct inpcb *inp; 248 struct tcpcb *tp = NULL; 249 struct sockaddr_in *sinp; 250 251 sinp = (struct sockaddr_in *)nam; 252 if (nam->sa_len != sizeof (*sinp)) 253 return (EINVAL); 254 /* 255 * Must check for multicast addresses and disallow binding 256 * to them. 257 */ 258 if (sinp->sin_family == AF_INET && 259 IN_MULTICAST(ntohl(sinp->sin_addr.s_addr))) 260 return (EAFNOSUPPORT); 261 262 TCPDEBUG0; 263 inp = sotoinpcb(so); 264 KASSERT(inp != NULL, ("tcp_usr_bind: inp == NULL")); 265 INP_WLOCK(inp); 266 if (inp->inp_flags & (INP_TIMEWAIT | INP_DROPPED)) { 267 error = EINVAL; 268 goto out; 269 } 270 tp = intotcpcb(inp); 271 TCPDEBUG1(); 272 INP_HASH_WLOCK(&V_tcbinfo); 273 error = in_pcbbind(inp, nam, td->td_ucred); 274 INP_HASH_WUNLOCK(&V_tcbinfo); 275 out: 276 TCPDEBUG2(PRU_BIND); 277 INP_WUNLOCK(inp); 278 279 return (error); 280 } 281 #endif /* INET */ 282 283 #ifdef INET6 284 static int 285 tcp6_usr_bind(struct socket *so, struct sockaddr *nam, struct thread *td) 286 { 287 int error = 0; 288 struct inpcb *inp; 289 struct tcpcb *tp = NULL; 290 struct sockaddr_in6 *sin6p; 291 292 sin6p = (struct sockaddr_in6 *)nam; 293 if (nam->sa_len != sizeof (*sin6p)) 294 return (EINVAL); 295 /* 296 * Must check for multicast addresses and disallow binding 297 * to them. 298 */ 299 if (sin6p->sin6_family == AF_INET6 && 300 IN6_IS_ADDR_MULTICAST(&sin6p->sin6_addr)) 301 return (EAFNOSUPPORT); 302 303 TCPDEBUG0; 304 inp = sotoinpcb(so); 305 KASSERT(inp != NULL, ("tcp6_usr_bind: inp == NULL")); 306 INP_WLOCK(inp); 307 if (inp->inp_flags & (INP_TIMEWAIT | INP_DROPPED)) { 308 error = EINVAL; 309 goto out; 310 } 311 tp = intotcpcb(inp); 312 TCPDEBUG1(); 313 INP_HASH_WLOCK(&V_tcbinfo); 314 inp->inp_vflag &= ~INP_IPV4; 315 inp->inp_vflag |= INP_IPV6; 316 #ifdef INET 317 if ((inp->inp_flags & IN6P_IPV6_V6ONLY) == 0) { 318 if (IN6_IS_ADDR_UNSPECIFIED(&sin6p->sin6_addr)) 319 inp->inp_vflag |= INP_IPV4; 320 else if (IN6_IS_ADDR_V4MAPPED(&sin6p->sin6_addr)) { 321 struct sockaddr_in sin; 322 323 in6_sin6_2_sin(&sin, sin6p); 324 inp->inp_vflag |= INP_IPV4; 325 inp->inp_vflag &= ~INP_IPV6; 326 error = in_pcbbind(inp, (struct sockaddr *)&sin, 327 td->td_ucred); 328 INP_HASH_WUNLOCK(&V_tcbinfo); 329 goto out; 330 } 331 } 332 #endif 333 error = in6_pcbbind(inp, nam, td->td_ucred); 334 INP_HASH_WUNLOCK(&V_tcbinfo); 335 out: 336 TCPDEBUG2(PRU_BIND); 337 INP_WUNLOCK(inp); 338 return (error); 339 } 340 #endif /* INET6 */ 341 342 #ifdef INET 343 /* 344 * Prepare to accept connections. 345 */ 346 static int 347 tcp_usr_listen(struct socket *so, int backlog, struct thread *td) 348 { 349 int error = 0; 350 struct inpcb *inp; 351 struct tcpcb *tp = NULL; 352 353 TCPDEBUG0; 354 inp = sotoinpcb(so); 355 KASSERT(inp != NULL, ("tcp_usr_listen: inp == NULL")); 356 INP_WLOCK(inp); 357 if (inp->inp_flags & (INP_TIMEWAIT | INP_DROPPED)) { 358 error = EINVAL; 359 goto out; 360 } 361 tp = intotcpcb(inp); 362 TCPDEBUG1(); 363 SOCK_LOCK(so); 364 error = solisten_proto_check(so); 365 INP_HASH_WLOCK(&V_tcbinfo); 366 if (error == 0 && inp->inp_lport == 0) 367 error = in_pcbbind(inp, (struct sockaddr *)0, td->td_ucred); 368 INP_HASH_WUNLOCK(&V_tcbinfo); 369 if (error == 0) { 370 tp->t_state = TCPS_LISTEN; 371 solisten_proto(so, backlog); 372 #ifdef TCP_OFFLOAD 373 if ((so->so_options & SO_NO_OFFLOAD) == 0) 374 tcp_offload_listen_start(tp); 375 #endif 376 } 377 SOCK_UNLOCK(so); 378 379 out: 380 TCPDEBUG2(PRU_LISTEN); 381 INP_WUNLOCK(inp); 382 return (error); 383 } 384 #endif /* INET */ 385 386 #ifdef INET6 387 static int 388 tcp6_usr_listen(struct socket *so, int backlog, struct thread *td) 389 { 390 int error = 0; 391 struct inpcb *inp; 392 struct tcpcb *tp = NULL; 393 394 TCPDEBUG0; 395 inp = sotoinpcb(so); 396 KASSERT(inp != NULL, ("tcp6_usr_listen: inp == NULL")); 397 INP_WLOCK(inp); 398 if (inp->inp_flags & (INP_TIMEWAIT | INP_DROPPED)) { 399 error = EINVAL; 400 goto out; 401 } 402 tp = intotcpcb(inp); 403 TCPDEBUG1(); 404 SOCK_LOCK(so); 405 error = solisten_proto_check(so); 406 INP_HASH_WLOCK(&V_tcbinfo); 407 if (error == 0 && inp->inp_lport == 0) { 408 inp->inp_vflag &= ~INP_IPV4; 409 if ((inp->inp_flags & IN6P_IPV6_V6ONLY) == 0) 410 inp->inp_vflag |= INP_IPV4; 411 error = in6_pcbbind(inp, (struct sockaddr *)0, td->td_ucred); 412 } 413 INP_HASH_WUNLOCK(&V_tcbinfo); 414 if (error == 0) { 415 tp->t_state = TCPS_LISTEN; 416 solisten_proto(so, backlog); 417 #ifdef TCP_OFFLOAD 418 if ((so->so_options & SO_NO_OFFLOAD) == 0) 419 tcp_offload_listen_start(tp); 420 #endif 421 } 422 SOCK_UNLOCK(so); 423 424 out: 425 TCPDEBUG2(PRU_LISTEN); 426 INP_WUNLOCK(inp); 427 return (error); 428 } 429 #endif /* INET6 */ 430 431 #ifdef INET 432 /* 433 * Initiate connection to peer. 434 * Create a template for use in transmissions on this connection. 435 * Enter SYN_SENT state, and mark socket as connecting. 436 * Start keep-alive timer, and seed output sequence space. 437 * Send initial segment on connection. 438 */ 439 static int 440 tcp_usr_connect(struct socket *so, struct sockaddr *nam, struct thread *td) 441 { 442 int error = 0; 443 struct inpcb *inp; 444 struct tcpcb *tp = NULL; 445 struct sockaddr_in *sinp; 446 447 sinp = (struct sockaddr_in *)nam; 448 if (nam->sa_len != sizeof (*sinp)) 449 return (EINVAL); 450 /* 451 * Must disallow TCP ``connections'' to multicast addresses. 452 */ 453 if (sinp->sin_family == AF_INET 454 && IN_MULTICAST(ntohl(sinp->sin_addr.s_addr))) 455 return (EAFNOSUPPORT); 456 if ((error = prison_remote_ip4(td->td_ucred, &sinp->sin_addr)) != 0) 457 return (error); 458 459 TCPDEBUG0; 460 inp = sotoinpcb(so); 461 KASSERT(inp != NULL, ("tcp_usr_connect: inp == NULL")); 462 INP_WLOCK(inp); 463 if (inp->inp_flags & (INP_TIMEWAIT | INP_DROPPED)) { 464 error = EINVAL; 465 goto out; 466 } 467 tp = intotcpcb(inp); 468 TCPDEBUG1(); 469 if ((error = tcp_connect(tp, nam, td)) != 0) 470 goto out; 471 #ifdef TCP_OFFLOAD 472 if (registered_toedevs > 0 && 473 (so->so_options & SO_NO_OFFLOAD) == 0 && 474 (error = tcp_offload_connect(so, nam)) == 0) 475 goto out; 476 #endif 477 tcp_timer_activate(tp, TT_KEEP, TP_KEEPINIT(tp)); 478 error = tcp_output(tp); 479 out: 480 TCPDEBUG2(PRU_CONNECT); 481 INP_WUNLOCK(inp); 482 return (error); 483 } 484 #endif /* INET */ 485 486 #ifdef INET6 487 static int 488 tcp6_usr_connect(struct socket *so, struct sockaddr *nam, struct thread *td) 489 { 490 int error = 0; 491 struct inpcb *inp; 492 struct tcpcb *tp = NULL; 493 struct sockaddr_in6 *sin6p; 494 495 TCPDEBUG0; 496 497 sin6p = (struct sockaddr_in6 *)nam; 498 if (nam->sa_len != sizeof (*sin6p)) 499 return (EINVAL); 500 /* 501 * Must disallow TCP ``connections'' to multicast addresses. 502 */ 503 if (sin6p->sin6_family == AF_INET6 504 && IN6_IS_ADDR_MULTICAST(&sin6p->sin6_addr)) 505 return (EAFNOSUPPORT); 506 507 inp = sotoinpcb(so); 508 KASSERT(inp != NULL, ("tcp6_usr_connect: inp == NULL")); 509 INP_WLOCK(inp); 510 if (inp->inp_flags & (INP_TIMEWAIT | INP_DROPPED)) { 511 error = EINVAL; 512 goto out; 513 } 514 tp = intotcpcb(inp); 515 TCPDEBUG1(); 516 #ifdef INET 517 /* 518 * XXXRW: Some confusion: V4/V6 flags relate to binding, and 519 * therefore probably require the hash lock, which isn't held here. 520 * Is this a significant problem? 521 */ 522 if (IN6_IS_ADDR_V4MAPPED(&sin6p->sin6_addr)) { 523 struct sockaddr_in sin; 524 525 if ((inp->inp_flags & IN6P_IPV6_V6ONLY) != 0) { 526 error = EINVAL; 527 goto out; 528 } 529 530 in6_sin6_2_sin(&sin, sin6p); 531 inp->inp_vflag |= INP_IPV4; 532 inp->inp_vflag &= ~INP_IPV6; 533 if ((error = prison_remote_ip4(td->td_ucred, 534 &sin.sin_addr)) != 0) 535 goto out; 536 if ((error = tcp_connect(tp, (struct sockaddr *)&sin, td)) != 0) 537 goto out; 538 #ifdef TCP_OFFLOAD 539 if (registered_toedevs > 0 && 540 (so->so_options & SO_NO_OFFLOAD) == 0 && 541 (error = tcp_offload_connect(so, nam)) == 0) 542 goto out; 543 #endif 544 error = tcp_output(tp); 545 goto out; 546 } 547 #endif 548 inp->inp_vflag &= ~INP_IPV4; 549 inp->inp_vflag |= INP_IPV6; 550 inp->inp_inc.inc_flags |= INC_ISIPV6; 551 if ((error = prison_remote_ip6(td->td_ucred, &sin6p->sin6_addr)) != 0) 552 goto out; 553 if ((error = tcp6_connect(tp, nam, td)) != 0) 554 goto out; 555 #ifdef TCP_OFFLOAD 556 if (registered_toedevs > 0 && 557 (so->so_options & SO_NO_OFFLOAD) == 0 && 558 (error = tcp_offload_connect(so, nam)) == 0) 559 goto out; 560 #endif 561 tcp_timer_activate(tp, TT_KEEP, TP_KEEPINIT(tp)); 562 error = tcp_output(tp); 563 564 out: 565 TCPDEBUG2(PRU_CONNECT); 566 INP_WUNLOCK(inp); 567 return (error); 568 } 569 #endif /* INET6 */ 570 571 /* 572 * Initiate disconnect from peer. 573 * If connection never passed embryonic stage, just drop; 574 * else if don't need to let data drain, then can just drop anyways, 575 * else have to begin TCP shutdown process: mark socket disconnecting, 576 * drain unread data, state switch to reflect user close, and 577 * send segment (e.g. FIN) to peer. Socket will be really disconnected 578 * when peer sends FIN and acks ours. 579 * 580 * SHOULD IMPLEMENT LATER PRU_CONNECT VIA REALLOC TCPCB. 581 */ 582 static int 583 tcp_usr_disconnect(struct socket *so) 584 { 585 struct inpcb *inp; 586 struct tcpcb *tp = NULL; 587 int error = 0; 588 589 TCPDEBUG0; 590 INP_INFO_WLOCK(&V_tcbinfo); 591 inp = sotoinpcb(so); 592 KASSERT(inp != NULL, ("tcp_usr_disconnect: inp == NULL")); 593 INP_WLOCK(inp); 594 if (inp->inp_flags & (INP_TIMEWAIT | INP_DROPPED)) { 595 error = ECONNRESET; 596 goto out; 597 } 598 tp = intotcpcb(inp); 599 TCPDEBUG1(); 600 tcp_disconnect(tp); 601 out: 602 TCPDEBUG2(PRU_DISCONNECT); 603 INP_WUNLOCK(inp); 604 INP_INFO_WUNLOCK(&V_tcbinfo); 605 return (error); 606 } 607 608 #ifdef INET 609 /* 610 * Accept a connection. Essentially all the work is done at higher levels; 611 * just return the address of the peer, storing through addr. 612 * 613 * The rationale for acquiring the tcbinfo lock here is somewhat complicated, 614 * and is described in detail in the commit log entry for r175612. Acquiring 615 * it delays an accept(2) racing with sonewconn(), which inserts the socket 616 * before the inpcb address/port fields are initialized. A better fix would 617 * prevent the socket from being placed in the listen queue until all fields 618 * are fully initialized. 619 */ 620 static int 621 tcp_usr_accept(struct socket *so, struct sockaddr **nam) 622 { 623 int error = 0; 624 struct inpcb *inp = NULL; 625 struct tcpcb *tp = NULL; 626 struct in_addr addr; 627 in_port_t port = 0; 628 TCPDEBUG0; 629 630 if (so->so_state & SS_ISDISCONNECTED) 631 return (ECONNABORTED); 632 633 inp = sotoinpcb(so); 634 KASSERT(inp != NULL, ("tcp_usr_accept: inp == NULL")); 635 INP_INFO_RLOCK(&V_tcbinfo); 636 INP_WLOCK(inp); 637 if (inp->inp_flags & (INP_TIMEWAIT | INP_DROPPED)) { 638 error = ECONNABORTED; 639 goto out; 640 } 641 tp = intotcpcb(inp); 642 TCPDEBUG1(); 643 644 /* 645 * We inline in_getpeeraddr and COMMON_END here, so that we can 646 * copy the data of interest and defer the malloc until after we 647 * release the lock. 648 */ 649 port = inp->inp_fport; 650 addr = inp->inp_faddr; 651 652 out: 653 TCPDEBUG2(PRU_ACCEPT); 654 INP_WUNLOCK(inp); 655 INP_INFO_RUNLOCK(&V_tcbinfo); 656 if (error == 0) 657 *nam = in_sockaddr(port, &addr); 658 return error; 659 } 660 #endif /* INET */ 661 662 #ifdef INET6 663 static int 664 tcp6_usr_accept(struct socket *so, struct sockaddr **nam) 665 { 666 struct inpcb *inp = NULL; 667 int error = 0; 668 struct tcpcb *tp = NULL; 669 struct in_addr addr; 670 struct in6_addr addr6; 671 in_port_t port = 0; 672 int v4 = 0; 673 TCPDEBUG0; 674 675 if (so->so_state & SS_ISDISCONNECTED) 676 return (ECONNABORTED); 677 678 inp = sotoinpcb(so); 679 KASSERT(inp != NULL, ("tcp6_usr_accept: inp == NULL")); 680 INP_INFO_RLOCK(&V_tcbinfo); 681 INP_WLOCK(inp); 682 if (inp->inp_flags & (INP_TIMEWAIT | INP_DROPPED)) { 683 error = ECONNABORTED; 684 goto out; 685 } 686 tp = intotcpcb(inp); 687 TCPDEBUG1(); 688 689 /* 690 * We inline in6_mapped_peeraddr and COMMON_END here, so that we can 691 * copy the data of interest and defer the malloc until after we 692 * release the lock. 693 */ 694 if (inp->inp_vflag & INP_IPV4) { 695 v4 = 1; 696 port = inp->inp_fport; 697 addr = inp->inp_faddr; 698 } else { 699 port = inp->inp_fport; 700 addr6 = inp->in6p_faddr; 701 } 702 703 out: 704 TCPDEBUG2(PRU_ACCEPT); 705 INP_WUNLOCK(inp); 706 INP_INFO_RUNLOCK(&V_tcbinfo); 707 if (error == 0) { 708 if (v4) 709 *nam = in6_v4mapsin6_sockaddr(port, &addr); 710 else 711 *nam = in6_sockaddr(port, &addr6); 712 } 713 return error; 714 } 715 #endif /* INET6 */ 716 717 /* 718 * Mark the connection as being incapable of further output. 719 */ 720 static int 721 tcp_usr_shutdown(struct socket *so) 722 { 723 int error = 0; 724 struct inpcb *inp; 725 struct tcpcb *tp = NULL; 726 727 TCPDEBUG0; 728 INP_INFO_WLOCK(&V_tcbinfo); 729 inp = sotoinpcb(so); 730 KASSERT(inp != NULL, ("inp == NULL")); 731 INP_WLOCK(inp); 732 if (inp->inp_flags & (INP_TIMEWAIT | INP_DROPPED)) { 733 error = ECONNRESET; 734 goto out; 735 } 736 tp = intotcpcb(inp); 737 TCPDEBUG1(); 738 socantsendmore(so); 739 tcp_usrclosed(tp); 740 if (!(inp->inp_flags & INP_DROPPED)) 741 error = tcp_output(tp); 742 743 out: 744 TCPDEBUG2(PRU_SHUTDOWN); 745 INP_WUNLOCK(inp); 746 INP_INFO_WUNLOCK(&V_tcbinfo); 747 748 return (error); 749 } 750 751 /* 752 * After a receive, possibly send window update to peer. 753 */ 754 static int 755 tcp_usr_rcvd(struct socket *so, int flags) 756 { 757 struct inpcb *inp; 758 struct tcpcb *tp = NULL; 759 int error = 0; 760 761 TCPDEBUG0; 762 inp = sotoinpcb(so); 763 KASSERT(inp != NULL, ("tcp_usr_rcvd: inp == NULL")); 764 INP_WLOCK(inp); 765 if (inp->inp_flags & (INP_TIMEWAIT | INP_DROPPED)) { 766 error = ECONNRESET; 767 goto out; 768 } 769 tp = intotcpcb(inp); 770 TCPDEBUG1(); 771 #ifdef TCP_OFFLOAD 772 if (tp->t_flags & TF_TOE) 773 tcp_offload_rcvd(tp); 774 else 775 #endif 776 tcp_output(tp); 777 778 out: 779 TCPDEBUG2(PRU_RCVD); 780 INP_WUNLOCK(inp); 781 return (error); 782 } 783 784 /* 785 * Do a send by putting data in output queue and updating urgent 786 * marker if URG set. Possibly send more data. Unlike the other 787 * pru_*() routines, the mbuf chains are our responsibility. We 788 * must either enqueue them or free them. The other pru_* routines 789 * generally are caller-frees. 790 */ 791 static int 792 tcp_usr_send(struct socket *so, int flags, struct mbuf *m, 793 struct sockaddr *nam, struct mbuf *control, struct thread *td) 794 { 795 int error = 0; 796 struct inpcb *inp; 797 struct tcpcb *tp = NULL; 798 #ifdef INET6 799 int isipv6; 800 #endif 801 TCPDEBUG0; 802 803 /* 804 * We require the pcbinfo lock if we will close the socket as part of 805 * this call. 806 */ 807 if (flags & PRUS_EOF) 808 INP_INFO_WLOCK(&V_tcbinfo); 809 inp = sotoinpcb(so); 810 KASSERT(inp != NULL, ("tcp_usr_send: inp == NULL")); 811 INP_WLOCK(inp); 812 if (inp->inp_flags & (INP_TIMEWAIT | INP_DROPPED)) { 813 if (control) 814 m_freem(control); 815 if (m) 816 m_freem(m); 817 error = ECONNRESET; 818 goto out; 819 } 820 #ifdef INET6 821 isipv6 = nam && nam->sa_family == AF_INET6; 822 #endif /* INET6 */ 823 tp = intotcpcb(inp); 824 TCPDEBUG1(); 825 if (control) { 826 /* TCP doesn't do control messages (rights, creds, etc) */ 827 if (control->m_len) { 828 m_freem(control); 829 if (m) 830 m_freem(m); 831 error = EINVAL; 832 goto out; 833 } 834 m_freem(control); /* empty control, just free it */ 835 } 836 if (!(flags & PRUS_OOB)) { 837 sbappendstream(&so->so_snd, m); 838 if (nam && tp->t_state < TCPS_SYN_SENT) { 839 /* 840 * Do implied connect if not yet connected, 841 * initialize window to default value, and 842 * initialize maxseg/maxopd using peer's cached 843 * MSS. 844 */ 845 #ifdef INET6 846 if (isipv6) 847 error = tcp6_connect(tp, nam, td); 848 #endif /* INET6 */ 849 #if defined(INET6) && defined(INET) 850 else 851 #endif 852 #ifdef INET 853 error = tcp_connect(tp, nam, td); 854 #endif 855 if (error) 856 goto out; 857 tp->snd_wnd = TTCP_CLIENT_SND_WND; 858 tcp_mss(tp, -1); 859 } 860 if (flags & PRUS_EOF) { 861 /* 862 * Close the send side of the connection after 863 * the data is sent. 864 */ 865 INP_INFO_WLOCK_ASSERT(&V_tcbinfo); 866 socantsendmore(so); 867 tcp_usrclosed(tp); 868 } 869 if (!(inp->inp_flags & INP_DROPPED)) { 870 if (flags & PRUS_MORETOCOME) 871 tp->t_flags |= TF_MORETOCOME; 872 error = tcp_output(tp); 873 if (flags & PRUS_MORETOCOME) 874 tp->t_flags &= ~TF_MORETOCOME; 875 } 876 } else { 877 /* 878 * XXXRW: PRUS_EOF not implemented with PRUS_OOB? 879 */ 880 SOCKBUF_LOCK(&so->so_snd); 881 if (sbspace(&so->so_snd) < -512) { 882 SOCKBUF_UNLOCK(&so->so_snd); 883 m_freem(m); 884 error = ENOBUFS; 885 goto out; 886 } 887 /* 888 * According to RFC961 (Assigned Protocols), 889 * the urgent pointer points to the last octet 890 * of urgent data. We continue, however, 891 * to consider it to indicate the first octet 892 * of data past the urgent section. 893 * Otherwise, snd_up should be one lower. 894 */ 895 sbappendstream_locked(&so->so_snd, m); 896 SOCKBUF_UNLOCK(&so->so_snd); 897 if (nam && tp->t_state < TCPS_SYN_SENT) { 898 /* 899 * Do implied connect if not yet connected, 900 * initialize window to default value, and 901 * initialize maxseg/maxopd using peer's cached 902 * MSS. 903 */ 904 #ifdef INET6 905 if (isipv6) 906 error = tcp6_connect(tp, nam, td); 907 #endif /* INET6 */ 908 #if defined(INET6) && defined(INET) 909 else 910 #endif 911 #ifdef INET 912 error = tcp_connect(tp, nam, td); 913 #endif 914 if (error) 915 goto out; 916 tp->snd_wnd = TTCP_CLIENT_SND_WND; 917 tcp_mss(tp, -1); 918 } 919 tp->snd_up = tp->snd_una + so->so_snd.sb_cc; 920 tp->t_flags |= TF_FORCEDATA; 921 error = tcp_output(tp); 922 tp->t_flags &= ~TF_FORCEDATA; 923 } 924 out: 925 TCPDEBUG2((flags & PRUS_OOB) ? PRU_SENDOOB : 926 ((flags & PRUS_EOF) ? PRU_SEND_EOF : PRU_SEND)); 927 INP_WUNLOCK(inp); 928 if (flags & PRUS_EOF) 929 INP_INFO_WUNLOCK(&V_tcbinfo); 930 return (error); 931 } 932 933 /* 934 * Abort the TCP. Drop the connection abruptly. 935 */ 936 static void 937 tcp_usr_abort(struct socket *so) 938 { 939 struct inpcb *inp; 940 struct tcpcb *tp = NULL; 941 TCPDEBUG0; 942 943 inp = sotoinpcb(so); 944 KASSERT(inp != NULL, ("tcp_usr_abort: inp == NULL")); 945 946 INP_INFO_WLOCK(&V_tcbinfo); 947 INP_WLOCK(inp); 948 KASSERT(inp->inp_socket != NULL, 949 ("tcp_usr_abort: inp_socket == NULL")); 950 951 /* 952 * If we still have full TCP state, and we're not dropped, drop. 953 */ 954 if (!(inp->inp_flags & INP_TIMEWAIT) && 955 !(inp->inp_flags & INP_DROPPED)) { 956 tp = intotcpcb(inp); 957 TCPDEBUG1(); 958 tcp_drop(tp, ECONNABORTED); 959 TCPDEBUG2(PRU_ABORT); 960 } 961 if (!(inp->inp_flags & INP_DROPPED)) { 962 SOCK_LOCK(so); 963 so->so_state |= SS_PROTOREF; 964 SOCK_UNLOCK(so); 965 inp->inp_flags |= INP_SOCKREF; 966 } 967 INP_WUNLOCK(inp); 968 INP_INFO_WUNLOCK(&V_tcbinfo); 969 } 970 971 /* 972 * TCP socket is closed. Start friendly disconnect. 973 */ 974 static void 975 tcp_usr_close(struct socket *so) 976 { 977 struct inpcb *inp; 978 struct tcpcb *tp = NULL; 979 TCPDEBUG0; 980 981 inp = sotoinpcb(so); 982 KASSERT(inp != NULL, ("tcp_usr_close: inp == NULL")); 983 984 INP_INFO_WLOCK(&V_tcbinfo); 985 INP_WLOCK(inp); 986 KASSERT(inp->inp_socket != NULL, 987 ("tcp_usr_close: inp_socket == NULL")); 988 989 /* 990 * If we still have full TCP state, and we're not dropped, initiate 991 * a disconnect. 992 */ 993 if (!(inp->inp_flags & INP_TIMEWAIT) && 994 !(inp->inp_flags & INP_DROPPED)) { 995 tp = intotcpcb(inp); 996 TCPDEBUG1(); 997 tcp_disconnect(tp); 998 TCPDEBUG2(PRU_CLOSE); 999 } 1000 if (!(inp->inp_flags & INP_DROPPED)) { 1001 SOCK_LOCK(so); 1002 so->so_state |= SS_PROTOREF; 1003 SOCK_UNLOCK(so); 1004 inp->inp_flags |= INP_SOCKREF; 1005 } 1006 INP_WUNLOCK(inp); 1007 INP_INFO_WUNLOCK(&V_tcbinfo); 1008 } 1009 1010 /* 1011 * Receive out-of-band data. 1012 */ 1013 static int 1014 tcp_usr_rcvoob(struct socket *so, struct mbuf *m, int flags) 1015 { 1016 int error = 0; 1017 struct inpcb *inp; 1018 struct tcpcb *tp = NULL; 1019 1020 TCPDEBUG0; 1021 inp = sotoinpcb(so); 1022 KASSERT(inp != NULL, ("tcp_usr_rcvoob: inp == NULL")); 1023 INP_WLOCK(inp); 1024 if (inp->inp_flags & (INP_TIMEWAIT | INP_DROPPED)) { 1025 error = ECONNRESET; 1026 goto out; 1027 } 1028 tp = intotcpcb(inp); 1029 TCPDEBUG1(); 1030 if ((so->so_oobmark == 0 && 1031 (so->so_rcv.sb_state & SBS_RCVATMARK) == 0) || 1032 so->so_options & SO_OOBINLINE || 1033 tp->t_oobflags & TCPOOB_HADDATA) { 1034 error = EINVAL; 1035 goto out; 1036 } 1037 if ((tp->t_oobflags & TCPOOB_HAVEDATA) == 0) { 1038 error = EWOULDBLOCK; 1039 goto out; 1040 } 1041 m->m_len = 1; 1042 *mtod(m, caddr_t) = tp->t_iobc; 1043 if ((flags & MSG_PEEK) == 0) 1044 tp->t_oobflags ^= (TCPOOB_HAVEDATA | TCPOOB_HADDATA); 1045 1046 out: 1047 TCPDEBUG2(PRU_RCVOOB); 1048 INP_WUNLOCK(inp); 1049 return (error); 1050 } 1051 1052 #ifdef INET 1053 struct pr_usrreqs tcp_usrreqs = { 1054 .pru_abort = tcp_usr_abort, 1055 .pru_accept = tcp_usr_accept, 1056 .pru_attach = tcp_usr_attach, 1057 .pru_bind = tcp_usr_bind, 1058 .pru_connect = tcp_usr_connect, 1059 .pru_control = in_control, 1060 .pru_detach = tcp_usr_detach, 1061 .pru_disconnect = tcp_usr_disconnect, 1062 .pru_listen = tcp_usr_listen, 1063 .pru_peeraddr = in_getpeeraddr, 1064 .pru_rcvd = tcp_usr_rcvd, 1065 .pru_rcvoob = tcp_usr_rcvoob, 1066 .pru_send = tcp_usr_send, 1067 .pru_shutdown = tcp_usr_shutdown, 1068 .pru_sockaddr = in_getsockaddr, 1069 .pru_sosetlabel = in_pcbsosetlabel, 1070 .pru_close = tcp_usr_close, 1071 }; 1072 #endif /* INET */ 1073 1074 #ifdef INET6 1075 struct pr_usrreqs tcp6_usrreqs = { 1076 .pru_abort = tcp_usr_abort, 1077 .pru_accept = tcp6_usr_accept, 1078 .pru_attach = tcp_usr_attach, 1079 .pru_bind = tcp6_usr_bind, 1080 .pru_connect = tcp6_usr_connect, 1081 .pru_control = in6_control, 1082 .pru_detach = tcp_usr_detach, 1083 .pru_disconnect = tcp_usr_disconnect, 1084 .pru_listen = tcp6_usr_listen, 1085 .pru_peeraddr = in6_mapped_peeraddr, 1086 .pru_rcvd = tcp_usr_rcvd, 1087 .pru_rcvoob = tcp_usr_rcvoob, 1088 .pru_send = tcp_usr_send, 1089 .pru_shutdown = tcp_usr_shutdown, 1090 .pru_sockaddr = in6_mapped_sockaddr, 1091 .pru_sosetlabel = in_pcbsosetlabel, 1092 .pru_close = tcp_usr_close, 1093 }; 1094 #endif /* INET6 */ 1095 1096 #ifdef INET 1097 /* 1098 * Common subroutine to open a TCP connection to remote host specified 1099 * by struct sockaddr_in in mbuf *nam. Call in_pcbbind to assign a local 1100 * port number if needed. Call in_pcbconnect_setup to do the routing and 1101 * to choose a local host address (interface). If there is an existing 1102 * incarnation of the same connection in TIME-WAIT state and if the remote 1103 * host was sending CC options and if the connection duration was < MSL, then 1104 * truncate the previous TIME-WAIT state and proceed. 1105 * Initialize connection parameters and enter SYN-SENT state. 1106 */ 1107 static int 1108 tcp_connect(struct tcpcb *tp, struct sockaddr *nam, struct thread *td) 1109 { 1110 struct inpcb *inp = tp->t_inpcb, *oinp; 1111 struct socket *so = inp->inp_socket; 1112 struct in_addr laddr; 1113 u_short lport; 1114 int error; 1115 1116 INP_WLOCK_ASSERT(inp); 1117 INP_HASH_WLOCK(&V_tcbinfo); 1118 1119 if (inp->inp_lport == 0) { 1120 error = in_pcbbind(inp, (struct sockaddr *)0, td->td_ucred); 1121 if (error) 1122 goto out; 1123 } 1124 1125 /* 1126 * Cannot simply call in_pcbconnect, because there might be an 1127 * earlier incarnation of this same connection still in 1128 * TIME_WAIT state, creating an ADDRINUSE error. 1129 */ 1130 laddr = inp->inp_laddr; 1131 lport = inp->inp_lport; 1132 error = in_pcbconnect_setup(inp, nam, &laddr.s_addr, &lport, 1133 &inp->inp_faddr.s_addr, &inp->inp_fport, &oinp, td->td_ucred); 1134 if (error && oinp == NULL) 1135 goto out; 1136 if (oinp) { 1137 error = EADDRINUSE; 1138 goto out; 1139 } 1140 inp->inp_laddr = laddr; 1141 in_pcbrehash(inp); 1142 INP_HASH_WUNLOCK(&V_tcbinfo); 1143 1144 /* 1145 * Compute window scaling to request: 1146 * Scale to fit into sweet spot. See tcp_syncache.c. 1147 * XXX: This should move to tcp_output(). 1148 */ 1149 while (tp->request_r_scale < TCP_MAX_WINSHIFT && 1150 (TCP_MAXWIN << tp->request_r_scale) < sb_max) 1151 tp->request_r_scale++; 1152 1153 soisconnecting(so); 1154 TCPSTAT_INC(tcps_connattempt); 1155 tp->t_state = TCPS_SYN_SENT; 1156 tp->iss = tcp_new_isn(tp); 1157 tcp_sendseqinit(tp); 1158 1159 return 0; 1160 1161 out: 1162 INP_HASH_WUNLOCK(&V_tcbinfo); 1163 return (error); 1164 } 1165 #endif /* INET */ 1166 1167 #ifdef INET6 1168 static int 1169 tcp6_connect(struct tcpcb *tp, struct sockaddr *nam, struct thread *td) 1170 { 1171 struct inpcb *inp = tp->t_inpcb, *oinp; 1172 struct socket *so = inp->inp_socket; 1173 struct sockaddr_in6 *sin6 = (struct sockaddr_in6 *)nam; 1174 struct in6_addr addr6; 1175 int error; 1176 1177 INP_WLOCK_ASSERT(inp); 1178 INP_HASH_WLOCK(&V_tcbinfo); 1179 1180 if (inp->inp_lport == 0) { 1181 error = in6_pcbbind(inp, (struct sockaddr *)0, td->td_ucred); 1182 if (error) 1183 goto out; 1184 } 1185 1186 /* 1187 * Cannot simply call in_pcbconnect, because there might be an 1188 * earlier incarnation of this same connection still in 1189 * TIME_WAIT state, creating an ADDRINUSE error. 1190 * in6_pcbladdr() also handles scope zone IDs. 1191 * 1192 * XXXRW: We wouldn't need to expose in6_pcblookup_hash_locked() 1193 * outside of in6_pcb.c if there were an in6_pcbconnect_setup(). 1194 */ 1195 error = in6_pcbladdr(inp, nam, &addr6); 1196 if (error) 1197 goto out; 1198 oinp = in6_pcblookup_hash_locked(inp->inp_pcbinfo, 1199 &sin6->sin6_addr, sin6->sin6_port, 1200 IN6_IS_ADDR_UNSPECIFIED(&inp->in6p_laddr) 1201 ? &addr6 1202 : &inp->in6p_laddr, 1203 inp->inp_lport, 0, NULL); 1204 if (oinp) { 1205 error = EADDRINUSE; 1206 goto out; 1207 } 1208 if (IN6_IS_ADDR_UNSPECIFIED(&inp->in6p_laddr)) 1209 inp->in6p_laddr = addr6; 1210 inp->in6p_faddr = sin6->sin6_addr; 1211 inp->inp_fport = sin6->sin6_port; 1212 /* update flowinfo - draft-itojun-ipv6-flowlabel-api-00 */ 1213 inp->inp_flow &= ~IPV6_FLOWLABEL_MASK; 1214 if (inp->inp_flags & IN6P_AUTOFLOWLABEL) 1215 inp->inp_flow |= 1216 (htonl(ip6_randomflowlabel()) & IPV6_FLOWLABEL_MASK); 1217 in_pcbrehash(inp); 1218 INP_HASH_WUNLOCK(&V_tcbinfo); 1219 1220 /* Compute window scaling to request. */ 1221 while (tp->request_r_scale < TCP_MAX_WINSHIFT && 1222 (TCP_MAXWIN << tp->request_r_scale) < sb_max) 1223 tp->request_r_scale++; 1224 1225 soisconnecting(so); 1226 TCPSTAT_INC(tcps_connattempt); 1227 tp->t_state = TCPS_SYN_SENT; 1228 tp->iss = tcp_new_isn(tp); 1229 tcp_sendseqinit(tp); 1230 1231 return 0; 1232 1233 out: 1234 INP_HASH_WUNLOCK(&V_tcbinfo); 1235 return error; 1236 } 1237 #endif /* INET6 */ 1238 1239 /* 1240 * Export TCP internal state information via a struct tcp_info, based on the 1241 * Linux 2.6 API. Not ABI compatible as our constants are mapped differently 1242 * (TCP state machine, etc). We export all information using FreeBSD-native 1243 * constants -- for example, the numeric values for tcpi_state will differ 1244 * from Linux. 1245 */ 1246 static void 1247 tcp_fill_info(struct tcpcb *tp, struct tcp_info *ti) 1248 { 1249 1250 INP_WLOCK_ASSERT(tp->t_inpcb); 1251 bzero(ti, sizeof(*ti)); 1252 1253 ti->tcpi_state = tp->t_state; 1254 if ((tp->t_flags & TF_REQ_TSTMP) && (tp->t_flags & TF_RCVD_TSTMP)) 1255 ti->tcpi_options |= TCPI_OPT_TIMESTAMPS; 1256 if (tp->t_flags & TF_SACK_PERMIT) 1257 ti->tcpi_options |= TCPI_OPT_SACK; 1258 if ((tp->t_flags & TF_REQ_SCALE) && (tp->t_flags & TF_RCVD_SCALE)) { 1259 ti->tcpi_options |= TCPI_OPT_WSCALE; 1260 ti->tcpi_snd_wscale = tp->snd_scale; 1261 ti->tcpi_rcv_wscale = tp->rcv_scale; 1262 } 1263 1264 ti->tcpi_rto = tp->t_rxtcur * tick; 1265 ti->tcpi_last_data_recv = (long)(ticks - (int)tp->t_rcvtime) * tick; 1266 ti->tcpi_rtt = ((u_int64_t)tp->t_srtt * tick) >> TCP_RTT_SHIFT; 1267 ti->tcpi_rttvar = ((u_int64_t)tp->t_rttvar * tick) >> TCP_RTTVAR_SHIFT; 1268 1269 ti->tcpi_snd_ssthresh = tp->snd_ssthresh; 1270 ti->tcpi_snd_cwnd = tp->snd_cwnd; 1271 1272 /* 1273 * FreeBSD-specific extension fields for tcp_info. 1274 */ 1275 ti->tcpi_rcv_space = tp->rcv_wnd; 1276 ti->tcpi_rcv_nxt = tp->rcv_nxt; 1277 ti->tcpi_snd_wnd = tp->snd_wnd; 1278 ti->tcpi_snd_bwnd = 0; /* Unused, kept for compat. */ 1279 ti->tcpi_snd_nxt = tp->snd_nxt; 1280 ti->tcpi_snd_mss = tp->t_maxseg; 1281 ti->tcpi_rcv_mss = tp->t_maxseg; 1282 if (tp->t_flags & TF_TOE) 1283 ti->tcpi_options |= TCPI_OPT_TOE; 1284 ti->tcpi_snd_rexmitpack = tp->t_sndrexmitpack; 1285 ti->tcpi_rcv_ooopack = tp->t_rcvoopack; 1286 ti->tcpi_snd_zerowin = tp->t_sndzerowin; 1287 } 1288 1289 /* 1290 * tcp_ctloutput() must drop the inpcb lock before performing copyin on 1291 * socket option arguments. When it re-acquires the lock after the copy, it 1292 * has to revalidate that the connection is still valid for the socket 1293 * option. 1294 */ 1295 #define INP_WLOCK_RECHECK(inp) do { \ 1296 INP_WLOCK(inp); \ 1297 if (inp->inp_flags & (INP_TIMEWAIT | INP_DROPPED)) { \ 1298 INP_WUNLOCK(inp); \ 1299 return (ECONNRESET); \ 1300 } \ 1301 tp = intotcpcb(inp); \ 1302 } while(0) 1303 1304 int 1305 tcp_ctloutput(struct socket *so, struct sockopt *sopt) 1306 { 1307 int error, opt, optval; 1308 u_int ui; 1309 struct inpcb *inp; 1310 struct tcpcb *tp; 1311 struct tcp_info ti; 1312 char buf[TCP_CA_NAME_MAX]; 1313 struct cc_algo *algo; 1314 1315 error = 0; 1316 inp = sotoinpcb(so); 1317 KASSERT(inp != NULL, ("tcp_ctloutput: inp == NULL")); 1318 INP_WLOCK(inp); 1319 if (sopt->sopt_level != IPPROTO_TCP) { 1320 #ifdef INET6 1321 if (inp->inp_vflag & INP_IPV6PROTO) { 1322 INP_WUNLOCK(inp); 1323 error = ip6_ctloutput(so, sopt); 1324 } 1325 #endif /* INET6 */ 1326 #if defined(INET6) && defined(INET) 1327 else 1328 #endif 1329 #ifdef INET 1330 { 1331 INP_WUNLOCK(inp); 1332 error = ip_ctloutput(so, sopt); 1333 } 1334 #endif 1335 return (error); 1336 } 1337 if (inp->inp_flags & (INP_TIMEWAIT | INP_DROPPED)) { 1338 INP_WUNLOCK(inp); 1339 return (ECONNRESET); 1340 } 1341 1342 switch (sopt->sopt_dir) { 1343 case SOPT_SET: 1344 switch (sopt->sopt_name) { 1345 #ifdef TCP_SIGNATURE 1346 case TCP_MD5SIG: 1347 INP_WUNLOCK(inp); 1348 error = sooptcopyin(sopt, &optval, sizeof optval, 1349 sizeof optval); 1350 if (error) 1351 return (error); 1352 1353 INP_WLOCK_RECHECK(inp); 1354 if (optval > 0) 1355 tp->t_flags |= TF_SIGNATURE; 1356 else 1357 tp->t_flags &= ~TF_SIGNATURE; 1358 goto unlock_and_done; 1359 #endif /* TCP_SIGNATURE */ 1360 1361 case TCP_NODELAY: 1362 case TCP_NOOPT: 1363 INP_WUNLOCK(inp); 1364 error = sooptcopyin(sopt, &optval, sizeof optval, 1365 sizeof optval); 1366 if (error) 1367 return (error); 1368 1369 INP_WLOCK_RECHECK(inp); 1370 switch (sopt->sopt_name) { 1371 case TCP_NODELAY: 1372 opt = TF_NODELAY; 1373 break; 1374 case TCP_NOOPT: 1375 opt = TF_NOOPT; 1376 break; 1377 default: 1378 opt = 0; /* dead code to fool gcc */ 1379 break; 1380 } 1381 1382 if (optval) 1383 tp->t_flags |= opt; 1384 else 1385 tp->t_flags &= ~opt; 1386 unlock_and_done: 1387 #ifdef TCP_OFFLOAD 1388 if (tp->t_flags & TF_TOE) { 1389 tcp_offload_ctloutput(tp, sopt->sopt_dir, 1390 sopt->sopt_name); 1391 } 1392 #endif 1393 INP_WUNLOCK(inp); 1394 break; 1395 1396 case TCP_NOPUSH: 1397 INP_WUNLOCK(inp); 1398 error = sooptcopyin(sopt, &optval, sizeof optval, 1399 sizeof optval); 1400 if (error) 1401 return (error); 1402 1403 INP_WLOCK_RECHECK(inp); 1404 if (optval) 1405 tp->t_flags |= TF_NOPUSH; 1406 else if (tp->t_flags & TF_NOPUSH) { 1407 tp->t_flags &= ~TF_NOPUSH; 1408 if (TCPS_HAVEESTABLISHED(tp->t_state)) 1409 error = tcp_output(tp); 1410 } 1411 goto unlock_and_done; 1412 1413 case TCP_MAXSEG: 1414 INP_WUNLOCK(inp); 1415 error = sooptcopyin(sopt, &optval, sizeof optval, 1416 sizeof optval); 1417 if (error) 1418 return (error); 1419 1420 INP_WLOCK_RECHECK(inp); 1421 if (optval > 0 && optval <= tp->t_maxseg && 1422 optval + 40 >= V_tcp_minmss) 1423 tp->t_maxseg = optval; 1424 else 1425 error = EINVAL; 1426 goto unlock_and_done; 1427 1428 case TCP_INFO: 1429 INP_WUNLOCK(inp); 1430 error = EINVAL; 1431 break; 1432 1433 case TCP_CONGESTION: 1434 INP_WUNLOCK(inp); 1435 bzero(buf, sizeof(buf)); 1436 error = sooptcopyin(sopt, &buf, sizeof(buf), 1); 1437 if (error) 1438 break; 1439 INP_WLOCK_RECHECK(inp); 1440 /* 1441 * Return EINVAL if we can't find the requested cc algo. 1442 */ 1443 error = EINVAL; 1444 CC_LIST_RLOCK(); 1445 STAILQ_FOREACH(algo, &cc_list, entries) { 1446 if (strncmp(buf, algo->name, TCP_CA_NAME_MAX) 1447 == 0) { 1448 /* We've found the requested algo. */ 1449 error = 0; 1450 /* 1451 * We hold a write lock over the tcb 1452 * so it's safe to do these things 1453 * without ordering concerns. 1454 */ 1455 if (CC_ALGO(tp)->cb_destroy != NULL) 1456 CC_ALGO(tp)->cb_destroy(tp->ccv); 1457 CC_ALGO(tp) = algo; 1458 /* 1459 * If something goes pear shaped 1460 * initialising the new algo, 1461 * fall back to newreno (which 1462 * does not require initialisation). 1463 */ 1464 if (algo->cb_init != NULL) 1465 if (algo->cb_init(tp->ccv) > 0) { 1466 CC_ALGO(tp) = &newreno_cc_algo; 1467 /* 1468 * The only reason init 1469 * should fail is 1470 * because of malloc. 1471 */ 1472 error = ENOMEM; 1473 } 1474 break; /* Break the STAILQ_FOREACH. */ 1475 } 1476 } 1477 CC_LIST_RUNLOCK(); 1478 goto unlock_and_done; 1479 1480 case TCP_KEEPIDLE: 1481 case TCP_KEEPINTVL: 1482 case TCP_KEEPINIT: 1483 INP_WUNLOCK(inp); 1484 error = sooptcopyin(sopt, &ui, sizeof(ui), sizeof(ui)); 1485 if (error) 1486 return (error); 1487 1488 if (ui > (UINT_MAX / hz)) { 1489 error = EINVAL; 1490 break; 1491 } 1492 ui *= hz; 1493 1494 INP_WLOCK_RECHECK(inp); 1495 switch (sopt->sopt_name) { 1496 case TCP_KEEPIDLE: 1497 tp->t_keepidle = ui; 1498 /* 1499 * XXX: better check current remaining 1500 * timeout and "merge" it with new value. 1501 */ 1502 if ((tp->t_state > TCPS_LISTEN) && 1503 (tp->t_state <= TCPS_CLOSING)) 1504 tcp_timer_activate(tp, TT_KEEP, 1505 TP_KEEPIDLE(tp)); 1506 break; 1507 case TCP_KEEPINTVL: 1508 tp->t_keepintvl = ui; 1509 if ((tp->t_state == TCPS_FIN_WAIT_2) && 1510 (TP_MAXIDLE(tp) > 0)) 1511 tcp_timer_activate(tp, TT_2MSL, 1512 TP_MAXIDLE(tp)); 1513 break; 1514 case TCP_KEEPINIT: 1515 tp->t_keepinit = ui; 1516 if (tp->t_state == TCPS_SYN_RECEIVED || 1517 tp->t_state == TCPS_SYN_SENT) 1518 tcp_timer_activate(tp, TT_KEEP, 1519 TP_KEEPINIT(tp)); 1520 break; 1521 } 1522 goto unlock_and_done; 1523 1524 case TCP_KEEPCNT: 1525 INP_WUNLOCK(inp); 1526 error = sooptcopyin(sopt, &ui, sizeof(ui), sizeof(ui)); 1527 if (error) 1528 return (error); 1529 1530 INP_WLOCK_RECHECK(inp); 1531 tp->t_keepcnt = ui; 1532 if ((tp->t_state == TCPS_FIN_WAIT_2) && 1533 (TP_MAXIDLE(tp) > 0)) 1534 tcp_timer_activate(tp, TT_2MSL, 1535 TP_MAXIDLE(tp)); 1536 INP_WUNLOCK(inp); 1537 break; 1538 1539 default: 1540 INP_WUNLOCK(inp); 1541 error = ENOPROTOOPT; 1542 break; 1543 } 1544 break; 1545 1546 case SOPT_GET: 1547 tp = intotcpcb(inp); 1548 switch (sopt->sopt_name) { 1549 #ifdef TCP_SIGNATURE 1550 case TCP_MD5SIG: 1551 optval = (tp->t_flags & TF_SIGNATURE) ? 1 : 0; 1552 INP_WUNLOCK(inp); 1553 error = sooptcopyout(sopt, &optval, sizeof optval); 1554 break; 1555 #endif 1556 1557 case TCP_NODELAY: 1558 optval = tp->t_flags & TF_NODELAY; 1559 INP_WUNLOCK(inp); 1560 error = sooptcopyout(sopt, &optval, sizeof optval); 1561 break; 1562 case TCP_MAXSEG: 1563 optval = tp->t_maxseg; 1564 INP_WUNLOCK(inp); 1565 error = sooptcopyout(sopt, &optval, sizeof optval); 1566 break; 1567 case TCP_NOOPT: 1568 optval = tp->t_flags & TF_NOOPT; 1569 INP_WUNLOCK(inp); 1570 error = sooptcopyout(sopt, &optval, sizeof optval); 1571 break; 1572 case TCP_NOPUSH: 1573 optval = tp->t_flags & TF_NOPUSH; 1574 INP_WUNLOCK(inp); 1575 error = sooptcopyout(sopt, &optval, sizeof optval); 1576 break; 1577 case TCP_INFO: 1578 tcp_fill_info(tp, &ti); 1579 INP_WUNLOCK(inp); 1580 error = sooptcopyout(sopt, &ti, sizeof ti); 1581 break; 1582 case TCP_CONGESTION: 1583 bzero(buf, sizeof(buf)); 1584 strlcpy(buf, CC_ALGO(tp)->name, TCP_CA_NAME_MAX); 1585 INP_WUNLOCK(inp); 1586 error = sooptcopyout(sopt, buf, TCP_CA_NAME_MAX); 1587 break; 1588 default: 1589 INP_WUNLOCK(inp); 1590 error = ENOPROTOOPT; 1591 break; 1592 } 1593 break; 1594 } 1595 return (error); 1596 } 1597 #undef INP_WLOCK_RECHECK 1598 1599 /* 1600 * Attach TCP protocol to socket, allocating 1601 * internet protocol control block, tcp control block, 1602 * bufer space, and entering LISTEN state if to accept connections. 1603 */ 1604 static int 1605 tcp_attach(struct socket *so) 1606 { 1607 struct tcpcb *tp; 1608 struct inpcb *inp; 1609 int error; 1610 1611 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { 1612 error = soreserve(so, V_tcp_sendspace, V_tcp_recvspace); 1613 if (error) 1614 return (error); 1615 } 1616 so->so_rcv.sb_flags |= SB_AUTOSIZE; 1617 so->so_snd.sb_flags |= SB_AUTOSIZE; 1618 INP_INFO_WLOCK(&V_tcbinfo); 1619 error = in_pcballoc(so, &V_tcbinfo); 1620 if (error) { 1621 INP_INFO_WUNLOCK(&V_tcbinfo); 1622 return (error); 1623 } 1624 inp = sotoinpcb(so); 1625 #ifdef INET6 1626 if (inp->inp_vflag & INP_IPV6PROTO) { 1627 inp->inp_vflag |= INP_IPV6; 1628 inp->in6p_hops = -1; /* use kernel default */ 1629 } 1630 else 1631 #endif 1632 inp->inp_vflag |= INP_IPV4; 1633 tp = tcp_newtcpcb(inp); 1634 if (tp == NULL) { 1635 in_pcbdetach(inp); 1636 in_pcbfree(inp); 1637 INP_INFO_WUNLOCK(&V_tcbinfo); 1638 return (ENOBUFS); 1639 } 1640 tp->t_state = TCPS_CLOSED; 1641 INP_WUNLOCK(inp); 1642 INP_INFO_WUNLOCK(&V_tcbinfo); 1643 return (0); 1644 } 1645 1646 /* 1647 * Initiate (or continue) disconnect. 1648 * If embryonic state, just send reset (once). 1649 * If in ``let data drain'' option and linger null, just drop. 1650 * Otherwise (hard), mark socket disconnecting and drop 1651 * current input data; switch states based on user close, and 1652 * send segment to peer (with FIN). 1653 */ 1654 static void 1655 tcp_disconnect(struct tcpcb *tp) 1656 { 1657 struct inpcb *inp = tp->t_inpcb; 1658 struct socket *so = inp->inp_socket; 1659 1660 INP_INFO_WLOCK_ASSERT(&V_tcbinfo); 1661 INP_WLOCK_ASSERT(inp); 1662 1663 /* 1664 * Neither tcp_close() nor tcp_drop() should return NULL, as the 1665 * socket is still open. 1666 */ 1667 if (tp->t_state < TCPS_ESTABLISHED) { 1668 tp = tcp_close(tp); 1669 KASSERT(tp != NULL, 1670 ("tcp_disconnect: tcp_close() returned NULL")); 1671 } else if ((so->so_options & SO_LINGER) && so->so_linger == 0) { 1672 tp = tcp_drop(tp, 0); 1673 KASSERT(tp != NULL, 1674 ("tcp_disconnect: tcp_drop() returned NULL")); 1675 } else { 1676 soisdisconnecting(so); 1677 sbflush(&so->so_rcv); 1678 tcp_usrclosed(tp); 1679 if (!(inp->inp_flags & INP_DROPPED)) 1680 tcp_output(tp); 1681 } 1682 } 1683 1684 /* 1685 * User issued close, and wish to trail through shutdown states: 1686 * if never received SYN, just forget it. If got a SYN from peer, 1687 * but haven't sent FIN, then go to FIN_WAIT_1 state to send peer a FIN. 1688 * If already got a FIN from peer, then almost done; go to LAST_ACK 1689 * state. In all other cases, have already sent FIN to peer (e.g. 1690 * after PRU_SHUTDOWN), and just have to play tedious game waiting 1691 * for peer to send FIN or not respond to keep-alives, etc. 1692 * We can let the user exit from the close as soon as the FIN is acked. 1693 */ 1694 static void 1695 tcp_usrclosed(struct tcpcb *tp) 1696 { 1697 1698 INP_INFO_WLOCK_ASSERT(&V_tcbinfo); 1699 INP_WLOCK_ASSERT(tp->t_inpcb); 1700 1701 switch (tp->t_state) { 1702 case TCPS_LISTEN: 1703 #ifdef TCP_OFFLOAD 1704 tcp_offload_listen_stop(tp); 1705 #endif 1706 /* FALLTHROUGH */ 1707 case TCPS_CLOSED: 1708 tp->t_state = TCPS_CLOSED; 1709 tp = tcp_close(tp); 1710 /* 1711 * tcp_close() should never return NULL here as the socket is 1712 * still open. 1713 */ 1714 KASSERT(tp != NULL, 1715 ("tcp_usrclosed: tcp_close() returned NULL")); 1716 break; 1717 1718 case TCPS_SYN_SENT: 1719 case TCPS_SYN_RECEIVED: 1720 tp->t_flags |= TF_NEEDFIN; 1721 break; 1722 1723 case TCPS_ESTABLISHED: 1724 tp->t_state = TCPS_FIN_WAIT_1; 1725 break; 1726 1727 case TCPS_CLOSE_WAIT: 1728 tp->t_state = TCPS_LAST_ACK; 1729 break; 1730 } 1731 if (tp->t_state >= TCPS_FIN_WAIT_2) { 1732 soisdisconnected(tp->t_inpcb->inp_socket); 1733 /* Prevent the connection hanging in FIN_WAIT_2 forever. */ 1734 if (tp->t_state == TCPS_FIN_WAIT_2) { 1735 int timeout; 1736 1737 timeout = (tcp_fast_finwait2_recycle) ? 1738 tcp_finwait2_timeout : TP_MAXIDLE(tp); 1739 tcp_timer_activate(tp, TT_2MSL, timeout); 1740 } 1741 } 1742 } 1743 1744 #ifdef DDB 1745 static void 1746 db_print_indent(int indent) 1747 { 1748 int i; 1749 1750 for (i = 0; i < indent; i++) 1751 db_printf(" "); 1752 } 1753 1754 static void 1755 db_print_tstate(int t_state) 1756 { 1757 1758 switch (t_state) { 1759 case TCPS_CLOSED: 1760 db_printf("TCPS_CLOSED"); 1761 return; 1762 1763 case TCPS_LISTEN: 1764 db_printf("TCPS_LISTEN"); 1765 return; 1766 1767 case TCPS_SYN_SENT: 1768 db_printf("TCPS_SYN_SENT"); 1769 return; 1770 1771 case TCPS_SYN_RECEIVED: 1772 db_printf("TCPS_SYN_RECEIVED"); 1773 return; 1774 1775 case TCPS_ESTABLISHED: 1776 db_printf("TCPS_ESTABLISHED"); 1777 return; 1778 1779 case TCPS_CLOSE_WAIT: 1780 db_printf("TCPS_CLOSE_WAIT"); 1781 return; 1782 1783 case TCPS_FIN_WAIT_1: 1784 db_printf("TCPS_FIN_WAIT_1"); 1785 return; 1786 1787 case TCPS_CLOSING: 1788 db_printf("TCPS_CLOSING"); 1789 return; 1790 1791 case TCPS_LAST_ACK: 1792 db_printf("TCPS_LAST_ACK"); 1793 return; 1794 1795 case TCPS_FIN_WAIT_2: 1796 db_printf("TCPS_FIN_WAIT_2"); 1797 return; 1798 1799 case TCPS_TIME_WAIT: 1800 db_printf("TCPS_TIME_WAIT"); 1801 return; 1802 1803 default: 1804 db_printf("unknown"); 1805 return; 1806 } 1807 } 1808 1809 static void 1810 db_print_tflags(u_int t_flags) 1811 { 1812 int comma; 1813 1814 comma = 0; 1815 if (t_flags & TF_ACKNOW) { 1816 db_printf("%sTF_ACKNOW", comma ? ", " : ""); 1817 comma = 1; 1818 } 1819 if (t_flags & TF_DELACK) { 1820 db_printf("%sTF_DELACK", comma ? ", " : ""); 1821 comma = 1; 1822 } 1823 if (t_flags & TF_NODELAY) { 1824 db_printf("%sTF_NODELAY", comma ? ", " : ""); 1825 comma = 1; 1826 } 1827 if (t_flags & TF_NOOPT) { 1828 db_printf("%sTF_NOOPT", comma ? ", " : ""); 1829 comma = 1; 1830 } 1831 if (t_flags & TF_SENTFIN) { 1832 db_printf("%sTF_SENTFIN", comma ? ", " : ""); 1833 comma = 1; 1834 } 1835 if (t_flags & TF_REQ_SCALE) { 1836 db_printf("%sTF_REQ_SCALE", comma ? ", " : ""); 1837 comma = 1; 1838 } 1839 if (t_flags & TF_RCVD_SCALE) { 1840 db_printf("%sTF_RECVD_SCALE", comma ? ", " : ""); 1841 comma = 1; 1842 } 1843 if (t_flags & TF_REQ_TSTMP) { 1844 db_printf("%sTF_REQ_TSTMP", comma ? ", " : ""); 1845 comma = 1; 1846 } 1847 if (t_flags & TF_RCVD_TSTMP) { 1848 db_printf("%sTF_RCVD_TSTMP", comma ? ", " : ""); 1849 comma = 1; 1850 } 1851 if (t_flags & TF_SACK_PERMIT) { 1852 db_printf("%sTF_SACK_PERMIT", comma ? ", " : ""); 1853 comma = 1; 1854 } 1855 if (t_flags & TF_NEEDSYN) { 1856 db_printf("%sTF_NEEDSYN", comma ? ", " : ""); 1857 comma = 1; 1858 } 1859 if (t_flags & TF_NEEDFIN) { 1860 db_printf("%sTF_NEEDFIN", comma ? ", " : ""); 1861 comma = 1; 1862 } 1863 if (t_flags & TF_NOPUSH) { 1864 db_printf("%sTF_NOPUSH", comma ? ", " : ""); 1865 comma = 1; 1866 } 1867 if (t_flags & TF_MORETOCOME) { 1868 db_printf("%sTF_MORETOCOME", comma ? ", " : ""); 1869 comma = 1; 1870 } 1871 if (t_flags & TF_LQ_OVERFLOW) { 1872 db_printf("%sTF_LQ_OVERFLOW", comma ? ", " : ""); 1873 comma = 1; 1874 } 1875 if (t_flags & TF_LASTIDLE) { 1876 db_printf("%sTF_LASTIDLE", comma ? ", " : ""); 1877 comma = 1; 1878 } 1879 if (t_flags & TF_RXWIN0SENT) { 1880 db_printf("%sTF_RXWIN0SENT", comma ? ", " : ""); 1881 comma = 1; 1882 } 1883 if (t_flags & TF_FASTRECOVERY) { 1884 db_printf("%sTF_FASTRECOVERY", comma ? ", " : ""); 1885 comma = 1; 1886 } 1887 if (t_flags & TF_CONGRECOVERY) { 1888 db_printf("%sTF_CONGRECOVERY", comma ? ", " : ""); 1889 comma = 1; 1890 } 1891 if (t_flags & TF_WASFRECOVERY) { 1892 db_printf("%sTF_WASFRECOVERY", comma ? ", " : ""); 1893 comma = 1; 1894 } 1895 if (t_flags & TF_SIGNATURE) { 1896 db_printf("%sTF_SIGNATURE", comma ? ", " : ""); 1897 comma = 1; 1898 } 1899 if (t_flags & TF_FORCEDATA) { 1900 db_printf("%sTF_FORCEDATA", comma ? ", " : ""); 1901 comma = 1; 1902 } 1903 if (t_flags & TF_TSO) { 1904 db_printf("%sTF_TSO", comma ? ", " : ""); 1905 comma = 1; 1906 } 1907 if (t_flags & TF_ECN_PERMIT) { 1908 db_printf("%sTF_ECN_PERMIT", comma ? ", " : ""); 1909 comma = 1; 1910 } 1911 } 1912 1913 static void 1914 db_print_toobflags(char t_oobflags) 1915 { 1916 int comma; 1917 1918 comma = 0; 1919 if (t_oobflags & TCPOOB_HAVEDATA) { 1920 db_printf("%sTCPOOB_HAVEDATA", comma ? ", " : ""); 1921 comma = 1; 1922 } 1923 if (t_oobflags & TCPOOB_HADDATA) { 1924 db_printf("%sTCPOOB_HADDATA", comma ? ", " : ""); 1925 comma = 1; 1926 } 1927 } 1928 1929 static void 1930 db_print_tcpcb(struct tcpcb *tp, const char *name, int indent) 1931 { 1932 1933 db_print_indent(indent); 1934 db_printf("%s at %p\n", name, tp); 1935 1936 indent += 2; 1937 1938 db_print_indent(indent); 1939 db_printf("t_segq first: %p t_segqlen: %d t_dupacks: %d\n", 1940 LIST_FIRST(&tp->t_segq), tp->t_segqlen, tp->t_dupacks); 1941 1942 db_print_indent(indent); 1943 db_printf("tt_rexmt: %p tt_persist: %p tt_keep: %p\n", 1944 &tp->t_timers->tt_rexmt, &tp->t_timers->tt_persist, &tp->t_timers->tt_keep); 1945 1946 db_print_indent(indent); 1947 db_printf("tt_2msl: %p tt_delack: %p t_inpcb: %p\n", &tp->t_timers->tt_2msl, 1948 &tp->t_timers->tt_delack, tp->t_inpcb); 1949 1950 db_print_indent(indent); 1951 db_printf("t_state: %d (", tp->t_state); 1952 db_print_tstate(tp->t_state); 1953 db_printf(")\n"); 1954 1955 db_print_indent(indent); 1956 db_printf("t_flags: 0x%x (", tp->t_flags); 1957 db_print_tflags(tp->t_flags); 1958 db_printf(")\n"); 1959 1960 db_print_indent(indent); 1961 db_printf("snd_una: 0x%08x snd_max: 0x%08x snd_nxt: x0%08x\n", 1962 tp->snd_una, tp->snd_max, tp->snd_nxt); 1963 1964 db_print_indent(indent); 1965 db_printf("snd_up: 0x%08x snd_wl1: 0x%08x snd_wl2: 0x%08x\n", 1966 tp->snd_up, tp->snd_wl1, tp->snd_wl2); 1967 1968 db_print_indent(indent); 1969 db_printf("iss: 0x%08x irs: 0x%08x rcv_nxt: 0x%08x\n", 1970 tp->iss, tp->irs, tp->rcv_nxt); 1971 1972 db_print_indent(indent); 1973 db_printf("rcv_adv: 0x%08x rcv_wnd: %lu rcv_up: 0x%08x\n", 1974 tp->rcv_adv, tp->rcv_wnd, tp->rcv_up); 1975 1976 db_print_indent(indent); 1977 db_printf("snd_wnd: %lu snd_cwnd: %lu\n", 1978 tp->snd_wnd, tp->snd_cwnd); 1979 1980 db_print_indent(indent); 1981 db_printf("snd_ssthresh: %lu snd_recover: " 1982 "0x%08x\n", tp->snd_ssthresh, tp->snd_recover); 1983 1984 db_print_indent(indent); 1985 db_printf("t_maxopd: %u t_rcvtime: %u t_startime: %u\n", 1986 tp->t_maxopd, tp->t_rcvtime, tp->t_starttime); 1987 1988 db_print_indent(indent); 1989 db_printf("t_rttime: %u t_rtsq: 0x%08x\n", 1990 tp->t_rtttime, tp->t_rtseq); 1991 1992 db_print_indent(indent); 1993 db_printf("t_rxtcur: %d t_maxseg: %u t_srtt: %d\n", 1994 tp->t_rxtcur, tp->t_maxseg, tp->t_srtt); 1995 1996 db_print_indent(indent); 1997 db_printf("t_rttvar: %d t_rxtshift: %d t_rttmin: %u " 1998 "t_rttbest: %u\n", tp->t_rttvar, tp->t_rxtshift, tp->t_rttmin, 1999 tp->t_rttbest); 2000 2001 db_print_indent(indent); 2002 db_printf("t_rttupdated: %lu max_sndwnd: %lu t_softerror: %d\n", 2003 tp->t_rttupdated, tp->max_sndwnd, tp->t_softerror); 2004 2005 db_print_indent(indent); 2006 db_printf("t_oobflags: 0x%x (", tp->t_oobflags); 2007 db_print_toobflags(tp->t_oobflags); 2008 db_printf(") t_iobc: 0x%02x\n", tp->t_iobc); 2009 2010 db_print_indent(indent); 2011 db_printf("snd_scale: %u rcv_scale: %u request_r_scale: %u\n", 2012 tp->snd_scale, tp->rcv_scale, tp->request_r_scale); 2013 2014 db_print_indent(indent); 2015 db_printf("ts_recent: %u ts_recent_age: %u\n", 2016 tp->ts_recent, tp->ts_recent_age); 2017 2018 db_print_indent(indent); 2019 db_printf("ts_offset: %u last_ack_sent: 0x%08x snd_cwnd_prev: " 2020 "%lu\n", tp->ts_offset, tp->last_ack_sent, tp->snd_cwnd_prev); 2021 2022 db_print_indent(indent); 2023 db_printf("snd_ssthresh_prev: %lu snd_recover_prev: 0x%08x " 2024 "t_badrxtwin: %u\n", tp->snd_ssthresh_prev, 2025 tp->snd_recover_prev, tp->t_badrxtwin); 2026 2027 db_print_indent(indent); 2028 db_printf("snd_numholes: %d snd_holes first: %p\n", 2029 tp->snd_numholes, TAILQ_FIRST(&tp->snd_holes)); 2030 2031 db_print_indent(indent); 2032 db_printf("snd_fack: 0x%08x rcv_numsacks: %d sack_newdata: " 2033 "0x%08x\n", tp->snd_fack, tp->rcv_numsacks, tp->sack_newdata); 2034 2035 /* Skip sackblks, sackhint. */ 2036 2037 db_print_indent(indent); 2038 db_printf("t_rttlow: %d rfbuf_ts: %u rfbuf_cnt: %d\n", 2039 tp->t_rttlow, tp->rfbuf_ts, tp->rfbuf_cnt); 2040 } 2041 2042 DB_SHOW_COMMAND(tcpcb, db_show_tcpcb) 2043 { 2044 struct tcpcb *tp; 2045 2046 if (!have_addr) { 2047 db_printf("usage: show tcpcb <addr>\n"); 2048 return; 2049 } 2050 tp = (struct tcpcb *)addr; 2051 2052 db_print_tcpcb(tp, "tcpcb", 0); 2053 } 2054 #endif
Cache object: 5190102cdba7239b2fce8a412bc1dab4
[ source navigation ] [ diff markup ] [ identifier search ] [ freetext search ] [ file search ] [ list types ] [ track identifier ]