Lines Matching refs:tp
141 static int tcp6_connect_oncpu(struct tcpcb *tp, int flags,
153 #define TCPDEBUG1() ostate = tp ? tp->t_state : 0
154 #define TCPDEBUG2(req) if (tp && (so->so_options & SO_DEBUG)) \
155 tcp_trace(TA_USER, ostate, tp, 0, 0, req)
206 struct tcpcb *tp = NULL; in tcp_usr_attach() local
219 tp = sototcpcb(so); in tcp_usr_attach()
238 struct tcpcb *tp; in tcp_usr_detach() local
249 tp = intotcpcb(inp); in tcp_usr_detach()
250 KASSERT(tp != NULL, ("tcp_usr_detach: tp is NULL")); in tcp_usr_detach()
252 tp = tcp_disconnect(tp); in tcp_usr_detach()
272 tp = NULL; \
275 tp = intotcpcb(inp); \
306 struct tcpcb *tp; in tcp_usr_bind() local
363 TCP_STATE_MIGRATE_START(tp); in tcp_usr_bind()
375 TCP_STATE_MIGRATE_END(tp); in tcp_usr_bind()
397 struct tcpcb *tp; in tcp6_usr_bind() local
449 struct tcpcb *tp; in tcp_usr_listen() local
464 TCP_STATE_MIGRATE_START(tp); in tcp_usr_listen()
476 TCP_STATE_MIGRATE_END(tp); in tcp_usr_listen()
481 if (tp->t_flags & TF_LISTEN) in tcp_usr_listen()
490 TCP_STATE_CHANGE(tp, TCPS_LISTEN); in tcp_usr_listen()
491 tp->t_flags |= TF_LISTEN; in tcp_usr_listen()
492 tp->tt_msg = NULL; /* Catch any invalid timer usage */ in tcp_usr_listen()
501 tcp_pcbport_create(tp); in tcp_usr_listen()
526 struct tcpcb *tp; in tcp6_usr_listen() local
531 if (tp->t_flags & TF_LISTEN) in tcp6_usr_listen()
540 TCP_STATE_CHANGE(tp, TCPS_LISTEN); in tcp6_usr_listen()
541 tp->t_flags |= TF_LISTEN; in tcp6_usr_listen()
542 tp->tt_msg = NULL; /* Catch any invalid timer usage */ in tcp6_usr_listen()
551 tcp_pcbport_create(tp); in tcp6_usr_listen()
587 struct tcpcb *tp; in tcp_usr_connect() local
630 struct tcpcb *tp; in tcp6_usr_connect() local
689 struct tcpcb *tp; in tcp_usr_disconnect() local
692 tp = tcp_disconnect(tp); in tcp_usr_disconnect()
708 struct tcpcb *tp = NULL; in tcp_usr_accept() local
721 tp = intotcpcb(inp); in tcp_usr_accept()
735 struct tcpcb *tp = NULL; in tcp6_usr_accept() local
748 tp = intotcpcb(inp); in tcp6_usr_accept()
764 struct tcpcb *tp; in tcp_usr_shutdown() local
768 tp = tcp_usrclosed(tp); in tcp_usr_shutdown()
769 if (tp) in tcp_usr_shutdown()
770 error = tcp_output(tp); in tcp_usr_shutdown()
783 struct tcpcb *tp; in tcp_usr_rcvd() local
791 tcp_output(tp); in tcp_usr_rcvd()
811 struct tcpcb *tp; in tcp_usr_send() local
828 tp = NULL; in tcp_usr_send()
832 tp = intotcpcb(inp); in tcp_usr_send()
870 tp->snd_up = tp->snd_una + so->so_snd.ssb_cc; in tcp_usr_send()
871 tp->t_flags |= TF_FORCE; in tcp_usr_send()
872 error = tcp_output(tp); in tcp_usr_send()
873 tp->t_flags &= ~TF_FORCE; in tcp_usr_send()
881 tp = tcp_usrclosed(tp); in tcp_usr_send()
883 if (tp != NULL && !tcp_output_pending(tp)) { in tcp_usr_send()
885 tp->t_flags |= TF_MORETOCOME; in tcp_usr_send()
886 error = tcp_output_fair(tp); in tcp_usr_send()
888 tp->t_flags &= ~TF_MORETOCOME; in tcp_usr_send()
906 struct tcpcb *tp; in tcp_usr_abort() local
909 tp = tcp_drop(tp, ECONNABORTED); in tcp_usr_abort()
924 struct tcpcb *tp; in tcp_usr_rcvoob() local
930 tp->t_oobflags & TCPOOB_HADDATA) { in tcp_usr_rcvoob()
934 if ((tp->t_oobflags & TCPOOB_HAVEDATA) == 0) { in tcp_usr_rcvoob()
939 *mtod(m, caddr_t) = tp->t_iobc; in tcp_usr_rcvoob()
941 tp->t_oobflags ^= (TCPOOB_HAVEDATA | TCPOOB_HADDATA); in tcp_usr_rcvoob()
1026 tcp_connect_oncpu(struct tcpcb *tp, int flags, struct mbuf *m, in tcp_connect_oncpu() argument
1030 struct inpcb *inp = tp->t_inpcb, *oinp; in tcp_connect_oncpu()
1081 tcp_create_timermsg(tp, &curthread->td_msgport); in tcp_connect_oncpu()
1088 if (tp->request_r_scale < TCP_MIN_WINSHIFT) in tcp_connect_oncpu()
1089 tp->request_r_scale = TCP_MIN_WINSHIFT; in tcp_connect_oncpu()
1090 while (tp->request_r_scale < TCP_MAX_WINSHIFT && in tcp_connect_oncpu()
1091 (TCP_MAXWIN << tp->request_r_scale) < so->so_rcv.ssb_hiwat in tcp_connect_oncpu()
1093 tp->request_r_scale++; in tcp_connect_oncpu()
1098 TCP_STATE_CHANGE(tp, TCPS_SYN_SENT); in tcp_connect_oncpu()
1099 tcp_callout_reset(tp, tp->tt_keep, tp->t_keepinit, tcp_timer_keep); in tcp_connect_oncpu()
1100 tp->iss = tcp_new_isn(tp); in tcp_connect_oncpu()
1101 tcp_sendseqinit(tp); in tcp_connect_oncpu()
1106 tp->snd_up = tp->snd_una + so->so_snd.ssb_cc; in tcp_connect_oncpu()
1115 tp = tcp_usrclosed(tp); in tcp_connect_oncpu()
1117 return (tcp_output(tp)); in tcp_connect_oncpu()
1136 struct tcpcb *tp; in tcp_connect() local
1148 TCP_STATE_MIGRATE_END(tp); in tcp_connect()
1239 TCP_STATE_MIGRATE_START(tp); in tcp_connect()
1290 error = tcp_connect_oncpu(tp, msg->connect.nm_sndflags, in tcp_connect()
1313 struct tcpcb *tp; in tcp6_connect() local
1330 TCP_STATE_MIGRATE_END(tp); in tcp6_connect()
1368 TCP_STATE_MIGRATE_START(tp); in tcp6_connect()
1376 error = tcp6_connect_oncpu(tp, msg->connect.nm_sndflags, in tcp6_connect()
1389 tcp6_connect_oncpu(struct tcpcb *tp, int flags, struct mbuf **mp, in tcp6_connect_oncpu() argument
1393 struct inpcb *inp = tp->t_inpcb; in tcp6_connect_oncpu()
1425 tcp_create_timermsg(tp, &curthread->td_msgport); in tcp6_connect_oncpu()
1428 if (tp->request_r_scale < TCP_MIN_WINSHIFT) in tcp6_connect_oncpu()
1429 tp->request_r_scale = TCP_MIN_WINSHIFT; in tcp6_connect_oncpu()
1430 while (tp->request_r_scale < TCP_MAX_WINSHIFT && in tcp6_connect_oncpu()
1431 (TCP_MAXWIN << tp->request_r_scale) < so->so_rcv.ssb_hiwat) { in tcp6_connect_oncpu()
1432 tp->request_r_scale++; in tcp6_connect_oncpu()
1437 TCP_STATE_CHANGE(tp, TCPS_SYN_SENT); in tcp6_connect_oncpu()
1438 tcp_callout_reset(tp, tp->tt_keep, tp->t_keepinit, tcp_timer_keep); in tcp6_connect_oncpu()
1439 tp->iss = tcp_new_isn(tp); in tcp6_connect_oncpu()
1440 tcp_sendseqinit(tp); in tcp6_connect_oncpu()
1445 tp->snd_up = tp->snd_una + so->so_snd.ssb_cc; in tcp6_connect_oncpu()
1454 tp = tcp_usrclosed(tp); in tcp6_connect_oncpu()
1456 return (tcp_output(tp)); in tcp6_connect_oncpu()
1476 struct tcpcb *tp; in tcp_ctloutput() local
1487 tp = intotcpcb(inp); in tcp_ctloutput()
1493 if (tp->t_flags & TF_LISTEN) { in tcp_ctloutput()
1551 tp->t_keepidle = tp->t_keepintvl; in tcp_ctloutput()
1553 tp->t_keepidle = tcp_keepidle; in tcp_ctloutput()
1554 tcp_timer_keep_activity(tp, 0); in tcp_ctloutput()
1558 if (tp->t_state == TCPS_CLOSED) { in tcp_ctloutput()
1566 tp->t_flags |= TF_SIGNATURE; in tcp_ctloutput()
1568 tp->t_flags &= ~TF_SIGNATURE; in tcp_ctloutput()
1589 tp->t_flags |= opt; in tcp_ctloutput()
1591 tp->t_flags &= ~opt; in tcp_ctloutput()
1598 tp->t_flags |= TF_NOPUSH; in tcp_ctloutput()
1600 tp->t_flags &= ~TF_NOPUSH; in tcp_ctloutput()
1601 error = tcp_output(tp); in tcp_ctloutput()
1613 if (optval > 0 && optval <= tp->t_maxseg) { in tcp_ctloutput()
1619 tp->t_maxseg = optval; in tcp_ctloutput()
1636 tp->t_keepinit = opthz; in tcp_ctloutput()
1639 tp->t_keepidle = opthz; in tcp_ctloutput()
1640 tcp_timer_keep_activity(tp, 0); in tcp_ctloutput()
1643 tp->t_keepintvl = opthz; in tcp_ctloutput()
1644 tp->t_maxidle = tp->t_keepintvl * tp->t_keepcnt; in tcp_ctloutput()
1654 tp->t_keepcnt = optval; in tcp_ctloutput()
1655 tp->t_maxidle = tp->t_keepintvl * tp->t_keepcnt; in tcp_ctloutput()
1668 optval = (tp->t_flags & TF_SIGNATURE) ? 1 : 0; in tcp_ctloutput()
1672 optval = tp->t_flags & TF_NODELAY; in tcp_ctloutput()
1675 optval = tp->t_maxseg; in tcp_ctloutput()
1678 optval = tp->t_flags & TF_NOOPT; in tcp_ctloutput()
1681 optval = tp->t_flags & TF_NOPUSH; in tcp_ctloutput()
1684 optval = tp->t_keepinit / hz; in tcp_ctloutput()
1687 optval = tp->t_keepidle / hz; in tcp_ctloutput()
1690 optval = tp->t_keepintvl / hz; in tcp_ctloutput()
1693 optval = tp->t_keepcnt; in tcp_ctloutput()
1835 tcp_disconnect(struct tcpcb *tp) in tcp_disconnect() argument
1837 struct socket *so = tp->t_inpcb->inp_socket; in tcp_disconnect()
1839 if (tp->t_state < TCPS_ESTABLISHED) { in tcp_disconnect()
1840 tp = tcp_close(tp); in tcp_disconnect()
1842 tp = tcp_drop(tp, 0); in tcp_disconnect()
1847 tp = tcp_usrclosed(tp); in tcp_disconnect()
1848 if (tp) in tcp_disconnect()
1849 tcp_output(tp); in tcp_disconnect()
1852 return (tp); in tcp_disconnect()
1866 tcp_usrclosed(struct tcpcb *tp) in tcp_usrclosed() argument
1869 switch (tp->t_state) { in tcp_usrclosed()
1873 TCP_STATE_CHANGE(tp, TCPS_CLOSED); in tcp_usrclosed()
1874 tp = tcp_close(tp); in tcp_usrclosed()
1879 tp->t_flags |= TF_NEEDFIN; in tcp_usrclosed()
1883 TCP_STATE_CHANGE(tp, TCPS_FIN_WAIT_1); in tcp_usrclosed()
1887 TCP_STATE_CHANGE(tp, TCPS_LAST_ACK); in tcp_usrclosed()
1890 if (tp && tp->t_state >= TCPS_FIN_WAIT_2) { in tcp_usrclosed()
1891 soisdisconnected(tp->t_inpcb->inp_socket); in tcp_usrclosed()
1893 if (tp->t_state == TCPS_FIN_WAIT_2) { in tcp_usrclosed()
1894 tcp_callout_reset(tp, tp->tt_2msl, tp->t_maxidle, in tcp_usrclosed()
1898 return (tp); in tcp_usrclosed()