[BACK]Return to raw_ip.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/raw_ip.c between version 1.36 and 1.73

version 1.36, 1997/01/11 05:21:13 version 1.73, 2003/08/22 21:53:05
Line 1 
Line 1 
 /*      $NetBSD$        */  /*      $NetBSD$        */
   
 /*  /*
    * Copyright (C) 1995, 1996, 1997, and 1998 WIDE Project.
    * All rights reserved.
    *
    * Redistribution and use in source and binary forms, with or without
    * modification, are permitted provided that the following conditions
    * are met:
    * 1. Redistributions of source code must retain the above copyright
    *    notice, this list of conditions and the following disclaimer.
    * 2. Redistributions in binary form must reproduce the above copyright
    *    notice, this list of conditions and the following disclaimer in the
    *    documentation and/or other materials provided with the distribution.
    * 3. Neither the name of the project nor the names of its contributors
    *    may be used to endorse or promote products derived from this software
    *    without specific prior written permission.
    *
    * THIS SOFTWARE IS PROVIDED BY THE PROJECT AND CONTRIBUTORS ``AS IS'' AND
    * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
    * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
    * ARE DISCLAIMED.  IN NO EVENT SHALL THE PROJECT OR CONTRIBUTORS BE LIABLE
    * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
    * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
    * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
    * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
    * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
    * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
    * SUCH DAMAGE.
    */
   
   /*
  * Copyright (c) 1982, 1986, 1988, 1993   * Copyright (c) 1982, 1986, 1988, 1993
  *      The Regents of the University of California.  All rights reserved.   *      The Regents of the University of California.  All rights reserved.
  *   *
Line 12 
Line 41 
  * 2. Redistributions in binary form must reproduce the above copyright   * 2. Redistributions in binary form must reproduce the above copyright
  *    notice, this list of conditions and the following disclaimer in the   *    notice, this list of conditions and the following disclaimer in the
  *    documentation and/or other materials provided with the distribution.   *    documentation and/or other materials provided with the distribution.
  * 3. All advertising materials mentioning features or use of this software   * 3. Neither the name of the University nor the names of its contributors
  *    must display the following acknowledgement:  
  *      This product includes software developed by the University of  
  *      California, Berkeley and its contributors.  
  * 4. Neither the name of the University nor the names of its contributors  
  *    may be used to endorse or promote products derived from this software   *    may be used to endorse or promote products derived from this software
  *    without specific prior written permission.   *    without specific prior written permission.
  *   *
Line 32 
Line 57 
  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF   * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
  * SUCH DAMAGE.   * SUCH DAMAGE.
  *   *
  *      @(#)raw_ip.c    8.2 (Berkeley) 1/4/94   *      @(#)raw_ip.c    8.7 (Berkeley) 5/15/95
  */   */
   
   #include <sys/cdefs.h>
   __KERNEL_RCSID(0, "$NetBSD$");
   
   #include "opt_ipsec.h"
   #include "opt_mrouting.h"
   
 #include <sys/param.h>  #include <sys/param.h>
 #include <sys/malloc.h>  #include <sys/malloc.h>
 #include <sys/mbuf.h>  #include <sys/mbuf.h>
Line 53 
Line 84 
 #include <netinet/ip.h>  #include <netinet/ip.h>
 #include <netinet/ip_var.h>  #include <netinet/ip_var.h>
 #include <netinet/ip_mroute.h>  #include <netinet/ip_mroute.h>
   #include <netinet/ip_icmp.h>
 #include <netinet/in_pcb.h>  #include <netinet/in_pcb.h>
 #include <netinet/in_var.h>  #include <netinet/in_var.h>
   
 #include <machine/stdarg.h>  #include <machine/stdarg.h>
   
   #ifdef IPSEC
   #include <netinet6/ipsec.h>
   #endif /*IPSEC*/
   
   #ifdef FAST_IPSEC
   #include <netipsec/ipsec.h>
   #endif  /* FAST_IPSEC*/
   
 struct inpcbtable rawcbtable;  struct inpcbtable rawcbtable;
   
   int      rip_pcbnotify __P((struct inpcbtable *, struct in_addr,
       struct in_addr, int, int, void (*) __P((struct inpcb *, int))));
 int      rip_bind __P((struct inpcb *, struct mbuf *));  int      rip_bind __P((struct inpcb *, struct mbuf *));
 int      rip_connect __P((struct inpcb *, struct mbuf *));  int      rip_connect __P((struct inpcb *, struct mbuf *));
 void     rip_disconnect __P((struct inpcb *));  void     rip_disconnect __P((struct inpcb *));
Line 98  rip_input(m, va_alist)
Line 140  rip_input(m, va_alist)
         va_dcl          va_dcl
 #endif  #endif
 {  {
         register struct ip *ip = mtod(m, struct ip *);          int proto;
         register struct inpcb *inp;          struct ip *ip = mtod(m, struct ip *);
           struct inpcb *inp;
         struct inpcb *last = 0;          struct inpcb *last = 0;
         struct mbuf *opts = 0;          struct mbuf *opts = 0;
         struct sockaddr_in ripsrc;          struct sockaddr_in ripsrc;
           va_list ap;
   
           va_start(ap, m);
           (void)va_arg(ap, int);          /* ignore value, advance ap */
           proto = va_arg(ap, int);
           va_end(ap);
   
         ripsrc.sin_family = AF_INET;          ripsrc.sin_family = AF_INET;
         ripsrc.sin_len = sizeof(struct sockaddr_in);          ripsrc.sin_len = sizeof(struct sockaddr_in);
Line 110  rip_input(m, va_alist)
Line 159  rip_input(m, va_alist)
         ripsrc.sin_port = 0;          ripsrc.sin_port = 0;
         bzero((caddr_t)ripsrc.sin_zero, sizeof(ripsrc.sin_zero));          bzero((caddr_t)ripsrc.sin_zero, sizeof(ripsrc.sin_zero));
   
         for (inp = rawcbtable.inpt_queue.cqh_first;          /*
             inp != (struct inpcb *)&rawcbtable.inpt_queue;           * XXX Compatibility: programs using raw IP expect ip_len
             inp = inp->inp_queue.cqe_next) {           * XXX to have the header length subtracted, and in host order.
                 if (inp->inp_ip.ip_p && inp->inp_ip.ip_p != ip->ip_p)           * XXX ip_off is also expected to be host order.
            */
           ip->ip_len = ntohs(ip->ip_len) - (ip->ip_hl << 2);
           NTOHS(ip->ip_off);
   
           CIRCLEQ_FOREACH(inp, &rawcbtable.inpt_queue, inp_queue) {
                   if (inp->inp_ip.ip_p && inp->inp_ip.ip_p != proto)
                         continue;                          continue;
                 if (!in_nullhost(inp->inp_laddr) &&                  if (!in_nullhost(inp->inp_laddr) &&
                     !in_hosteq(inp->inp_laddr, ip->ip_dst))                      !in_hosteq(inp->inp_laddr, ip->ip_dst))
Line 123  rip_input(m, va_alist)
Line 178  rip_input(m, va_alist)
                         continue;                          continue;
                 if (last) {                  if (last) {
                         struct mbuf *n;                          struct mbuf *n;
   
   #if defined(IPSEC) || defined(FAST_IPSEC)
                           /* check AH/ESP integrity. */
                           if (ipsec4_in_reject_so(m, last->inp_socket)) {
                                   ipsecstat.in_polvio++;
                                   /* do not inject data to pcb */
                           } else
   #endif /*IPSEC*/
                         if ((n = m_copy(m, 0, (int)M_COPYALL)) != NULL) {                          if ((n = m_copy(m, 0, (int)M_COPYALL)) != NULL) {
                                 if (last->inp_flags & INP_CONTROLOPTS ||                                  if (last->inp_flags & INP_CONTROLOPTS ||
                                     last->inp_socket->so_options & SO_TIMESTAMP)                                      last->inp_socket->so_options & SO_TIMESTAMP)
Line 135  rip_input(m, va_alist)
Line 198  rip_input(m, va_alist)
                                                 m_freem(opts);                                                  m_freem(opts);
                                 } else                                  } else
                                         sorwakeup(last->inp_socket);                                          sorwakeup(last->inp_socket);
                                   opts = NULL;
                         }                          }
                 }                  }
                 last = inp;                  last = inp;
         }          }
   #if defined(IPSEC) || defined(FAST_IPSEC)
           /* check AH/ESP integrity. */
           if (last && ipsec4_in_reject_so(m, last->inp_socket)) {
                   m_freem(m);
                   ipsecstat.in_polvio++;
                   ipstat.ips_delivered--;
                   /* do not inject data to pcb */
           } else
   #endif /*IPSEC*/
         if (last) {          if (last) {
                 if (last->inp_flags & INP_CONTROLOPTS ||                  if (last->inp_flags & INP_CONTROLOPTS ||
                     last->inp_socket->so_options & SO_TIMESTAMP)                      last->inp_socket->so_options & SO_TIMESTAMP)
Line 151  rip_input(m, va_alist)
Line 224  rip_input(m, va_alist)
                 } else                  } else
                         sorwakeup(last->inp_socket);                          sorwakeup(last->inp_socket);
         } else {          } else {
                 m_freem(m);                  if (inetsw[ip_protox[ip->ip_p]].pr_input == rip_input) {
                 ipstat.ips_noproto++;                          icmp_error(m, ICMP_UNREACH, ICMP_UNREACH_PROTOCOL,
                 ipstat.ips_delivered--;                              0, 0);
                           ipstat.ips_noproto++;
                           ipstat.ips_delivered--;
                   } else
                           m_freem(m);
           }
           return;
   }
   
   int
   rip_pcbnotify(table, faddr, laddr, proto, errno, notify)
           struct inpcbtable *table;
           struct in_addr faddr, laddr;
           int proto;
           int errno;
           void (*notify) __P((struct inpcb *, int));
   {
           struct inpcb *inp, *ninp;
           int nmatch;
   
           nmatch = 0;
           for (inp = CIRCLEQ_FIRST(&table->inpt_queue);
               inp != (struct inpcb *)&table->inpt_queue;
               inp = ninp) {
                   ninp = inp->inp_queue.cqe_next;
                   if (inp->inp_ip.ip_p && inp->inp_ip.ip_p != proto)
                           continue;
                   if (in_hosteq(inp->inp_faddr, faddr) &&
                       in_hosteq(inp->inp_laddr, laddr)) {
                           (*notify)(inp, errno);
                           nmatch++;
                   }
         }          }
   
           return nmatch;
   }
   
   void *
   rip_ctlinput(cmd, sa, v)
           int cmd;
           struct sockaddr *sa;
           void *v;
   {
           struct ip *ip = v;
           void (*notify) __P((struct inpcb *, int)) = in_rtchange;
           int errno;
   
           if (sa->sa_family != AF_INET ||
               sa->sa_len != sizeof(struct sockaddr_in))
                   return NULL;
           if ((unsigned)cmd >= PRC_NCMDS)
                   return NULL;
           errno = inetctlerrmap[cmd];
           if (PRC_IS_REDIRECT(cmd))
                   notify = in_rtchange, ip = 0;
           else if (cmd == PRC_HOSTDEAD)
                   ip = 0;
           else if (errno == 0)
                   return NULL;
           if (ip) {
                   rip_pcbnotify(&rawcbtable, satosin(sa)->sin_addr,
                       ip->ip_src, ip->ip_p, errno, notify);
   
                   /* XXX mapped address case */
           } else
                   in_pcbnotifyall(&rawcbtable, satosin(sa)->sin_addr, errno,
                       notify);
           return NULL;
 }  }
   
 /*  /*
Line 170  rip_output(m, va_alist)
Line 309  rip_output(m, va_alist)
         va_dcl          va_dcl
 #endif  #endif
 {  {
         register struct inpcb *inp;          struct inpcb *inp;
         register struct ip *ip;          struct ip *ip;
         struct mbuf *opts;          struct mbuf *opts;
         int flags;          int flags;
         va_list ap;          va_list ap;
Line 181  rip_output(m, va_alist)
Line 320  rip_output(m, va_alist)
         va_end(ap);          va_end(ap);
   
         flags =          flags =
             (inp->inp_socket->so_options & SO_DONTROUTE) | IP_ALLOWBROADCAST;              (inp->inp_socket->so_options & SO_DONTROUTE) | IP_ALLOWBROADCAST
               | IP_RETURNMTU;
   
         /*          /*
          * If the user handed us a complete IP packet, use it.           * If the user handed us a complete IP packet, use it.
Line 192  rip_output(m, va_alist)
Line 332  rip_output(m, va_alist)
                         m_freem(m);                          m_freem(m);
                         return (EMSGSIZE);                          return (EMSGSIZE);
                 }                  }
                 M_PREPEND(m, sizeof(struct ip), M_WAIT);                  M_PREPEND(m, sizeof(struct ip), M_DONTWAIT);
                   if (!m)
                           return (ENOBUFS);
                 ip = mtod(m, struct ip *);                  ip = mtod(m, struct ip *);
                 ip->ip_tos = 0;                  ip->ip_tos = 0;
                 ip->ip_off = 0;                  ip->ip_off = htons(0);
                 ip->ip_p = inp->inp_ip.ip_p;                  ip->ip_p = inp->inp_ip.ip_p;
                 ip->ip_len = m->m_pkthdr.len;                  ip->ip_len = htons(m->m_pkthdr.len);
                 ip->ip_src = inp->inp_laddr;                  ip->ip_src = inp->inp_laddr;
                 ip->ip_dst = inp->inp_faddr;                  ip->ip_dst = inp->inp_faddr;
                 ip->ip_ttl = MAXTTL;                  ip->ip_ttl = MAXTTL;
Line 208  rip_output(m, va_alist)
Line 350  rip_output(m, va_alist)
                         return (EMSGSIZE);                          return (EMSGSIZE);
                 }                  }
                 ip = mtod(m, struct ip *);                  ip = mtod(m, struct ip *);
   
                   /*
                    * If the mbuf is read-only, we need to allocate
                    * a new mbuf for the header, since we need to
                    * modify the header.
                    */
                   if (M_READONLY(m)) {
                           int hlen = ip->ip_hl << 2;
   
                           m = m_copyup(m, hlen, (max_linkhdr + 3) & ~3);
                           if (m == NULL)
                                   return (ENOMEM);        /* XXX */
                           ip = mtod(m, struct ip *);
                   }
   
                   /* XXX userland passes ip_len and ip_off in host order */
                   if (m->m_pkthdr.len != ip->ip_len) {
                           m_freem(m);
                           return (EINVAL);
                   }
                   HTONS(ip->ip_len);
                   HTONS(ip->ip_off);
                 if (ip->ip_id == 0)                  if (ip->ip_id == 0)
                         ip->ip_id = htons(ip_id++);                          ip->ip_id = htons(ip_id++);
                 opts = NULL;                  opts = NULL;
Line 215  rip_output(m, va_alist)
Line 379  rip_output(m, va_alist)
                 flags |= IP_RAWOUTPUT;                  flags |= IP_RAWOUTPUT;
                 ipstat.ips_rawout++;                  ipstat.ips_rawout++;
         }          }
         return (ip_output(m, opts, &inp->inp_route, flags, inp->inp_moptions));  #ifdef IPSEC
           if (ipsec_setsocket(m, inp->inp_socket) != 0) {
                   m_freem(m);
                   return ENOBUFS;
           }
   #endif /*IPSEC*/
           return (ip_output(m, opts, &inp->inp_route, flags, inp->inp_moptions,
                inp->inp_socket, &inp->inp_errormtu));
 }  }
   
 /*  /*
Line 228  rip_ctloutput(op, so, level, optname, m)
Line 399  rip_ctloutput(op, so, level, optname, m)
         int level, optname;          int level, optname;
         struct mbuf **m;          struct mbuf **m;
 {  {
         register struct inpcb *inp = sotoinpcb(so);          struct inpcb *inp = sotoinpcb(so);
         int error = 0;          int error = 0;
   
         if (level != IPPROTO_IP) {          if (level != IPPROTO_IP) {
Line 273  rip_ctloutput(op, so, level, optname, m)
Line 444  rip_ctloutput(op, so, level, optname, m)
         case PRCO_GETOPT:          case PRCO_GETOPT:
                 switch (optname) {                  switch (optname) {
                 case IP_HDRINCL:                  case IP_HDRINCL:
                         *m = m_get(M_WAIT, M_SOOPTS);                          *m = m_get(M_WAIT, MT_SOOPTS);
                           MCLAIM((*m), so->so_mowner);
                         (*m)->m_len = sizeof (int);                          (*m)->m_len = sizeof (int);
                         *mtod(*m, int *) = inp->inp_flags & INP_HDRINCL ? 1 : 0;                          *mtod(*m, int *) = inp->inp_flags & INP_HDRINCL ? 1 : 0;
                         break;                          break;
Line 303  rip_bind(inp, nam)
Line 475  rip_bind(inp, nam)
   
         if (nam->m_len != sizeof(*addr))          if (nam->m_len != sizeof(*addr))
                 return (EINVAL);                  return (EINVAL);
         if (ifnet.tqh_first == 0)          if (TAILQ_FIRST(&ifnet) == 0)
                 return (EADDRNOTAVAIL);                  return (EADDRNOTAVAIL);
         if (addr->sin_family != AF_INET &&          if (addr->sin_family != AF_INET &&
             addr->sin_family != AF_IMPLINK)              addr->sin_family != AF_IMPLINK)
Line 324  rip_connect(inp, nam)
Line 496  rip_connect(inp, nam)
   
         if (nam->m_len != sizeof(*addr))          if (nam->m_len != sizeof(*addr))
                 return (EINVAL);                  return (EINVAL);
         if (ifnet.tqh_first == 0)          if (TAILQ_FIRST(&ifnet) == 0)
                 return (EADDRNOTAVAIL);                  return (EADDRNOTAVAIL);
         if (addr->sin_family != AF_INET &&          if (addr->sin_family != AF_INET &&
             addr->sin_family != AF_IMPLINK)              addr->sin_family != AF_IMPLINK)
Line 347  u_long rip_recvspace = RIPRCVQ;
Line 519  u_long rip_recvspace = RIPRCVQ;
 /*ARGSUSED*/  /*ARGSUSED*/
 int  int
 rip_usrreq(so, req, m, nam, control, p)  rip_usrreq(so, req, m, nam, control, p)
         register struct socket *so;          struct socket *so;
         int req;          int req;
         struct mbuf *m, *nam, *control;          struct mbuf *m, *nam, *control;
         struct proc *p;          struct proc *p;
 {  {
         register struct inpcb *inp;          struct inpcb *inp;
         int s;          int s;
         register int error = 0;          int error = 0;
 #ifdef MROUTING  #ifdef MROUTING
         extern struct socket *ip_mrouter;          extern struct socket *ip_mrouter;
 #endif  #endif
Line 363  rip_usrreq(so, req, m, nam, control, p)
Line 535  rip_usrreq(so, req, m, nam, control, p)
                 return (in_control(so, (long)m, (caddr_t)nam,                  return (in_control(so, (long)m, (caddr_t)nam,
                     (struct ifnet *)control, p));                      (struct ifnet *)control, p));
   
           if (req == PRU_PURGEIF) {
                   in_pcbpurgeif0(&rawcbtable, (struct ifnet *)control);
                   in_purgeif((struct ifnet *)control);
                   in_pcbpurgeif(&rawcbtable, (struct ifnet *)control);
                   return (0);
           }
   
         s = splsoftnet();          s = splsoftnet();
         inp = sotoinpcb(so);          inp = sotoinpcb(so);
 #ifdef DIAGNOSTIC  #ifdef DIAGNOSTIC

Legend:
Removed from v.1.36  
changed lines
  Added in v.1.73

CVSweb <webmaster@jp.NetBSD.org>