--- zzzz-none-000/linux-2.6.39.4/net/ipv4/igmp.c 2011-08-03 19:43:28.000000000 +0000 +++ puma6-arm-6490-729/linux-2.6.39.4/net/ipv4/igmp.c 2021-11-10 13:23:11.000000000 +0000 @@ -114,7 +114,7 @@ #define IGMP_V1_Router_Present_Timeout (400*HZ) #define IGMP_V2_Router_Present_Timeout (400*HZ) -#define IGMP_Unsolicited_Report_Interval (10*HZ) +#define IGMP_Unsolicited_Report_Interval (1*HZ) #define IGMP_Query_Response_Interval (10*HZ) #define IGMP_Unsolicited_Report_Count 2 @@ -1206,6 +1206,7 @@ } /* else, v3 */ + if (im->sfmode == MCAST_EXCLUDE) im->crcount = in_dev->mr_qrv ? in_dev->mr_qrv : IGMP_Unsolicited_Report_Count; igmp_ifc_event(in_dev); @@ -1222,7 +1223,7 @@ * A socket has joined a multicast group on device dev. */ -void ip_mc_inc_group(struct in_device *in_dev, __be32 addr) +void ip_mc_inc_group_for_mode(struct in_device *in_dev, __be32 addr, int omode) { struct ip_mc_list *im; @@ -1231,7 +1232,7 @@ for_each_pmc_rtnl(in_dev, im) { if (im->multiaddr == addr) { im->users++; - ip_mc_add_src(in_dev, &addr, MCAST_EXCLUDE, 0, NULL, 0); + ip_mc_add_src(in_dev, &addr, omode, 0, NULL, 0); goto out; } } @@ -1244,9 +1245,15 @@ im->interface = in_dev; in_dev_hold(in_dev); im->multiaddr = addr; - /* initial mode is (EX, empty) */ - im->sfmode = MCAST_EXCLUDE; - im->sfcount[MCAST_EXCLUDE] = 1; + if (omode == MCAST_EXCLUDE) { + /* initial mode is (EX, empty) */ + im->sfmode = MCAST_EXCLUDE; + im->sfcount[MCAST_EXCLUDE] = 1; + } else { + im->sfmode = MCAST_INCLUDE; + im->sfcount[MCAST_INCLUDE] = 1; + im->sfcount[MCAST_EXCLUDE] = 0; + } atomic_set(&im->refcnt, 1); spin_lock_init(&im->lock); #ifdef CONFIG_IP_MULTICAST @@ -1298,6 +1305,11 @@ } EXPORT_SYMBOL(ip_mc_rejoin_groups); +void ip_mc_inc_group(struct in_device *in_dev, u32 addr) +{ + ip_mc_inc_group_for_mode(in_dev, addr, MCAST_EXCLUDE); +} + /* * A socket has left a multicast group on device dev */ @@ -1784,7 +1796,7 @@ /* * Join a multicast group */ -int ip_mc_join_group(struct sock *sk , struct ip_mreqn *imr) +int ip_mc_join_group_for_mode(struct sock *sk , struct ip_mreqn *imr, int omode) { int err; __be32 addr = imr->imr_multiaddr.s_addr; @@ -1826,15 +1838,15 @@ memcpy(&iml->multi, imr, sizeof(*imr)); iml->next_rcu = inet->mc_list; iml->sflist = NULL; - iml->sfmode = MCAST_EXCLUDE; + iml->sfmode = omode; rcu_assign_pointer(inet->mc_list, iml); - ip_mc_inc_group(in_dev, addr); + ip_mc_inc_group_for_mode(in_dev, addr, omode); err = 0; done: rtnl_unlock(); return err; } -EXPORT_SYMBOL(ip_mc_join_group); +EXPORT_SYMBOL(ip_mc_join_group_for_mode); static void ip_sf_socklist_reclaim(struct rcu_head *rp) { @@ -1842,6 +1854,12 @@ /* sk_omem_alloc should have been decreased by the caller*/ } +int ip_mc_join_group(struct sock *sk , struct ip_mreqn *imr) +{ + return ip_mc_join_group_for_mode(sk, imr, MCAST_EXCLUDE); +} +EXPORT_SYMBOL(ip_mc_join_group); + static int ip_mc_leave_src(struct sock *sk, struct ip_mc_socklist *iml, struct in_device *in_dev) { @@ -2266,9 +2284,10 @@ int i; int ret; - ret = 1; - if (!ipv4_is_multicast(loc_addr)) + if (!ipv4_is_multicast(loc_addr)) { + ret = sock_flag(sk, SOCK_BROADCAST) ? 1 : 0; goto out; + } rcu_read_lock(); for_each_pmc_rcu(inet, pmc) {