Lines Matching full:pmc
83 static void mld_add_delrec(struct inet6_dev *idev, struct ifmcaddr6 *pmc);
84 static void mld_del_delrec(struct inet6_dev *idev, struct ifmcaddr6 *pmc);
87 static int sf_setstate(struct ifmcaddr6 *pmc);
88 static void sf_markstate(struct ifmcaddr6 *pmc);
89 static void ip6_mc_clear_src(struct ifmcaddr6 *pmc);
120 #define for_each_pmc_rcu(np, pmc) \ argument
121 for (pmc = rcu_dereference(np->ipv6_mc_list); \
122 pmc != NULL; \
123 pmc = rcu_dereference(pmc->next))
336 struct ipv6_mc_socklist *pmc; in ip6_mc_source() local
361 for_each_pmc_rcu(inet6, pmc) { in ip6_mc_source()
362 if (pgsr->gsr_interface && pmc->ifindex != pgsr->gsr_interface) in ip6_mc_source()
364 if (ipv6_addr_equal(&pmc->addr, group)) in ip6_mc_source()
367 if (!pmc) { /* must have a prior join */ in ip6_mc_source()
372 if (pmc->sflist) { in ip6_mc_source()
373 if (pmc->sfmode != omode) { in ip6_mc_source()
377 } else if (pmc->sfmode != omode) { in ip6_mc_source()
380 ip6_mc_del_src(idev, group, pmc->sfmode, 0, NULL, 0); in ip6_mc_source()
381 pmc->sfmode = omode; in ip6_mc_source()
384 write_lock(&pmc->sflock); in ip6_mc_source()
387 psl = pmc->sflist; in ip6_mc_source()
439 pmc->sflist = psl = newpsl; in ip6_mc_source()
456 write_unlock(&pmc->sflock); in ip6_mc_source()
467 struct ipv6_mc_socklist *pmc; in ip6_mc_msfilter() local
498 for_each_pmc_rcu(inet6, pmc) { in ip6_mc_msfilter()
499 if (pmc->ifindex != gsf->gf_interface) in ip6_mc_msfilter()
501 if (ipv6_addr_equal(&pmc->addr, group)) in ip6_mc_msfilter()
504 if (!pmc) { /* must have a prior join */ in ip6_mc_msfilter()
533 write_lock(&pmc->sflock); in ip6_mc_msfilter()
534 psl = pmc->sflist; in ip6_mc_msfilter()
536 (void) ip6_mc_del_src(idev, group, pmc->sfmode, in ip6_mc_msfilter()
540 (void) ip6_mc_del_src(idev, group, pmc->sfmode, 0, NULL, 0); in ip6_mc_msfilter()
541 pmc->sflist = newpsl; in ip6_mc_msfilter()
542 pmc->sfmode = gsf->gf_fmode; in ip6_mc_msfilter()
543 write_unlock(&pmc->sflock); in ip6_mc_msfilter()
558 struct ipv6_mc_socklist *pmc; in ip6_mc_msfget() local
583 for_each_pmc_rcu(inet6, pmc) { in ip6_mc_msfget()
584 if (pmc->ifindex != gsf->gf_interface) in ip6_mc_msfget()
586 if (ipv6_addr_equal(group, &pmc->addr)) in ip6_mc_msfget()
589 if (!pmc) /* must have a prior join */ in ip6_mc_msfget()
591 gsf->gf_fmode = pmc->sfmode; in ip6_mc_msfget()
592 psl = pmc->sflist; in ip6_mc_msfget()
604 * on pmc->sflock. We have the socket lock so reading here is safe. in ip6_mc_msfget()
733 struct ifmcaddr6 *pmc; in mld_add_delrec() local
741 pmc = kzalloc(sizeof(*pmc), GFP_ATOMIC); in mld_add_delrec()
742 if (!pmc) in mld_add_delrec()
746 spin_lock_init(&pmc->mca_lock); in mld_add_delrec()
747 pmc->idev = im->idev; in mld_add_delrec()
749 pmc->mca_addr = im->mca_addr; in mld_add_delrec()
750 pmc->mca_crcount = idev->mc_qrv; in mld_add_delrec()
751 pmc->mca_sfmode = im->mca_sfmode; in mld_add_delrec()
752 if (pmc->mca_sfmode == MCAST_INCLUDE) { in mld_add_delrec()
755 pmc->mca_tomb = im->mca_tomb; in mld_add_delrec()
756 pmc->mca_sources = im->mca_sources; in mld_add_delrec()
758 for (psf = pmc->mca_sources; psf; psf = psf->sf_next) in mld_add_delrec()
759 psf->sf_crcount = pmc->mca_crcount; in mld_add_delrec()
764 pmc->next = idev->mc_tomb; in mld_add_delrec()
765 idev->mc_tomb = pmc; in mld_add_delrec()
771 struct ifmcaddr6 *pmc, *pmc_prev; in mld_del_delrec() local
777 for (pmc = idev->mc_tomb; pmc; pmc = pmc->next) { in mld_del_delrec()
778 if (ipv6_addr_equal(&pmc->mca_addr, pmca)) in mld_del_delrec()
780 pmc_prev = pmc; in mld_del_delrec()
782 if (pmc) { in mld_del_delrec()
784 pmc_prev->next = pmc->next; in mld_del_delrec()
786 idev->mc_tomb = pmc->next; in mld_del_delrec()
791 if (pmc) { in mld_del_delrec()
792 im->idev = pmc->idev; in mld_del_delrec()
794 swap(im->mca_tomb, pmc->mca_tomb); in mld_del_delrec()
795 swap(im->mca_sources, pmc->mca_sources); in mld_del_delrec()
801 in6_dev_put(pmc->idev); in mld_del_delrec()
802 ip6_mc_clear_src(pmc); in mld_del_delrec()
803 kfree(pmc); in mld_del_delrec()
810 struct ifmcaddr6 *pmc, *nextpmc; in mld_clear_delrec() local
813 pmc = idev->mc_tomb; in mld_clear_delrec()
817 for (; pmc; pmc = nextpmc) { in mld_clear_delrec()
818 nextpmc = pmc->next; in mld_clear_delrec()
819 ip6_mc_clear_src(pmc); in mld_clear_delrec()
820 in6_dev_put(pmc->idev); in mld_clear_delrec()
821 kfree(pmc); in mld_clear_delrec()
826 for (pmc = idev->mc_list; pmc; pmc = pmc->next) { in mld_clear_delrec()
829 spin_lock_bh(&pmc->mca_lock); in mld_clear_delrec()
830 psf = pmc->mca_tomb; in mld_clear_delrec()
831 pmc->mca_tomb = NULL; in mld_clear_delrec()
832 spin_unlock_bh(&pmc->mca_lock); in mld_clear_delrec()
1108 static bool mld_xmarksources(struct ifmcaddr6 *pmc, int nsrcs, in mld_xmarksources() argument
1115 for (psf = pmc->mca_sources; psf; psf = psf->sf_next) { in mld_xmarksources()
1121 pmc->mca_sfcount[MCAST_EXCLUDE] != in mld_xmarksources()
1130 pmc->mca_flags &= ~MAF_GSQUERY; in mld_xmarksources()
1136 static bool mld_marksources(struct ifmcaddr6 *pmc, int nsrcs, in mld_marksources() argument
1142 if (pmc->mca_sfmode == MCAST_EXCLUDE) in mld_marksources()
1143 return mld_xmarksources(pmc, nsrcs, srcs); in mld_marksources()
1148 for (psf = pmc->mca_sources; psf; psf = psf->sf_next) { in mld_marksources()
1160 pmc->mca_flags &= ~MAF_GSQUERY; in mld_marksources()
1163 pmc->mca_flags |= MAF_GSQUERY; in mld_marksources()
1508 static bool is_in(struct ifmcaddr6 *pmc, struct ip6_sf_list *psf, int type, in is_in() argument
1516 if (!((pmc->mca_flags & MAF_GSQUERY) && !psf->sf_gsresp)) { in is_in()
1517 if (pmc->mca_sfmode == MCAST_INCLUDE) in is_in()
1524 return pmc->mca_sfcount[MCAST_EXCLUDE] == in is_in()
1535 if (pmc->mca_sfcount[MCAST_EXCLUDE] == 0 || in is_in()
1538 return pmc->mca_sfcount[MCAST_EXCLUDE] == in is_in()
1543 return (pmc->mca_sfmode == MCAST_INCLUDE) ^ sdeleted; in is_in()
1545 if (pmc->mca_sfmode == MCAST_INCLUDE) in is_in()
1553 mld_scount(struct ifmcaddr6 *pmc, int type, int gdeleted, int sdeleted) in mld_scount() argument
1558 for (psf = pmc->mca_sources; psf; psf = psf->sf_next) { in mld_scount()
1559 if (!is_in(pmc, psf, type, gdeleted, sdeleted)) in mld_scount()
1703 static int grec_size(struct ifmcaddr6 *pmc, int type, int gdel, int sdel) in grec_size() argument
1705 return sizeof(struct mld2_grec) + 16 * mld_scount(pmc,type,gdel,sdel); in grec_size()
1708 static struct sk_buff *add_grhead(struct sk_buff *skb, struct ifmcaddr6 *pmc, in add_grhead() argument
1715 skb = mld_newpack(pmc->idev, mtu); in add_grhead()
1723 pgr->grec_mca = pmc->mca_addr; /* structure copy */ in add_grhead()
1732 static struct sk_buff *add_grec(struct sk_buff *skb, struct ifmcaddr6 *pmc, in add_grec() argument
1735 struct inet6_dev *idev = pmc->idev; in add_grec()
1743 if (pmc->mca_flags & MAF_NOREPORT) in add_grec()
1757 psf_list = sdeleted ? &pmc->mca_tomb : &pmc->mca_sources; in add_grec()
1767 AVAILABLE(skb) < grec_size(pmc, type, gdeleted, sdeleted)) { in add_grec()
1780 if (!is_in(pmc, psf, type, gdeleted, sdeleted) && !crsend) { in add_grec()
1788 if (((gdeleted && pmc->mca_sfmode == MCAST_EXCLUDE) || in add_grec()
1789 (!gdeleted && pmc->mca_crcount)) && in add_grec()
1811 skb = add_grhead(skb, pmc, type, &pgr, mtu); in add_grec()
1840 if (pmc->mca_crcount || isquery || crsend) { in add_grec()
1846 skb = add_grhead(skb, pmc, type, &pgr, mtu); in add_grec()
1853 pmc->mca_flags &= ~MAF_GSQUERY; /* clear query state */ in add_grec()
1857 static void mld_send_report(struct inet6_dev *idev, struct ifmcaddr6 *pmc) in mld_send_report() argument
1863 if (!pmc) { in mld_send_report()
1864 for (pmc = idev->mc_list; pmc; pmc = pmc->next) { in mld_send_report()
1865 if (pmc->mca_flags & MAF_NOREPORT) in mld_send_report()
1867 spin_lock_bh(&pmc->mca_lock); in mld_send_report()
1868 if (pmc->mca_sfcount[MCAST_EXCLUDE]) in mld_send_report()
1872 skb = add_grec(skb, pmc, type, 0, 0, 0); in mld_send_report()
1873 spin_unlock_bh(&pmc->mca_lock); in mld_send_report()
1876 spin_lock_bh(&pmc->mca_lock); in mld_send_report()
1877 if (pmc->mca_sfcount[MCAST_EXCLUDE]) in mld_send_report()
1881 skb = add_grec(skb, pmc, type, 0, 0, 0); in mld_send_report()
1882 spin_unlock_bh(&pmc->mca_lock); in mld_send_report()
1912 struct ifmcaddr6 *pmc, *pmc_prev, *pmc_next; in mld_send_cr() local
1921 for (pmc = idev->mc_tomb; pmc; pmc = pmc_next) { in mld_send_cr()
1922 pmc_next = pmc->next; in mld_send_cr()
1923 if (pmc->mca_sfmode == MCAST_INCLUDE) { in mld_send_cr()
1926 skb = add_grec(skb, pmc, type, 1, 0, 0); in mld_send_cr()
1927 skb = add_grec(skb, pmc, dtype, 1, 1, 0); in mld_send_cr()
1929 if (pmc->mca_crcount) { in mld_send_cr()
1930 if (pmc->mca_sfmode == MCAST_EXCLUDE) { in mld_send_cr()
1932 skb = add_grec(skb, pmc, type, 1, 0, 0); in mld_send_cr()
1934 pmc->mca_crcount--; in mld_send_cr()
1935 if (pmc->mca_crcount == 0) { in mld_send_cr()
1936 mld_clear_zeros(&pmc->mca_tomb); in mld_send_cr()
1937 mld_clear_zeros(&pmc->mca_sources); in mld_send_cr()
1940 if (pmc->mca_crcount == 0 && !pmc->mca_tomb && in mld_send_cr()
1941 !pmc->mca_sources) { in mld_send_cr()
1946 in6_dev_put(pmc->idev); in mld_send_cr()
1947 kfree(pmc); in mld_send_cr()
1949 pmc_prev = pmc; in mld_send_cr()
1954 for (pmc = idev->mc_list; pmc; pmc = pmc->next) { in mld_send_cr()
1955 spin_lock_bh(&pmc->mca_lock); in mld_send_cr()
1956 if (pmc->mca_sfcount[MCAST_EXCLUDE]) { in mld_send_cr()
1963 skb = add_grec(skb, pmc, type, 0, 0, 0); in mld_send_cr()
1964 skb = add_grec(skb, pmc, dtype, 0, 1, 0); /* deleted sources */ in mld_send_cr()
1967 if (pmc->mca_crcount) { in mld_send_cr()
1968 if (pmc->mca_sfmode == MCAST_EXCLUDE) in mld_send_cr()
1972 skb = add_grec(skb, pmc, type, 0, 0, 0); in mld_send_cr()
1973 pmc->mca_crcount--; in mld_send_cr()
1975 spin_unlock_bh(&pmc->mca_lock); in mld_send_cr()
2082 struct ifmcaddr6 *pmc; in mld_send_initial_cr() local
2090 for (pmc = idev->mc_list; pmc; pmc = pmc->next) { in mld_send_initial_cr()
2091 spin_lock_bh(&pmc->mca_lock); in mld_send_initial_cr()
2092 if (pmc->mca_sfcount[MCAST_EXCLUDE]) in mld_send_initial_cr()
2096 skb = add_grec(skb, pmc, type, 0, 0, 1); in mld_send_initial_cr()
2097 spin_unlock_bh(&pmc->mca_lock); in mld_send_initial_cr()
2130 static int ip6_mc_del1_src(struct ifmcaddr6 *pmc, int sfmode, in ip6_mc_del1_src() argument
2137 for (psf = pmc->mca_sources; psf; psf = psf->sf_next) { in ip6_mc_del1_src()
2148 struct inet6_dev *idev = pmc->idev; in ip6_mc_del1_src()
2154 pmc->mca_sources = psf->sf_next; in ip6_mc_del1_src()
2155 if (psf->sf_oldin && !(pmc->mca_flags & MAF_NOREPORT) && in ip6_mc_del1_src()
2158 psf->sf_next = pmc->mca_tomb; in ip6_mc_del1_src()
2159 pmc->mca_tomb = psf; in ip6_mc_del1_src()
2171 struct ifmcaddr6 *pmc; in ip6_mc_del_src() local
2178 for (pmc = idev->mc_list; pmc; pmc = pmc->next) { in ip6_mc_del_src()
2179 if (ipv6_addr_equal(pmca, &pmc->mca_addr)) in ip6_mc_del_src()
2182 if (!pmc) { in ip6_mc_del_src()
2187 spin_lock_bh(&pmc->mca_lock); in ip6_mc_del_src()
2188 sf_markstate(pmc); in ip6_mc_del_src()
2190 if (!pmc->mca_sfcount[sfmode]) { in ip6_mc_del_src()
2191 spin_unlock_bh(&pmc->mca_lock); in ip6_mc_del_src()
2195 pmc->mca_sfcount[sfmode]--; in ip6_mc_del_src()
2199 int rv = ip6_mc_del1_src(pmc, sfmode, &psfsrc[i]); in ip6_mc_del_src()
2205 if (pmc->mca_sfmode == MCAST_EXCLUDE && in ip6_mc_del_src()
2206 pmc->mca_sfcount[MCAST_EXCLUDE] == 0 && in ip6_mc_del_src()
2207 pmc->mca_sfcount[MCAST_INCLUDE]) { in ip6_mc_del_src()
2211 pmc->mca_sfmode = MCAST_INCLUDE; in ip6_mc_del_src()
2212 pmc->mca_crcount = idev->mc_qrv; in ip6_mc_del_src()
2213 idev->mc_ifc_count = pmc->mca_crcount; in ip6_mc_del_src()
2214 for (psf = pmc->mca_sources; psf; psf = psf->sf_next) in ip6_mc_del_src()
2216 mld_ifc_event(pmc->idev); in ip6_mc_del_src()
2217 } else if (sf_setstate(pmc) || changerec) in ip6_mc_del_src()
2218 mld_ifc_event(pmc->idev); in ip6_mc_del_src()
2219 spin_unlock_bh(&pmc->mca_lock); in ip6_mc_del_src()
2227 static int ip6_mc_add1_src(struct ifmcaddr6 *pmc, int sfmode, in ip6_mc_add1_src() argument
2233 for (psf = pmc->mca_sources; psf; psf = psf->sf_next) { in ip6_mc_add1_src()
2247 pmc->mca_sources = psf; in ip6_mc_add1_src()
2253 static void sf_markstate(struct ifmcaddr6 *pmc) in sf_markstate() argument
2256 int mca_xcount = pmc->mca_sfcount[MCAST_EXCLUDE]; in sf_markstate()
2258 for (psf = pmc->mca_sources; psf; psf = psf->sf_next) in sf_markstate()
2259 if (pmc->mca_sfcount[MCAST_EXCLUDE]) { in sf_markstate()
2267 static int sf_setstate(struct ifmcaddr6 *pmc) in sf_setstate() argument
2270 int mca_xcount = pmc->mca_sfcount[MCAST_EXCLUDE]; in sf_setstate()
2271 int qrv = pmc->idev->mc_qrv; in sf_setstate()
2275 for (psf = pmc->mca_sources; psf; psf = psf->sf_next) { in sf_setstate()
2276 if (pmc->mca_sfcount[MCAST_EXCLUDE]) { in sf_setstate()
2285 for (dpsf = pmc->mca_tomb; dpsf; in sf_setstate()
2296 pmc->mca_tomb = dpsf->sf_next; in sf_setstate()
2308 for (dpsf = pmc->mca_tomb; dpsf; dpsf = dpsf->sf_next) in sf_setstate()
2317 /* pmc->mca_lock held by callers */ in sf_setstate()
2318 dpsf->sf_next = pmc->mca_tomb; in sf_setstate()
2319 pmc->mca_tomb = dpsf; in sf_setstate()
2335 struct ifmcaddr6 *pmc; in ip6_mc_add_src() local
2342 for (pmc = idev->mc_list; pmc; pmc = pmc->next) { in ip6_mc_add_src()
2343 if (ipv6_addr_equal(pmca, &pmc->mca_addr)) in ip6_mc_add_src()
2346 if (!pmc) { in ip6_mc_add_src()
2351 spin_lock_bh(&pmc->mca_lock); in ip6_mc_add_src()
2353 sf_markstate(pmc); in ip6_mc_add_src()
2354 isexclude = pmc->mca_sfmode == MCAST_EXCLUDE; in ip6_mc_add_src()
2356 pmc->mca_sfcount[sfmode]++; in ip6_mc_add_src()
2359 err = ip6_mc_add1_src(pmc, sfmode, &psfsrc[i]); in ip6_mc_add_src()
2367 pmc->mca_sfcount[sfmode]--; in ip6_mc_add_src()
2369 ip6_mc_del1_src(pmc, sfmode, &psfsrc[j]); in ip6_mc_add_src()
2370 } else if (isexclude != (pmc->mca_sfcount[MCAST_EXCLUDE] != 0)) { in ip6_mc_add_src()
2374 if (pmc->mca_sfcount[MCAST_EXCLUDE]) in ip6_mc_add_src()
2375 pmc->mca_sfmode = MCAST_EXCLUDE; in ip6_mc_add_src()
2376 else if (pmc->mca_sfcount[MCAST_INCLUDE]) in ip6_mc_add_src()
2377 pmc->mca_sfmode = MCAST_INCLUDE; in ip6_mc_add_src()
2380 pmc->mca_crcount = idev->mc_qrv; in ip6_mc_add_src()
2381 idev->mc_ifc_count = pmc->mca_crcount; in ip6_mc_add_src()
2382 for (psf = pmc->mca_sources; psf; psf = psf->sf_next) in ip6_mc_add_src()
2385 } else if (sf_setstate(pmc)) in ip6_mc_add_src()
2387 spin_unlock_bh(&pmc->mca_lock); in ip6_mc_add_src()
2392 static void ip6_mc_clear_src(struct ifmcaddr6 *pmc) in ip6_mc_clear_src() argument
2396 for (psf = pmc->mca_tomb; psf; psf = nextpsf) { in ip6_mc_clear_src()
2400 pmc->mca_tomb = NULL; in ip6_mc_clear_src()
2401 for (psf = pmc->mca_sources; psf; psf = nextpsf) { in ip6_mc_clear_src()
2405 pmc->mca_sources = NULL; in ip6_mc_clear_src()
2406 pmc->mca_sfmode = MCAST_EXCLUDE; in ip6_mc_clear_src()
2407 pmc->mca_sfcount[MCAST_INCLUDE] = 0; in ip6_mc_clear_src()
2408 pmc->mca_sfcount[MCAST_EXCLUDE] = 1; in ip6_mc_clear_src()
2632 struct ifmcaddr6 *pmc; in ipv6_mc_rejoin_groups() local
2638 for (pmc = idev->mc_list; pmc; pmc = pmc->next) in ipv6_mc_rejoin_groups()
2639 igmp6_join_group(pmc); in ipv6_mc_rejoin_groups()