Lines Matching refs:subflow
399 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(sk); in mptcp_syn_options() local
404 subflow->snd_isn = TCP_SKB_CB(skb)->end_seq; in mptcp_syn_options()
405 if (subflow->request_mptcp) { in mptcp_syn_options()
411 } else if (subflow->request_join) { in mptcp_syn_options()
412 pr_debug("remote_token=%u, nonce=%u", subflow->remote_token, in mptcp_syn_options()
413 subflow->local_nonce); in mptcp_syn_options()
415 opts->join_id = subflow->local_id; in mptcp_syn_options()
416 opts->token = subflow->remote_token; in mptcp_syn_options()
417 opts->nonce = subflow->local_nonce; in mptcp_syn_options()
418 opts->backup = subflow->request_bkup; in mptcp_syn_options()
441 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(sk); in mptcp_established_options_mp() local
442 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_established_options_mp()
457 if (subflow->fully_established || snd_data_fin_enable || in mptcp_established_options_mp()
458 subflow->snd_isn != TCP_SKB_CB(skb)->seq || in mptcp_established_options_mp()
462 if (subflow->mp_capable) { in mptcp_established_options_mp()
472 opts->sndr_key = subflow->local_key; in mptcp_established_options_mp()
473 opts->rcvr_key = subflow->remote_key; in mptcp_established_options_mp()
497 subflow, subflow->local_key, subflow->remote_key, in mptcp_established_options_mp()
501 } else if (subflow->mp_join) { in mptcp_established_options_mp()
503 memcpy(opts->hmac, subflow->hmac, MPTCPOPT_HMAC_LEN); in mptcp_established_options_mp()
505 pr_debug("subflow=%p", subflow); in mptcp_established_options_mp()
513 set_bit(MPTCP_DELEGATE_ACK, &subflow->delegated_status); in mptcp_established_options_mp()
515 mptcp_subflow_delegate(subflow, MPTCP_DELEGATE_ACK); in mptcp_established_options_mp()
521 static void mptcp_write_data_fin(struct mptcp_subflow_context *subflow, in mptcp_write_data_fin() argument
527 u64 data_fin_tx_seq = READ_ONCE(mptcp_sk(subflow->conn)->write_seq) - 1; in mptcp_write_data_fin()
555 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(sk); in mptcp_established_options_dss() local
556 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_established_options_dss()
579 mptcp_write_data_fin(subflow, skb, &opts->ext_copy); in mptcp_established_options_dss()
649 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(sk); in mptcp_established_options_add_addr() local
650 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_established_options_add_addr()
702 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(sk); in mptcp_established_options_rm_addr() local
703 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_established_options_rm_addr()
732 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(sk); in mptcp_established_options_mp_prio() local
737 if (!subflow->send_mp_prio || (opts->suboptions & OPTIONS_MPTCP_MPC)) in mptcp_established_options_mp_prio()
746 opts->backup = subflow->request_bkup; in mptcp_established_options_mp_prio()
758 const struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(sk); in mptcp_established_options_rst() local
765 opts->reset_transient = subflow->reset_transient; in mptcp_established_options_rst()
766 opts->reset_reason = subflow->reset_reason; in mptcp_established_options_rst()
776 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(sk); in mptcp_established_options_mp_fail() local
778 if (likely(!subflow->send_mp_fail)) in mptcp_established_options_mp_fail()
786 opts->fail_seq = subflow->map_seq; in mptcp_established_options_mp_fail()
797 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(sk); in mptcp_established_options() local
798 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_established_options()
889 struct mptcp_subflow_context *subflow, in check_fully_established() argument
896 if (likely(subflow->fully_established)) { in check_fully_established()
901 if (TCP_SKB_CB(skb)->seq == subflow->ssn_offset + 1 && in check_fully_established()
903 subflow->mp_join && (mp_opt->suboptions & OPTIONS_MPTCP_MPJ) && in check_fully_established()
914 if (TCP_SKB_CB(skb)->seq != subflow->ssn_offset + 1) { in check_fully_established()
915 if (subflow->mp_join) in check_fully_established()
917 return subflow->mp_capable; in check_fully_established()
925 subflow->fully_established = 1; in check_fully_established()
935 if (subflow->mp_join) in check_fully_established()
937 subflow->mp_capable = 0; in check_fully_established()
948 mptcp_subflow_fully_established(subflow, mp_opt); in check_fully_established()
956 if (likely(subflow->pm_notified) || list_empty(&subflow->node)) in check_fully_established()
959 subflow->pm_notified = 1; in check_fully_established()
960 if (subflow->mp_join) { in check_fully_established()
1069 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(sk); in mptcp_incoming_options() local
1070 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_incoming_options()
1080 mptcp_data_lock(subflow->conn); in mptcp_incoming_options()
1082 __mptcp_check_push(subflow->conn, sk); in mptcp_incoming_options()
1083 __mptcp_data_acked(subflow->conn); in mptcp_incoming_options()
1084 mptcp_data_unlock(subflow->conn); in mptcp_incoming_options()
1093 if (!check_fully_established(msk, sk, subflow, skb, &mp_opt)) in mptcp_incoming_options()
1132 subflow->reset_seen = 1; in mptcp_incoming_options()
1133 subflow->reset_reason = mp_opt.reset_reason; in mptcp_incoming_options()
1134 subflow->reset_transient = mp_opt.reset_transient; in mptcp_incoming_options()
1156 sock_hold(subflow->conn); in mptcp_incoming_options()
1172 mptcp_crypto_key_sha(subflow->remote_key, NULL, in mptcp_incoming_options()
1199 const struct mptcp_subflow_context *subflow; in mptcp_set_rwin() local
1203 subflow = mptcp_subflow_ctx(ssk); in mptcp_set_rwin()
1204 msk = mptcp_sk(subflow->conn); in mptcp_set_rwin()
1242 struct mptcp_subflow_context *subflow; in mptcp_write_options() local
1244 subflow = mptcp_subflow_ctx(ssk); in mptcp_write_options()
1245 subflow->send_mp_fail = 0; in mptcp_write_options()
1454 struct mptcp_subflow_context *subflow; in mptcp_write_options() local
1456 subflow = mptcp_subflow_ctx(ssk); in mptcp_write_options()
1457 subflow->send_mp_prio = 0; in mptcp_write_options()