[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.330 and 1.345

version 1.330, 2016/06/28 02:02:56 version 1.345, 2016/12/08 05:16:33
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 225  pfil_head_t *  inet_pfil_hook  __read_mo
Line 226  pfil_head_t *  inet_pfil_hook  __read_mo
 ipid_state_t *          ip_ids                  __read_mostly;  ipid_state_t *          ip_ids                  __read_mostly;
 percpu_t *              ipstat_percpu           __read_mostly;  percpu_t *              ipstat_percpu           __read_mostly;
   
 static struct route     ipforward_rt            __cacheline_aligned;  static percpu_t         *ipforward_rt_percpu    __cacheline_aligned;
   
 uint16_t ip_id;  uint16_t ip_id;
   
Line 289  static bool  ip_dooptions(struct mbuf *)
Line 290  static bool  ip_dooptions(struct mbuf *)
 static struct in_ifaddr *ip_rtaddr(struct in_addr);  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 **);
   
 /* XXX: Not yet enabled. */  static struct in_ifaddr *ip_match_our_address(struct ifnet *, struct ip *,
                               int *);
   static struct in_ifaddr *ip_match_our_address_broadcast(struct ifnet *,
                               struct ip *);
   
   #ifdef NET_MPSAFE
   #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 340  ip_init(void)
Line 350  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");
   }
   
   static struct in_ifaddr *
   ip_match_our_address(struct ifnet *ifp, struct ip *ip, int *downmatch)
   {
           struct in_ifaddr *ia = NULL;
           int checkif;
   
           /*
            * Enable a consistency check between the destination address
            * and the arrival interface for a unicast packet (the RFC 1122
            * strong ES model) if IP forwarding is disabled and the packet
            * is not locally generated.
            *
            * XXX - Checking also should be disabled if the destination
            * address is ipnat'ed to a different interface.
            *
            * XXX - Checking is incompatible with IP aliases added
            * to the loopback interface instead of the interface where
            * the packets are received.
            *
            * XXX - We need to add a per ifaddr flag for this so that
            * we get finer grain control.
            */
           checkif = ip_checkinterface && (ipforwarding == 0) &&
               (ifp->if_flags & IFF_LOOPBACK) == 0;
   
           IN_ADDRHASH_READER_FOREACH(ia, ip->ip_dst.s_addr) {
                   if (in_hosteq(ia->ia_addr.sin_addr, ip->ip_dst)) {
                           if (ia->ia4_flags & IN_IFF_NOTREADY)
                                   continue;
                           if (checkif && ia->ia_ifp != ifp)
                                   continue;
                           if ((ia->ia_ifp->if_flags & IFF_UP) != 0 &&
                               (ia->ia4_flags & IN_IFF_DETACHED) == 0)
                                   break;
                           else
                                   (*downmatch)++;
                   }
           }
   
           return ia;
   }
   
   static struct in_ifaddr *
   ip_match_our_address_broadcast(struct ifnet *ifp, struct ip *ip)
   {
           struct in_ifaddr *ia = NULL;
           struct ifaddr *ifa;
   
           IFADDR_READER_FOREACH(ifa, ifp) {
                   if (ifa->ifa_addr->sa_family != AF_INET)
                           continue;
                   ia = ifatoia(ifa);
                   if (ia->ia4_flags & (IN_IFF_NOTREADY | IN_IFF_DETACHED))
                           continue;
                   if (in_hosteq(ip->ip_dst, ia->ia_broadaddr.sin_addr) ||
                       in_hosteq(ip->ip_dst, ia->ia_netbroadcast) ||
                       /*
                        * Look for all-0's host part (old broadcast addr),
                        * either for subnet or net.
                        */
                       ip->ip_dst.s_addr == ia->ia_subnet ||
                       ip->ip_dst.s_addr == ia->ia_net)
                           goto matched;
                   /*
                    * An interface with IP address zero accepts
                    * all packets that arrive on that interface.
                    */
                   if (in_nullhost(ia->ia_addr.sin_addr))
                           goto matched;
           }
           ia = NULL;
   
   matched:
           return ia;
 }  }
   
 /*  /*
Line 352  ipintr(void *arg __unused)
Line 442  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 367  static void
Line 461  static void
 ip_input(struct mbuf *m)  ip_input(struct mbuf *m)
 {  {
         struct ip *ip = NULL;          struct ip *ip = NULL;
         struct in_ifaddr *ia;          struct in_ifaddr *ia = NULL;
         struct ifaddr *ifa;  
         int hlen = 0, len;          int hlen = 0, len;
         int downmatch;          int downmatch;
         int checkif;  
         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 384  ip_input(struct mbuf *m)
Line 477  ip_input(struct mbuf *m)
   
         ifp = m_get_rcvif_psref(m, &psref);          ifp = m_get_rcvif_psref(m, &psref);
         if (__predict_false(ifp == NULL))          if (__predict_false(ifp == NULL))
                 goto bad;                  goto out;
   
         /*          /*
          * If no IP addresses have been set yet but the interfaces           * If no IP addresses have been set yet but the interfaces
          * are receiving, can't do anything with incoming packets yet.           * are receiving, can't do anything with incoming packets yet.
          * Note: we pre-check without locks held.           * Note: we pre-check without locks held.
          */           */
         if (!TAILQ_FIRST(&in_ifaddrhead)) {          if (IN_ADDRLIST_READER_EMPTY())
                 goto bad;                  goto out;
         }  
         IP_STATINC(IP_STAT_TOTAL);          IP_STATINC(IP_STAT_TOTAL);
   
         /*          /*
Line 418  ip_input(struct mbuf *m)
Line 510  ip_input(struct mbuf *m)
         ip = mtod(m, struct ip *);          ip = mtod(m, struct ip *);
         if (ip->ip_v != IPVERSION) {          if (ip->ip_v != IPVERSION) {
                 IP_STATINC(IP_STAT_BADVERS);                  IP_STATINC(IP_STAT_BADVERS);
                 goto bad;                  goto out;
         }          }
         hlen = ip->ip_hl << 2;          hlen = ip->ip_hl << 2;
         if (hlen < sizeof(struct ip)) { /* minimum header length */          if (hlen < sizeof(struct ip)) { /* minimum header length */
                 IP_STATINC(IP_STAT_BADHLEN);                  IP_STATINC(IP_STAT_BADHLEN);
                 goto bad;                  goto out;
         }          }
         if (hlen > m->m_len) {          if (hlen > m->m_len) {
                 if ((m = m_pullup(m, hlen)) == NULL) {                  if ((m = m_pullup(m, hlen)) == NULL) {
Line 439  ip_input(struct mbuf *m)
Line 531  ip_input(struct mbuf *m)
          */           */
         if (IN_MULTICAST(ip->ip_src.s_addr)) {          if (IN_MULTICAST(ip->ip_src.s_addr)) {
                 IP_STATINC(IP_STAT_BADADDR);                  IP_STATINC(IP_STAT_BADADDR);
                 goto bad;                  goto out;
         }          }
   
         /* 127/8 must not appear on wire - RFC1122 */          /* 127/8 must not appear on wire - RFC1122 */
Line 447  ip_input(struct mbuf *m)
Line 539  ip_input(struct mbuf *m)
             (ntohl(ip->ip_src.s_addr) >> IN_CLASSA_NSHIFT) == IN_LOOPBACKNET) {              (ntohl(ip->ip_src.s_addr) >> IN_CLASSA_NSHIFT) == IN_LOOPBACKNET) {
                 if ((ifp->if_flags & IFF_LOOPBACK) == 0) {                  if ((ifp->if_flags & IFF_LOOPBACK) == 0) {
                         IP_STATINC(IP_STAT_BADADDR);                          IP_STATINC(IP_STAT_BADADDR);
                         goto bad;                          goto out;
                 }                  }
         }          }
   
Line 456  ip_input(struct mbuf *m)
Line 548  ip_input(struct mbuf *m)
                  M_CSUM_IPv4_BAD)) {                   M_CSUM_IPv4_BAD)) {
         case M_CSUM_IPv4|M_CSUM_IPv4_BAD:          case M_CSUM_IPv4|M_CSUM_IPv4_BAD:
                 INET_CSUM_COUNTER_INCR(&ip_hwcsum_bad);                  INET_CSUM_COUNTER_INCR(&ip_hwcsum_bad);
                 goto badcsum;                  IP_STATINC(IP_STAT_BADSUM);
                   goto out;
   
         case M_CSUM_IPv4:          case M_CSUM_IPv4:
                 /* Checksum was okay. */                  /* Checksum was okay. */
Line 471  ip_input(struct mbuf *m)
Line 564  ip_input(struct mbuf *m)
                 if (__predict_true(!(ifp->if_flags & IFF_LOOPBACK) ||                  if (__predict_true(!(ifp->if_flags & IFF_LOOPBACK) ||
                     ip_do_loopback_cksum)) {                      ip_do_loopback_cksum)) {
                         INET_CSUM_COUNTER_INCR(&ip_swcsum);                          INET_CSUM_COUNTER_INCR(&ip_swcsum);
                         if (in_cksum(m, hlen) != 0)                          if (in_cksum(m, hlen) != 0) {
                                 goto badcsum;                                  IP_STATINC(IP_STAT_BADSUM);
                                   goto out;
                           }
                 }                  }
                 break;                  break;
         }          }
Line 485  ip_input(struct mbuf *m)
Line 580  ip_input(struct mbuf *m)
          */           */
         if (len < hlen) {          if (len < hlen) {
                 IP_STATINC(IP_STAT_BADLEN);                  IP_STATINC(IP_STAT_BADLEN);
                 goto bad;                  goto out;
         }          }
   
         /*          /*
Line 496  ip_input(struct mbuf *m)
Line 591  ip_input(struct mbuf *m)
          */           */
         if (m->m_pkthdr.len < len) {          if (m->m_pkthdr.len < len) {
                 IP_STATINC(IP_STAT_TOOSHORT);                  IP_STATINC(IP_STAT_TOOSHORT);
                 goto bad;                  goto out;
         }          }
         if (m->m_pkthdr.len > len) {          if (m->m_pkthdr.len > len) {
                 if (m->m_len == m->m_pkthdr.len) {                  if (m->m_len == m->m_pkthdr.len) {
Line 528  ip_input(struct mbuf *m)
Line 623  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 561  ip_input(struct mbuf *m)
Line 655  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 574  ip_input(struct mbuf *m)
Line 669  ip_input(struct mbuf *m)
          * to be sent and the original packet to be freed).           * to be sent and the original packet to be freed).
          */           */
         ip_nhops = 0;           /* for source routed packets */          ip_nhops = 0;           /* for source routed packets */
         if (hlen > sizeof (struct ip) && ip_dooptions(m))          if (hlen > sizeof (struct ip) && ip_dooptions(m)) {
                   m = NULL;
                 goto out;                  goto out;
           }
         /*  
          * Enable a consistency check between the destination address  
          * and the arrival interface for a unicast packet (the RFC 1122  
          * strong ES model) if IP forwarding is disabled and the packet  
          * is not locally generated.  
          *  
          * XXX - Checking also should be disabled if the destination  
          * address is ipnat'ed to a different interface.  
          *  
          * XXX - Checking is incompatible with IP aliases added  
          * to the loopback interface instead of the interface where  
          * the packets are received.  
          *  
          * XXX - We need to add a per ifaddr flag for this so that  
          * we get finer grain control.  
          */  
         checkif = ip_checkinterface && (ipforwarding == 0) &&  
             (ifp->if_flags & IFF_LOOPBACK) == 0;  
   
         /*          /*
          * 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 604  ip_input(struct mbuf *m)
Line 682  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;
         LIST_FOREACH(ia, &IN_IFADDR_HASH(ip->ip_dst.s_addr), ia_hash) {          s = pserialize_read_enter();
                 if (in_hosteq(ia->ia_addr.sin_addr, ip->ip_dst)) {          ia = ip_match_our_address(ifp, ip, &downmatch);
                         if (ia->ia4_flags & IN_IFF_NOTREADY)          if (ia != NULL) {
                                 continue;                  pserialize_read_exit(s);
                         if (checkif && ia->ia_ifp != ifp)  
                                 continue;  
                         if ((ia->ia_ifp->if_flags & IFF_UP) != 0)  
                                 break;  
                         else  
                                 downmatch++;  
                 }  
         }  
         if (ia != NULL)  
                 goto ours;                  goto ours;
           }
   
         if (ifp->if_flags & IFF_BROADCAST) {          if (ifp->if_flags & IFF_BROADCAST) {
                 IFADDR_FOREACH(ifa, ifp) {                  ia = ip_match_our_address_broadcast(ifp, ip);
                         if (ifa->ifa_addr->sa_family != AF_INET)                  if (ia != NULL) {
                                 continue;                          pserialize_read_exit(s);
                         ia = ifatoia(ifa);                          goto ours;
                         if (ia->ia4_flags & IN_IFF_NOTREADY)  
                                 continue;  
                         if (in_hosteq(ip->ip_dst, ia->ia_broadaddr.sin_addr) ||  
                             in_hosteq(ip->ip_dst, ia->ia_netbroadcast) ||  
                             /*  
                              * Look for all-0's host part (old broadcast addr),  
                              * either for subnet or net.  
                              */  
                             ip->ip_dst.s_addr == ia->ia_subnet ||  
                             ip->ip_dst.s_addr == ia->ia_net)  
                                 goto ours;  
                         /*  
                          * An interface with IP address zero accepts  
                          * all packets that arrive on that interface.  
                          */  
                         if (in_nullhost(ia->ia_addr.sin_addr))  
                                 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
                 extern struct socket *ip_mrouter;                  extern struct socket *ip_mrouter;
Line 663  ip_input(struct mbuf *m)
Line 719  ip_input(struct mbuf *m)
                         if (ip_mforward(m, ifp) != 0) {                          if (ip_mforward(m, ifp) != 0) {
                                 SOFTNET_UNLOCK();                                  SOFTNET_UNLOCK();
                                 IP_STATINC(IP_STAT_CANTFORWARD);                                  IP_STATINC(IP_STAT_CANTFORWARD);
                                 goto bad;                                  goto out;
                         }                          }
                         SOFTNET_UNLOCK();                          SOFTNET_UNLOCK();
   
Line 684  ip_input(struct mbuf *m)
Line 740  ip_input(struct mbuf *m)
                  */                   */
                 if (!in_multi_group(ip->ip_dst, ifp, 0)) {                  if (!in_multi_group(ip->ip_dst, ifp, 0)) {
                         IP_STATINC(IP_STAT_CANTFORWARD);                          IP_STATINC(IP_STAT_CANTFORWARD);
                         goto bad;                          goto out;
                 }                  }
                 goto ours;                  goto ours;
         }          }
Line 719  ip_input(struct mbuf *m)
Line 775  ip_input(struct mbuf *m)
                         if (ipsec4_input(m, IP_FORWARDING |                          if (ipsec4_input(m, IP_FORWARDING |
                             (ip_directedbcast ? IP_ALLOWBROADCAST : 0)) != 0) {                              (ip_directedbcast ? IP_ALLOWBROADCAST : 0)) != 0) {
                                 SOFTNET_UNLOCK();                                  SOFTNET_UNLOCK();
                                 goto bad;                                  goto out;
                         }                          }
                         SOFTNET_UNLOCK();                          SOFTNET_UNLOCK();
                 }                  }
Line 731  ip_input(struct mbuf *m)
Line 787  ip_input(struct mbuf *m)
   
 ours:  ours:
         m_put_rcvif_psref(ifp, &psref);          m_put_rcvif_psref(ifp, &psref);
           ifp = NULL;
   
         /*          /*
          * If offset or IP_MF are set, must reassemble.           * If offset or IP_MF are set, must reassemble.
Line 741  ours:
Line 798  ours:
                  */                   */
                 if (ip_reass_packet(&m, ip) != 0) {                  if (ip_reass_packet(&m, ip) != 0) {
                         /* Failed; invalid fragment(s) or packet. */                          /* Failed; invalid fragment(s) or packet. */
                         goto bad;                          goto out;
                 }                  }
                 if (m == NULL) {                  if (m == NULL) {
                         /* More fragments should come; silently return. */                          /* More fragments should come; silently return. */
                         return;                          goto out;
                 }                  }
                 /*                  /*
                  * Reassembly is done, we have the final packet.                   * Reassembly is done, we have the final packet.
Line 766  ours:
Line 823  ours:
                 SOFTNET_LOCK();                  SOFTNET_LOCK();
                 if (ipsec4_input(m, 0) != 0) {                  if (ipsec4_input(m, 0) != 0) {
                         SOFTNET_UNLOCK();                          SOFTNET_UNLOCK();
                         goto bad;                          goto out;
                 }                  }
                 SOFTNET_UNLOCK();                  SOFTNET_UNLOCK();
         }          }
Line 776  ours:
Line 833  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) {
                 ia->ia_ifa.ifa_data.ifad_inbytes += ntohs(ip->ip_len);                  struct in_ifaddr *_ia;
                   /*
                    * 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 787  ours:
Line 853  ours:
         (*inetsw[ip_protox[nh]].pr_input)(m, off, nh);          (*inetsw[ip_protox[nh]].pr_input)(m, off, nh);
         SOFTNET_UNLOCK();          SOFTNET_UNLOCK();
         return;          return;
 bad:  
         m_put_rcvif_psref(ifp, &psref);  
         m_freem(m);  
         return;  
   
 badcsum:  
         m_put_rcvif_psref(ifp, &psref);  
         IP_STATINC(IP_STAT_BADSUM);  
         m_freem(m);  
         return;  
 out:  out:
         m_put_rcvif_psref(ifp, &psref);          m_put_rcvif_psref(ifp, &psref);
           if (m != NULL)
                   m_freem(m);
 }  }
   
 /*  /*
Line 846  ip_dooptions(struct mbuf *m)
Line 905  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;
           int s;
   
         dst = ip->ip_dst;          dst = ip->ip_dst;
         cp = (u_char *)(ip + 1);          cp = (u_char *)(ip + 1);
Line 897  ip_dooptions(struct mbuf *m)
Line 958  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)));  
                         if (ia == 0) {                          s = pserialize_read_enter();
                           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 910  ip_dooptions(struct mbuf *m)
Line 974  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) {
                                 /*                                  /*
Line 923  ip_dooptions(struct mbuf *m)
Line 989  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)                          s = pserialize_read_enter();
                                 ia = ifatoia(ifa_ifwithladdr(sintosa(&ipaddr)));                          if (opt == IPOPT_SSRR) {
                         else                                  ifa = ifa_ifwithladdr(sintosa(&ipaddr));
                                   if (ifa != NULL)
                                           ia = ifatoia(ifa);
                                   else
                                           ia = NULL;
                           } else {
                                 ia = ip_rtaddr(ipaddr.sin_addr);                                  ia = ip_rtaddr(ipaddr.sin_addr);
                         if (ia == 0) {                          }
                           if (ia == NULL) {
                                 type = ICMP_UNREACH;                                  type = ICMP_UNREACH;
                                 code = ICMP_UNREACH_SRCFAIL;                                  code = ICMP_UNREACH_SRCFAIL;
                                   pserialize_read_exit(s);
                                 goto bad;                                  goto bad;
                         }                          }
                         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));
                           pserialize_read_exit(s);
                         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
Line 963  ip_dooptions(struct mbuf *m)
Line 1037  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).
                          */                           */
                         if ((ia = ifatoia(ifa_ifwithaddr(sintosa(&ipaddr))))                          s = pserialize_read_enter();
                             == NULL &&                          ifa = ifa_ifwithaddr(sintosa(&ipaddr));
                             (ia = ip_rtaddr(ipaddr.sin_addr)) == NULL) {                          if (ifa == NULL) {
                                 type = ICMP_UNREACH;                                  ia = ip_rtaddr(ipaddr.sin_addr);
                                 code = ICMP_UNREACH_HOST;                                  if (ia == NULL) {
                                 goto bad;                                          pserialize_read_exit(s);
                                           type = ICMP_UNREACH;
                                           code = ICMP_UNREACH_HOST;
                                           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));
                           pserialize_read_exit(s);
                         cp[IPOPT_OFFSET] += sizeof(struct in_addr);                          cp[IPOPT_OFFSET] += sizeof(struct in_addr);
                         break;                          break;
   
Line 1002  ip_dooptions(struct mbuf *m)
Line 1083  ip_dooptions(struct mbuf *m)
   
                         case IPOPT_TS_TSANDADDR: {                          case IPOPT_TS_TSANDADDR: {
                                 struct ifnet *rcvif;                                  struct ifnet *rcvif;
                                 int s;                                  int _s, _ss;
   
                                 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 1011  ip_dooptions(struct mbuf *m)
Line 1092  ip_dooptions(struct mbuf *m)
                                         goto bad;                                          goto bad;
                                 }                                  }
                                 ipaddr.sin_addr = dst;                                  ipaddr.sin_addr = dst;
                                 rcvif = m_get_rcvif(m, &s);                                  _ss = pserialize_read_enter();
                                 ia = ifatoia(ifaof_ifpforaddr(sintosa(&ipaddr),                                  rcvif = m_get_rcvif(m, &_s);
                                     rcvif));                                  ifa = ifaof_ifpforaddr(sintosa(&ipaddr), rcvif);
                                 m_put_rcvif(rcvif, &s);                                  m_put_rcvif(rcvif, &_s);
                                 if (ia == 0)                                  if (ifa == NULL) {
                                         continue;                                          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;
                         }                          }
Line 1032  ip_dooptions(struct mbuf *m)
Line 1117  ip_dooptions(struct mbuf *m)
                                 }                                  }
                                 memcpy(&ipaddr.sin_addr, cp0,                                  memcpy(&ipaddr.sin_addr, cp0,
                                     sizeof(struct in_addr));                                      sizeof(struct in_addr));
                                 if (ifatoia(ifa_ifwithaddr(sintosa(&ipaddr)))                                  s = pserialize_read_enter();
                                     == NULL)                                  ifa = ifa_ifwithaddr(sintosa(&ipaddr));
                                   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;
   
Line 1053  ip_dooptions(struct mbuf *m)
Line 1142  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 1061  ip_dooptions(struct mbuf *m)
Line 1150  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 1090  ip_rtaddr(struct in_addr dst)
Line 1179  ip_rtaddr(struct in_addr dst)
                 struct sockaddr         dst;                  struct sockaddr         dst;
                 struct sockaddr_in      dst4;                  struct sockaddr_in      dst4;
         } u;          } u;
           struct route *ro;
   
         sockaddr_in_init(&u.dst4, &dst, 0);          sockaddr_in_init(&u.dst4, &dst, 0);
   
         SOFTNET_LOCK();          ro = percpu_getref(ipforward_rt_percpu);
         rt = rtcache_lookup(&ipforward_rt, &u.dst);          rt = rtcache_lookup(ro, &u.dst);
         SOFTNET_UNLOCK();          if (rt == NULL) {
         if (rt == NULL)                  percpu_putref(ipforward_rt_percpu);
                 return NULL;                  return NULL;
           }
   
           rtcache_unref(rt, ro);
           percpu_putref(ipforward_rt_percpu);
   
         return ifatoia(rt->rt_ifa);          return ifatoia(rt->rt_ifa);
 }  }
Line 1227  ip_forward(struct mbuf *m, int srcrt, st
Line 1321  ip_forward(struct mbuf *m, int srcrt, st
                 struct sockaddr_in      dst4;                  struct sockaddr_in      dst4;
         } u;          } u;
         uint64_t *ips;          uint64_t *ips;
           struct route *ro;
   
         KASSERTMSG(cpu_softintr_p(), "ip_forward: not in the software "          KASSERTMSG(cpu_softintr_p(), "ip_forward: not in the software "
             "interrupt handler; synchronization assumptions violated");              "interrupt handler; synchronization assumptions violated");
Line 1248  ip_forward(struct mbuf *m, int srcrt, st
Line 1343  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);
   
         if ((rt = rtcache_lookup(&ipforward_rt, &u.dst)) == NULL) {          ro = percpu_getref(ipforward_rt_percpu);
           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 1302  ip_forward(struct mbuf *m, int srcrt, st
Line 1396  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, ro,
             (IP_FORWARDING | (ip_directedbcast ? IP_ALLOWBROADCAST : 0)),              (IP_FORWARDING | (ip_directedbcast ? IP_ALLOWBROADCAST : 0)),
             NULL, NULL);              NULL, NULL);
   
Line 1325  ip_forward(struct mbuf *m, int srcrt, st
Line 1420  ip_forward(struct mbuf *m, int srcrt, st
         if (mcopy) {          if (mcopy) {
 #ifdef GATEWAY  #ifdef GATEWAY
                 if (mcopy->m_flags & M_CANFASTFWD)                  if (mcopy->m_flags & M_CANFASTFWD)
                         ipflow_create(&ipforward_rt, mcopy);                          ipflow_create(ro, mcopy);
 #endif  #endif
                 m_freem(mcopy);                  m_freem(mcopy);
         }          }
   
         SOFTNET_UNLOCK();          percpu_putref(ipforward_rt_percpu);
         return;          return;
   
 redirect:  redirect:
 error:  error:
         if (mcopy == NULL) {          if (mcopy == NULL) {
                 SOFTNET_UNLOCK();                  percpu_putref(ipforward_rt_percpu);
                 return;                  return;
         }          }
   
Line 1359  error:
Line 1454  error:
                 type = ICMP_UNREACH;                  type = ICMP_UNREACH;
                 code = ICMP_UNREACH_NEEDFRAG;                  code = ICMP_UNREACH_NEEDFRAG;
   
                 if ((rt = rtcache_validate(&ipforward_rt)) != NULL)                  if ((rt = rtcache_validate(ro)) != 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 1377  error:
Line 1474  error:
                  */                   */
                 if (mcopy)                  if (mcopy)
                         m_freem(mcopy);                          m_freem(mcopy);
                 SOFTNET_UNLOCK();                  percpu_putref(ipforward_rt_percpu);
                 return;                  return;
         }          }
         icmp_error(mcopy, type, code, dest, destmtu);          icmp_error(mcopy, type, code, dest, destmtu);
         SOFTNET_UNLOCK();          percpu_putref(ipforward_rt_percpu);
 }  }
   
 void  void
Line 1445  ip_savecontrol(struct inpcb *inp, struct
Line 1542  ip_savecontrol(struct inpcb *inp, struct
         if (inpflags & INP_RECVIF) {          if (inpflags & INP_RECVIF) {
                 struct sockaddr_dl sdl;                  struct sockaddr_dl sdl;
   
                 sockaddr_dl_init(&sdl, sizeof(sdl), ifp ?                  sockaddr_dl_init(&sdl, sizeof(sdl), ifp->if_index, 0, NULL, 0,
                     ifp->if_index : 0, 0, NULL, 0, NULL, 0);                      NULL, 0);
                 *mp = sbcreatecontrol(&sdl, sdl.sdl_len, IP_RECVIF, IPPROTO_IP);                  *mp = sbcreatecontrol(&sdl, sdl.sdl_len, IP_RECVIF, IPPROTO_IP);
                 if (*mp)                  if (*mp)
                         mp = &(*mp)->m_next;                          mp = &(*mp)->m_next;
Legend:
Removed from v.1.330  
changed lines
  Added in v.1.345
CVSweb <webmaster@jp.NetBSD.org>