~ljy/RK356X_SDK_RELEASE.git

..	..	@@ -15,6 +15,11 @@
15	15	PAUSE_ON_CLEANUP=${PAUSE_ON_CLEANUP:=no}
16	16	NETIF_TYPE=${NETIF_TYPE:=veth}
17	17	NETIF_CREATE=${NETIF_CREATE:=yes}
	18	+MCD=${MCD:=smcrouted}
	19	+MC_CLI=${MC_CLI:=smcroutectl}
	20	+PING_TIMEOUT=${PING_TIMEOUT:=5}
	21	+WAIT_TIMEOUT=${WAIT_TIMEOUT:=20}
	22	+INTERFACE_TIMEOUT=${INTERFACE_TIMEOUT:=600}
18	23
19	24	relative_path="${BASH_SOURCE%/*}"
20	25	if [[ "$relative_path" == "${BASH_SOURCE}" ]]; then
..	..	@@ -51,6 +56,15 @@
51	56	tc help 2>&1\|grep chain &> /dev/null
52	57	if [[ $? -ne 0 ]]; then
53	58	echo "SKIP: iproute2 too old; tc is missing chain support"
	59	+ exit 1
	60	+ fi
	61	+}
	62	+
	63	+check_tc_action_hw_stats_support()
	64	+{
	65	+ tc actions help 2>&1 \| grep -q hw_stats
	66	+ if [[ $? -ne 0 ]]; then
	67	+ echo "SKIP: iproute2 too old; tc is missing action hw_stats support"
54	68	exit 1
55	69	fi
56	70	}
..	..	@@ -104,7 +118,7 @@
104	118	{
105	119	local i
106	120
107		- for i in $(eval echo {1..$NUM_NETIFS}); do
	121	+ for ((i = 1; i <= NUM_NETIFS; ++i)); do
108	122	local j=$((i+1))
109	123
110	124	ip link show dev ${NETIFS[p$i]} &> /dev/null
..	..	@@ -135,7 +149,7 @@
135	149	create_netif
136	150	fi
137	151
138		-for i in $(eval echo {1..$NUM_NETIFS}); do
	152	+for ((i = 1; i <= NUM_NETIFS; ++i)); do
139	153	ip link show dev ${NETIFS[p$i]} &> /dev/null
140	154	if [[ $? -ne 0 ]]; then
141	155	echo "SKIP: could not find all required interfaces"
..	..	@@ -209,7 +223,7 @@
209	223	return 1
210	224	fi
211	225
212		- printf "TEST: %-60s [PASS]\n" "$test_name $opt_str"
	226	+ printf "TEST: %-60s [ OK ]\n" "$test_name $opt_str"
213	227	return 0
214	228	}
215	229
..	..	@@ -220,31 +234,144 @@
220	234	echo "INFO: $msg"
221	235	}
222	236
	237	+busywait()
	238	+{
	239	+ local timeout=$1; shift
	240	+
	241	+ local start_time="$(date -u +%s%3N)"
	242	+ while true
	243	+ do
	244	+ local out
	245	+ out=$("$@")
	246	+ local ret=$?
	247	+ if ((!ret)); then
	248	+ echo -n "$out"
	249	+ return 0
	250	+ fi
	251	+
	252	+ local current_time="$(date -u +%s%3N)"
	253	+ if ((current_time - start_time > timeout)); then
	254	+ echo -n "$out"
	255	+ return 1
	256	+ fi
	257	+ done
	258	+}
	259	+
	260	+not()
	261	+{
	262	+ "$@"
	263	+ [[ $? != 0 ]]
	264	+}
	265	+
	266	+grep_bridge_fdb()
	267	+{
	268	+ local addr=$1; shift
	269	+ local word
	270	+ local flag
	271	+
	272	+ if [ "$1" == "self" ] \|\| [ "$1" == "master" ]; then
	273	+ word=$1; shift
	274	+ if [ "$1" == "-v" ]; then
	275	+ flag=$1; shift
	276	+ fi
	277	+ fi
	278	+
	279	+ $@ \| grep $addr \| grep $flag "$word"
	280	+}
	281	+
	282	+wait_for_offload()
	283	+{
	284	+ "$@" \| grep -q offload
	285	+}
	286	+
	287	+until_counter_is()
	288	+{
	289	+ local expr=$1; shift
	290	+ local current=$("$@")
	291	+
	292	+ echo $((current))
	293	+ ((current $expr))
	294	+}
	295	+
	296	+busywait_for_counter()
	297	+{
	298	+ local timeout=$1; shift
	299	+ local delta=$1; shift
	300	+
	301	+ local base=$("$@")
	302	+ busywait "$timeout" until_counter_is ">= $((base + delta))" "$@"
	303	+}
	304	+
223	305	setup_wait_dev()
224	306	{
225	307	local dev=$1; shift
	308	+ local wait_time=${1:-$WAIT_TIME}; shift
226	309
227		- while true; do
	310	+ setup_wait_dev_with_timeout "$dev" $INTERFACE_TIMEOUT $wait_time
	311	+
	312	+ if (($?)); then
	313	+ check_err 1
	314	+ log_test setup_wait_dev ": Interface $dev does not come up."
	315	+ exit 1
	316	+ fi
	317	+}
	318	+
	319	+setup_wait_dev_with_timeout()
	320	+{
	321	+ local dev=$1; shift
	322	+ local max_iterations=${1:-$WAIT_TIMEOUT}; shift
	323	+ local wait_time=${1:-$WAIT_TIME}; shift
	324	+ local i
	325	+
	326	+ for ((i = 1; i <= $max_iterations; ++i)); do
228	327	ip link show dev $dev up \
229	328	\| grep 'state UP' &> /dev/null
230	329	if [[ $? -ne 0 ]]; then
231	330	sleep 1
232	331	else
233		- break
	332	+ sleep $wait_time
	333	+ return 0
234	334	fi
235	335	done
	336	+
	337	+ return 1
236	338	}
237	339
238	340	setup_wait()
239	341	{
240	342	local num_netifs=${1:-$NUM_NETIFS}
	343	+ local i
241	344
242	345	for ((i = 1; i <= num_netifs; ++i)); do
243		- setup_wait_dev ${NETIFS[p$i]}
	346	+ setup_wait_dev ${NETIFS[p$i]} 0
244	347	done
245	348
246	349	# Make sure links are ready.
247	350	sleep $WAIT_TIME
	351	+}
	352	+
	353	+cmd_jq()
	354	+{
	355	+ local cmd=$1
	356	+ local jq_exp=$2
	357	+ local jq_opts=$3
	358	+ local ret
	359	+ local output
	360	+
	361	+ output="$($cmd)"
	362	+ # it the command fails, return error right away
	363	+ ret=$?
	364	+ if [[ $ret -ne 0 ]]; then
	365	+ return $ret
	366	+ fi
	367	+ output=$(echo $output \| jq -r $jq_opts "$jq_exp")
	368	+ ret=$?
	369	+ if [[ $ret -ne 0 ]]; then
	370	+ return $ret
	371	+ fi
	372	+ echo $output
	373	+ # return success only in case of non-empty output
	374	+ [ ! -z "$output" ]
248	375	}
249	376
250	377	lldpad_app_wait_set()
..	..	@@ -477,11 +604,24 @@
477	604	ip -j link show dev $if_name \| jq -r '.[]["master"]'
478	605	}
479	606
	607	+link_stats_get()
	608	+{
	609	+ local if_name=$1; shift
	610	+ local dir=$1; shift
	611	+ local stat=$1; shift
	612	+
	613	+ ip -j -s link show dev $if_name \
	614	+ \| jq '.[]["stats64"]["'$dir'"]["'$stat'"]'
	615	+}
	616	+
480	617	link_stats_tx_packets_get()
481	618	{
482		- local if_name=$1
	619	+ link_stats_get $1 tx packets
	620	+}
483	621
484		- ip -j -s link show dev $if_name \| jq '.[]["stats64"]["tx"]["packets"]'
	622	+link_stats_rx_errors_get()
	623	+{
	624	+ link_stats_get $1 rx errors
485	625	}
486	626
487	627	tc_rule_stats_get()
..	..	@@ -489,9 +629,81 @@
489	629	local dev=$1; shift
490	630	local pref=$1; shift
491	631	local dir=$1; shift
	632	+ local selector=${1:-.packets}; shift
492	633
493	634	tc -j -s filter show dev $dev ${dir:-ingress} pref $pref \
494		- \| jq '.[1].options.actions[].stats.packets'
	635	+ \| jq ".[1].options.actions[].stats$selector"
	636	+}
	637	+
	638	+tc_rule_handle_stats_get()
	639	+{
	640	+ local id=$1; shift
	641	+ local handle=$1; shift
	642	+ local selector=${1:-.packets}; shift
	643	+
	644	+ tc -j -s filter show $id \
	645	+ \| jq ".[] \| select(.options.handle == $handle) \| \
	646	+ .options.actions[0].stats$selector"
	647	+}
	648	+
	649	+ethtool_stats_get()
	650	+{
	651	+ local dev=$1; shift
	652	+ local stat=$1; shift
	653	+
	654	+ ethtool -S $dev \| grep "^ *$stat:" \| head -n 1 \| cut -d: -f2
	655	+}
	656	+
	657	+qdisc_stats_get()
	658	+{
	659	+ local dev=$1; shift
	660	+ local handle=$1; shift
	661	+ local selector=$1; shift
	662	+
	663	+ tc -j -s qdisc show dev "$dev" \
	664	+ \| jq '.[] \| select(.handle == "'"$handle"'") \| '"$selector"
	665	+}
	666	+
	667	+qdisc_parent_stats_get()
	668	+{
	669	+ local dev=$1; shift
	670	+ local parent=$1; shift
	671	+ local selector=$1; shift
	672	+
	673	+ tc -j -s qdisc show dev "$dev" invisible \
	674	+ \| jq '.[] \| select(.parent == "'"$parent"'") \| '"$selector"
	675	+}
	676	+
	677	+ipv6_stats_get()
	678	+{
	679	+ local dev=$1; shift
	680	+ local stat=$1; shift
	681	+
	682	+ cat /proc/net/dev_snmp6/$dev \| grep "^$stat" \| cut -f2
	683	+}
	684	+
	685	+humanize()
	686	+{
	687	+ local speed=$1; shift
	688	+
	689	+ for unit in bps Kbps Mbps Gbps; do
	690	+ if (($(echo "$speed < 1024" \| bc))); then
	691	+ break
	692	+ fi
	693	+
	694	+ speed=$(echo "scale=1; $speed / 1024" \| bc)
	695	+ done
	696	+
	697	+ echo "$speed${unit}"
	698	+}
	699	+
	700	+rate()
	701	+{
	702	+ local t0=$1; shift
	703	+ local t1=$1; shift
	704	+ local interval=$1; shift
	705	+
	706	+ echo $((8 * (t1 - t0) / interval))
495	707	}
496	708
497	709	mac_get()
..	..	@@ -539,6 +751,23 @@
539	751	{
540	752	sysctl_restore net.ipv6.conf.all.forwarding
541	753	sysctl_restore net.ipv4.conf.all.forwarding
	754	+}
	755	+
	756	+declare -A MTU_ORIG
	757	+mtu_set()
	758	+{
	759	+ local dev=$1; shift
	760	+ local mtu=$1; shift
	761	+
	762	+ MTU_ORIG["$dev"]=$(ip -j link show dev $dev \| jq -e '.[].mtu')
	763	+ ip link set dev $dev mtu $mtu
	764	+}
	765	+
	766	+mtu_restore()
	767	+{
	768	+ local dev=$1; shift
	769	+
	770	+ ip link set dev $dev mtu ${MTU_ORIG["$dev"]}
542	771	}
543	772
544	773	tc_offload_check()
..	..	@@ -758,6 +987,17 @@
758	987	log_info "Expected ratio $weights_ratio Measured ratio $packets_ratio"
759	988	}
760	989
	990	+in_ns()
	991	+{
	992	+ local name=$1; shift
	993	+
	994	+ ip netns exec $name bash <<-EOF
	995	+ NUM_NETIFS=0
	996	+ source lib.sh
	997	+ $(for a in "$@"; do printf "%q${IFS:0:1}" "$a"; done)
	998	+ EOF
	999	+}
	1000	+
761	1001	##############################################################################
762	1002	# Tests
763	1003
..	..	@@ -765,10 +1005,12 @@
765	1005	{
766	1006	local if_name=$1
767	1007	local dip=$2
	1008	+ local args=$3
768	1009	local vrf_name
769	1010
770	1011	vrf_name=$(master_name_get $if_name)
771		- ip vrf exec $vrf_name $PING $dip -c 10 -i 0.1 -w 2 &> /dev/null
	1012	+ ip vrf exec $vrf_name \
	1013	+ $PING $args $dip -c 10 -i 0.1 -w $PING_TIMEOUT &> /dev/null
772	1014	}
773	1015
774	1016	ping_test()
..	..	@@ -777,17 +1019,19 @@
777	1019
778	1020	ping_do $1 $2
779	1021	check_err $?
780		- log_test "ping"
	1022	+ log_test "ping$3"
781	1023	}
782	1024
783	1025	ping6_do()
784	1026	{
785	1027	local if_name=$1
786	1028	local dip=$2
	1029	+ local args=$3
787	1030	local vrf_name
788	1031
789	1032	vrf_name=$(master_name_get $if_name)
790		- ip vrf exec $vrf_name $PING6 $dip -c 10 -i 0.1 -w 2 &> /dev/null
	1033	+ ip vrf exec $vrf_name \
	1034	+ $PING6 $args $dip -c 10 -i 0.1 -w $PING_TIMEOUT &> /dev/null
791	1035	}
792	1036
793	1037	ping6_test()
..	..	@@ -796,7 +1040,7 @@
796	1040
797	1041	ping6_do $1 $2
798	1042	check_err $?
799		- log_test "ping6"
	1043	+ log_test "ping6$3"
800	1044	}
801	1045
802	1046	learning_test()
..	..	@@ -819,6 +1063,7 @@
819	1063	# FDB entry was installed.
820	1064	bridge link set dev $br_port1 flood off
821	1065
	1066	+ ip link set $host1_if promisc on
822	1067	tc qdisc add dev $host1_if ingress
823	1068	tc filter add dev $host1_if ingress protocol ip pref 1 handle 101 \
824	1069	flower dst_mac $mac action drop
..	..	@@ -829,7 +1074,7 @@
829	1074	tc -j -s filter show dev $host1_if ingress \
830	1075	\| jq -e ".[] \| select(.options.handle == 101) \
831	1076	\| select(.options.actions[0].stats.packets == 1)" &> /dev/null
832		- check_fail $? "Packet reached second host when should not"
	1077	+ check_fail $? "Packet reached first host when should not"
833	1078
834	1079	$MZ $host1_if -c 1 -p 64 -a $mac -t ip -q
835	1080	sleep 1
..	..	@@ -868,6 +1113,7 @@
868	1113
869	1114	tc filter del dev $host1_if ingress protocol ip pref 1 handle 101 flower
870	1115	tc qdisc del dev $host1_if ingress
	1116	+ ip link set $host1_if promisc off
871	1117
872	1118	bridge link set dev $br_port1 flood on
873	1119
..	..	@@ -885,6 +1131,7 @@
885	1131
886	1132	# Add an ACL on `host2_if` which will tell us whether the packet
887	1133	# was flooded to it or not.
	1134	+ ip link set $host2_if promisc on
888	1135	tc qdisc add dev $host2_if ingress
889	1136	tc filter add dev $host2_if ingress protocol ip pref 1 handle 101 \
890	1137	flower dst_mac $mac action drop
..	..	@@ -902,6 +1149,7 @@
902	1149
903	1150	tc filter del dev $host2_if ingress protocol ip pref 1 handle 101 flower
904	1151	tc qdisc del dev $host2_if ingress
	1152	+ ip link set $host2_if promisc off
905	1153
906	1154	return $err
907	1155	}
..	..	@@ -962,3 +1210,75 @@
962	1210	flood_unicast_test $br_port $host1_if $host2_if
963	1211	flood_multicast_test $br_port $host1_if $host2_if
964	1212	}
	1213	+
	1214	+__start_traffic()
	1215	+{
	1216	+ local proto=$1; shift
	1217	+ local h_in=$1; shift # Where the traffic egresses the host
	1218	+ local sip=$1; shift
	1219	+ local dip=$1; shift
	1220	+ local dmac=$1; shift
	1221	+
	1222	+ $MZ $h_in -p 8000 -A $sip -B $dip -c 0 \
	1223	+ -a own -b $dmac -t "$proto" -q "$@" &
	1224	+ sleep 1
	1225	+}
	1226	+
	1227	+start_traffic()
	1228	+{
	1229	+ __start_traffic udp "$@"
	1230	+}
	1231	+
	1232	+start_tcp_traffic()
	1233	+{
	1234	+ __start_traffic tcp "$@"
	1235	+}
	1236	+
	1237	+stop_traffic()
	1238	+{
	1239	+ # Suppress noise from killing mausezahn.
	1240	+ { kill %% && wait %%; } 2>/dev/null
	1241	+}
	1242	+
	1243	+tcpdump_start()
	1244	+{
	1245	+ local if_name=$1; shift
	1246	+ local ns=$1; shift
	1247	+
	1248	+ capfile=$(mktemp)
	1249	+ capout=$(mktemp)
	1250	+
	1251	+ if [ -z $ns ]; then
	1252	+ ns_cmd=""
	1253	+ else
	1254	+ ns_cmd="ip netns exec ${ns}"
	1255	+ fi
	1256	+
	1257	+ if [ -z $SUDO_USER ] ; then
	1258	+ capuser=""
	1259	+ else
	1260	+ capuser="-Z $SUDO_USER"
	1261	+ fi
	1262	+
	1263	+ $ns_cmd tcpdump -e -n -Q in -i $if_name \
	1264	+ -s 65535 -B 32768 $capuser -w $capfile > "$capout" 2>&1 &
	1265	+ cappid=$!
	1266	+
	1267	+ sleep 1
	1268	+}
	1269	+
	1270	+tcpdump_stop()
	1271	+{
	1272	+ $ns_cmd kill $cappid
	1273	+ sleep 1
	1274	+}
	1275	+
	1276	+tcpdump_cleanup()
	1277	+{
	1278	+ rm $capfile $capout
	1279	+}
	1280	+
	1281	+tcpdump_show()
	1282	+{
	1283	+ tcpdump -e -n -r $capfile 2>&1
	1284	+}