2 # SPDX-License-Identifier: GPL-2.0
4 . "$(dirname "${0}")/mptcp_lib.sh"
6 rndh=$(printf %x $sec)-$(mktemp -u XXXXXX)
11 timeout_test=$((timeout_poll * 2 + 1))
16 # mptcp_connect in join mode will sleep a bit before completing,
20 ip netns pids "${ns}" | xargs --no-run-if-empty kill -SIGUSR1 &>/dev/null
25 ip netns pids "${ns}" | xargs --no-run-if-empty kill -SIGKILL &>/dev/null
32 ip -Version > /dev/null 2>&1
34 echo "SKIP: Could not run test without ip tool"
39 echo "SKIP: ss tool does not support MPTCP"
51 nr=$(ss -inmHMN $ns | $condition)
54 if [ $nr != $expected ]; then
55 echo "[ fail ] expected $expected found $nr"
60 test_cnt=$((test_cnt+1))
65 __chk_nr "grep -c token:" $*
70 local condition="grep -c token:"
80 while [ $i -lt $timeout ]; do
81 nr=$(ss -inmHMN $ns | $condition)
82 [ $nr == $expected ] && break;
83 [ $nr -gt $max ] && max=$nr
89 if [ $i -ge $timeout ]; then
90 echo "[ fail ] timeout while expecting $expected max $max last $nr"
92 elif [ $nr != $expected ]; then
93 echo "[ fail ] expected $expected found $nr"
98 test_cnt=$((test_cnt+1))
101 chk_msk_fallback_nr()
103 __chk_nr "grep -c fallback" $*
106 chk_msk_remote_key_nr()
108 __chk_nr "grep -c remote_key" $*
119 nr=$(ss -N $ns -Ml "$filter" | grep -c LISTEN)
120 printf "%-50s" "$msg"
122 if [ $nr != $expected ]; then
123 echo "[ fail ] expected $expected found $nr"
133 local msg="check for listen socket"
135 # destination port search should always return empty list
136 __chk_listen "dport $lport" 0 "listen match for dport $lport"
138 # should return 'our' mptcp listen socket
139 __chk_listen "sport $lport" 1 "listen match for sport $lport"
141 __chk_listen "src inet:0.0.0.0:$lport" 1 "listen match for saddr and sport"
143 __chk_listen "" 1 "all listen sockets"
145 nr=$(ss -Ml $filter | wc -l)
149 wait_local_port_listen()
151 local listener_ns="${1}"
156 port_hex="$(printf "%04X" "${port}")"
157 for i in $(seq 10); do
158 ip netns exec "${listener_ns}" cat /proc/net/tcp | \
159 awk "BEGIN {rc=1} {if (\$2 ~ /:${port_hex}\$/ && \$4 ~ /0A/) {rc=0; exit}} END {exit rc}" &&
167 local listener_ns="${1}"
172 port_hex="$(printf "%04X" "${port}")"
173 for i in $(seq 10); do
174 ip netns exec ${listener_ns} grep -q " 0100007F:${port_hex} " /proc/net/tcp && break
181 ip -n $ns link set dev lo up
184 timeout ${timeout_test} \
186 ./mptcp_connect -p 10000 -l -t ${timeout_poll} -w 20 \
188 wait_local_port_listen $ns 10000
189 chk_msk_nr 0 "no msk on netns creation"
193 timeout ${timeout_test} \
195 ./mptcp_connect -p 10000 -r 0 -t ${timeout_poll} -w 20 \
196 127.0.0.1 >/dev/null &
197 wait_connected $ns 10000
198 chk_msk_nr 2 "after MPC handshake "
199 chk_msk_remote_key_nr 2 "....chk remote_key"
200 chk_msk_fallback_nr 0 "....chk no fallback"
205 timeout ${timeout_test} \
207 ./mptcp_connect -p 10001 -l -s TCP -t ${timeout_poll} -w 20 \
209 wait_local_port_listen $ns 10001
211 timeout ${timeout_test} \
213 ./mptcp_connect -p 10001 -r 0 -t ${timeout_poll} -w 20 \
214 127.0.0.1 >/dev/null &
215 wait_connected $ns 10001
216 chk_msk_fallback_nr 1 "check fallback"
220 for I in `seq 1 $NR_CLIENTS`; do
222 timeout ${timeout_test} \
224 ./mptcp_connect -p $((I+10001)) -l -w 20 \
225 -t ${timeout_poll} 0.0.0.0 >/dev/null &
227 wait_local_port_listen $ns $((NR_CLIENTS + 10001))
229 for I in `seq 1 $NR_CLIENTS`; do
231 timeout ${timeout_test} \
233 ./mptcp_connect -p $((I+10001)) -w 20 \
234 -t ${timeout_poll} 127.0.0.1 >/dev/null &
237 wait_msk_nr $((NR_CLIENTS*2)) "many msk socket present"