Home
last modified time | relevance | path

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

/xnu-12377.81.4/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()
78 DTRACE_MPTCP2(timer, struct mptses *, mpte, struct mptcb *, mp_tp); in mptcp_timer_demux()
80 switch (mp_tp->mpt_timer_vals) { in mptcp_timer_demux()
82 if (mp_tp->mpt_rxtstart == 0) { in mptcp_timer_demux()
85 if ((now_msecs - mp_tp->mpt_rxtstart) > (mptcp_rto * hz)) { in mptcp_timer_demux()
86 if (MPTCP_SEQ_GT(mp_tp->mpt_snduna, mp_tp->mpt_rtseq)) { in mptcp_timer_demux()
87 mp_tp->mpt_timer_vals = 0; in mptcp_timer_demux()
88 mp_tp->mpt_rtseq = 0; in mptcp_timer_demux()
91 mp_tp->mpt_rxtshift++; in mptcp_timer_demux()
[all …]
H A Dmptcp_opt.c72 struct mptcb *mp_tp = tptomptp(tp); in mptcp_setup_first_subflow_syn_opts() local
73 struct mptses *mpte = mp_tp->mpt_mpte; in mptcp_setup_first_subflow_syn_opts()
76 uint8_t mmco_len = mp_tp->mpt_version == MPTCP_VERSION_0 ? in mptcp_setup_first_subflow_syn_opts()
83 __func__, (unsigned long)VM_KERNEL_ADDRPERM(mp_tp->mpt_mpte)); in mptcp_setup_first_subflow_syn_opts()
84 mp_tp->mpt_flags |= MPTCPF_FALLBACK_HEURISTIC; in mptcp_setup_first_subflow_syn_opts()
94 if (!(mp_tp->mpt_flags & (MPTCPF_FALLBACK_HEURISTIC | MPTCPF_HEURISTIC_TRAC))) { in mptcp_setup_first_subflow_syn_opts()
95 mp_tp->mpt_flags |= MPTCPF_HEURISTIC_TRAC; in mptcp_setup_first_subflow_syn_opts()
106 mptcp_opt.mmc_common.mmco_version = mp_tp->mpt_version; in mptcp_setup_first_subflow_syn_opts()
108 if (mp_tp->mpt_flags & MPTCPF_CHECKSUM) { in mptcp_setup_first_subflow_syn_opts()
111 mptcp_opt.mmc_localkey = mp_tp->mpt_localkey; in mptcp_setup_first_subflow_syn_opts()
[all …]
H A Dmptcp.c211 struct mptcb *mp_tp = mpte->mpte_mptcb; in mptcp_reass_present() local
221 if (mp_tp->mpt_state < MPTCPS_ESTABLISHED) { in mptcp_reass_present()
224 q = LIST_FIRST(&mp_tp->mpt_segq); in mptcp_reass_present()
225 if (!q || q->tqe_m->m_pkthdr.mp_dsn != mp_tp->mpt_rcvnxt) { in mptcp_reass_present()
234 if (mp_tp->mpt_flags & MPTCPF_REASS_INPROG) { in mptcp_reass_present()
238 mp_tp->mpt_flags |= MPTCPF_REASS_INPROG; in mptcp_reass_present()
241 mp_tp->mpt_rcvnxt += q->tqe_len; in mptcp_reass_present()
252 mp_tp->mpt_reassqlen--; in mptcp_reass_present()
254 q = LIST_FIRST(&mp_tp->mpt_segq); in mptcp_reass_present()
255 } while (q && q->tqe_m->m_pkthdr.mp_dsn == mp_tp->mpt_rcvnxt); in mptcp_reass_present()
[all …]
H A Dmptcp_subr.c117 static int mptcp_freeq(struct mptcb *mp_tp);
267 struct mptcb *mp_tp; in mptcp_session_create() local
275 mp_tp = &mtp->mtcb; in mptcp_session_create()
282 mpte->mpte_mptcb = mp_tp; in mptcp_session_create()
301 bzero(mp_tp, sizeof(*mp_tp)); in mptcp_session_create()
302 mp_tp->mpt_mpte = mpte; in mptcp_session_create()
303 mp_tp->mpt_state = MPTCPS_CLOSED; in mptcp_session_create()
496 struct mptcb *mp_tp = mpte->mpte_mptcb; in mptcp_session_destroy() local
498 VERIFY(mp_tp != NULL); in mptcp_session_destroy()
511 mptcp_freeq(mp_tp); in mptcp_session_destroy()
[all …]
H A Dmptcp_usrreq.c179 struct mptcb *__single mp_tp = NULL; in mptcp_attach() local
214 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()
310 if (mp_tp->mpt_flags & MPTCPF_FALLBACK_TO_TCP) { in mptcp_usr_connectx()
473 struct mptcb *mp_tp = mpte->mpte_mptcb; in mptcp_getconninfo() local
497 if (!(mp_tp->mpt_flags & MPTCPF_FALLBACK_TO_TCP)) { in mptcp_getconninfo()
500 if (mp_tp->mpt_flags & MPTCPF_FALLBACK_TO_TCP) { in mptcp_getconninfo()
503 if (mp_tp->mpt_version == MPTCP_VERSION_1) { in mptcp_getconninfo()
[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_var.h555 extern boolean_t mptcp_ok_to_create_subflows(struct mptcb *mp_tp);
561 extern struct mptses *mptcp_drop(struct mptses *mpte, struct mptcb *mp_tp, u_short errno);
594 extern boolean_t mptcp_can_send_more(struct mptcb *mp_tp, boolean_t ignore_reinject);
622 extern void mptcp_sbrcv_grow(struct mptcb *mp_tp);
H A Dmptcp_opt.h39 extern void mptcp_data_ack_rcvd(struct mptcb *mp_tp, struct tcpcb *tp, u_int64_t full_dack);
H A Dtcp_output.c1716 struct mptcb *mp_tp = tptomptp(tp); in tcp_output() local
1722 mp_tp->mpt_version == MPTCP_VERSION_0) || in tcp_output()
1789 struct mptcb *mp_tp = tptomptp(tp); in tcp_output() local
1790 struct socket *mp_so = mptetoso(mp_tp->mpt_mpte); in tcp_output()
1834 struct mptcb *mp_tp = tptomptp(tp); in tcp_output() local
1835 int64_t recwin_announced = (int64_t)(mp_tp->mpt_rcvadv - mp_tp->mpt_rcvnxt); in tcp_output()
1843 if (mp_tp->mpt_flags & MPTCPF_FALLBACK_TO_TCP) { in tcp_output()
2986 struct mptcb *mp_tp = tptomptp(tp); in tcp_output() local
2991 if (recwin > 0 && MPTCP_SEQ_LT(mp_tp->mpt_rcvadv, mp_tp->mpt_rcvnxt + recwin)) { in tcp_output()
2992 mp_tp->mpt_rcvadv = mp_tp->mpt_rcvnxt + recwin; in tcp_output()
H A Dtcp_timer.c1477 struct mptcb *mp_tp = tptomptp(tp); in tcp_timers() local
1481 } else if (mp_tp != NULL) { in tcp_timers()
1482 if ((mptcp_ok_to_keepalive(mp_tp) == 0)) { in tcp_timers()
H A Dtcp_subr.c3507 struct mptcb *mp_tp = tptomptp(sototcpcb(so)); in tcp_lock() local
3508 struct socket *mp_so = mptetoso(mp_tp->mpt_mpte); in tcp_lock()
3583 struct mptcb *mp_tp = tptomptp(sototcpcb(so)); in tcp_unlock() local
3584 struct socket *mp_so = mptetoso(mp_tp->mpt_mpte); in tcp_unlock()
3610 struct mptcb *mp_tp = tptomptp(sototcpcb(so)); in tcp_getlock() local
3611 struct socket *mp_so = mptetoso(mp_tp->mpt_mpte); in tcp_getlock()
H A Dtcp_input.c2781 struct mptcb *mp_tp = NULL; in tcp_input() local
4043 if ((tp->t_mpflags & TMPF_MPTCP_TRUE) && (mp_tp = tptomptp(tp))) { in tcp_input()
4044 socket_lock_assert_owned(mptetoso(mp_tp->mpt_mpte)); in tcp_input()
4045 int64_t recwin_conn = (int64_t)(mp_tp->mpt_rcvadv - mp_tp->mpt_rcvnxt); in tcp_input()