Lines Matching defs:mpte
116 mptcp_input(struct mptses *mpte, struct mbuf *m)
128 MPTE_LOCK_ASSERT_HELD(mpte); /* same as MP socket lock */
129 mp_so = mpte->mpte_mppcb->mpp_socket;
153 struct mptses *, mpte);
159 mp_tp = mpte->mpte_mptcb;
216 struct mptses *, mpte,
243 mptcp_output(struct mptses *mpte)
250 MPTE_LOCK_ASSERT_HELD(mpte); /* same as MP socket lock */
251 mp_so = mpte->mpte_mppcb->mpp_socket;
258 mpts = mptcp_get_subflow(mpte, NULL);
277 MPT_LOCK(mpte->mpte_mptcb);
278 mptcp_start_timer(mpte->mpte_mptcb, MPTT_REXMT);
279 MPT_UNLOCK(mpte->mpte_mptcb);
285 DTRACE_MPTCP3(output, struct mptses *, mpte, struct mptsub *, mpts,
287 error = mptcp_subflow_output(mpte, mpts);
300 if (mpte->mpte_active_sub == NULL) {
301 mpte->mpte_active_sub = mpts;
302 } else if (mpte->mpte_active_sub != mpts) {
303 MPTS_LOCK(mpte->mpte_active_sub);
304 mpte->mpte_active_sub->mpts_flags &= ~MPTSF_ACTIVE;
305 MPTS_UNLOCK(mpte->mpte_active_sub);
306 mpte->mpte_active_sub = mpts;
319 mptcp_get_subflow(struct mptses *mpte, struct mptsub *ignore)
325 MPTE_LOCK_ASSERT_HELD(mpte); /* same as MP socket lock */
327 TAILQ_FOREACH(mpts, &mpte->mpte_subflows, mpts_entry) {