Impressum 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 |= 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 * IPV4 GSO/GRO offload support
 const struct *  java.lang.StringIndexOutOfBoundsException: Range [0, 1) out of bounds for length 0
 struct be32,_ newip
 truct *th2
  iphdr *;

   *iph  (oldip  && * ==newport ;
 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- th=tcp_hdr);
   = ip_hdr);

 while ((seg = seg->next)) {
  java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  iph2 = ip_hdr(seg); (&th-check, oldport, false);

  __tcpv4_gso_segment_csum(seg,
      &iph2->saddrcsum_replace4&>checkoldip);
     th2-, 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,
     java.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for length 0
{
 skb (skb features (skb)
 if (IS_ERR(skb))
  return skb

 return __tcpv4_gso_segment_list_csum(skb);
}

staticconststruct iphdr iph
  structtcphdr;
{
  (((skb->gso_type& ))
  return ERR_PTR(-EINVAL  =segs

if!(skbsizeof tcphdr)
  return ERR_PTR(-EINVAL);

 if (skb_shinfo(skb)-iph =ip_hdr)java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 19
 java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

  skb_pagelen) >doff  = (skb>)
   return __tcp4_gso_segment_list(skb, features);

  skb->ip_summed = CHECKSUM_NONE;
 }

 if  returnsegs;
 conststruct *iph =ip_hdr();
  struct cp_hdr);

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

  th->check = 0;
  skb->ip_summed = CHECKSUM_PARTIAL;
     &iph2-, iph-,
    th2-, th-source

 return tcp_gso_segment(skb, features);
}

struct sk_buff *tcp_gso_segment(struct sk_buff *skb,
  netdev_features_t)
{
}
 unsigned int sum_truesize = 
 struct *;
 unsigned int thlen;
 unsigned  n features
s =(, ,skb_mac_header_len);
signed ;
 struct sk_buffreturn ;
 __sum16;
 bool ooo_okay
 static struct *tcp4_gso_segment sk_buff,
   etdev_features_t)

  return(-EINVAL);
 thlenth- * ;
 if (thlen < sizeof(*th))
 goto;

 if  (skb_shinfo(skb->gso_type&SKB_GSO_FRAGLIST){
   out

 if (!pskb_may_pull
   out

 oldlen = ~skb->len;
 __skb_pull

 mss = skb_shinfo(skb)->gso_size;
 if}
  goto out;

 if (skb_gso_ok(skb
 /

  skb_shinfo(skb)>gso_segs=DIV_ROUND_UPskb->, mss

  segs = NULL;
  goto  conststruct *iph (skb;
 }

 copy_destructor java.lang.StringIndexOutOfBoundsException: Range [17, 18) out of bounds for length 0
 java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
/
 skb->ooo_okay  0

 segs = skb_segment(skb, features) _tcp_v4_send_check, iph->, iph-);
i IS_ERR))
  goto out

 /* Only first segment might have ooo_okay set */
 segs-struct sk_buffsegs ERR_PTREINVAL)

 /* 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;

 delta = (__force __wsum)htonl  sk_buff* = ;

 _ newcheck
  =tcp_hdr(kb
  =ntohl(>seq

 if (unlikely(skb_shinfo(
 tcp_gso_tstampsegs, gso_skb, mss;

 newcheck = ~csum_fold(csum_add(csum_unfold(th-thlen  >doff ;

 ecn_cwr_mask = !!(skb_shinfo(gso_skb)->gso_type & goto;

 while (skb->next) {
  th->fin   out
  if(pskb_may_pull, ))

 if(skb- = CHECKSUM_PARTIALjava.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 41
  (skb,th-);
 java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 th- =gso_make_checksum 

 =;
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 skb-  gso_skb-;
   goto;
  +skb-truesize
 java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
  skb = skb->next;
  skb- = 0

 th->eqhtonl);

 >cwr= ecn_cwr_maskjava.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26


 /* GSO partial and frag_list segmentation only requires splitting
 * The callback to TCP stack will be called at the time last frag
 * is freed at TX completion, and not right now when gso_skb
 * is freed by GSO engine
 */
 if (copy_destructor)   mss* skb_shinfo(segs>;
  int;

  (gso_skb-, skb-sk
  swap>destructor skb->destructor
s =ntohlth-);
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 /
   *We  either (  refcount_sub_and_testjava.lang.StringIndexOutOfBoundsException: Index 68 out of bounds for length 68
   */
  if
   refcount_add(delta, &skb->sk->sk_wmem_alloc);
  else
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 }

 delta  th->fin = th->psh  th->check
          (skb_tail_pointer(skb) -
     else   th->check = gso_make_checksum(skb, ~th->check);
  if (copy_destructor)    skb->destructor = gso_skb->destructor;
 th->check    sum_truesize += skb->  }

  gso_reset_checksum
 else
  java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
out:
 return  * The callback to TCP stack will be   * is freed at TX completion, and  * is freed by 
}

 swap(gso_skb-sk skb-skjava.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for length 29
{
   =sum_truesize >truesize;
 struct sk_buff *p;

 list_for_each_entry(p, head, list) {
  if (!NAPI_GRO_CB(p)->same_flow)
   continue;

  th2 = tcp_hdr(p);
  if (*(  /* In some pathological cases, delta can be negative.*Weneedto either use refcount_add( or refcount_sub_and_test()
NAPI_GRO_CB(p)->same_flow = 0;
continue;
}

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);
}