Branch data     Line data    Source code

       1                 :             : // SPDX-License-Identifier: GPL-2.0
       2                 :             : /* MPTCP Fast Open Mechanism
       3                 :             :  *
       4                 :             :  * Copyright (c) 2021-2022, Dmytro SHYTYI
       5                 :             :  */
       6                 :             : 
       7                 :             : #include "protocol.h"
       8                 :             : 
       9                 :          38 : void mptcp_fastopen_subflow_synack_set_params(struct mptcp_subflow_context *subflow,
      10                 :             :                                               struct request_sock *req)
      11                 :             : {
      12                 :          38 :         struct sock *sk, *ssk;
      13                 :          38 :         struct sk_buff *skb;
      14                 :          38 :         struct tcp_sock *tp;
      15                 :             : 
      16                 :             :         /* on early fallback the subflow context is deleted by
      17                 :             :          * subflow_syn_recv_sock()
      18                 :             :          */
      19         [ +  - ]:          38 :         if (!subflow)
      20                 :             :                 return;
      21                 :             : 
      22                 :          38 :         ssk = subflow->tcp_sock;
      23                 :          38 :         sk = subflow->conn;
      24         [ -  + ]:          38 :         tp = tcp_sk(ssk);
      25                 :             : 
      26                 :          38 :         subflow->is_mptfo = 1;
      27                 :             : 
      28         [ +  - ]:          38 :         skb = skb_peek(&ssk->sk_receive_queue);
      29         [ -  + ]:          38 :         if (WARN_ON_ONCE(!skb))
      30                 :           0 :                 return;
      31                 :             : 
      32                 :             :         /* dequeue the skb from sk receive queue */
      33                 :          38 :         __skb_unlink(skb, &ssk->sk_receive_queue);
      34                 :          38 :         skb_ext_reset(skb);
      35                 :          38 :         skb_orphan(skb);
      36                 :             : 
      37                 :             :         /* We copy the fastopen data, but that don't belong to the mptcp sequence
      38                 :             :          * space, need to offset it in the subflow sequence, see mptcp_subflow_get_map_offset()
      39                 :             :          */
      40                 :          38 :         tp->copied_seq += skb->len;
      41                 :          38 :         subflow->ssn_offset += skb->len;
      42                 :             : 
      43                 :             :         /* Only the sequence delta is relevant */
      44                 :          38 :         MPTCP_SKB_CB(skb)->map_seq = -skb->len;
      45                 :          38 :         MPTCP_SKB_CB(skb)->end_seq = 0;
      46                 :          38 :         MPTCP_SKB_CB(skb)->offset = 0;
      47                 :          38 :         MPTCP_SKB_CB(skb)->has_rxtstamp = TCP_SKB_CB(skb)->has_rxtstamp;
      48                 :          38 :         MPTCP_SKB_CB(skb)->cant_coalesce = 1;
      49                 :             : 
      50                 :          38 :         mptcp_data_lock(sk);
      51         [ -  + ]:          38 :         DEBUG_NET_WARN_ON_ONCE(sock_owned_by_user_nocheck(sk));
      52                 :             : 
      53                 :          38 :         skb_set_owner_r(skb, sk);
      54         [ -  + ]:          38 :         __skb_queue_tail(&sk->sk_receive_queue, skb);
      55         [ -  + ]:          38 :         mptcp_sk(sk)->bytes_received += skb->len;
      56                 :             : 
      57                 :          38 :         sk->sk_data_ready(sk);
      58                 :             : 
      59                 :          38 :         mptcp_data_unlock(sk);
      60                 :             : }