Lines Matching refs:subflow

179 				 const struct mptcp_subflow_context *subflow)  in mptcp_pm_subflow_check_next()  argument
184 update_subflows = (subflow->request_join || subflow->mp_join) && in mptcp_pm_subflow_check_next()
205 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); in mptcp_pm_add_addr_received() local
206 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_pm_add_addr_received()
279 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); in mptcp_pm_mp_prio_received() local
280 struct sock *sk = subflow->conn; in mptcp_pm_mp_prio_received()
283 pr_debug("subflow->backup=%d, bkup=%d\n", subflow->backup, bkup); in mptcp_pm_mp_prio_received()
285 if (subflow->backup != bkup) { in mptcp_pm_mp_prio_received()
286 subflow->backup = bkup; in mptcp_pm_mp_prio_received()
300 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(sk); in mptcp_pm_mp_fail_received() local
301 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_pm_mp_fail_received()
308 if (!subflow->fail_tout) { in mptcp_pm_mp_fail_received()
311 subflow->send_mp_fail = 1; in mptcp_pm_mp_fail_received()
312 subflow->send_infinite_map = 1; in mptcp_pm_mp_fail_received()
316 WRITE_ONCE(subflow->fail_tout, 0); in mptcp_pm_mp_fail_received()
406 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); in mptcp_pm_subflow_chk_stale() local
410 if (!subflow->stale_count) { in mptcp_pm_subflow_chk_stale()
411 subflow->stale_rcv_tstamp = rcv_tstamp; in mptcp_pm_subflow_chk_stale()
412 subflow->stale_count++; in mptcp_pm_subflow_chk_stale()
413 } else if (subflow->stale_rcv_tstamp == rcv_tstamp) { in mptcp_pm_subflow_chk_stale()
414 if (subflow->stale_count < U8_MAX) in mptcp_pm_subflow_chk_stale()
415 subflow->stale_count++; in mptcp_pm_subflow_chk_stale()
418 subflow->stale_count = 0; in mptcp_pm_subflow_chk_stale()
419 mptcp_subflow_set_active(subflow); in mptcp_pm_subflow_chk_stale()