13ee17bc7SMat Martineau /* SPDX-License-Identifier: GPL-2.0 */ 23ee17bc7SMat Martineau /* 33ee17bc7SMat Martineau * Multipath TCP 43ee17bc7SMat Martineau * 53ee17bc7SMat Martineau * Copyright (c) 2017 - 2019, Intel Corporation. 63ee17bc7SMat Martineau */ 73ee17bc7SMat Martineau 83ee17bc7SMat Martineau #ifndef __NET_MPTCP_H 93ee17bc7SMat Martineau #define __NET_MPTCP_H 103ee17bc7SMat Martineau 1185712484SMat Martineau #include <linux/skbuff.h> 12eda7acddSPeter Krystad #include <linux/tcp.h> 133ee17bc7SMat Martineau #include <linux/types.h> 143ee17bc7SMat Martineau 1561bc6e82SFlorian Westphal struct mptcp_info; 1661bc6e82SFlorian Westphal struct mptcp_sock; 17fc518953SFlorian Westphal struct seq_file; 18fc518953SFlorian Westphal 193ee17bc7SMat Martineau /* MPTCP sk_buff extension data */ 203ee17bc7SMat Martineau struct mptcp_ext { 21a0c1d0eaSChristoph Paasch union { 223ee17bc7SMat Martineau u64 data_ack; 23a0c1d0eaSChristoph Paasch u32 data_ack32; 24a0c1d0eaSChristoph Paasch }; 253ee17bc7SMat Martineau u64 data_seq; 263ee17bc7SMat Martineau u32 subflow_seq; 273ee17bc7SMat Martineau u16 data_len; 28d0cc2987SGeliang Tang __sum16 csum; 293ee17bc7SMat Martineau u8 use_map:1, 303ee17bc7SMat Martineau dsn64:1, 313ee17bc7SMat Martineau data_fin:1, 323ee17bc7SMat Martineau use_ack:1, 333ee17bc7SMat Martineau ack64:1, 34cc7972eaSChristoph Paasch mpc_map:1, 355a369ca6SPaolo Abeni frozen:1, 36dc87efdbSFlorian Westphal reset_transient:1; 37208e8f66SGeliang Tang u8 reset_reason:4, 381e39e5a3SGeliang Tang csum_reqd:1, 391e39e5a3SGeliang Tang infinite_map:1; 403ee17bc7SMat Martineau }; 413ee17bc7SMat Martineau 42f7657ff4SGeliang Tang #define MPTCPOPT_HMAC_LEN 20 436445e17aSGeliang Tang #define MPTCP_RM_IDS_MAX 8 446445e17aSGeliang Tang 456445e17aSGeliang Tang struct mptcp_rm_list { 466445e17aSGeliang Tang u8 ids[MPTCP_RM_IDS_MAX]; 476445e17aSGeliang Tang u8 nr; 486445e17aSGeliang Tang }; 496445e17aSGeliang Tang 5030f60baeSGeliang Tang struct mptcp_addr_info { 5130f60baeSGeliang Tang u8 id; 5230f60baeSGeliang Tang sa_family_t family; 5330f60baeSGeliang Tang __be16 port; 543df523abSPeter Krystad union { 553df523abSPeter Krystad struct in_addr addr; 563df523abSPeter Krystad #if IS_ENABLED(CONFIG_MPTCP_IPV6) 573df523abSPeter Krystad struct in6_addr addr6; 583df523abSPeter Krystad #endif 593df523abSPeter Krystad }; 6030f60baeSGeliang Tang }; 6130f60baeSGeliang Tang 6230f60baeSGeliang Tang struct mptcp_out_options { 6330f60baeSGeliang Tang #if IS_ENABLED(CONFIG_MPTCP) 6430f60baeSGeliang Tang u16 suboptions; 656445e17aSGeliang Tang struct mptcp_rm_list rm_list; 66f296234cSPeter Krystad u8 join_id; 67f296234cSPeter Krystad u8 backup; 6806fe1719SGeliang Tang u8 reset_reason:4, 6906fe1719SGeliang Tang reset_transient:1, 70bab6b88eSGeliang Tang csum_reqd:1, 71bab6b88eSGeliang Tang allow_join_id0:1; 72d7b26908SPaolo Abeni union { 73d7b26908SPaolo Abeni struct { 74d7b26908SPaolo Abeni u64 sndr_key; 75d7b26908SPaolo Abeni u64 rcvr_key; 76f7cc8890SDavide Caratti u64 data_seq; 77f7cc8890SDavide Caratti u32 subflow_seq; 78f7cc8890SDavide Caratti u16 data_len; 79f7cc8890SDavide Caratti __sum16 csum; 80d7b26908SPaolo Abeni }; 81d7b26908SPaolo Abeni struct { 82d7b26908SPaolo Abeni struct mptcp_addr_info addr; 83d7b26908SPaolo Abeni u64 ahmac; 84d7b26908SPaolo Abeni }; 85c25aeb4eSGeliang Tang struct { 866d0060f6SMat Martineau struct mptcp_ext ext_copy; 87c25aeb4eSGeliang Tang u64 fail_seq; 88c25aeb4eSGeliang Tang }; 89d7b26908SPaolo Abeni struct { 90d7b26908SPaolo Abeni u32 nonce; 91d7b26908SPaolo Abeni u32 token; 92d7b26908SPaolo Abeni u64 thmac; 93f7657ff4SGeliang Tang u8 hmac[MPTCPOPT_HMAC_LEN]; 94d7b26908SPaolo Abeni }; 95d7b26908SPaolo Abeni }; 96eda7acddSPeter Krystad #endif 97eda7acddSPeter Krystad }; 98eda7acddSPeter Krystad 9985712484SMat Martineau #ifdef CONFIG_MPTCP 10008b8d080SFlorian Westphal extern struct request_sock_ops mptcp_subflow_request_sock_ops; 10185712484SMat Martineau 102f870fa0bSMat Martineau void mptcp_init(void); 103f870fa0bSMat Martineau 104cec37a6eSPeter Krystad static inline bool sk_is_mptcp(const struct sock *sk) 105cec37a6eSPeter Krystad { 106cec37a6eSPeter Krystad return tcp_sk(sk)->is_mptcp; 107cec37a6eSPeter Krystad } 108cec37a6eSPeter Krystad 109cec37a6eSPeter Krystad static inline bool rsk_is_mptcp(const struct request_sock *req) 110cec37a6eSPeter Krystad { 111cec37a6eSPeter Krystad return tcp_rsk(req)->is_mptcp; 112cec37a6eSPeter Krystad } 113cec37a6eSPeter Krystad 11490bf4513SPaolo Abeni static inline bool rsk_drop_req(const struct request_sock *req) 11590bf4513SPaolo Abeni { 11690bf4513SPaolo Abeni return tcp_rsk(req)->is_mptcp && tcp_rsk(req)->drop_req; 11790bf4513SPaolo Abeni } 11890bf4513SPaolo Abeni 119071c8ed6SFlorian Westphal void mptcp_space(const struct sock *ssk, int *space, int *full_space); 120cc7972eaSChristoph Paasch bool mptcp_syn_options(struct sock *sk, const struct sk_buff *skb, 121cc7972eaSChristoph Paasch unsigned int *size, struct mptcp_out_options *opts); 122cec37a6eSPeter Krystad bool mptcp_synack_options(const struct request_sock *req, unsigned int *size, 123cec37a6eSPeter Krystad struct mptcp_out_options *opts); 124cec37a6eSPeter Krystad bool mptcp_established_options(struct sock *sk, struct sk_buff *skb, 125cec37a6eSPeter Krystad unsigned int *size, unsigned int remaining, 126cec37a6eSPeter Krystad struct mptcp_out_options *opts); 1276787b7e3SJianguo Wu bool mptcp_incoming_options(struct sock *sk, struct sk_buff *skb); 128cec37a6eSPeter Krystad 129ea66758cSPaolo Abeni void mptcp_write_options(struct tcphdr *th, __be32 *ptr, struct tcp_sock *tp, 130fa3fe2b1SFlorian Westphal struct mptcp_out_options *opts); 131eda7acddSPeter Krystad 13261bc6e82SFlorian Westphal void mptcp_diag_fill_info(struct mptcp_sock *msk, struct mptcp_info *info); 13361bc6e82SFlorian Westphal 13485712484SMat Martineau /* move the skb extension owership, with the assumption that 'to' is 13585712484SMat Martineau * newly allocated 13685712484SMat Martineau */ 13785712484SMat Martineau static inline void mptcp_skb_ext_move(struct sk_buff *to, 13885712484SMat Martineau struct sk_buff *from) 13985712484SMat Martineau { 14085712484SMat Martineau if (!skb_ext_exist(from, SKB_EXT_MPTCP)) 14185712484SMat Martineau return; 14285712484SMat Martineau 14385712484SMat Martineau if (WARN_ON_ONCE(to->active_extensions)) 14485712484SMat Martineau skb_ext_put(to); 14585712484SMat Martineau 14685712484SMat Martineau to->active_extensions = from->active_extensions; 14785712484SMat Martineau to->extensions = from->extensions; 14885712484SMat Martineau from->active_extensions = 0; 14985712484SMat Martineau } 15085712484SMat Martineau 1515a369ca6SPaolo Abeni static inline void mptcp_skb_ext_copy(struct sk_buff *to, 1525a369ca6SPaolo Abeni struct sk_buff *from) 1535a369ca6SPaolo Abeni { 1545a369ca6SPaolo Abeni struct mptcp_ext *from_ext; 1555a369ca6SPaolo Abeni 1565a369ca6SPaolo Abeni from_ext = skb_ext_find(from, SKB_EXT_MPTCP); 1575a369ca6SPaolo Abeni if (!from_ext) 1585a369ca6SPaolo Abeni return; 1595a369ca6SPaolo Abeni 1605a369ca6SPaolo Abeni from_ext->frozen = 1; 1615a369ca6SPaolo Abeni skb_ext_copy(to, from); 1625a369ca6SPaolo Abeni } 1635a369ca6SPaolo Abeni 16485712484SMat Martineau static inline bool mptcp_ext_matches(const struct mptcp_ext *to_ext, 16585712484SMat Martineau const struct mptcp_ext *from_ext) 16685712484SMat Martineau { 16785712484SMat Martineau /* MPTCP always clears the ext when adding it to the skb, so 16885712484SMat Martineau * holes do not bother us here 16985712484SMat Martineau */ 17085712484SMat Martineau return !from_ext || 17185712484SMat Martineau (to_ext && from_ext && 17285712484SMat Martineau !memcmp(from_ext, to_ext, sizeof(struct mptcp_ext))); 17385712484SMat Martineau } 17485712484SMat Martineau 17585712484SMat Martineau /* check if skbs can be collapsed. 17685712484SMat Martineau * MPTCP collapse is allowed if neither @to or @from carry an mptcp data 17785712484SMat Martineau * mapping, or if the extension of @to is the same as @from. 17885712484SMat Martineau * Collapsing is not possible if @to lacks an extension, but @from carries one. 17985712484SMat Martineau */ 18085712484SMat Martineau static inline bool mptcp_skb_can_collapse(const struct sk_buff *to, 18185712484SMat Martineau const struct sk_buff *from) 18285712484SMat Martineau { 18385712484SMat Martineau return mptcp_ext_matches(skb_ext_find(to, SKB_EXT_MPTCP), 18485712484SMat Martineau skb_ext_find(from, SKB_EXT_MPTCP)); 18585712484SMat Martineau } 18685712484SMat Martineau 187fc518953SFlorian Westphal void mptcp_seq_show(struct seq_file *seq); 188c83a47e5SFlorian Westphal int mptcp_subflow_init_cookie_req(struct request_sock *req, 189c83a47e5SFlorian Westphal const struct sock *sk_listener, 190c83a47e5SFlorian Westphal struct sk_buff *skb); 191dc87efdbSFlorian Westphal 192dc87efdbSFlorian Westphal __be32 mptcp_get_reset_option(const struct sk_buff *skb); 193dc87efdbSFlorian Westphal 194dc87efdbSFlorian Westphal static inline __be32 mptcp_reset_option(const struct sk_buff *skb) 195dc87efdbSFlorian Westphal { 196dc87efdbSFlorian Westphal if (skb_ext_exist(skb, SKB_EXT_MPTCP)) 197dc87efdbSFlorian Westphal return mptcp_get_reset_option(skb); 198dc87efdbSFlorian Westphal 199dc87efdbSFlorian Westphal return htonl(0u); 200dc87efdbSFlorian Westphal } 20185712484SMat Martineau #else 20285712484SMat Martineau 203f870fa0bSMat Martineau static inline void mptcp_init(void) 204f870fa0bSMat Martineau { 205f870fa0bSMat Martineau } 206f870fa0bSMat Martineau 207cec37a6eSPeter Krystad static inline bool sk_is_mptcp(const struct sock *sk) 208cec37a6eSPeter Krystad { 209cec37a6eSPeter Krystad return false; 210cec37a6eSPeter Krystad } 211cec37a6eSPeter Krystad 212cec37a6eSPeter Krystad static inline bool rsk_is_mptcp(const struct request_sock *req) 213cec37a6eSPeter Krystad { 214cec37a6eSPeter Krystad return false; 215cec37a6eSPeter Krystad } 216cec37a6eSPeter Krystad 21790bf4513SPaolo Abeni static inline bool rsk_drop_req(const struct request_sock *req) 21890bf4513SPaolo Abeni { 21990bf4513SPaolo Abeni return false; 22090bf4513SPaolo Abeni } 22190bf4513SPaolo Abeni 222cc7972eaSChristoph Paasch static inline bool mptcp_syn_options(struct sock *sk, const struct sk_buff *skb, 223cc7972eaSChristoph Paasch unsigned int *size, 224cec37a6eSPeter Krystad struct mptcp_out_options *opts) 225cec37a6eSPeter Krystad { 226cec37a6eSPeter Krystad return false; 227cec37a6eSPeter Krystad } 228cec37a6eSPeter Krystad 229cec37a6eSPeter Krystad static inline bool mptcp_synack_options(const struct request_sock *req, 230cec37a6eSPeter Krystad unsigned int *size, 231cec37a6eSPeter Krystad struct mptcp_out_options *opts) 232cec37a6eSPeter Krystad { 233cec37a6eSPeter Krystad return false; 234cec37a6eSPeter Krystad } 235cec37a6eSPeter Krystad 236cec37a6eSPeter Krystad static inline bool mptcp_established_options(struct sock *sk, 237cec37a6eSPeter Krystad struct sk_buff *skb, 238cec37a6eSPeter Krystad unsigned int *size, 239cec37a6eSPeter Krystad unsigned int remaining, 240cec37a6eSPeter Krystad struct mptcp_out_options *opts) 241cec37a6eSPeter Krystad { 242cec37a6eSPeter Krystad return false; 243cec37a6eSPeter Krystad } 244cec37a6eSPeter Krystad 2456787b7e3SJianguo Wu static inline bool mptcp_incoming_options(struct sock *sk, 24677d0cab9SFlorian Westphal struct sk_buff *skb) 247648ef4b8SMat Martineau { 2486787b7e3SJianguo Wu return true; 249648ef4b8SMat Martineau } 250648ef4b8SMat Martineau 25185712484SMat Martineau static inline void mptcp_skb_ext_move(struct sk_buff *to, 25285712484SMat Martineau const struct sk_buff *from) 25385712484SMat Martineau { 25485712484SMat Martineau } 25585712484SMat Martineau 2565a369ca6SPaolo Abeni static inline void mptcp_skb_ext_copy(struct sk_buff *to, 2575a369ca6SPaolo Abeni struct sk_buff *from) 2585a369ca6SPaolo Abeni { 2595a369ca6SPaolo Abeni } 2605a369ca6SPaolo Abeni 26185712484SMat Martineau static inline bool mptcp_skb_can_collapse(const struct sk_buff *to, 26285712484SMat Martineau const struct sk_buff *from) 26385712484SMat Martineau { 26485712484SMat Martineau return true; 26585712484SMat Martineau } 26685712484SMat Martineau 267071c8ed6SFlorian Westphal static inline void mptcp_space(const struct sock *ssk, int *s, int *fs) { } 268fc518953SFlorian Westphal static inline void mptcp_seq_show(struct seq_file *seq) { } 269c83a47e5SFlorian Westphal 270c83a47e5SFlorian Westphal static inline int mptcp_subflow_init_cookie_req(struct request_sock *req, 271c83a47e5SFlorian Westphal const struct sock *sk_listener, 272c83a47e5SFlorian Westphal struct sk_buff *skb) 273c83a47e5SFlorian Westphal { 274c83a47e5SFlorian Westphal return 0; /* TCP fallback */ 275c83a47e5SFlorian Westphal } 276dc87efdbSFlorian Westphal 277dc87efdbSFlorian Westphal static inline __be32 mptcp_reset_option(const struct sk_buff *skb) { return htonl(0u); } 27885712484SMat Martineau #endif /* CONFIG_MPTCP */ 279f870fa0bSMat Martineau 280f870fa0bSMat Martineau #if IS_ENABLED(CONFIG_MPTCP_IPV6) 281f870fa0bSMat Martineau int mptcpv6_init(void); 28231484d56SGeert Uytterhoeven void mptcpv6_handle_mapped(struct sock *sk, bool mapped); 283f870fa0bSMat Martineau #elif IS_ENABLED(CONFIG_IPV6) 28431484d56SGeert Uytterhoeven static inline int mptcpv6_init(void) { return 0; } 28531484d56SGeert Uytterhoeven static inline void mptcpv6_handle_mapped(struct sock *sk, bool mapped) { } 286f870fa0bSMat Martineau #endif 287f870fa0bSMat Martineau 2883bc253c2SGeliang Tang #if defined(CONFIG_MPTCP) && defined(CONFIG_BPF_SYSCALL) 2893bc253c2SGeliang Tang struct mptcp_sock *bpf_mptcp_sock_from_subflow(struct sock *sk); 2903bc253c2SGeliang Tang #else 2913bc253c2SGeliang Tang static inline struct mptcp_sock *bpf_mptcp_sock_from_subflow(struct sock *sk) { return NULL; } 2923bc253c2SGeliang Tang #endif 2933bc253c2SGeliang Tang 294*f1d41f77SJiri Olsa #if !IS_ENABLED(CONFIG_MPTCP) 295*f1d41f77SJiri Olsa struct mptcp_sock { }; 296*f1d41f77SJiri Olsa #endif 297*f1d41f77SJiri Olsa 2983ee17bc7SMat Martineau #endif /* __NET_MPTCP_H */ 299