[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.137.2.1 and 1.138

version 1.137.2.1, 2001/11/12 21:19:24 version 1.138, 2001/10/29 07:02:33
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 (TAILQ_FIRST(&in_ifaddr) == 0)          if (in_ifaddr.tqh_first == 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;
         LIST_FOREACH(ia, &IN_IFADDR_HASH(ip->ip_dst.s_addr), ia_hash) {          for (ia = IN_IFADDR_HASH(ip->ip_dst.s_addr).lh_first;
                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 584  ip_input(struct mbuf *m)
Line 586  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) {
                 TAILQ_FOREACH(ifa, &m->m_pkthdr.rcvif->if_addrlist, ifa_list) {                  for (ifa = m->m_pkthdr.rcvif->if_addrlist.tqh_first;
                         if (ifa->ifa_addr->sa_family != AF_INET)                      ifa != NULL; ifa = ifa->ifa_list.tqe_next) {
                                 continue;                          if (ifa->ifa_addr->sa_family != AF_INET) 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 699  ours:
Line 701  ours:
                  * of this datagram.                   * of this datagram.
                  */                   */
                 IPQ_LOCK();                  IPQ_LOCK();
                 LIST_FOREACH(fp, &ipq, ipq_q)                  for (fp = ipq.lh_first; fp != NULL; fp = fp->ipq_q.le_next)
                         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 855  ip_reass(ipqe, fp)
Line 857  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 = LIST_FIRST(&fp->ipq_fragq); q != NULL;          for (p = NULL, q = fp->ipq_fragq.lh_first; q != NULL;
             p = q, q = LIST_NEXT(q, ipqe_q))              p = q, q = q->ipqe_q.le_next)
                 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 891  ip_reass(ipqe, fp)
Line 893  ip_reass(ipqe, fp)
                         m_adj(q->ipqe_m, i);                          m_adj(q->ipqe_m, i);
                         break;                          break;
                 }                  }
                 nq = LIST_NEXT(q, ipqe_q);                  nq = q->ipqe_q.le_next;
                 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 908  insert:
Line 910  insert:
                 LIST_INSERT_AFTER(p, ipqe, ipqe_q);                  LIST_INSERT_AFTER(p, ipqe, ipqe_q);
         }          }
         next = 0;          next = 0;
         for (p = NULL, q = LIST_FIRST(&fp->ipq_fragq); q != NULL;          for (p = NULL, q = fp->ipq_fragq.lh_first; q != NULL;
             p = q, q = LIST_NEXT(q, ipqe_q)) {              p = q, q = q->ipqe_q.le_next) {
                 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 921  insert:
Line 923  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 = LIST_FIRST(&fp->ipq_fragq);          q = fp->ipq_fragq.lh_first;
         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 932  insert:
Line 934  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 = LIST_NEXT(q, ipqe_q);          nq = q->ipqe_q.le_next;
         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 = LIST_NEXT(q, ipqe_q);                  nq = q->ipqe_q.le_next;
                 pool_put(&ipqent_pool, q);                  pool_put(&ipqent_pool, q);
                 m_cat(m, t);                  m_cat(m, t);
         }          }
Line 983  ip_freef(fp)
Line 985  ip_freef(fp)
   
         IPQ_LOCK_CHECK();          IPQ_LOCK_CHECK();
   
         for (q = LIST_FIRST(&fp->ipq_fragq); q != NULL; q = p) {          for (q = fp->ipq_fragq.lh_first; q != NULL; q = p) {
                 p = LIST_NEXT(q, ipqe_q);                  p = q->ipqe_q.le_next;
                 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 1006  ip_slowtimo()
Line 1008  ip_slowtimo()
         int s = splsoftnet();          int s = splsoftnet();
   
         IPQ_LOCK();          IPQ_LOCK();
         for (fp = LIST_FIRST(&ipq); fp != NULL; fp = nfp) {          for (fp = ipq.lh_first; fp != NULL; fp = nfp) {
                 nfp = LIST_NEXT(fp, ipq_q);                  nfp = fp->ipq_q.le_next;
                 if (--fp->ipq_ttl == 0) {                  if (--fp->ipq_ttl == 0) {
                         ipstat.ips_fragtimeout++;                          ipstat.ips_fragtimeout++;
                         ip_freef(fp);                          ip_freef(fp);
Line 1021  ip_slowtimo()
Line 1023  ip_slowtimo()
         if (ip_maxfragpackets < 0)          if (ip_maxfragpackets < 0)
                 ;                  ;
         else {          else {
                 while (ip_nfragpackets > ip_maxfragpackets && LIST_FIRST(&ipq))                  while (ip_nfragpackets > ip_maxfragpackets && ipq.lh_first)
                         ip_freef(LIST_FIRST(&ipq));                          ip_freef(ipq.lh_first);
         }          }
         IPQ_UNLOCK();          IPQ_UNLOCK();
 #ifdef GATEWAY  #ifdef GATEWAY
Line 1045  ip_drain()
Line 1047  ip_drain()
         if (ipq_lock_try() == 0)          if (ipq_lock_try() == 0)
                 return;                  return;
   
         while (LIST_FIRST(&ipq) != NULL) {          while (ipq.lh_first != NULL) {
                 ipstat.ips_fragdropped++;                  ipstat.ips_fragdropped++;
                 ip_freef(LIST_FIRST(&ipq));                  ip_freef(ipq.lh_first);
         }          }
   
         IPQ_UNLOCK();          IPQ_UNLOCK();
Line 1434  ip_stripoptions(m, mopt)
Line 1436  ip_stripoptions(m, mopt)
         ip->ip_hl = sizeof (struct ip) >> 2;          ip->ip_hl = sizeof (struct ip) >> 2;
 }  }
   
 const int inetctlerrmap[PRC_NCMDS] = {  int inetctlerrmap[PRC_NCMDS] = {
         0,              0,              0,              0,          0,              0,              0,              0,
         0,              EMSGSIZE,       EHOSTDOWN,      EHOSTUNREACH,          0,              EMSGSIZE,       EHOSTDOWN,      EHOSTUNREACH,
         EHOSTUNREACH,   EHOSTUNREACH,   ECONNREFUSED,   ECONNREFUSED,          EHOSTUNREACH,   EHOSTUNREACH,   ECONNREFUSED,   ECONNREFUSED,
Legend:
Removed from v.1.137.2.1  
changed lines
  Added in v.1.138
CVSweb <webmaster@jp.NetBSD.org>