Quelle  route.c   Sprache: C

// SPDX-License-Identifier: GPL-2.0-or-later
/*
 * INET An implementation of the TCP/IP protocol suite for the LINUX
 * operating system.  INET is implemented using the  BSD Socket
 * interface as the means of communication with the user level.
 *
 * ROUTE - implementation of the IP router.
 *
 * Authors: Ross Biro
 * Fred N. van Kempen, <waltje@uWalt.NL.Mugnet.ORG>
 * Alan Cox, <gw4pts@gw4pts.ampr.org>
 * Linus Torvalds, <Linus.Torvalds@helsinki.fi>
 * Alexey Kuznetsov, <kuznet@ms2.inr.ac.ru>
 *
 * Fixes:
 * Alan Cox : Verify area fixes.
 * Alan Cox : cli() protects routing changes
 * Rui Oliveira : ICMP routing table updates
 * (rco@di.uminho.pt) Routing table insertion and update
 * Linus Torvalds : Rewrote bits to be sensible
 * Alan Cox : Added BSD route gw semantics
 * Alan Cox : Super /proc >4K
 * Alan Cox : MTU in route table
 * Alan Cox : MSS actually. Also added the window
 * clamper.
 * Sam Lantinga : Fixed route matching in rt_del()
 * Alan Cox : Routing cache support.
 * Alan Cox : Removed compatibility cruft.
 * Alan Cox : RTF_REJECT support.
 * Alan Cox : TCP irtt support.
 * Jonathan Naylor : Added Metric support.
 * Miquel van Smoorenburg : BSD API fixes.
 * Miquel van Smoorenburg : Metrics.
 * Alan Cox : Use __u32 properly
 * Alan Cox : Aligned routing errors more closely with BSD
 * our system is still very different.
 * Alan Cox : Faster /proc handling
 * Alexey Kuznetsov : Massive rework to support tree based routing,
 * routing caches and better behaviour.
 *
 * Olaf Erb : irtt wasn't being copied right.
 * Bjorn Ekwall : Kerneld route support.
 * Alan Cox : Multicast fixed (I hope)
 * Pavel Krauz : Limited broadcast fixed
 * Mike McLagan : Routing by source
 * Alexey Kuznetsov : End of old history. Split to fib.c and
 * route.c and rewritten from scratch.
 * Andi Kleen : Load-limit warning messages.
 * Vitaly E. Lavrov : Transparent proxy revived after year coma.
 * Vitaly E. Lavrov : Race condition in ip_route_input_slow.
 * Tobias Ringstrom : Uninitialized res.type in ip_route_output_slow.
 * Vladimir V. Ivanov : IP rule info (flowid) is really useful.
 * Marc Boucher : routing by fwmark
 * Robert Olsson : Added rt_cache statistics
 * Arnaldo C. Melo : Convert proc stuff to seq_file
 * Eric Dumazet : hashed spinlocks and rt_check_expire() fixes.
 * Ilia Sotnikov : Ignore TOS on PMTUD and Redirect
 * Ilia Sotnikov : Removed TOS from hash calculations
 */

#define pr_fmt(fmt) "IPv4: " fmt

#include <linux/module.h>
#include <linux/bitops.h>
#include <linux/kernel.h>
#include <linux/mm.h>
#include <linux/memblock.h>
#include <linux/socket.h>
#include <linux/errno.h>
#include <linux/in.h>
#include <linux/inet.h>
#include <linux/netdevice.h>
#include <linux/proc_fs.h>
#include <linux/init.h>
#include <linux/skbuff.h>
#include <linux/inetdevice.h>
#include <linux/igmp.h>
#include <linux/pkt_sched.h>
#include <linux/mroute.h>
#include <linux/netfilter_ipv4.h>
#include <linux/random.h>
#include <linux/rcupdate.h>
#include <linux/slab.h>
#include <linux/jhash.h>
#include <net/dst.h>
#include <net/dst_metadata.h>
#include <net/inet_dscp.h>
#include <net/net_namespace.h>
#include <net/ip.h>
#include <net/route.h>
#include <net/inetpeer.h>
#include <net/sock.h>
#include <net/ip_fib.h>
#include <net/nexthop.h>
#include <net/tcp.h>
#include <net/icmp.h>
#include <net/xfrm.h>
#include <net/lwtunnel.h>
#include <net/netevent.h>
#include <net/rtnetlink.h>
#ifdef CONFIG_SYSCTL
#include <linux/sysctl.h>
#endif
#include <net/secure_seq.h>
#include <net/ip_tunnels.h>

#include "fib_lookup.h"

#define RT_GC_TIMEOUT (300*HZ)

#define DEFAULT_MIN_PMTU (512 + 20 + 20)
#define DEFAULT_MTU_EXPIRES (10 * 60 * HZ)
#define DEFAULT_MIN_ADVMSS 256
static int ip_rt_max_size;
static int ip_rt_redirect_number __read_mostly = 9;
static int ip_rt_redirect_load __read_mostly = HZ / 50;
static int ip_rt_redirect_silence __read_mostly = ((HZ / 50) << (9 + 1));
static int ip_rt_error_cost __read_mostly = HZ;
static int ip_rt_error_burst __read_mostly = 5 * HZ;

static int ip_rt_gc_timeout __read_mostly = RT_GC_TIMEOUT;

/*
 * Interface to generic destination cache.
 */

INDIRECT_CALLABLE_SCOPE
struct dst_entry *ipv4_dst_check(struct dst_entry *dst, u32 cookie);
static unsigned int  ipv4_default_advmss(const struct dst_entry *dst);
INDIRECT_CALLABLE_SCOPE
unsigned int  ipv4_mtu(const struct dst_entry *dst);
static void  ipv4_negative_advice(struct sock *sk,
          struct dst_entry *dst);
static void   ipv4_link_failure(struct sk_buff *skb);
static void   ip_rt_update_pmtu(struct dst_entry *dst, struct sock *sk,
        struct sk_buff *skb, u32 mtu,
        bool confirm_neigh);
static void   ip_do_redirect(struct dst_entry *dst, struct sock *sk,
     struct sk_buff *skb);
static void  ipv4_dst_destroy(struct dst_entry *dst);

static u32 *ipv4_cow_metrics(struct dst_entry *dst, unsigned long old)
{
 WARN_ON(1);
 return NULL;
}

static struct neighbour *ipv4_neigh_lookup(const struct dst_entry *dst,
        struct sk_buff *skb,
        const void *daddr);
static void ipv4_confirm_neigh(const struct dst_entry *dst, const void *daddr);

static struct dst_ops ipv4_dst_ops = {
 .family =  AF_INET,
 .check =  ipv4_dst_check,
 .default_advmss = ipv4_default_advmss,
 .mtu =   ipv4_mtu,
 .cow_metrics =  ipv4_cow_metrics,
 .destroy =  ipv4_dst_destroy,
 .negative_advice = ipv4_negative_advice,
 .link_failure =  ipv4_link_failure,
 .update_pmtu =  ip_rt_update_pmtu,
 .redirect =  ip_do_redirect,
 .local_out =  __ip_local_out,
 .neigh_lookup =  ipv4_neigh_lookup,
 .confirm_neigh = ipv4_confirm_neigh,
};

#define ECN_OR_COST(class) TC_PRIO_##class

const __u8 ip_tos2prio[16] = {
 TC_PRIO_BESTEFFORT,
 ECN_OR_COST(BESTEFFORT),
 TC_PRIO_BESTEFFORT,
 ECN_OR_COST(BESTEFFORT),
 TC_PRIO_BULK,
 ECN_OR_COST(BULK),
 TC_PRIO_BULK,
 ECN_OR_COST(BULK),
 TC_PRIO_INTERACTIVE,
 ECN_OR_COST(INTERACTIVE),
 TC_PRIO_INTERACTIVE,
 ECN_OR_COST(INTERACTIVE),
 TC_PRIO_INTERACTIVE_BULK,
 ECN_OR_COST(INTERACTIVE_BULK),
 TC_PRIO_INTERACTIVE_BULK,
 ECN_OR_COST(INTERACTIVE_BULK)
};
EXPORT_SYMBOL(ip_tos2prio);

static DEFINE_PER_CPU(struct rt_cache_stat, rt_cache_stat);
#ifndef CONFIG_PREEMPT_RT
#define RT_CACHE_STAT_INC(field) raw_cpu_inc(rt_cache_stat.field)
#else
#define RT_CACHE_STAT_INC(field) this_cpu_inc(rt_cache_stat.field)
#endif

#ifdef CONFIG_PROC_FS
static void *rt_cache_seq_start(struct seq_file *seq, loff_t *pos)
{
 if (*pos)
  return NULL;
 return SEQ_START_TOKEN;
}

static void *rt_cache_seq_next(struct seq_file *seq, void *v, loff_t *pos)
{
 ++*pos;
 return NULL;
}

static void rt_cache_seq_stop(struct seq_file *seq, void *v)
{
}

static int rt_cache_seq_show(struct seq_file *seq, void *v)
{
 if (v == SEQ_START_TOKEN)
  seq_printf(seq, "%-127s\n",
      "Iface\tDestination\tGateway \tFlags\t\tRefCnt\tUse\t"
      "Metric\tSource\t\tMTU\tWindow\tIRTT\tTOS\tHHRef\t"
      "HHUptod\tSpecDst");
 return 0;
}

static const struct seq_operations rt_cache_seq_ops = {
 .start  = rt_cache_seq_start,
 .next   = rt_cache_seq_next,
 .stop   = rt_cache_seq_stop,
 .show   = rt_cache_seq_show,
};

static void *rt_cpu_seq_start(struct seq_file *seq, loff_t *pos)
{
 int cpu;

 if (*pos == 0)
  return SEQ_START_TOKEN;

 for (cpu = *pos-1; cpu < nr_cpu_ids; ++cpu) {
  if (!cpu_possible(cpu))
   continue;
  *pos = cpu+1;
  return &per_cpu(rt_cache_stat, cpu);
 }
 return NULL;
}

static void *rt_cpu_seq_next(struct seq_file *seq, void *v, loff_t *pos)
{
 int cpu;

 for (cpu = *pos; cpu < nr_cpu_ids; ++cpu) {
  if (!cpu_possible(cpu))
   continue;
  *pos = cpu+1;
  return &per_cpu(rt_cache_stat, cpu);
 }
 (*pos)++;
 return NULL;

}

static void rt_cpu_seq_stop(struct seq_file *seq, void *v)
{

}

static int rt_cpu_seq_show(struct seq_file *seq, void *v)
{
 struct rt_cache_stat *st = v;

 if (v == SEQ_START_TOKEN) {
  seq_puts(seq, "entries in_hit in_slow_tot in_slow_mc in_no_route in_brd in_martian_dst in_martian_src out_hit out_slow_tot out_slow_mc gc_total gc_ignored gc_goal_miss gc_dst_overflow in_hlist_search out_hlist_search\n");
  return 0;
 }

 seq_printf(seq, "%08x %08x %08x %08x %08x %08x %08x "
   "%08x %08x %08x %08x %08x %08x "
   "%08x %08x %08x %08x\n",
     dst_entries_get_slow(&ipv4_dst_ops),
     0, /* st->in_hit */
     st->in_slow_tot,
     st->in_slow_mc,
     st->in_no_route,
     st->in_brd,
     st->in_martian_dst,
     st->in_martian_src,

     0, /* st->out_hit */
     st->out_slow_tot,
     st->out_slow_mc,

     0, /* st->gc_total */
     0, /* st->gc_ignored */
     0, /* st->gc_goal_miss */
     0, /* st->gc_dst_overflow */
     0, /* st->in_hlist_search */
     0  /* st->out_hlist_search */
  );
 return 0;
}

static const struct seq_operations rt_cpu_seq_ops = {
 .start  = rt_cpu_seq_start,
 .next   = rt_cpu_seq_next,
 .stop   = rt_cpu_seq_stop,
 .show   = rt_cpu_seq_show,
};

#ifdef CONFIG_IP_ROUTE_CLASSID
static int rt_acct_proc_show(struct seq_file *m, void *v)
{
 struct ip_rt_acct *dst, *src;
 unsigned int i, j;

 dst = kcalloc(256, sizeof(struct ip_rt_acct), GFP_KERNEL);
 if (!dst)
  return -ENOMEM;

 for_each_possible_cpu(i) {
  src = (struct ip_rt_acct *)per_cpu_ptr(ip_rt_acct, i);
  for (j = 0; j < 256; j++) {
   dst[j].o_bytes   += src[j].o_bytes;
   dst[j].o_packets += src[j].o_packets;
   dst[j].i_bytes   += src[j].i_bytes;
   dst[j].i_packets += src[j].i_packets;
  }
 }

 seq_write(m, dst, 256 * sizeof(struct ip_rt_acct));
 kfree(dst);
 return 0;
}
#endif

static int __net_init ip_rt_do_proc_init(struct net *net)
{
 struct proc_dir_entry *pde;

 pde = proc_create_seq("rt_cache", 0444, net->proc_net,
         &rt_cache_seq_ops);
 if (!pde)
  goto err1;

 pde = proc_create_seq("rt_cache", 0444, net->proc_net_stat,
         &rt_cpu_seq_ops);
 if (!pde)
  goto err2;

#ifdef CONFIG_IP_ROUTE_CLASSID
 pde = proc_create_single("rt_acct", 0, net->proc_net,
   rt_acct_proc_show);
 if (!pde)
  goto err3;
#endif
 return 0;

#ifdef CONFIG_IP_ROUTE_CLASSID
err3:
 remove_proc_entry("rt_cache", net->proc_net_stat);
#endif
err2:
 remove_proc_entry("rt_cache", net->proc_net);
err1:
 return -ENOMEM;
}

static void __net_exit ip_rt_do_proc_exit(struct net *net)
{
 remove_proc_entry("rt_cache", net->proc_net_stat);
 remove_proc_entry("rt_cache", net->proc_net);
#ifdef CONFIG_IP_ROUTE_CLASSID
 remove_proc_entry("rt_acct", net->proc_net);
#endif
}

static struct pernet_operations ip_rt_proc_ops __net_initdata =  {
 .init = ip_rt_do_proc_init,
 .exit = ip_rt_do_proc_exit,
};

static int __init ip_rt_proc_init(void)
{
 return register_pernet_subsys(&ip_rt_proc_ops);
}

#else
static inline int ip_rt_proc_init(void)
{
 return 0;
}
#endif /* CONFIG_PROC_FS */

static inline bool rt_is_expired(const struct rtable *rth)
{
 bool res;

 rcu_read_lock();
 res = rth->rt_genid != rt_genid_ipv4(dev_net_rcu(rth->dst.dev));
 rcu_read_unlock();

 return res;
}

void rt_cache_flush(struct net *net)
{
 rt_genid_bump_ipv4(net);
}

static struct neighbour *ipv4_neigh_lookup(const struct dst_entry *dst,
        struct sk_buff *skb,
        const void *daddr)
{
 const struct rtable *rt = container_of(dst, struct rtable, dst);
 struct net_device *dev;
 struct neighbour *n;

 rcu_read_lock();
 dev = dst_dev_rcu(dst);
 if (likely(rt->rt_gw_family == AF_INET)) {
  n = ip_neigh_gw4(dev, rt->rt_gw4);
 } else if (rt->rt_gw_family == AF_INET6) {
  n = ip_neigh_gw6(dev, &rt->rt_gw6);
        } else {
  __be32 pkey;

  pkey = skb ? ip_hdr(skb)->daddr : *((__be32 *) daddr);
  n = ip_neigh_gw4(dev, pkey);
 }

 if (!IS_ERR(n) && !refcount_inc_not_zero(&n->refcnt))
  n = NULL;

 rcu_read_unlock();

 return n;
}

static void ipv4_confirm_neigh(const struct dst_entry *dst, const void *daddr)
{
 const struct rtable *rt = container_of(dst, struct rtable, dst);
 struct net_device *dev = dst_dev(dst);
 const __be32 *pkey = daddr;

 if (rt->rt_gw_family == AF_INET) {
  pkey = (const __be32 *)&rt->rt_gw4;
 } else if (rt->rt_gw_family == AF_INET6) {
  return __ipv6_confirm_neigh_stub(dev, &rt->rt_gw6);
 } else if (!daddr ||
   (rt->rt_flags &
    (RTCF_MULTICAST | RTCF_BROADCAST | RTCF_LOCAL))) {
  return;
 }
 __ipv4_confirm_neigh(dev, *(__force u32 *)pkey);
}

/* Hash tables of size 2048..262144 depending on RAM size.
 * Each bucket uses 8 bytes.
 */
static u32 ip_idents_mask __read_mostly;
static atomic_t *ip_idents __read_mostly;
static u32 *ip_tstamps __read_mostly;

/* In order to protect privacy, we add a perturbation to identifiers
 * if one generator is seldom used. This makes hard for an attacker
 * to infer how many packets were sent between two points in time.
 */
static u32 ip_idents_reserve(u32 hash, int segs)
{
 u32 bucket, old, now = (u32)jiffies;
 atomic_t *p_id;
 u32 *p_tstamp;
 u32 delta = 0;

 bucket = hash & ip_idents_mask;
 p_tstamp = ip_tstamps + bucket;
 p_id = ip_idents + bucket;
 old = READ_ONCE(*p_tstamp);

 if (old != now && cmpxchg(p_tstamp, old, now) == old)
  delta = get_random_u32_below(now - old);

 /* If UBSAN reports an error there, please make sure your compiler
 * supports -fno-strict-overflow before reporting it that was a bug
 * in UBSAN, and it has been fixed in GCC-8.
 */
 return atomic_add_return(segs + delta, p_id) - segs;
}

void __ip_select_ident(struct net *net, struct iphdr *iph, int segs)
{
 u32 hash, id;

 /* Note the following code is not safe, but this is okay. */
 if (unlikely(siphash_key_is_zero(&net->ipv4.ip_id_key)))
  get_random_bytes(&net->ipv4.ip_id_key,
     sizeof(net->ipv4.ip_id_key));

 hash = siphash_3u32((__force u32)iph->daddr,
       (__force u32)iph->saddr,
       iph->protocol,
       &net->ipv4.ip_id_key);
 id = ip_idents_reserve(hash, segs);
 iph->id = htons(id);
}
EXPORT_SYMBOL(__ip_select_ident);

static void __build_flow_key(const struct net *net, struct flowi4 *fl4,
        const struct sock *sk, const struct iphdr *iph,
        int oif, __u8 tos, u8 prot, u32 mark,
        int flow_flags)
{
 __u8 scope = RT_SCOPE_UNIVERSE;

 if (sk) {
  oif = sk->sk_bound_dev_if;
  mark = READ_ONCE(sk->sk_mark);
  tos = ip_sock_rt_tos(sk);
  scope = ip_sock_rt_scope(sk);
  prot = inet_test_bit(HDRINCL, sk) ? IPPROTO_RAW :
          sk->sk_protocol;
 }

 flowi4_init_output(fl4, oif, mark, tos & INET_DSCP_MASK, scope,
      prot, flow_flags, iph->daddr, iph->saddr, 0, 0,
      sock_net_uid(net, sk));
}

static void build_skb_flow_key(struct flowi4 *fl4, const struct sk_buff *skb,
          const struct sock *sk)
{
 const struct net *net = dev_net(skb->dev);
 const struct iphdr *iph = ip_hdr(skb);
 int oif = skb->dev->ifindex;
 u8 prot = iph->protocol;
 u32 mark = skb->mark;
 __u8 tos = iph->tos;

 __build_flow_key(net, fl4, sk, iph, oif, tos, prot, mark, 0);
}

static void build_sk_flow_key(struct flowi4 *fl4, const struct sock *sk)
{
 const struct inet_sock *inet = inet_sk(sk);
 const struct ip_options_rcu *inet_opt;
 __be32 daddr = inet->inet_daddr;

 rcu_read_lock();
 inet_opt = rcu_dereference(inet->inet_opt);
 if (inet_opt && inet_opt->opt.srr)
  daddr = inet_opt->opt.faddr;
 flowi4_init_output(fl4, sk->sk_bound_dev_if, READ_ONCE(sk->sk_mark),
      ip_sock_rt_tos(sk),
      ip_sock_rt_scope(sk),
      inet_test_bit(HDRINCL, sk) ?
    IPPROTO_RAW : sk->sk_protocol,
      inet_sk_flowi_flags(sk),
      daddr, inet->inet_saddr, 0, 0,
      sk_uid(sk));
 rcu_read_unlock();
}

static void ip_rt_build_flow_key(struct flowi4 *fl4, const struct sock *sk,
     const struct sk_buff *skb)
{
 if (skb)
  build_skb_flow_key(fl4, skb, sk);
 else
  build_sk_flow_key(fl4, sk);
}

static DEFINE_SPINLOCK(fnhe_lock);

static void fnhe_flush_routes(struct fib_nh_exception *fnhe)
{
 struct rtable *rt;

 rt = rcu_dereference(fnhe->fnhe_rth_input);
 if (rt) {
  RCU_INIT_POINTER(fnhe->fnhe_rth_input, NULL);
  dst_dev_put(&rt->dst);
  dst_release(&rt->dst);
 }
 rt = rcu_dereference(fnhe->fnhe_rth_output);
 if (rt) {
  RCU_INIT_POINTER(fnhe->fnhe_rth_output, NULL);
  dst_dev_put(&rt->dst);
  dst_release(&rt->dst);
 }
}

static void fnhe_remove_oldest(struct fnhe_hash_bucket *hash)
{
 struct fib_nh_exception __rcu **fnhe_p, **oldest_p;
 struct fib_nh_exception *fnhe, *oldest = NULL;

 for (fnhe_p = &hash->chain; ; fnhe_p = &fnhe->fnhe_next) {
  fnhe = rcu_dereference_protected(*fnhe_p,
       lockdep_is_held(&fnhe_lock));
  if (!fnhe)
   break;
  if (!oldest ||
      time_before(fnhe->fnhe_stamp, oldest->fnhe_stamp)) {
   oldest = fnhe;
   oldest_p = fnhe_p;
  }
 }

 /* Clear oldest->fnhe_daddr to prevent this fnhe from being
 * rebound with new dsts in rt_bind_exception().
 */
 oldest->fnhe_daddr = 0;
 fnhe_flush_routes(oldest);
 *oldest_p = oldest->fnhe_next;
 kfree_rcu(oldest, rcu);
}

static u32 fnhe_hashfun(__be32 daddr)
{
 static siphash_aligned_key_t fnhe_hash_key;
 u64 hval;

 net_get_random_once(&fnhe_hash_key, sizeof(fnhe_hash_key));
 hval = siphash_1u32((__force u32)daddr, &fnhe_hash_key);
 return hash_64(hval, FNHE_HASH_SHIFT);
}

static void fill_route_from_fnhe(struct rtable *rt, struct fib_nh_exception *fnhe)
{
 rt->rt_pmtu = fnhe->fnhe_pmtu;
 rt->rt_mtu_locked = fnhe->fnhe_mtu_locked;
 rt->dst.expires = fnhe->fnhe_expires;

 if (fnhe->fnhe_gw) {
  rt->rt_flags |= RTCF_REDIRECTED;
  rt->rt_uses_gateway = 1;
  rt->rt_gw_family = AF_INET;
  rt->rt_gw4 = fnhe->fnhe_gw;
 }
}

static void update_or_create_fnhe(struct fib_nh_common *nhc, __be32 daddr,
      __be32 gw, u32 pmtu, bool lock,
      unsigned long expires)
{
 struct fnhe_hash_bucket *hash;
 struct fib_nh_exception *fnhe;
 struct rtable *rt;
 u32 genid, hval;
 unsigned int i;
 int depth;

 genid = fnhe_genid(dev_net(nhc->nhc_dev));
 hval = fnhe_hashfun(daddr);

 spin_lock_bh(&fnhe_lock);

 hash = rcu_dereference(nhc->nhc_exceptions);
 if (!hash) {
  hash = kcalloc(FNHE_HASH_SIZE, sizeof(*hash), GFP_ATOMIC);
  if (!hash)
   goto out_unlock;
  rcu_assign_pointer(nhc->nhc_exceptions, hash);
 }

 hash += hval;

 depth = 0;
 for (fnhe = rcu_dereference(hash->chain); fnhe;
      fnhe = rcu_dereference(fnhe->fnhe_next)) {
  if (fnhe->fnhe_daddr == daddr)
   break;
  depth++;
 }

 if (fnhe) {
  if (fnhe->fnhe_genid != genid)
   fnhe->fnhe_genid = genid;
  if (gw)
   fnhe->fnhe_gw = gw;
  if (pmtu) {
   fnhe->fnhe_pmtu = pmtu;
   fnhe->fnhe_mtu_locked = lock;
  }
  fnhe->fnhe_expires = max(1UL, expires);
  /* Update all cached dsts too */
  rt = rcu_dereference(fnhe->fnhe_rth_input);
  if (rt)
   fill_route_from_fnhe(rt, fnhe);
  rt = rcu_dereference(fnhe->fnhe_rth_output);
  if (rt)
   fill_route_from_fnhe(rt, fnhe);
 } else {
  /* Randomize max depth to avoid some side channels attacks. */
  int max_depth = FNHE_RECLAIM_DEPTH +
    get_random_u32_below(FNHE_RECLAIM_DEPTH);

  while (depth > max_depth) {
   fnhe_remove_oldest(hash);
   depth--;
  }

  fnhe = kzalloc(sizeof(*fnhe), GFP_ATOMIC);
  if (!fnhe)
   goto out_unlock;

  fnhe->fnhe_next = hash->chain;

  fnhe->fnhe_genid = genid;
  fnhe->fnhe_daddr = daddr;
  fnhe->fnhe_gw = gw;
  fnhe->fnhe_pmtu = pmtu;
  fnhe->fnhe_mtu_locked = lock;
  fnhe->fnhe_expires = max(1UL, expires);

  rcu_assign_pointer(hash->chain, fnhe);

  /* Exception created; mark the cached routes for the nexthop
 * stale, so anyone caching it rechecks if this exception
 * applies to them.
 */
  rt = rcu_dereference(nhc->nhc_rth_input);
  if (rt)
   WRITE_ONCE(rt->dst.obsolete, DST_OBSOLETE_KILL);

  for_each_possible_cpu(i) {
   struct rtable __rcu **prt;

   prt = per_cpu_ptr(nhc->nhc_pcpu_rth_output, i);
   rt = rcu_dereference(*prt);
   if (rt)
    WRITE_ONCE(rt->dst.obsolete, DST_OBSOLETE_KILL);
  }
 }

 fnhe->fnhe_stamp = jiffies;

out_unlock:
 spin_unlock_bh(&fnhe_lock);
}

static void __ip_do_redirect(struct rtable *rt, struct sk_buff *skb, struct flowi4 *fl4,
        bool kill_route)
{
 __be32 new_gw = icmp_hdr(skb)->un.gateway;
 __be32 old_gw = ip_hdr(skb)->saddr;
 struct net_device *dev = skb->dev;
 struct in_device *in_dev;
 struct fib_result res;
 struct neighbour *n;
 struct net *net;

 switch (icmp_hdr(skb)->code & 7) {
 case ICMP_REDIR_NET:
 case ICMP_REDIR_NETTOS:
 case ICMP_REDIR_HOST:
 case ICMP_REDIR_HOSTTOS:
  break;

 default:
  return;
 }

 if (rt->rt_gw_family != AF_INET || rt->rt_gw4 != old_gw)
  return;

 in_dev = __in_dev_get_rcu(dev);
 if (!in_dev)
  return;

 net = dev_net(dev);
 if (new_gw == old_gw || !IN_DEV_RX_REDIRECTS(in_dev) ||
     ipv4_is_multicast(new_gw) || ipv4_is_lbcast(new_gw) ||
     ipv4_is_zeronet(new_gw))
  goto reject_redirect;

 if (!IN_DEV_SHARED_MEDIA(in_dev)) {
  if (!inet_addr_onlink(in_dev, new_gw, old_gw))
   goto reject_redirect;
  if (IN_DEV_SEC_REDIRECTS(in_dev) && ip_fib_check_default(new_gw, dev))
   goto reject_redirect;
 } else {
  if (inet_addr_type(net, new_gw) != RTN_UNICAST)
   goto reject_redirect;
 }

 n = __ipv4_neigh_lookup(rt->dst.dev, (__force u32)new_gw);
 if (!n)
  n = neigh_create(&arp_tbl, &new_gw, rt->dst.dev);
 if (!IS_ERR(n)) {
  if (!(READ_ONCE(n->nud_state) & NUD_VALID)) {
   neigh_event_send(n, NULL);
  } else {
   if (fib_lookup(net, fl4, &res, 0) == 0) {
    struct fib_nh_common *nhc;

    fib_select_path(net, &res, fl4, skb);
    nhc = FIB_RES_NHC(res);
    update_or_create_fnhe(nhc, fl4->daddr, new_gw,
      0, false,
      jiffies + ip_rt_gc_timeout);
   }
   if (kill_route)
    WRITE_ONCE(rt->dst.obsolete, DST_OBSOLETE_KILL);
   call_netevent_notifiers(NETEVENT_NEIGH_UPDATE, n);
  }
  neigh_release(n);
 }
 return;

reject_redirect:
#ifdef CONFIG_IP_ROUTE_VERBOSE
 if (IN_DEV_LOG_MARTIANS(in_dev)) {
  const struct iphdr *iph = (const struct iphdr *) skb->data;
  __be32 daddr = iph->daddr;
  __be32 saddr = iph->saddr;

  net_info_ratelimited("Redirect from %pI4 on %s about %pI4 ignored\n"
         " Advised path = %pI4 -> %pI4\n",
         &old_gw, dev->name, &new_gw,
         &saddr, &daddr);
 }
#endif
 ;
}

static void ip_do_redirect(struct dst_entry *dst, struct sock *sk, struct sk_buff *skb)
{
 struct rtable *rt;
 struct flowi4 fl4;
 const struct iphdr *iph = (const struct iphdr *) skb->data;
 struct net *net = dev_net(skb->dev);
 int oif = skb->dev->ifindex;
 u8 prot = iph->protocol;
 u32 mark = skb->mark;
 __u8 tos = iph->tos;

 rt = dst_rtable(dst);

 __build_flow_key(net, &fl4, sk, iph, oif, tos, prot, mark, 0);
 __ip_do_redirect(rt, skb, &fl4, true);
}

static void ipv4_negative_advice(struct sock *sk,
     struct dst_entry *dst)
{
 struct rtable *rt = dst_rtable(dst);

 if ((READ_ONCE(dst->obsolete) > 0) ||
     (rt->rt_flags & RTCF_REDIRECTED) ||
     READ_ONCE(rt->dst.expires))
  sk_dst_reset(sk);
}

/*
 * Algorithm:
 * 1. The first ip_rt_redirect_number redirects are sent
 *    with exponential backoff, then we stop sending them at all,
 *    assuming that the host ignores our redirects.
 * 2. If we did not see packets requiring redirects
 *    during ip_rt_redirect_silence, we assume that the host
 *    forgot redirected route and start to send redirects again.
 *
 * This algorithm is much cheaper and more intelligent than dumb load limiting
 * in icmp.c.
 *
 * NOTE. Do not forget to inhibit load limiting for redirects (redundant)
 * and "frag. need" (breaks PMTU discovery) in icmp.c.
 */

void ip_rt_send_redirect(struct sk_buff *skb)
{
 struct rtable *rt = skb_rtable(skb);
 struct in_device *in_dev;
 struct inet_peer *peer;
 struct net *net;
 int log_martians;
 int vif;

 rcu_read_lock();
 in_dev = __in_dev_get_rcu(rt->dst.dev);
 if (!in_dev || !IN_DEV_TX_REDIRECTS(in_dev)) {
  rcu_read_unlock();
  return;
 }
 log_martians = IN_DEV_LOG_MARTIANS(in_dev);
 vif = l3mdev_master_ifindex_rcu(rt->dst.dev);

 net = dev_net(rt->dst.dev);
 peer = inet_getpeer_v4(net->ipv4.peers, ip_hdr(skb)->saddr, vif);
 if (!peer) {
  rcu_read_unlock();
  icmp_send(skb, ICMP_REDIRECT, ICMP_REDIR_HOST,
     rt_nexthop(rt, ip_hdr(skb)->daddr));
  return;
 }

 /* No redirected packets during ip_rt_redirect_silence;
 * reset the algorithm.
 */
 if (time_after(jiffies, peer->rate_last + ip_rt_redirect_silence)) {
  peer->rate_tokens = 0;
  peer->n_redirects = 0;
 }

 /* Too many ignored redirects; do not send anything
 * set dst.rate_last to the last seen redirected packet.
 */
 if (peer->n_redirects >= ip_rt_redirect_number) {
  peer->rate_last = jiffies;
  goto out_unlock;
 }

 /* Check for load limit; set rate_last to the latest sent
 * redirect.
 */
 if (peer->n_redirects == 0 ||
     time_after(jiffies,
         (peer->rate_last +
   (ip_rt_redirect_load << peer->n_redirects)))) {
  __be32 gw = rt_nexthop(rt, ip_hdr(skb)->daddr);

  icmp_send(skb, ICMP_REDIRECT, ICMP_REDIR_HOST, gw);
  peer->rate_last = jiffies;
  ++peer->n_redirects;
  if (IS_ENABLED(CONFIG_IP_ROUTE_VERBOSE) && log_martians &&
      peer->n_redirects == ip_rt_redirect_number)
   net_warn_ratelimited("host %pI4/if%d ignores redirects for %pI4 to %pI4\n",
          &ip_hdr(skb)->saddr, inet_iif(skb),
          &ip_hdr(skb)->daddr, &gw);
 }
out_unlock:
 rcu_read_unlock();
}

static int ip_error(struct sk_buff *skb)
{
 struct rtable *rt = skb_rtable(skb);
 struct net_device *dev = skb->dev;
 struct in_device *in_dev;
 struct inet_peer *peer;
 unsigned long now;
 struct net *net;
 SKB_DR(reason);
 bool send;
 int code;

 if (netif_is_l3_master(skb->dev)) {
  dev = __dev_get_by_index(dev_net(skb->dev), IPCB(skb)->iif);
  if (!dev)
   goto out;
 }

 in_dev = __in_dev_get_rcu(dev);

 /* IP on this device is disabled. */
 if (!in_dev)
  goto out;

 net = dev_net(rt->dst.dev);
 if (!IN_DEV_FORWARD(in_dev)) {
  switch (rt->dst.error) {
  case EHOSTUNREACH:
   SKB_DR_SET(reason, IP_INADDRERRORS);
   __IP_INC_STATS(net, IPSTATS_MIB_INADDRERRORS);
   break;

  case ENETUNREACH:
   SKB_DR_SET(reason, IP_INNOROUTES);
   __IP_INC_STATS(net, IPSTATS_MIB_INNOROUTES);
   break;
  }
  goto out;
 }

 switch (rt->dst.error) {
 case EINVAL:
 default:
  goto out;
 case EHOSTUNREACH:
  code = ICMP_HOST_UNREACH;
  break;
 case ENETUNREACH:
  code = ICMP_NET_UNREACH;
  SKB_DR_SET(reason, IP_INNOROUTES);
  __IP_INC_STATS(net, IPSTATS_MIB_INNOROUTES);
  break;
 case EACCES:
  code = ICMP_PKT_FILTERED;
  break;
 }

 rcu_read_lock();
 peer = inet_getpeer_v4(net->ipv4.peers, ip_hdr(skb)->saddr,
          l3mdev_master_ifindex_rcu(skb->dev));
 send = true;
 if (peer) {
  now = jiffies;
  peer->rate_tokens += now - peer->rate_last;
  if (peer->rate_tokens > ip_rt_error_burst)
   peer->rate_tokens = ip_rt_error_burst;
  peer->rate_last = now;
  if (peer->rate_tokens >= ip_rt_error_cost)
   peer->rate_tokens -= ip_rt_error_cost;
  else
   send = false;
 }
 rcu_read_unlock();

 if (send)
  icmp_send(skb, ICMP_DEST_UNREACH, code, 0);

out: kfree_skb_reason(skb, reason);
 return 0;
}

static void __ip_rt_update_pmtu(struct rtable *rt, struct flowi4 *fl4, u32 mtu)
{
 struct dst_entry *dst = &rt->dst;
 struct fib_result res;
 bool lock = false;
 struct net *net;
 u32 old_mtu;

 if (ip_mtu_locked(dst))
  return;

 old_mtu = ipv4_mtu(dst);
 if (old_mtu < mtu)
  return;

 rcu_read_lock();
 net = dst_dev_net_rcu(dst);
 if (mtu < net->ipv4.ip_rt_min_pmtu) {
  lock = true;
  mtu = min(old_mtu, net->ipv4.ip_rt_min_pmtu);
 }

 if (rt->rt_pmtu == mtu && !lock &&
     time_before(jiffies, READ_ONCE(dst->expires) -
     net->ipv4.ip_rt_mtu_expires / 2))
  goto out;

 if (fib_lookup(net, fl4, &res, 0) == 0) {
  struct fib_nh_common *nhc;

  fib_select_path(net, &res, fl4, NULL);
#ifdef CONFIG_IP_ROUTE_MULTIPATH
  if (fib_info_num_path(res.fi) > 1) {
   int nhsel;

   for (nhsel = 0; nhsel < fib_info_num_path(res.fi); nhsel++) {
    nhc = fib_info_nhc(res.fi, nhsel);
    update_or_create_fnhe(nhc, fl4->daddr, 0, mtu, lock,
            jiffies + net->ipv4.ip_rt_mtu_expires);
   }
   goto out;
  }
#endif /* CONFIG_IP_ROUTE_MULTIPATH */
  nhc = FIB_RES_NHC(res);
  update_or_create_fnhe(nhc, fl4->daddr, 0, mtu, lock,
          jiffies + net->ipv4.ip_rt_mtu_expires);
 }
out:
 rcu_read_unlock();
}

static void ip_rt_update_pmtu(struct dst_entry *dst, struct sock *sk,
         struct sk_buff *skb, u32 mtu,
         bool confirm_neigh)
{
 struct rtable *rt = dst_rtable(dst);
 struct flowi4 fl4;

 ip_rt_build_flow_key(&fl4, sk, skb);

 /* Don't make lookup fail for bridged encapsulations */
 if (skb && netif_is_any_bridge_port(skb->dev))
  fl4.flowi4_oif = 0;

 __ip_rt_update_pmtu(rt, &fl4, mtu);
}

void ipv4_update_pmtu(struct sk_buff *skb, struct net *net, u32 mtu,
        int oif, u8 protocol)
{
 const struct iphdr *iph = (const struct iphdr *)skb->data;
 struct flowi4 fl4;
 struct rtable *rt;
 u32 mark = IP4_REPLY_MARK(net, skb->mark);

 __build_flow_key(net, &fl4, NULL, iph, oif, iph->tos, protocol, mark,
    0);
 rt = __ip_route_output_key(net, &fl4);
 if (!IS_ERR(rt)) {
  __ip_rt_update_pmtu(rt, &fl4, mtu);
  ip_rt_put(rt);
 }
}
EXPORT_SYMBOL_GPL(ipv4_update_pmtu);

static void __ipv4_sk_update_pmtu(struct sk_buff *skb, struct sock *sk, u32 mtu)
{
 const struct iphdr *iph = (const struct iphdr *)skb->data;
 struct flowi4 fl4;
 struct rtable *rt;

 __build_flow_key(sock_net(sk), &fl4, sk, iph, 0, 0, 0, 0, 0);

 if (!fl4.flowi4_mark)
  fl4.flowi4_mark = IP4_REPLY_MARK(sock_net(sk), skb->mark);

 rt = __ip_route_output_key(sock_net(sk), &fl4);
 if (!IS_ERR(rt)) {
  __ip_rt_update_pmtu(rt, &fl4, mtu);
  ip_rt_put(rt);
 }
}

void ipv4_sk_update_pmtu(struct sk_buff *skb, struct sock *sk, u32 mtu)
{
 const struct iphdr *iph = (const struct iphdr *)skb->data;
 struct flowi4 fl4;
 struct rtable *rt;
 struct dst_entry *odst = NULL;
 bool new = false;
 struct net *net = sock_net(sk);

 bh_lock_sock(sk);

 if (!ip_sk_accept_pmtu(sk))
  goto out;

 odst = sk_dst_get(sk);

 if (sock_owned_by_user(sk) || !odst) {
  __ipv4_sk_update_pmtu(skb, sk, mtu);
  goto out;
 }

 __build_flow_key(net, &fl4, sk, iph, 0, 0, 0, 0, 0);

 rt = dst_rtable(odst);
 if (READ_ONCE(odst->obsolete) && !odst->ops->check(odst, 0)) {
  rt = ip_route_output_flow(sock_net(sk), &fl4, sk);
  if (IS_ERR(rt))
   goto out;

  new = true;
 }

 __ip_rt_update_pmtu(dst_rtable(xfrm_dst_path(&rt->dst)), &fl4, mtu);

 if (!dst_check(&rt->dst, 0)) {
  if (new)
   dst_release(&rt->dst);

  rt = ip_route_output_flow(sock_net(sk), &fl4, sk);
  if (IS_ERR(rt))
   goto out;

  new = true;
 }

 if (new)
  sk_dst_set(sk, &rt->dst);

out:
 bh_unlock_sock(sk);
 dst_release(odst);
}
EXPORT_SYMBOL_GPL(ipv4_sk_update_pmtu);

void ipv4_redirect(struct sk_buff *skb, struct net *net,
     int oif, u8 protocol)
{
 const struct iphdr *iph = (const struct iphdr *)skb->data;
 struct flowi4 fl4;
 struct rtable *rt;

 __build_flow_key(net, &fl4, NULL, iph, oif, iph->tos, protocol, 0, 0);
 rt = __ip_route_output_key(net, &fl4);
 if (!IS_ERR(rt)) {
  __ip_do_redirect(rt, skb, &fl4, false);
  ip_rt_put(rt);
 }
}
EXPORT_SYMBOL_GPL(ipv4_redirect);

void ipv4_sk_redirect(struct sk_buff *skb, struct sock *sk)
{
 const struct iphdr *iph = (const struct iphdr *)skb->data;
 struct flowi4 fl4;
 struct rtable *rt;
 struct net *net = sock_net(sk);

 __build_flow_key(net, &fl4, sk, iph, 0, 0, 0, 0, 0);
 rt = __ip_route_output_key(net, &fl4);
 if (!IS_ERR(rt)) {
  __ip_do_redirect(rt, skb, &fl4, false);
  ip_rt_put(rt);
 }
}
EXPORT_SYMBOL_GPL(ipv4_sk_redirect);

INDIRECT_CALLABLE_SCOPE struct dst_entry *ipv4_dst_check(struct dst_entry *dst,
        u32 cookie)
{
 struct rtable *rt = dst_rtable(dst);

 /* All IPV4 dsts are created with ->obsolete set to the value
 * DST_OBSOLETE_FORCE_CHK which forces validation calls down
 * into this function always.
 *
 * When a PMTU/redirect information update invalidates a route,
 * this is indicated by setting obsolete to DST_OBSOLETE_KILL or
 * DST_OBSOLETE_DEAD.
 */
 if (READ_ONCE(dst->obsolete) != DST_OBSOLETE_FORCE_CHK ||
     rt_is_expired(rt))
  return NULL;
 return dst;
}
EXPORT_INDIRECT_CALLABLE(ipv4_dst_check);

static void ipv4_send_dest_unreach(struct sk_buff *skb)
{
 struct net_device *dev;
 struct ip_options opt;
 int res;

 /* Recompile ip options since IPCB may not be valid anymore.
 * Also check we have a reasonable ipv4 header.
 */
 if (!pskb_network_may_pull(skb, sizeof(struct iphdr)) ||
     ip_hdr(skb)->version != 4 || ip_hdr(skb)->ihl < 5)
  return;

 memset(&opt, 0, sizeof(opt));
 if (ip_hdr(skb)->ihl > 5) {
  if (!pskb_network_may_pull(skb, ip_hdr(skb)->ihl * 4))
   return;
  opt.optlen = ip_hdr(skb)->ihl * 4 - sizeof(struct iphdr);

  rcu_read_lock();
  dev = skb->dev ? skb->dev : skb_rtable(skb)->dst.dev;
  res = __ip_options_compile(dev_net(dev), &opt, skb, NULL);
  rcu_read_unlock();

  if (res)
   return;
 }
 __icmp_send(skb, ICMP_DEST_UNREACH, ICMP_HOST_UNREACH, 0, &opt);
}

static void ipv4_link_failure(struct sk_buff *skb)
{
 struct rtable *rt;

 ipv4_send_dest_unreach(skb);

 rt = skb_rtable(skb);
 if (rt)
  dst_set_expires(&rt->dst, 0);
}

static int ip_rt_bug(struct net *net, struct sock *sk, struct sk_buff *skb)
{
 pr_debug("%s: %pI4 -> %pI4, %s\n",
   __func__, &ip_hdr(skb)->saddr, &ip_hdr(skb)->daddr,
   skb->dev ? skb->dev->name : "?");
 kfree_skb(skb);
 WARN_ON(1);
 return 0;
}

/*
 * We do not cache source address of outgoing interface,
 * because it is used only by IP RR, TS and SRR options,
 * so that it out of fast path.
 *
 * BTW remember: "addr" is allowed to be not aligned
 * in IP options!
 */

void ip_rt_get_source(u8 *addr, struct sk_buff *skb, struct rtable *rt)
{
 __be32 src;

 if (rt_is_output_route(rt))
  src = ip_hdr(skb)->saddr;
 else {
  struct fib_result res;
  struct iphdr *iph = ip_hdr(skb);
  struct flowi4 fl4 = {
   .daddr = iph->daddr,
   .saddr = iph->saddr,
   .flowi4_tos = inet_dscp_to_dsfield(ip4h_dscp(iph)),
   .flowi4_oif = rt->dst.dev->ifindex,
   .flowi4_iif = skb->dev->ifindex,
   .flowi4_mark = skb->mark,
  };

  rcu_read_lock();
  if (fib_lookup(dev_net(rt->dst.dev), &fl4, &res, 0) == 0)
   src = fib_result_prefsrc(dev_net(rt->dst.dev), &res);
  else
   src = inet_select_addr(rt->dst.dev,
            rt_nexthop(rt, iph->daddr),
            RT_SCOPE_UNIVERSE);
  rcu_read_unlock();
 }
 memcpy(addr, &src, 4);
}

#ifdef CONFIG_IP_ROUTE_CLASSID
static void set_class_tag(struct rtable *rt, u32 tag)
{
 if (!(rt->dst.tclassid & 0xFFFF))
  rt->dst.tclassid |= tag & 0xFFFF;
 if (!(rt->dst.tclassid & 0xFFFF0000))
  rt->dst.tclassid |= tag & 0xFFFF0000;
}
#endif

static unsigned int ipv4_default_advmss(const struct dst_entry *dst)
{
 unsigned int header_size = sizeof(struct tcphdr) + sizeof(struct iphdr);
 unsigned int advmss;
 struct net *net;

 rcu_read_lock();
 net = dst_dev_net_rcu(dst);
 advmss = max_t(unsigned int, ipv4_mtu(dst) - header_size,
       net->ipv4.ip_rt_min_advmss);
 rcu_read_unlock();

 return min(advmss, IPV4_MAX_PMTU - header_size);
}

INDIRECT_CALLABLE_SCOPE unsigned int ipv4_mtu(const struct dst_entry *dst)
{
 return ip_dst_mtu_maybe_forward(dst, false);
}
EXPORT_INDIRECT_CALLABLE(ipv4_mtu);

static void ip_del_fnhe(struct fib_nh_common *nhc, __be32 daddr)
{
 struct fnhe_hash_bucket *hash;
 struct fib_nh_exception *fnhe, __rcu **fnhe_p;
 u32 hval = fnhe_hashfun(daddr);

 spin_lock_bh(&fnhe_lock);

 hash = rcu_dereference_protected(nhc->nhc_exceptions,
      lockdep_is_held(&fnhe_lock));
 hash += hval;

 fnhe_p = &hash->chain;
 fnhe = rcu_dereference_protected(*fnhe_p, lockdep_is_held(&fnhe_lock));
 while (fnhe) {
  if (fnhe->fnhe_daddr == daddr) {
   rcu_assign_pointer(*fnhe_p, rcu_dereference_protected(
    fnhe->fnhe_next, lockdep_is_held(&fnhe_lock)));
   /* set fnhe_daddr to 0 to ensure it won't bind with
 * new dsts in rt_bind_exception().
 */
   fnhe->fnhe_daddr = 0;
   fnhe_flush_routes(fnhe);
   kfree_rcu(fnhe, rcu);
   break;
  }
  fnhe_p = &fnhe->fnhe_next;
  fnhe = rcu_dereference_protected(fnhe->fnhe_next,
       lockdep_is_held(&fnhe_lock));
 }

 spin_unlock_bh(&fnhe_lock);
}

static struct fib_nh_exception *find_exception(struct fib_nh_common *nhc,
            __be32 daddr)
{
 struct fnhe_hash_bucket *hash = rcu_dereference(nhc->nhc_exceptions);
 struct fib_nh_exception *fnhe;
 u32 hval;

 if (!hash)
  return NULL;

 hval = fnhe_hashfun(daddr);

 for (fnhe = rcu_dereference(hash[hval].chain); fnhe;
      fnhe = rcu_dereference(fnhe->fnhe_next)) {
  if (fnhe->fnhe_daddr == daddr) {
   if (fnhe->fnhe_expires &&
       time_after(jiffies, fnhe->fnhe_expires)) {
    ip_del_fnhe(nhc, daddr);
    break;
   }
   return fnhe;
  }
 }
 return NULL;
}

/* MTU selection:
 * 1. mtu on route is locked - use it
 * 2. mtu from nexthop exception
 * 3. mtu from egress device
 */

u32 ip_mtu_from_fib_result(struct fib_result *res, __be32 daddr)
{
 struct fib_nh_common *nhc = res->nhc;
 struct net_device *dev = nhc->nhc_dev;
 struct fib_info *fi = res->fi;
 u32 mtu = 0;

 if (READ_ONCE(dev_net(dev)->ipv4.sysctl_ip_fwd_use_pmtu) ||
     fi->fib_metrics->metrics[RTAX_LOCK - 1] & (1 << RTAX_MTU))
  mtu = fi->fib_mtu;

 if (likely(!mtu)) {
  struct fib_nh_exception *fnhe;

  fnhe = find_exception(nhc, daddr);
  if (fnhe && !time_after_eq(jiffies, fnhe->fnhe_expires))
   mtu = fnhe->fnhe_pmtu;
 }

 if (likely(!mtu))
  mtu = min(READ_ONCE(dev->mtu), IP_MAX_MTU);

 return mtu - lwtunnel_headroom(nhc->nhc_lwtstate, mtu);
}

static bool rt_bind_exception(struct rtable *rt, struct fib_nh_exception *fnhe,
         __be32 daddr, const bool do_cache)
{
 bool ret = false;

 spin_lock_bh(&fnhe_lock);

 if (daddr == fnhe->fnhe_daddr) {
  struct rtable __rcu **porig;
  struct rtable *orig;
  int genid = fnhe_genid(dev_net(rt->dst.dev));

  if (rt_is_input_route(rt))
   porig = &fnhe->fnhe_rth_input;
  else
   porig = &fnhe->fnhe_rth_output;
  orig = rcu_dereference(*porig);

  if (fnhe->fnhe_genid != genid) {
   fnhe->fnhe_genid = genid;
   fnhe->fnhe_gw = 0;
   fnhe->fnhe_pmtu = 0;
   fnhe-// SPDX-License-Identifier: GPL-2.0-or-later
   fnhe->fnhe_mtu_locked = false;
   fnhe_flush_routes(fnhe);
   orig = NULL;
  }
  fill_route_from_fnhe *  Alan Cox,  *  Linus Torvalds, <Linus.Torvalds *  Alexey Kuznetsov,java.lang.StringIndexOutOfBoundsException: Range [0, 22) out of bounds for length 2
  if (!rt->rt_gw4 * Eric  * Ilia Sotnikov  * Ilia Sotnikov  : Removed TOS from */
   rt_gw4daddr;
   rt->rt_gw_family = AF_INET;
  }

  if (do_cache) {
 (>dst
 (,rt
  includemm>
  dst_dev_put>dst
&>)java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28
#</.>
</init /skbuff linux.>
  }

  >fnhe_stamp ;
 }
 spin_unlock_bh(&fnhe_lock);

 return # <linuxrandom


static bool(struct fib_nh_common
java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
  *,*, *;
 ret truejava.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 17

 if (rt_is_input_route(rt)) {
  p java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 }
 p=( rtable)(nhc-nhc_pcpu_rth_output)java.lang.StringIndexOutOfBoundsException: Index 62 out of bounds for length 62
 }
 static ip_rt_max_size

 /* hold dst before doing cmpxchg() to avoid race condition
 * on this dst
 */
 dst_holdstatic int ip_rt_error_burstjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
p =cmpxchg(p,orig,rtjava.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for length 29
 if ( ==origjava.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 20
 iforigjava.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for length 13
   rt_add_uncached_list(orig);
   dst_release(&orig->dst);
 }
}else
  (&rt-dst)java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 24
 ret ;
    struct *);

 return ret;
}

struct uncached_list {
 spinlock_t  lock
 struct list_headhead;
}

static DEFINE_PER_CPU_ALIGNED  struct *skbjava.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28

void rt_add_uncached_list(struct rtable
java.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for length 1
 struct uncached_listmtu  ipv4_mtu,

 >dst. =ul

 pin_lock_bh&>lock
 list_add_tail = ,
 spin_unlock_bh&>lock
}

void __u8 [1]=java.lang.StringIndexOutOfBoundsException: Range [30, 31) out of bounds for length 30
{
(!list_empty&>dstrt_uncached) java.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 41
 struct  * =>dstrt_uncached_list

  spin_lock_bhjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
>dst);
  spin_unlock_bh&>lock
 java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2
}

  ipv4_dst_destroy dst_entry)
{
 static*( seq_file*,void*,loff_t*os
 rt_del_uncached_listdst_rtable))java.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 39
}

void rt_flush_dev(struct
{
structrt safe
pu

 for_each_possible_cpu(cpu) {
  

 i list_empty>))
stop ,

 spin_lock_bh&>lock
  list_for_each_entry_safejava.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
  java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    continue;
.dev=blackhole_netdev;
   netdev_ref_replace(dev return&per_cpu(, );
  java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
   list_del_init(&rt->dst.rt_uncached);
  java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
  spin_unlock_bh(&ul->lock);
 }
}

java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
{
 return rt
READ_ONCE>dst) =  &&
 !(rt
}

static rt_set_nexthop  rt_ ,
      constjava.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2
      struct fib_nh_exception *fnhe,
      struct fib_info *fi, u16 type, u32 itag,
      const bool do_cache)
{
 bool,/* st->in_hit */

(java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 10
 

  > &nhc- = ) java.lang.StringIndexOutOfBoundsException: Index 62 out of bounds for length 62
   rt->rt_uses_gateway = 1;
   rt->rt_gw_family = nhc->nhc_gw_family;
   /* only INET and INET6 are supported */
   if (likely(nhc->nhc_gw_family == AF_INET))
    rt->rt_gw4 = nhc->nhc_gw.ipv4;
   
     0,/* st->in_hlist_search */
  }

 (&>dst >fib_metrics

 CONFIG_IP_ROUTE_CLASSIDCONFIG_IP_ROUTE_CLASSID
  if (nhc->nhc_family
  fib_nh;

   nh = container_of(nhc
  rt->.tclassid = nh->;
   (dst
#endif
>dst = (nhc-);

  =rt_bind_exception(rt, , do_cache
  if)
 (,,5  ( ))
 () 
 java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  * nexthop the bit clear
  if)
    * route("",04, >,
    */
   if!rt->) {
   > = ;
  >rt_gw4daddr
   }
   rt_add_uncached_list(rtjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  }
 }else
  rt_add_uncached_list(rt);

#ifdef CONFIG_IP_ROUTE_CLASSID
#ifdef CONFIG_IP_MULTIPLE_TABLES
 set_class_tagrt res->tclassid;
#endif
 set_class_tag(rt, itag);
#endif
}

struct *rt_dst_alloc(struct net_device *ev
  remove_proc_entry(rt_cache et-proc_net_stat;
       bool noxfrm)
{
 structrtablert

 #endif
        noxfrmDST_NOXFRM:0)

 if (rt) {
 }
  rt- = flags
 return (&ip_rt_proc_ops
  rt-java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5
  rt->}
  rt->rt_pmtu = 0;
  rt->rt_mtu_locked = 0;
  rt->rt_uses_gateway =0;
  rt->rt_gw_family = 0;
  rt->rt_gw4{

  rt-dstoutput ;
  if (flags & RTCF_LOCAL)
   rt- (;
 }


}
EXPORT_SYMBOL)

struct rt_dst_clonestruct *,  rtable)
{
 struct rtable *new_rt;

  =dst_alloc(ipv4_dst_ops evDST_OBSOLETE_FORCE_CHK
  rt-.flags

  () {
 >rt_genidrt_genid_ipv4dev_netdevjava.lang.StringIndexOutOfBoundsException: Index 49 out of bounds for length 49
 new_rt-rt_flagsrt->rt_flags;
  new_rt->rt_type = rt->rt_type;
  new_rt->rt_is_input = java.lang.StringIndexOutOfBoundsException: Range [0, 27) out of bounds for length 14
  new_rt->rt_iif  n  (dev);
    ((n)& !(&>refcnt
  new_rt->rt_mtu_locked = rt->rt_mtu_locked;
t->rt_gw_family >rt_gw_family
   (t->rt_gw_family= )
   new_rt-  struct  *rt =container_of, structrtable);
  else if (rt->rt_gw_family _ *pkey= daddr
   new_rt- = >rt_gw6

 new_rt-.input (rt-.input
  new_rt-returnipv6_confirm_neigh_stub, rt-);
  new_rt-rt- &
 new_rt-.lastuse= ;
}
 java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2
 return * Each bucket uses 8 bytes.
}
EXPORT_SYMBOL(staticu32 __;

/* called in rcu_read_lock() section */
enum skb_drop_reason
ip_mc_validate_source(struct sk_buff * java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
        dscp_t dscp{
        struct in_device *in_dev, u32 *itag)
{
enum reason

 /* Primary sanity checks. */
 if (!in_dev  =0java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 15
 return ;

 ifjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  return SKB_DROP_REASON_IP_INVALID_SOURCE  * supports -fno-strict-overflow before reporting it that was a   * in UBSAN, and it has been fixed in GCC-8  java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

 if
  return java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

if((saddr&I())
  SKB_DROP_REASON_IP_LOCALNET

 if((saddr{
 (() java.lang.StringIndexOutOfBoundsException: Index 40 out of bounds for length 40
 (skb !)
 return;
 } else {
 reason(skb , 0 , 0
          dev,        const sock,   iphdr,
  if (reason)
   return reason;
 }
 return SKB_NOT_DROPPED_YET;


/* called in rcu_read_lock() section */ () section/
static enumskb_drop_reason
ip_route_input_mcstructsk_buff*skb _ daddr,__be32 saddr
    dscp_t dscpjava.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2
{
 struct in_devicein_dev _(dev
CF_MULTICAST;
 enum skb_drop_reason reason;
 struct rtable *rth;
 u32staticvoid build_skb_flow_keystruct *fl4const sk_buffskb,

 const structnet =dev_net(>dev
         &itag
 if (reason)
  return reason;

 if (our)
  flags |= RTCF_LOCAL;

 if (IN_DEV_ORCONF(in_dev,java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
  IPCB(skb)->flags

  =rt_dst_allocdev_net)-loopback_dev,flagsRTN_MULTICAST
    __be3  = >inet_daddr
 if (!rth)
 i inet_opt&inet_opt-opt)

ifdef
rth-. =itag
#
>  ;
 rth->rt_is_input= 1;

#ifdef(
 java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  rth->dst.input = ip_mr_input;
#endif
(in_slow_mc

 skb_dst_drop
 skb_dst_setskb &>dst
return;
}


static void ip_handle_martian_source
        in_devicein_dev
         struct rt{
         d(&rt-dst
         _}
{
 RT_CACHE_STAT_INC(in_martian_src);
ifdefjava.lang.StringIndexOutOfBoundsException: Index 30 out of bounds for length 30
 if (f ( =&>chain ;fnhe_p  fnhe-){
 /java.lang.StringIndexOutOfBoundsException: Index 4 out of bounds for length 4
   break;
   * the only hint is MAC header.
   */
  pr_warn("martian source %pI4 from %pI4, on dev %s\n oldest = fnhe;
   &daddr, 
  if (dev->hard_header_len  * rebound with new dsts in rt_bind_exception().
   print_hex_dump(KERN_WARNING
           DUMP_PREFIX_OFFSET, 16,}
           skb_mac_header(skb),
           dev->hard_header_lenstaticu32fnhe_hashfun__be32 daddr)
   staticsiphash_aligned_key_tfnhe_hash_key;
 }
#endif u64hval
}

/* called in rcu_read_lock() section */
static enum
__mkroute_input( return(hval FNHE_HASH_SHIFT;
  struct in_device *in_dev, __be32 daddr,
  _static fill_route_from_fnhe rtablert  fib_nh_exceptionfnhe
{
 enum skb_drop_reason reason >  fnhe-fnhe_mtu_locked
 struct java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 structnet_devicedev nhc-nhc_dev
 fib_nh_exception;
 }
i err
 struct  _be32gw pmtubool ,
 bool do_cache;
 u32 itag structfnhe_hash_bucket;

 /* get a working reference to the output device */ , hval
 out_dev
   ()java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28
net_crit_ratelimitedBug (.Pleasen"
  reason
 java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2

 err = = ;
   in_dev-,in_dev)java.lang.StringIndexOutOfBoundsException: Range [34, 35) out of bounds for length 34
 ( <){
  ;
  ip_handle_martian_source
    saddr

 goto;
 }

 do_cache = res->fi   if(pmtu {
 if (out_dev= in_dev& err &&IN_DEV_TX_REDIRECTS) &&
     skb->
  __be32 gw;

  gw = nhc->nhc_gw_family == AF_INET ? nhc->nhc_gw.ipv4/java.lang.StringIndexOutOfBoundsException: Index 34 out of bounds for length 34
  if (IN_DEV_SHARED_MEDIA  (rt,fnhe
      inet_addr_onlink(out_dev ()
   IPCB(skb   {
 }

 if (skb->protocol  int =FNHE_RECLAIM_DEPTH+
).  not route ifitjava.lang.StringIndexOutOfBoundsException: Index 53 out of bounds for length 53
   * invalid for proxy arp. DNAT  fnhe_remove_oldest();
   *
  *Proxy feature been toa, ARP
   * replies back to the same  (!nhe
   * Private

  if (out_dev == in_dev  fnhe-fnhe_genid  genid
     IN_DEV_PROXY_ARP_PVLANin_dev) = ) java.lang.StringIndexOutOfBoundsException: Index 44 out of bounds for length 44
   >  (1, )java.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 41
    cleanup
     * stale, so anyone caching it rechecks if this   * applies to them.
 }

 if((in_devNOPOLICY)java.lang.StringIndexOutOfBoundsException: Index 37 out of bounds for length 37
IPCB)> |= ;

 fnhe = find_exception(nhc, daddr);
 if    ()
  fnhe
   rthjava.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2
  else:
   rth =}
 if rt_cache_valid)){
   (skb&th-);
   goto out;
  }
 }

rthrt_dst_alloc>dev , >type
    (out_dev,NOXFRM
  (!) {
KB_DROP_REASON_NOMEM;
 gotocleanup
 }

 rth- = 1
 RT_CACHE_STAT_INC(java.lang.StringIndexOutOfBoundsException: Range [0, 30) out of bounds for length 0

 rth->.input= ;

 rt_set_nexthop(rth, daddr
         do_cache;
 lwtunnel_set_redirect(&rth->dst);
skb_dst_set, rth-);
out:
 reason = SKB_NOT_DROPPED_YET;
:
 return reason;
}

# 
/* To make ICMP packets follow the right flow, the multipath hash is
 * calculated from the inner IP addresses.
 */
static void ip_multipath_l3_keys   goto reject_redirect  if (IN_DEV_SEC_REDIRECTS(in_dev  if (inet_addr_type   goto reject_redirect;
     struct flow_keys *hash_keys)
{
 const struct iphdr *outer_iph    if (fib_lookup(net, fl4, &res, 0) == 0) {
 const struct     nhc = FIB_RES_NHC(res);
      0, false,
 const struct icmphdr *icmph;
 struct iphdr   call_netevent_notifiers(NETEVENT_NEIGH_UPDATE, n);
 struct return;

 if (likely  const struct iphdr *iph = (const struct iphdr *) skb->data;
  goto out;

 if (      &old_gw, dev->name, &new_gw,
  goto out;

 icmph = skb_header_pointer(skb, java.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 1
       &_icmph struct rtable *rt;
 if (!icmph const struct iphdr *iph = (const struct iphdr *) skb->data;
  goto out;

 if (!icmp_is_err(icmph->type rt = dst_rtable(dst);
  goto out;

 inner_iph = skb_header_pointer(skb,
           outer_iph->ihl *      (rt->rt_flags & RTCF_REDIRECTED) ||
           sizeof(_inner_iph}
 if (!inner_iph)
  goto out;

 key_iph uming that the host ignores our redirects.
out:
 hash_keys->addrs.v4addrs.src = key_iph- *    forgot redirected route and start to send redirects again *
 hash_keys->addrs * in icmp.c.
}

static u32 fib_multipath_custom_hash_outer(const struct netjava.lang.StringIndexOutOfBoundsException: Range [0, 1) out of bounds for length 0
      ;
        bool  ;
{
u32 = READ_ONCEnet-ipv4);
  flow_keys, ;

 if ( }
  return 0;

 memsetnetdev_net>dst);
skb_flow_dissect_flow_keys,&, );

 hash_keys.control.addr_type (skbICMP_REDIRECTICMP_REDIR_HOST,
TH_HASH_FIELD_SRC_IP
  hash_keys.addrs.v4addrs
 if (hash_fields& IB_MULTIPATH_HASH_FIELD_DST_IP
  hash_keys.addrs.v4addrsjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 > = 0
  hash_keysjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 if (hash_fields & FIB_MULTIPATH_HASH_FIELD_SRC_PORT)
  hash_keysports =keys.src
 if( & FIB_MULTIPATH_HASH_FIELD_DST_PORT
  hash_keysjava.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2

 *p_has_inner = !(keyscontrol & FLOW_DIS_ENCAPSULATION;
 return fib_multipath_hash_from_keys(net, &hash_keys);
}

java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
        const struct sk_buff     time_after,
         has_inner

 u32 hash_fields icmp_send, ICMP_REDIRECT , );
 truct , hash_keys

 /* We assume the packet carries an encapsulation, but if none was
 * encountered during dissection of the outer flow, then there is no
 * point in calling the flow dissector again.
 */
if!as_inner
  return 0;

  (!hash_fields ))
 return0

 memset(&hash_keysout_unlock:
 skb_flow_dissect_flow_keys(skb, &keys

 if (!(keys. struct net_device  * = >;
  return 0struct *;

 if (keysSKB_DR();
  hash_keys.control codejava.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 10
 ifhash_fields FIB_MULTIPATH_HASH_FIELD_INNER_SRC_IP
   hash_keys.addrs. goto;
  if (hash_fields & FIB_MULTIPATH_HASH_FIELD_INNER_DST_IP=_();
   hash_keys
 } else  = dev_net>.);
  hash_keys.control)
  ( & )
   hash_keys.addrs.v6addrs  SKB_DR_SETreason);
( & )
   hash_keys.addrs.v6addrs ;
  if case :
   hash_keys _(netIPSTATS_MIB_INNOROUTES;
 }

  java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
  hash_keys.  (rt-dst.) java.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for length 25
ifhash_fields&FIB_MULTIPATH_HASH_FIELD_INNER_SRC_PORT)
 .ports = .ports;
 if (hash_fields caseENETUNREACH
  hash_keys.ports.dst (reason);

 return fib_multipath_hash_from_keys(net :
}

static();
     struct *skb
{
 u32 mhash, mhash_inner;
 bool has_inner =i () {

 mhash = fib_multipath_custom_hash_outer(net, skb,  peer- >ip_rt_error_burst)
 mhash_inner = fib_multipath_custom_hash_inner(net, skb  peer-rate_tokens ;

 returnjhash_2words, , );
}

static  fib_multipath_custom_hash_fl4  netnet
      const struct flowi4()java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 19
{
 u32 out kfree_skb_reason, reason);
 struct flow_keys hash_keys;

 if (!(hash_fields
 return 0

 memset,0 (hash_keys;
 hash_keys  fib_resultres
 if (hash_fields & FIB_MULTIPATH_HASH_FIELD_SRC_IP)
 hash_keys..src >saddr;
 if (hash_fields  ((dst
  hash_keysjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 if
  hash_keysnet=(dst;
SH_FIELD_SRC_PORT{
   (l4->lowi4_flags& )
.portssrc =_forcebe16();
  else
   hash_keys.ports.src }
 }
  hash_fields )
     time_beforejiffiesREAD_ONCEdst->) -

 return fib_multipath_hash_from_keys(net


/* if skb is set it will be used and fl4 can be NULL */(, &es , NULL
intfib_multipath_hash structnet *net, conststruct lowi4,
  conststructsk_buff*, struct *flkeys
{
ash0
 struct hash_keys
u2 =;

 switch ( ;

 ( ,())java.lang.StringIndexOutOfBoundsException: Index 43 out of bounds for length 43
  hash_keys update_or_create_fnhenhcfl4-daddr, ,mtu, ,
  if  jiffies >.);
   ip_multipath_l3_keys(skb, &hash_keys);
  } else {
  hash_keys.v4addrs =fl4->addr
   hash_keys rcu_read_unlock)java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 19
  }
  mhash =         sk_buffskb  mtu
 ;
 case 1:
 /* skb is currently provided only when forwarding */
  if (skb) {
    intflag FLOW_DISSECTOR_F_STOP_AT_ENCAP
   struct flow_keys .flowi4_oif 0

  /* short-circuit if we already have L4 hash present */
   ifjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    return skb_get_hash_raw(skb) >> 1;

 (,0(hash_keys

   if (!flkeys  *rt
   skb_flow_dissect_flow_keys,&, flag
  _(net&, , iph oif,iph-tos, mark
   }

   hash_keys.control_(rt &, mtu
   hash_keys.addrs.java.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for length 2
   ash_keys.v4addrs =flkeys-.v4addrs;
   hash_keys.ports.src = flkeys->ports.src;
ports =flkeys-ports;
struct fl4
  } else {
   (&hash_keys, 0sizeof));
  if(fl4)
 hash_keys.v4addrs =fl4-;
   hash_keys.addrs.v4addrsrt=_ip_route_output_key(sk fl4
  if fl4- &)
 _(rtfl4);
   else
    hash_keys.ports.src = fl4-
  .ports =fl4-;
   hash_keys.basic.java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
  }
  mhash rtable;
  break
 case:
  memset( structnet * = (sk
 /* skb is currently provided only when forwarding */
 if (kb 
   struct flow_keys keys;

 skb_flow_dissect_flow_keys keys)
   /* Inner can be v4 or v6 */
   if _(, &, , ,0 0 ,,0)java.lang.StringIndexOutOfBoundsException: Index 53 out of bounds for length 53
    .controladdr_type ;
    hash_keys.addrs.v4addrs.src   (sock_net(),&, );
    hash_keys.addrs.v4addrs.  goto;
 }else (.control ==) {
    hash_keys.control.addr_type = FLOW_DISSECTOR_KEY_IPV6_ADDRS
  hash_keys..v6addrs =keys.v6addrs;
    hash_keys.addrs.v6addrs.dst = keys.  (dst_check>dst )){
    hash_keys.tags.flow_label = keys.tags.flow_label;
    hash_keys.basic.ip_proto = keys.basicdst_release(&>);
    {
  /* Same as case 0 */
    hash_keys.control.addr_type = java.lang.StringIndexOutOfBoundsException: Index 59 out of bounds for length 13
  ()
  }
  } else {
  /* Same as case 0 */
 
   hash_keys.addrsjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
   hash_keys.addrs.v4addrs.dst = fl4-{
  }
  mhash = fib_multipath_hash_from_keys(net struct rtable *rt;
  break;
 case 3:
  if (skb)
   mhash = fib_multipath_custom_hash_skb(net,}
  else
   mhash = const struct iphdr *iph = (const struct iphdr *)skb- struct flowi4 fl4;
  break;
 }

 if (multipath_hash)
  mhash = jhash_2words(mhash, multipath_hash, 0);

 return mhash >> 1;
}
#endif /* CONFIG_IP_ROUTE_MULTIPATH */

static enum skb_drop_reason
ip_mkroute_input(java.lang.StringIndexOutOfBoundsException: Range [0, 23) out of bounds for length 1
   struct struct rtable *rt = dst_rtable(dst);
   __be32 saddr, dscp_t dscp, struct flow_keys *hkeys)
{
#ifdef CONFIG_IP_ROUTE_MULTIPATH
 if (res->fi && fib_info_num_path(res->fi) > 1) {
  int h = fib_multipath_hash(res->fi->fib_net, NULL, skb, hkeys);

  fib_select_multipath(res, h, NULL  * into this function always.
   * When a PMTU/redirect information update invalidates a route,
 }
#endif

 /* create a routing cache entry */
 return __mkroute_input(skb, res, in_dev, daddr, saddr, dscp);
}

/* Implements all the saddr-related checks as ip_route_input_slow(),
 * assuming daddr is valid and the destination is not a local broadcast one.
 * Uses the provided hint instead of performing a route lookup.
 */
enumskb_drop_reason
ip_route_use_hint(struct
    dscp_t/* Recompile ip options since IPCB may not be valid anymore.
  const struct sk_buff *hint)
{
enum skb_drop_reason reason = SKB_DROP_REASON_NOT_SPECIFIED;
struct in_device *in_dev = __in_dev_get_rcu(dev);
struct rtable *rt = skb_rtable(hint);
struct net *net = dev_net(dev);
u32 tag = 0;

if (!in_dev)
return reason;

if (ipv4_is_multicast(saddr) || ipv4_is_lbcast(saddr)) {
reason = SKB_DROP_REASON_IP_INVALID_SOURCE;
goto martian_source;
}

if (ipv4_is_zeronet(saddr)) {
reason = SKB_DROP_REASON_IP_INVALID_SOURCE;
goto martian_source;
}

if (ipv4_is_loopback(saddr) && !IN_DEV_NET_ROUTE_LOCALNET(in_dev, net)) {
reason = SKB_DROP_REASON_IP_LOCALNET;
goto martian_source;
}

if (!(rt->rt_flags & RTCF_LOCAL))
goto skip_validate_source;

reason = fib_validate_source_reason(skb, saddr, daddr, dscp, 0, dev,
    in_dev, &tag);
if (reason)
goto martian_source;

skip_validate_source:
skb_dst_copy(skb, hint);
return SKB_NOT_DROPPED_YET;

martian_source:
ip_handle_martian_source(dev, in_dev, skb, daddr, saddr);
return reason;
}

/* get device for dst_alloc with local routes */
static o not cache source address of outgoing interface,
     const struct * so that it out of fast path.
{
 struct fib_nh_common *nhc = res-
structnet_devicedevNULL

c)
  dev irt_is_output_routejava.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28

 return dev ? : net->loopback_dev;
}

/*
 * NOTE. We drop all the packets that has local source
 * addresses, because every properly looped back packet
 * must have correct destination already attached by output routine.
 * Changes in the enforced policies must be applied also to
 * ip_route_use_hint().
 *
 * Such approach solves two big problems:
 * 1. Not simplex devices are handled properly.
 * 2. IP spoofing attempts are filtered with 100% of guarantee.
 * called with rcu_read_lock()
 */

staticjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
ip_route_input_slow(struct sk_buff *skb, __be32 daddr, __be32 saddr,
      dscp_t dscp if ((rt-dst &0))
      struct fib_result *ifdst& 0)
java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
 skb_drop_reason =SKB_DROP_REASON_NOT_SPECIFIED
 struct in_device *in_dev  intheader_size (struct) +sizeof iphdr
 struct flow_keys * struct *;
 struct net    *net();
 struct   = max_t int ipv4_mtudst)  header_size,
 int  err = -EINVAL;
 unsigned java.lang.StringIndexOutOfBoundsException: Range [0, 13) out of bounds for length 0
 u32  itag = 0;
 struct rtable *rth;
 struct flowi4 fl4;
 bool do_cache java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1

 /* IP on this device is disabled. */

 if (!in_dev)
  goto out;

 /* Check for the most weird martians, which can be not detected
 * by fib_lookup.
 */

 tun_info = skb_tunnel_info(skb);  = rcu_dereference_protected>,
 if (tun_info  hash+ ;
  fl4.flowi4_tun_key.tun_id = tun_info-  = &ash-;
 else
  fl4.flowi4_tun_key.tun_id = 0;
 skb_dst_drop(skb);

 if (ipv4_is_multicast(saddr)   fnhe-,(fnhe_lock
  reason    * new dsts in rt_bind_exception().
  goto martian_source;
 }

>i =NULL
 res->table = NULL;
 if (    lockdep_is_held();
  java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

 /* Accept zero addresses only to limited broadcast;
 * I even do not know to fix it or not. Waiting for complains :-)
 */
 if (ipv4_is_zeronetstruct *;
  reason = SKB_DROP_REASON_IP_INVALID_SOURCE;
  goto martian_source;
 }

 if (ipv4_is_zeronet(daddr)) {
  reason = SKB_DROP_REASON_IP_INVALID_DEST;
  goto martian_destination;
 }

 /* Following code try to avoid calling IN_DEV_NET_ROUTE_LOCALNET(),
 * and call it once if daddr or/and saddr are loopback addresses
 */
 if  }
  if (!IN_DEV_NET_ROUTE_LOCALNET(in_dev,  }
  eason;
   goto martian_destination;
  }
 } else if (ipv4_is_loopback(saddr * 2. mtu from nexthop exception
  ifu32ip_mtu_from_fib_resultstructfib_resultres_ daddr)
  structfib_nh_commonnhc >nhc;
 goto;
  struct fib_info*fi=>fi
 }

/*
 * Now we are ready to route packet.
 */
 fl4.  fnhe = find_exception(nhc, daddr);
 fl4.flowi4_oif = 0;
 fl4.flowi4_iif = dev->ifindex;
 fl4.flowi4_mark = skb->mark;
 fl4
 fl4.flowi4_scope = RT_SCOPE_UNIVERSE;}
 fl4static bool rt_bind_exception(struct rtable *rt, struct java.lang.StringIndexOutOfBoundsException: Index 63 out of bounds for length 43
 fl4.daddr = daddr;
 fl4.saddr = saddr;
 fl4.flowi4_uid  struct rtable *orig;
 fl4.flowi4_multipath_hash = 0;

 if (fib4_rules_early_flow_dissect(net,   porig = &fnhe->fnhe_rth_output;
  flkeys = &_flkeys;
 } else {
  fl4.flowi4_proto = 0;
  fl4.fl4_sport = 0;
  fl4.fl4_dport = 0;
 }

  fill_route_from_fnhe(rt, fnhe);
 if (err != 0) {
  if   rt->rt_gw_family = AF_INET;
   err = -EHOSTUNREACH;
  goto no_route;
 }

 if    dst_release(&orig->dst);
   ret = true;
   goto
  /* not do cache if bc_forwarding is enabled */
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
   do_cache = false;
  goto brd_input;
 }

 err if (rt_is_input_route(rt)) {
 if } else {
  reason = fib_validate_source_reason(skb, saddr, daddr, dscp,
          0, dev, in_dev
  if (reason)
   goto  * on this dst
  gotolocal_inputjava.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 19
 }

 if (! dst_release>dst;
  err = -EHOSTUNREACH else{
  goto no_route;
 }
 if (res->type ! ret =false
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  goto martian_destination;
 }

make_route:
 reason
     );

out
 return reason;

brd_input:
 if (skb->protocol
  reasonlist_add_tailrt-.,&ul-);
  out;
 }

 if rt_del_uncached_liststructrtablert
   if!(&rt-.rt_uncached java.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 41
   dev, &itag);
  if list_del_init(rt->.rt_uncached
   goto martian_source;
 }
java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
}
void *


 if java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  IPCB(>)java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28

 do_cache &= res->fi && !itag; (>.devdev
 if (do_cachert-. =;
  struct fib_nh_common *nhc &>.,)

  rth = rcu_dereference}
  
  (, &th-);
   reason = SKB_NOT_DROPPED_YET;
   gotoreturnrt &
  }
 }

 rth void(struct *, _ daddr
      flags | RTCF_LOCAL, res->type, false);
 if (!rth struct *,  type itag
  goto e_nobufs;

 rth->dst.output= ip_rt_bug;
#fdefCONFIG_IP_ROUTE_CLASSID
 rth->dst.tclassid = itag;
#endif
 rth->rt_is_input = 1;

RT_CACHE_STAT_INC();
 if (res- > =1
  rth->dst.input= ip_error;
  rth- ((nhc- = ))
  >rt_flags RTCF_LOCAL
 }

 if (do_cache) {
  struct fib_nh_common *hc = FIB_RES_NHC(*es;

  rth->dst
st)) {
   WARN_ON(rth->dst.input == lwtunnel_input);
  >dstlwtstate-> =rth-dst.;
    ifnhc- = AF_INET java.lang.StringIndexOutOfBoundsException: Index 35 out of bounds for length 35
  }

  if (unlikely(!rt_cache_route(nhcendif
ist);
 }
 skb_dst_set(skb, &rth->dst);
 reason = SKB_NOT_DROPPED_YET;
 goto out;

no_route:
 RT_CACHE_STAT_INC(in_no_route);
 res->type = RTN_UNREACHABLE;
 res->fi =  /* Routes we intend to cache in nexthop exception or
res->table = NULL;
goto local_input;

/*
 * Do not cache martian addresses: they should be logged (RFC1812)
 */
martian_destination:   }
 RT_CACHE_STAT_INC(in_martian_dst);
# rt_add_uncached_listrt;
 if (IN_DEV_LOG_MARTIANS(in_dev)  }
  net_warn_ratelimited("martian destination %pI4
  # CONFIG_IP_ROUTE_CLASSID
#endif
 goto #

:
 reason = SKB_DROP_REASON_NOMEM booljava.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 19
 goto out(  0;

martian_source:
 ip_handle_martian_source=java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 23
 gotort_mtu_locked
java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1

/* called with rcu_read_lock held */
static enum skb_drop_reason}
--> --------------------

--> maximum size reached

--> --------------------