From: Geliang Tang <geliangtang@gmail.com>
To: Kishen Maloor <kishen.maloor@intel.com>
Cc: MPTCP Upstream <mptcp@lists.linux.dev>
Subject: Re: [PATCH mptcp-next v3 14/14] selftests: mptcp: functional tests for the userspace PM type
Date: Fri, 28 Jan 2022 14:51:21 +0800 [thread overview]
Message-ID: <CA+WQbwvJOa3iJ8BucsMUPho-=eBQziemvneM_Ld82gOC0f4Zwg@mail.gmail.com> (raw)
In-Reply-To: <20220128003836.2732694-15-kishen.maloor@intel.com>
Hi Kishen,
This patch will get many checkpatch.pl warnings:
WARNING: line length of 103 exceeds 100 columns
Thanks,
-Geliang
Kishen Maloor <kishen.maloor@intel.com> 于2022年1月28日周五 08:39写道：
>
> This change adds a selftest script that performs a comprehensive
> behavioral/functional test of all userspace PM capabilities by exercising
> all the newly added APIs and changes to support said capabilities.
>
> Signed-off-by: Kishen Maloor <kishen.maloor@intel.com>
> ---
> v3: configure net.mptcp.userspace_pm_local_addr_max via sysctl on
> the namespaces established for testing, read and verify the new
> "server_side" attribute from netlink events upon connection
> establishment, new test case for sysctl configured local_addr limit,
> added descriptive remarks throughout script
> ---
> .../selftests/net/mptcp/userspace_pm.sh | 656 ++++++++++++++++++
> 1 file changed, 656 insertions(+)
> create mode 100755 tools/testing/selftests/net/mptcp/userspace_pm.sh
>
> diff --git a/tools/testing/selftests/net/mptcp/userspace_pm.sh b/tools/testing/selftests/net/mptcp/userspace_pm.sh
> new file mode 100755
> index 000000000000..cc6c03626c21
> --- /dev/null
> +++ b/tools/testing/selftests/net/mptcp/userspace_pm.sh
> @@ -0,0 +1,656 @@
> +#!/bin/bash
> +# SPDX-License-Identifier: GPL-2.0
> +
> +ip -Version > /dev/null 2>&1
> +if [ $? -ne 0 ];then
> + echo "SKIP: Cannot not run test without ip tool"
> + exit 1
> +fi
> +
> +ANNOUNCED=6 # MPTCP_EVENT_ANNOUNCED
> +REMOVED=7 # MPTCP_EVENT_REMOVED
> +SUB_ESTABLISHED=10 # MPTCP_EVENT_SUB_ESTABLISHED
> +SUB_CLOSED=11 # MPTCP_EVENT_SUB_CLOSED
> +
> +AF_INET=2
> +AF_INET6=10
> +
> +evts_pid=0
> +client4_pid=0
> +server4_pid=0
> +client6_pid=0
> +server6_pid=0
> +client4_token=""
> +server4_token=""
> +client6_token=""
> +server6_token=""
> +client4_port=0;
> +client6_port=0;
> +app4_port=50002
> +new4_port=50003
> +app6_port=50004
> +client_addr_id=${RANDOM:0:2}
> +server_addr_id=${RANDOM:0:2}
> +
> +sec=$(date +%s)
> +rndh=$(printf %x $sec)-$(mktemp -u XXXXXX)
> +ns1="ns1-$rndh"
> +ns2="ns2-$rndh"
> +
> +cleanup()
> +{
> + echo "cleanup"
> +
> + # Terminate the MPTCP connection and related processes
> + kill -SIGUSR1 $client4_pid > /dev/null 2>&1
> + kill $server4_pid > /dev/null 2>&1
> + kill -SIGUSR1 $client6_pid > /dev/null 2>&1
> + kill $server6_pid > /dev/null 2>&1
> +
> + kill $evts_pid > /dev/null 2>&1
> +
> + local netns
> + for netns in "$ns1" "$ns2" ;do
> + ip netns del $netns
> + done
> +}
> +
> +trap cleanup EXIT
> +
> +# Create and configure network namespaces for testing
> +for i in "$ns1" "$ns2" ;do
> + ip netns add $i || exit 1
> + ip -net $i link set lo up
> + ip netns exec $i sysctl -q net.mptcp.enabled=1
> + ip netns exec $i sysctl -q net.mptcp.pm_type=1
> + ip netns exec $i sysctl -q net.mptcp.userspace_pm_local_addr_max=2
> +done
> +
> +# "$ns1" ns2
> +# ns1eth2 ns2eth1
> +
> +ip link add ns1eth2 netns "$ns1" type veth peer name ns2eth1 netns "$ns2"
> +
> +# Add IPv4/v6 addresses to the namespaces
> +ip -net "$ns1" addr add 10.0.1.1/24 dev ns1eth2
> +ip -net "$ns1" addr add 10.0.2.1/24 dev ns1eth2
> +ip -net "$ns1" addr add dead:beef:1::1/64 dev ns1eth2 nodad
> +ip -net "$ns1" addr add dead:beef:2::1/64 dev ns1eth2 nodad
> +ip -net "$ns1" link set ns1eth2 up
> +
> +ip -net "$ns2" addr add 10.0.1.2/24 dev ns2eth1
> +ip -net "$ns2" addr add 10.0.2.2/24 dev ns2eth1
> +ip -net "$ns2" addr add dead:beef:1::2/64 dev ns2eth1 nodad
> +ip -net "$ns2" addr add dead:beef:2::2/64 dev ns2eth1 nodad
> +ip -net "$ns2" link set ns2eth1 up
> +
> +printf "Created network namespaces ns1, ns2 \t\t\t[OK]\n"
> +
> +make_file()
> +{
> + # Store a chunk of data in a file to transmit over an MPTCP connection
> + local name=$1
> + local who=$2
> + local ksize=1
> +
> + dd if=/dev/urandom of="$name" bs=1024 count=$ksize 2> /dev/null
> + echo -e "\nMPTCP_TEST_FILE_END_MARKER" >> "$name"
> +}
> +
> +make_connection()
> +{
> + local file=$(mktemp)
> + make_file "$file" "client"
> +
> + local is_v6=$1
> + local app_port=$app4_port
> + local connect_addr="10.0.1.1"
> + local listen_addr="0.0.0.0"
> + if [ "$is_v6" = "v6" ]
> + then
> + connect_addr="dead:beef:1::1"
> + listen_addr="::"
> + app_port=$app6_port
> + else
> + is_v6="v4"
> + fi
> +
> + # Capture netlink events over the two network namespaces running
> + # the MPTCP client and server
> + local client_evts=$(mktemp)
> + :>"$client_evts"
> + ip netns exec $ns2 ./pm_nl_ctl events >> "$client_evts" 2>&1 &
> + local client_evts_pid=$!
> + local server_evts=$(mktemp)
> + :>"$server_evts"
> + ip netns exec $ns1 ./pm_nl_ctl events >> "$server_evts" 2>&1 &
> + local server_evts_pid=$!
> + sleep 0.1
> +
> + # Run the server
> + ip netns exec $ns1 \
> + ./mptcp_connect -s MPTCP -w 300 -p $app_port -l $listen_addr 2>&1 > /dev/null &
> + local server_pid=$!
> + sleep 0.1
> +
> + # Run the client, transfer $file and stay connected to the server
> + # to conduct tests
> + ip netns exec $ns2 \
> + ./mptcp_connect -s MPTCP -w 300 -m sendfile -p $app_port $connect_addr 2>&1 > /dev/null < $file &
> + local client_pid=$!
> + sleep 0.1
> +
> + # Capture client/server attributes from MPTCP connection netlink events
> + kill $client_evts_pid
> + local client_token=$(sed -n 's/.*\(token:\)\([[:digit:]]*\).*$/\2/p;q' "$client_evts")
> + local client_port=$(sed -n 's/.*\(sport:\)\([[:digit:]]*\).*$/\2/p;q' "$client_evts")
> + local client_serverside=$(sed -n 's/.*\(server_side:\)\([[:digit:]]*\).*$/\2/p;q' "$client_evts")
> +
> + kill $server_evts_pid
> + local server_token=$(sed -n 's/.*\(token:\)\([[:digit:]]*\).*$/\2/p;q' "$server_evts")
> + local server_serverside=$(sed -n 's/.*\(server_side:\)\([[:digit:]]*\).*$/\2/p;q' "$server_evts")
> +
> + rm -f "$client_evts" "$server_evts" "$file"
> +
> + if [ $client_token != "" ] && [ $server_token != "" ] && [ $client_serverside = 0 ] && [ $server_serverside = 1 ]
> + then
> + printf "Established IP%s MPTCP Connection ns2 => ns1 \t\t[OK]\n" $is_v6
> + else
> + exit 1
> + fi
> +
> + if [ "$is_v6" = "v6" ]
> + then
> + client6_token=$client_token
> + server6_token=$server_token
> + client6_port=$client_port
> + client6_pid=$client_pid
> + server6_pid=$server_pid
> + else
> + client4_token=$client_token
> + server4_token=$server_token
> + client4_port=$client_port
> + client4_pid=$client_pid
> + server4_pid=$server_pid
> + fi
> +}
> +
> +verify_announce_event()
> +{
> + local evt=$1
> + local e_type=$2
> + local e_token=$3
> + local e_addr=$4
> + local e_id=$5
> + local e_dport=$6
> + local e_af=$7
> +
> + local type=$(sed -n 's/.*\(type:\)\([[:digit:]]*\).*$/\2/p;q' "$evt")
> + local token=$(sed -n 's/.*\(token:\)\([[:digit:]]*\).*$/\2/p;q' "$evt")
> + local addr=""
> + if [ "$e_af" = "v6" ]
> + then
> + addr=$(sed -n 's/.*\(daddr6:\)\([0-9a-f:.]*\).*$/\2/p;q' "$evt")
> + else
> + addr=$(sed -n 's/.*\(daddr4:\)\([0-9.]*\).*$/\2/p;q' "$evt")
> + fi
> + local dport=$(sed -n 's/.*\(dport:\)\([[:digit:]]*\).*$/\2/p;q' "$evt")
> + local id=$(sed -n 's/.*\(rem_id:\)\([[:digit:]]*\).*$/\2/p;q' "$evt")
> + if [ "$type" = "$e_type" ] && [ "$token" = "$e_token" ] && [ "$addr" = "$e_addr" ] && [ "$dport" = "$e_dport" ] && [ "$id" = "$e_id" ]
> + then
> + printf "[OK]\n"
> + return 0
> + fi
> + printf "[FAIL]\n"
> + exit 1
> +}
> +
> +test_announce()
> +{
> + local evts=$(mktemp)
> + # Capture events on the network namespace running the server
> + :>"$evts"
> + ip netns exec $ns1 ./pm_nl_ctl events >> "$evts" 2>&1 &
> + evts_pid=$!
> + sleep 0.1
> +
> + # ADD_ADDR using an invalid token should result in no action
> + local invalid_token=$(( $client4_token - 1))
> + ip netns exec $ns2 ./pm_nl_ctl ann 10.0.2.2 token $invalid_token id $client_addr_id dev ns2eth1 2>&1 > /dev/null
> + local type=$(sed -n 's/.*\(type:\)\([[:digit:]]*\).*$/\2/p;q' "$evts")
> + printf "ADD_ADDR 10.0.2.2 (ns2) => ns1, invalid token \t\t"
> + if [ "$type" = "" ]
> + then
> + printf "[OK]\n"
> + else
> + printf "[FAIL]\n"
> + exit 1
> + fi
> +
> + # ADD_ADDR from the client to server machine reusing the subflow port
> + :>"$evts"
> + ip netns exec $ns2 ./pm_nl_ctl ann 10.0.2.2 token $client4_token id $client_addr_id dev ns2eth1 2>&1 > /dev/null
> + printf "ADD_ADDR id:%d 10.0.2.2 (ns2) => ns1, reuse port \t\t" $client_addr_id
> + sleep 0.1
> + verify_announce_event "$evts" "$ANNOUNCED" "$server4_token" "10.0.2.2" "$client_addr_id" "$client4_port"
> +
> + # ADD_ADDR6 from the client to server machine reusing the subflow port
> + :>"$evts"
> + ip netns exec $ns2 ./pm_nl_ctl ann dead:beef:2::2 token $client6_token id $client_addr_id dev ns2eth1 2>&1 > /dev/null
> + printf "ADD_ADDR6 id:%d dead:beef:2::2 (ns2) => ns1, reuse port\t\t" $client_addr_id
> + sleep 0.1
> + verify_announce_event "$evts" "$ANNOUNCED" "$server6_token" "dead:beef:2::2" "$client_addr_id" "$client6_port" "v6"
> +
> + # ADD_ADDR from the client to server machine using a new port
> + :>"$evts"
> + client_addr_id=$((client_addr_id+1))
> + ip netns exec $ns2 ./pm_nl_ctl ann 10.0.2.2 token $client4_token id $client_addr_id dev ns2eth1 port $new4_port 2>&1 > /dev/null
> + printf "ADD_ADDR id:%d 10.0.2.2 (ns2) => ns1, new port \t\t\t" $client_addr_id
> + sleep 0.1
> + verify_announce_event "$evts" "$ANNOUNCED" "$server4_token" "10.0.2.2" "$client_addr_id" "$new4_port"
> +
> + kill $evts_pid
> +
> + # Capture events on the network namespace running the client
> + :>"$evts"
> + ip netns exec $ns2 ./pm_nl_ctl events >> "$evts" 2>&1 &
> + evts_pid=$!
> + sleep 0.1
> +
> + # ADD_ADDR from the server to client machine reusing the subflow port
> + ip netns exec $ns1 ./pm_nl_ctl ann 10.0.2.1 token $server4_token id $server_addr_id dev ns1eth2 2>&1 > /dev/null
> + printf "ADD_ADDR id:%d 10.0.2.1 (ns1) => ns2, reuse port \t\t" $server_addr_id
> + sleep 0.1
> + verify_announce_event "$evts" "$ANNOUNCED" "$client4_token" "10.0.2.1" "$server_addr_id" "$app4_port"
> +
> + # ADD_ADDR6 from the server to client machine reusing the subflow port
> + :>"$evts"
> + ip netns exec $ns1 ./pm_nl_ctl ann dead:beef:2::1 token $server6_token id $server_addr_id dev ns1eth2 2>&1 > /dev/null
> + printf "ADD_ADDR6 id:%d dead:beef:2::1 (ns1) => ns2, reuse port\t\t" $server_addr_id
> + sleep 0.1
> + verify_announce_event "$evts" "$ANNOUNCED" "$client6_token" "dead:beef:2::1" "$server_addr_id" "$app6_port" "v6"
> +
> + # ADD_ADDR from the server to client machine using a new port
> + :>"$evts"
> + server_addr_id=$((server_addr_id+1))
> + ip netns exec $ns1 ./pm_nl_ctl ann 10.0.2.1 token $server4_token id $server_addr_id dev ns1eth2 port $new4_port 2>&1 > /dev/null
> + printf "ADD_ADDR id:%d 10.0.2.1 (ns1) => ns2, new port \t\t\t" $server_addr_id
> + sleep 0.1
> + verify_announce_event "$evts" "$ANNOUNCED" "$client4_token" "10.0.2.1" "$server_addr_id" "$new4_port"
> +
> + kill $evts_pid
> + rm -f "$evts"
> +}
> +
> +verify_remove_event()
> +{
> + local evt=$1
> + local e_type=$2
> + local e_token=$3
> + local e_id=$4
> +
> + local type=$(sed -n 's/.*\(type:\)\([[:digit:]]*\).*$/\2/p;q' "$evt")
> + local token=$(sed -n 's/.*\(token:\)\([[:digit:]]*\).*$/\2/p;q' "$evt")
> + local id=$(sed -n 's/.*\(rem_id:\)\([[:digit:]]*\).*$/\2/p;q' "$evt")
> + if [ "$type" = "$e_type" ] && [ "$token" = "$e_token" ] && [ "$id" = "$e_id" ]
> + then
> + printf "[OK]\n"
> + return 0
> + fi
> + printf "[FAIL]\n"
> + exit 1
> +}
> +
> +test_remove()
> +{
> + local evts=$(mktemp)
> +
> + # Capture events on the network namespace running the server
> + :>"$evts"
> + ip netns exec $ns1 ./pm_nl_ctl events >> "$evts" 2>&1 &
> + evts_pid=$!
> + sleep 0.1
> +
> + # RM_ADDR using an invalid token should result in no action
> + local invalid_token=$(( $client4_token - 1 ))
> + ip netns exec $ns2 ./pm_nl_ctl rem token $invalid_token id $client_addr_id 2>&1 > /dev/null
> + printf "RM_ADDR id:%d ns2 => ns1, invalid token \t" $client_addr_id
> + local type=$(sed -n 's/.*\(type:\)\([[:digit:]]*\).*$/\2/p;q' "$evts")
> + if [ "$type" = "" ]
> + then
> + printf "[OK]\n"
> + else
> + printf "[FAIL]\n"
> + fi
> +
> + # RM_ADDR using an invalid addr id should result in no action
> + local invalid_id=$(( $client_addr_id + 1 ))
> + ip netns exec $ns2 ./pm_nl_ctl rem token $client4_token id $invalid_id 2>&1 > /dev/null
> + printf "RM_ADDR id:%d ns2 => ns1, invalid id \t" $invalid_id
> + type=$(sed -n 's/.*\(type:\)\([[:digit:]]*\).*$/\2/p;q' "$evts")
> + if [ "$type" = "" ]
> + then
> + printf "[OK]\n"
> + else
> + printf "[FAIL]\n"
> + fi
> +
> + # RM_ADDR from the client to server machine
> + :>"$evts"
> + ip netns exec $ns2 ./pm_nl_ctl rem token $client4_token id $client_addr_id 2>&1 > /dev/null
> + printf "RM_ADDR id:%d ns2 => ns1 \t" $client_addr_id
> + sleep 0.1
> + verify_remove_event "$evts" "$REMOVED" "$server4_token" "$client_addr_id"
> +
> + # RM_ADDR from the client to server machine
> + :>"$evts"
> + client_addr_id=$(( $client_addr_id - 1 ))
> + ip netns exec $ns2 ./pm_nl_ctl rem token $client4_token id $client_addr_id 2>&1 > /dev/null
> + printf "RM_ADDR id:%d ns2 => ns1 \t" $client_addr_id
> + sleep 0.1
> + verify_remove_event "$evts" "$REMOVED" "$server4_token" "$client_addr_id"
> +
> + # RM_ADDR6 from the client to server machine
> + :>"$evts"
> + ip netns exec $ns2 ./pm_nl_ctl rem token $client6_token id $client_addr_id 2>&1 > /dev/null
> + printf "RM_ADDR6 id:%d ns2 => ns1 \t" $client_addr_id
> + sleep 0.1
> + verify_remove_event "$evts" "$REMOVED" "$server6_token" "$client_addr_id"
> +
> + kill $evts_pid
> +
> + # Capture events on the network namespace running the client
> + :>"$evts"
> + ip netns exec $ns2 ./pm_nl_ctl events >> "$evts" 2>&1 &
> + evts_pid=$!
> + sleep 0.1
> +
> + # RM_ADDR from the server to client machine
> + ip netns exec $ns1 ./pm_nl_ctl rem token $server4_token id $server_addr_id 2>&1 > /dev/null
> + printf "RM_ADDR id:%d ns1 => ns2 \t" $server_addr_id
> + sleep 0.1
> + verify_remove_event "$evts" "$REMOVED" "$client4_token" "$server_addr_id"
> +
> + # RM_ADDR from the server to client machine
> + :>"$evts"
> + server_addr_id=$(( $server_addr_id - 1 ))
> + ip netns exec $ns1 ./pm_nl_ctl rem token $server4_token id $server_addr_id 2>&1 > /dev/null
> + printf "RM_ADDR id:%d ns1 => ns2 \t" $server_addr_id
> + sleep 0.1
> + verify_remove_event "$evts" "$REMOVED" "$client4_token" "$server_addr_id"
> +
> + # RM_ADDR6 from the server to client machine
> + :>"$evts"
> + ip netns exec $ns1 ./pm_nl_ctl rem token $server6_token id $server_addr_id 2>&1 > /dev/null
> + printf "RM_ADDR6 id:%d ns1 => ns2 \t" $server_addr_id
> + sleep 0.1
> + verify_remove_event "$evts" "$REMOVED" "$client6_token" "$server_addr_id"
> +
> + kill $evts_pid
> + rm -f "$evts"
> +}
> +
> +verify_subflow_events()
> +{
> + local evt=$1
> + local e_type=$2
> + local e_token=$3
> + local e_family=$4
> + local e_saddr=$5
> + local e_daddr=$6
> + local e_dport=$7
> + local e_locid=$8
> + local e_remid=$9
> + shift 2
> + local e_from=$8
> + local e_to=$9
> +
> + if [ "$e_type" = "$SUB_ESTABLISHED" ]
> + then
> + if [ "$e_family" = "$AF_INET6" ]
> + then
> + printf "CREATE_SUBFLOW6 %s (%s) => %s (%s) " $e_saddr $e_from $e_daddr $e_to
> + else
> + printf "CREATE_SUBFLOW %s (%s) => %s (%s) \t" $e_saddr $e_from $e_daddr $e_to
> + fi
> + else
> + if [ "$e_family" = "$AF_INET6" ]
> + then
> + printf "DESTROY_SUBFLOW6 %s (%s) => %s (%s) " $e_saddr $e_from $e_daddr $e_to
> + else
> + printf "DESTROY_SUBFLOW %s (%s) => %s (%s) \t" $e_saddr $e_from $e_daddr $e_to
> + fi
> + fi
> +
> + local type=$(sed -n 's/.*\(type:\)\([[:digit:]]*\).*$/\2/p;q' "$evt")
> + local token=$(sed -n 's/.*\(token:\)\([[:digit:]]*\).*$/\2/p;q' "$evt")
> + local family=$(sed -n 's/.*\(family:\)\([[:digit:]]*\).*$/\2/p;q' "$evt")
> + local dport=$(sed -n 's/.*\(dport:\)\([[:digit:]]*\).*$/\2/p;q' "$evt")
> + local locid=$(sed -n 's/.*\(loc_id:\)\([[:digit:]]*\).*$/\2/p;q' "$evt")
> + local remid=$(sed -n 's/.*\(rem_id:\)\([[:digit:]]*\).*$/\2/p;q' "$evt")
> + local saddr=""
> + local daddr=""
> + if [ "$family" = "$AF_INET6" ]
> + then
> + saddr=$(sed -n 's/.*\(saddr6:\)\([0-9a-f:.]*\).*$/\2/p;q' "$evt")
> + daddr=$(sed -n 's/.*\(daddr6:\)\([0-9a-f:.]*\).*$/\2/p;q' "$evt")
> + else
> + saddr=$(sed -n 's/.*\(saddr4:\)\([0-9.]*\).*$/\2/p;q' "$evt")
> + daddr=$(sed -n 's/.*\(daddr4:\)\([0-9.]*\).*$/\2/p;q' "$evt")
> + fi
> +
> + if [ "$type" = "$e_type" ] && [ "$token" = "$e_token" ] && [ "$daddr" = "$e_daddr" ] && [ "$e_dport" = "$dport" ] && [ "$family" = "$e_family" ] && [ "$saddr" = "$e_saddr" ] && [ "$e_locid" = "$locid" ] && [ "$e_remid" = "$remid" ]
> + then
> + printf "[OK]\n"
> + return 0
> + fi
> + printf "[FAIL]\n"
> + exit 1
> +}
> +
> +test_subflows()
> +{
> + local evts=$(mktemp)
> + # Capture events on the network namespace running the server
> + :>"$evts"
> + ip netns exec $ns1 ./pm_nl_ctl events >> "$evts" 2>&1 &
> + evts_pid=$!
> + sleep 0.1
> +
> + # ADD_ADDR from client to server machine reusing the subflow port
> + ip netns exec $ns2 ./pm_nl_ctl ann 10.0.2.2 token $client4_token id $client_addr_id 2>&1 > /dev/null
> + sleep 0.1
> +
> + # CREATE_SUBFLOW from server to client machine
> + :>"$evts"
> + ip netns exec $ns1 ./pm_nl_ctl csf lip 10.0.2.1 lid 23 rip 10.0.2.2 rport $client4_port token $server4_token 2>&1 > /dev/null
> + sleep 0.1
> + verify_subflow_events "$evts" "$SUB_ESTABLISHED" "$server4_token" "$AF_INET" "10.0.2.1" "10.0.2.2" "$client4_port" "23" "$client_addr_id" "ns1" "ns2"
> +
> + local sport=$(sed -n 's/.*\(sport:\)\([[:digit:]]*\).*$/\2/p;q' "$evts")
> +
> + # DESTROY_SUBFLOW from server to client machine
> + :>"$evts"
> + ip netns exec $ns1 ./pm_nl_ctl dsf lip 10.0.2.1 lport $sport rip 10.0.2.2 rport $client4_port token $server4_token 2>&1 > /dev/null
> + sleep 0.1
> + verify_subflow_events "$evts" "$SUB_CLOSED" "$server4_token" "$AF_INET" "10.0.2.1" "10.0.2.2" "$client4_port" "23" "$client_addr_id" "ns1" "ns2"
> +
> + # RM_ADDR from client to server machine
> + ip netns exec $ns2 ./pm_nl_ctl rem id $client_addr_id token $client4_token 2>&1 > /dev/null
> + sleep 0.1
> +
> + # ADD_ADDR6 from client to server machine reusing the subflow port
> + :>"$evts"
> + ip netns exec $ns2 ./pm_nl_ctl ann dead:beef:2::2 token $client6_token id $client_addr_id 2>&1 > /dev/null
> + sleep 0.1
> +
> + # CREATE_SUBFLOW6 from server to client machine
> + :>"$evts"
> + ip netns exec $ns1 ./pm_nl_ctl csf lip dead:beef:2::1 lid 23 rip dead:beef:2::2 rport $client6_port token $server6_token 2>&1 > /dev/null
> + sleep 0.1
> + verify_subflow_events "$evts" "$SUB_ESTABLISHED" "$server6_token" "$AF_INET6" "dead:beef:2::1" "dead:beef:2::2" "$client6_port" "23" "$client_addr_id" "ns1" "ns2"
> +
> + local sport=$(sed -n 's/.*\(sport:\)\([[:digit:]]*\).*$/\2/p;q' "$evts")
> +
> + # DESTROY_SUBFLOW6 from server to client machine
> + :>"$evts"
> + ip netns exec $ns1 ./pm_nl_ctl dsf lip dead:beef:2::1 lport $sport rip dead:beef:2::2 rport $client6_port token $server6_token 2>&1 > /dev/null
> + sleep 0.1
> + verify_subflow_events "$evts" "$SUB_CLOSED" "$server6_token" "$AF_INET6" "dead:beef:2::1" "dead:beef:2::2" "$client6_port" "23" "$client_addr_id" "ns1" "ns2"
> +
> + # RM_ADDR from client to server machine
> + ip netns exec $ns2 ./pm_nl_ctl rem id $client_addr_id token $client6_token 2>&1 > /dev/null
> + sleep 0.1
> +
> + # ADD_ADDR from client to server machine using a new port
> + :>"$evts"
> + ip netns exec $ns2 ./pm_nl_ctl ann 10.0.2.2 token $client4_token id $client_addr_id port $new4_port 2>&1 > /dev/null
> + sleep 0.1
> +
> + # CREATE_SUBFLOW from server to client machine
> + :>"$evts"
> + ip netns exec $ns1 ./pm_nl_ctl csf lip 10.0.2.1 lid 23 rip 10.0.2.2 rport $new4_port token $server4_token 2>&1 > /dev/null
> + sleep 0.1
> + verify_subflow_events "$evts" "$SUB_ESTABLISHED" "$server4_token" "$AF_INET" "10.0.2.1" "10.0.2.2" "$new4_port" "23" "$client_addr_id" "ns1" "ns2"
> +
> + sport=$(sed -n 's/.*\(sport:\)\([[:digit:]]*\).*$/\2/p;q' "$evts")
> +
> + # DESTROY_SUBFLOW from server to client machine
> + :>"$evts"
> + ip netns exec $ns1 ./pm_nl_ctl dsf lip 10.0.2.1 lport $sport rip 10.0.2.2 rport $new4_port token $server4_token 2>&1 > /dev/null
> + sleep 0.1
> + verify_subflow_events "$evts" "$SUB_CLOSED" "$server4_token" "$AF_INET" "10.0.2.1" "10.0.2.2" "$new4_port" "23" "$client_addr_id" "ns1" "ns2"
> +
> + # RM_ADDR from client to server machine
> + ip netns exec $ns2 ./pm_nl_ctl rem id $client_addr_id token $client4_token 2>&1 > /dev/null
> +
> + kill $evts_pid
> +
> + # Capture events on the network namespace running the client
> + :>"$evts"
> + ip netns exec $ns2 ./pm_nl_ctl events >> "$evts" 2>&1 &
> + evts_pid=$!
> + sleep 0.1
> +
> + # ADD_ADDR from server to client machine reusing the subflow port
> + ip netns exec $ns1 ./pm_nl_ctl ann 10.0.2.1 token $server4_token id $server_addr_id 2>&1 > /dev/null
> + sleep 0.1
> +
> + # CREATE_SUBFLOW from client to server machine
> + :>"$evts"
> + ip netns exec $ns2 ./pm_nl_ctl csf lip 10.0.2.2 lid 23 rip 10.0.2.1 rport $app4_port token $client4_token 2>&1 > /dev/null
> + sleep 0.1
> + verify_subflow_events "$evts" "$SUB_ESTABLISHED" "$client4_token" "$AF_INET" "10.0.2.2" "10.0.2.1" "$app4_port" "23" "$server_addr_id" "ns2" "ns1"
> +
> + sport=$(sed -n 's/.*\(sport:\)\([[:digit:]]*\).*$/\2/p;q' "$evts")
> +
> + # DESTROY_SUBFLOW from client to server machine
> + :>"$evts"
> + ip netns exec $ns2 ./pm_nl_ctl dsf lip 10.0.2.2 lport $sport rip 10.0.2.1 rport $app4_port token $client4_token 2>&1 > /dev/null
> + sleep 0.1
> + verify_subflow_events "$evts" "$SUB_CLOSED" "$client4_token" "$AF_INET" "10.0.2.2" "10.0.2.1" "$app4_port" "23" "$server_addr_id" "ns2" "ns1"
> +
> + # RM_ADDR from server to client machine
> + ip netns exec $ns1 ./pm_nl_ctl rem id $server_addr_id token $server4_token 2>&1 > /dev/null
> + sleep 0.1
> +
> + # ADD_ADDR6 from server to client machine reusing the subflow port
> + :>"$evts"
> + ip netns exec $ns1 ./pm_nl_ctl ann dead:beef:2::1 token $server6_token id $server_addr_id 2>&1 > /dev/null
> + sleep 0.1
> +
> + # CREATE_SUBFLOW6 from client to server machine
> + :>"$evts"
> + ip netns exec $ns2 ./pm_nl_ctl csf lip dead:beef:2::2 lid 23 rip dead:beef:2::1 rport $app6_port token $client6_token 2>&1 > /dev/null
> + sleep 0.1
> + verify_subflow_events "$evts" "$SUB_ESTABLISHED" "$client6_token" "$AF_INET6" "dead:beef:2::2" "dead:beef:2::1" "$app6_port" "23" "$server_addr_id" "ns2" "ns1"
> +
> + local sport=$(sed -n 's/.*\(sport:\)\([[:digit:]]*\).*$/\2/p;q' "$evts")
> +
> + # DESTROY_SUBFLOW6 from client to server machine
> + :>"$evts"
> + ip netns exec $ns2 ./pm_nl_ctl dsf lip dead:beef:2::2 lport $sport rip dead:beef:2::1 rport $app6_port token $client6_token 2>&1 > /dev/null
> + sleep 0.1
> + verify_subflow_events "$evts" "$SUB_CLOSED" "$client6_token" "$AF_INET6" "dead:beef:2::2" "dead:beef:2::1" "$app6_port" "23" "$server_addr_id" "ns2" "ns1"
> +
> + # RM_ADDR6 from server to client machine
> + ip netns exec $ns1 ./pm_nl_ctl rem id $server_addr_id token $server6_token 2>&1 > /dev/null
> + sleep 0.1
> +
> + # ADD_ADDR from client to server machine using a new port
> + :>"$evts"
> + ip netns exec $ns1 ./pm_nl_ctl ann 10.0.2.1 token $server4_token id $server_addr_id port $new4_port 2>&1 > /dev/null
> + sleep 0.1
> +
> + # CREATE_SUBFLOW from client to server machine
> + :>"$evts"
> + ip netns exec $ns2 ./pm_nl_ctl csf lip 10.0.2.2 lid 23 rip 10.0.2.1 rport $new4_port token $client4_token 2>&1 > /dev/null
> + sleep 0.1
> + verify_subflow_events "$evts" "$SUB_ESTABLISHED" "$client4_token" "$AF_INET" "10.0.2.2" "10.0.2.1" "$new4_port" "23" "$server_addr_id" "ns2" "ns1"
> +
> + sport=$(sed -n 's/.*\(sport:\)\([[:digit:]]*\).*$/\2/p;q' "$evts")
> +
> + # DESTROY_SUBFLOW from client to server machine
> + :>"$evts"
> + ip netns exec $ns2 ./pm_nl_ctl dsf lip 10.0.2.2 lport $sport rip 10.0.2.1 rport $new4_port token $client4_token 2>&1 > /dev/null
> + sleep 0.1
> + verify_subflow_events "$evts" "$SUB_CLOSED" "$client4_token" "$AF_INET" "10.0.2.2" "10.0.2.1" "$new4_port" "23" "$server_addr_id" "ns2" "ns1"
> +
> + # RM_ADDR from server to client machine
> + ip netns exec $ns1 ./pm_nl_ctl rem id $server_addr_id token $server4_token 2>&1 > /dev/null
> +
> + kill $evts_pid
> + rm -f "$evts"
> +}
> +
> +test_local_addr_limit()
> +{
> + printf "Test sysctl: net.mptcp.userspace_pm_local_addr_max=1\t\t"
> + # Limit the # of local addrs for both namespaces to 1
> + for i in "$ns1" "$ns2" ;do
> + ip netns exec $i sysctl -q net.mptcp.userspace_pm_local_addr_max=1
> + done
> +
> + local evts=$(mktemp)
> + # Capture events from the network namespace running the server
> + :>"$evts"
> + ip netns exec $ns1 ./pm_nl_ctl events >> "$evts" 2>&1 &
> + evts_pid=$!
> + sleep 0.1
> +
> + :>"$evts"
> + # ADD_ADDR from the client to server machine -> success
> + ip netns exec $ns2 ./pm_nl_ctl ann 10.0.2.2 token $client4_token id $client_addr_id dev ns2eth1 2>&1 > /dev/nulls
> + sleep 0.1
> + local type=$(sed -n 's/.*\(type:\)\([[:digit:]]*\).*$/\2/p;q' "$evts")
> + if [ "$type" = "" ]
> + then
> + printf "[FAIL]\n"
> + exit 1
> + fi
> +
> + :>"$evts"
> + # ADD_ADDR from the client to server machine -> fail (limit already met)
> + client_addr_id=$((client_addr_id+1))
> + ip netns exec $ns2 ./pm_nl_ctl ann 10.0.2.2 token $client4_token id $client_addr_id dev ns2eth1 port $new4_port 2>&1 > /dev/null
> + sleep 0.1
> + type=$(sed -n 's/.*\(type:\)\([[:digit:]]*\).*$/\2/p;q' "$evts")
> + if [ "$type" = "" ]
> + then
> + printf "[OK]\n"
> + else
> + printf "[FAIL]\n"
> + exit 1
> + fi
> +
> + kill $evts_pid
> + rm -f "$evts"
> +}
> +
> +make_connection
> +make_connection "v6"
> +test_announce
> +test_remove
> +test_subflows
> +test_local_addr_limit
> +exit 0
> --
> 2.31.1
>
>
next prev parent reply other threads:[~2022-01-28 6:51 UTC|newest]
Thread overview: 24+ messages / expand[flat|nested] mbox.gz Atom feed top
2022-01-28 0:38 [PATCH mptcp-next v3 00/14] mptcp: APIs and self-tests for userspace path management Kishen Maloor
2022-01-28 0:38 ` [PATCH mptcp-next v3 01/14] mptcp: add sysctl param to limit userspace PM activity Kishen Maloor
2022-01-28 6:38 ` Geliang Tang
2022-01-31 22:23 ` Kishen Maloor
2022-02-01 11:49 ` Paolo Abeni
2022-02-01 21:20 ` Kishen Maloor
2022-01-28 0:38 ` [PATCH mptcp-next v3 02/14] mptcp: allow ADD_ADDR reissuance by userspace PMs Kishen Maloor
2022-01-28 0:38 ` [PATCH mptcp-next v3 03/14] mptcp: handle local addrs announced " Kishen Maloor
2022-02-01 11:58 ` Paolo Abeni
2022-02-01 21:21 ` Kishen Maloor
2022-01-28 0:38 ` [PATCH mptcp-next v3 04/14] mptcp: read attributes of addr entries managed " Kishen Maloor
2022-01-28 0:38 ` [PATCH mptcp-next v3 05/14] mptcp: netlink: split mptcp_pm_parse_addr into two functions Kishen Maloor
2022-01-28 0:38 ` [PATCH mptcp-next v3 06/14] mptcp: netlink: Add MPTCP_PM_CMD_ANNOUNCE Kishen Maloor
2022-01-28 0:38 ` [PATCH mptcp-next v3 07/14] mptcp: selftests: support MPTCP_PM_CMD_ANNOUNCE Kishen Maloor
2022-01-28 0:38 ` [PATCH mptcp-next v3 08/14] mptcp: netlink: Add MPTCP_PM_CMD_REMOVE Kishen Maloor
2022-01-28 0:38 ` [PATCH mptcp-next v3 09/14] mptcp: selftests: support MPTCP_PM_CMD_REMOVE Kishen Maloor
2022-01-28 0:38 ` [PATCH mptcp-next v3 10/14] mptcp: netlink: allow userspace-driven subflow establishment Kishen Maloor
2022-01-28 0:38 ` [PATCH mptcp-next v3 11/14] mptcp: selftests: support MPTCP_PM_CMD_SUBFLOW_CREATE Kishen Maloor
2022-01-28 0:38 ` [PATCH mptcp-next v3 12/14] mptcp: selftests: support MPTCP_PM_CMD_SUBFLOW_DESTROY Kishen Maloor
2022-01-28 0:38 ` [PATCH mptcp-next v3 13/14] mptcp: selftests: capture netlink events Kishen Maloor
2022-01-28 0:38 ` [PATCH mptcp-next v3 14/14] selftests: mptcp: functional tests for the userspace PM type Kishen Maloor
2022-01-28 6:51 ` Geliang Tang [this message]
2022-01-28 19:48 ` Mat Martineau
2022-01-31 22:24 ` Kishen Maloor
Reply instructions:
You may reply publicly to this message via plain-text email
using any one of the following methods:
* Save the following mbox file, import it into your mail client,
and reply-to-all from there: mbox
Avoid top-posting and favor interleaved quoting:
https://en.wikipedia.org/wiki/Posting_style#Interleaved_style
* Reply using the --to, --cc, and --in-reply-to
switches of git-send-email(1):
git send-email \
--in-reply-to='CA+WQbwvJOa3iJ8BucsMUPho-=eBQziemvneM_Ld82gOC0f4Zwg@mail.gmail.com' \
--to=geliangtang@gmail.com \
--cc=kishen.maloor@intel.com \
--cc=mptcp@lists.linux.dev \
/path/to/YOUR_REPLY
https://kernel.org/pub/software/scm/git/docs/git-send-email.html
* If your mail client supports setting the In-Reply-To header
via mailto: links, try the mailto: link
Be sure your reply has a Subject: header at the top and a blank line
before the message body.
This is an external index of several public inboxes,
see mirroring instructions on how to clone and mirror
all data and code used by this external index.