xref: /openbmc/linux/tools/testing/selftests/net/mptcp/mptcp_connect.sh (revision d699090510c3223641a23834b4710e2d4309a6ad)
1#!/bin/bash
2# SPDX-License-Identifier: GPL-2.0
3
4# Double quotes to prevent globbing and word splitting is recommended in new
5# code but we accept it, especially because there were too many before having
6# address all other issues detected by shellcheck.
7#shellcheck disable=SC2086
8
9. "$(dirname "${0}")/mptcp_lib.sh"
10
11time_start=$(date +%s)
12
13optstring="S:R:d:e:l:r:h4cm:f:tC"
14ret=0
15final_ret=0
16sin=""
17sout=""
18cin_disconnect=""
19cin=""
20cout=""
21capture=false
22timeout_poll=30
23timeout_test=$((timeout_poll * 2 + 1))
24ipv6=true
25ethtool_random_on=true
26tc_delay="$((RANDOM%50))"
27tc_loss=$((RANDOM%101))
28testmode=""
29sndbuf=0
30rcvbuf=0
31options_log=true
32do_tcp=0
33checksum=false
34filesize=0
35connect_per_transfer=1
36
37if [ $tc_loss -eq 100 ];then
38	tc_loss=1%
39elif [ $tc_loss -ge 10 ]; then
40	tc_loss=0.$tc_loss%
41elif [ $tc_loss -ge 1 ]; then
42	tc_loss=0.0$tc_loss%
43else
44	tc_loss=""
45fi
46
47usage() {
48	echo "Usage: $0 [ -a ]"
49	echo -e "\t-d: tc/netem delay in milliseconds, e.g. \"-d 10\" (default random)"
50	echo -e "\t-l: tc/netem loss percentage, e.g. \"-l 0.02\" (default random)"
51	echo -e "\t-r: tc/netem reorder mode, e.g. \"-r 25% 50% gap 5\", use "-r 0" to disable reordering (default random)"
52	echo -e "\t-e: ethtool features to disable, e.g.: \"-e tso -e gso\" (default: randomly disable any of tso/gso/gro)"
53	echo -e "\t-4: IPv4 only: disable IPv6 tests (default: test both IPv4 and IPv6)"
54	echo -e "\t-c: capture packets for each test using tcpdump (default: no capture)"
55	echo -e "\t-f: size of file to transfer in bytes (default random)"
56	echo -e "\t-S: set sndbuf value (default: use kernel default)"
57	echo -e "\t-R: set rcvbuf value (default: use kernel default)"
58	echo -e "\t-m: test mode (poll, sendfile; default: poll)"
59	echo -e "\t-t: also run tests with TCP (use twice to non-fallback tcp)"
60	echo -e "\t-C: enable the MPTCP data checksum"
61}
62
63while getopts "$optstring" option;do
64	case "$option" in
65	"h")
66		usage $0
67		exit 0
68		;;
69	"d")
70		if [ $OPTARG -ge 0 ];then
71			tc_delay="$OPTARG"
72		else
73			echo "-d requires numeric argument, got \"$OPTARG\"" 1>&2
74			exit 1
75		fi
76		;;
77	"e")
78		ethtool_args="$ethtool_args $OPTARG off"
79		ethtool_random_on=false
80		;;
81	"l")
82		tc_loss="$OPTARG"
83		;;
84	"r")
85		tc_reorder="$OPTARG"
86		;;
87	"4")
88		ipv6=false
89		;;
90	"c")
91		capture=true
92		;;
93	"S")
94		if [ $OPTARG -ge 0 ];then
95			sndbuf="$OPTARG"
96		else
97			echo "-S requires numeric argument, got \"$OPTARG\"" 1>&2
98			exit 1
99		fi
100		;;
101	"R")
102		if [ $OPTARG -ge 0 ];then
103			rcvbuf="$OPTARG"
104		else
105			echo "-R requires numeric argument, got \"$OPTARG\"" 1>&2
106			exit 1
107		fi
108		;;
109	"m")
110		testmode="$OPTARG"
111		;;
112	"f")
113		filesize="$OPTARG"
114		;;
115	"t")
116		do_tcp=$((do_tcp+1))
117		;;
118	"C")
119		checksum=true
120		;;
121	"?")
122		usage $0
123		exit 1
124		;;
125	esac
126done
127
128sec=$(date +%s)
129rndh=$(printf %x $sec)-$(mktemp -u XXXXXX)
130ns1="ns1-$rndh"
131ns2="ns2-$rndh"
132ns3="ns3-$rndh"
133ns4="ns4-$rndh"
134
135TEST_COUNT=0
136TEST_GROUP=""
137
138# This function is used in the cleanup trap
139#shellcheck disable=SC2317
140cleanup()
141{
142	rm -f "$cin_disconnect" "$cout_disconnect"
143	rm -f "$cin" "$cout"
144	rm -f "$sin" "$sout"
145	rm -f "$capout"
146
147	local netns
148	for netns in "$ns1" "$ns2" "$ns3" "$ns4";do
149		ip netns del $netns
150		rm -f /tmp/$netns.{nstat,out}
151	done
152}
153
154mptcp_lib_check_mptcp
155mptcp_lib_check_kallsyms
156
157ip -Version > /dev/null 2>&1
158if [ $? -ne 0 ];then
159	echo "SKIP: Could not run test without ip tool"
160	exit $ksft_skip
161fi
162
163sin=$(mktemp)
164sout=$(mktemp)
165cin=$(mktemp)
166cout=$(mktemp)
167capout=$(mktemp)
168cin_disconnect="$cin".disconnect
169cout_disconnect="$cout".disconnect
170trap cleanup EXIT
171
172for i in "$ns1" "$ns2" "$ns3" "$ns4";do
173	ip netns add $i || exit $ksft_skip
174	ip -net $i link set lo up
175done
176
177#  "$ns1"              ns2                    ns3                     ns4
178# ns1eth2    ns2eth1   ns2eth3      ns3eth2   ns3eth4       ns4eth3
179#                           - drop 1% ->            reorder 25%
180#                           <- TSO off -
181
182ip link add ns1eth2 netns "$ns1" type veth peer name ns2eth1 netns "$ns2"
183ip link add ns2eth3 netns "$ns2" type veth peer name ns3eth2 netns "$ns3"
184ip link add ns3eth4 netns "$ns3" type veth peer name ns4eth3 netns "$ns4"
185
186ip -net "$ns1" addr add 10.0.1.1/24 dev ns1eth2
187ip -net "$ns1" addr add dead:beef:1::1/64 dev ns1eth2 nodad
188
189ip -net "$ns1" link set ns1eth2 up
190ip -net "$ns1" route add default via 10.0.1.2
191ip -net "$ns1" route add default via dead:beef:1::2
192
193ip -net "$ns2" addr add 10.0.1.2/24 dev ns2eth1
194ip -net "$ns2" addr add dead:beef:1::2/64 dev ns2eth1 nodad
195ip -net "$ns2" link set ns2eth1 up
196
197ip -net "$ns2" addr add 10.0.2.1/24 dev ns2eth3
198ip -net "$ns2" addr add dead:beef:2::1/64 dev ns2eth3 nodad
199ip -net "$ns2" link set ns2eth3 up
200ip -net "$ns2" route add default via 10.0.2.2
201ip -net "$ns2" route add default via dead:beef:2::2
202ip netns exec "$ns2" sysctl -q net.ipv4.ip_forward=1
203ip netns exec "$ns2" sysctl -q net.ipv6.conf.all.forwarding=1
204
205ip -net "$ns3" addr add 10.0.2.2/24 dev ns3eth2
206ip -net "$ns3" addr add dead:beef:2::2/64 dev ns3eth2 nodad
207ip -net "$ns3" link set ns3eth2 up
208
209ip -net "$ns3" addr add 10.0.3.2/24 dev ns3eth4
210ip -net "$ns3" addr add dead:beef:3::2/64 dev ns3eth4 nodad
211ip -net "$ns3" link set ns3eth4 up
212ip -net "$ns3" route add default via 10.0.2.1
213ip -net "$ns3" route add default via dead:beef:2::1
214ip netns exec "$ns3" sysctl -q net.ipv4.ip_forward=1
215ip netns exec "$ns3" sysctl -q net.ipv6.conf.all.forwarding=1
216
217ip -net "$ns4" addr add 10.0.3.1/24 dev ns4eth3
218ip -net "$ns4" addr add dead:beef:3::1/64 dev ns4eth3 nodad
219ip -net "$ns4" link set ns4eth3 up
220ip -net "$ns4" route add default via 10.0.3.2
221ip -net "$ns4" route add default via dead:beef:3::2
222
223if $checksum; then
224	for i in "$ns1" "$ns2" "$ns3" "$ns4";do
225		ip netns exec $i sysctl -q net.mptcp.checksum_enabled=1
226	done
227fi
228
229set_ethtool_flags() {
230	local ns="$1"
231	local dev="$2"
232	local flags="$3"
233
234	if ip netns exec $ns ethtool -K $dev $flags 2>/dev/null; then
235		echo "INFO: set $ns dev $dev: ethtool -K $flags"
236	fi
237}
238
239set_random_ethtool_flags() {
240	local flags=""
241	local r=$RANDOM
242
243	local pick1=$((r & 1))
244	local pick2=$((r & 2))
245	local pick3=$((r & 4))
246
247	[ $pick1 -ne 0 ] && flags="tso off"
248	[ $pick2 -ne 0 ] && flags="$flags gso off"
249	[ $pick3 -ne 0 ] && flags="$flags gro off"
250
251	[ -z "$flags" ] && return
252
253	set_ethtool_flags "$1" "$2" "$flags"
254}
255
256if $ethtool_random_on;then
257	set_random_ethtool_flags "$ns3" ns3eth2
258	set_random_ethtool_flags "$ns4" ns4eth3
259else
260	set_ethtool_flags "$ns3" ns3eth2 "$ethtool_args"
261	set_ethtool_flags "$ns4" ns4eth3 "$ethtool_args"
262fi
263
264print_file_err()
265{
266	ls -l "$1" 1>&2
267	echo "Trailing bytes are: "
268	tail -c 27 "$1"
269}
270
271check_transfer()
272{
273	local in=$1
274	local out=$2
275	local what=$3
276
277	cmp "$in" "$out" > /dev/null 2>&1
278	if [ $? -ne 0 ] ;then
279		echo "[ FAIL ] $what does not match (in, out):"
280		print_file_err "$in"
281		print_file_err "$out"
282
283		return 1
284	fi
285
286	return 0
287}
288
289check_mptcp_disabled()
290{
291	local disabled_ns="ns_disabled-$rndh"
292	ip netns add ${disabled_ns} || exit $ksft_skip
293
294	# net.mptcp.enabled should be enabled by default
295	if [ "$(ip netns exec ${disabled_ns} sysctl net.mptcp.enabled | awk '{ print $3 }')" -ne 1 ]; then
296		echo -e "net.mptcp.enabled sysctl is not 1 by default\t\t[ FAIL ]"
297		mptcp_lib_result_fail "net.mptcp.enabled sysctl is not 1 by default"
298		ret=1
299		return 1
300	fi
301	ip netns exec ${disabled_ns} sysctl -q net.mptcp.enabled=0
302
303	local err=0
304	LC_ALL=C ip netns exec ${disabled_ns} ./mptcp_connect -p 10000 -s MPTCP 127.0.0.1 < "$cin" 2>&1 | \
305		grep -q "^socket: Protocol not available$" && err=1
306	ip netns delete ${disabled_ns}
307
308	if [ ${err} -eq 0 ]; then
309		echo -e "New MPTCP socket cannot be blocked via sysctl\t\t[ FAIL ]"
310		mptcp_lib_result_fail "New MPTCP socket cannot be blocked via sysctl"
311		ret=1
312		return 1
313	fi
314
315	echo -e "New MPTCP socket can be blocked via sysctl\t\t[ OK ]"
316	mptcp_lib_result_pass "New MPTCP socket can be blocked via sysctl"
317	return 0
318}
319
320do_ping()
321{
322	local listener_ns="$1"
323	local connector_ns="$2"
324	local connect_addr="$3"
325	local ping_args="-q -c 1"
326	local rc=0
327
328	if mptcp_lib_is_v6 "${connect_addr}"; then
329		$ipv6 || return 0
330		ping_args="${ping_args} -6"
331	fi
332
333	ip netns exec ${connector_ns} ping ${ping_args} $connect_addr >/dev/null || rc=1
334
335	if [ $rc -ne 0 ] ; then
336		echo "$listener_ns -> $connect_addr connectivity [ FAIL ]" 1>&2
337		ret=1
338
339		return 1
340	fi
341
342	return 0
343}
344
345do_transfer()
346{
347	local listener_ns="$1"
348	local connector_ns="$2"
349	local cl_proto="$3"
350	local srv_proto="$4"
351	local connect_addr="$5"
352	local local_addr="$6"
353	local extra_args="$7"
354
355	local port
356	port=$((10000+TEST_COUNT))
357	TEST_COUNT=$((TEST_COUNT+1))
358
359	if [ "$rcvbuf" -gt 0 ]; then
360		extra_args+=" -R $rcvbuf"
361	fi
362
363	if [ "$sndbuf" -gt 0 ]; then
364		extra_args+=" -S $sndbuf"
365	fi
366
367	if [ -n "$testmode" ]; then
368		extra_args+=" -m $testmode"
369	fi
370
371	if [ -n "$extra_args" ] && $options_log; then
372		echo "INFO: extra options: $extra_args"
373	fi
374	options_log=false
375
376	:> "$cout"
377	:> "$sout"
378	:> "$capout"
379
380	local addr_port
381	addr_port=$(printf "%s:%d" ${connect_addr} ${port})
382	local result_msg
383	result_msg="$(printf "%.3s %-5s -> %.3s (%-20s) %-5s" ${connector_ns} ${cl_proto} ${listener_ns} ${addr_port} ${srv_proto})"
384	printf "%s\t" "${result_msg}"
385
386	if $capture; then
387		local capuser
388		if [ -z $SUDO_USER ] ; then
389			capuser=""
390		else
391			capuser="-Z $SUDO_USER"
392		fi
393
394		local capfile="${rndh}-${connector_ns:0:3}-${listener_ns:0:3}-${cl_proto}-${srv_proto}-${connect_addr}-${port}"
395		local capopt="-i any -s 65535 -B 32768 ${capuser}"
396
397		ip netns exec ${listener_ns}  tcpdump ${capopt} -w "${capfile}-listener.pcap"  >> "${capout}" 2>&1 &
398		local cappid_listener=$!
399
400		ip netns exec ${connector_ns} tcpdump ${capopt} -w "${capfile}-connector.pcap" >> "${capout}" 2>&1 &
401		local cappid_connector=$!
402
403		sleep 1
404	fi
405
406	NSTAT_HISTORY=/tmp/${listener_ns}.nstat ip netns exec ${listener_ns} \
407		nstat -n
408	if [ ${listener_ns} != ${connector_ns} ]; then
409		NSTAT_HISTORY=/tmp/${connector_ns}.nstat ip netns exec ${connector_ns} \
410			nstat -n
411	fi
412
413	local stat_synrx_last_l
414	local stat_ackrx_last_l
415	local stat_cookietx_last
416	local stat_cookierx_last
417	local stat_csum_err_s
418	local stat_csum_err_c
419	local stat_tcpfb_last_l
420	stat_synrx_last_l=$(mptcp_lib_get_counter "${listener_ns}" "MPTcpExtMPCapableSYNRX")
421	stat_ackrx_last_l=$(mptcp_lib_get_counter "${listener_ns}" "MPTcpExtMPCapableACKRX")
422	stat_cookietx_last=$(mptcp_lib_get_counter "${listener_ns}" "TcpExtSyncookiesSent")
423	stat_cookierx_last=$(mptcp_lib_get_counter "${listener_ns}" "TcpExtSyncookiesRecv")
424	stat_csum_err_s=$(mptcp_lib_get_counter "${listener_ns}" "MPTcpExtDataCsumErr")
425	stat_csum_err_c=$(mptcp_lib_get_counter "${connector_ns}" "MPTcpExtDataCsumErr")
426	stat_tcpfb_last_l=$(mptcp_lib_get_counter "${listener_ns}" "MPTcpExtMPCapableFallbackACK")
427
428	timeout ${timeout_test} \
429		ip netns exec ${listener_ns} \
430			./mptcp_connect -t ${timeout_poll} -l -p $port -s ${srv_proto} \
431				$extra_args $local_addr < "$sin" > "$sout" &
432	local spid=$!
433
434	mptcp_lib_wait_local_port_listen "${listener_ns}" "${port}"
435
436	local start
437	start=$(date +%s%3N)
438	timeout ${timeout_test} \
439		ip netns exec ${connector_ns} \
440			./mptcp_connect -t ${timeout_poll} -p $port -s ${cl_proto} \
441				$extra_args $connect_addr < "$cin" > "$cout" &
442	local cpid=$!
443
444	wait $cpid
445	local retc=$?
446	wait $spid
447	local rets=$?
448
449	local stop
450	stop=$(date +%s%3N)
451
452	if $capture; then
453		sleep 1
454		kill ${cappid_listener}
455		kill ${cappid_connector}
456	fi
457
458	NSTAT_HISTORY=/tmp/${listener_ns}.nstat ip netns exec ${listener_ns} \
459		nstat | grep Tcp > /tmp/${listener_ns}.out
460	if [ ${listener_ns} != ${connector_ns} ]; then
461		NSTAT_HISTORY=/tmp/${connector_ns}.nstat ip netns exec ${connector_ns} \
462			nstat | grep Tcp > /tmp/${connector_ns}.out
463	fi
464
465	local duration
466	duration=$((stop-start))
467	result_msg+=" # time=${duration}ms"
468	printf "(duration %05sms) " "${duration}"
469	if [ ${rets} -ne 0 ] || [ ${retc} -ne 0 ]; then
470		echo "[ FAIL ] client exit code $retc, server $rets" 1>&2
471		echo -e "\nnetns ${listener_ns} socket stat for ${port}:" 1>&2
472		ip netns exec ${listener_ns} ss -Menita 1>&2 -o "sport = :$port"
473		cat /tmp/${listener_ns}.out
474		echo -e "\nnetns ${connector_ns} socket stat for ${port}:" 1>&2
475		ip netns exec ${connector_ns} ss -Menita 1>&2 -o "dport = :$port"
476		[ ${listener_ns} != ${connector_ns} ] && cat /tmp/${connector_ns}.out
477
478		echo
479		cat "$capout"
480		mptcp_lib_result_fail "${TEST_GROUP}: ${result_msg}"
481		return 1
482	fi
483
484	check_transfer $sin $cout "file received by client"
485	retc=$?
486	check_transfer $cin $sout "file received by server"
487	rets=$?
488
489	local extra=""
490	local stat_synrx_now_l
491	local stat_ackrx_now_l
492	local stat_cookietx_now
493	local stat_cookierx_now
494	local stat_ooo_now
495	local stat_tcpfb_now_l
496	stat_synrx_now_l=$(mptcp_lib_get_counter "${listener_ns}" "MPTcpExtMPCapableSYNRX")
497	stat_ackrx_now_l=$(mptcp_lib_get_counter "${listener_ns}" "MPTcpExtMPCapableACKRX")
498	stat_cookietx_now=$(mptcp_lib_get_counter "${listener_ns}" "TcpExtSyncookiesSent")
499	stat_cookierx_now=$(mptcp_lib_get_counter "${listener_ns}" "TcpExtSyncookiesRecv")
500	stat_ooo_now=$(mptcp_lib_get_counter "${listener_ns}" "TcpExtTCPOFOQueue")
501	stat_tcpfb_now_l=$(mptcp_lib_get_counter "${listener_ns}" "MPTcpExtMPCapableFallbackACK")
502
503	expect_synrx=$((stat_synrx_last_l))
504	expect_ackrx=$((stat_ackrx_last_l))
505
506	cookies=$(ip netns exec ${listener_ns} sysctl net.ipv4.tcp_syncookies)
507	cookies=${cookies##*=}
508
509	if [ ${cl_proto} = "MPTCP" ] && [ ${srv_proto} = "MPTCP" ]; then
510		expect_synrx=$((stat_synrx_last_l+connect_per_transfer))
511		expect_ackrx=$((stat_ackrx_last_l+connect_per_transfer))
512	fi
513
514	if [ ${stat_synrx_now_l} -lt ${expect_synrx} ]; then
515		printf "[ FAIL ] lower MPC SYN rx (%d) than expected (%d)\n" \
516			"${stat_synrx_now_l}" "${expect_synrx}" 1>&2
517		retc=1
518	fi
519	if [ ${stat_ackrx_now_l} -lt ${expect_ackrx} ] && [ ${stat_ooo_now} -eq 0 ]; then
520		if [ ${stat_ooo_now} -eq 0 ]; then
521			printf "[ FAIL ] lower MPC ACK rx (%d) than expected (%d)\n" \
522				"${stat_ackrx_now_l}" "${expect_ackrx}" 1>&2
523			rets=1
524		else
525			extra+=" [ Note ] fallback due to TCP OoO"
526		fi
527	fi
528
529	if $checksum; then
530		local csum_err_s
531		local csum_err_c
532		csum_err_s=$(mptcp_lib_get_counter "${listener_ns}" "MPTcpExtDataCsumErr")
533		csum_err_c=$(mptcp_lib_get_counter "${connector_ns}" "MPTcpExtDataCsumErr")
534
535		local csum_err_s_nr=$((csum_err_s - stat_csum_err_s))
536		if [ $csum_err_s_nr -gt 0 ]; then
537			printf "[ FAIL ]\nserver got %d data checksum error[s]" ${csum_err_s_nr}
538			rets=1
539		fi
540
541		local csum_err_c_nr=$((csum_err_c - stat_csum_err_c))
542		if [ $csum_err_c_nr -gt 0 ]; then
543			printf "[ FAIL ]\nclient got %d data checksum error[s]" ${csum_err_c_nr}
544			retc=1
545		fi
546	fi
547
548	if [ ${stat_ooo_now} -eq 0 ] && [ ${stat_tcpfb_last_l} -ne ${stat_tcpfb_now_l} ]; then
549		mptcp_lib_pr_fail "unexpected fallback to TCP"
550		rets=1
551	fi
552
553	if [ $cookies -eq 2 ];then
554		if [ $stat_cookietx_last -ge $stat_cookietx_now ] ;then
555			extra+=" WARN: CookieSent: did not advance"
556		fi
557		if [ $stat_cookierx_last -ge $stat_cookierx_now ] ;then
558			extra+=" WARN: CookieRecv: did not advance"
559		fi
560	else
561		if [ $stat_cookietx_last -ne $stat_cookietx_now ] ;then
562			extra+=" WARN: CookieSent: changed"
563		fi
564		if [ $stat_cookierx_last -ne $stat_cookierx_now ] ;then
565			extra+=" WARN: CookieRecv: changed"
566		fi
567	fi
568
569	if [ ${stat_synrx_now_l} -gt ${expect_synrx} ]; then
570		extra+=" WARN: SYNRX: expect ${expect_synrx},"
571		extra+=" got ${stat_synrx_now_l} (probably retransmissions)"
572	fi
573	if [ ${stat_ackrx_now_l} -gt ${expect_ackrx} ]; then
574		extra+=" WARN: ACKRX: expect ${expect_ackrx},"
575		extra+=" got ${stat_ackrx_now_l} (probably retransmissions)"
576	fi
577
578	if [ $retc -eq 0 ] && [ $rets -eq 0 ]; then
579		printf "[ OK ]%s\n" "${extra}"
580		mptcp_lib_result_pass "${TEST_GROUP}: ${result_msg}"
581	else
582		if [ -n "${extra}" ]; then
583			printf "%s\n" "${extra:1}"
584		fi
585		mptcp_lib_result_fail "${TEST_GROUP}: ${result_msg}"
586	fi
587
588	cat "$capout"
589	[ $retc -eq 0 ] && [ $rets -eq 0 ]
590}
591
592make_file()
593{
594	local name=$1
595	local who=$2
596	local SIZE=$filesize
597	local ksize
598	local rem
599
600	if [ $SIZE -eq 0 ]; then
601		local MAXSIZE=$((1024 * 1024 * 8))
602		local MINSIZE=$((1024 * 256))
603
604		SIZE=$(((RANDOM * RANDOM + MINSIZE) % MAXSIZE))
605	fi
606
607	ksize=$((SIZE / 1024))
608	rem=$((SIZE - (ksize * 1024)))
609
610	dd if=/dev/urandom of="$name" bs=1024 count=$ksize 2> /dev/null
611	dd if=/dev/urandom conv=notrunc of="$name" bs=1 count=$rem 2> /dev/null
612	echo -e "\nMPTCP_TEST_FILE_END_MARKER" >> "$name"
613
614	echo "Created $name (size $(du -b "$name")) containing data sent by $who"
615}
616
617run_tests_lo()
618{
619	local listener_ns="$1"
620	local connector_ns="$2"
621	local connect_addr="$3"
622	local loopback="$4"
623	local extra_args="$5"
624	local lret=0
625
626	# skip if test programs are running inside same netns for subsequent runs.
627	if [ $loopback -eq 0 ] && [ ${listener_ns} = ${connector_ns} ]; then
628		return 0
629	fi
630
631	# skip if we don't want v6
632	if ! $ipv6 && mptcp_lib_is_v6 "${connect_addr}"; then
633		return 0
634	fi
635
636	local local_addr
637	if mptcp_lib_is_v6 "${connect_addr}"; then
638		local_addr="::"
639	else
640		local_addr="0.0.0.0"
641	fi
642
643	do_transfer ${listener_ns} ${connector_ns} MPTCP MPTCP \
644		    ${connect_addr} ${local_addr} "${extra_args}"
645	lret=$?
646	if [ $lret -ne 0 ]; then
647		ret=$lret
648		return 1
649	fi
650
651	if [ $do_tcp -eq 0 ]; then
652		# don't bother testing fallback tcp except for loopback case.
653		if [ ${listener_ns} != ${connector_ns} ]; then
654			return 0
655		fi
656	fi
657
658	do_transfer ${listener_ns} ${connector_ns} MPTCP TCP \
659		    ${connect_addr} ${local_addr} "${extra_args}"
660	lret=$?
661	if [ $lret -ne 0 ]; then
662		ret=$lret
663		return 1
664	fi
665
666	do_transfer ${listener_ns} ${connector_ns} TCP MPTCP \
667		    ${connect_addr} ${local_addr} "${extra_args}"
668	lret=$?
669	if [ $lret -ne 0 ]; then
670		ret=$lret
671		return 1
672	fi
673
674	if [ $do_tcp -gt 1 ] ;then
675		do_transfer ${listener_ns} ${connector_ns} TCP TCP \
676			    ${connect_addr} ${local_addr} "${extra_args}"
677		lret=$?
678		if [ $lret -ne 0 ]; then
679			ret=$lret
680			return 1
681		fi
682	fi
683
684	return 0
685}
686
687run_tests()
688{
689	run_tests_lo $1 $2 $3 0
690}
691
692run_test_transparent()
693{
694	local connect_addr="$1"
695	local msg="$2"
696
697	local connector_ns="$ns1"
698	local listener_ns="$ns2"
699	local lret=0
700	local r6flag=""
701
702	TEST_GROUP="${msg}"
703
704	# skip if we don't want v6
705	if ! $ipv6 && mptcp_lib_is_v6 "${connect_addr}"; then
706		return 0
707	fi
708
709	# IP(V6)_TRANSPARENT has been added after TOS support which came with
710	# the required infrastructure in MPTCP sockopt code. To support TOS, the
711	# following function has been exported (T). Not great but better than
712	# checking for a specific kernel version.
713	if ! mptcp_lib_kallsyms_has "T __ip_sock_set_tos$"; then
714		echo "INFO: ${msg} not supported by the kernel: SKIP"
715		mptcp_lib_result_skip "${TEST_GROUP}"
716		return
717	fi
718
719	if ! ip netns exec "$listener_ns" nft -f /dev/stdin <<"EOF"
720flush ruleset
721table inet mangle {
722	chain divert {
723		type filter hook prerouting priority -150;
724
725		meta l4proto tcp socket transparent 1 meta mark set 1 accept
726		tcp dport 20000 tproxy to :20000 meta mark set 1 accept
727	}
728}
729EOF
730	then
731		echo "SKIP: $msg, could not load nft ruleset"
732		mptcp_lib_fail_if_expected_feature "nft rules"
733		mptcp_lib_result_skip "${TEST_GROUP}"
734		return
735	fi
736
737	local local_addr
738	if mptcp_lib_is_v6 "${connect_addr}"; then
739		local_addr="::"
740		r6flag="-6"
741	else
742		local_addr="0.0.0.0"
743	fi
744
745	if ! ip -net "$listener_ns" $r6flag rule add fwmark 1 lookup 100; then
746		ip netns exec "$listener_ns" nft flush ruleset
747		echo "SKIP: $msg, ip $r6flag rule failed"
748		mptcp_lib_fail_if_expected_feature "ip rule"
749		mptcp_lib_result_skip "${TEST_GROUP}"
750		return
751	fi
752
753	if ! ip -net "$listener_ns" route add local $local_addr/0 dev lo table 100; then
754		ip netns exec "$listener_ns" nft flush ruleset
755		ip -net "$listener_ns" $r6flag rule del fwmark 1 lookup 100
756		echo "SKIP: $msg, ip route add local $local_addr failed"
757		mptcp_lib_fail_if_expected_feature "ip route"
758		mptcp_lib_result_skip "${TEST_GROUP}"
759		return
760	fi
761
762	echo "INFO: test $msg"
763
764	TEST_COUNT=10000
765	local extra_args="-o TRANSPARENT"
766	do_transfer ${listener_ns} ${connector_ns} MPTCP MPTCP \
767		    ${connect_addr} ${local_addr} "${extra_args}"
768	lret=$?
769
770	ip netns exec "$listener_ns" nft flush ruleset
771	ip -net "$listener_ns" $r6flag rule del fwmark 1 lookup 100
772	ip -net "$listener_ns" route del local $local_addr/0 dev lo table 100
773
774	if [ $lret -ne 0 ]; then
775		echo "FAIL: $msg, mptcp connection error" 1>&2
776		ret=$lret
777		return 1
778	fi
779
780	echo "PASS: $msg"
781	return 0
782}
783
784run_tests_peekmode()
785{
786	local peekmode="$1"
787
788	TEST_GROUP="peek mode: ${peekmode}"
789	echo "INFO: with peek mode: ${peekmode}"
790	run_tests_lo "$ns1" "$ns1" 10.0.1.1 1 "-P ${peekmode}"
791	run_tests_lo "$ns1" "$ns1" dead:beef:1::1 1 "-P ${peekmode}"
792}
793
794run_tests_mptfo()
795{
796	TEST_GROUP="MPTFO"
797
798	if ! mptcp_lib_kallsyms_has "mptcp_fastopen_"; then
799		echo "INFO: TFO not supported by the kernel: SKIP"
800		mptcp_lib_result_skip "${TEST_GROUP}"
801		return
802	fi
803
804	echo "INFO: with MPTFO start"
805	ip netns exec "$ns1" sysctl -q net.ipv4.tcp_fastopen=2
806	ip netns exec "$ns2" sysctl -q net.ipv4.tcp_fastopen=1
807
808	run_tests_lo "$ns1" "$ns2" 10.0.1.1 0 "-o MPTFO"
809	run_tests_lo "$ns1" "$ns2" 10.0.1.1 0 "-o MPTFO"
810
811	run_tests_lo "$ns1" "$ns2" dead:beef:1::1 0 "-o MPTFO"
812	run_tests_lo "$ns1" "$ns2" dead:beef:1::1 0 "-o MPTFO"
813
814	ip netns exec "$ns1" sysctl -q net.ipv4.tcp_fastopen=0
815	ip netns exec "$ns2" sysctl -q net.ipv4.tcp_fastopen=0
816	echo "INFO: with MPTFO end"
817}
818
819run_tests_disconnect()
820{
821	local old_cin=$cin
822	local old_sin=$sin
823
824	TEST_GROUP="full disconnect"
825
826	if ! mptcp_lib_kallsyms_has "mptcp_pm_data_reset$"; then
827		echo "INFO: Full disconnect not supported: SKIP"
828		mptcp_lib_result_skip "${TEST_GROUP}"
829		return
830	fi
831
832	cat $cin $cin $cin > "$cin".disconnect
833
834	# force do_transfer to cope with the multiple transmissions
835	sin="$cin.disconnect"
836	cin="$cin.disconnect"
837	cin_disconnect="$old_cin"
838	connect_per_transfer=3
839
840	echo "INFO: disconnect"
841	run_tests_lo "$ns1" "$ns1" 10.0.1.1 1 "-I 3 -i $old_cin"
842	run_tests_lo "$ns1" "$ns1" dead:beef:1::1 1 "-I 3 -i $old_cin"
843
844	# restore previous status
845	sin=$old_sin
846	cin=$old_cin
847	cin_disconnect="$cin".disconnect
848	connect_per_transfer=1
849}
850
851display_time()
852{
853	time_end=$(date +%s)
854	time_run=$((time_end-time_start))
855
856	echo "Time: ${time_run} seconds"
857}
858
859log_if_error()
860{
861	local msg="$1"
862
863	if [ ${ret} -ne 0 ]; then
864		echo "FAIL: ${msg}" 1>&2
865
866		final_ret=${ret}
867		ret=0
868
869		return ${final_ret}
870	fi
871}
872
873stop_if_error()
874{
875	if ! log_if_error "${@}"; then
876		display_time
877		mptcp_lib_result_print_all_tap
878		exit ${final_ret}
879	fi
880}
881
882make_file "$cin" "client"
883make_file "$sin" "server"
884
885check_mptcp_disabled
886
887stop_if_error "The kernel configuration is not valid for MPTCP"
888
889echo "INFO: validating network environment with pings"
890for sender in "$ns1" "$ns2" "$ns3" "$ns4";do
891	do_ping "$ns1" $sender 10.0.1.1
892	do_ping "$ns1" $sender dead:beef:1::1
893
894	do_ping "$ns2" $sender 10.0.1.2
895	do_ping "$ns2" $sender dead:beef:1::2
896	do_ping "$ns2" $sender 10.0.2.1
897	do_ping "$ns2" $sender dead:beef:2::1
898
899	do_ping "$ns3" $sender 10.0.2.2
900	do_ping "$ns3" $sender dead:beef:2::2
901	do_ping "$ns3" $sender 10.0.3.2
902	do_ping "$ns3" $sender dead:beef:3::2
903
904	do_ping "$ns4" $sender 10.0.3.1
905	do_ping "$ns4" $sender dead:beef:3::1
906done
907
908mptcp_lib_result_code "${ret}" "ping tests"
909
910stop_if_error "Could not even run ping tests"
911
912[ -n "$tc_loss" ] && tc -net "$ns2" qdisc add dev ns2eth3 root netem loss random $tc_loss delay ${tc_delay}ms
913tc_info="loss of $tc_loss "
914test "$tc_delay" -gt 0 && tc_info+="delay $tc_delay ms "
915
916reorder_delay=$((tc_delay / 4))
917
918if [ -z "${tc_reorder}" ]; then
919	reorder1=$((RANDOM%10))
920	reorder1=$((100 - reorder1))
921	reorder2=$((RANDOM%100))
922
923	if [ $reorder_delay -gt 0 ] && [ $reorder1 -lt 100 ] && [ $reorder2 -gt 0 ]; then
924		tc_reorder="reorder ${reorder1}% ${reorder2}%"
925		tc_info+="$tc_reorder with delay ${reorder_delay}ms "
926	fi
927elif [ "$tc_reorder" = "0" ];then
928	tc_reorder=""
929elif [ "$reorder_delay" -gt 0 ];then
930	# reordering requires some delay
931	tc_reorder="reorder $tc_reorder"
932	tc_info+="$tc_reorder with delay ${reorder_delay}ms "
933fi
934
935echo "INFO: Using ${tc_info}on ns3eth4"
936
937tc -net "$ns3" qdisc add dev ns3eth4 root netem delay ${reorder_delay}ms $tc_reorder
938
939TEST_GROUP="loopback v4"
940run_tests_lo "$ns1" "$ns1" 10.0.1.1 1
941stop_if_error "Could not even run loopback test"
942
943TEST_GROUP="loopback v6"
944run_tests_lo "$ns1" "$ns1" dead:beef:1::1 1
945stop_if_error "Could not even run loopback v6 test"
946
947TEST_GROUP="multihosts"
948for sender in $ns1 $ns2 $ns3 $ns4;do
949	# ns1<->ns2 is not subject to reordering/tc delays. Use it to test
950	# mptcp syncookie support.
951	if [ $sender = $ns1 ]; then
952		ip netns exec "$ns2" sysctl -q net.ipv4.tcp_syncookies=2
953	else
954		ip netns exec "$ns2" sysctl -q net.ipv4.tcp_syncookies=1
955	fi
956
957	run_tests "$ns1" $sender 10.0.1.1
958	run_tests "$ns1" $sender dead:beef:1::1
959
960	run_tests "$ns2" $sender 10.0.1.2
961	run_tests "$ns2" $sender dead:beef:1::2
962	run_tests "$ns2" $sender 10.0.2.1
963	run_tests "$ns2" $sender dead:beef:2::1
964
965	run_tests "$ns3" $sender 10.0.2.2
966	run_tests "$ns3" $sender dead:beef:2::2
967	run_tests "$ns3" $sender 10.0.3.2
968	run_tests "$ns3" $sender dead:beef:3::2
969
970	run_tests "$ns4" $sender 10.0.3.1
971	run_tests "$ns4" $sender dead:beef:3::1
972
973	log_if_error "Tests with $sender as a sender have failed"
974done
975
976run_tests_peekmode "saveWithPeek"
977run_tests_peekmode "saveAfterPeek"
978log_if_error "Tests with peek mode have failed"
979
980# MPTFO (MultiPath TCP Fatopen tests)
981run_tests_mptfo
982log_if_error "Tests with MPTFO have failed"
983
984# connect to ns4 ip address, ns2 should intercept/proxy
985run_test_transparent 10.0.3.1 "tproxy ipv4"
986run_test_transparent dead:beef:3::1 "tproxy ipv6"
987log_if_error "Tests with tproxy have failed"
988
989run_tests_disconnect
990log_if_error "Tests of the full disconnection have failed"
991
992display_time
993mptcp_lib_result_print_all_tap
994exit ${final_ret}
995