Lines Matching refs:mpts

433 	struct mptsub *mpts;  in mptcp_getconnids()  local
448 TAILQ_FOREACH(mpts, &mpte->mpte_subflows, mpts_entry) { in mptcp_getconnids()
449 if ((error = copyout(&mpts->mpts_connid, cidp, in mptcp_getconnids()
450 sizeof(mpts->mpts_connid))) != 0) { in mptcp_getconnids()
454 cidp += sizeof(mpts->mpts_connid); in mptcp_getconnids()
514 const struct mptsub *mpts; in mptcp_getconninfo() local
525 TAILQ_FOREACH(mpts, &mpte->mpte_subflows, mpts_entry) { in mptcp_getconninfo()
529 mptcp_ci.mptcpci_subflow_connids[i] = mpts->mpts_connid; in mptcp_getconninfo()
531 if (mpts->mpts_flags & MPTSF_INITIAL_SUB) { in mptcp_getconninfo()
534 inp = sotoinpcb(mpts->mpts_socket); in mptcp_getconninfo()
541 mptcpstats_update(mptcp_ci.mptcpci_itfstats, MPTCP_ITFSTATS_SIZE, mpts); in mptcp_getconninfo()
568 const struct mptsub *mpts; in mptcp_getconninfo() local
573 mpts = TAILQ_FIRST(&mpte->mpte_subflows); in mptcp_getconninfo()
574 if (mpts == NULL) { in mptcp_getconninfo()
578 so = mpts->mpts_socket; in mptcp_getconninfo()
597 if (mpts->mpts_flags & MPTSF_MP_CAPABLE) { in mptcp_getconninfo()
600 if (mpts->mpts_flags & MPTSF_MP_DEGRADED) { in mptcp_getconninfo()
603 if (mpts->mpts_flags & MPTSF_MP_READY) { in mptcp_getconninfo()
606 if (mpts->mpts_flags & MPTSF_ACTIVE) { in mptcp_getconninfo()
616 const struct mptsub *mpts, *orig_mpts = NULL; in mptcp_getconninfo() local
631 TAILQ_FOREACH(mpts, &mpte->mpte_subflows, mpts_entry) { in mptcp_getconninfo()
632 const struct ifnet *ifp = sotoinpcb(mpts->mpts_socket)->inp_last_outifp; in mptcp_getconninfo()
639 if (mpts == NULL) { in mptcp_getconninfo()
644 so = mpts->mpts_socket; in mptcp_getconninfo()
665 if (mpts->mpts_flags & MPTSF_MP_CAPABLE) { in mptcp_getconninfo()
668 if (mpts->mpts_flags & MPTSF_MP_DEGRADED) { in mptcp_getconninfo()
671 if (mpts->mpts_flags & MPTSF_MP_READY) { in mptcp_getconninfo()
674 if (mpts->mpts_flags & MPTSF_ACTIVE) { in mptcp_getconninfo()
692 orig_mpts = mpts; in mptcp_getconninfo()
693 TAILQ_FOREACH(mpts, &mpte->mpte_subflows, mpts_entry) { in mptcp_getconninfo()
694 const struct inpcb *mptsinp = sotoinpcb(mpts->mpts_socket); in mptcp_getconninfo()
699 if (ifp == NULL || ifp->if_index != *cid || mpts == orig_mpts) { in mptcp_getconninfo()
982 struct mptsub *mpts; in mptcp_finish_usrclosed() local
984 TAILQ_FOREACH(mpts, &mpte->mpte_subflows, mpts_entry) { in mptcp_finish_usrclosed()
987 mptcp_subflow_disconnect(mpte, mpts); in mptcp_finish_usrclosed()
989 mptcp_subflow_shutdown(mpte, mpts); in mptcp_finish_usrclosed()
1025 struct mptsub *mpts; in mptcp_usr_rcvd() local
1035 TAILQ_FOREACH(mpts, &mpte->mpte_subflows, mpts_entry) { in mptcp_usr_rcvd()
1036 struct socket *so = mpts->mpts_socket; in mptcp_usr_rcvd()
1479 struct mptsub *mpts; in mptcp_setopt_apply() local
1521 TAILQ_FOREACH(mpts, &mpte->mpte_subflows, mpts_entry) { in mptcp_setopt_apply()
1524 mpts->mpts_flags &= ~(MPTSF_SOPT_OLDVAL | MPTSF_SOPT_INPROG); in mptcp_setopt_apply()
1525 mpts->mpts_oldintval = 0; in mptcp_setopt_apply()
1527 VERIFY(mpts->mpts_socket != NULL); in mptcp_setopt_apply()
1528 so = mpts->mpts_socket; in mptcp_setopt_apply()
1530 mpts->mpts_flags |= MPTSF_SOPT_OLDVAL; in mptcp_setopt_apply()
1531 mpts->mpts_oldintval = smpo.mpo_intval; in mptcp_setopt_apply()
1536 TAILQ_FOREACH(mpts, &mpte->mpte_subflows, mpts_entry) { in mptcp_setopt_apply()
1539 mpts->mpts_flags |= MPTSF_SOPT_INPROG; in mptcp_setopt_apply()
1540 VERIFY(mpts->mpts_socket != NULL); in mptcp_setopt_apply()
1541 so = mpts->mpts_socket; in mptcp_setopt_apply()
1542 error = mptcp_subflow_sosetopt(mpte, mpts, mpo); in mptcp_setopt_apply()
1549 TAILQ_FOREACH(mpts, &mpte->mpte_subflows, mpts_entry) { in mptcp_setopt_apply()
1552 if (!(mpts->mpts_flags & MPTSF_SOPT_INPROG)) { in mptcp_setopt_apply()
1554 mpts->mpts_flags &= ~MPTSF_SOPT_OLDVAL; in mptcp_setopt_apply()
1555 mpts->mpts_oldintval = 0; in mptcp_setopt_apply()
1558 if (!(mpts->mpts_flags & MPTSF_SOPT_OLDVAL)) { in mptcp_setopt_apply()
1559 mpts->mpts_flags &= ~MPTSF_SOPT_INPROG; in mptcp_setopt_apply()
1560 VERIFY(mpts->mpts_oldintval == 0); in mptcp_setopt_apply()
1565 VERIFY(mpts->mpts_socket != NULL); in mptcp_setopt_apply()
1566 so = mpts->mpts_socket; in mptcp_setopt_apply()
1567 smpo.mpo_intval = mpts->mpts_oldintval; in mptcp_setopt_apply()
1568 mptcp_subflow_sosetopt(mpte, mpts, &smpo); in mptcp_setopt_apply()
1570 mpts->mpts_oldintval = 0; in mptcp_setopt_apply()
1571 mpts->mpts_flags &= ~(MPTSF_SOPT_OLDVAL | MPTSF_SOPT_INPROG); in mptcp_setopt_apply()
1944 struct mptsub *mpts; in mptcp_fill_info_bytestats() local
1947 TAILQ_FOREACH(mpts, &mpte->mpte_subflows, mpts_entry) { in mptcp_fill_info_bytestats()
1948 const struct inpcb *inp = sotoinpcb(mpts->mpts_socket); in mptcp_fill_info_bytestats()
2364 struct mptsub *__single mpts = NULL; in mptcp_usr_preconnect() local
2373 mpts = mptcp_get_subflow(mpte, NULL); in mptcp_usr_preconnect()
2374 if (mpts == NULL) { in mptcp_usr_preconnect()
2379 mpts->mpts_flags &= ~MPTSF_TFO_REQD; in mptcp_usr_preconnect()
2380 so = mpts->mpts_socket; in mptcp_usr_preconnect()