[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 and 1.337.2.1

version 1.337, 2016/07/08 06:15:33 version 1.337.2.1, 2016/08/06 00:19:10
Line 381  ip_match_our_address(struct ifnet *ifp, 
Line 381  ip_match_our_address(struct ifnet *ifp, 
                         if ((ia->ia_ifp->if_flags & IFF_UP) != 0)                          if ((ia->ia_ifp->if_flags & IFF_UP) != 0)
                                 break;                                  break;
                         else                          else
                                 downmatch++;                                  (*downmatch)++;
                 }                  }
         }          }
   
Line 447  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;          struct in_ifaddr *ia = NULL;
         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 665  ip_input(struct mbuf *m)
Line 666  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 810  ours:
Line 817  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.s_addr);
                   _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 873  ip_dooptions(struct mbuf *m)
Line 889  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 924  ip_dooptions(struct mbuf *m)
Line 942  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 937  ip_dooptions(struct mbuf *m)
Line 958  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 950  ip_dooptions(struct mbuf *m)
Line 973  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 990  ip_dooptions(struct mbuf *m)
Line 1021  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 1029  ip_dooptions(struct mbuf *m)
Line 1067  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 1038  ip_dooptions(struct mbuf *m)
Line 1076  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 1059  ip_dooptions(struct mbuf *m)
Line 1101  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 1080  ip_dooptions(struct mbuf *m)
Line 1126  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 1088  ip_dooptions(struct mbuf *m)
Line 1134  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;

Legend:
Removed from v.1.337  
changed lines
  Added in v.1.337.2.1

CVSweb <webmaster@jp.NetBSD.org>