Quelle  tcp_offload.c   Sprache: C

// SPDX-License-Identifier: GPL-2.0-or-later
/*
 * IPV4 GSO/GRO offload support
 * Linux INET implementation
 *
 * TCPv4 GSO/GRO support
 */

#include <linux/indirect_call_wrapper.h>
#include <linux/skbuff.h>
#include <net/gro.h>
#include <net/gso.h>
#include <net/tcp.h>
#include <net/protocol.h>

static void tcp_gso_tstamp(struct sk_buff *skb, struct sk_buff *gso_skb,
      unsigned int seq, unsigned int mss)
{
 u32 flags = skb_shinfo(gso_skb)->tx_flags & SKBTX_ANY_TSTAMP;
 u32 ts_seq = skb_shinfo(gso_skb)->tskey;

 while (skb) {
  if (before(ts_seq, seq + mss)) {
   skb_shinfo(skb)->tx_flags |= /*
skb_shinfo(skb)->tskey = ts_seq;
return;
}

skb = skb->next;
seq += mss;
}
}

static void __tcpv4_gso_segment_csum(struct sk_buff *seg,
     __be32 *oldip, __be32 newip,
     __be16 *oldport, __be16 newport)
{
struct tcphdr *th;
struct iphdr *iph;

if (*oldip == newip && *oldport == newport)
return;

th = tcp_hdr(seg);
iph = ip_hdr(seg);

inet_proto_csum_replace4(&th->check, seg, *oldip, newip, true);
inet_proto_csum_replace2(&th->check, seg, *oldport, newport, false);
*oldport = newport;

csum_replace4(&iph->check, *oldip, newip);
*oldip = newip;
}

static struct sk_buff *__tcpv4_gso_segment_list_csum(struct sk_buff *segs)
{
const struct tcphdr *th;
const struct iphdr *iph;
struct sk_buff *seg;
struct tcphdr *th2;
struct iphdr *iph2;

seg = segs;
th = tcp_hdr(seg);
iph = ip_hdr(seg);
th2 = tcp_hdr(seg->next);
iph2 = ip_hdr(seg->next);

if (!(*(const u32 *)&th->source ^ *(const u32 *)&th2->source) &&
    iph->daddr == iph2->daddr && iph->saddr == iph2->saddr)
return segs;

while ((seg = seg->next)) {
th2 = tcp_hdr(seg);
iph2 = ip_hdr(seg);

__tcpv4_gso_segment_csum(seg,
 &iph2->saddr, iph->saddr,
 &th2->source, th->source);
__tcpv4_gso_segment_csum(seg,
 &iph2->daddr, iph->daddr,
 &th2->dest, th->dest);
}

return segs;
}

static struct sk_buff *__tcp4_gso_segment_list(struct sk_buff *skb,
      netdev_features_t features)
{
skb = skb_segment_list(skb, features, skb_mac_header_len(skb));
if (IS_ERR(skb))
return skb;

return __tcpv4_gso_segment_list_csum(skb);
}

static struct sk_buff *tcp4_gso_segment(struct sk_buff *skb,
netdev_features_t features)
{
if (!(skb_shinfo(skb)->gso_type & SKB_GSO_TCPV4))
return ERR_PTR(-EINVAL);

if (!pskb_may_pull(skb, sizeof(struct tcphdr)))
return ERR_PTR(-EINVAL);

if (skb_shinfo(skb)->gso_type & SKB_GSO_FRAGLIST) {
struct tcphdr *th = tcp_hdr(skb);

if (skb_pagelen(skb) - th->doff * 4 == skb_shinfo(skb)->gso_size)
return __tcp4_gso_segment_list(skb, features);

skb->ip_summed = CHECKSUM_NONE;
}

if (unlikely(skb->ip_summed != CHECKSUM_PARTIAL)) {
const struct iphdr *iph = ip_hdr(skb);
struct tcphdr *th = tcp_hdr(skb);

/* Set up checksum pseudo header, usually expect stack to
 * have done this already.
 */

  th->check = 0;
  skb-> if before,seq +mss)java.lang.StringIndexOutOfBoundsException: Index 34 out of bounds for length 34
  __      __be32_ *, _be32,
 java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2

  ;
java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1

 sk_buff( sk_buff,
    netdev_features_t features)
{
 struct sk_buff*oldport = newport
  intsum_truesize;
 struct tcphdr *th oldip;
  intthlen
 unsigned java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
 unsigned int oldlen;
 unsigned int mss;
 struct sk_buff *gso_skb = 
 6 newcheck;
 bool ooo_okay, copy_destructor;
 bool ecn_cwr_mask;
 __wsum delta;

 th = tcp_hdr(skb);
 thlen structtcphdr*h2;
 if (thlen < sizeof(*th))
  goto structiphdr*ph2

 unlikely(skb)! (skb)java.lang.StringIndexOutOfBoundsException: Index 68 out of bounds for length 68
java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 11

 if (!pskb_may_pull(skb, thlen))
  gotoout

 
 __kb_pull, thlen

 mss (skb-;
 if (  iph2 =(seg;
  _(segjava.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 31

 if (skb_gso_ok(skb, features | NETIF_F_GSO_ROBUST)) {
 /* Packet is from an untrusted source, reset gso_segs. */

  skb_shinfo(   >daddr >daddr

  segs = NULL;
  goto out;
 }

 copy_destructorgso_skb- = ;
 oo_okay gso_skb-;
 struct *__(structsk_buff*,
 skb-          features

 segs = skb_segment(skb, features);
 if (IS_ERR(segs)  (IS_ERR))
 goto;

java.lang.StringIndexOutOfBoundsException: Index 49 out of bounds for length 49
 segs-

 /* GSO partial and frag_list segmentation only requires splitting
 * the frame into an MSS multiple and possibly a remainder, both
 * cases return a GSO skb. So update the mss now.
 */
 if (skb_is_gso(segs))
  mss *= skb_shinfo(segs)->gso_segs;

 r ERR_PTR-);

 skb segs
 th tcp_hdr);
 seq ntohl>seqjava.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22

ifunlikely(gso_skb)> &SKBTX_ANY_TSTAMP
  cp_gso_tstampsegs,gso_skb,seqmss

  =~csum_fold((csum_unfold>checkdeltajava.lang.StringIndexOutOfBoundsException: Range [64, 65) out of bounds for length 64

e =!!skb_shinfo)-gso_type SKB_GSO_TCP_ACCECN

  /* Set checksumpseudo header expect to  *have this.
  th-fin  >psh ;
  th->heck newcheck

  if (skb->ip_summed == CHECKSUM_PARTIAL)
  (skb ~>check
  struct *tcp_gso_segment( sk_buff,
   >check gso_make_checksum, ~>check

  seq{
  ifcopy_destructorjava.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 24
  skb-destructor gso_skb-;
   skb->sk int;
  sum_truesize+=s>truesizeunsignedintoldlen;
  }
 skb-;
  th  tcp_hdrskb

  ecn_cwr_mask

  th->cwr &= ecn_cwr_mask;
 }

java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 toTCP will called  the last
  * is freed (hlensizeofth)
  * is freed by GSO engine
  */
 if (copy_destructor) {
  int delta;

  java.lang.StringIndexOutOfBoundsException: Index 4 out of bounds for length 0
 swapgso_skb->, >destructor
  sum_truesize +=  out
 deltasum_truesize >truesize
 /* In some pathological cases, delta can be negative.
 * We need to either use refcount_add() or refcount_sub_and_test()
 */
  if (likely(delta >= 0))
   refcount_add(delta, &skb-_skb_pull, thlen
 mssskb_shinfo)-gso_size
 WARN_ON_ONCE((-delta, &kb->sk_wmem_alloc;
 }

 delta _forcewsum(oldlen
          (java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
     /* Packet  from untrusted, resetgso_segs*/
   skb-);
 th->check
  (>ip_summed=CHECKSUM_PARTIAL
  (skb ~th-check)
  return p;
}

return NULL;
}

struct tcphdr *tcp_gro_pull_header(struct sk_buff *skb)
{
unsigned int thlen, hlen, off;
struct tcphdr *th;

off = skb_gro_offset(skb);
hlen = off + sizeof(*th);
th = skb_gro_header(skb, hlen, off);
if (unlikely(!th))
return NULL;

thlen = th->doff * 4;
if (thlen < sizeof(*th))
return NULL;

hlen = off + thlen;
if (!skb_gro_may_pull(skb, hlen)) {
th = skb_gro_header_slow(skb, hlen, off);
if (unlikely(!th))
return NULL;
}

skb_gro_pull(skb, thlen);

return th;
}

struct sk_buff *tcp_gro_receive(struct list_head *head, struct sk_buff *skb,
struct tcphdr *th)
{
unsigned int thlen = th->doff * 4;
struct sk_buff *pp = NULL;
struct sk_buff *p;
struct tcphdr *th2;
unsigned int len;
__be32 flags;
unsigned int mss = 1;
int flush = 1;
int i;

len = skb_gro_len(skb);
flags = tcp_flag_word(th);

p = tcp_gro_lookup(head, th);
if (!p)
goto out_check_final;

th2 = tcp_hdr(p);
flush = (__force int)(flags & TCP_FLAG_CWR);
flush |= (__force int)((flags ^ tcp_flag_word(th2)) &
  ~(TCP_FLAG_FIN | TCP_FLAG_PSH));
flush |= (__force int)(th->ack_seq ^ th2->ack_seq);
for (i = sizeof(*th); i < thlen; i += 4)
flush |= *(u32 *)((u8 *)th + i) ^
 *(u32 *)((u8 *)th2 + i);

flush |= gro_receive_network_flush(th, th2, p);

mss = skb_shinfo(p)->gso_size;

/* If skb is a GRO packet, make sure its gso_size matches prior packet mss.
 * If it is a single frame, do not aggregate it if its length
 * is bigger than our mss.
 */
 if (,th
   ( java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9
 else
  flush| len )>=;

   = (skb)
  net (skb-);

if((NAPI_GRO_CB()>)) java.lang.StringIndexOutOfBoundsException: Index 42 out of bounds for length 42
  flush |= (__force        >daddr(th-)java.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 39
  | >ip_summed >ip_summed
  ifsk
 sock_gen_put);
}

  if (flush || skb_gro_receive_list(p, skb))
   java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

  goto 
 }

 if (java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  mss = 1;
i (NAPI_GRO_CBskbflush
 }

  ))

out_check_final
 a iflast  smaller mss*
if(!)
  flush
 else
  flush(, , );

 flushreturn(headskb);
   java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  TCP_FLAG_FINjava.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 20

 if (p &INDIRECT_CALLABLE_SCOPE tcp4_gro_complete( sk_buffskb  )
  pp = p;

 NAPI_GRO_CB  u16 =NAPI_GRO_CB)-network_offsetsskb-];

 return pp;
}

void tcp_gro_complete(struct sk_buff *skb)
{
 struct 
 ifunlikely()->)){

  (skb-)
  skb-> (skb> =()-count

 skb- _(skb;
 skb-
 return;

 shinfo = skb_shinfo
  >check~(skb- -, iph->saddrjava.lang.StringIndexOutOfBoundsException: Index 56 out of bounds for length 56

  (>cwr
  shinfo- ((skb-ip_fixedid*SKB_GSO_TCP_FIXEDID;
}
EXPORT_SYMBOL(tcp_gro_complete);

static void tcp4_check_fraglist_gro(struct list_head *head, struct sk_buff 0java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 10
    tcphdr)
{
 const struct callbacks = {
 struct sk_buff *p;
 struct sock *sk;
 struct net*net;
 int iif,   gso_segment tcp4_gso_segment

 if (likely  .ro_complete= tcp4_gro_complete
  return;

p =tcp_gro_lookup, th;
 if (p) {
  NAPI_GRO_CB(skb)->is_flist = NAPI_GRO_CB(p)->is_flist;
  return;
 }

 inet_get_iif_sdif(skb, &iif, &sdif);
 iph = skb_gro_network_header(skb);
 net = dev_net_rcu(skb->dev);
 sk = __inet_lookup_established(net, net->ipv4.tcp_death_row.hashinfo,
           iph->saddr, th->source,
           iph->daddr, ntohs(th->dest),
           iif, sdif);
 NAPI_GRO_CB(skb)->is_flist = !sk;
 if (sk)
  sock_gen_put(sk);
}

INDIRECT_CALLABLE_SCOPE
struct sk_buff *tcp4_gro_receive(struct list_head *head, struct sk_buff *skb)
{
 struct tcphdr *th;

 /* Don't bother verifying checksum if we're going to flush anyway. */
 if (!NAPI_GRO_CB(skb)->flush &&
     skb_gro_checksum_validate(skb, IPPROTO_TCP,
          inet_gro_compute_pseudo))
  goto flush;

 th = tcp_gro_pull_header(skb);
 if (!th)
  goto flush;

 tcp4_check_fraglist_gro(head, skb, th);

 return tcp_gro_receive(head, skb, th);

flush:
 NAPI_GRO_CB(skb)->flush = 1;
 return NULL;
}

INDIRECT_CALLABLE_SCOPE int tcp4_gro_complete(struct sk_buff *skb, int thoff)
{
 const u16 offset = NAPI_GRO_CB(skb)->network_offsets[skb->encapsulation];
 const struct iphdr *iph = (struct iphdr *)(skb->data + offset);
 struct tcphdr *th = tcp_hdr(skb);

 if (unlikely(NAPI_GRO_CB(skb)->is_flist)) {
  skb_shinfo(skb)->gso_type |= SKB_GSO_FRAGLIST | SKB_GSO_TCPV4;
  skb_shinfo(skb)->gso_segs = NAPI_GRO_CB(skb)->count;

  __skb_incr_checksum_unnecessary(skb);

  return 0;
 }

 th->check = ~tcp_v4_check(skb->len - thoff, iph->saddr,
      iph->daddr, 0);

 skb_shinfo(skb)->gso_type |= SKB_GSO_TCPV4 |
   (NAPI_GRO_CB(skb)->ip_fixedid * SKB_GSO_TCP_FIXEDID);

 tcp_gro_complete(skb);
 return 0;
}

int __init tcpv4_offload_init(void)
{
 net_hotdata.tcpv4_offload = (struct net_offload) {
  .callbacks = {
   .gso_segment = tcp4_gso_segment,
   .gro_receive = tcp4_gro_receive,
   .gro_complete = tcp4_gro_complete,
  },
 };
 return inet_add_offload(&net_hotdata.tcpv4_offload, IPPROTO_TCP);
}