[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.300 and 1.307.2.3

version 1.300, 2012/06/02 21:36:47 version 1.307.2.3, 2014/05/18 17:46:13
Line 96  __KERNEL_RCSID(0, "$NetBSD$");
Line 96  __KERNEL_RCSID(0, "$NetBSD$");
 #include "opt_inet.h"  #include "opt_inet.h"
 #include "opt_compat_netbsd.h"  #include "opt_compat_netbsd.h"
 #include "opt_gateway.h"  #include "opt_gateway.h"
 #include "opt_pfil_hooks.h"  
 #include "opt_ipsec.h"  #include "opt_ipsec.h"
 #include "opt_mrouting.h"  #include "opt_mrouting.h"
 #include "opt_mbuftrace.h"  #include "opt_mbuftrace.h"
Line 139  __KERNEL_RCSID(0, "$NetBSD$");
Line 138  __KERNEL_RCSID(0, "$NetBSD$");
 #ifdef MROUTING  #ifdef MROUTING
 #include <netinet/ip_mroute.h>  #include <netinet/ip_mroute.h>
 #endif  #endif
   #include <netinet/portalgo.h>
   
 #ifdef FAST_IPSEC  #ifdef IPSEC
 #include <netipsec/ipsec.h>  #include <netipsec/ipsec.h>
 #include <netipsec/key.h>  #endif
 #endif  /* FAST_IPSEC*/  
   
 #ifndef IPFORWARDING  #ifndef IPFORWARDING
 #ifdef GATEWAY  #ifdef GATEWAY
Line 213  int ip_do_randomid = 0;
Line 212  int ip_do_randomid = 0;
  */   */
 int     ip_checkinterface = 0;  int     ip_checkinterface = 0;
   
   
 struct rttimer_queue *ip_mtudisc_timeout_q = NULL;  struct rttimer_queue *ip_mtudisc_timeout_q = NULL;
   
 u_long  in_ifaddrhash;                          /* size of hash table - 1 */  
 int     in_ifaddrentries;                       /* total number of addrs */  
 struct in_ifaddrhead in_ifaddrhead;  
 struct  in_ifaddrhashhead *in_ifaddrhashtbl;  
 u_long  in_multihash;                           /* size of hash table - 1 */  
 int     in_multientries;                        /* total number of addrs */  
 struct  in_multihashhead *in_multihashtbl;  
 struct  ifqueue ipintrq;  struct  ifqueue ipintrq;
   
 ipid_state_t *          ip_ids;  ipid_state_t *          ip_ids;
Line 230  uint16_t ip_id;
Line 221  uint16_t ip_id;
   
 percpu_t *ipstat_percpu;  percpu_t *ipstat_percpu;
   
 #ifdef PFIL_HOOKS  pfil_head_t *inet_pfil_hook;
 struct pfil_head inet_pfil_hook;  
 #endif  
   
 struct pool inmulti_pool;  
   
 #ifdef INET_CSUM_COUNTERS  #ifdef INET_CSUM_COUNTERS
 #include <sys/device.h>  #include <sys/device.h>
Line 265  EVCNT_ATTACH_STATIC(ip_swcsum);
Line 252  EVCNT_ATTACH_STATIC(ip_swcsum);
  * maintenance when the remote end is on a network that is not known   * maintenance when the remote end is on a network that is not known
  * to us.   * to us.
  */   */
 int     ip_nhops = 0;  
   static int      ip_nhops = 0;
   
 static  struct ip_srcrt {  static  struct ip_srcrt {
         struct  in_addr dst;                    /* final destination */          struct  in_addr dst;                    /* final destination */
         char    nop;                            /* one NOP to align */          char    nop;                            /* one NOP to align */
Line 282  struct mowner ip_rx_mowner = MOWNER_INIT
Line 271  struct mowner ip_rx_mowner = MOWNER_INIT
 struct mowner ip_tx_mowner = MOWNER_INIT("internet", "tx");  struct mowner ip_tx_mowner = MOWNER_INIT("internet", "tx");
 #endif  #endif
   
 static void sysctl_net_inet_ip_setup(struct sysctllog **);  static bool             ip_dooptions(struct mbuf *);
   static struct in_ifaddr *ip_rtaddr(struct in_addr);
   static void             sysctl_net_inet_ip_setup(struct sysctllog **);
   
 /*  /*
  * IP initialization: fill in IP protocol switch table.   * IP initialization: fill in IP protocol switch table.
Line 292  void
Line 283  void
 ip_init(void)  ip_init(void)
 {  {
         const struct protosw *pr;          const struct protosw *pr;
         int i;  
   
           in_init();
         sysctl_net_inet_ip_setup(NULL);          sysctl_net_inet_ip_setup(NULL);
   
         pool_init(&inmulti_pool, sizeof(struct in_multi), 0, 0, 0, "inmltpl",  
             NULL, IPL_SOFTNET);  
   
         pr = pffindproto(PF_INET, IPPROTO_RAW, SOCK_RAW);          pr = pffindproto(PF_INET, IPPROTO_RAW, SOCK_RAW);
         if (pr == 0)          KASSERT(pr != NULL);
                 panic("ip_init");  
         for (i = 0; i < IPPROTO_MAX; i++)          for (u_int i = 0; i < IPPROTO_MAX; i++) {
                 ip_protox[i] = pr - inetsw;                  ip_protox[i] = pr - inetsw;
           }
         for (pr = inetdomain.dom_protosw;          for (pr = inetdomain.dom_protosw;
             pr < inetdomain.dom_protoswNPROTOSW; pr++)              pr < inetdomain.dom_protoswNPROTOSW; pr++)
                 if (pr->pr_domain->dom_family == PF_INET &&                  if (pr->pr_domain->dom_family == PF_INET &&
Line 317  ip_init(void)
Line 306  ip_init(void)
   
         ipintrq.ifq_maxlen = IFQ_MAXLEN;          ipintrq.ifq_maxlen = IFQ_MAXLEN;
   
         TAILQ_INIT(&in_ifaddrhead);  
         in_ifaddrhashtbl = hashinit(IN_IFADDR_HASH_SIZE, HASH_LIST, true,  
             &in_ifaddrhash);  
         in_multihashtbl = hashinit(IN_IFADDR_HASH_SIZE, HASH_LIST, true,  
             &in_multihash);  
         ip_mtudisc_timeout_q = rt_timer_queue_create(ip_mtudisc_timeout);          ip_mtudisc_timeout_q = rt_timer_queue_create(ip_mtudisc_timeout);
 #ifdef GATEWAY  #ifdef GATEWAY
         ipflow_init(ip_hashsize);          ipflow_init();
 #endif  #endif
   
 #ifdef PFIL_HOOKS  
         /* Register our Packet Filter hook. */          /* Register our Packet Filter hook. */
         inet_pfil_hook.ph_type = PFIL_TYPE_AF;          inet_pfil_hook = pfil_head_create(PFIL_TYPE_AF, (void *)AF_INET);
         inet_pfil_hook.ph_af   = AF_INET;          KASSERT(inet_pfil_hook != NULL);
         i = pfil_head_register(&inet_pfil_hook);  
         if (i != 0)  
                 printf("ip_init: WARNING: unable to register pfil hook, "  
                     "error %d\n", i);  
 #endif /* PFIL_HOOKS */  
   
 #ifdef MBUFTRACE  #ifdef MBUFTRACE
         MOWNER_ATTACH(&ip_tx_mowner);          MOWNER_ATTACH(&ip_tx_mowner);
Line 349  struct sockaddr_in ipaddr = {
Line 327  struct sockaddr_in ipaddr = {
         .sin_len = sizeof(ipaddr),          .sin_len = sizeof(ipaddr),
         .sin_family = AF_INET,          .sin_family = AF_INET,
 };  };
 struct  route ipforward_rt;  
   static struct route     ipforward_rt;
   
 /*  /*
  * IP software interrupt routine   * IP software interrupt routine
Line 404  ip_input(struct mbuf *m)
Line 383  ip_input(struct mbuf *m)
         int downmatch;          int downmatch;
         int checkif;          int checkif;
         int srcrt = 0;          int srcrt = 0;
 #ifdef FAST_IPSEC  
         struct m_tag *mtag;  
         struct tdb_ident *tdbi;  
         struct secpolicy *sp;  
         int error, s;  
 #endif /* FAST_IPSEC */  
   
         MCLAIM(m, &ip_rx_mowner);          MCLAIM(m, &ip_rx_mowner);
         KASSERT((m->m_flags & M_PKTHDR) != 0);          KASSERT((m->m_flags & M_PKTHDR) != 0);
Line 537  ip_input(struct mbuf *m)
Line 510  ip_input(struct mbuf *m)
          */           */
         m->m_flags |= M_CANFASTFWD;          m->m_flags |= M_CANFASTFWD;
   
 #ifdef PFIL_HOOKS  
         /*          /*
          * Run through list of hooks for input packets.  If there are any           * Run through list of hooks for input packets.  If there are any
          * filters which require that additional packets in the flow are           * filters which require that additional packets in the flow are
Line 549  ip_input(struct mbuf *m)
Line 521  ip_input(struct mbuf *m)
          * let ipfilter look at packet on the wire,           * let ipfilter look at packet on the wire,
          * not the decapsulated packet.           * not the decapsulated packet.
          */           */
 #if defined(FAST_IPSEC)  #if defined(IPSEC)
         if (!ipsec_indone(m))          if (!ipsec_indone(m))
 #else  #else
         if (1)          if (1)
Line 558  ip_input(struct mbuf *m)
Line 530  ip_input(struct mbuf *m)
                 struct in_addr odst;                  struct in_addr odst;
   
                 odst = ip->ip_dst;                  odst = ip->ip_dst;
                 if (pfil_run_hooks(&inet_pfil_hook, &m, m->m_pkthdr.rcvif,                  if (pfil_run_hooks(inet_pfil_hook, &m, m->m_pkthdr.rcvif,
                     PFIL_IN) != 0)                      PFIL_IN) != 0)
                         return;                          return;
                 if (m == NULL)                  if (m == NULL)
Line 581  ip_input(struct mbuf *m)
Line 553  ip_input(struct mbuf *m)
                  */                   */
                 srcrt = (odst.s_addr != ip->ip_dst.s_addr);                  srcrt = (odst.s_addr != ip->ip_dst.s_addr);
         }          }
 #endif /* PFIL_HOOKS */  
   
 #ifdef ALTQ  #ifdef ALTQ
         /* XXX Temporary until ALTQ is changed to use a pfil hook */          /* XXX Temporary until ALTQ is changed to use a pfil hook */
Line 731  ip_input(struct mbuf *m)
Line 702  ip_input(struct mbuf *m)
                         IP_STATINC(IP_STAT_CANTFORWARD);                          IP_STATINC(IP_STAT_CANTFORWARD);
                         return;                          return;
                 }                  }
 #ifdef FAST_IPSEC  #ifdef IPSEC
                 mtag = m_tag_find(m, PACKET_TAG_IPSEC_IN_DONE, NULL);                  /* Perform IPsec, if any. */
                 s = splsoftnet();                  if (ipsec4_input(m, IP_FORWARDING | (ip_directedbcast ?
                 if (mtag != NULL) {                      IP_ALLOWBROADCAST : 0)) != 0) {
                         tdbi = (struct tdb_ident *)(mtag + 1);  
                         sp = ipsec_getpolicy(tdbi, IPSEC_DIR_INBOUND);  
                 } else {  
                         sp = ipsec_getpolicybyaddr(m, IPSEC_DIR_INBOUND,  
                                                    IP_FORWARDING, &error);  
                 }  
                 if (sp == NULL) {       /* NB: can happen if error */  
                         splx(s);  
                         /*XXX error stat???*/  
                         DPRINTF(("ip_input: no SP for forwarding\n"));  /*XXX*/  
                         goto bad;                          goto bad;
                 }                  }
   #endif
                 /*  
                  * Check security policy against packet attributes.  
                  */  
                 error = ipsec_in_reject(sp, m);  
                 KEY_FREESP(&sp);  
                 splx(s);  
                 if (error) {  
                         IP_STATINC(IP_STAT_CANTFORWARD);  
                         goto bad;  
                 }  
   
                 /*  
                  * Peek at the outbound SP for this packet to determine if  
                  * it's a Fast Forward candidate.  
                  */  
                 mtag = m_tag_find(m, PACKET_TAG_IPSEC_PENDING_TDB, NULL);  
                 if (mtag != NULL)  
                         m->m_flags &= ~M_CANFASTFWD;  
                 else {  
                         s = splsoftnet();  
                         sp = ipsec4_checkpolicy(m, IPSEC_DIR_OUTBOUND,  
                             (IP_FORWARDING |  
                              (ip_directedbcast ? IP_ALLOWBROADCAST : 0)),  
                             &error, NULL);  
                         if (sp != NULL) {  
                                 m->m_flags &= ~M_CANFASTFWD;  
                                 KEY_FREESP(&sp);  
                         }  
                         splx(s);  
                 }  
 #endif  /* FAST_IPSEC */  
   
                 ip_forward(m, srcrt);                  ip_forward(m, srcrt);
         }          }
         return;          return;
Line 808  ours:
Line 737  ours:
                 hlen = ip->ip_hl << 2;                  hlen = ip->ip_hl << 2;
         }          }
   
 #ifdef FAST_IPSEC  #ifdef IPSEC
         /*          /*
          * enforce IPsec policy checking if we are seeing last header.           * Enforce IPsec policy checking if we are seeing last header.
          * note that we do not visit this with protocols with pcb layer           * Note that we do not visit this with protocols with PCB layer
          * code - like udp/tcp/raw ip.           * code - like UDP/TCP/raw IP.
          */           */
         if ((inetsw[ip_protox[ip->ip_p]].pr_flags & PR_LASTHDR) != 0) {          if ((inetsw[ip_protox[ip->ip_p]].pr_flags & PR_LASTHDR) != 0) {
                 /*                  if (ipsec4_input(m, 0) != 0) {
                  * Check if the packet has already had IPsec processing  
                  * done.  If so, then just pass it along.  This tag gets  
                  * set during AH, ESP, etc. input handling, before the  
                  * packet is returned to the ip input queue for delivery.  
                  */  
                 mtag = m_tag_find(m, PACKET_TAG_IPSEC_IN_DONE, NULL);  
                 s = splsoftnet();  
                 if (mtag != NULL) {  
                         tdbi = (struct tdb_ident *)(mtag + 1);  
                         sp = ipsec_getpolicy(tdbi, IPSEC_DIR_INBOUND);  
                 } else {  
                         sp = ipsec_getpolicybyaddr(m, IPSEC_DIR_INBOUND,  
                                                    IP_FORWARDING, &error);  
                 }  
                 if (sp != NULL) {  
                         /*  
                          * Check security policy against packet attributes.  
                          */  
                         error = ipsec_in_reject(sp, m);  
                         KEY_FREESP(&sp);  
                 } else {  
                         /* XXX error stat??? */  
                         error = EINVAL;  
 DPRINTF(("ip_input: no SP, packet discarded\n"));/*XXX*/  
                 }  
                 splx(s);  
                 if (error)  
                         goto bad;                          goto bad;
                   }
         }          }
 #endif /* FAST_IPSEC */  #endif
   
         /*          /*
          * Switch out to protocol's input routine.           * Switch out to protocol's input routine.
Line 899  ip_drain(void)
Line 802  ip_drain(void)
 }  }
   
 /*  /*
  * Do option processing on a datagram,   * ip_dooptions: perform option processing on a datagram, possibly discarding
  * possibly discarding it if bad options are encountered,   * it if bad options are encountered, or forwarding it if source-routed.
  * or forwarding it if source-routed.   *
  * Returns 1 if packet has been forwarded/freed,   * => Returns true if packet has been forwarded/freed.
  * 0 if the packet should be processed further.   * => Returns false if the packet should be processed further.
  */   */
 int  static bool
 ip_dooptions(struct mbuf *m)  ip_dooptions(struct mbuf *m)
 {  {
         struct ip *ip = mtod(m, struct ip *);          struct ip *ip = mtod(m, struct ip *);
Line 1121  ip_dooptions(struct mbuf *m)
Line 1024  ip_dooptions(struct mbuf *m)
                         goto bad;                          goto bad;
                 }                  }
                 ip_forward(m, 1);                  ip_forward(m, 1);
                 return (1);                  return true;
         }          }
         return (0);          return false;
 bad:  bad:
         icmp_error(m, type, code, 0, 0);          icmp_error(m, type, code, 0, 0);
         IP_STATINC(IP_STAT_BADOPTIONS);          IP_STATINC(IP_STAT_BADOPTIONS);
         return (1);          return true;
 }  }
   
 /*  /*
  * Given address of next destination (final or next hop),   * ip_rtaddr: given address of next destination (final or next hop),
  * return internet address info of interface to be used to get there.   * return internet address info of interface to be used to get there.
  */   */
 struct in_ifaddr *  static struct in_ifaddr *
 ip_rtaddr(struct in_addr dst)  ip_rtaddr(struct in_addr dst)
 {  {
         struct rtentry *rt;          struct rtentry *rt;
Line 1152  ip_rtaddr(struct in_addr dst)
Line 1055  ip_rtaddr(struct in_addr dst)
 }  }
   
 /*  /*
  * Save incoming source route for use in replies,   * save_rte: save incoming source route for use in replies, to be picked
  * to be picked up later by ip_srcroute if the receiver is interested.   * up later by ip_srcroute if the receiver is interested.
  */   */
 void  static void
 save_rte(u_char *option, struct in_addr dst)  save_rte(u_char *option, struct in_addr dst)
 {  {
         unsigned olen;          unsigned olen;
   
         olen = option[IPOPT_OLEN];          olen = option[IPOPT_OLEN];
 #ifdef DIAGNOSTIC  
         if (ipprintfs)  
                 printf("save_rte: olen %d\n", olen);  
 #endif /* 0 */  
         if (olen > sizeof(ip_srcrt) - (1 + sizeof(dst)))          if (olen > sizeof(ip_srcrt) - (1 + sizeof(dst)))
                 return;                  return;
         memcpy((void *)ip_srcrt.srcopt, (void *)option, olen);          memcpy((void *)ip_srcrt.srcopt, (void *)option, olen);
Line 1195  ip_srcroute(void)
Line 1094  ip_srcroute(void)
         /* length is (nhops+1)*sizeof(addr) + sizeof(nop + srcrt header) */          /* length is (nhops+1)*sizeof(addr) + sizeof(nop + srcrt header) */
         m->m_len = ip_nhops * sizeof(struct in_addr) + sizeof(struct in_addr) +          m->m_len = ip_nhops * sizeof(struct in_addr) + sizeof(struct in_addr) +
             OPTSIZ;              OPTSIZ;
 #ifdef DIAGNOSTIC  
         if (ipprintfs)  
                 printf("ip_srcroute: nhops %d mlen %d", ip_nhops, m->m_len);  
 #endif  
   
         /*          /*
          * First save first hop for return route           * First save first hop for return route
          */           */
         p = &ip_srcrt.route[ip_nhops - 1];          p = &ip_srcrt.route[ip_nhops - 1];
         *(mtod(m, struct in_addr *)) = *p--;          *(mtod(m, struct in_addr *)) = *p--;
 #ifdef DIAGNOSTIC  
         if (ipprintfs)  
                 printf(" hops %x", ntohl(mtod(m, struct in_addr *)->s_addr));  
 #endif  
   
         /*          /*
          * Copy option fields and padding (nop) to mbuf.           * Copy option fields and padding (nop) to mbuf.
Line 1225  ip_srcroute(void)
Line 1116  ip_srcroute(void)
          * reversing the path (pointers are now aligned).           * reversing the path (pointers are now aligned).
          */           */
         while (p >= ip_srcrt.route) {          while (p >= ip_srcrt.route) {
 #ifdef DIAGNOSTIC  
                 if (ipprintfs)  
                         printf(" %x", ntohl(q->s_addr));  
 #endif  
                 *q++ = *p--;                  *q++ = *p--;
         }          }
         /*          /*
          * Last hop goes to final destination.           * Last hop goes to final destination.
          */           */
         *q = ip_srcrt.dst;          *q = ip_srcrt.dst;
 #ifdef DIAGNOSTIC  
         if (ipprintfs)  
                 printf(" %x\n", ntohl(q->s_addr));  
 #endif  
         return (m);          return (m);
 }  }
   
Line 1307  ip_forward(struct mbuf *m, int srcrt)
Line 1190  ip_forward(struct mbuf *m, int srcrt)
         m->m_pkthdr.csum_flags = 0;          m->m_pkthdr.csum_flags = 0;
   
         dest = 0;          dest = 0;
 #ifdef DIAGNOSTIC  
         if (ipprintfs) {  
                 printf("forward: src %s ", inet_ntoa(ip->ip_src));  
                 printf("dst %s ttl %x\n", inet_ntoa(ip->ip_dst), ip->ip_ttl);  
         }  
 #endif  
         if (m->m_flags & (M_BCAST|M_MCAST) || in_canforward(ip->ip_dst) == 0) {          if (m->m_flags & (M_BCAST|M_MCAST) || in_canforward(ip->ip_dst) == 0) {
                 IP_STATINC(IP_STAT_CANTFORWARD);                  IP_STATINC(IP_STAT_CANTFORWARD);
                 m_freem(m);                  m_freem(m);
Line 1365  ip_forward(struct mbuf *m, int srcrt)
Line 1242  ip_forward(struct mbuf *m, int srcrt)
                          */                           */
                         type = ICMP_REDIRECT;                          type = ICMP_REDIRECT;
                         code = ICMP_REDIRECT_HOST;                          code = ICMP_REDIRECT_HOST;
 #ifdef DIAGNOSTIC  
                         if (ipprintfs)  
                                 printf("redirect (%d) to %x\n", code,  
                                     (u_int32_t)dest);  
 #endif  
                 }                  }
         }          }
   
Line 1421  ip_forward(struct mbuf *m, int srcrt)
Line 1293  ip_forward(struct mbuf *m, int srcrt)
   
                 if ((rt = rtcache_validate(&ipforward_rt)) != NULL)                  if ((rt = rtcache_validate(&ipforward_rt)) != NULL)
                         destmtu = rt->rt_ifp->if_mtu;                          destmtu = rt->rt_ifp->if_mtu;
   #ifdef IPSEC
 #if defined(FAST_IPSEC)                  (void)ipsec4_forward(mcopy, &destmtu);
                 {  #endif
                         /*  
                          * If the packet is routed over IPsec tunnel, tell the  
                          * originator the tunnel MTU.  
                          *      tunnel MTU = if MTU - sizeof(IP) - ESP/AH hdrsiz  
                          * XXX quickhack!!!  
                          */  
   
                         struct secpolicy *sp;  
                         int ipsecerror;  
                         size_t ipsechdr;  
                         struct route *ro;  
   
                         sp = ipsec4_getpolicybyaddr(mcopy,  
                             IPSEC_DIR_OUTBOUND, IP_FORWARDING,  
                             &ipsecerror);  
   
                         if (sp != NULL) {  
                                 /* count IPsec header size */  
                                 ipsechdr = ipsec4_hdrsiz(mcopy,  
                                     IPSEC_DIR_OUTBOUND, NULL);  
   
                                 /*  
                                  * find the correct route for outer IPv4  
                                  * header, compute tunnel MTU.  
                                  */  
   
                                 if (sp->req != NULL  
                                  && sp->req->sav != NULL  
                                  && sp->req->sav->sah != NULL) {  
                                         ro = &sp->req->sav->sah->sa_route;  
                                         rt = rtcache_validate(ro);  
                                         if (rt && rt->rt_ifp) {  
                                                 destmtu =  
                                                     rt->rt_rmx.rmx_mtu ?  
                                                     rt->rt_rmx.rmx_mtu :  
                                                     rt->rt_ifp->if_mtu;  
                                                 destmtu -= ipsechdr;  
                                         }  
                                 }  
   
                                 KEY_FREESP(&sp);  
                         }  
                 }  
 #endif /*defined(FAST_IPSEC)*/  
                 IP_STATINC(IP_STAT_CANTFRAG);                  IP_STATINC(IP_STAT_CANTFRAG);
                 break;                  break;
   
         case ENOBUFS:          case ENOBUFS:
 #if 1  
                 /*                  /*
                  * a router should not generate ICMP_SOURCEQUENCH as                   * Do not generate ICMP_SOURCEQUENCH as required in RFC 1812,
                  * required in RFC1812 Requirements for IP Version 4 Routers.                   * Requirements for IP Version 4 Routers.  Source quench can
                  * source quench could be a big problem under DoS attacks,                   * big problem under DoS attacks or if the underlying
                  * or if the underlying interface is rate-limited.                   * interface is rate-limited.
                  */                   */
                 if (mcopy)                  if (mcopy)
                         m_freem(mcopy);                          m_freem(mcopy);
                 return;                  return;
 #else  
                 type = ICMP_SOURCEQUENCH;  
                 code = 0;  
                 break;  
 #endif  
         }          }
         icmp_error(mcopy, type, code, dest, destmtu);          icmp_error(mcopy, type, code, dest, destmtu);
 }  }
   
 void  void
 ip_savecontrol(struct inpcb *inp, struct mbuf **mp, struct ip *ip,  ip_savecontrol(inpcb_t *inp, struct mbuf **mp, struct ip *ip, struct mbuf *m)
     struct mbuf *m)  
 {  {
           struct socket *so = inpcb_get_socket(inp);
           int inpflags = inpcb_get_flags(inp);
   
         if (inp->inp_socket->so_options & SO_TIMESTAMP          if (so->so_options & SO_TIMESTAMP
 #ifdef SO_OTIMESTAMP  #ifdef SO_OTIMESTAMP
             || inp->inp_socket->so_options & SO_OTIMESTAMP              || so->so_options & SO_OTIMESTAMP
 #endif  #endif
             ) {              ) {
                 struct timeval tv;                  struct timeval tv;
   
                 microtime(&tv);                  microtime(&tv);
 #ifdef SO_OTIMESTAMP  #ifdef SO_OTIMESTAMP
                 if (inp->inp_socket->so_options & SO_OTIMESTAMP) {                  if (so->so_options & SO_OTIMESTAMP) {
                         struct timeval50 tv50;                          struct timeval50 tv50;
                         timeval_to_timeval50(&tv, &tv50);                          timeval_to_timeval50(&tv, &tv50);
                         *mp = sbcreatecontrol((void *) &tv50, sizeof(tv50),                          *mp = sbcreatecontrol((void *) &tv50, sizeof(tv50),
Line 1517  ip_savecontrol(struct inpcb *inp, struct
Line 1340  ip_savecontrol(struct inpcb *inp, struct
                 if (*mp)                  if (*mp)
                         mp = &(*mp)->m_next;                          mp = &(*mp)->m_next;
         }          }
         if (inp->inp_flags & INP_RECVDSTADDR) {          if (inpflags & INP_RECVDSTADDR) {
                 *mp = sbcreatecontrol((void *) &ip->ip_dst,                  *mp = sbcreatecontrol((void *) &ip->ip_dst,
                     sizeof(struct in_addr), IP_RECVDSTADDR, IPPROTO_IP);                      sizeof(struct in_addr), IP_RECVDSTADDR, IPPROTO_IP);
                 if (*mp)                  if (*mp)
                         mp = &(*mp)->m_next;                          mp = &(*mp)->m_next;
         }          }
 #ifdef notyet          if (inpflags & INP_RECVPKTINFO) {
         /*                  struct in_pktinfo ipi;
          * XXX                  ipi.ipi_addr = ip->ip_src;
          * Moving these out of udp_input() made them even more broken                  ipi.ipi_ifindex = m->m_pkthdr.rcvif->if_index;
          * than they already were.                  *mp = sbcreatecontrol((void *) &ipi,
          *      - fenner@parc.xerox.com                      sizeof(ipi), IP_RECVPKTINFO, IPPROTO_IP);
          */  
         /* options were tossed already */  
         if (inp->inp_flags & INP_RECVOPTS) {  
                 *mp = sbcreatecontrol((void *) opts_deleted_above,  
                     sizeof(struct in_addr), IP_RECVOPTS, IPPROTO_IP);  
                 if (*mp)                  if (*mp)
                         mp = &(*mp)->m_next;                          mp = &(*mp)->m_next;
         }          }
         /* ip_srcroute doesn't do what we want here, need to fix */          if (inpflags & INP_PKTINFO) {
         if (inp->inp_flags & INP_RECVRETOPTS) {                  struct in_pktinfo ipi;
                 *mp = sbcreatecontrol((void *) ip_srcroute(),                  ipi.ipi_addr = ip->ip_dst;
                     sizeof(struct in_addr), IP_RECVRETOPTS, IPPROTO_IP);                  ipi.ipi_ifindex = m->m_pkthdr.rcvif->if_index;
                   *mp = sbcreatecontrol((void *) &ipi,
                       sizeof(ipi), IP_PKTINFO, IPPROTO_IP);
                 if (*mp)                  if (*mp)
                         mp = &(*mp)->m_next;                          mp = &(*mp)->m_next;
         }          }
 #endif          if (inpflags & INP_RECVIF) {
         if (inp->inp_flags & INP_RECVIF) {  
                 struct sockaddr_dl sdl;                  struct sockaddr_dl sdl;
   
                 sockaddr_dl_init(&sdl, sizeof(sdl),                  sockaddr_dl_init(&sdl, sizeof(sdl), m->m_pkthdr.rcvif ?
                     (m->m_pkthdr.rcvif != NULL)                      m->m_pkthdr.rcvif->if_index : 0, 0, NULL, 0, NULL, 0);
                         ?  m->m_pkthdr.rcvif->if_index  
                         : 0,  
                         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;
         }          }
         if (inp->inp_flags & INP_RECVTTL) {          if (inpflags & INP_RECVTTL) {
                 *mp = sbcreatecontrol((void *) &ip->ip_ttl,                  *mp = sbcreatecontrol((void *) &ip->ip_ttl,
                     sizeof(uint8_t), IP_RECVTTL, IPPROTO_IP);                      sizeof(uint8_t), IP_RECVTTL, IPPROTO_IP);
                 if (*mp)                  if (*mp)
Line 1620  sysctl_net_inet_ip_pmtudto(SYSCTLFN_ARGS
Line 1436  sysctl_net_inet_ip_pmtudto(SYSCTLFN_ARGS
         return (0);          return (0);
 }  }
   
 #ifdef GATEWAY  
 /*  
  * sysctl helper routine for net.inet.ip.maxflows.  
  */  
 static int  
 sysctl_net_inet_ip_maxflows(SYSCTLFN_ARGS)  
 {  
         int error;  
   
         error = sysctl_lookup(SYSCTLFN_CALL(rnode));  
         if (error || newp == NULL)  
                 return (error);  
   
         mutex_enter(softnet_lock);  
         KERNEL_LOCK(1, NULL);  
   
         ipflow_prune();  
   
         KERNEL_UNLOCK_ONE(NULL);  
         mutex_exit(softnet_lock);  
   
         return (0);  
 }  
   
 static int  
 sysctl_net_inet_ip_hashsize(SYSCTLFN_ARGS)  
 {  
         int error, tmp;  
         struct sysctlnode node;  
   
         node = *rnode;  
         tmp = ip_hashsize;  
         node.sysctl_data = &tmp;  
         error = sysctl_lookup(SYSCTLFN_CALL(&node));  
         if (error || newp == NULL)  
                 return (error);  
   
         if ((tmp & (tmp - 1)) == 0 && tmp != 0) {  
                 /*  
                  * Can only fail due to malloc()  
                  */  
                 mutex_enter(softnet_lock);  
                 KERNEL_LOCK(1, NULL);  
   
                 error = ipflow_invalidate_all(tmp);  
   
                 KERNEL_UNLOCK_ONE(NULL);  
                 mutex_exit(softnet_lock);  
   
         } else {  
                 /*  
                  * EINVAL if not a power of 2  
                  */  
                 error = EINVAL;  
         }  
   
         return error;  
 }  
 #endif /* GATEWAY */  
   
 static int  static int
 sysctl_net_inet_ip_stats(SYSCTLFN_ARGS)  sysctl_net_inet_ip_stats(SYSCTLFN_ARGS)
 {  {
Line 1690  sysctl_net_inet_ip_stats(SYSCTLFN_ARGS)
Line 1446  sysctl_net_inet_ip_stats(SYSCTLFN_ARGS)
 static void  static void
 sysctl_net_inet_ip_setup(struct sysctllog **clog)  sysctl_net_inet_ip_setup(struct sysctllog **clog)
 {  {
         extern int subnetsarelocal, hostzeroisbroadcast;  
   
         sysctl_createv(clog, 0, NULL, NULL,  
                        CTLFLAG_PERMANENT,  
                        CTLTYPE_NODE, "net", NULL,  
                        NULL, 0, NULL, 0,  
                        CTL_NET, CTL_EOL);  
         sysctl_createv(clog, 0, NULL, NULL,          sysctl_createv(clog, 0, NULL, NULL,
                        CTLFLAG_PERMANENT,                         CTLFLAG_PERMANENT,
                        CTLTYPE_NODE, "inet",                         CTLTYPE_NODE, "inet",
Line 1762  sysctl_net_inet_ip_setup(struct sysctllo
Line 1511  sysctl_net_inet_ip_setup(struct sysctllo
                        NULL, 0, &ip_allowsrcrt, 0,                         NULL, 0, &ip_allowsrcrt, 0,
                        CTL_NET, PF_INET, IPPROTO_IP,                         CTL_NET, PF_INET, IPPROTO_IP,
                        IPCTL_ALLOWSRCRT, CTL_EOL);                         IPCTL_ALLOWSRCRT, CTL_EOL);
         sysctl_createv(clog, 0, NULL, NULL,  
                        CTLFLAG_PERMANENT|CTLFLAG_READWRITE,  
                        CTLTYPE_INT, "subnetsarelocal",  
                        SYSCTL_DESCR("Whether logical subnets are considered "  
                                     "local"),  
                        NULL, 0, &subnetsarelocal, 0,  
                        CTL_NET, PF_INET, IPPROTO_IP,  
                        IPCTL_SUBNETSARELOCAL, CTL_EOL);  
         sysctl_createv(clog, 0, NULL, NULL,          sysctl_createv(clog, 0, NULL, NULL,
                        CTLFLAG_PERMANENT|CTLFLAG_READWRITE,                         CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
                        CTLTYPE_INT, "mtudisc",                         CTLTYPE_INT, "mtudisc",
Line 1798  sysctl_net_inet_ip_setup(struct sysctllo
Line 1540  sysctl_net_inet_ip_setup(struct sysctllo
                        sysctl_net_inet_ip_pmtudto, 0, (void *)&ip_mtudisc_timeout, 0,                         sysctl_net_inet_ip_pmtudto, 0, (void *)&ip_mtudisc_timeout, 0,
                        CTL_NET, PF_INET, IPPROTO_IP,                         CTL_NET, PF_INET, IPPROTO_IP,
                        IPCTL_MTUDISCTIMEOUT, CTL_EOL);                         IPCTL_MTUDISCTIMEOUT, CTL_EOL);
 #ifdef GATEWAY  
         sysctl_createv(clog, 0, NULL, NULL,  
                        CTLFLAG_PERMANENT|CTLFLAG_READWRITE,  
                        CTLTYPE_INT, "maxflows",  
                        SYSCTL_DESCR("Number of flows for fast forwarding"),  
                        sysctl_net_inet_ip_maxflows, 0, &ip_maxflows, 0,  
                        CTL_NET, PF_INET, IPPROTO_IP,  
                        IPCTL_MAXFLOWS, CTL_EOL);  
         sysctl_createv(clog, 0, NULL, NULL,  
                         CTLFLAG_PERMANENT|CTLFLAG_READWRITE,  
                         CTLTYPE_INT, "hashsize",  
                         SYSCTL_DESCR("Size of hash table for fast forwarding (IPv4)"),  
                         sysctl_net_inet_ip_hashsize, 0, &ip_hashsize, 0,  
                         CTL_NET, PF_INET, IPPROTO_IP,  
                         CTL_CREATE, CTL_EOL);  
 #endif /* GATEWAY */  
         sysctl_createv(clog, 0, NULL, NULL,  
                        CTLFLAG_PERMANENT|CTLFLAG_READWRITE,  
                        CTLTYPE_INT, "hostzerobroadcast",  
                        SYSCTL_DESCR("All zeroes address is broadcast address"),  
                        NULL, 0, &hostzeroisbroadcast, 0,  
                        CTL_NET, PF_INET, IPPROTO_IP,  
                        IPCTL_HOSTZEROBROADCAST, CTL_EOL);  
 #if NGIF > 0  #if NGIF > 0
         sysctl_createv(clog, 0, NULL, NULL,          sysctl_createv(clog, 0, NULL, NULL,
                        CTLFLAG_PERMANENT|CTLFLAG_READWRITE,                         CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
Line 1886  sysctl_net_inet_ip_setup(struct sysctllo
Line 1605  sysctl_net_inet_ip_setup(struct sysctllo
                        sysctl_net_inet_ip_stats, 0, NULL, 0,                         sysctl_net_inet_ip_stats, 0, NULL, 0,
                        CTL_NET, PF_INET, IPPROTO_IP, IPCTL_STATS,                         CTL_NET, PF_INET, IPPROTO_IP, IPCTL_STATS,
                        CTL_EOL);                         CTL_EOL);
   
           /* anonportalgo RFC6056 subtree */
           const struct sysctlnode *portalgo_node;
           sysctl_createv(clog, 0, NULL, &portalgo_node,
                          CTLFLAG_PERMANENT,
                          CTLTYPE_NODE, "anonportalgo",
                          SYSCTL_DESCR("Anonymous Port Algorithm Selection (RFC 6056)"),
                          NULL, 0, NULL, 0,
                          CTL_NET, PF_INET, IPPROTO_IP, CTL_CREATE, CTL_EOL);
           sysctl_createv(clog, 0, &portalgo_node, NULL,
                          CTLFLAG_PERMANENT,
                          CTLTYPE_STRING, "available",
                          SYSCTL_DESCR("available algorithms"),
                          sysctl_portalgo_available, 0, NULL, PORTALGO_MAXLEN,
                          CTL_CREATE, CTL_EOL);
           sysctl_createv(clog, 0, &portalgo_node, NULL,
                          CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
                          CTLTYPE_STRING, "selected",
                          SYSCTL_DESCR("selected algorithm"),
                          sysctl_portalgo_selected4, 0, NULL, PORTALGO_MAXLEN,
                          CTL_CREATE, CTL_EOL);
           sysctl_createv(clog, 0, &portalgo_node, NULL,
                          CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
                          CTLTYPE_STRUCT, "reserve",
                          SYSCTL_DESCR("bitmap of reserved ports"),
                          sysctl_portalgo_reserve4, 0, NULL, 0,
                          CTL_CREATE, CTL_EOL);
 }  }
   
 void  void

Legend:
Removed from v.1.300  
changed lines
  Added in v.1.307.2.3

CVSweb <webmaster@jp.NetBSD.org>