From 3a2674270b950e3823423157809a2f3ce1ef74ff Mon Sep 17 00:00:00 2001
From: Rahul Thakur <rahul.thakur@iopsys.eu>
Date: Wed, 21 Jun 2023 15:59:13 +0530
Subject: [PATCH] mcastmngr: implement snoop mode for linux targets

---
 mcastmngr/files/linux/lib/mcast/linux.sh | 39 +++++++++++++++++++++++-
 1 file changed, 38 insertions(+), 1 deletion(-)

diff --git a/mcastmngr/files/linux/lib/mcast/linux.sh b/mcastmngr/files/linux/lib/mcast/linux.sh
index 43b609a49..272c4746e 100755
--- a/mcastmngr/files/linux/lib/mcast/linux.sh
+++ b/mcastmngr/files/linux/lib/mcast/linux.sh
@@ -11,7 +11,40 @@ PROG_PARAMS=
 PROG_PARAMS_SEPARATOR=:
 
 setup_mcast_mode() {
-	 unused(){ :;}
+	local snooped_interface=$1
+	local mcast_mode=$2
+
+	local mcast_flood=
+	local devsec=
+	local sectype=
+	local devtype=
+	local ports=
+	if [ -z "$snooped_interface" ]; then
+		return
+	fi
+
+	if [ $mcast_mode == "2" ]; then # disable mcast flood
+		mcast_flood=0
+	else
+		mcast_flood=1
+	fi
+
+	for intf in $snooped_interface;
+	do
+		devsec="$(uci show network | grep name=.*$intf | cut -d'.' -f2)"
+		sectype="$(uci -q get network.$devsec)"
+		devtype="$(uci -q get network.$devsec.type)"
+		if [ "$sectype" == "device" -a "$devtype" == "bridge" ]; then
+			ports="$(uci get network.$devsec.ports)"
+			for prt in $ports; do
+				echo $mcast_flood > /sys/class/net/$prt/brport/multicast_flood
+			done
+		else
+			if [ -f  /sys/class/net/$intf/brport/multicast_flood ]; then
+				echo $mcast_flood > /sys/class/net/$intf/brport/multicast_flood
+			fi
+		fi
+	done
 }
 
 config_mcproxy_interfaces() {
@@ -97,6 +130,7 @@ config_mcproxy_instance() {
 	local upstreams=
 	local downstreams=
 	local intf_has_ip=
+	local mcast_mode=2 # default value 2 is for blocking mode
 
 	CONFFILE=/var/etc/mcproxy_"$protocol".conf
 	rm -f $CONFFILE
@@ -121,6 +155,7 @@ config_mcproxy_instance() {
 
 		upstreams=$igmp_p_up_interfaces
 		downstreams=$igmp_p_down_interfaces
+		mcast_mode=$igmp_p_mode
 	elif [ "$protocol" == "mld" ]; then
 		case "$version" in
 			[1-2])
@@ -140,6 +175,7 @@ config_mcproxy_instance() {
 
 		upstreams=$mld_p_up_interfaces
 		downstreams=$mld_p_down_interfaces
+		mcast_mode=$mld_p_mode
 	fi
 
 	# for snooping to work we should enable it on the bridge, doing it from
@@ -156,6 +192,7 @@ config_mcproxy_instance() {
 		config_sysfs_mcast_fastleave $fast_leave
 	fi
 
+	setup_mcast_mode $downstreams $mcast_mode
 	[ -n "$upstreams" ] && [ -n "$downstreams" ] &&
 		config_mcproxy_interfaces "$upstreams" "$downstreams" "$exceptions"