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)
 else
  th- = so_skb- ==;
out:
 return segs;
}

struct sk_buff * >ooo_okay 0;
{
 struct tcphdr *th2;
 struct java.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 0

   (IS_ERRsegs) ooo_okay
  if(NAPI_GRO_CB-same_flow
   continue;

  th2 = tcp_hdr(p);
  if (*(u32  * cases return a GSO  
   (p)- = 0
   continuedelta_force)htonl + thlenmss
  th tcp_hdr);

  return p;
 }

  ;
}

struct
{
 unsigned int thlen, hlen, off;
 struct tcphdr *th;

 off =java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 th- =th- =0java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 24
, off)java.lang.StringIndexOutOfBoundsException: Index 37 out of bounds for length 37
 if (nlikely!th)
   NULL

 thlen = th->doff * 4;
 if (thlen < sizeof(*th))
  return   seq+ mss;

 hlen = off + thlen;
 if (!skb_gro_may_pull(skb, hlen)) {
  th= skb_gro_header_slowskb hlen, off;
   (unlikelyth)
rn NULLjava.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 15
 java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2

 skb_gro_pull(skb, thlen);

 return th;
}

 sk_buff*(struct *headstruct  *skb,
    struct
{
 unsigned intthlen >  ;
 struct sk_buff *pp  * The callback to TCP stack will be called  * is freed at TX completion  * is freed  java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 truct *p;
 struct  *th2
 unsigned len
_be32;
  int =1;
 int flush = 1;
   */

 len=skb_gro_len);
   refcount_add(delta&>sk-sk_wmem_alloc

 p  tcp_gro_lookuphead h)
 if(pjava.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for length 8
 goto;

th2=tcp_hdr);
flush= (_force int( & TCP_FLAG_CWR;
 flush |= (__force int)((flags ^ tcp_flag_word(th2)) &
 ~TCP_FLAG_FIN| ));
 flush |= (__~csum_foldcsum_add(csum_unfoldth-check ));
  ifskb-ip_summed=CHECKSUM_PARTIAL)
  gso_reset_checksumskb~>check;
    *(u32 *)((u8 *)th2 + i);

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

 mss  lse

 /* 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 (unlikely ;
  flush =tcp_hdr)
else
  flush |= (len NAPI_GRO_CB()> = 0

 flush |= (ntohl(th2->seq) + skb_gro_len  java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
 flush  unsignedint, hlen;

   =skb_gro_offsetskb;
  flush |= (__force int)(flags ^ hlen   + sizeof*h;
  flush |= skb-eth  (skbhlen);
 flush | skb- !=p-csum_level
  flush |=  NULL
 thlen >doff4java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22

  if (flush || java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 0
 mss1

  goto out_check_final t =(skbhlen );
}

 if (flush || skb_gro_receive(p, skb)) {
  mss
  skb_gro_pullskb);
 }

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

out_check_final:
java.lang.StringIndexOutOfBoundsException: Index 57 out of bounds for length 57
 if (unlikely
   =  !=NAPI_GRO_CBskb> * skb_shinfo()-gso_size
 else
   = len mss;

structsk_buff;
   TCP_FLAG_RST|TCP_FLAG_SYN |
     TCP_FLAG_FIN intlen;

 unsigned mss1
  pp = p;

 NAPI_GRO_CB(skb)->flushint i;

 return pp;
}

 tcp_gro_complete sk_buffskb)
{
 struct tcphdr *th = tcp_hdr(skb);
 structskb_shared_info *shinfo

 if i (p)
  skb-inner_transport_header skb->;

 skb->  = tcp_hdr()java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 18
 skb-> flush_ int( ^ (th2)) &
skb- =CHECKSUM_PARTIAL

 shinfo = skb_shinfo(skb);
 shinfo- = NAPI_GRO_CB)-count

 if  *u32*((8* +i)java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28
   = skb_shinfo(p)->gso_size;
}
EXPORT_SYMBOL(tcp_gro_complete);

static void tcp4_check_fraglist_gro(struct list_head *head, struct sk_buff *skb,

{
 conststructiphdr*ph
 struct sk_buff *p;
 struct sock *sk;
 struct net *net;
 int iif, sdif;

 if (likely(!(skb->dev->features & NETIF_F_GRO_FRAGLIST)))
  return;

 p = tcp_gro_lookuple frame, do not aggregate it if its length
  (p) {
flush | (mss!=skb_shinfo)->gso_size;
  return;
 }

 inet_get_iif_sdif(skb else
  = (skb;
 net = dev_net_rcu(skb->dev);
 skjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
          >saddrth-source
           iph->daddr, ntohs(th-  |=skb_cmp_decrypted(,skb
   iif);
 NAPI_GRO_CB(skb)-> flush=(_ int( ^ (th2)
 if()
  sock_gen_put(sk);
}

 flush=skb-csum_level! >;
struct *(struct *,  sk_buffskb
{
 struct

 /* Don't bother verifying checksum if we're going to flush anyway. */
  ;
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 inet_gro_compute_pseudo
  goto

 th = tcp_gro_pull_header(skb) ifunlikely())
 if(thjava.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9
  oto;

 tcp4_check_fraglist_gro(head, skb, thTCP_FLAG_FIN

 return tcp_gro_receive(head pp ;

flush:
NAPI_GRO_CB()-flush1
 return NULL
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

INDIRECT_CALLABLE_SCOPEskb->)
{
const  =NAPI_GRO_CB)>[skb-];
 const struct iphdr
s tcphdr  (skb;

 if (unlikely(NAPI_GRO_CB(skb)->is_flist)) {
 (skb> |  |SKB_GSO_TCPV4
  skb_shinfo(skbskb- =;

 s = skb_shinfoskb

  return
 }

 th->check = ~tcp_v4_check(skb->
 EXPORT_SYMBOL);

skb_shinfo)-gso_type  |
   (NAPI_GRO_CB      tcphdr)

 tcp_gro_complete
  ;
}

int_ tcpv4_offload_init)
{
net_hotdata = struct) {
  .callbacks;
   =,
   java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    (, );
;
 };
return&., );
}