Home
last modified time | relevance | path

Searched refs:mp_tp (Results 1 – 12 of 12) sorted by relevance

/xnu-11215/bsd/netinet/
H A Dmptcp_timer.c74 struct mptcb *mp_tp = NULL; in mptcp_timer_demux() local
75 mp_tp = mpte->mpte_mptcb; in mptcp_timer_demux()
86 if (MPTCP_SEQ_GT(mp_tp->mpt_snduna, mp_tp->mpt_rtseq)) { in mptcp_timer_demux()
88 mp_tp->mpt_rtseq = 0; in mptcp_timer_demux()
91 mp_tp->mpt_rxtshift++; in mptcp_timer_demux()
96 mp_tp->mpt_sndnxt = mp_tp->mpt_rtseq; in mptcp_timer_demux()
177 mp_tp->mpt_rxtshift = 0; in mptcp_start_timer()
178 mp_tp->mpt_rtseq = mp_tp->mpt_sndnxt; in mptcp_start_timer()
202 mp_tp->mpt_rxtstart = 0; in mptcp_cancel_timer()
203 mp_tp->mpt_rxtshift = 0; in mptcp_cancel_timer()
[all …]
H A Dmptcp_opt.c275 ((mp_tp->mpt_local_idsn + 1) == mp_tp->mpt_snduna)) { in mptcp_send_infinite_mapping()
843 if ((mp_tp->mpt_sndnxt + 1 != mp_tp->mpt_sndmax) || in mptcp_setup_opts()
844 (mp_tp->mpt_snduna == mp_tp->mpt_sndmax)) { in mptcp_setup_opts()
1134 MPTCP_SEQ_GT(mp_tp->mpt_sndnxt, mp_tp->mpt_snduna)) { in mptcp_data_ack_rcvd()
1136 mp_tp->mpt_sndnxt = mp_tp->mpt_dsn_at_csum_fail; in mptcp_data_ack_rcvd()
1153 MPTCP_SEQ_GT(mp_tp->mpt_snduna, mp_tp->mpt_local_idsn + 1)) { in mptcp_data_ack_rcvd()
1167 mp_tp->mpt_sndwl1 = mp_tp->mpt_rcvnxt; in mptcp_update_window_wakeup()
1168 mp_tp->mpt_sndwl2 = mp_tp->mpt_snduna; in mptcp_update_window_wakeup()
1180 (mp_tp->mpt_sndwl2 == ack && tiwin > mp_tp->mpt_sndwnd)))) { in mptcp_update_window()
1455 if (!mp_tp) { in mptcp_do_dss_opt()
[all …]
H A Dmptcp.c413 mp_tp->mpt_rcvwnd = mptcp_sbspace(mp_tp); in mptcp_input()
521 todrop = (mb_dsn + mb_datalen) - (mp_tp->mpt_rcvnxt + mp_tp->mpt_rcvwnd); in mptcp_input()
658 if (MPTCP_SEQ_LEQ(mp_tp->mpt_snduna + mp_tp->mpt_sndwnd, mp_tp->mpt_sndnxt)) { in mptcp_can_send_more()
662 if (mp_tp->mpt_sndnxt + 1 == mp_tp->mpt_sndmax && mp_tp->mpt_state > MPTCPS_CLOSE_WAIT) { in mptcp_can_send_more()
679 struct mptcb *mp_tp; in mptcp_output() local
780 if (mp_tp->mpt_sndnxt + 1 == mp_tp->mpt_sndmax && in mptcp_output()
781 mp_tp->mpt_snduna == mp_tp->mpt_sndnxt) { in mptcp_output()
1078 mptcp_close(mp_tp->mpt_mpte, mp_tp); in mptcp_close_fsm()
1157 if (mp_tp == NULL) { in mptcp_input_csum()
1304 struct mptcb *mp_tp; in mptcp_session_necp_cb() local
[all …]
H A Dmptcp_subr.c297 bzero(mp_tp, sizeof(*mp_tp)); in mptcp_session_create()
1567 mp_tp->mpt_state, mp_tp->mpt_flags); in mptcp_subflow_socreate()
3077 mp_tp->mpt_sndnxt = mp_tp->mpt_snduna; in mptcp_subflow_output()
3152 mp_tp->mpt_sndnxt = mp_tp->mpt_snduna; in mptcp_subflow_output()
4010 mp_tp->mpt_sndnxt = mp_tp->mpt_snduna; in mptcp_drop_tfo_data()
4143 mp_tp->mpt_sndwl1 = mp_tp->mpt_rcvnxt; in mptcp_subflow_connected_ev()
4144 mp_tp->mpt_sndwl2 = mp_tp->mpt_snduna; in mptcp_subflow_connected_ev()
5321 mp_tp->mpt_rcvwnd = mptcp_sbspace(mp_tp); in mptcp_conn_properties()
5358 mp_tp->mpt_snduna = mp_tp->mpt_sndmax = mp_tp->mpt_local_idsn + 1; in mptcp_init_local_parms()
5359 mp_tp->mpt_sndnxt = mp_tp->mpt_snduna; in mptcp_init_local_parms()
[all …]
H A Dmptcp_usrreq.c214 mp_tp = mpte->mpte_mptcb; in mptcp_attach()
216 VERIFY(mp_tp != NULL); in mptcp_attach()
296 struct mptcb *mp_tp = NULL; in mptcp_usr_connectx() local
308 mp_tp = mpte->mpte_mptcb; in mptcp_usr_connectx()
901 struct mptcb *mp_tp; in mptcp_disconnect() local
905 mp_tp = mpte->mpte_mptcb; in mptcp_disconnect()
920 mptcp_cancel_all_timers(mp_tp); in mptcp_disconnect()
922 mptcp_close(mpte, mp_tp); in mptcp_disconnect()
926 mptcp_drop(mpte, mp_tp, 0); in mptcp_disconnect()
975 if (mp_tp->mpt_state == MPTCPS_CLOSED || mp_tp->mpt_state == MPTCPS_TERMINATE) { in mptcp_finish_usrclosed()
[all …]
H A Dmptcp_timer.h37 extern void mptcp_cancel_timer(struct mptcb *mp_tp, int timer_type);
38 extern void mptcp_cancel_all_timers(struct mptcb *mp_tp);
H A Dmptcp_opt.h35 extern void mptcp_data_ack_rcvd(struct mptcb *mp_tp, struct tcpcb *tp, u_int64_t full_dack);
H A Dmptcp_var.h552 extern boolean_t mptcp_ok_to_create_subflows(struct mptcb *mp_tp);
558 extern struct mptses *mptcp_drop(struct mptses *mpte, struct mptcb *mp_tp, u_short errno);
591 extern boolean_t mptcp_can_send_more(struct mptcb *mp_tp, boolean_t ignore_reinject);
619 extern void mptcp_sbrcv_grow(struct mptcb *mp_tp);
H A Dtcp_output.c1388 struct mptcb *mp_tp = tptomptp(tp); in tcp_output() local
1394 mp_tp->mpt_version == MPTCP_VERSION_0) || in tcp_output()
1461 struct mptcb *mp_tp = tptomptp(tp); in tcp_output() local
1462 struct socket *mp_so = mptetoso(mp_tp->mpt_mpte); in tcp_output()
1506 struct mptcb *mp_tp = tptomptp(tp); in tcp_output() local
1507 int64_t recwin_announced = (int64_t)(mp_tp->mpt_rcvadv - mp_tp->mpt_rcvnxt); in tcp_output()
2751 struct mptcb *mp_tp = tptomptp(tp); in tcp_output() local
2756 if (recwin > 0 && MPTCP_SEQ_LT(mp_tp->mpt_rcvadv, mp_tp->mpt_rcvnxt + recwin)) { in tcp_output()
2757 mp_tp->mpt_rcvadv = mp_tp->mpt_rcvnxt + recwin; in tcp_output()
H A Dtcp_subr.c3256 struct mptcb *mp_tp = tptomptp(sototcpcb(so)); in tcp_lock() local
3257 struct socket *mp_so = mptetoso(mp_tp->mpt_mpte); in tcp_lock()
3337 struct mptcb *mp_tp = tptomptp(sototcpcb(so)); in tcp_unlock() local
3338 struct socket *mp_so = mptetoso(mp_tp->mpt_mpte); in tcp_unlock()
3364 struct mptcb *mp_tp = tptomptp(sototcpcb(so)); in tcp_getlock() local
3365 struct socket *mp_so = mptetoso(mp_tp->mpt_mpte); in tcp_getlock()
H A Dtcp_timer.c1485 struct mptcb *mp_tp = tptomptp(tp); in tcp_timers() local
1489 } else if (mp_tp != NULL) { in tcp_timers()
1490 if ((mptcp_ok_to_keepalive(mp_tp) == 0)) { in tcp_timers()
H A Dtcp_input.c2045 struct mptcb *mp_tp = NULL; in tcp_input() local
3471 if ((tp->t_mpflags & TMPF_MPTCP_TRUE) && (mp_tp = tptomptp(tp))) { in tcp_input()
3472 socket_lock_assert_owned(mptetoso(mp_tp->mpt_mpte)); in tcp_input()
3473 int64_t recwin_conn = (int64_t)(mp_tp->mpt_rcvadv - mp_tp->mpt_rcvnxt); in tcp_input()