Lines Matching full:subflow

180 				 const struct mptcp_subflow_context *subflow)  in mptcp_pm_subflow_check_next()  argument
185 update_subflows = subflow->request_join || subflow->mp_join; in mptcp_pm_subflow_check_next()
202 /* Even if this subflow is not really established, tell the PM to try in mptcp_pm_subflow_check_next()
214 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); in mptcp_pm_add_addr_received() local
215 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_pm_add_addr_received()
290 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); in mptcp_pm_mp_prio_received() local
291 struct sock *sk = subflow->conn; in mptcp_pm_mp_prio_received()
294 pr_debug("subflow->backup=%d, bkup=%d\n", subflow->backup, bkup); in mptcp_pm_mp_prio_received()
296 if (subflow->backup != bkup) in mptcp_pm_mp_prio_received()
297 subflow->backup = bkup; in mptcp_pm_mp_prio_received()
304 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(sk); in mptcp_pm_mp_fail_received() local
305 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_pm_mp_fail_received()
312 if (!subflow->fail_tout) { in mptcp_pm_mp_fail_received()
315 subflow->send_mp_fail = 1; in mptcp_pm_mp_fail_received()
316 subflow->send_infinite_map = 1; in mptcp_pm_mp_fail_received()
320 WRITE_ONCE(subflow->fail_tout, 0); in mptcp_pm_mp_fail_received()
411 /* The 0 ID mapping is defined by the first subflow, copied into the msk in mptcp_pm_get_local_id()
461 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); in mptcp_pm_subflow_chk_stale() local
465 if (!subflow->stale_count) { in mptcp_pm_subflow_chk_stale()
466 subflow->stale_rcv_tstamp = rcv_tstamp; in mptcp_pm_subflow_chk_stale()
467 subflow->stale_count++; in mptcp_pm_subflow_chk_stale()
468 } else if (subflow->stale_rcv_tstamp == rcv_tstamp) { in mptcp_pm_subflow_chk_stale()
469 if (subflow->stale_count < U8_MAX) in mptcp_pm_subflow_chk_stale()
470 subflow->stale_count++; in mptcp_pm_subflow_chk_stale()
473 subflow->stale_count = 0; in mptcp_pm_subflow_chk_stale()
474 mptcp_subflow_set_active(subflow); in mptcp_pm_subflow_chk_stale()