Lines Matching refs:subflow
128 struct mptcp_subflow_context *subflow; in lookup_subflow_by_saddr() local
132 list_for_each_entry(subflow, list, node) { in lookup_subflow_by_saddr()
133 skc = (struct sock_common *)mptcp_subflow_tcp_sock(subflow); in lookup_subflow_by_saddr()
146 struct mptcp_subflow_context *subflow; in lookup_subflow_by_daddr() local
150 list_for_each_entry(subflow, list, node) { in lookup_subflow_by_daddr()
151 skc = (struct sock_common *)mptcp_subflow_tcp_sock(subflow); in lookup_subflow_by_daddr()
433 struct mptcp_subflow_context *subflow; in fill_remote_addresses_vec() local
448 mptcp_for_each_subflow(msk, subflow) { in fill_remote_addresses_vec()
449 ssk = mptcp_subflow_tcp_sock(subflow); in fill_remote_addresses_vec()
634 struct mptcp_subflow_context *subflow; in mptcp_pm_nl_addr_send_ack() local
644 subflow = list_first_entry_or_null(&msk->conn_list, typeof(*subflow), node); in mptcp_pm_nl_addr_send_ack()
645 if (subflow) { in mptcp_pm_nl_addr_send_ack()
646 struct sock *ssk = mptcp_subflow_tcp_sock(subflow); in mptcp_pm_nl_addr_send_ack()
661 struct mptcp_subflow_context *subflow; in mptcp_pm_nl_mp_prio_send_ack() local
665 mptcp_for_each_subflow(msk, subflow) { in mptcp_pm_nl_mp_prio_send_ack()
666 struct sock *ssk = mptcp_subflow_tcp_sock(subflow); in mptcp_pm_nl_mp_prio_send_ack()
674 subflow->backup = bkup; in mptcp_pm_nl_mp_prio_send_ack()
675 subflow->send_mp_prio = 1; in mptcp_pm_nl_mp_prio_send_ack()
676 subflow->request_bkup = bkup; in mptcp_pm_nl_mp_prio_send_ack()
694 struct mptcp_subflow_context *subflow, *tmp; in mptcp_pm_nl_rm_addr_or_subflow() local
713 list_for_each_entry_safe(subflow, tmp, &msk->conn_list, node) { in mptcp_pm_nl_rm_addr_or_subflow()
714 struct sock *ssk = mptcp_subflow_tcp_sock(subflow); in mptcp_pm_nl_rm_addr_or_subflow()
716 u8 id = subflow->local_id; in mptcp_pm_nl_rm_addr_or_subflow()
719 id = subflow->remote_id; in mptcp_pm_nl_rm_addr_or_subflow()
726 i, rm_list->ids[i], subflow->local_id, subflow->remote_id); in mptcp_pm_nl_rm_addr_or_subflow()
729 mptcp_close_ssk(sk, ssk, subflow); in mptcp_pm_nl_rm_addr_or_subflow()
1003 struct mptcp_subflow_context *iter, *subflow = mptcp_subflow_ctx(ssk); in mptcp_pm_nl_subflow_chk_stale() local
1011 if (subflow->stale || !stale_loss_cnt || subflow->stale_count <= stale_loss_cnt) in mptcp_pm_nl_subflow_chk_stale()
1017 if (iter != subflow && mptcp_subflow_active(iter) && in mptcp_pm_nl_subflow_chk_stale()
1022 subflow->stale = 1; in mptcp_pm_nl_subflow_chk_stale()