Blame view
net/ipv6/udp_offload.c
5.33 KB
2874c5fd2 treewide: Replace... |
1 |
// SPDX-License-Identifier: GPL-2.0-or-later |
5edbb07dc ipv6: Separate ou... |
2 3 4 5 |
/* * IPV6 GSO/GRO offload support * Linux INET6 implementation * |
5edbb07dc ipv6: Separate ou... |
6 7 8 |
* UDPv6 GSO support */ #include <linux/skbuff.h> |
57c67ff4b udp: additional G... |
9 |
#include <linux/netdevice.h> |
028e0a476 net: use indirect... |
10 |
#include <linux/indirect_call_wrapper.h> |
5edbb07dc ipv6: Separate ou... |
11 12 13 |
#include <net/protocol.h> #include <net/ipv6.h> #include <net/udp.h> |
d4d0d3557 ipv6: Fix build e... |
14 |
#include <net/ip6_checksum.h> |
5edbb07dc ipv6: Separate ou... |
15 |
#include "ip6_offload.h" |
0c19f846d net: accept UFO d... |
16 17 |
static struct sk_buff *udp6_ufo_fragment(struct sk_buff *skb, netdev_features_t features) |
5edbb07dc ipv6: Separate ou... |
18 19 |
{ struct sk_buff *segs = ERR_PTR(-EINVAL); |
0c19f846d net: accept UFO d... |
20 21 22 23 24 25 26 27 28 29 30 31 32 |
unsigned int mss; unsigned int unfrag_ip6hlen, unfrag_len; struct frag_hdr *fptr; u8 *packet_start, *prevhdr; u8 nexthdr; u8 frag_hdr_sz = sizeof(struct frag_hdr); __wsum csum; int tnl_hlen; int err; mss = skb_shinfo(skb)->gso_size; if (unlikely(skb->len <= mss)) goto out; |
5edbb07dc ipv6: Separate ou... |
33 |
|
0f4f4ffa7 net: Add GSO supp... |
34 35 |
if (skb->encapsulation && skb_shinfo(skb)->gso_type & (SKB_GSO_UDP_TUNNEL|SKB_GSO_UDP_TUNNEL_CSUM)) |
8bce6d7d0 udp: Generalize s... |
36 |
segs = skb_udp_tunnel_segment(skb, features, true); |
0c19f846d net: accept UFO d... |
37 38 39 |
else { const struct ipv6hdr *ipv6h; struct udphdr *uh; |
ee80d1ebe udp: add udp gso |
40 |
if (!(skb_shinfo(skb)->gso_type & (SKB_GSO_UDP | SKB_GSO_UDP_L4))) |
121d57af3 gso: validate gso... |
41 |
goto out; |
0c19f846d net: accept UFO d... |
42 43 |
if (!pskb_may_pull(skb, sizeof(struct udphdr))) goto out; |
ee80d1ebe udp: add udp gso |
44 |
if (skb_shinfo(skb)->gso_type & SKB_GSO_UDP_L4) |
6053d0f18 udp: Add support ... |
45 |
return __udp_gso_segment(skb, features); |
ee80d1ebe udp: add udp gso |
46 |
|
0c19f846d net: accept UFO d... |
47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 |
/* Do software UFO. Complete and fill in the UDP checksum as HW cannot * do checksum of UDP packets sent as multiple IP fragments. */ uh = udp_hdr(skb); ipv6h = ipv6_hdr(skb); uh->check = 0; csum = skb_checksum(skb, 0, skb->len, 0); uh->check = udp_v6_check(skb->len, &ipv6h->saddr, &ipv6h->daddr, csum); if (uh->check == 0) uh->check = CSUM_MANGLED_0; skb->ip_summed = CHECKSUM_UNNECESSARY; /* If there is no outer header we can fake a checksum offload * due to the fact that we have already done the checksum in * software prior to segmenting the frame. */ if (!skb->encap_hdr_csum) features |= NETIF_F_HW_CSUM; /* Check if there is enough headroom to insert fragment header. */ tnl_hlen = skb_tnl_header_len(skb); if (skb->mac_header < (tnl_hlen + frag_hdr_sz)) { if (gso_pskb_expand_head(skb, tnl_hlen + frag_hdr_sz)) goto out; } /* Find the unfragmentable header and shift it left by frag_hdr_sz * bytes to insert fragment header. */ err = ip6_find_1stfragopt(skb, &prevhdr); if (err < 0) return ERR_PTR(err); unfrag_ip6hlen = err; nexthdr = *prevhdr; *prevhdr = NEXTHDR_FRAGMENT; unfrag_len = (skb_network_header(skb) - skb_mac_header(skb)) + unfrag_ip6hlen + tnl_hlen; packet_start = (u8 *) skb->head + SKB_GSO_CB(skb)->mac_offset; memmove(packet_start-frag_hdr_sz, packet_start, unfrag_len); SKB_GSO_CB(skb)->mac_offset -= frag_hdr_sz; skb->mac_header -= frag_hdr_sz; skb->network_header -= frag_hdr_sz; fptr = (struct frag_hdr *)(skb_network_header(skb) + unfrag_ip6hlen); fptr->nexthdr = nexthdr; fptr->reserved = 0; fptr->identification = ipv6_proxy_select_ident(dev_net(skb->dev), skb); /* Fragment the skb. ipv6 header and the remaining fields of the * fragment header are updated in ipv6_gso_segment() */ segs = skb_segment(skb, features); } |
5edbb07dc ipv6: Separate ou... |
105 |
|
0c19f846d net: accept UFO d... |
106 |
out: |
5edbb07dc ipv6: Separate ou... |
107 108 |
return segs; } |
57c67ff4b udp: additional G... |
109 |
|
55e729889 net: udp: fix IP ... |
110 111 112 113 114 115 116 117 118 |
static struct sock *udp6_gro_lookup_skb(struct sk_buff *skb, __be16 sport, __be16 dport) { const struct ipv6hdr *iph = skb_gro_network_header(skb); return __udp6_lib_lookup(dev_net(skb->dev), &iph->saddr, sport, &iph->daddr, dport, inet6_iif(skb), inet6_sdif(skb), &udp_table, NULL); } |
028e0a476 net: use indirect... |
119 120 |
INDIRECT_CALLABLE_SCOPE struct sk_buff *udp6_gro_receive(struct list_head *head, struct sk_buff *skb) |
57c67ff4b udp: additional G... |
121 122 |
{ struct udphdr *uh = udp_gro_udphdr(skb); |
55e729889 net: udp: fix IP ... |
123 |
struct sock *sk = NULL; |
9fd1ff5d2 udp: Support UDP ... |
124 |
struct sk_buff *pp; |
57c67ff4b udp: additional G... |
125 |
|
9fd1ff5d2 udp: Support UDP ... |
126 |
if (unlikely(!uh)) |
2abb7cdc0 udp: Add support ... |
127 |
goto flush; |
57c67ff4b udp: additional G... |
128 |
/* Don't bother verifying checksum if we're going to flush anyway. */ |
2d8f7e2c8 udp: Fix inverted... |
129 |
if (NAPI_GRO_CB(skb)->flush) |
2abb7cdc0 udp: Add support ... |
130 |
goto skip; |
57c67ff4b udp: additional G... |
131 |
|
2abb7cdc0 udp: Add support ... |
132 133 134 135 |
if (skb_gro_checksum_validate_zero_check(skb, IPPROTO_UDP, uh->check, ip6_gro_compute_pseudo)) goto flush; else if (uh->check) |
b39c78b2a net: remove the c... |
136 |
skb_gro_checksum_try_convert(skb, IPPROTO_UDP, |
2abb7cdc0 udp: Add support ... |
137 138 139 |
ip6_gro_compute_pseudo); skip: |
efc98d08e fou: eliminate IP... |
140 |
NAPI_GRO_CB(skb)->is_ipv6 = 1; |
9fd1ff5d2 udp: Support UDP ... |
141 |
rcu_read_lock(); |
55e729889 net: udp: fix IP ... |
142 143 144 |
if (static_branch_unlikely(&udpv6_encap_needed_key)) sk = udp6_gro_lookup_skb(skb, uh->source, uh->dest); |
9fd1ff5d2 udp: Support UDP ... |
145 146 147 |
pp = udp_gro_receive(head, skb, uh, sk); rcu_read_unlock(); return pp; |
2abb7cdc0 udp: Add support ... |
148 149 150 151 |
flush: NAPI_GRO_CB(skb)->flush = 1; return NULL; |
57c67ff4b udp: additional G... |
152 |
} |
028e0a476 net: use indirect... |
153 |
INDIRECT_CALLABLE_SCOPE int udp6_gro_complete(struct sk_buff *skb, int nhoff) |
57c67ff4b udp: additional G... |
154 155 156 |
{ const struct ipv6hdr *ipv6h = ipv6_hdr(skb); struct udphdr *uh = (struct udphdr *)(skb->data + nhoff); |
9fd1ff5d2 udp: Support UDP ... |
157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 |
if (NAPI_GRO_CB(skb)->is_flist) { uh->len = htons(skb->len - nhoff); skb_shinfo(skb)->gso_type |= (SKB_GSO_FRAGLIST|SKB_GSO_UDP_L4); skb_shinfo(skb)->gso_segs = NAPI_GRO_CB(skb)->count; if (skb->ip_summed == CHECKSUM_UNNECESSARY) { if (skb->csum_level < SKB_MAX_CSUM_LEVEL) skb->csum_level++; } else { skb->ip_summed = CHECKSUM_UNNECESSARY; skb->csum_level = 0; } return 0; } |
e20cf8d3f udp: implement GR... |
173 |
if (uh->check) |
57c67ff4b udp: additional G... |
174 175 |
uh->check = ~udp_v6_check(skb->len - nhoff, &ipv6h->saddr, &ipv6h->daddr, 0); |
a6024562f udp: Add GRO func... |
176 |
return udp_gro_complete(skb, nhoff, udp6_lib_lookup_skb); |
57c67ff4b udp: additional G... |
177 |
} |
5edbb07dc ipv6: Separate ou... |
178 |
static const struct net_offload udpv6_offload = { |
f191a1d17 net: Remove code ... |
179 |
.callbacks = { |
0c19f846d net: accept UFO d... |
180 |
.gso_segment = udp6_ufo_fragment, |
57c67ff4b udp: additional G... |
181 182 |
.gro_receive = udp6_gro_receive, .gro_complete = udp6_gro_complete, |
f191a1d17 net: Remove code ... |
183 |
}, |
5edbb07dc ipv6: Separate ou... |
184 |
}; |
a6024562f udp: Add GRO func... |
185 |
int udpv6_offload_init(void) |
5edbb07dc ipv6: Separate ou... |
186 187 188 |
{ return inet6_add_offload(&udpv6_offload, IPPROTO_UDP); } |
a6024562f udp: Add GRO func... |
189 190 191 192 193 |
int udpv6_offload_exit(void) { return inet6_del_offload(&udpv6_offload, IPPROTO_UDP); } |