[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.139 and 1.140

version 1.139, 2001/11/04 13:42:27 version 1.140, 2001/11/04 20:55:27
Line 410  ip_input(struct mbuf *m)
Line 410  ip_input(struct mbuf *m)
          * 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.
          */           */
         if (in_ifaddr.tqh_first == 0)          if (TAILQ_FIRST(&in_ifaddr) == 0)
                 goto bad;                  goto bad;
         ipstat.ips_total++;          ipstat.ips_total++;
         if (m->m_len < sizeof (struct ip) &&          if (m->m_len < sizeof (struct ip) &&
Line 573  ip_input(struct mbuf *m)
Line 573  ip_input(struct mbuf *m)
          * as not mine.           * as not mine.
          */           */
         downmatch = 0;          downmatch = 0;
         for (ia = IN_IFADDR_HASH(ip->ip_dst.s_addr).lh_first;          LIST_FOREACH(ia, &IN_IFADDR_HASH(ip->ip_dst.s_addr), ia_hash) {
              ia != NULL;  
              ia = ia->ia_hash.le_next) {  
                 if (in_hosteq(ia->ia_addr.sin_addr, ip->ip_dst)) {                  if (in_hosteq(ia->ia_addr.sin_addr, ip->ip_dst)) {
                         if ((ia->ia_ifp->if_flags & IFF_UP) != 0)                          if ((ia->ia_ifp->if_flags & IFF_UP) != 0)
                                 break;                                  break;
Line 586  ip_input(struct mbuf *m)
Line 584  ip_input(struct mbuf *m)
         if (ia != NULL)          if (ia != NULL)
                 goto ours;                  goto ours;
         if (m->m_pkthdr.rcvif->if_flags & IFF_BROADCAST) {          if (m->m_pkthdr.rcvif->if_flags & IFF_BROADCAST) {
                 for (ifa = m->m_pkthdr.rcvif->if_addrlist.tqh_first;                  TAILQ_FOREACH(ifa, &m->m_pkthdr.rcvif->if_addrlist, ifa_list) {
                     ifa != NULL; ifa = ifa->ifa_list.tqe_next) {                          if (ifa->ifa_addr->sa_family != AF_INET)
                         if (ifa->ifa_addr->sa_family != AF_INET) continue;                                  continue;
                         ia = ifatoia(ifa);                          ia = ifatoia(ifa);
                         if (in_hosteq(ip->ip_dst, ia->ia_broadaddr.sin_addr) ||                          if (in_hosteq(ip->ip_dst, ia->ia_broadaddr.sin_addr) ||
                             in_hosteq(ip->ip_dst, ia->ia_netbroadcast) ||                              in_hosteq(ip->ip_dst, ia->ia_netbroadcast) ||
Line 701  ours:
Line 699  ours:
                  * of this datagram.                   * of this datagram.
                  */                   */
                 IPQ_LOCK();                  IPQ_LOCK();
                 for (fp = ipq.lh_first; fp != NULL; fp = fp->ipq_q.le_next)                  LIST_FOREACH(fp, &ipq, ipq_q)
                         if (ip->ip_id == fp->ipq_id &&                          if (ip->ip_id == fp->ipq_id &&
                             in_hosteq(ip->ip_src, fp->ipq_src) &&                              in_hosteq(ip->ip_src, fp->ipq_src) &&
                             in_hosteq(ip->ip_dst, fp->ipq_dst) &&                              in_hosteq(ip->ip_dst, fp->ipq_dst) &&
Line 857  ip_reass(ipqe, fp)
Line 855  ip_reass(ipqe, fp)
         /*          /*
          * Find a segment which begins after this one does.           * Find a segment which begins after this one does.
          */           */
         for (p = NULL, q = fp->ipq_fragq.lh_first; q != NULL;          for (p = NULL, q = LIST_FIRST(&fp->ipq_fragq); q != NULL;
             p = q, q = q->ipqe_q.le_next)              p = q, q = LIST_NEXT(q, ipqe_q))
                 if (q->ipqe_ip->ip_off > ipqe->ipqe_ip->ip_off)                  if (q->ipqe_ip->ip_off > ipqe->ipqe_ip->ip_off)
                         break;                          break;
   
Line 893  ip_reass(ipqe, fp)
Line 891  ip_reass(ipqe, fp)
                         m_adj(q->ipqe_m, i);                          m_adj(q->ipqe_m, i);
                         break;                          break;
                 }                  }
                 nq = q->ipqe_q.le_next;                  nq = LIST_NEXT(q, ipqe_q);
                 m_freem(q->ipqe_m);                  m_freem(q->ipqe_m);
                 LIST_REMOVE(q, ipqe_q);                  LIST_REMOVE(q, ipqe_q);
                 pool_put(&ipqent_pool, q);                  pool_put(&ipqent_pool, q);
Line 910  insert:
Line 908  insert:
                 LIST_INSERT_AFTER(p, ipqe, ipqe_q);                  LIST_INSERT_AFTER(p, ipqe, ipqe_q);
         }          }
         next = 0;          next = 0;
         for (p = NULL, q = fp->ipq_fragq.lh_first; q != NULL;          for (p = NULL, q = LIST_FIRST(&fp->ipq_fragq); q != NULL;
             p = q, q = q->ipqe_q.le_next) {              p = q, q = LIST_NEXT(q, ipqe_q)) {
                 if (q->ipqe_ip->ip_off != next)                  if (q->ipqe_ip->ip_off != next)
                         return (0);                          return (0);
                 next += q->ipqe_ip->ip_len;                  next += q->ipqe_ip->ip_len;
Line 923  insert:
Line 921  insert:
          * Reassembly is complete.  Check for a bogus message size and           * Reassembly is complete.  Check for a bogus message size and
          * concatenate fragments.           * concatenate fragments.
          */           */
         q = fp->ipq_fragq.lh_first;          q = LIST_FIRST(&fp->ipq_fragq);
         ip = q->ipqe_ip;          ip = q->ipqe_ip;
         if ((next + (ip->ip_hl << 2)) > IP_MAXPACKET) {          if ((next + (ip->ip_hl << 2)) > IP_MAXPACKET) {
                 ipstat.ips_toolong++;                  ipstat.ips_toolong++;
Line 934  insert:
Line 932  insert:
         t = m->m_next;          t = m->m_next;
         m->m_next = 0;          m->m_next = 0;
         m_cat(m, t);          m_cat(m, t);
         nq = q->ipqe_q.le_next;          nq = LIST_NEXT(q, ipqe_q);
         pool_put(&ipqent_pool, q);          pool_put(&ipqent_pool, q);
         for (q = nq; q != NULL; q = nq) {          for (q = nq; q != NULL; q = nq) {
                 t = q->ipqe_m;                  t = q->ipqe_m;
                 nq = q->ipqe_q.le_next;                  nq = LIST_NEXT(q, ipqe_q);
                 pool_put(&ipqent_pool, q);                  pool_put(&ipqent_pool, q);
                 m_cat(m, t);                  m_cat(m, t);
         }          }
Line 985  ip_freef(fp)
Line 983  ip_freef(fp)
   
         IPQ_LOCK_CHECK();          IPQ_LOCK_CHECK();
   
         for (q = fp->ipq_fragq.lh_first; q != NULL; q = p) {          for (q = LIST_FIRST(&fp->ipq_fragq); q != NULL; q = p) {
                 p = q->ipqe_q.le_next;                  p = LIST_NEXT(q, ipqe_q);
                 m_freem(q->ipqe_m);                  m_freem(q->ipqe_m);
                 LIST_REMOVE(q, ipqe_q);                  LIST_REMOVE(q, ipqe_q);
                 pool_put(&ipqent_pool, q);                  pool_put(&ipqent_pool, q);
Line 1008  ip_slowtimo()
Line 1006  ip_slowtimo()
         int s = splsoftnet();          int s = splsoftnet();
   
         IPQ_LOCK();          IPQ_LOCK();
         for (fp = ipq.lh_first; fp != NULL; fp = nfp) {          for (fp = LIST_FIRST(&ipq); fp != NULL; fp = nfp) {
                 nfp = fp->ipq_q.le_next;                  nfp = LIST_NEXT(fp, ipq_q);
                 if (--fp->ipq_ttl == 0) {                  if (--fp->ipq_ttl == 0) {
                         ipstat.ips_fragtimeout++;                          ipstat.ips_fragtimeout++;
                         ip_freef(fp);                          ip_freef(fp);
Line 1023  ip_slowtimo()
Line 1021  ip_slowtimo()
         if (ip_maxfragpackets < 0)          if (ip_maxfragpackets < 0)
                 ;                  ;
         else {          else {
                 while (ip_nfragpackets > ip_maxfragpackets && ipq.lh_first)                  while (ip_nfragpackets > ip_maxfragpackets && LIST_FIRST(&ipq))
                         ip_freef(ipq.lh_first);                          ip_freef(LIST_FIRST(&ipq));
         }          }
         IPQ_UNLOCK();          IPQ_UNLOCK();
 #ifdef GATEWAY  #ifdef GATEWAY
Line 1047  ip_drain()
Line 1045  ip_drain()
         if (ipq_lock_try() == 0)          if (ipq_lock_try() == 0)
                 return;                  return;
   
         while (ipq.lh_first != NULL) {          while (LIST_FIRST(&ipq) != NULL) {
                 ipstat.ips_fragdropped++;                  ipstat.ips_fragdropped++;
                 ip_freef(ipq.lh_first);                  ip_freef(LIST_FIRST(&ipq));
         }          }
   
         IPQ_UNLOCK();          IPQ_UNLOCK();

Legend:
Removed from v.1.139  
changed lines
  Added in v.1.140

CVSweb <webmaster@jp.NetBSD.org>