[BACK]Return to mld6.c CVS log [TXT][DIR] Up to [cvs.NetBSD.org] / src / sys / netinet6

Please note that diffs are not public domain; they are subject to the copyright notices on the relevant files.

Diff for /src/sys/netinet6/mld6.c between version 1.68 and 1.82

version 1.68, 2016/06/21 03:28:27 version 1.82, 2017/02/22 07:46:00
Line 106  __KERNEL_RCSID(0, "$NetBSD$");
Line 106  __KERNEL_RCSID(0, "$NetBSD$");
   
 #ifdef _KERNEL_OPT  #ifdef _KERNEL_OPT
 #include "opt_inet.h"  #include "opt_inet.h"
   #include "opt_net_mpsafe.h"
 #endif  #endif
   
 #include <sys/param.h>  #include <sys/param.h>
Line 113  __KERNEL_RCSID(0, "$NetBSD$");
Line 114  __KERNEL_RCSID(0, "$NetBSD$");
 #include <sys/mbuf.h>  #include <sys/mbuf.h>
 #include <sys/socket.h>  #include <sys/socket.h>
 #include <sys/socketvar.h>  #include <sys/socketvar.h>
 #include <sys/protosw.h>  
 #include <sys/syslog.h>  #include <sys/syslog.h>
 #include <sys/sysctl.h>  #include <sys/sysctl.h>
 #include <sys/kernel.h>  #include <sys/kernel.h>
Line 229  mld_timeo(void *arg)
Line 229  mld_timeo(void *arg)
 {  {
         struct in6_multi *in6m = arg;          struct in6_multi *in6m = arg;
   
           /* XXX NOMPSAFE still need softnet_lock */
         mutex_enter(softnet_lock);          mutex_enter(softnet_lock);
         KERNEL_LOCK(1, NULL);          KERNEL_LOCK(1, NULL);
   
Line 344  mld_input(struct mbuf *m, int off)
Line 345  mld_input(struct mbuf *m, int off)
         int s;          int s;
   
         ifp = m_get_rcvif(m, &s);          ifp = m_get_rcvif(m, &s);
           if (__predict_false(ifp == NULL))
                   goto out;
         IP6_EXTHDR_GET(mldh, struct mld_hdr *, m, off, sizeof(*mldh));          IP6_EXTHDR_GET(mldh, struct mld_hdr *, m, off, sizeof(*mldh));
         if (mldh == NULL) {          if (mldh == NULL) {
                 ICMP6_STATINC(ICMP6_STAT_TOOSHORT);                  ICMP6_STATINC(ICMP6_STAT_TOOSHORT);
Line 373  mld_input(struct mbuf *m, int off)
Line 376  mld_input(struct mbuf *m, int off)
                  * though RFC3590 says "SHOULD log" if the source of a query                   * though RFC3590 says "SHOULD log" if the source of a query
                  * is the unspecified address.                   * is the unspecified address.
                  */                   */
                   char ip6bufs[INET6_ADDRSTRLEN];
                   char ip6bufm[INET6_ADDRSTRLEN];
                 log(LOG_INFO,                  log(LOG_INFO,
                     "mld_input: src %s is not link-local (grp=%s)\n",                      "mld_input: src %s is not link-local (grp=%s)\n",
                     ip6_sprintf(&ip6->ip6_src), ip6_sprintf(&mldh->mld_addr));                      IN6_PRINT(ip6bufs,&ip6->ip6_src),
                       IN6_PRINT(ip6bufm, &mldh->mld_addr));
 #endif  #endif
                 goto out;                  goto out;
         }          }
Line 402  mld_input(struct mbuf *m, int off)
Line 408  mld_input(struct mbuf *m, int off)
          * if we sent the last report.           * if we sent the last report.
          */           */
         switch (mldh->mld_type) {          switch (mldh->mld_type) {
         case MLD_LISTENER_QUERY:          case MLD_LISTENER_QUERY: {
                   struct psref psref;
   
                 if (ifp->if_flags & IFF_LOOPBACK)                  if (ifp->if_flags & IFF_LOOPBACK)
                         break;                          break;
   
Line 428  mld_input(struct mbuf *m, int off)
Line 436  mld_input(struct mbuf *m, int off)
                  */                   */
                 timer = ntohs(mldh->mld_maxdelay);                  timer = ntohs(mldh->mld_maxdelay);
   
                 IFP_TO_IA6(ifp, ia);                  ia = in6_get_ia_from_ifp_psref(ifp, &psref);
                 if (ia == NULL)                  if (ia == NULL)
                         break;                          break;
   
                   /* The following operations may sleep */
                   m_put_rcvif(ifp, &s);
                   ifp = NULL;
   
                 LIST_FOREACH(in6m, &ia->ia6_multiaddrs, in6m_entry) {                  LIST_FOREACH(in6m, &ia->ia6_multiaddrs, in6m_entry) {
                         if (IN6_ARE_ADDR_EQUAL(&in6m->in6m_addr, &all_in6) ||                          if (IN6_ARE_ADDR_EQUAL(&in6m->in6m_addr, &all_in6) ||
                             IPV6_ADDR_MC_SCOPE(&in6m->in6m_addr) <                              IPV6_ADDR_MC_SCOPE(&in6m->in6m_addr) <
Line 457  mld_input(struct mbuf *m, int off)
Line 469  mld_input(struct mbuf *m, int off)
                                 mld_starttimer(in6m);                                  mld_starttimer(in6m);
                         }                          }
                 }                  }
                   ia6_release(ia, &psref);
                 break;                  break;
               }
   
         case MLD_LISTENER_REPORT:          case MLD_LISTENER_REPORT:
                 /*                  /*
Line 479  mld_input(struct mbuf *m, int off)
Line 493  mld_input(struct mbuf *m, int off)
                  * If we belong to the group being reported, stop                   * If we belong to the group being reported, stop
                  * our timer for that group.                   * our timer for that group.
                  */                   */
                 IN6_LOOKUP_MULTI(mld_addr, ifp, in6m);                  in6m = in6_lookup_multi(&mld_addr, ifp);
                 if (in6m) {                  if (in6m) {
                         mld_stoptimer(in6m); /* transit to idle state */                          mld_stoptimer(in6m); /* transit to idle state */
                         in6m->in6m_state = MLD_OTHERLISTENER; /* clear flag */                          in6m->in6m_state = MLD_OTHERLISTENER; /* clear flag */
Line 514  mld_sendpkt(struct in6_multi *in6m, int 
Line 528  mld_sendpkt(struct in6_multi *in6m, int 
         struct in6_ifaddr *ia = NULL;          struct in6_ifaddr *ia = NULL;
         struct ifnet *ifp = in6m->in6m_ifp;          struct ifnet *ifp = in6m->in6m_ifp;
         int ignflags;          int ignflags;
           struct psref psref;
           int bound;
   
         /*          /*
          * At first, find a link local address on the outgoing interface           * At first, find a link local address on the outgoing interface
Line 522  mld_sendpkt(struct in6_multi *in6m, int 
Line 538  mld_sendpkt(struct in6_multi *in6m, int 
          * the case where we first join a link-local address.           * the case where we first join a link-local address.
          */           */
         ignflags = (IN6_IFF_NOTREADY|IN6_IFF_ANYCAST) & ~IN6_IFF_TENTATIVE;          ignflags = (IN6_IFF_NOTREADY|IN6_IFF_ANYCAST) & ~IN6_IFF_TENTATIVE;
         if ((ia = in6ifa_ifpforlinklocal(ifp, ignflags)) == NULL)          bound = curlwp_bind();
           ia = in6ifa_ifpforlinklocal_psref(ifp, ignflags, &psref);
           if (ia == NULL) {
                   curlwp_bindx(bound);
                 return;                  return;
         if ((ia->ia6_flags & IN6_IFF_TENTATIVE))          }
           if ((ia->ia6_flags & IN6_IFF_TENTATIVE)) {
                   ia6_release(ia, &psref);
                 ia = NULL;                  ia = NULL;
           }
   
         /* Allocate two mbufs to store IPv6 header and MLD header */          /* Allocate two mbufs to store IPv6 header and MLD header */
         mldh = mld_allocbuf(&mh, sizeof(struct mld_hdr), in6m, type);          mldh = mld_allocbuf(&mh, sizeof(struct mld_hdr), in6m, type);
         if (mldh == NULL)          if (mldh == NULL) {
                   ia6_release(ia, &psref);
                   curlwp_bindx(bound);
                 return;                  return;
           }
   
         /* fill src/dst here */          /* fill src/dst here */
         ip6 = mtod(mh, struct ip6_hdr *);          ip6 = mtod(mh, struct ip6_hdr *);
         ip6->ip6_src = ia ? ia->ia_addr.sin6_addr : in6addr_any;          ip6->ip6_src = ia ? ia->ia_addr.sin6_addr : in6addr_any;
         ip6->ip6_dst = dst ? *dst : in6m->in6m_addr;          ip6->ip6_dst = dst ? *dst : in6m->in6m_addr;
           ia6_release(ia, &psref);
           curlwp_bindx(bound);
   
         mldh->mld_addr = in6m->in6m_addr;          mldh->mld_addr = in6m->in6m_addr;
         in6_clearscope(&mldh->mld_addr); /* XXX */          in6_clearscope(&mldh->mld_addr); /* XXX */
Line 638  in6_addmulti(struct in6_addr *maddr6, st
Line 665  in6_addmulti(struct in6_addr *maddr6, st
         /*          /*
          * See if address already in list.           * See if address already in list.
          */           */
         IN6_LOOKUP_MULTI(*maddr6, ifp, in6m);          in6m = in6_lookup_multi(maddr6, ifp);
         if (in6m != NULL) {          if (in6m != NULL) {
                 /*                  /*
                  * Found it; just increment the refrence count.                   * Found it; just increment the refrence count.
                  */                   */
                 in6m->in6m_refcount++;                  in6m->in6m_refcount++;
         } else {          } else {
                   int _s;
                 /*                  /*
                  * New address; allocate a new multicast record                   * New address; allocate a new multicast record
                  * and link it into the interface's multicast list.                   * and link it into the interface's multicast list.
Line 664  in6_addmulti(struct in6_addr *maddr6, st
Line 692  in6_addmulti(struct in6_addr *maddr6, st
                 callout_init(&in6m->in6m_timer_ch, CALLOUT_MPSAFE);                  callout_init(&in6m->in6m_timer_ch, CALLOUT_MPSAFE);
                 callout_setfunc(&in6m->in6m_timer_ch, mld_timeo, in6m);                  callout_setfunc(&in6m->in6m_timer_ch, mld_timeo, in6m);
   
                 IFP_TO_IA6(ifp, ia);                  _s = pserialize_read_enter();
                   ia = in6_get_ia_from_ifp(ifp);
                 if (ia == NULL) {                  if (ia == NULL) {
                           pserialize_read_exit(_s);
                         callout_destroy(&in6m->in6m_timer_ch);                          callout_destroy(&in6m->in6m_timer_ch);
                         free(in6m, M_IPMADDR);                          free(in6m, M_IPMADDR);
                         splx(s);                          splx(s);
Line 674  in6_addmulti(struct in6_addr *maddr6, st
Line 704  in6_addmulti(struct in6_addr *maddr6, st
                 }                  }
                 in6m->in6m_ia = ia;                  in6m->in6m_ia = ia;
                 ifaref(&ia->ia_ifa); /* gain a reference */                  ifaref(&ia->ia_ifa); /* gain a reference */
                   /* FIXME NOMPSAFE: need to lock */
                 LIST_INSERT_HEAD(&ia->ia6_multiaddrs, in6m, in6m_entry);                  LIST_INSERT_HEAD(&ia->ia6_multiaddrs, in6m, in6m_entry);
                   pserialize_read_exit(_s);
   
                 /*                  /*
                  * Ask the network driver to update its multicast reception                   * Ask the network driver to update its multicast reception
Line 723  in6_delmulti(struct in6_multi *in6m)
Line 755  in6_delmulti(struct in6_multi *in6m)
         mld_stoptimer(in6m);          mld_stoptimer(in6m);
   
         if (--in6m->in6m_refcount == 0) {          if (--in6m->in6m_refcount == 0) {
                   int _s;
   
                 /*                  /*
                  * No remaining claims to this record; let MLD6 know                   * No remaining claims to this record; let MLD6 know
                  * that we are leaving the multicast group.                   * that we are leaving the multicast group.
Line 742  in6_delmulti(struct in6_multi *in6m)
Line 776  in6_delmulti(struct in6_multi *in6m)
                  * Delete all references of this multicasting group from                   * Delete all references of this multicasting group from
                  * the membership arrays                   * the membership arrays
                  */                   */
                 for (ia = in6_ifaddr; ia; ia = ia->ia_next) {                  _s = pserialize_read_enter();
                   IN6_ADDRLIST_READER_FOREACH(ia) {
                         struct in6_multi_mship *imm;                          struct in6_multi_mship *imm;
                         LIST_FOREACH(imm, &ia->ia6_memberships, i6mm_chain) {                          LIST_FOREACH(imm, &ia->ia6_memberships, i6mm_chain) {
                                 if (imm->i6mm_maddr == in6m)                                  if (imm->i6mm_maddr == in6m)
                                         imm->i6mm_maddr = NULL;                                          imm->i6mm_maddr = NULL;
                         }                          }
                 }                  }
                   pserialize_read_exit(_s);
   
                 /*                  /*
                  * Notify the network driver to update its multicast                   * Notify the network driver to update its multicast
Line 759  in6_delmulti(struct in6_multi *in6m)
Line 795  in6_delmulti(struct in6_multi *in6m)
   
                 /* Tell mld_timeo we're halting the timer */                  /* Tell mld_timeo we're halting the timer */
                 in6m->in6m_timer = IN6M_TIMER_UNDEF;                  in6m->in6m_timer = IN6M_TIMER_UNDEF;
                 callout_halt(&in6m->in6m_timer_ch, softnet_lock);                  if (mutex_owned(softnet_lock))
                           callout_halt(&in6m->in6m_timer_ch, softnet_lock);
                   else
                           callout_halt(&in6m->in6m_timer_ch, NULL);
                 callout_destroy(&in6m->in6m_timer_ch);                  callout_destroy(&in6m->in6m_timer_ch);
   
                 free(in6m, M_IPMADDR);                  free(in6m, M_IPMADDR);
Line 812  in6_savemkludge(struct in6_ifaddr *oia)
Line 851  in6_savemkludge(struct in6_ifaddr *oia)
 {  {
         struct in6_ifaddr *ia;          struct in6_ifaddr *ia;
         struct in6_multi *in6m;          struct in6_multi *in6m;
           int s;
   
         IFP_TO_IA6(oia->ia_ifp, ia);          s = pserialize_read_enter();
           ia = in6_get_ia_from_ifp(oia->ia_ifp);
         if (ia) {       /* there is another address */          if (ia) {       /* there is another address */
                 KASSERT(ia != oia);                  KASSERT(ia != oia);
                 while ((in6m = LIST_FIRST(&oia->ia6_multiaddrs)) != NULL) {                  while ((in6m = LIST_FIRST(&oia->ia6_multiaddrs)) != NULL) {
Line 821  in6_savemkludge(struct in6_ifaddr *oia)
Line 862  in6_savemkludge(struct in6_ifaddr *oia)
                         ifaref(&ia->ia_ifa);                          ifaref(&ia->ia_ifa);
                         ifafree(&in6m->in6m_ia->ia_ifa);                          ifafree(&in6m->in6m_ia->ia_ifa);
                         in6m->in6m_ia = ia;                          in6m->in6m_ia = ia;
                           /* FIXME NOMPSAFE: need to lock */
                         LIST_INSERT_HEAD(&ia->ia6_multiaddrs, in6m, in6m_entry);                          LIST_INSERT_HEAD(&ia->ia6_multiaddrs, in6m, in6m_entry);
                 }                  }
         } else {        /* last address on this if deleted, save */          } else {        /* last address on this if deleted, save */
Line 840  in6_savemkludge(struct in6_ifaddr *oia)
Line 882  in6_savemkludge(struct in6_ifaddr *oia)
                         LIST_INSERT_HEAD(&mk->mk_head, in6m, in6m_entry);                          LIST_INSERT_HEAD(&mk->mk_head, in6m, in6m_entry);
                 }                  }
         }          }
           pserialize_read_exit(s);
 }  }
   
 /*  /*
Line 982  in6_multicast_sysctl(SYSCTLFN_ARGS)
Line 1025  in6_multicast_sysctl(SYSCTLFN_ARGS)
         uint32_t tmp;          uint32_t tmp;
         int error;          int error;
         size_t written;          size_t written;
         struct psref psref;          struct psref psref, psref_ia;
         int bound;          int bound, s;
   
         if (namelen != 1)          if (namelen != 1)
                 return EINVAL;                  return EINVAL;
Line 997  in6_multicast_sysctl(SYSCTLFN_ARGS)
Line 1040  in6_multicast_sysctl(SYSCTLFN_ARGS)
   
         if (oldp == NULL) {          if (oldp == NULL) {
                 *oldlenp = 0;                  *oldlenp = 0;
                 IFADDR_FOREACH(ifa, ifp) {                  s = pserialize_read_enter();
                         if (ifa->ifa_addr == NULL)                  IFADDR_READER_FOREACH(ifa, ifp) {
                                 continue;  
                         if (ifa->ifa_addr->sa_family != AF_INET6)                          if (ifa->ifa_addr->sa_family != AF_INET6)
                                 continue;                                  continue;
                         ifa6 = (struct in6_ifaddr *)ifa;                          ifa6 = (struct in6_ifaddr *)ifa;
Line 1008  in6_multicast_sysctl(SYSCTLFN_ARGS)
Line 1050  in6_multicast_sysctl(SYSCTLFN_ARGS)
                                     sizeof(uint32_t);                                      sizeof(uint32_t);
                         }                          }
                 }                  }
                   pserialize_read_exit(s);
                 if_put(ifp, &psref);                  if_put(ifp, &psref);
                 curlwp_bindx(bound);                  curlwp_bindx(bound);
                 return 0;                  return 0;
Line 1015  in6_multicast_sysctl(SYSCTLFN_ARGS)
Line 1058  in6_multicast_sysctl(SYSCTLFN_ARGS)
   
         error = 0;          error = 0;
         written = 0;          written = 0;
         IFADDR_FOREACH(ifa, ifp) {          s = pserialize_read_enter();
                 if (ifa->ifa_addr == NULL)          IFADDR_READER_FOREACH(ifa, ifp) {
                         continue;  
                 if (ifa->ifa_addr->sa_family != AF_INET6)                  if (ifa->ifa_addr->sa_family != AF_INET6)
                         continue;                          continue;
   
                   ifa_acquire(ifa, &psref_ia);
                   pserialize_read_exit(s);
   
                 ifa6 = (struct in6_ifaddr *)ifa;                  ifa6 = (struct in6_ifaddr *)ifa;
                 LIST_FOREACH(in6m, &ifa6->ia6_multiaddrs, in6m_entry) {                  LIST_FOREACH(in6m, &ifa6->ia6_multiaddrs, in6m_entry) {
                         if (written + 2 * sizeof(struct in6_addr) +                          if (written + 2 * sizeof(struct in6_addr) +
Line 1044  in6_multicast_sysctl(SYSCTLFN_ARGS)
Line 1090  in6_multicast_sysctl(SYSCTLFN_ARGS)
                         oldp = (char *)oldp + sizeof(tmp);                          oldp = (char *)oldp + sizeof(tmp);
                         written += sizeof(tmp);                          written += sizeof(tmp);
                 }                  }
   
                   s = pserialize_read_enter();
                   ifa_release(ifa, &psref_ia);
         }          }
           pserialize_read_exit(s);
 done:  done:
           ifa_release(ifa, &psref_ia);
         if_put(ifp, &psref);          if_put(ifp, &psref);
         curlwp_bindx(bound);          curlwp_bindx(bound);
         *oldlenp = written;          *oldlenp = written;
         return error;          return error;
 }  }
   
 SYSCTL_SETUP(sysctl_in6_mklude_setup, "sysctl net.inet6.multicast_kludge subtree setup")  void
   in6_sysctl_multicast_setup(struct sysctllog **clog)
 {  {
   
         sysctl_createv(clog, 0, NULL, NULL,          sysctl_createv(clog, 0, NULL, NULL,

Legend:
Removed from v.1.68  
changed lines
  Added in v.1.82

CVSweb <webmaster@jp.NetBSD.org>