Lines Matching full:subflow

188 				 const struct mptcp_subflow_context *subflow)  in mptcp_pm_subflow_check_next()  argument
193 update_subflows = subflow->request_join || subflow->mp_join; in mptcp_pm_subflow_check_next()
210 /* Even if this subflow is not really established, tell the PM to try in mptcp_pm_subflow_check_next()
222 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); in mptcp_pm_add_addr_received() local
223 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_pm_add_addr_received()
296 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); in mptcp_pm_mp_prio_received() local
297 struct sock *sk = subflow->conn; in mptcp_pm_mp_prio_received()
300 pr_debug("subflow->backup=%d, bkup=%d\n", subflow->backup, bkup); in mptcp_pm_mp_prio_received()
302 if (subflow->backup != bkup) in mptcp_pm_mp_prio_received()
303 subflow->backup = bkup; in mptcp_pm_mp_prio_received()
310 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(sk); in mptcp_pm_mp_fail_received() local
311 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_pm_mp_fail_received()
318 if (!subflow->fail_tout) { in mptcp_pm_mp_fail_received()
321 subflow->send_mp_fail = 1; in mptcp_pm_mp_fail_received()
322 subflow->send_infinite_map = 1; in mptcp_pm_mp_fail_received()
326 WRITE_ONCE(subflow->fail_tout, 0); in mptcp_pm_mp_fail_received()
417 /* The 0 ID mapping is defined by the first subflow, copied into the msk in mptcp_pm_get_local_id()
455 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); in mptcp_pm_subflow_chk_stale() local
459 if (!subflow->stale_count) { in mptcp_pm_subflow_chk_stale()
460 subflow->stale_rcv_tstamp = rcv_tstamp; in mptcp_pm_subflow_chk_stale()
461 subflow->stale_count++; in mptcp_pm_subflow_chk_stale()
462 } else if (subflow->stale_rcv_tstamp == rcv_tstamp) { in mptcp_pm_subflow_chk_stale()
463 if (subflow->stale_count < U8_MAX) in mptcp_pm_subflow_chk_stale()
464 subflow->stale_count++; in mptcp_pm_subflow_chk_stale()
467 subflow->stale_count = 0; in mptcp_pm_subflow_chk_stale()
468 mptcp_subflow_set_active(subflow); in mptcp_pm_subflow_chk_stale()