Lines Matching refs:subflow

177 				 const struct mptcp_subflow_context *subflow)  in mptcp_pm_subflow_check_next()  argument
182 update_subflows = subflow->request_join || subflow->mp_join; in mptcp_pm_subflow_check_next()
211 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); in mptcp_pm_add_addr_received() local
212 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_pm_add_addr_received()
287 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); in mptcp_pm_mp_prio_received() local
288 struct sock *sk = subflow->conn; in mptcp_pm_mp_prio_received()
291 pr_debug("subflow->backup=%d, bkup=%d\n", subflow->backup, bkup); in mptcp_pm_mp_prio_received()
293 if (subflow->backup != bkup) in mptcp_pm_mp_prio_received()
294 subflow->backup = bkup; in mptcp_pm_mp_prio_received()
301 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(sk); in mptcp_pm_mp_fail_received() local
302 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_pm_mp_fail_received()
309 if (!subflow->fail_tout) { in mptcp_pm_mp_fail_received()
312 subflow->send_mp_fail = 1; in mptcp_pm_mp_fail_received()
313 subflow->send_infinite_map = 1; in mptcp_pm_mp_fail_received()
317 WRITE_ONCE(subflow->fail_tout, 0); in mptcp_pm_mp_fail_received()
458 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); in mptcp_pm_subflow_chk_stale() local
462 if (!subflow->stale_count) { in mptcp_pm_subflow_chk_stale()
463 subflow->stale_rcv_tstamp = rcv_tstamp; in mptcp_pm_subflow_chk_stale()
464 subflow->stale_count++; in mptcp_pm_subflow_chk_stale()
465 } else if (subflow->stale_rcv_tstamp == rcv_tstamp) { in mptcp_pm_subflow_chk_stale()
466 if (subflow->stale_count < U8_MAX) in mptcp_pm_subflow_chk_stale()
467 subflow->stale_count++; in mptcp_pm_subflow_chk_stale()
470 subflow->stale_count = 0; in mptcp_pm_subflow_chk_stale()
471 mptcp_subflow_set_active(subflow); in mptcp_pm_subflow_chk_stale()