[BACK]Return to ip_input.c CVS log [TXT][DIR] Up to [cvs.NetBSD.org] / src / sys / netinet

Please note that diffs are not public domain; they are subject to the copyright notices on the relevant files.

Diff for /src/sys/netinet/ip_input.c between version 1.337.2.5 and 1.338

version 1.337.2.5, 2017/04/26 02:53:29 version 1.338, 2016/07/26 08:34:55
Line 101  __KERNEL_RCSID(0, "$NetBSD$");
Line 101  __KERNEL_RCSID(0, "$NetBSD$");
 #include "opt_mrouting.h"  #include "opt_mrouting.h"
 #include "opt_mbuftrace.h"  #include "opt_mbuftrace.h"
 #include "opt_inet_csum.h"  #include "opt_inet_csum.h"
 #include "opt_net_mpsafe.h"  
 #endif  #endif
   
 #include "arp.h"  #include "arp.h"
Line 253  EVCNT_ATTACH_STATIC(ip_swcsum);
Line 252  EVCNT_ATTACH_STATIC(ip_swcsum);
 #endif /* INET_CSUM_COUNTERS */  #endif /* INET_CSUM_COUNTERS */
   
 /*  /*
  * Used to save the IP options in case a protocol wants to respond   * We need to save the IP options in case a protocol wants to respond
  * to an incoming packet over the same route if the packet got here   * to an incoming packet over the same route if the packet got here
  * using IP source routing.  This allows connection establishment and   * using IP source routing.  This allows connection establishment and
  * maintenance when the remote end is on a network that is not known   * maintenance when the remote end is on a network that is not known
  * to us.   * to us.
  */   */
 struct ip_srcrt {  
         int             isr_nhops;                 /* number of hops */  static int      ip_nhops = 0;
         struct in_addr  isr_dst;                   /* final destination */  
         char            isr_nop;                   /* one NOP to align */  static  struct ip_srcrt {
         char            isr_hdr[IPOPT_OFFSET + 1]; /* OPTVAL, OLEN & OFFSET */          struct  in_addr dst;                    /* final destination */
         struct in_addr  isr_routes[MAX_IPOPTLEN/sizeof(struct in_addr)];          char    nop;                            /* one NOP to align */
 };          char    srcopt[IPOPT_OFFSET + 1];       /* OPTVAL, OLEN and OFFSET */
           struct  in_addr route[MAX_IPOPTLEN/sizeof(struct in_addr)];
   } ip_srcrt;
   
 static int ip_drainwanted;  static int ip_drainwanted;
   
 static void save_rte(struct mbuf *, u_char *, struct in_addr);  struct  sockaddr_in ipaddr = {
           .sin_len = sizeof(ipaddr),
           .sin_family = AF_INET,
   };
   
   static void save_rte(u_char *, struct in_addr);
   
 #ifdef MBUFTRACE  #ifdef MBUFTRACE
 struct mowner ip_rx_mowner = MOWNER_INIT("internet", "rx");  struct mowner ip_rx_mowner = MOWNER_INIT("internet", "rx");
Line 280  static void  ipintr(void *);
Line 286  static void  ipintr(void *);
 static void             ip_input(struct mbuf *);  static void             ip_input(struct mbuf *);
 static void             ip_forward(struct mbuf *, int, struct ifnet *);  static void             ip_forward(struct mbuf *, int, struct ifnet *);
 static bool             ip_dooptions(struct mbuf *);  static bool             ip_dooptions(struct mbuf *);
 static struct in_ifaddr *ip_rtaddr(struct in_addr, struct psref *);  static struct in_ifaddr *ip_rtaddr(struct in_addr);
 static void             sysctl_net_inet_ip_setup(struct sysctllog **);  static void             sysctl_net_inet_ip_setup(struct sysctllog **);
   
 static struct in_ifaddr *ip_match_our_address(struct ifnet *, struct ip *,  static struct in_ifaddr *ip_match_our_address(struct ifnet *, struct ip *,
Line 288  static struct in_ifaddr *ip_match_our_ad
Line 294  static struct in_ifaddr *ip_match_our_ad
 static struct in_ifaddr *ip_match_our_address_broadcast(struct ifnet *,  static struct in_ifaddr *ip_match_our_address_broadcast(struct ifnet *,
                             struct ip *);                              struct ip *);
   
 #ifdef NET_MPSAFE  /* XXX: Not yet enabled. */
 #define SOFTNET_LOCK()          mutex_enter(softnet_lock)  
 #define SOFTNET_UNLOCK()        mutex_exit(softnet_lock)  
 #else  
 #define SOFTNET_LOCK()          KASSERT(mutex_owned(softnet_lock))  #define SOFTNET_LOCK()          KASSERT(mutex_owned(softnet_lock))
 #define SOFTNET_UNLOCK()        KASSERT(mutex_owned(softnet_lock))  #define SOFTNET_UNLOCK()        KASSERT(mutex_owned(softnet_lock))
 #endif  
   
 /*  /*
  * IP initialization: fill in IP protocol switch table.   * IP initialization: fill in IP protocol switch table.
Line 328  ip_init(void)
Line 330  ip_init(void)
         ip_ids = ip_id_init();          ip_ids = ip_id_init();
         ip_id = time_uptime & 0xfffff;          ip_id = time_uptime & 0xfffff;
   
           ip_mtudisc_timeout_q = rt_timer_queue_create(ip_mtudisc_timeout);
 #ifdef GATEWAY  #ifdef GATEWAY
         ipflow_init();          ipflow_init();
 #endif  #endif
Line 342  ip_init(void)
Line 345  ip_init(void)
 #endif /* MBUFTRACE */  #endif /* MBUFTRACE */
   
         ipstat_percpu = percpu_alloc(sizeof(uint64_t) * IP_NSTATS);          ipstat_percpu = percpu_alloc(sizeof(uint64_t) * IP_NSTATS);
   
         ipforward_rt_percpu = percpu_alloc(sizeof(struct route));  
         if (ipforward_rt_percpu == NULL)  
                 panic("failed to allocate ipforward_rt_percpu");  
   
         ip_mtudisc_timeout_q = rt_timer_queue_create(ip_mtudisc_timeout);  
 }  }
   
 static struct in_ifaddr *  static struct in_ifaddr *
Line 435  ipintr(void *arg __unused)
Line 432  ipintr(void *arg __unused)
   
         KASSERT(cpu_softintr_p());          KASSERT(cpu_softintr_p());
   
 #ifndef NET_MPSAFE  
         mutex_enter(softnet_lock);          mutex_enter(softnet_lock);
 #endif  
         while ((m = pktq_dequeue(ip_pktq)) != NULL) {          while ((m = pktq_dequeue(ip_pktq)) != NULL) {
                 ip_input(m);                  ip_input(m);
         }          }
 #ifndef NET_MPSAFE  
         mutex_exit(softnet_lock);          mutex_exit(softnet_lock);
 #endif  
 }  }
   
 /*  /*
Line 454  static void
Line 447  static void
 ip_input(struct mbuf *m)  ip_input(struct mbuf *m)
 {  {
         struct ip *ip = NULL;          struct ip *ip = NULL;
         struct in_ifaddr *ia = NULL;          struct in_ifaddr *ia;
         int hlen = 0, len;          int hlen = 0, len;
         int downmatch;          int downmatch;
         int srcrt = 0;          int srcrt = 0;
         ifnet_t *ifp;          ifnet_t *ifp;
         struct psref psref;          struct psref psref;
         int s;  
   
         KASSERTMSG(cpu_softintr_p(), "ip_input: not in the software "          KASSERTMSG(cpu_softintr_p(), "ip_input: not in the software "
             "interrupt handler; synchronization assumptions violated");              "interrupt handler; synchronization assumptions violated");
Line 616  ip_input(struct mbuf *m)
Line 608  ip_input(struct mbuf *m)
                 struct in_addr odst = ip->ip_dst;                  struct in_addr odst = ip->ip_dst;
                 bool freed;                  bool freed;
   
                   SOFTNET_LOCK();
                 freed = pfil_run_hooks(inet_pfil_hook, &m, ifp, PFIL_IN) != 0;                  freed = pfil_run_hooks(inet_pfil_hook, &m, ifp, PFIL_IN) != 0;
                   SOFTNET_UNLOCK();
                 if (freed || m == NULL) {                  if (freed || m == NULL) {
                         m = NULL;  
                         goto out;                          goto out;
                 }                  }
                 ip = mtod(m, struct ip *);                  ip = mtod(m, struct ip *);
Line 648  ip_input(struct mbuf *m)
Line 641  ip_input(struct mbuf *m)
                 if ((*altq_input)(m, AF_INET) == 0) {                  if ((*altq_input)(m, AF_INET) == 0) {
                         /* Packet dropped by traffic conditioner. */                          /* Packet dropped by traffic conditioner. */
                         SOFTNET_UNLOCK();                          SOFTNET_UNLOCK();
                         m = NULL;  
                         goto out;                          goto out;
                 }                  }
                 SOFTNET_UNLOCK();                  SOFTNET_UNLOCK();
Line 661  ip_input(struct mbuf *m)
Line 653  ip_input(struct mbuf *m)
          * error was detected (causing an icmp message           * error was detected (causing an icmp message
          * to be sent and the original packet to be freed).           * to be sent and the original packet to be freed).
          */           */
         if (hlen > sizeof (struct ip) && ip_dooptions(m)) {          ip_nhops = 0;           /* for source routed packets */
                 m = NULL;          if (hlen > sizeof (struct ip) && ip_dooptions(m))
                 goto out;                  goto out;
         }  
   
         /*          /*
          * Check our list of addresses, to see if the packet is for us.           * Check our list of addresses, to see if the packet is for us.
Line 674  ip_input(struct mbuf *m)
Line 665  ip_input(struct mbuf *m)
          * or IN_IFF_NOTREADY addresses as not mine.           * or IN_IFF_NOTREADY addresses as not mine.
          */           */
         downmatch = 0;          downmatch = 0;
         s = pserialize_read_enter();  
         ia = ip_match_our_address(ifp, ip, &downmatch);          ia = ip_match_our_address(ifp, ip, &downmatch);
         if (ia != NULL) {          if (ia != NULL)
                 pserialize_read_exit(s);  
                 goto ours;                  goto ours;
         }  
   
         if (ifp->if_flags & IFF_BROADCAST) {          if (ifp->if_flags & IFF_BROADCAST) {
                 ia = ip_match_our_address_broadcast(ifp, ip);                  ia = ip_match_our_address_broadcast(ifp, ip);
                 if (ia != NULL) {                  if (ia != NULL)
                         pserialize_read_exit(s);  
                         goto ours;                          goto ours;
                 }  
         }          }
         pserialize_read_exit(s);  
   
         if (IN_MULTICAST(ip->ip_dst.s_addr)) {          if (IN_MULTICAST(ip->ip_dst.s_addr)) {
 #ifdef MROUTING  #ifdef MROUTING
Line 825  ours:
Line 810  ours:
          * Switch out to protocol's input routine.           * Switch out to protocol's input routine.
          */           */
 #if IFA_STATS  #if IFA_STATS
         if (ia && ip) {          if (ia && ip)
                 struct in_ifaddr *_ia;                  ia->ia_ifa.ifa_data.ifad_inbytes += ntohs(ip->ip_len);
                 /*  
                  * Keep a reference from ip_match_our_address with psref  
                  * is expensive, so explore ia here again.  
                  */  
                 s = pserialize_read_enter();  
                 _ia = in_get_ia(ip->ip_dst);  
                 _ia->ia_ifa.ifa_data.ifad_inbytes += ntohs(ip->ip_len);  
                 pserialize_read_exit(s);  
         }  
 #endif  #endif
         IP_STATINC(IP_STAT_DELIVERED);          IP_STATINC(IP_STAT_DELIVERED);
   
Line 859  void
Line 835  void
 ip_slowtimo(void)  ip_slowtimo(void)
 {  {
   
 #ifndef NET_MPSAFE  
         mutex_enter(softnet_lock);          mutex_enter(softnet_lock);
         KERNEL_LOCK(1, NULL);          KERNEL_LOCK(1, NULL);
 #endif  
   
         ip_reass_slowtimo();          ip_reass_slowtimo();
   
 #ifndef NET_MPSAFE  
         KERNEL_UNLOCK_ONE(NULL);          KERNEL_UNLOCK_ONE(NULL);
         mutex_exit(softnet_lock);          mutex_exit(softnet_lock);
 #endif  
 }  }
   
 /*  /*
Line 901  ip_dooptions(struct mbuf *m)
Line 873  ip_dooptions(struct mbuf *m)
         int opt, optlen, cnt, off, code, type = ICMP_PARAMPROB, forward = 0;          int opt, optlen, cnt, off, code, type = ICMP_PARAMPROB, forward = 0;
         struct in_addr dst;          struct in_addr dst;
         n_time ntime;          n_time ntime;
         struct ifaddr *ifa = NULL;  
         int s;  
   
         dst = ip->ip_dst;          dst = ip->ip_dst;
         cp = (u_char *)(ip + 1);          cp = (u_char *)(ip + 1);
Line 939  ip_dooptions(struct mbuf *m)
Line 909  ip_dooptions(struct mbuf *m)
                  * address is on directly accessible net.                   * address is on directly accessible net.
                  */                   */
                 case IPOPT_LSRR:                  case IPOPT_LSRR:
                 case IPOPT_SSRR: {                  case IPOPT_SSRR:
                         struct psref psref;  
                         struct sockaddr_in ipaddr = {  
                             .sin_len = sizeof(ipaddr),  
                             .sin_family = AF_INET,  
                         };  
   
                         if (ip_allowsrcrt == 0) {                          if (ip_allowsrcrt == 0) {
                                 type = ICMP_UNREACH;                                  type = ICMP_UNREACH;
                                 code = ICMP_UNREACH_NET_PROHIB;                                  code = ICMP_UNREACH_NET_PROHIB;
Line 960  ip_dooptions(struct mbuf *m)
Line 924  ip_dooptions(struct mbuf *m)
                                 goto bad;                                  goto bad;
                         }                          }
                         ipaddr.sin_addr = ip->ip_dst;                          ipaddr.sin_addr = ip->ip_dst;
                           ia = ifatoia(ifa_ifwithaddr(sintosa(&ipaddr)));
                         s = pserialize_read_enter();                          if (ia == 0) {
                         ifa = ifa_ifwithaddr(sintosa(&ipaddr));  
                         if (ifa == NULL) {  
                                 pserialize_read_exit(s);  
                                 if (opt == IPOPT_SSRR) {                                  if (opt == IPOPT_SSRR) {
                                         type = ICMP_UNREACH;                                          type = ICMP_UNREACH;
                                         code = ICMP_UNREACH_SRCFAIL;                                          code = ICMP_UNREACH_SRCFAIL;
Line 976  ip_dooptions(struct mbuf *m)
Line 937  ip_dooptions(struct mbuf *m)
                                  */                                   */
                                 break;                                  break;
                         }                          }
                         pserialize_read_exit(s);  
   
                         off--;                  /* 0 origin */                          off--;                  /* 0 origin */
                         if ((off + sizeof(struct in_addr)) > optlen) {                          if ((off + sizeof(struct in_addr)) > optlen) {
                                 /*                                  /*
                                  * End of source route.  Should be for us.                                   * End of source route.  Should be for us.
                                  */                                   */
                                 save_rte(m, cp, ip->ip_src);                                  save_rte(cp, ip->ip_src);
                                 break;                                  break;
                         }                          }
                         /*                          /*
Line 991  ip_dooptions(struct mbuf *m)
Line 950  ip_dooptions(struct mbuf *m)
                          */                           */
                         memcpy((void *)&ipaddr.sin_addr, (void *)(cp + off),                          memcpy((void *)&ipaddr.sin_addr, (void *)(cp + off),
                             sizeof(ipaddr.sin_addr));                              sizeof(ipaddr.sin_addr));
                         if (opt == IPOPT_SSRR) {                          if (opt == IPOPT_SSRR)
                                 ifa = ifa_ifwithladdr_psref(sintosa(&ipaddr),                                  ia = ifatoia(ifa_ifwithladdr(sintosa(&ipaddr)));
                                     &psref);                          else
                                 if (ifa != NULL)                                  ia = ip_rtaddr(ipaddr.sin_addr);
                                         ia = ifatoia(ifa);                          if (ia == 0) {
                                 else  
                                         ia = NULL;  
                         } else {  
                                 ia = ip_rtaddr(ipaddr.sin_addr, &psref);  
                         }  
                         if (ia == NULL) {  
                                 type = ICMP_UNREACH;                                  type = ICMP_UNREACH;
                                 code = ICMP_UNREACH_SRCFAIL;                                  code = ICMP_UNREACH_SRCFAIL;
                                 goto bad;                                  goto bad;
Line 1009  ip_dooptions(struct mbuf *m)
Line 962  ip_dooptions(struct mbuf *m)
                         ip->ip_dst = ipaddr.sin_addr;                          ip->ip_dst = ipaddr.sin_addr;
                         bcopy((void *)&ia->ia_addr.sin_addr,                          bcopy((void *)&ia->ia_addr.sin_addr,
                             (void *)(cp + off), sizeof(struct in_addr));                              (void *)(cp + off), sizeof(struct in_addr));
                         ia4_release(ia, &psref);  
                         cp[IPOPT_OFFSET] += sizeof(struct in_addr);                          cp[IPOPT_OFFSET] += sizeof(struct in_addr);
                         /*                          /*
                          * Let ip_intr's mcast routing check handle mcast pkts                           * Let ip_intr's mcast routing check handle mcast pkts
                          */                           */
                         forward = !IN_MULTICAST(ip->ip_dst.s_addr);                          forward = !IN_MULTICAST(ip->ip_dst.s_addr);
                         break;                          break;
                     }  
   
                 case IPOPT_RR: {  
                         struct psref psref;  
                         struct sockaddr_in ipaddr = {  
                             .sin_len = sizeof(ipaddr),  
                             .sin_family = AF_INET,  
                         };  
   
                   case IPOPT_RR:
                         if (optlen < IPOPT_OFFSET + sizeof(*cp)) {                          if (optlen < IPOPT_OFFSET + sizeof(*cp)) {
                                 code = &cp[IPOPT_OLEN] - (u_char *)ip;                                  code = &cp[IPOPT_OLEN] - (u_char *)ip;
                                 goto bad;                                  goto bad;
Line 1045  ip_dooptions(struct mbuf *m)
Line 990  ip_dooptions(struct mbuf *m)
                          * locate outgoing interface; if we're the destination,                           * locate outgoing interface; if we're the destination,
                          * use the incoming interface (should be same).                           * use the incoming interface (should be same).
                          */                           */
                         ifa = ifa_ifwithaddr_psref(sintosa(&ipaddr), &psref);                          if ((ia = ifatoia(ifa_ifwithaddr(sintosa(&ipaddr))))
                         if (ifa == NULL) {                              == NULL &&
                                 ia = ip_rtaddr(ipaddr.sin_addr, &psref);                              (ia = ip_rtaddr(ipaddr.sin_addr)) == NULL) {
                                 if (ia == NULL) {                                  type = ICMP_UNREACH;
                                         type = ICMP_UNREACH;                                  code = ICMP_UNREACH_HOST;
                                         code = ICMP_UNREACH_HOST;                                  goto bad;
                                         goto bad;  
                                 }  
                         } else {  
                                 ia = ifatoia(ifa);  
                         }                          }
                         bcopy((void *)&ia->ia_addr.sin_addr,                          bcopy((void *)&ia->ia_addr.sin_addr,
                             (void *)(cp + off), sizeof(struct in_addr));                              (void *)(cp + off), sizeof(struct in_addr));
                         ia4_release(ia, &psref);  
                         cp[IPOPT_OFFSET] += sizeof(struct in_addr);                          cp[IPOPT_OFFSET] += sizeof(struct in_addr);
                         break;                          break;
                     }  
   
                 case IPOPT_TS:                  case IPOPT_TS:
                         code = cp - (u_char *)ip;                          code = cp - (u_char *)ip;
Line 1090  ip_dooptions(struct mbuf *m)
Line 1029  ip_dooptions(struct mbuf *m)
   
                         case IPOPT_TS_TSANDADDR: {                          case IPOPT_TS_TSANDADDR: {
                                 struct ifnet *rcvif;                                  struct ifnet *rcvif;
                                 int _s, _ss;                                  int s;
                                 struct sockaddr_in ipaddr = {  
                                     .sin_len = sizeof(ipaddr),  
                                     .sin_family = AF_INET,  
                                 };  
   
                                 if (ipt->ipt_ptr - 1 + sizeof(n_time) +                                  if (ipt->ipt_ptr - 1 + sizeof(n_time) +
                                     sizeof(struct in_addr) > ipt->ipt_len) {                                      sizeof(struct in_addr) > ipt->ipt_len) {
Line 1103  ip_dooptions(struct mbuf *m)
Line 1038  ip_dooptions(struct mbuf *m)
                                         goto bad;                                          goto bad;
                                 }                                  }
                                 ipaddr.sin_addr = dst;                                  ipaddr.sin_addr = dst;
                                 _ss = pserialize_read_enter();                                  rcvif = m_get_rcvif(m, &s);
                                 rcvif = m_get_rcvif(m, &_s);                                  ia = ifatoia(ifaof_ifpforaddr(sintosa(&ipaddr),
                                 if (__predict_true(rcvif != NULL)) {                                      rcvif));
                                         ifa = ifaof_ifpforaddr(sintosa(&ipaddr),                                  m_put_rcvif(rcvif, &s);
                                             rcvif);                                  if (ia == 0)
                                 }                                          continue;
                                 m_put_rcvif(rcvif, &_s);  
                                 if (ifa == NULL) {  
                                         pserialize_read_exit(_ss);  
                                         break;  
                                 }  
                                 ia = ifatoia(ifa);  
                                 bcopy(&ia->ia_addr.sin_addr,                                  bcopy(&ia->ia_addr.sin_addr,
                                     cp0, sizeof(struct in_addr));                                      cp0, sizeof(struct in_addr));
                                 pserialize_read_exit(_ss);  
                                 ipt->ipt_ptr += sizeof(struct in_addr);                                  ipt->ipt_ptr += sizeof(struct in_addr);
                                 break;                                  break;
                         }                          }
   
                         case IPOPT_TS_PRESPEC: {                          case IPOPT_TS_PRESPEC:
                                 struct sockaddr_in ipaddr = {  
                                     .sin_len = sizeof(ipaddr),  
                                     .sin_family = AF_INET,  
                                 };  
   
                                 if (ipt->ipt_ptr - 1 + sizeof(n_time) +                                  if (ipt->ipt_ptr - 1 + sizeof(n_time) +
                                     sizeof(struct in_addr) > ipt->ipt_len) {                                      sizeof(struct in_addr) > ipt->ipt_len) {
                                         code = (u_char *)&ipt->ipt_ptr -                                          code = (u_char *)&ipt->ipt_ptr -
Line 1136  ip_dooptions(struct mbuf *m)
Line 1059  ip_dooptions(struct mbuf *m)
                                 }                                  }
                                 memcpy(&ipaddr.sin_addr, cp0,                                  memcpy(&ipaddr.sin_addr, cp0,
                                     sizeof(struct in_addr));                                      sizeof(struct in_addr));
                                 s = pserialize_read_enter();                                  if (ifatoia(ifa_ifwithaddr(sintosa(&ipaddr)))
                                 ifa = ifa_ifwithaddr(sintosa(&ipaddr));                                      == NULL)
                                 if (ifa == NULL) {  
                                         pserialize_read_exit(s);  
                                         continue;                                          continue;
                                 }  
                                 pserialize_read_exit(s);  
                                 ipt->ipt_ptr += sizeof(struct in_addr);                                  ipt->ipt_ptr += sizeof(struct in_addr);
                                 break;                                  break;
                             }  
   
                         default:                          default:
                                 /* XXX can't take &ipt->ipt_flg */                                  /* XXX can't take &ipt->ipt_flg */
Line 1162  ip_dooptions(struct mbuf *m)
Line 1080  ip_dooptions(struct mbuf *m)
         }          }
         if (forward) {          if (forward) {
                 struct ifnet *rcvif;                  struct ifnet *rcvif;
                 struct psref _psref;                  struct psref psref;
   
                 if (ip_forwsrcrt == 0) {                  if (ip_forwsrcrt == 0) {
                         type = ICMP_UNREACH;                          type = ICMP_UNREACH;
Line 1170  ip_dooptions(struct mbuf *m)
Line 1088  ip_dooptions(struct mbuf *m)
                         goto bad;                          goto bad;
                 }                  }
   
                 rcvif = m_get_rcvif_psref(m, &_psref);                  rcvif = m_get_rcvif_psref(m, &psref);
                 if (__predict_false(rcvif == NULL)) {                  if (__predict_false(rcvif == NULL)) {
                         type = ICMP_UNREACH;                          type = ICMP_UNREACH;
                         code = ICMP_UNREACH_HOST;                          code = ICMP_UNREACH_HOST;
                         goto bad;                          goto bad;
                 }                  }
                 ip_forward(m, 1, rcvif);                  ip_forward(m, 1, rcvif);
                 m_put_rcvif_psref(rcvif, &_psref);                  m_put_rcvif_psref(rcvif, &psref);
                 return true;                  return true;
         }          }
         return false;          return false;
Line 1192  bad:
Line 1110  bad:
  * return internet address info of interface to be used to get there.   * return internet address info of interface to be used to get there.
  */   */
 static struct in_ifaddr *  static struct in_ifaddr *
 ip_rtaddr(struct in_addr dst, struct psref *psref)  ip_rtaddr(struct in_addr dst)
 {  {
         struct rtentry *rt;          struct rtentry *rt;
         union {          union {
Line 1202  ip_rtaddr(struct in_addr dst, struct psr
Line 1120  ip_rtaddr(struct in_addr dst, struct psr
   
         sockaddr_in_init(&u.dst4, &dst, 0);          sockaddr_in_init(&u.dst4, &dst, 0);
   
         ro = percpu_getref(ipforward_rt_percpu);          SOFTNET_LOCK();
         rt = rtcache_lookup(ro, &u.dst);          rt = rtcache_lookup(&ipforward_rt, &u.dst);
         if (rt == NULL) {          SOFTNET_UNLOCK();
                 percpu_putref(ipforward_rt_percpu);          if (rt == NULL)
                 return NULL;                  return NULL;
         }  
   
         ia4_acquire(ifatoia(rt->rt_ifa), psref);  
         rtcache_unref(rt, ro);  
         percpu_putref(ipforward_rt_percpu);  
   
         return ifatoia(rt->rt_ifa);          return ifatoia(rt->rt_ifa);
 }  }
Line 1221  ip_rtaddr(struct in_addr dst, struct psr
Line 1134  ip_rtaddr(struct in_addr dst, struct psr
  * up later by ip_srcroute if the receiver is interested.   * up later by ip_srcroute if the receiver is interested.
  */   */
 static void  static void
 save_rte(struct mbuf *m, u_char *option, struct in_addr dst)  save_rte(u_char *option, struct in_addr dst)
 {  {
         struct ip_srcrt *isr;  
         struct m_tag *mtag;  
         unsigned olen;          unsigned olen;
   
         olen = option[IPOPT_OLEN];          olen = option[IPOPT_OLEN];
         if (olen > sizeof(isr->isr_hdr) + sizeof(isr->isr_routes))          if (olen > sizeof(ip_srcrt) - (1 + sizeof(dst)))
                 return;                  return;
           memcpy((void *)ip_srcrt.srcopt, (void *)option, olen);
         mtag = m_tag_get(PACKET_TAG_SRCROUTE, sizeof(*isr), M_NOWAIT);          ip_nhops = (olen - IPOPT_OFFSET - 1) / sizeof(struct in_addr);
         if (mtag == NULL)          ip_srcrt.dst = dst;
                 return;  
         isr = (struct ip_srcrt *)(mtag + 1);  
   
         memcpy(isr->isr_hdr, option, olen);  
         isr->isr_nhops = (olen - IPOPT_OFFSET - 1) / sizeof(struct in_addr);  
         isr->isr_dst = dst;  
         m_tag_prepend(m, mtag);  
 }  }
   
 /*  /*
Line 1248  save_rte(struct mbuf *m, u_char *option,
Line 1152  save_rte(struct mbuf *m, u_char *option,
  * The first hop is placed before the options, will be removed later.   * The first hop is placed before the options, will be removed later.
  */   */
 struct mbuf *  struct mbuf *
 ip_srcroute(struct mbuf *m0)  ip_srcroute(void)
 {  {
         struct in_addr *p, *q;          struct in_addr *p, *q;
         struct mbuf *m;          struct mbuf *m;
         struct ip_srcrt *isr;  
         struct m_tag *mtag;  
   
         mtag = m_tag_find(m0, PACKET_TAG_SRCROUTE, NULL);  
         if (mtag == NULL)  
                 return NULL;  
         isr = (struct ip_srcrt *)(mtag + 1);  
   
         if (isr->isr_nhops == 0)          if (ip_nhops == 0)
                 return NULL;                  return NULL;
   
         m = m_get(M_DONTWAIT, MT_SOOPTS);          m = m_get(M_DONTWAIT, MT_SOOPTS);
         if (m == NULL)          if (m == 0)
                 return NULL;                  return NULL;
   
         MCLAIM(m, &inetdomain.dom_mowner);          MCLAIM(m, &inetdomain.dom_mowner);
 #define OPTSIZ  (sizeof(isr->isr_nop) + sizeof(isr->isr_hdr))  #define OPTSIZ  (sizeof(ip_srcrt.nop) + sizeof(ip_srcrt.srcopt))
   
         /* length is (nhops+1)*sizeof(addr) + sizeof(nop + header) */          /* length is (nhops+1)*sizeof(addr) + sizeof(nop + srcrt header) */
         m->m_len = (isr->isr_nhops + 1) * sizeof(struct in_addr) + OPTSIZ;          m->m_len = ip_nhops * sizeof(struct in_addr) + sizeof(struct in_addr) +
               OPTSIZ;
   
         /*          /*
          * First save first hop for return route           * First save first hop for return route
          */           */
         p = &(isr->isr_routes[isr->isr_nhops - 1]);          p = &ip_srcrt.route[ip_nhops - 1];
         *(mtod(m, struct in_addr *)) = *p--;          *(mtod(m, struct in_addr *)) = *p--;
   
         /*          /*
          * Copy option fields and padding (nop) to mbuf.           * Copy option fields and padding (nop) to mbuf.
          */           */
         isr->isr_nop = IPOPT_NOP;          ip_srcrt.nop = IPOPT_NOP;
         isr->isr_hdr[IPOPT_OFFSET] = IPOPT_MINOFF;          ip_srcrt.srcopt[IPOPT_OFFSET] = IPOPT_MINOFF;
         memmove(mtod(m, char *) + sizeof(struct in_addr), &isr->isr_nop,          memmove(mtod(m, char *) + sizeof(struct in_addr), &ip_srcrt.nop,
             OPTSIZ);              OPTSIZ);
         q = (struct in_addr *)(mtod(m, char *) +          q = (struct in_addr *)(mtod(m, char *) +
             sizeof(struct in_addr) + OPTSIZ);              sizeof(struct in_addr) + OPTSIZ);
Line 1293  ip_srcroute(struct mbuf *m0)
Line 1190  ip_srcroute(struct mbuf *m0)
          * Record return path as an IP source route,           * Record return path as an IP source route,
          * reversing the path (pointers are now aligned).           * reversing the path (pointers are now aligned).
          */           */
         while (p >= isr->isr_routes) {          while (p >= ip_srcrt.route) {
                 *q++ = *p--;                  *q++ = *p--;
         }          }
         /*          /*
          * Last hop goes to final destination.           * Last hop goes to final destination.
          */           */
         *q = isr->isr_dst;          *q = ip_srcrt.dst;
         m_tag_delete(m0, mtag);          return (m);
         return m;  
 }  }
   
 const int inetctlerrmap[PRC_NCMDS] = {  const int inetctlerrmap[PRC_NCMDS] = {
Line 1379  ip_forward(struct mbuf *m, int srcrt, st
Line 1275  ip_forward(struct mbuf *m, int srcrt, st
                 return;                  return;
         }          }
   
           SOFTNET_LOCK();
   
         if (ip->ip_ttl <= IPTTLDEC) {          if (ip->ip_ttl <= IPTTLDEC) {
                 icmp_error(m, ICMP_TIMXCEED, ICMP_TIMXCEED_INTRANS, dest, 0);                  icmp_error(m, ICMP_TIMXCEED, ICMP_TIMXCEED_INTRANS, dest, 0);
                   SOFTNET_UNLOCK();
                 return;                  return;
         }          }
   
         sockaddr_in_init(&u.dst4, &ip->ip_dst, 0);          sockaddr_in_init(&u.dst4, &ip->ip_dst, 0);
   
         ro = percpu_getref(ipforward_rt_percpu);          if ((rt = rtcache_lookup(&ipforward_rt, &u.dst)) == NULL) {
         rt = rtcache_lookup(ro, &u.dst);  
         if (rt == NULL) {  
                 percpu_putref(ipforward_rt_percpu);  
                 icmp_error(m, ICMP_UNREACH, ICMP_UNREACH_NET, dest, 0);                  icmp_error(m, ICMP_UNREACH, ICMP_UNREACH_NET, dest, 0);
                   SOFTNET_UNLOCK();
                 return;                  return;
         }          }
   
Line 1432  ip_forward(struct mbuf *m, int srcrt, st
Line 1329  ip_forward(struct mbuf *m, int srcrt, st
                         code = ICMP_REDIRECT_HOST;                          code = ICMP_REDIRECT_HOST;
                 }                  }
         }          }
         rtcache_unref(rt, ro);  
   
         error = ip_output(m, NULL, &ipforward_rt,          error = ip_output(m, NULL, &ipforward_rt,
             (IP_FORWARDING | (ip_directedbcast ? IP_ALLOWBROADCAST : 0)),              (IP_FORWARDING | (ip_directedbcast ? IP_ALLOWBROADCAST : 0)),
Line 1461  ip_forward(struct mbuf *m, int srcrt, st
Line 1357  ip_forward(struct mbuf *m, int srcrt, st
                 m_freem(mcopy);                  m_freem(mcopy);
         }          }
   
         percpu_putref(ipforward_rt_percpu);          SOFTNET_UNLOCK();
         return;          return;
   
 redirect:  redirect:
 error:  error:
         if (mcopy == NULL) {          if (mcopy == NULL) {
                 percpu_putref(ipforward_rt_percpu);                  SOFTNET_UNLOCK();
                 return;                  return;
         }          }
   
Line 1490  error:
Line 1386  error:
                 type = ICMP_UNREACH;                  type = ICMP_UNREACH;
                 code = ICMP_UNREACH_NEEDFRAG;                  code = ICMP_UNREACH_NEEDFRAG;
   
                 if ((rt = rtcache_validate(ro)) != NULL) {                  if ((rt = rtcache_validate(&ipforward_rt)) != NULL)
                         destmtu = rt->rt_ifp->if_mtu;                          destmtu = rt->rt_ifp->if_mtu;
                         rtcache_unref(rt, ro);  
                 }  
 #ifdef IPSEC  #ifdef IPSEC
                 if (ipsec_used)                  if (ipsec_used)
                         (void)ipsec4_forward(mcopy, &destmtu);                          (void)ipsec4_forward(mcopy, &destmtu);
Line 1510  error:
Line 1404  error:
                  */                   */
                 if (mcopy)                  if (mcopy)
                         m_freem(mcopy);                          m_freem(mcopy);
                 percpu_putref(ipforward_rt_percpu);                  SOFTNET_UNLOCK();
                 return;                  return;
         }          }
         icmp_error(mcopy, type, code, dest, destmtu);          icmp_error(mcopy, type, code, dest, destmtu);
         percpu_putref(ipforward_rt_percpu);          SOFTNET_UNLOCK();
 }  }
   
 void  void
Line 1629  sysctl_net_inet_ip_pmtudto(SYSCTLFN_ARGS
Line 1523  sysctl_net_inet_ip_pmtudto(SYSCTLFN_ARGS
         int error, tmp;          int error, tmp;
         struct sysctlnode node;          struct sysctlnode node;
   
         icmp_mtudisc_lock();  
   
         node = *rnode;          node = *rnode;
         tmp = ip_mtudisc_timeout;          tmp = ip_mtudisc_timeout;
         node.sysctl_data = &tmp;          node.sysctl_data = &tmp;
         error = sysctl_lookup(SYSCTLFN_CALL(&node));          error = sysctl_lookup(SYSCTLFN_CALL(&node));
         if (error || newp == NULL)          if (error || newp == NULL)
                 goto out;                  return (error);
         if (tmp < 0) {          if (tmp < 0)
                 error = EINVAL;                  return (EINVAL);
                 goto out;  
         }          mutex_enter(softnet_lock);
   
         ip_mtudisc_timeout = tmp;          ip_mtudisc_timeout = tmp;
         rt_timer_queue_change(ip_mtudisc_timeout_q, ip_mtudisc_timeout);          rt_timer_queue_change(ip_mtudisc_timeout_q, ip_mtudisc_timeout);
         error = 0;  
 out:          mutex_exit(softnet_lock);
         icmp_mtudisc_unlock();  
         return error;          return (0);
 }  }
   
 static int  static int

Legend:
Removed from v.1.337.2.5  
changed lines
  Added in v.1.338

CVSweb <webmaster@jp.NetBSD.org>