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# ShellCheck incorrectly believes that most of the code here is unreachable 10# because it's invoked by variable name, see how the "tests" array is used 11#shellcheck disable=SC2317 12 13. "$(dirname "${0}")/mptcp_lib.sh" 14 15ret=0 16sin="" 17sinfail="" 18sout="" 19cin="" 20cinfail="" 21cinsent="" 22tmpfile="" 23cout="" 24err="" 25capout="" 26ns1="" 27ns2="" 28iptables="iptables" 29ip6tables="ip6tables" 30timeout_poll=30 31timeout_test=$((timeout_poll * 2 + 1)) 32capture=false 33checksum=false 34check_invert=0 35validate_checksum=false 36init=0 37evts_ns1="" 38evts_ns2="" 39evts_ns1_pid=0 40evts_ns2_pid=0 41last_test_failed=0 42last_test_skipped=0 43last_test_ignored=1 44 45declare -A all_tests 46declare -a only_tests_ids 47declare -a only_tests_names 48declare -A failed_tests 49MPTCP_LIB_TEST_FORMAT="%03u %s\n" 50TEST_NAME="" 51nr_blank=6 52 53# These var are used only in some tests, make sure they are not already set 54unset FAILING_LINKS 55unset test_linkfail 56unset addr_nr_ns1 57unset addr_nr_ns2 58unset cestab_ns1 59unset cestab_ns2 60unset sflags 61unset fastclose 62unset fullmesh 63unset speed 64 65# generated using "nfbpf_compile '(ip && (ip[54] & 0xf0) == 0x30) || 66# (ip6 && (ip6[74] & 0xf0) == 0x30)'" 67CBPF_MPTCP_SUBOPTION_ADD_ADDR="14, 68 48 0 0 0, 69 84 0 0 240, 70 21 0 3 64, 71 48 0 0 54, 72 84 0 0 240, 73 21 6 7 48, 74 48 0 0 0, 75 84 0 0 240, 76 21 0 4 96, 77 48 0 0 74, 78 84 0 0 240, 79 21 0 1 48, 80 6 0 0 65535, 81 6 0 0 0" 82 83init_partial() 84{ 85 capout=$(mktemp) 86 87 mptcp_lib_ns_init ns1 ns2 88 89 local netns 90 for netns in "$ns1" "$ns2"; do 91 ip netns exec $netns sysctl -q net.mptcp.pm_type=0 2>/dev/null || true 92 if $checksum; then 93 ip netns exec $netns sysctl -q net.mptcp.checksum_enabled=1 94 fi 95 done 96 97 check_invert=0 98 validate_checksum=$checksum 99 100 # ns1 ns2 101 # ns1eth1 ns2eth1 102 # ns1eth2 ns2eth2 103 # ns1eth3 ns2eth3 104 # ns1eth4 ns2eth4 105 106 local i 107 for i in $(seq 1 4); do 108 ip link add ns1eth$i netns "$ns1" type veth peer name ns2eth$i netns "$ns2" 109 ip -net "$ns1" addr add 10.0.$i.1/24 dev ns1eth$i 110 ip -net "$ns1" addr add dead:beef:$i::1/64 dev ns1eth$i nodad 111 ip -net "$ns1" link set ns1eth$i up 112 113 ip -net "$ns2" addr add 10.0.$i.2/24 dev ns2eth$i 114 ip -net "$ns2" addr add dead:beef:$i::2/64 dev ns2eth$i nodad 115 ip -net "$ns2" link set ns2eth$i up 116 117 # let $ns2 reach any $ns1 address from any interface 118 ip -net "$ns2" route add default via 10.0.$i.1 dev ns2eth$i metric 10$i 119 ip -net "$ns2" route add default via dead:beef:$i::1 dev ns2eth$i metric 10$i 120 done 121} 122 123init_shapers() 124{ 125 local i 126 for i in $(seq 1 4); do 127 tc -n $ns1 qdisc add dev ns1eth$i root netem rate 20mbit delay 1ms 128 tc -n $ns2 qdisc add dev ns2eth$i root netem rate 20mbit delay 1ms 129 done 130} 131 132cleanup_partial() 133{ 134 rm -f "$capout" 135 136 mptcp_lib_ns_exit "${ns1}" "${ns2}" 137} 138 139init() { 140 init=1 141 142 mptcp_lib_check_mptcp 143 mptcp_lib_check_kallsyms 144 mptcp_lib_check_tools ip tc ss "${iptables}" "${ip6tables}" 145 146 sin=$(mktemp) 147 sout=$(mktemp) 148 cin=$(mktemp) 149 cinsent=$(mktemp) 150 cout=$(mktemp) 151 err=$(mktemp) 152 evts_ns1=$(mktemp) 153 evts_ns2=$(mktemp) 154 155 trap cleanup EXIT 156 157 make_file "$cin" "client" 1 >/dev/null 158 make_file "$sin" "server" 1 >/dev/null 159} 160 161cleanup() 162{ 163 rm -f "$cin" "$cout" "$sinfail" 164 rm -f "$sin" "$sout" "$cinsent" "$cinfail" 165 rm -f "$tmpfile" 166 rm -rf $evts_ns1 $evts_ns2 167 rm -f "$err" 168 cleanup_partial 169} 170 171print_check() 172{ 173 printf "%-${nr_blank}s%-36s" " " "${*}" 174} 175 176print_info() 177{ 178 # It can be empty, no need to print anything then 179 [ -z "${1}" ] && return 180 181 mptcp_lib_print_info " Info: ${*}" 182} 183 184print_ok() 185{ 186 mptcp_lib_pr_ok "${@}" 187} 188 189print_fail() 190{ 191 mptcp_lib_pr_fail "${@}" 192} 193 194print_skip() 195{ 196 mptcp_lib_pr_skip "${@}" 197} 198 199# [ $1: fail msg ] 200mark_as_skipped() 201{ 202 local msg="${1:-"Feature not supported"}" 203 204 mptcp_lib_fail_if_expected_feature "${msg}" 205 206 print_check "${msg}" 207 print_skip 208 209 last_test_skipped=1 210} 211 212# $@: condition 213continue_if() 214{ 215 if ! "${@}"; then 216 mark_as_skipped 217 return 1 218 fi 219} 220 221skip_test() 222{ 223 if [ "${#only_tests_ids[@]}" -eq 0 ] && [ "${#only_tests_names[@]}" -eq 0 ]; then 224 return 1 225 fi 226 227 local i 228 for i in "${only_tests_ids[@]}"; do 229 if [ "$((MPTCP_LIB_TEST_COUNTER+1))" -eq "${i}" ]; then 230 return 1 231 fi 232 done 233 for i in "${only_tests_names[@]}"; do 234 if [ "${TEST_NAME}" = "${i}" ]; then 235 return 1 236 fi 237 done 238 239 return 0 240} 241 242append_prev_results() 243{ 244 if [ ${last_test_failed} -eq 1 ]; then 245 mptcp_lib_result_fail "${TEST_NAME}" 246 elif [ ${last_test_skipped} -eq 1 ]; then 247 mptcp_lib_result_skip "${TEST_NAME}" 248 elif [ ${last_test_ignored} -ne 1 ]; then 249 mptcp_lib_result_pass "${TEST_NAME}" 250 fi 251 252 last_test_failed=0 253 last_test_skipped=0 254 last_test_ignored=0 255} 256 257# $1: test name 258reset() 259{ 260 append_prev_results 261 262 TEST_NAME="${1}" 263 264 MPTCP_LIB_SUBTEST_FLAKY=0 # reset if modified 265 266 if skip_test; then 267 MPTCP_LIB_TEST_COUNTER=$((MPTCP_LIB_TEST_COUNTER+1)) 268 last_test_ignored=1 269 return 1 270 fi 271 272 mptcp_lib_print_title "${TEST_NAME}" 273 274 if [ "${init}" != "1" ]; then 275 init 276 else 277 cleanup_partial 278 fi 279 280 init_partial 281 282 return 0 283} 284 285# $1: test name ; $2: counter to check 286reset_check_counter() 287{ 288 reset "${1}" || return 1 289 290 local counter="${2}" 291 292 if ! nstat -asz "${counter}" | grep -wq "${counter}"; then 293 mark_as_skipped "counter '${counter}' is not available" 294 return 1 295 fi 296} 297 298# $1: test name 299reset_with_cookies() 300{ 301 reset "${1}" || return 1 302 303 local netns 304 for netns in "$ns1" "$ns2"; do 305 ip netns exec $netns sysctl -q net.ipv4.tcp_syncookies=2 306 done 307} 308 309# $1: test name 310reset_with_add_addr_timeout() 311{ 312 local ip="${2:-4}" 313 local tables 314 315 reset "${1}" || return 1 316 317 tables="${iptables}" 318 if [ $ip -eq 6 ]; then 319 tables="${ip6tables}" 320 fi 321 322 ip netns exec $ns1 sysctl -q net.mptcp.add_addr_timeout=1 323 324 if ! ip netns exec $ns2 $tables -A OUTPUT -p tcp \ 325 -m tcp --tcp-option 30 \ 326 -m bpf --bytecode \ 327 "$CBPF_MPTCP_SUBOPTION_ADD_ADDR" \ 328 -j DROP; then 329 mark_as_skipped "unable to set the 'add addr' rule" 330 return 1 331 fi 332} 333 334# $1: test name 335reset_with_checksum() 336{ 337 local ns1_enable=$1 338 local ns2_enable=$2 339 340 reset "checksum test ${1} ${2}" || return 1 341 342 ip netns exec $ns1 sysctl -q net.mptcp.checksum_enabled=$ns1_enable 343 ip netns exec $ns2 sysctl -q net.mptcp.checksum_enabled=$ns2_enable 344 345 validate_checksum=true 346} 347 348reset_with_allow_join_id0() 349{ 350 local ns1_enable=$2 351 local ns2_enable=$3 352 353 reset "${1}" || return 1 354 355 ip netns exec $ns1 sysctl -q net.mptcp.allow_join_initial_addr_port=$ns1_enable 356 ip netns exec $ns2 sysctl -q net.mptcp.allow_join_initial_addr_port=$ns2_enable 357} 358 359# Modify TCP payload without corrupting the TCP packet 360# 361# This rule inverts a 8-bit word at byte offset 148 for the 2nd TCP ACK packets 362# carrying enough data. 363# Once it is done, the TCP Checksum field is updated so the packet is still 364# considered as valid at the TCP level. 365# Because the MPTCP checksum, covering the TCP options and data, has not been 366# updated, the modification will be detected and an MP_FAIL will be emitted: 367# what we want to validate here without corrupting "random" MPTCP options. 368# 369# To avoid having tc producing this pr_info() message for each TCP ACK packets 370# not carrying enough data: 371# 372# tc action pedit offset 162 out of bounds 373# 374# Netfilter is used to mark packets with enough data. 375setup_fail_rules() 376{ 377 check_invert=1 378 validate_checksum=true 379 local i="$1" 380 local ip="${2:-4}" 381 local tables 382 383 tables="${iptables}" 384 if [ $ip -eq 6 ]; then 385 tables="${ip6tables}" 386 fi 387 388 ip netns exec $ns2 $tables \ 389 -t mangle \ 390 -A OUTPUT \ 391 -o ns2eth$i \ 392 -p tcp \ 393 -m length --length 150:9999 \ 394 -m statistic --mode nth --packet 1 --every 99999 \ 395 -j MARK --set-mark 42 || return ${KSFT_SKIP} 396 397 tc -n $ns2 qdisc add dev ns2eth$i clsact || return ${KSFT_SKIP} 398 tc -n $ns2 filter add dev ns2eth$i egress \ 399 protocol ip prio 1000 \ 400 handle 42 fw \ 401 action pedit munge offset 148 u8 invert \ 402 pipe csum tcp \ 403 index 100 || return ${KSFT_SKIP} 404} 405 406reset_with_fail() 407{ 408 reset_check_counter "${1}" "MPTcpExtInfiniteMapTx" || return 1 409 shift 410 411 ip netns exec $ns1 sysctl -q net.mptcp.checksum_enabled=1 412 ip netns exec $ns2 sysctl -q net.mptcp.checksum_enabled=1 413 414 local rc=0 415 setup_fail_rules "${@}" || rc=$? 416 417 if [ ${rc} -eq ${KSFT_SKIP} ]; then 418 mark_as_skipped "unable to set the 'fail' rules" 419 return 1 420 fi 421} 422 423reset_with_events() 424{ 425 reset "${1}" || return 1 426 427 mptcp_lib_events "${ns1}" "${evts_ns1}" evts_ns1_pid 428 mptcp_lib_events "${ns2}" "${evts_ns2}" evts_ns2_pid 429} 430 431reset_with_tcp_filter() 432{ 433 reset "${1}" || return 1 434 shift 435 436 local ns="${!1}" 437 local src="${2}" 438 local target="${3}" 439 440 if ! ip netns exec "${ns}" ${iptables} \ 441 -A INPUT \ 442 -s "${src}" \ 443 -p tcp \ 444 -j "${target}"; then 445 mark_as_skipped "unable to set the filter rules" 446 return 1 447 fi 448} 449 450# $1: err msg 451fail_test() 452{ 453 if ! mptcp_lib_subtest_is_flaky; then 454 ret=${KSFT_FAIL} 455 fi 456 457 if [ ${#} -gt 0 ]; then 458 print_fail "${@}" 459 fi 460 461 # just in case a test is marked twice as failed 462 if [ ${last_test_failed} -eq 0 ]; then 463 failed_tests[${MPTCP_LIB_TEST_COUNTER}]="${TEST_NAME}" 464 dump_stats 465 last_test_failed=1 466 fi 467} 468 469get_failed_tests_ids() 470{ 471 # sorted 472 local i 473 for i in "${!failed_tests[@]}"; do 474 echo "${i}" 475 done | sort -n 476} 477 478check_transfer() 479{ 480 local in=$1 481 local out=$2 482 local what=$3 483 local bytes=$4 484 local i a b 485 486 local line 487 if [ -n "$bytes" ]; then 488 local out_size 489 # when truncating we must check the size explicitly 490 out_size=$(wc -c $out | awk '{print $1}') 491 if [ $out_size -ne $bytes ]; then 492 fail_test "$what output file has wrong size ($out_size, $bytes)" 493 return 1 494 fi 495 496 # note: BusyBox's "cmp" command doesn't support --bytes 497 tmpfile=$(mktemp) 498 head --bytes="$bytes" "$in" > "$tmpfile" 499 mv "$tmpfile" "$in" 500 head --bytes="$bytes" "$out" > "$tmpfile" 501 mv "$tmpfile" "$out" 502 tmpfile="" 503 fi 504 cmp -l "$in" "$out" | while read -r i a b; do 505 local sum=$((0${a} + 0${b})) 506 if [ $check_invert -eq 0 ] || [ $sum -ne $((0xff)) ]; then 507 fail_test "$what does not match (in, out):" 508 mptcp_lib_print_file_err "$in" 509 mptcp_lib_print_file_err "$out" 510 511 return 1 512 else 513 print_info "$what has inverted byte at ${i}" 514 fi 515 done 516 517 return 0 518} 519 520do_ping() 521{ 522 local listener_ns="$1" 523 local connector_ns="$2" 524 local connect_addr="$3" 525 526 if ! ip netns exec ${connector_ns} ping -q -c 1 $connect_addr >/dev/null; then 527 fail_test "$listener_ns -> $connect_addr connectivity" 528 fi 529} 530 531link_failure() 532{ 533 local ns="$1" 534 535 if [ -z "$FAILING_LINKS" ]; then 536 l=$((RANDOM%4)) 537 FAILING_LINKS=$((l+1)) 538 fi 539 540 local l 541 for l in $FAILING_LINKS; do 542 local veth="ns1eth$l" 543 ip -net "$ns" link set "$veth" down 544 done 545} 546 547rm_addr_count() 548{ 549 mptcp_lib_get_counter "${1}" "MPTcpExtRmAddr" 550} 551 552# $1: ns, $2: old rm_addr counter in $ns 553wait_rm_addr() 554{ 555 local ns="${1}" 556 local old_cnt="${2}" 557 local cnt 558 559 local i 560 for i in $(seq 10); do 561 cnt=$(rm_addr_count ${ns}) 562 [ "$cnt" = "${old_cnt}" ] || break 563 sleep 0.1 564 done 565} 566 567rm_sf_count() 568{ 569 mptcp_lib_get_counter "${1}" "MPTcpExtRmSubflow" 570} 571 572# $1: ns, $2: old rm_sf counter in $ns 573wait_rm_sf() 574{ 575 local ns="${1}" 576 local old_cnt="${2}" 577 local cnt 578 579 local i 580 for i in $(seq 10); do 581 cnt=$(rm_sf_count ${ns}) 582 [ "$cnt" = "${old_cnt}" ] || break 583 sleep 0.1 584 done 585} 586 587wait_mpj() 588{ 589 local ns="${1}" 590 local cnt old_cnt 591 592 old_cnt=$(mptcp_lib_get_counter ${ns} "MPTcpExtMPJoinAckRx") 593 594 local i 595 for i in $(seq 10); do 596 cnt=$(mptcp_lib_get_counter ${ns} "MPTcpExtMPJoinAckRx") 597 [ "$cnt" = "${old_cnt}" ] || break 598 sleep 0.1 599 done 600} 601 602kill_events_pids() 603{ 604 mptcp_lib_kill_wait $evts_ns1_pid 605 evts_ns1_pid=0 606 mptcp_lib_kill_wait $evts_ns2_pid 607 evts_ns2_pid=0 608} 609 610pm_nl_set_limits() 611{ 612 mptcp_lib_pm_nl_set_limits "${@}" 613} 614 615pm_nl_add_endpoint() 616{ 617 mptcp_lib_pm_nl_add_endpoint "${@}" 618} 619 620pm_nl_del_endpoint() 621{ 622 mptcp_lib_pm_nl_del_endpoint "${@}" 623} 624 625pm_nl_flush_endpoint() 626{ 627 mptcp_lib_pm_nl_flush_endpoint "${@}" 628} 629 630pm_nl_show_endpoints() 631{ 632 mptcp_lib_pm_nl_show_endpoints "${@}" 633} 634 635pm_nl_change_endpoint() 636{ 637 mptcp_lib_pm_nl_change_endpoint "${@}" 638} 639 640pm_nl_check_endpoint() 641{ 642 local msg="$1" 643 local ns=$2 644 local addr=$3 645 local flags dev id port 646 647 print_check "${msg}" 648 649 shift 3 650 while [ -n "$1" ]; do 651 case "${1}" in 652 "flags" | "dev" | "id" | "port") 653 eval "${1}"="${2}" 654 shift 655 ;; 656 *) 657 ;; 658 esac 659 660 shift 661 done 662 663 if [ -z "${id}" ]; then 664 fail_test "bad test - missing endpoint id" 665 return 666 fi 667 668 check_output "mptcp_lib_pm_nl_get_endpoint ${ns} ${id}" \ 669 "$(mptcp_lib_pm_nl_format_endpoints \ 670 "${id},${addr},${flags//","/" "},${dev},${port}")" 671} 672 673pm_nl_set_endpoint() 674{ 675 local listener_ns="$1" 676 local connector_ns="$2" 677 local connect_addr="$3" 678 679 local addr_nr_ns1=${addr_nr_ns1:-0} 680 local addr_nr_ns2=${addr_nr_ns2:-0} 681 local sflags=${sflags:-""} 682 local fullmesh=${fullmesh:-""} 683 684 local flags="subflow" 685 if [ -n "${fullmesh}" ]; then 686 flags="${flags},fullmesh" 687 addr_nr_ns2=${fullmesh} 688 fi 689 690 # let the mptcp subflow be established in background before 691 # do endpoint manipulation 692 if [ $addr_nr_ns1 != "0" ] || [ $addr_nr_ns2 != "0" ]; then 693 sleep 1 694 fi 695 696 if [ $addr_nr_ns1 -gt 0 ]; then 697 local counter=2 698 local add_nr_ns1=${addr_nr_ns1} 699 local id=10 700 while [ $add_nr_ns1 -gt 0 ]; do 701 local addr 702 if mptcp_lib_is_v6 "${connect_addr}"; then 703 addr="dead:beef:$counter::1" 704 else 705 addr="10.0.$counter.1" 706 fi 707 pm_nl_add_endpoint $ns1 $addr flags signal 708 counter=$((counter + 1)) 709 add_nr_ns1=$((add_nr_ns1 - 1)) 710 id=$((id + 1)) 711 done 712 elif [ $addr_nr_ns1 -lt 0 ]; then 713 local rm_nr_ns1=$((-addr_nr_ns1)) 714 if [ $rm_nr_ns1 -lt 8 ]; then 715 local counter=0 716 local line 717 pm_nl_show_endpoints ${listener_ns} | while read -r line; do 718 # shellcheck disable=SC2206 # we do want to split per word 719 local arr=($line) 720 local nr=0 721 722 local i 723 for i in "${arr[@]}"; do 724 if [ $i = "id" ]; then 725 if [ $counter -eq $rm_nr_ns1 ]; then 726 break 727 fi 728 id=${arr[$nr+1]} 729 rm_addr=$(rm_addr_count ${connector_ns}) 730 pm_nl_del_endpoint ${listener_ns} $id 731 wait_rm_addr ${connector_ns} ${rm_addr} 732 counter=$((counter + 1)) 733 fi 734 nr=$((nr + 1)) 735 done 736 done 737 elif [ $rm_nr_ns1 -eq 8 ]; then 738 pm_nl_flush_endpoint ${listener_ns} 739 elif [ $rm_nr_ns1 -eq 9 ]; then 740 pm_nl_del_endpoint ${listener_ns} 0 ${connect_addr} 741 fi 742 fi 743 744 # if newly added endpoints must be deleted, give the background msk 745 # some time to created them 746 [ $addr_nr_ns1 -gt 0 ] && [ $addr_nr_ns2 -lt 0 ] && sleep 1 747 748 if [ $addr_nr_ns2 -gt 0 ]; then 749 local add_nr_ns2=${addr_nr_ns2} 750 local counter=3 751 local id=20 752 while [ $add_nr_ns2 -gt 0 ]; do 753 local addr 754 if mptcp_lib_is_v6 "${connect_addr}"; then 755 addr="dead:beef:$counter::2" 756 else 757 addr="10.0.$counter.2" 758 fi 759 pm_nl_add_endpoint $ns2 $addr flags $flags 760 counter=$((counter + 1)) 761 add_nr_ns2=$((add_nr_ns2 - 1)) 762 id=$((id + 1)) 763 done 764 elif [ $addr_nr_ns2 -lt 0 ]; then 765 local rm_nr_ns2=$((-addr_nr_ns2)) 766 if [ $rm_nr_ns2 -lt 8 ]; then 767 local counter=0 768 local line 769 pm_nl_show_endpoints ${connector_ns} | while read -r line; do 770 # shellcheck disable=SC2206 # we do want to split per word 771 local arr=($line) 772 local nr=0 773 774 local i 775 for i in "${arr[@]}"; do 776 if [ $i = "id" ]; then 777 if [ $counter -eq $rm_nr_ns2 ]; then 778 break 779 fi 780 local id rm_addr 781 # rm_addr are serialized, allow the previous one to 782 # complete 783 id=${arr[$nr+1]} 784 rm_addr=$(rm_addr_count ${listener_ns}) 785 pm_nl_del_endpoint ${connector_ns} $id 786 wait_rm_addr ${listener_ns} ${rm_addr} 787 counter=$((counter + 1)) 788 fi 789 nr=$((nr + 1)) 790 done 791 done 792 elif [ $rm_nr_ns2 -eq 8 ]; then 793 pm_nl_flush_endpoint ${connector_ns} 794 elif [ $rm_nr_ns2 -eq 9 ]; then 795 local addr 796 if mptcp_lib_is_v6 "${connect_addr}"; then 797 addr="dead:beef:1::2" 798 else 799 addr="10.0.1.2" 800 fi 801 pm_nl_del_endpoint ${connector_ns} 0 $addr 802 fi 803 fi 804 805 if [ -n "${sflags}" ]; then 806 sleep 1 807 808 local netns 809 for netns in "$ns1" "$ns2"; do 810 local line 811 pm_nl_show_endpoints $netns | while read -r line; do 812 # shellcheck disable=SC2206 # we do want to split per word 813 local arr=($line) 814 local nr=0 815 local id 816 817 local i 818 for i in "${arr[@]}"; do 819 if [ $i = "id" ]; then 820 id=${arr[$nr+1]} 821 fi 822 nr=$((nr + 1)) 823 done 824 pm_nl_change_endpoint $netns $id $sflags 825 done 826 done 827 fi 828} 829 830chk_cestab_nr() 831{ 832 local ns=$1 833 local cestab=$2 834 local count 835 836 print_check "cestab $cestab" 837 count=$(mptcp_lib_get_counter ${ns} "MPTcpExtMPCurrEstab") 838 if [ -z "$count" ]; then 839 print_skip 840 elif [ "$count" != "$cestab" ]; then 841 fail_test "got $count current establish[s] expected $cestab" 842 else 843 print_ok 844 fi 845} 846 847# $1 namespace 1, $2 namespace 2 848check_cestab() 849{ 850 if [ -n "${cestab_ns1}" ]; then 851 chk_cestab_nr ${1} ${cestab_ns1} 852 fi 853 if [ -n "${cestab_ns2}" ]; then 854 chk_cestab_nr ${2} ${cestab_ns2} 855 fi 856} 857 858do_transfer() 859{ 860 local listener_ns="$1" 861 local connector_ns="$2" 862 local cl_proto="$3" 863 local srv_proto="$4" 864 local connect_addr="$5" 865 866 local port=$((10000 + MPTCP_LIB_TEST_COUNTER - 1)) 867 local cappid 868 local FAILING_LINKS=${FAILING_LINKS:-""} 869 local fastclose=${fastclose:-""} 870 local speed=${speed:-"fast"} 871 872 :> "$cout" 873 :> "$sout" 874 :> "$capout" 875 876 if $capture; then 877 local capuser 878 if [ -z $SUDO_USER ] ; then 879 capuser="" 880 else 881 capuser="-Z $SUDO_USER" 882 fi 883 884 capfile=$(printf "mp_join-%02u-%s.pcap" "$MPTCP_LIB_TEST_COUNTER" "${listener_ns}") 885 886 echo "Capturing traffic for test $MPTCP_LIB_TEST_COUNTER into $capfile" 887 ip netns exec ${listener_ns} tcpdump -i any -s 65535 -B 32768 $capuser -w $capfile > "$capout" 2>&1 & 888 cappid=$! 889 890 sleep 1 891 fi 892 893 NSTAT_HISTORY=/tmp/${listener_ns}.nstat ip netns exec ${listener_ns} \ 894 nstat -n 895 NSTAT_HISTORY=/tmp/${connector_ns}.nstat ip netns exec ${connector_ns} \ 896 nstat -n 897 898 local extra_args 899 if [ $speed = "fast" ]; then 900 extra_args="-j" 901 elif [ $speed = "slow" ]; then 902 extra_args="-r 50" 903 elif [ $speed -gt 0 ]; then 904 extra_args="-r ${speed}" 905 fi 906 907 local extra_cl_args="" 908 local extra_srv_args="" 909 local trunc_size="" 910 if [ -n "${fastclose}" ]; then 911 if [ ${test_linkfail} -le 1 ]; then 912 fail_test "fastclose tests need test_linkfail argument" 913 return 1 914 fi 915 916 # disconnect 917 trunc_size=${test_linkfail} 918 local side=${fastclose} 919 920 if [ ${side} = "client" ]; then 921 extra_cl_args="-f ${test_linkfail}" 922 extra_srv_args="-f -1" 923 elif [ ${side} = "server" ]; then 924 extra_srv_args="-f ${test_linkfail}" 925 extra_cl_args="-f -1" 926 else 927 fail_test "wrong/unknown fastclose spec ${side}" 928 return 1 929 fi 930 fi 931 932 extra_srv_args="$extra_args $extra_srv_args" 933 if [ "$test_linkfail" -gt 1 ];then 934 timeout ${timeout_test} \ 935 ip netns exec ${listener_ns} \ 936 ./mptcp_connect -t ${timeout_poll} -l -p $port -s ${srv_proto} \ 937 $extra_srv_args "::" < "$sinfail" > "$sout" & 938 else 939 timeout ${timeout_test} \ 940 ip netns exec ${listener_ns} \ 941 ./mptcp_connect -t ${timeout_poll} -l -p $port -s ${srv_proto} \ 942 $extra_srv_args "::" < "$sin" > "$sout" & 943 fi 944 local spid=$! 945 946 mptcp_lib_wait_local_port_listen "${listener_ns}" "${port}" 947 948 extra_cl_args="$extra_args $extra_cl_args" 949 if [ "$test_linkfail" -eq 0 ];then 950 timeout ${timeout_test} \ 951 ip netns exec ${connector_ns} \ 952 ./mptcp_connect -t ${timeout_poll} -p $port -s ${cl_proto} \ 953 $extra_cl_args $connect_addr < "$cin" > "$cout" & 954 elif [ "$test_linkfail" -eq 1 ] || [ "$test_linkfail" -eq 2 ];then 955 ( cat "$cinfail" ; sleep 2; link_failure $listener_ns ; cat "$cinfail" ) | \ 956 tee "$cinsent" | \ 957 timeout ${timeout_test} \ 958 ip netns exec ${connector_ns} \ 959 ./mptcp_connect -t ${timeout_poll} -p $port -s ${cl_proto} \ 960 $extra_cl_args $connect_addr > "$cout" & 961 else 962 tee "$cinsent" < "$cinfail" | \ 963 timeout ${timeout_test} \ 964 ip netns exec ${connector_ns} \ 965 ./mptcp_connect -t ${timeout_poll} -p $port -s ${cl_proto} \ 966 $extra_cl_args $connect_addr > "$cout" & 967 fi 968 local cpid=$! 969 970 pm_nl_set_endpoint $listener_ns $connector_ns $connect_addr 971 check_cestab $listener_ns $connector_ns 972 973 wait $cpid 974 local retc=$? 975 wait $spid 976 local rets=$? 977 978 if $capture; then 979 sleep 1 980 kill $cappid 981 fi 982 983 NSTAT_HISTORY=/tmp/${listener_ns}.nstat ip netns exec ${listener_ns} \ 984 nstat | grep Tcp > /tmp/${listener_ns}.out 985 NSTAT_HISTORY=/tmp/${connector_ns}.nstat ip netns exec ${connector_ns} \ 986 nstat | grep Tcp > /tmp/${connector_ns}.out 987 988 if [ ${rets} -ne 0 ] || [ ${retc} -ne 0 ]; then 989 fail_test "client exit code $retc, server $rets" 990 echo -e "\nnetns ${listener_ns} socket stat for ${port}:" 1>&2 991 ip netns exec ${listener_ns} ss -Menita 1>&2 -o "sport = :$port" 992 cat /tmp/${listener_ns}.out 993 echo -e "\nnetns ${connector_ns} socket stat for ${port}:" 1>&2 994 ip netns exec ${connector_ns} ss -Menita 1>&2 -o "dport = :$port" 995 cat /tmp/${connector_ns}.out 996 997 cat "$capout" 998 return 1 999 fi 1000 1001 if [ "$test_linkfail" -gt 1 ];then 1002 check_transfer $sinfail $cout "file received by client" $trunc_size 1003 else 1004 check_transfer $sin $cout "file received by client" $trunc_size 1005 fi 1006 retc=$? 1007 if [ "$test_linkfail" -eq 0 ];then 1008 check_transfer $cin $sout "file received by server" $trunc_size 1009 else 1010 check_transfer $cinsent $sout "file received by server" $trunc_size 1011 fi 1012 rets=$? 1013 1014 if [ $retc -eq 0 ] && [ $rets -eq 0 ];then 1015 cat "$capout" 1016 return 0 1017 fi 1018 1019 cat "$capout" 1020 return 1 1021} 1022 1023make_file() 1024{ 1025 local name=$1 1026 local who=$2 1027 local size=$3 1028 1029 mptcp_lib_make_file $name 1024 $size 1030 1031 print_info "Test file (size $size KB) for $who" 1032} 1033 1034run_tests() 1035{ 1036 local listener_ns="$1" 1037 local connector_ns="$2" 1038 local connect_addr="$3" 1039 1040 local size 1041 local test_linkfail=${test_linkfail:-0} 1042 1043 # The values above 2 are reused to make test files 1044 # with the given sizes (KB) 1045 if [ "$test_linkfail" -gt 2 ]; then 1046 size=$test_linkfail 1047 1048 if [ -z "$cinfail" ]; then 1049 cinfail=$(mktemp) 1050 fi 1051 make_file "$cinfail" "client" $size 1052 # create the input file for the failure test when 1053 # the first failure test run 1054 elif [ "$test_linkfail" -ne 0 ] && [ -z "$cinfail" ]; then 1055 # the client file must be considerably larger 1056 # of the maximum expected cwin value, or the 1057 # link utilization will be not predicable 1058 size=$((RANDOM%2)) 1059 size=$((size+1)) 1060 size=$((size*8192)) 1061 size=$((size + ( RANDOM % 8192) )) 1062 1063 cinfail=$(mktemp) 1064 make_file "$cinfail" "client" $size 1065 fi 1066 1067 if [ "$test_linkfail" -gt 2 ]; then 1068 size=$test_linkfail 1069 1070 if [ -z "$sinfail" ]; then 1071 sinfail=$(mktemp) 1072 fi 1073 make_file "$sinfail" "server" $size 1074 elif [ "$test_linkfail" -eq 2 ] && [ -z "$sinfail" ]; then 1075 size=$((RANDOM%16)) 1076 size=$((size+1)) 1077 size=$((size*2048)) 1078 1079 sinfail=$(mktemp) 1080 make_file "$sinfail" "server" $size 1081 fi 1082 1083 do_transfer ${listener_ns} ${connector_ns} MPTCP MPTCP ${connect_addr} 1084} 1085 1086dump_stats() 1087{ 1088 echo Server ns stats 1089 ip netns exec $ns1 nstat -as | grep Tcp 1090 echo Client ns stats 1091 ip netns exec $ns2 nstat -as | grep Tcp 1092} 1093 1094chk_csum_nr() 1095{ 1096 local csum_ns1=${1:-0} 1097 local csum_ns2=${2:-0} 1098 local count 1099 local extra_msg="" 1100 local allow_multi_errors_ns1=0 1101 local allow_multi_errors_ns2=0 1102 1103 if [[ "${csum_ns1}" = "+"* ]]; then 1104 allow_multi_errors_ns1=1 1105 csum_ns1=${csum_ns1:1} 1106 fi 1107 if [[ "${csum_ns2}" = "+"* ]]; then 1108 allow_multi_errors_ns2=1 1109 csum_ns2=${csum_ns2:1} 1110 fi 1111 1112 print_check "sum" 1113 count=$(mptcp_lib_get_counter ${ns1} "MPTcpExtDataCsumErr") 1114 if [ "$count" != "$csum_ns1" ]; then 1115 extra_msg+=" ns1=$count" 1116 fi 1117 if [ -z "$count" ]; then 1118 print_skip 1119 elif { [ "$count" != $csum_ns1 ] && [ $allow_multi_errors_ns1 -eq 0 ]; } || 1120 { [ "$count" -lt $csum_ns1 ] && [ $allow_multi_errors_ns1 -eq 1 ]; }; then 1121 fail_test "got $count data checksum error[s] expected $csum_ns1" 1122 else 1123 print_ok 1124 fi 1125 print_check "csum" 1126 count=$(mptcp_lib_get_counter ${ns2} "MPTcpExtDataCsumErr") 1127 if [ "$count" != "$csum_ns2" ]; then 1128 extra_msg+=" ns2=$count" 1129 fi 1130 if [ -z "$count" ]; then 1131 print_skip 1132 elif { [ "$count" != $csum_ns2 ] && [ $allow_multi_errors_ns2 -eq 0 ]; } || 1133 { [ "$count" -lt $csum_ns2 ] && [ $allow_multi_errors_ns2 -eq 1 ]; }; then 1134 fail_test "got $count data checksum error[s] expected $csum_ns2" 1135 else 1136 print_ok 1137 fi 1138 1139 print_info "$extra_msg" 1140} 1141 1142chk_fail_nr() 1143{ 1144 local fail_tx=$1 1145 local fail_rx=$2 1146 local ns_invert=${3:-""} 1147 local count 1148 local ns_tx=$ns1 1149 local ns_rx=$ns2 1150 local extra_msg="" 1151 local allow_tx_lost=0 1152 local allow_rx_lost=0 1153 1154 if [[ $ns_invert = "invert" ]]; then 1155 ns_tx=$ns2 1156 ns_rx=$ns1 1157 extra_msg="invert" 1158 fi 1159 1160 if [[ "${fail_tx}" = "-"* ]]; then 1161 allow_tx_lost=1 1162 fail_tx=${fail_tx:1} 1163 fi 1164 if [[ "${fail_rx}" = "-"* ]]; then 1165 allow_rx_lost=1 1166 fail_rx=${fail_rx:1} 1167 fi 1168 1169 print_check "ftx" 1170 count=$(mptcp_lib_get_counter ${ns_tx} "MPTcpExtMPFailTx") 1171 if [ "$count" != "$fail_tx" ]; then 1172 extra_msg+=",tx=$count" 1173 fi 1174 if [ -z "$count" ]; then 1175 print_skip 1176 elif { [ "$count" != "$fail_tx" ] && [ $allow_tx_lost -eq 0 ]; } || 1177 { [ "$count" -gt "$fail_tx" ] && [ $allow_tx_lost -eq 1 ]; }; then 1178 fail_test "got $count MP_FAIL[s] TX expected $fail_tx" 1179 else 1180 print_ok 1181 fi 1182 1183 print_check "failrx" 1184 count=$(mptcp_lib_get_counter ${ns_rx} "MPTcpExtMPFailRx") 1185 if [ "$count" != "$fail_rx" ]; then 1186 extra_msg+=",rx=$count" 1187 fi 1188 if [ -z "$count" ]; then 1189 print_skip 1190 elif { [ "$count" != "$fail_rx" ] && [ $allow_rx_lost -eq 0 ]; } || 1191 { [ "$count" -gt "$fail_rx" ] && [ $allow_rx_lost -eq 1 ]; }; then 1192 fail_test "got $count MP_FAIL[s] RX expected $fail_rx" 1193 else 1194 print_ok 1195 fi 1196 1197 print_info "$extra_msg" 1198} 1199 1200chk_fclose_nr() 1201{ 1202 local fclose_tx=$1 1203 local fclose_rx=$2 1204 local ns_invert=$3 1205 local count 1206 local ns_tx=$ns2 1207 local ns_rx=$ns1 1208 local extra_msg="" 1209 1210 if [[ $ns_invert = "invert" ]]; then 1211 ns_tx=$ns1 1212 ns_rx=$ns2 1213 extra_msg="invert" 1214 fi 1215 1216 print_check "ctx" 1217 count=$(mptcp_lib_get_counter ${ns_tx} "MPTcpExtMPFastcloseTx") 1218 if [ -z "$count" ]; then 1219 print_skip 1220 elif [ "$count" != "$fclose_tx" ]; then 1221 extra_msg+=",tx=$count" 1222 fail_test "got $count MP_FASTCLOSE[s] TX expected $fclose_tx" 1223 else 1224 print_ok 1225 fi 1226 1227 print_check "fclzrx" 1228 count=$(mptcp_lib_get_counter ${ns_rx} "MPTcpExtMPFastcloseRx") 1229 if [ -z "$count" ]; then 1230 print_skip 1231 elif [ "$count" != "$fclose_rx" ]; then 1232 extra_msg+=",rx=$count" 1233 fail_test "got $count MP_FASTCLOSE[s] RX expected $fclose_rx" 1234 else 1235 print_ok 1236 fi 1237 1238 print_info "$extra_msg" 1239} 1240 1241chk_rst_nr() 1242{ 1243 local rst_tx=$1 1244 local rst_rx=$2 1245 local ns_invert=${3:-""} 1246 local count 1247 local ns_tx=$ns1 1248 local ns_rx=$ns2 1249 local extra_msg="" 1250 1251 if [[ $ns_invert = "invert" ]]; then 1252 ns_tx=$ns2 1253 ns_rx=$ns1 1254 extra_msg="invert" 1255 fi 1256 1257 print_check "rtx" 1258 count=$(mptcp_lib_get_counter ${ns_tx} "MPTcpExtMPRstTx") 1259 if [ -z "$count" ]; then 1260 print_skip 1261 # accept more rst than expected except if we don't expect any 1262 elif { [ $rst_tx -ne 0 ] && [ $count -lt $rst_tx ]; } || 1263 { [ $rst_tx -eq 0 ] && [ $count -ne 0 ]; }; then 1264 fail_test "got $count MP_RST[s] TX expected $rst_tx" 1265 else 1266 print_ok 1267 fi 1268 1269 print_check "rstrx" 1270 count=$(mptcp_lib_get_counter ${ns_rx} "MPTcpExtMPRstRx") 1271 if [ -z "$count" ]; then 1272 print_skip 1273 # accept more rst than expected except if we don't expect any 1274 elif { [ $rst_rx -ne 0 ] && [ $count -lt $rst_rx ]; } || 1275 { [ $rst_rx -eq 0 ] && [ $count -ne 0 ]; }; then 1276 fail_test "got $count MP_RST[s] RX expected $rst_rx" 1277 else 1278 print_ok 1279 fi 1280 1281 print_info "$extra_msg" 1282} 1283 1284chk_infi_nr() 1285{ 1286 local infi_tx=$1 1287 local infi_rx=$2 1288 local count 1289 1290 print_check "itx" 1291 count=$(mptcp_lib_get_counter ${ns2} "MPTcpExtInfiniteMapTx") 1292 if [ -z "$count" ]; then 1293 print_skip 1294 elif [ "$count" != "$infi_tx" ]; then 1295 fail_test "got $count infinite map[s] TX expected $infi_tx" 1296 else 1297 print_ok 1298 fi 1299 1300 print_check "infirx" 1301 count=$(mptcp_lib_get_counter ${ns1} "MPTcpExtInfiniteMapRx") 1302 if [ -z "$count" ]; then 1303 print_skip 1304 elif [ "$count" != "$infi_rx" ]; then 1305 fail_test "got $count infinite map[s] RX expected $infi_rx" 1306 else 1307 print_ok 1308 fi 1309} 1310 1311chk_join_nr() 1312{ 1313 local syn_nr=$1 1314 local syn_ack_nr=$2 1315 local ack_nr=$3 1316 local csum_ns1=${4:-0} 1317 local csum_ns2=${5:-0} 1318 local fail_nr=${6:-0} 1319 local rst_nr=${7:-0} 1320 local infi_nr=${8:-0} 1321 local corrupted_pkts=${9:-0} 1322 local count 1323 local with_cookie 1324 1325 if [ "${corrupted_pkts}" -gt 0 ]; then 1326 print_info "${corrupted_pkts} corrupted pkts" 1327 fi 1328 1329 print_check "syn" 1330 count=$(mptcp_lib_get_counter ${ns1} "MPTcpExtMPJoinSynRx") 1331 if [ -z "$count" ]; then 1332 print_skip 1333 elif [ "$count" != "$syn_nr" ]; then 1334 fail_test "got $count JOIN[s] syn expected $syn_nr" 1335 else 1336 print_ok 1337 fi 1338 1339 print_check "synack" 1340 with_cookie=$(ip netns exec $ns2 sysctl -n net.ipv4.tcp_syncookies) 1341 count=$(mptcp_lib_get_counter ${ns2} "MPTcpExtMPJoinSynAckRx") 1342 if [ -z "$count" ]; then 1343 print_skip 1344 elif [ "$count" != "$syn_ack_nr" ]; then 1345 # simult connections exceeding the limit with cookie enabled could go up to 1346 # synack validation as the conn limit can be enforced reliably only after 1347 # the subflow creation 1348 if [ "$with_cookie" = 2 ] && [ "$count" -gt "$syn_ack_nr" ] && [ "$count" -le "$syn_nr" ]; then 1349 print_ok 1350 else 1351 fail_test "got $count JOIN[s] synack expected $syn_ack_nr" 1352 fi 1353 else 1354 print_ok 1355 fi 1356 1357 print_check "ack" 1358 count=$(mptcp_lib_get_counter ${ns1} "MPTcpExtMPJoinAckRx") 1359 if [ -z "$count" ]; then 1360 print_skip 1361 elif [ "$count" != "$ack_nr" ]; then 1362 fail_test "got $count JOIN[s] ack expected $ack_nr" 1363 else 1364 print_ok 1365 fi 1366 if $validate_checksum; then 1367 chk_csum_nr $csum_ns1 $csum_ns2 1368 chk_fail_nr $fail_nr $fail_nr 1369 chk_rst_nr $rst_nr $rst_nr 1370 chk_infi_nr $infi_nr $infi_nr 1371 fi 1372} 1373 1374# a negative value for 'stale_max' means no upper bound: 1375# for bidirectional transfer, if one peer sleep for a while 1376# - as these tests do - we can have a quite high number of 1377# stale/recover conversions, proportional to 1378# sleep duration/ MPTCP-level RTX interval. 1379chk_stale_nr() 1380{ 1381 local ns=$1 1382 local stale_min=$2 1383 local stale_max=$3 1384 local stale_delta=$4 1385 local dump_stats 1386 local stale_nr 1387 local recover_nr 1388 1389 print_check "stale" 1390 1391 stale_nr=$(mptcp_lib_get_counter ${ns} "MPTcpExtSubflowStale") 1392 recover_nr=$(mptcp_lib_get_counter ${ns} "MPTcpExtSubflowRecover") 1393 if [ -z "$stale_nr" ] || [ -z "$recover_nr" ]; then 1394 print_skip 1395 elif [ $stale_nr -lt $stale_min ] || 1396 { [ $stale_max -gt 0 ] && [ $stale_nr -gt $stale_max ]; } || 1397 [ $((stale_nr - recover_nr)) -ne $stale_delta ]; then 1398 fail_test "got $stale_nr stale[s] $recover_nr recover[s], " \ 1399 " expected stale in range [$stale_min..$stale_max]," \ 1400 " stale-recover delta $stale_delta" 1401 dump_stats=1 1402 else 1403 print_ok 1404 fi 1405 1406 if [ "${dump_stats}" = 1 ]; then 1407 echo $ns stats 1408 ip netns exec $ns ip -s link show 1409 ip netns exec $ns nstat -as | grep MPTcp 1410 fi 1411} 1412 1413chk_add_nr() 1414{ 1415 local add_nr=$1 1416 local echo_nr=$2 1417 local port_nr=${3:-0} 1418 local syn_nr=${4:-$port_nr} 1419 local syn_ack_nr=${5:-$port_nr} 1420 local ack_nr=${6:-$port_nr} 1421 local mis_syn_nr=${7:-0} 1422 local mis_ack_nr=${8:-0} 1423 local count 1424 local timeout 1425 1426 timeout=$(ip netns exec $ns1 sysctl -n net.mptcp.add_addr_timeout) 1427 1428 print_check "add" 1429 count=$(mptcp_lib_get_counter ${ns2} "MPTcpExtAddAddr") 1430 if [ -z "$count" ]; then 1431 print_skip 1432 # if the test configured a short timeout tolerate greater then expected 1433 # add addrs options, due to retransmissions 1434 elif [ "$count" != "$add_nr" ] && { [ "$timeout" -gt 1 ] || [ "$count" -lt "$add_nr" ]; }; then 1435 fail_test "got $count ADD_ADDR[s] expected $add_nr" 1436 else 1437 print_ok 1438 fi 1439 1440 print_check "echo" 1441 count=$(mptcp_lib_get_counter ${ns1} "MPTcpExtEchoAdd") 1442 if [ -z "$count" ]; then 1443 print_skip 1444 elif [ "$count" != "$echo_nr" ]; then 1445 fail_test "got $count ADD_ADDR echo[s] expected $echo_nr" 1446 else 1447 print_ok 1448 fi 1449 1450 if [ $port_nr -gt 0 ]; then 1451 print_check "pt" 1452 count=$(mptcp_lib_get_counter ${ns2} "MPTcpExtPortAdd") 1453 if [ -z "$count" ]; then 1454 print_skip 1455 elif [ "$count" != "$port_nr" ]; then 1456 fail_test "got $count ADD_ADDR[s] with a port-number expected $port_nr" 1457 else 1458 print_ok 1459 fi 1460 1461 print_check "syn" 1462 count=$(mptcp_lib_get_counter ${ns1} "MPTcpExtMPJoinPortSynRx") 1463 if [ -z "$count" ]; then 1464 print_skip 1465 elif [ "$count" != "$syn_nr" ]; then 1466 fail_test "got $count JOIN[s] syn with a different \ 1467 port-number expected $syn_nr" 1468 else 1469 print_ok 1470 fi 1471 1472 print_check "synack" 1473 count=$(mptcp_lib_get_counter ${ns2} "MPTcpExtMPJoinPortSynAckRx") 1474 if [ -z "$count" ]; then 1475 print_skip 1476 elif [ "$count" != "$syn_ack_nr" ]; then 1477 fail_test "got $count JOIN[s] synack with a different \ 1478 port-number expected $syn_ack_nr" 1479 else 1480 print_ok 1481 fi 1482 1483 print_check "ack" 1484 count=$(mptcp_lib_get_counter ${ns1} "MPTcpExtMPJoinPortAckRx") 1485 if [ -z "$count" ]; then 1486 print_skip 1487 elif [ "$count" != "$ack_nr" ]; then 1488 fail_test "got $count JOIN[s] ack with a different \ 1489 port-number expected $ack_nr" 1490 else 1491 print_ok 1492 fi 1493 1494 print_check "syn" 1495 count=$(mptcp_lib_get_counter ${ns1} "MPTcpExtMismatchPortSynRx") 1496 if [ -z "$count" ]; then 1497 print_skip 1498 elif [ "$count" != "$mis_syn_nr" ]; then 1499 fail_test "got $count JOIN[s] syn with a mismatched \ 1500 port-number expected $mis_syn_nr" 1501 else 1502 print_ok 1503 fi 1504 1505 print_check "ack" 1506 count=$(mptcp_lib_get_counter ${ns1} "MPTcpExtMismatchPortAckRx") 1507 if [ -z "$count" ]; then 1508 print_skip 1509 elif [ "$count" != "$mis_ack_nr" ]; then 1510 fail_test "got $count JOIN[s] ack with a mismatched \ 1511 port-number expected $mis_ack_nr" 1512 else 1513 print_ok 1514 fi 1515 fi 1516} 1517 1518chk_add_tx_nr() 1519{ 1520 local add_tx_nr=$1 1521 local echo_tx_nr=$2 1522 local timeout 1523 local count 1524 1525 timeout=$(ip netns exec $ns1 sysctl -n net.mptcp.add_addr_timeout) 1526 1527 print_check "add TX" 1528 count=$(mptcp_lib_get_counter ${ns1} "MPTcpExtAddAddrTx") 1529 if [ -z "$count" ]; then 1530 print_skip 1531 # if the test configured a short timeout tolerate greater then expected 1532 # add addrs options, due to retransmissions 1533 elif [ "$count" != "$add_tx_nr" ] && { [ "$timeout" -gt 1 ] || [ "$count" -lt "$add_tx_nr" ]; }; then 1534 fail_test "got $count ADD_ADDR[s] TX, expected $add_tx_nr" 1535 else 1536 print_ok 1537 fi 1538 1539 print_check "echo TX" 1540 count=$(mptcp_lib_get_counter ${ns2} "MPTcpExtEchoAddTx") 1541 if [ -z "$count" ]; then 1542 print_skip 1543 elif [ "$count" != "$echo_tx_nr" ]; then 1544 fail_test "got $count ADD_ADDR echo[s] TX, expected $echo_tx_nr" 1545 else 1546 print_ok 1547 fi 1548} 1549 1550chk_rm_nr() 1551{ 1552 local rm_addr_nr=$1 1553 local rm_subflow_nr=$2 1554 local invert 1555 local simult 1556 local count 1557 local addr_ns=$ns1 1558 local subflow_ns=$ns2 1559 local extra_msg="" 1560 1561 shift 2 1562 while [ -n "$1" ]; do 1563 [ "$1" = "invert" ] && invert=true 1564 [ "$1" = "simult" ] && simult=true 1565 shift 1566 done 1567 1568 if [ -z $invert ]; then 1569 addr_ns=$ns1 1570 subflow_ns=$ns2 1571 elif [ $invert = "true" ]; then 1572 addr_ns=$ns2 1573 subflow_ns=$ns1 1574 extra_msg="invert" 1575 fi 1576 1577 print_check "rm" 1578 count=$(mptcp_lib_get_counter ${addr_ns} "MPTcpExtRmAddr") 1579 if [ -z "$count" ]; then 1580 print_skip 1581 elif [ "$count" != "$rm_addr_nr" ]; then 1582 fail_test "got $count RM_ADDR[s] expected $rm_addr_nr" 1583 else 1584 print_ok 1585 fi 1586 1587 print_check "rmsf" 1588 count=$(mptcp_lib_get_counter ${subflow_ns} "MPTcpExtRmSubflow") 1589 if [ -z "$count" ]; then 1590 print_skip 1591 elif [ -n "$simult" ]; then 1592 local cnt suffix 1593 1594 cnt=$(mptcp_lib_get_counter ${addr_ns} "MPTcpExtRmSubflow") 1595 1596 # in case of simult flush, the subflow removal count on each side is 1597 # unreliable 1598 count=$((count + cnt)) 1599 if [ "$count" != "$rm_subflow_nr" ]; then 1600 suffix="$count in [$rm_subflow_nr:$((rm_subflow_nr*2))]" 1601 extra_msg+=" simult" 1602 fi 1603 if [ $count -ge "$rm_subflow_nr" ] && \ 1604 [ "$count" -le "$((rm_subflow_nr *2 ))" ]; then 1605 print_ok "$suffix" 1606 else 1607 fail_test "got $count RM_SUBFLOW[s] expected in range [$rm_subflow_nr:$((rm_subflow_nr*2))]" 1608 fi 1609 elif [ "$count" != "$rm_subflow_nr" ]; then 1610 fail_test "got $count RM_SUBFLOW[s] expected $rm_subflow_nr" 1611 else 1612 print_ok 1613 fi 1614 1615 print_info "$extra_msg" 1616} 1617 1618chk_rm_tx_nr() 1619{ 1620 local rm_addr_tx_nr=$1 1621 1622 print_check "rm TX" 1623 count=$(mptcp_lib_get_counter ${ns2} "MPTcpExtRmAddrTx") 1624 if [ -z "$count" ]; then 1625 print_skip 1626 elif [ "$count" != "$rm_addr_tx_nr" ]; then 1627 fail_test "got $count RM_ADDR[s] expected $rm_addr_tx_nr" 1628 else 1629 print_ok 1630 fi 1631} 1632 1633chk_prio_nr() 1634{ 1635 local mp_prio_nr_tx=$1 1636 local mp_prio_nr_rx=$2 1637 local mpj_syn=$3 1638 local mpj_syn_ack=$4 1639 local count 1640 1641 print_check "ptx" 1642 count=$(mptcp_lib_get_counter ${ns1} "MPTcpExtMPPrioTx") 1643 if [ -z "$count" ]; then 1644 print_skip 1645 elif [ "$count" != "$mp_prio_nr_tx" ]; then 1646 fail_test "got $count MP_PRIO[s] TX expected $mp_prio_nr_tx" 1647 else 1648 print_ok 1649 fi 1650 1651 print_check "prx" 1652 count=$(mptcp_lib_get_counter ${ns1} "MPTcpExtMPPrioRx") 1653 if [ -z "$count" ]; then 1654 print_skip 1655 elif [ "$count" != "$mp_prio_nr_rx" ]; then 1656 fail_test "got $count MP_PRIO[s] RX expected $mp_prio_nr_rx" 1657 else 1658 print_ok 1659 fi 1660 1661 print_check "syn backup" 1662 count=$(mptcp_lib_get_counter ${ns1} "MPTcpExtMPJoinSynBackupRx") 1663 if [ -z "$count" ]; then 1664 print_skip 1665 elif [ "$count" != "$mpj_syn" ]; then 1666 fail_test "got $count JOIN[s] syn with Backup expected $mpj_syn" 1667 else 1668 print_ok 1669 fi 1670 1671 print_check "synack backup" 1672 count=$(mptcp_lib_get_counter ${ns2} "MPTcpExtMPJoinSynAckBackupRx") 1673 if [ -z "$count" ]; then 1674 print_skip 1675 elif [ "$count" != "$mpj_syn_ack" ]; then 1676 fail_test "got $count JOIN[s] synack with Backup expected $mpj_syn_ack" 1677 else 1678 print_ok 1679 fi 1680} 1681 1682chk_subflow_nr() 1683{ 1684 local msg="$1" 1685 local subflow_nr=$2 1686 local cnt1 1687 local cnt2 1688 local dump_stats 1689 1690 print_check "${msg}" 1691 1692 cnt1=$(ss -N $ns1 -tOni | grep -c token) 1693 cnt2=$(ss -N $ns2 -tOni | grep -c token) 1694 if [ "$cnt1" != "$subflow_nr" ] || [ "$cnt2" != "$subflow_nr" ]; then 1695 fail_test "got $cnt1:$cnt2 subflows expected $subflow_nr" 1696 dump_stats=1 1697 else 1698 print_ok 1699 fi 1700 1701 if [ "${dump_stats}" = 1 ]; then 1702 ss -N $ns1 -tOni 1703 ss -N $ns1 -tOni | grep token 1704 ip -n $ns1 mptcp endpoint 1705 fi 1706} 1707 1708chk_mptcp_info() 1709{ 1710 local info1=$1 1711 local exp1=$2 1712 local info2=$3 1713 local exp2=$4 1714 local cnt1 1715 local cnt2 1716 local dump_stats 1717 1718 print_check "mptcp_info ${info1:0:15}=$exp1:$exp2" 1719 1720 cnt1=$(ss -N $ns1 -inmHM | mptcp_lib_get_info_value "$info1" "$info1") 1721 cnt2=$(ss -N $ns2 -inmHM | mptcp_lib_get_info_value "$info2" "$info2") 1722 # 'ss' only display active connections and counters that are not 0. 1723 [ -z "$cnt1" ] && cnt1=0 1724 [ -z "$cnt2" ] && cnt2=0 1725 1726 if [ "$cnt1" != "$exp1" ] || [ "$cnt2" != "$exp2" ]; then 1727 fail_test "got $cnt1:$cnt2 $info1:$info2 expected $exp1:$exp2" 1728 dump_stats=1 1729 else 1730 print_ok 1731 fi 1732 1733 if [ "$dump_stats" = 1 ]; then 1734 ss -N $ns1 -inmHM 1735 ss -N $ns2 -inmHM 1736 fi 1737} 1738 1739# $1: subflows in ns1 ; $2: subflows in ns2 1740# number of all subflows, including the initial subflow. 1741chk_subflows_total() 1742{ 1743 local cnt1 1744 local cnt2 1745 local info="subflows_total" 1746 local dump_stats 1747 1748 # if subflows_total counter is supported, use it: 1749 if [ -n "$(ss -N $ns1 -inmHM | mptcp_lib_get_info_value $info $info)" ]; then 1750 chk_mptcp_info $info $1 $info $2 1751 return 1752 fi 1753 1754 print_check "$info $1:$2" 1755 1756 # if not, count the TCP connections that are in fact MPTCP subflows 1757 cnt1=$(ss -N $ns1 -ti state established state syn-sent state syn-recv | 1758 grep -c tcp-ulp-mptcp) 1759 cnt2=$(ss -N $ns2 -ti state established state syn-sent state syn-recv | 1760 grep -c tcp-ulp-mptcp) 1761 1762 if [ "$1" != "$cnt1" ] || [ "$2" != "$cnt2" ]; then 1763 fail_test "got subflows $cnt1:$cnt2 expected $1:$2" 1764 dump_stats=1 1765 else 1766 print_ok 1767 fi 1768 1769 if [ "$dump_stats" = 1 ]; then 1770 ss -N $ns1 -ti 1771 ss -N $ns2 -ti 1772 fi 1773} 1774 1775chk_link_usage() 1776{ 1777 local ns=$1 1778 local link=$2 1779 local out=$3 1780 local expected_rate=$4 1781 1782 local tx_link tx_total 1783 tx_link=$(ip netns exec $ns cat /sys/class/net/$link/statistics/tx_bytes) 1784 tx_total=$(stat --format=%s $out) 1785 local tx_rate=$((tx_link * 100 / tx_total)) 1786 local tolerance=5 1787 1788 print_check "link usage" 1789 if [ $tx_rate -lt $((expected_rate - tolerance)) ] || \ 1790 [ $tx_rate -gt $((expected_rate + tolerance)) ]; then 1791 fail_test "got $tx_rate% usage, expected $expected_rate%" 1792 else 1793 print_ok 1794 fi 1795} 1796 1797wait_attempt_fail() 1798{ 1799 local timeout_ms=$((timeout_poll * 1000)) 1800 local time=0 1801 local ns=$1 1802 1803 while [ $time -lt $timeout_ms ]; do 1804 local cnt 1805 1806 cnt=$(mptcp_lib_get_counter ${ns} "TcpAttemptFails") 1807 1808 [ "$cnt" = 1 ] && return 1 1809 time=$((time + 100)) 1810 sleep 0.1 1811 done 1812 return 1 1813} 1814 1815set_userspace_pm() 1816{ 1817 local ns=$1 1818 1819 ip netns exec $ns sysctl -q net.mptcp.pm_type=1 1820} 1821 1822subflows_tests() 1823{ 1824 if reset "no JOIN"; then 1825 run_tests $ns1 $ns2 10.0.1.1 1826 chk_join_nr 0 0 0 1827 fi 1828 1829 # subflow limited by client 1830 if reset "single subflow, limited by client"; then 1831 pm_nl_set_limits $ns1 0 0 1832 pm_nl_set_limits $ns2 0 0 1833 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow 1834 run_tests $ns1 $ns2 10.0.1.1 1835 chk_join_nr 0 0 0 1836 fi 1837 1838 # subflow limited by server 1839 if reset "single subflow, limited by server"; then 1840 pm_nl_set_limits $ns1 0 0 1841 pm_nl_set_limits $ns2 0 1 1842 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow 1843 run_tests $ns1 $ns2 10.0.1.1 1844 chk_join_nr 1 1 0 1845 fi 1846 1847 # subflow 1848 if reset "single subflow"; then 1849 pm_nl_set_limits $ns1 0 1 1850 pm_nl_set_limits $ns2 0 1 1851 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow 1852 run_tests $ns1 $ns2 10.0.1.1 1853 chk_join_nr 1 1 1 1854 fi 1855 1856 # multiple subflows 1857 if reset "multiple subflows"; then 1858 pm_nl_set_limits $ns1 0 2 1859 pm_nl_set_limits $ns2 0 2 1860 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow 1861 pm_nl_add_endpoint $ns2 10.0.2.2 flags subflow 1862 run_tests $ns1 $ns2 10.0.1.1 1863 chk_join_nr 2 2 2 1864 fi 1865 1866 # multiple subflows limited by server 1867 if reset "multiple subflows, limited by server"; then 1868 pm_nl_set_limits $ns1 0 1 1869 pm_nl_set_limits $ns2 0 2 1870 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow 1871 pm_nl_add_endpoint $ns2 10.0.2.2 flags subflow 1872 run_tests $ns1 $ns2 10.0.1.1 1873 chk_join_nr 2 2 1 1874 fi 1875 1876 # single subflow, dev 1877 if reset "single subflow, dev"; then 1878 pm_nl_set_limits $ns1 0 1 1879 pm_nl_set_limits $ns2 0 1 1880 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow dev ns2eth3 1881 run_tests $ns1 $ns2 10.0.1.1 1882 chk_join_nr 1 1 1 1883 fi 1884} 1885 1886subflows_error_tests() 1887{ 1888 # If a single subflow is configured, and matches the MPC src 1889 # address, no additional subflow should be created 1890 if reset "no MPC reuse with single endpoint"; then 1891 pm_nl_set_limits $ns1 0 1 1892 pm_nl_set_limits $ns2 0 1 1893 pm_nl_add_endpoint $ns2 10.0.1.2 flags subflow 1894 speed=slow \ 1895 run_tests $ns1 $ns2 10.0.1.1 1896 chk_join_nr 0 0 0 1897 fi 1898 1899 # multiple subflows, with subflow creation error 1900 if reset_with_tcp_filter "multi subflows, with failing subflow" ns1 10.0.3.2 REJECT && 1901 continue_if mptcp_lib_kallsyms_has "mptcp_pm_subflow_check_next$"; then 1902 pm_nl_set_limits $ns1 0 2 1903 pm_nl_set_limits $ns2 0 2 1904 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow 1905 pm_nl_add_endpoint $ns2 10.0.2.2 flags subflow 1906 speed=slow \ 1907 run_tests $ns1 $ns2 10.0.1.1 1908 chk_join_nr 1 1 1 1909 fi 1910 1911 # multiple subflows, with subflow timeout on MPJ 1912 if reset_with_tcp_filter "multi subflows, with subflow timeout" ns1 10.0.3.2 DROP && 1913 continue_if mptcp_lib_kallsyms_has "mptcp_pm_subflow_check_next$"; then 1914 pm_nl_set_limits $ns1 0 2 1915 pm_nl_set_limits $ns2 0 2 1916 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow 1917 pm_nl_add_endpoint $ns2 10.0.2.2 flags subflow 1918 speed=slow \ 1919 run_tests $ns1 $ns2 10.0.1.1 1920 chk_join_nr 1 1 1 1921 fi 1922 1923 # multiple subflows, check that the endpoint corresponding to 1924 # closed subflow (due to reset) is not reused if additional 1925 # subflows are added later 1926 if reset_with_tcp_filter "multi subflows, fair usage on close" ns1 10.0.3.2 REJECT && 1927 continue_if mptcp_lib_kallsyms_has "mptcp_pm_subflow_check_next$"; then 1928 pm_nl_set_limits $ns1 0 1 1929 pm_nl_set_limits $ns2 0 1 1930 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow 1931 speed=slow \ 1932 run_tests $ns1 $ns2 10.0.1.1 & 1933 1934 # mpj subflow will be in TW after the reset 1935 wait_attempt_fail $ns2 1936 pm_nl_add_endpoint $ns2 10.0.2.2 flags subflow 1937 wait 1938 1939 # additional subflow could be created only if the PM select 1940 # the later endpoint, skipping the already used one 1941 chk_join_nr 1 1 1 1942 fi 1943} 1944 1945signal_address_tests() 1946{ 1947 # add_address, unused 1948 if reset "unused signal address"; then 1949 pm_nl_add_endpoint $ns1 10.0.2.1 flags signal 1950 run_tests $ns1 $ns2 10.0.1.1 1951 chk_join_nr 0 0 0 1952 chk_add_tx_nr 1 1 1953 chk_add_nr 1 1 1954 fi 1955 1956 # accept and use add_addr 1957 if reset "signal address"; then 1958 pm_nl_set_limits $ns1 0 1 1959 pm_nl_set_limits $ns2 1 1 1960 pm_nl_add_endpoint $ns1 10.0.2.1 flags signal 1961 run_tests $ns1 $ns2 10.0.1.1 1962 chk_join_nr 1 1 1 1963 chk_add_nr 1 1 1964 fi 1965 1966 # accept and use add_addr with an additional subflow 1967 # note: signal address in server ns and local addresses in client ns must 1968 # belong to different subnets or one of the listed local address could be 1969 # used for 'add_addr' subflow 1970 if reset "subflow and signal"; then 1971 pm_nl_add_endpoint $ns1 10.0.2.1 flags signal 1972 pm_nl_set_limits $ns1 0 2 1973 pm_nl_set_limits $ns2 1 2 1974 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow 1975 run_tests $ns1 $ns2 10.0.1.1 1976 chk_join_nr 2 2 2 1977 chk_add_nr 1 1 1978 fi 1979 1980 # accept and use add_addr with additional subflows 1981 if reset "multiple subflows and signal"; then 1982 pm_nl_set_limits $ns1 0 3 1983 pm_nl_add_endpoint $ns1 10.0.2.1 flags signal 1984 pm_nl_set_limits $ns2 1 3 1985 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow 1986 pm_nl_add_endpoint $ns2 10.0.4.2 flags subflow 1987 run_tests $ns1 $ns2 10.0.1.1 1988 chk_join_nr 3 3 3 1989 chk_add_nr 1 1 1990 fi 1991 1992 # signal addresses 1993 if reset "signal addresses"; then 1994 pm_nl_set_limits $ns1 3 3 1995 pm_nl_add_endpoint $ns1 10.0.2.1 flags signal 1996 pm_nl_add_endpoint $ns1 10.0.3.1 flags signal 1997 pm_nl_add_endpoint $ns1 10.0.4.1 flags signal 1998 pm_nl_set_limits $ns2 3 3 1999 run_tests $ns1 $ns2 10.0.1.1 2000 chk_join_nr 3 3 3 2001 chk_add_nr 3 3 2002 fi 2003 2004 # signal invalid addresses 2005 if reset "signal invalid addresses"; then 2006 pm_nl_set_limits $ns1 3 3 2007 pm_nl_add_endpoint $ns1 10.0.12.1 flags signal 2008 pm_nl_add_endpoint $ns1 10.0.3.1 flags signal 2009 pm_nl_add_endpoint $ns1 10.0.14.1 flags signal 2010 pm_nl_set_limits $ns2 3 3 2011 run_tests $ns1 $ns2 10.0.1.1 2012 chk_join_nr 1 1 1 2013 chk_add_nr 3 3 2014 fi 2015 2016 # signal addresses race test 2017 if reset "signal addresses race test"; then 2018 pm_nl_set_limits $ns1 4 4 2019 pm_nl_set_limits $ns2 4 4 2020 pm_nl_add_endpoint $ns1 10.0.1.1 flags signal 2021 pm_nl_add_endpoint $ns1 10.0.2.1 flags signal 2022 pm_nl_add_endpoint $ns1 10.0.3.1 flags signal 2023 pm_nl_add_endpoint $ns1 10.0.4.1 flags signal 2024 pm_nl_add_endpoint $ns2 10.0.1.2 flags signal 2025 pm_nl_add_endpoint $ns2 10.0.2.2 flags signal 2026 pm_nl_add_endpoint $ns2 10.0.3.2 flags signal 2027 pm_nl_add_endpoint $ns2 10.0.4.2 flags signal 2028 2029 # the peer could possibly miss some addr notification, allow retransmission 2030 ip netns exec $ns1 sysctl -q net.mptcp.add_addr_timeout=1 2031 speed=slow \ 2032 run_tests $ns1 $ns2 10.0.1.1 2033 2034 # It is not directly linked to the commit introducing this 2035 # symbol but for the parent one which is linked anyway. 2036 if ! mptcp_lib_kallsyms_has "mptcp_pm_subflow_check_next$"; then 2037 chk_join_nr 3 3 2 2038 chk_add_nr 4 4 2039 else 2040 chk_join_nr 3 3 3 2041 # the server will not signal the address terminating 2042 # the MPC subflow 2043 chk_add_nr 3 3 2044 fi 2045 fi 2046} 2047 2048link_failure_tests() 2049{ 2050 # accept and use add_addr with additional subflows and link loss 2051 if reset "multiple flows, signal, link failure"; then 2052 # without any b/w limit each veth could spool the packets and get 2053 # them acked at xmit time, so that the corresponding subflow will 2054 # have almost always no outstanding pkts, the scheduler will pick 2055 # always the first subflow and we will have hard time testing 2056 # active backup and link switch-over. 2057 # Let's set some arbitrary (low) virtual link limits. 2058 init_shapers 2059 pm_nl_set_limits $ns1 0 3 2060 pm_nl_add_endpoint $ns1 10.0.2.1 dev ns1eth2 flags signal 2061 pm_nl_set_limits $ns2 1 3 2062 pm_nl_add_endpoint $ns2 10.0.3.2 dev ns2eth3 flags subflow 2063 pm_nl_add_endpoint $ns2 10.0.4.2 dev ns2eth4 flags subflow 2064 test_linkfail=1 \ 2065 run_tests $ns1 $ns2 10.0.1.1 2066 chk_join_nr 3 3 3 2067 chk_add_nr 1 1 2068 chk_stale_nr $ns2 1 5 1 2069 fi 2070 2071 # accept and use add_addr with additional subflows and link loss 2072 # for bidirectional transfer 2073 if reset "multi flows, signal, bidi, link fail"; then 2074 init_shapers 2075 pm_nl_set_limits $ns1 0 3 2076 pm_nl_add_endpoint $ns1 10.0.2.1 dev ns1eth2 flags signal 2077 pm_nl_set_limits $ns2 1 3 2078 pm_nl_add_endpoint $ns2 10.0.3.2 dev ns2eth3 flags subflow 2079 pm_nl_add_endpoint $ns2 10.0.4.2 dev ns2eth4 flags subflow 2080 test_linkfail=2 \ 2081 run_tests $ns1 $ns2 10.0.1.1 2082 chk_join_nr 3 3 3 2083 chk_add_nr 1 1 2084 chk_stale_nr $ns2 1 -1 1 2085 fi 2086 2087 # 2 subflows plus 1 backup subflow with a lossy link, backup 2088 # will never be used 2089 if reset "backup subflow unused, link failure"; then 2090 init_shapers 2091 pm_nl_set_limits $ns1 0 2 2092 pm_nl_add_endpoint $ns1 10.0.2.1 dev ns1eth2 flags signal 2093 pm_nl_set_limits $ns2 1 2 2094 pm_nl_add_endpoint $ns2 10.0.3.2 dev ns2eth3 flags subflow,backup 2095 FAILING_LINKS="1" test_linkfail=1 \ 2096 run_tests $ns1 $ns2 10.0.1.1 2097 chk_join_nr 2 2 2 2098 chk_add_nr 1 1 2099 chk_link_usage $ns2 ns2eth3 $cinsent 0 2100 fi 2101 2102 # 2 lossy links after half transfer, backup will get half of 2103 # the traffic 2104 if reset "backup flow used, multi links fail"; then 2105 init_shapers 2106 pm_nl_set_limits $ns1 0 2 2107 pm_nl_add_endpoint $ns1 10.0.2.1 dev ns1eth2 flags signal 2108 pm_nl_set_limits $ns2 1 2 2109 pm_nl_add_endpoint $ns2 10.0.3.2 dev ns2eth3 flags subflow,backup 2110 FAILING_LINKS="1 2" test_linkfail=1 \ 2111 run_tests $ns1 $ns2 10.0.1.1 2112 chk_join_nr 2 2 2 2113 chk_add_nr 1 1 2114 chk_stale_nr $ns2 2 4 2 2115 chk_link_usage $ns2 ns2eth3 $cinsent 50 2116 fi 2117 2118 # use a backup subflow with the first subflow on a lossy link 2119 # for bidirectional transfer 2120 if reset "backup flow used, bidi, link failure"; then 2121 init_shapers 2122 pm_nl_set_limits $ns1 0 2 2123 pm_nl_add_endpoint $ns1 10.0.2.1 dev ns1eth2 flags signal 2124 pm_nl_set_limits $ns2 1 3 2125 pm_nl_add_endpoint $ns2 10.0.3.2 dev ns2eth3 flags subflow,backup 2126 FAILING_LINKS="1 2" test_linkfail=2 \ 2127 run_tests $ns1 $ns2 10.0.1.1 2128 chk_join_nr 2 2 2 2129 chk_add_nr 1 1 2130 chk_stale_nr $ns2 1 -1 2 2131 chk_link_usage $ns2 ns2eth3 $cinsent 50 2132 fi 2133} 2134 2135add_addr_timeout_tests() 2136{ 2137 # add_addr timeout 2138 if reset_with_add_addr_timeout "signal address, ADD_ADDR timeout"; then 2139 pm_nl_set_limits $ns1 0 1 2140 pm_nl_set_limits $ns2 1 1 2141 pm_nl_add_endpoint $ns1 10.0.2.1 flags signal 2142 speed=slow \ 2143 run_tests $ns1 $ns2 10.0.1.1 2144 chk_join_nr 1 1 1 2145 chk_add_tx_nr 4 4 2146 chk_add_nr 4 0 2147 fi 2148 2149 # add_addr timeout IPv6 2150 if reset_with_add_addr_timeout "signal address, ADD_ADDR6 timeout" 6; then 2151 pm_nl_set_limits $ns1 0 1 2152 pm_nl_set_limits $ns2 1 1 2153 pm_nl_add_endpoint $ns1 dead:beef:2::1 flags signal 2154 speed=slow \ 2155 run_tests $ns1 $ns2 dead:beef:1::1 2156 chk_join_nr 1 1 1 2157 chk_add_nr 4 0 2158 fi 2159 2160 # signal addresses timeout 2161 if reset_with_add_addr_timeout "signal addresses, ADD_ADDR timeout"; then 2162 pm_nl_set_limits $ns1 2 2 2163 pm_nl_add_endpoint $ns1 10.0.2.1 flags signal 2164 pm_nl_add_endpoint $ns1 10.0.3.1 flags signal 2165 pm_nl_set_limits $ns2 2 2 2166 speed=10 \ 2167 run_tests $ns1 $ns2 10.0.1.1 2168 chk_join_nr 2 2 2 2169 chk_add_nr 8 0 2170 fi 2171 2172 # signal invalid addresses timeout 2173 if reset_with_add_addr_timeout "invalid address, ADD_ADDR timeout"; then 2174 pm_nl_set_limits $ns1 2 2 2175 pm_nl_add_endpoint $ns1 10.0.12.1 flags signal 2176 pm_nl_add_endpoint $ns1 10.0.3.1 flags signal 2177 pm_nl_set_limits $ns2 2 2 2178 speed=10 \ 2179 run_tests $ns1 $ns2 10.0.1.1 2180 chk_join_nr 1 1 1 2181 chk_add_nr 8 0 2182 fi 2183} 2184 2185remove_tests() 2186{ 2187 # single subflow, remove 2188 if reset "remove single subflow"; then 2189 pm_nl_set_limits $ns1 0 1 2190 pm_nl_set_limits $ns2 0 1 2191 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow 2192 addr_nr_ns2=-1 speed=slow \ 2193 run_tests $ns1 $ns2 10.0.1.1 2194 chk_join_nr 1 1 1 2195 chk_rm_tx_nr 1 2196 chk_rm_nr 1 1 2197 chk_rst_nr 0 0 2198 fi 2199 2200 # multiple subflows, remove 2201 if reset "remove multiple subflows"; then 2202 pm_nl_set_limits $ns1 0 2 2203 pm_nl_set_limits $ns2 0 2 2204 pm_nl_add_endpoint $ns2 10.0.2.2 flags subflow 2205 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow 2206 addr_nr_ns2=-2 speed=slow \ 2207 run_tests $ns1 $ns2 10.0.1.1 2208 chk_join_nr 2 2 2 2209 chk_rm_nr 2 2 2210 chk_rst_nr 0 0 2211 fi 2212 2213 # single address, remove 2214 if reset "remove single address"; then 2215 pm_nl_set_limits $ns1 0 1 2216 pm_nl_add_endpoint $ns1 10.0.2.1 flags signal 2217 pm_nl_set_limits $ns2 1 1 2218 addr_nr_ns1=-1 speed=slow \ 2219 run_tests $ns1 $ns2 10.0.1.1 2220 chk_join_nr 1 1 1 2221 chk_add_nr 1 1 2222 chk_rm_nr 1 1 invert 2223 chk_rst_nr 0 0 2224 fi 2225 2226 # subflow and signal, remove 2227 if reset "remove subflow and signal"; then 2228 pm_nl_set_limits $ns1 0 2 2229 pm_nl_add_endpoint $ns1 10.0.2.1 flags signal 2230 pm_nl_set_limits $ns2 1 2 2231 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow 2232 addr_nr_ns1=-1 addr_nr_ns2=-1 speed=slow \ 2233 run_tests $ns1 $ns2 10.0.1.1 2234 chk_join_nr 2 2 2 2235 chk_add_nr 1 1 2236 chk_rm_nr 1 1 2237 chk_rst_nr 0 0 2238 fi 2239 2240 # subflows and signal, remove 2241 if reset "remove subflows and signal"; then 2242 pm_nl_set_limits $ns1 0 3 2243 pm_nl_add_endpoint $ns1 10.0.2.1 flags signal 2244 pm_nl_set_limits $ns2 1 3 2245 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow 2246 pm_nl_add_endpoint $ns2 10.0.4.2 flags subflow 2247 addr_nr_ns1=-1 addr_nr_ns2=-2 speed=10 \ 2248 run_tests $ns1 $ns2 10.0.1.1 2249 chk_join_nr 3 3 3 2250 chk_add_nr 1 1 2251 chk_rm_nr 2 2 2252 chk_rst_nr 0 0 2253 fi 2254 2255 # addresses remove 2256 if reset "remove addresses"; then 2257 pm_nl_set_limits $ns1 3 3 2258 pm_nl_add_endpoint $ns1 10.0.2.1 flags signal id 250 2259 pm_nl_add_endpoint $ns1 10.0.3.1 flags signal 2260 pm_nl_add_endpoint $ns1 10.0.4.1 flags signal 2261 pm_nl_set_limits $ns2 3 3 2262 addr_nr_ns1=-3 speed=10 \ 2263 run_tests $ns1 $ns2 10.0.1.1 2264 chk_join_nr 3 3 3 2265 chk_add_nr 3 3 2266 chk_rm_nr 3 3 invert 2267 chk_rst_nr 0 0 2268 fi 2269 2270 # invalid addresses remove 2271 if reset "remove invalid addresses"; then 2272 pm_nl_set_limits $ns1 3 3 2273 pm_nl_add_endpoint $ns1 10.0.12.1 flags signal 2274 # broadcast IP: no packet for this address will be received on ns1 2275 pm_nl_add_endpoint $ns1 224.0.0.1 flags signal 2276 pm_nl_add_endpoint $ns1 10.0.3.1 flags signal 2277 pm_nl_set_limits $ns2 2 2 2278 addr_nr_ns1=-3 speed=10 \ 2279 run_tests $ns1 $ns2 10.0.1.1 2280 chk_join_nr 1 1 1 2281 chk_add_nr 3 3 2282 chk_rm_nr 3 1 invert 2283 chk_rst_nr 0 0 2284 fi 2285 2286 # subflows and signal, flush 2287 if reset "flush subflows and signal"; then 2288 pm_nl_set_limits $ns1 0 3 2289 pm_nl_add_endpoint $ns1 10.0.2.1 flags signal 2290 pm_nl_set_limits $ns2 1 3 2291 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow 2292 pm_nl_add_endpoint $ns2 10.0.4.2 flags subflow 2293 addr_nr_ns1=-8 addr_nr_ns2=-8 speed=slow \ 2294 run_tests $ns1 $ns2 10.0.1.1 2295 chk_join_nr 3 3 3 2296 chk_add_nr 1 1 2297 chk_rm_nr 1 3 invert simult 2298 chk_rst_nr 0 0 2299 fi 2300 2301 # subflows flush 2302 if reset "flush subflows"; then 2303 pm_nl_set_limits $ns1 3 3 2304 pm_nl_set_limits $ns2 3 3 2305 pm_nl_add_endpoint $ns2 10.0.2.2 flags subflow id 150 2306 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow 2307 pm_nl_add_endpoint $ns2 10.0.4.2 flags subflow 2308 addr_nr_ns1=-8 addr_nr_ns2=-8 speed=slow \ 2309 run_tests $ns1 $ns2 10.0.1.1 2310 chk_join_nr 3 3 3 2311 2312 if mptcp_lib_kversion_ge 5.18; then 2313 chk_rm_tx_nr 0 2314 chk_rm_nr 0 3 simult 2315 else 2316 chk_rm_nr 3 3 2317 fi 2318 chk_rst_nr 0 0 2319 fi 2320 2321 # addresses flush 2322 if reset "flush addresses"; then 2323 pm_nl_set_limits $ns1 3 3 2324 pm_nl_add_endpoint $ns1 10.0.2.1 flags signal id 250 2325 pm_nl_add_endpoint $ns1 10.0.3.1 flags signal 2326 pm_nl_add_endpoint $ns1 10.0.4.1 flags signal 2327 pm_nl_set_limits $ns2 3 3 2328 addr_nr_ns1=-8 addr_nr_ns2=-8 speed=slow \ 2329 run_tests $ns1 $ns2 10.0.1.1 2330 chk_join_nr 3 3 3 2331 chk_add_nr 3 3 2332 chk_rm_nr 3 3 invert simult 2333 chk_rst_nr 0 0 2334 fi 2335 2336 # invalid addresses flush 2337 if reset "flush invalid addresses"; then 2338 pm_nl_set_limits $ns1 3 3 2339 pm_nl_add_endpoint $ns1 10.0.12.1 flags signal 2340 pm_nl_add_endpoint $ns1 10.0.3.1 flags signal 2341 pm_nl_add_endpoint $ns1 10.0.14.1 flags signal 2342 pm_nl_set_limits $ns2 3 3 2343 addr_nr_ns1=-8 speed=slow \ 2344 run_tests $ns1 $ns2 10.0.1.1 2345 chk_join_nr 1 1 1 2346 chk_add_nr 3 3 2347 chk_rm_nr 3 1 invert 2348 chk_rst_nr 0 0 2349 fi 2350 2351 # remove id 0 subflow 2352 if reset "remove id 0 subflow"; then 2353 pm_nl_set_limits $ns1 0 1 2354 pm_nl_set_limits $ns2 0 1 2355 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow 2356 addr_nr_ns2=-9 speed=slow \ 2357 run_tests $ns1 $ns2 10.0.1.1 2358 chk_join_nr 1 1 1 2359 chk_rm_nr 1 1 2360 chk_rst_nr 0 0 2361 fi 2362 2363 # remove id 0 address 2364 if reset "remove id 0 address"; then 2365 pm_nl_set_limits $ns1 0 1 2366 pm_nl_add_endpoint $ns1 10.0.2.1 flags signal 2367 pm_nl_set_limits $ns2 1 1 2368 addr_nr_ns1=-9 speed=slow \ 2369 run_tests $ns1 $ns2 10.0.1.1 2370 chk_join_nr 1 1 1 2371 chk_add_nr 1 1 2372 chk_rm_nr 1 1 invert 2373 chk_rst_nr 0 0 invert 2374 fi 2375} 2376 2377add_tests() 2378{ 2379 # add single subflow 2380 if reset "add single subflow"; then 2381 pm_nl_set_limits $ns1 0 1 2382 pm_nl_set_limits $ns2 0 1 2383 addr_nr_ns2=1 speed=slow cestab_ns2=1 \ 2384 run_tests $ns1 $ns2 10.0.1.1 2385 chk_join_nr 1 1 1 2386 chk_cestab_nr $ns2 0 2387 fi 2388 2389 # add signal address 2390 if reset "add signal address"; then 2391 pm_nl_set_limits $ns1 0 1 2392 pm_nl_set_limits $ns2 1 1 2393 addr_nr_ns1=1 speed=slow cestab_ns1=1 \ 2394 run_tests $ns1 $ns2 10.0.1.1 2395 chk_join_nr 1 1 1 2396 chk_add_nr 1 1 2397 chk_cestab_nr $ns1 0 2398 fi 2399 2400 # add multiple subflows 2401 if reset "add multiple subflows"; then 2402 pm_nl_set_limits $ns1 0 2 2403 pm_nl_set_limits $ns2 0 2 2404 addr_nr_ns2=2 speed=slow cestab_ns2=1 \ 2405 run_tests $ns1 $ns2 10.0.1.1 2406 chk_join_nr 2 2 2 2407 chk_cestab_nr $ns2 0 2408 fi 2409 2410 # add multiple subflows IPv6 2411 if reset "add multiple subflows IPv6"; then 2412 pm_nl_set_limits $ns1 0 2 2413 pm_nl_set_limits $ns2 0 2 2414 addr_nr_ns2=2 speed=slow cestab_ns2=1 \ 2415 run_tests $ns1 $ns2 dead:beef:1::1 2416 chk_join_nr 2 2 2 2417 chk_cestab_nr $ns2 0 2418 fi 2419 2420 # add multiple addresses IPv6 2421 if reset "add multiple addresses IPv6"; then 2422 pm_nl_set_limits $ns1 0 2 2423 pm_nl_set_limits $ns2 2 2 2424 addr_nr_ns1=2 speed=slow cestab_ns1=1 \ 2425 run_tests $ns1 $ns2 dead:beef:1::1 2426 chk_join_nr 2 2 2 2427 chk_add_nr 2 2 2428 chk_cestab_nr $ns1 0 2429 fi 2430} 2431 2432ipv6_tests() 2433{ 2434 # subflow IPv6 2435 if reset "single subflow IPv6"; then 2436 pm_nl_set_limits $ns1 0 1 2437 pm_nl_set_limits $ns2 0 1 2438 pm_nl_add_endpoint $ns2 dead:beef:3::2 dev ns2eth3 flags subflow 2439 speed=slow \ 2440 run_tests $ns1 $ns2 dead:beef:1::1 2441 chk_join_nr 1 1 1 2442 fi 2443 2444 # add_address, unused IPv6 2445 if reset "unused signal address IPv6"; then 2446 pm_nl_add_endpoint $ns1 dead:beef:2::1 flags signal 2447 speed=slow \ 2448 run_tests $ns1 $ns2 dead:beef:1::1 2449 chk_join_nr 0 0 0 2450 chk_add_nr 1 1 2451 fi 2452 2453 # signal address IPv6 2454 if reset "single address IPv6"; then 2455 pm_nl_set_limits $ns1 0 1 2456 pm_nl_add_endpoint $ns1 dead:beef:2::1 flags signal 2457 pm_nl_set_limits $ns2 1 1 2458 speed=slow \ 2459 run_tests $ns1 $ns2 dead:beef:1::1 2460 chk_join_nr 1 1 1 2461 chk_add_nr 1 1 2462 fi 2463 2464 # single address IPv6, remove 2465 if reset "remove single address IPv6"; then 2466 pm_nl_set_limits $ns1 0 1 2467 pm_nl_add_endpoint $ns1 dead:beef:2::1 flags signal 2468 pm_nl_set_limits $ns2 1 1 2469 addr_nr_ns1=-1 speed=slow \ 2470 run_tests $ns1 $ns2 dead:beef:1::1 2471 chk_join_nr 1 1 1 2472 chk_add_nr 1 1 2473 chk_rm_nr 1 1 invert 2474 fi 2475 2476 # subflow and signal IPv6, remove 2477 if reset "remove subflow and signal IPv6"; then 2478 pm_nl_set_limits $ns1 0 2 2479 pm_nl_add_endpoint $ns1 dead:beef:2::1 flags signal 2480 pm_nl_set_limits $ns2 1 2 2481 pm_nl_add_endpoint $ns2 dead:beef:3::2 dev ns2eth3 flags subflow 2482 addr_nr_ns1=-1 addr_nr_ns2=-1 speed=slow \ 2483 run_tests $ns1 $ns2 dead:beef:1::1 2484 chk_join_nr 2 2 2 2485 chk_add_nr 1 1 2486 chk_rm_nr 1 1 2487 fi 2488} 2489 2490v4mapped_tests() 2491{ 2492 # subflow IPv4-mapped to IPv4-mapped 2493 if reset "single subflow IPv4-mapped"; then 2494 pm_nl_set_limits $ns1 0 1 2495 pm_nl_set_limits $ns2 0 1 2496 pm_nl_add_endpoint $ns2 "::ffff:10.0.3.2" flags subflow 2497 run_tests $ns1 $ns2 "::ffff:10.0.1.1" 2498 chk_join_nr 1 1 1 2499 fi 2500 2501 # signal address IPv4-mapped with IPv4-mapped sk 2502 if reset "signal address IPv4-mapped"; then 2503 pm_nl_set_limits $ns1 0 1 2504 pm_nl_set_limits $ns2 1 1 2505 pm_nl_add_endpoint $ns1 "::ffff:10.0.2.1" flags signal 2506 run_tests $ns1 $ns2 "::ffff:10.0.1.1" 2507 chk_join_nr 1 1 1 2508 chk_add_nr 1 1 2509 fi 2510 2511 # subflow v4-map-v6 2512 if reset "single subflow v4-map-v6"; then 2513 pm_nl_set_limits $ns1 0 1 2514 pm_nl_set_limits $ns2 0 1 2515 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow 2516 run_tests $ns1 $ns2 "::ffff:10.0.1.1" 2517 chk_join_nr 1 1 1 2518 fi 2519 2520 # signal address v4-map-v6 2521 if reset "signal address v4-map-v6"; then 2522 pm_nl_set_limits $ns1 0 1 2523 pm_nl_set_limits $ns2 1 1 2524 pm_nl_add_endpoint $ns1 10.0.2.1 flags signal 2525 run_tests $ns1 $ns2 "::ffff:10.0.1.1" 2526 chk_join_nr 1 1 1 2527 chk_add_nr 1 1 2528 fi 2529 2530 # subflow v6-map-v4 2531 if reset "single subflow v6-map-v4"; then 2532 pm_nl_set_limits $ns1 0 1 2533 pm_nl_set_limits $ns2 0 1 2534 pm_nl_add_endpoint $ns2 "::ffff:10.0.3.2" flags subflow 2535 run_tests $ns1 $ns2 10.0.1.1 2536 chk_join_nr 1 1 1 2537 fi 2538 2539 # signal address v6-map-v4 2540 if reset "signal address v6-map-v4"; then 2541 pm_nl_set_limits $ns1 0 1 2542 pm_nl_set_limits $ns2 1 1 2543 pm_nl_add_endpoint $ns1 "::ffff:10.0.2.1" flags signal 2544 run_tests $ns1 $ns2 10.0.1.1 2545 chk_join_nr 1 1 1 2546 chk_add_nr 1 1 2547 fi 2548 2549 # no subflow IPv6 to v4 address 2550 if reset "no JOIN with diff families v4-v6"; then 2551 pm_nl_set_limits $ns1 0 1 2552 pm_nl_set_limits $ns2 0 1 2553 pm_nl_add_endpoint $ns2 dead:beef:2::2 flags subflow 2554 run_tests $ns1 $ns2 10.0.1.1 2555 chk_join_nr 0 0 0 2556 fi 2557 2558 # no subflow IPv6 to v4 address even if v6 has a valid v4 at the end 2559 if reset "no JOIN with diff families v4-v6-2"; then 2560 pm_nl_set_limits $ns1 0 1 2561 pm_nl_set_limits $ns2 0 1 2562 pm_nl_add_endpoint $ns2 dead:beef:2::10.0.3.2 flags subflow 2563 run_tests $ns1 $ns2 10.0.1.1 2564 chk_join_nr 0 0 0 2565 fi 2566 2567 # no subflow IPv4 to v6 address, no need to slow down too then 2568 if reset "no JOIN with diff families v6-v4"; then 2569 pm_nl_set_limits $ns1 0 1 2570 pm_nl_set_limits $ns2 0 1 2571 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow 2572 run_tests $ns1 $ns2 dead:beef:1::1 2573 chk_join_nr 0 0 0 2574 fi 2575} 2576 2577mixed_tests() 2578{ 2579 if reset "IPv4 sockets do not use IPv6 addresses" && 2580 continue_if mptcp_lib_kversion_ge 6.3; then 2581 pm_nl_set_limits $ns1 0 1 2582 pm_nl_set_limits $ns2 1 1 2583 pm_nl_add_endpoint $ns1 dead:beef:2::1 flags signal 2584 speed=slow \ 2585 run_tests $ns1 $ns2 10.0.1.1 2586 chk_join_nr 0 0 0 2587 fi 2588 2589 # Need an IPv6 mptcp socket to allow subflows of both families 2590 if reset "simult IPv4 and IPv6 subflows" && 2591 continue_if mptcp_lib_kversion_ge 6.3; then 2592 pm_nl_set_limits $ns1 0 1 2593 pm_nl_set_limits $ns2 1 1 2594 pm_nl_add_endpoint $ns1 10.0.1.1 flags signal 2595 speed=slow \ 2596 run_tests $ns1 $ns2 dead:beef:2::1 2597 chk_join_nr 1 1 1 2598 fi 2599 2600 # cross families subflows will not be created even in fullmesh mode 2601 if reset "simult IPv4 and IPv6 subflows, fullmesh 1x1" && 2602 continue_if mptcp_lib_kversion_ge 6.3; then 2603 pm_nl_set_limits $ns1 0 4 2604 pm_nl_set_limits $ns2 1 4 2605 pm_nl_add_endpoint $ns2 dead:beef:2::2 flags subflow,fullmesh 2606 pm_nl_add_endpoint $ns1 10.0.1.1 flags signal 2607 speed=slow \ 2608 run_tests $ns1 $ns2 dead:beef:2::1 2609 chk_join_nr 1 1 1 2610 fi 2611 2612 # fullmesh still tries to create all the possibly subflows with 2613 # matching family 2614 if reset "simult IPv4 and IPv6 subflows, fullmesh 2x2" && 2615 continue_if mptcp_lib_kversion_ge 6.3; then 2616 pm_nl_set_limits $ns1 0 4 2617 pm_nl_set_limits $ns2 2 4 2618 pm_nl_add_endpoint $ns1 10.0.2.1 flags signal 2619 pm_nl_add_endpoint $ns1 dead:beef:2::1 flags signal 2620 fullmesh=1 speed=slow \ 2621 run_tests $ns1 $ns2 dead:beef:1::1 2622 chk_join_nr 4 4 4 2623 fi 2624} 2625 2626backup_tests() 2627{ 2628 # single subflow, backup 2629 if reset "single subflow, backup" && 2630 continue_if mptcp_lib_kallsyms_has "subflow_rebuild_header$"; then 2631 pm_nl_set_limits $ns1 0 1 2632 pm_nl_set_limits $ns2 0 1 2633 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow,backup 2634 sflags=nobackup speed=slow \ 2635 run_tests $ns1 $ns2 10.0.1.1 2636 chk_join_nr 1 1 1 2637 chk_prio_nr 0 1 1 0 2638 fi 2639 2640 # single address, backup 2641 if reset "single address, backup" && 2642 continue_if mptcp_lib_kallsyms_has "subflow_rebuild_header$"; then 2643 pm_nl_set_limits $ns1 0 1 2644 pm_nl_add_endpoint $ns1 10.0.2.1 flags signal,backup 2645 pm_nl_set_limits $ns2 1 1 2646 sflags=nobackup speed=slow \ 2647 run_tests $ns1 $ns2 10.0.1.1 2648 chk_join_nr 1 1 1 2649 chk_add_nr 1 1 2650 chk_prio_nr 1 0 0 1 2651 fi 2652 2653 # single address, switch to backup 2654 if reset "single address, switch to backup" && 2655 continue_if mptcp_lib_kallsyms_has "subflow_rebuild_header$"; then 2656 pm_nl_set_limits $ns1 0 1 2657 pm_nl_add_endpoint $ns1 10.0.2.1 flags signal 2658 pm_nl_set_limits $ns2 1 1 2659 sflags=backup speed=slow \ 2660 run_tests $ns1 $ns2 10.0.1.1 2661 chk_join_nr 1 1 1 2662 chk_add_nr 1 1 2663 chk_prio_nr 1 1 0 0 2664 fi 2665 2666 # single address with port, backup 2667 if reset "single address with port, backup" && 2668 continue_if mptcp_lib_kallsyms_has "subflow_rebuild_header$"; then 2669 pm_nl_set_limits $ns1 0 1 2670 pm_nl_add_endpoint $ns1 10.0.2.1 flags signal,backup port 10100 2671 pm_nl_set_limits $ns2 1 1 2672 sflags=nobackup speed=slow \ 2673 run_tests $ns1 $ns2 10.0.1.1 2674 chk_join_nr 1 1 1 2675 chk_add_nr 1 1 2676 chk_prio_nr 1 0 0 1 2677 fi 2678 2679 if reset "mpc backup" && 2680 continue_if mptcp_lib_kallsyms_doesnt_have "T mptcp_subflow_send_ack$"; then 2681 pm_nl_add_endpoint $ns2 10.0.1.2 flags subflow,backup 2682 speed=slow \ 2683 run_tests $ns1 $ns2 10.0.1.1 2684 chk_join_nr 0 0 0 2685 chk_prio_nr 0 1 0 0 2686 fi 2687 2688 if reset "mpc backup both sides" && 2689 continue_if mptcp_lib_kallsyms_doesnt_have "T mptcp_subflow_send_ack$"; then 2690 pm_nl_set_limits $ns1 0 2 2691 pm_nl_set_limits $ns2 1 2 2692 pm_nl_add_endpoint $ns1 10.0.1.1 flags signal,backup 2693 pm_nl_add_endpoint $ns2 10.0.1.2 flags subflow,backup 2694 2695 # 10.0.2.2 (non-backup) -> 10.0.1.1 (backup) 2696 pm_nl_add_endpoint $ns2 10.0.2.2 flags subflow 2697 # 10.0.1.2 (backup) -> 10.0.2.1 (non-backup) 2698 pm_nl_add_endpoint $ns1 10.0.2.1 flags signal 2699 ip -net "$ns2" route add 10.0.2.1 via 10.0.1.1 dev ns2eth1 # force this path 2700 2701 speed=slow \ 2702 run_tests $ns1 $ns2 10.0.1.1 2703 chk_join_nr 2 2 2 2704 chk_prio_nr 1 1 1 1 2705 fi 2706 2707 if reset "mpc switch to backup" && 2708 continue_if mptcp_lib_kallsyms_doesnt_have "T mptcp_subflow_send_ack$"; then 2709 pm_nl_add_endpoint $ns2 10.0.1.2 flags subflow 2710 sflags=backup speed=slow \ 2711 run_tests $ns1 $ns2 10.0.1.1 2712 chk_join_nr 0 0 0 2713 chk_prio_nr 0 1 0 0 2714 fi 2715 2716 if reset "mpc switch to backup both sides" && 2717 continue_if mptcp_lib_kallsyms_doesnt_have "T mptcp_subflow_send_ack$"; then 2718 pm_nl_add_endpoint $ns1 10.0.1.1 flags subflow 2719 pm_nl_add_endpoint $ns2 10.0.1.2 flags subflow 2720 sflags=backup speed=slow \ 2721 run_tests $ns1 $ns2 10.0.1.1 2722 chk_join_nr 0 0 0 2723 chk_prio_nr 1 1 0 0 2724 fi 2725} 2726 2727verify_listener_events() 2728{ 2729 local e_type=$2 2730 local e_saddr=$4 2731 local e_sport=$5 2732 local name 2733 2734 if [ $e_type = $MPTCP_LIB_EVENT_LISTENER_CREATED ]; then 2735 name="LISTENER_CREATED" 2736 elif [ $e_type = $MPTCP_LIB_EVENT_LISTENER_CLOSED ]; then 2737 name="LISTENER_CLOSED " 2738 else 2739 name="$e_type" 2740 fi 2741 2742 print_check "$name $e_saddr:$e_sport" 2743 2744 if ! mptcp_lib_kallsyms_has "mptcp_event_pm_listener$"; then 2745 print_skip "event not supported" 2746 return 2747 fi 2748 2749 if mptcp_lib_verify_listener_events "${@}"; then 2750 print_ok 2751 return 0 2752 fi 2753 fail_test 2754} 2755 2756add_addr_ports_tests() 2757{ 2758 # signal address with port 2759 if reset "signal address with port"; then 2760 pm_nl_set_limits $ns1 0 1 2761 pm_nl_set_limits $ns2 1 1 2762 pm_nl_add_endpoint $ns1 10.0.2.1 flags signal port 10100 2763 run_tests $ns1 $ns2 10.0.1.1 2764 chk_join_nr 1 1 1 2765 chk_add_nr 1 1 1 2766 fi 2767 2768 # subflow and signal with port 2769 if reset "subflow and signal with port"; then 2770 pm_nl_add_endpoint $ns1 10.0.2.1 flags signal port 10100 2771 pm_nl_set_limits $ns1 0 2 2772 pm_nl_set_limits $ns2 1 2 2773 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow 2774 run_tests $ns1 $ns2 10.0.1.1 2775 chk_join_nr 2 2 2 2776 chk_add_nr 1 1 1 2777 fi 2778 2779 # single address with port, remove 2780 # pm listener events 2781 if reset_with_events "remove single address with port"; then 2782 pm_nl_set_limits $ns1 0 1 2783 pm_nl_add_endpoint $ns1 10.0.2.1 flags signal port 10100 2784 pm_nl_set_limits $ns2 1 1 2785 addr_nr_ns1=-1 speed=slow \ 2786 run_tests $ns1 $ns2 10.0.1.1 2787 chk_join_nr 1 1 1 2788 chk_add_nr 1 1 1 2789 chk_rm_nr 1 1 invert 2790 2791 verify_listener_events $evts_ns1 $MPTCP_LIB_EVENT_LISTENER_CREATED \ 2792 $MPTCP_LIB_AF_INET 10.0.2.1 10100 2793 verify_listener_events $evts_ns1 $MPTCP_LIB_EVENT_LISTENER_CLOSED \ 2794 $MPTCP_LIB_AF_INET 10.0.2.1 10100 2795 kill_events_pids 2796 fi 2797 2798 # subflow and signal with port, remove 2799 if reset "remove subflow and signal with port"; then 2800 pm_nl_set_limits $ns1 0 2 2801 pm_nl_add_endpoint $ns1 10.0.2.1 flags signal port 10100 2802 pm_nl_set_limits $ns2 1 2 2803 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow 2804 addr_nr_ns1=-1 addr_nr_ns2=-1 speed=slow \ 2805 run_tests $ns1 $ns2 10.0.1.1 2806 chk_join_nr 2 2 2 2807 chk_add_nr 1 1 1 2808 chk_rm_nr 1 1 2809 fi 2810 2811 # subflows and signal with port, flush 2812 if reset "flush subflows and signal with port"; then 2813 pm_nl_set_limits $ns1 0 3 2814 pm_nl_add_endpoint $ns1 10.0.2.1 flags signal port 10100 2815 pm_nl_set_limits $ns2 1 3 2816 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow 2817 pm_nl_add_endpoint $ns2 10.0.4.2 flags subflow 2818 addr_nr_ns1=-8 addr_nr_ns2=-2 speed=slow \ 2819 run_tests $ns1 $ns2 10.0.1.1 2820 chk_join_nr 3 3 3 2821 chk_add_nr 1 1 2822 chk_rm_nr 1 3 invert simult 2823 fi 2824 2825 # multiple addresses with port 2826 if reset "multiple addresses with port"; then 2827 pm_nl_set_limits $ns1 2 2 2828 pm_nl_add_endpoint $ns1 10.0.2.1 flags signal port 10100 2829 pm_nl_add_endpoint $ns1 10.0.3.1 flags signal port 10100 2830 pm_nl_set_limits $ns2 2 2 2831 run_tests $ns1 $ns2 10.0.1.1 2832 chk_join_nr 2 2 2 2833 chk_add_nr 2 2 2 2834 fi 2835 2836 # multiple addresses with ports 2837 if reset "multiple addresses with ports"; then 2838 pm_nl_set_limits $ns1 2 2 2839 pm_nl_add_endpoint $ns1 10.0.2.1 flags signal port 10100 2840 pm_nl_add_endpoint $ns1 10.0.3.1 flags signal port 10101 2841 pm_nl_set_limits $ns2 2 2 2842 run_tests $ns1 $ns2 10.0.1.1 2843 chk_join_nr 2 2 2 2844 chk_add_nr 2 2 2 2845 fi 2846} 2847 2848syncookies_tests() 2849{ 2850 # single subflow, syncookies 2851 if reset_with_cookies "single subflow with syn cookies"; then 2852 pm_nl_set_limits $ns1 0 1 2853 pm_nl_set_limits $ns2 0 1 2854 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow 2855 run_tests $ns1 $ns2 10.0.1.1 2856 chk_join_nr 1 1 1 2857 fi 2858 2859 # multiple subflows with syn cookies 2860 if reset_with_cookies "multiple subflows with syn cookies"; then 2861 pm_nl_set_limits $ns1 0 2 2862 pm_nl_set_limits $ns2 0 2 2863 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow 2864 pm_nl_add_endpoint $ns2 10.0.2.2 flags subflow 2865 run_tests $ns1 $ns2 10.0.1.1 2866 chk_join_nr 2 2 2 2867 fi 2868 2869 # multiple subflows limited by server 2870 if reset_with_cookies "subflows limited by server w cookies"; then 2871 pm_nl_set_limits $ns1 0 1 2872 pm_nl_set_limits $ns2 0 2 2873 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow 2874 pm_nl_add_endpoint $ns2 10.0.2.2 flags subflow 2875 run_tests $ns1 $ns2 10.0.1.1 2876 chk_join_nr 2 1 1 2877 fi 2878 2879 # test signal address with cookies 2880 if reset_with_cookies "signal address with syn cookies"; then 2881 pm_nl_set_limits $ns1 0 1 2882 pm_nl_set_limits $ns2 1 1 2883 pm_nl_add_endpoint $ns1 10.0.2.1 flags signal 2884 run_tests $ns1 $ns2 10.0.1.1 2885 chk_join_nr 1 1 1 2886 chk_add_nr 1 1 2887 fi 2888 2889 # test cookie with subflow and signal 2890 if reset_with_cookies "subflow and signal w cookies"; then 2891 pm_nl_add_endpoint $ns1 10.0.2.1 flags signal 2892 pm_nl_set_limits $ns1 0 2 2893 pm_nl_set_limits $ns2 1 2 2894 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow 2895 run_tests $ns1 $ns2 10.0.1.1 2896 chk_join_nr 2 2 2 2897 chk_add_nr 1 1 2898 fi 2899 2900 # accept and use add_addr with additional subflows 2901 if reset_with_cookies "subflows and signal w. cookies"; then 2902 pm_nl_set_limits $ns1 0 3 2903 pm_nl_add_endpoint $ns1 10.0.2.1 flags signal 2904 pm_nl_set_limits $ns2 1 3 2905 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow 2906 pm_nl_add_endpoint $ns2 10.0.4.2 flags subflow 2907 run_tests $ns1 $ns2 10.0.1.1 2908 chk_join_nr 3 3 3 2909 chk_add_nr 1 1 2910 fi 2911} 2912 2913checksum_tests() 2914{ 2915 # checksum test 0 0 2916 if reset_with_checksum 0 0; then 2917 pm_nl_set_limits $ns1 0 1 2918 pm_nl_set_limits $ns2 0 1 2919 run_tests $ns1 $ns2 10.0.1.1 2920 chk_join_nr 0 0 0 2921 fi 2922 2923 # checksum test 1 1 2924 if reset_with_checksum 1 1; then 2925 pm_nl_set_limits $ns1 0 1 2926 pm_nl_set_limits $ns2 0 1 2927 run_tests $ns1 $ns2 10.0.1.1 2928 chk_join_nr 0 0 0 2929 fi 2930 2931 # checksum test 0 1 2932 if reset_with_checksum 0 1; then 2933 pm_nl_set_limits $ns1 0 1 2934 pm_nl_set_limits $ns2 0 1 2935 run_tests $ns1 $ns2 10.0.1.1 2936 chk_join_nr 0 0 0 2937 fi 2938 2939 # checksum test 1 0 2940 if reset_with_checksum 1 0; then 2941 pm_nl_set_limits $ns1 0 1 2942 pm_nl_set_limits $ns2 0 1 2943 run_tests $ns1 $ns2 10.0.1.1 2944 chk_join_nr 0 0 0 2945 fi 2946} 2947 2948deny_join_id0_tests() 2949{ 2950 # subflow allow join id0 ns1 2951 if reset_with_allow_join_id0 "single subflow allow join id0 ns1" 1 0; then 2952 pm_nl_set_limits $ns1 1 1 2953 pm_nl_set_limits $ns2 1 1 2954 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow 2955 run_tests $ns1 $ns2 10.0.1.1 2956 chk_join_nr 1 1 1 2957 fi 2958 2959 # subflow allow join id0 ns2 2960 if reset_with_allow_join_id0 "single subflow allow join id0 ns2" 0 1; then 2961 pm_nl_set_limits $ns1 1 1 2962 pm_nl_set_limits $ns2 1 1 2963 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow 2964 run_tests $ns1 $ns2 10.0.1.1 2965 chk_join_nr 0 0 0 2966 fi 2967 2968 # signal address allow join id0 ns1 2969 # ADD_ADDRs are not affected by allow_join_id0 value. 2970 if reset_with_allow_join_id0 "signal address allow join id0 ns1" 1 0; then 2971 pm_nl_set_limits $ns1 1 1 2972 pm_nl_set_limits $ns2 1 1 2973 pm_nl_add_endpoint $ns1 10.0.2.1 flags signal 2974 run_tests $ns1 $ns2 10.0.1.1 2975 chk_join_nr 1 1 1 2976 chk_add_nr 1 1 2977 fi 2978 2979 # signal address allow join id0 ns2 2980 # ADD_ADDRs are not affected by allow_join_id0 value. 2981 if reset_with_allow_join_id0 "signal address allow join id0 ns2" 0 1; then 2982 pm_nl_set_limits $ns1 1 1 2983 pm_nl_set_limits $ns2 1 1 2984 pm_nl_add_endpoint $ns1 10.0.2.1 flags signal 2985 run_tests $ns1 $ns2 10.0.1.1 2986 chk_join_nr 1 1 1 2987 chk_add_nr 1 1 2988 fi 2989 2990 # subflow and address allow join id0 ns1 2991 if reset_with_allow_join_id0 "subflow and address allow join id0 1" 1 0; then 2992 pm_nl_set_limits $ns1 2 2 2993 pm_nl_set_limits $ns2 2 2 2994 pm_nl_add_endpoint $ns1 10.0.2.1 flags signal 2995 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow 2996 run_tests $ns1 $ns2 10.0.1.1 2997 chk_join_nr 2 2 2 2998 fi 2999 3000 # subflow and address allow join id0 ns2 3001 if reset_with_allow_join_id0 "subflow and address allow join id0 2" 0 1; then 3002 pm_nl_set_limits $ns1 2 2 3003 pm_nl_set_limits $ns2 2 2 3004 pm_nl_add_endpoint $ns1 10.0.2.1 flags signal 3005 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow 3006 run_tests $ns1 $ns2 10.0.1.1 3007 chk_join_nr 1 1 1 3008 fi 3009} 3010 3011fullmesh_tests() 3012{ 3013 # fullmesh 1 3014 # 2 fullmesh addrs in ns2, added before the connection, 3015 # 1 non-fullmesh addr in ns1, added during the connection. 3016 if reset "fullmesh test 2x1"; then 3017 pm_nl_set_limits $ns1 0 4 3018 pm_nl_set_limits $ns2 1 4 3019 pm_nl_add_endpoint $ns2 10.0.2.2 flags subflow,fullmesh 3020 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow,fullmesh 3021 addr_nr_ns1=1 speed=slow \ 3022 run_tests $ns1 $ns2 10.0.1.1 3023 chk_join_nr 4 4 4 3024 chk_add_nr 1 1 3025 fi 3026 3027 # fullmesh 2 3028 # 1 non-fullmesh addr in ns1, added before the connection, 3029 # 1 fullmesh addr in ns2, added during the connection. 3030 if reset "fullmesh test 1x1"; then 3031 pm_nl_set_limits $ns1 1 3 3032 pm_nl_set_limits $ns2 1 3 3033 pm_nl_add_endpoint $ns1 10.0.2.1 flags signal 3034 fullmesh=1 speed=slow \ 3035 run_tests $ns1 $ns2 10.0.1.1 3036 chk_join_nr 3 3 3 3037 chk_add_nr 1 1 3038 fi 3039 3040 # fullmesh 3 3041 # 1 non-fullmesh addr in ns1, added before the connection, 3042 # 2 fullmesh addrs in ns2, added during the connection. 3043 if reset "fullmesh test 1x2"; then 3044 pm_nl_set_limits $ns1 2 5 3045 pm_nl_set_limits $ns2 1 5 3046 pm_nl_add_endpoint $ns1 10.0.2.1 flags signal 3047 fullmesh=2 speed=slow \ 3048 run_tests $ns1 $ns2 10.0.1.1 3049 chk_join_nr 5 5 5 3050 chk_add_nr 1 1 3051 fi 3052 3053 # fullmesh 4 3054 # 1 non-fullmesh addr in ns1, added before the connection, 3055 # 2 fullmesh addrs in ns2, added during the connection, 3056 # limit max_subflows to 4. 3057 if reset "fullmesh test 1x2, limited"; then 3058 pm_nl_set_limits $ns1 2 4 3059 pm_nl_set_limits $ns2 1 4 3060 pm_nl_add_endpoint $ns1 10.0.2.1 flags signal 3061 fullmesh=2 speed=slow \ 3062 run_tests $ns1 $ns2 10.0.1.1 3063 chk_join_nr 4 4 4 3064 chk_add_nr 1 1 3065 fi 3066 3067 # set fullmesh flag 3068 if reset "set fullmesh flag test" && 3069 continue_if mptcp_lib_kversion_ge 5.18; then 3070 pm_nl_set_limits $ns1 4 4 3071 pm_nl_add_endpoint $ns1 10.0.2.1 flags subflow 3072 pm_nl_set_limits $ns2 4 4 3073 addr_nr_ns2=1 sflags=fullmesh speed=slow \ 3074 run_tests $ns1 $ns2 10.0.1.1 3075 chk_join_nr 2 2 2 3076 chk_rm_nr 0 1 3077 fi 3078 3079 # set nofullmesh flag 3080 if reset "set nofullmesh flag test" && 3081 continue_if mptcp_lib_kversion_ge 5.18; then 3082 pm_nl_set_limits $ns1 4 4 3083 pm_nl_add_endpoint $ns1 10.0.2.1 flags subflow,fullmesh 3084 pm_nl_set_limits $ns2 4 4 3085 fullmesh=1 sflags=nofullmesh speed=slow \ 3086 run_tests $ns1 $ns2 10.0.1.1 3087 chk_join_nr 2 2 2 3088 chk_rm_nr 0 1 3089 fi 3090 3091 # set backup,fullmesh flags 3092 if reset "set backup,fullmesh flags test" && 3093 continue_if mptcp_lib_kversion_ge 5.18; then 3094 pm_nl_set_limits $ns1 4 4 3095 pm_nl_add_endpoint $ns1 10.0.2.1 flags subflow 3096 pm_nl_set_limits $ns2 4 4 3097 addr_nr_ns2=1 sflags=backup,fullmesh speed=slow \ 3098 run_tests $ns1 $ns2 10.0.1.1 3099 chk_join_nr 2 2 2 3100 chk_prio_nr 0 1 1 0 3101 chk_rm_nr 0 1 3102 fi 3103 3104 # set nobackup,nofullmesh flags 3105 if reset "set nobackup,nofullmesh flags test" && 3106 continue_if mptcp_lib_kversion_ge 5.18; then 3107 pm_nl_set_limits $ns1 4 4 3108 pm_nl_set_limits $ns2 4 4 3109 pm_nl_add_endpoint $ns2 10.0.2.2 flags subflow,backup,fullmesh 3110 sflags=nobackup,nofullmesh speed=slow \ 3111 run_tests $ns1 $ns2 10.0.1.1 3112 chk_join_nr 2 2 2 3113 chk_prio_nr 0 1 1 0 3114 chk_rm_nr 0 1 3115 fi 3116} 3117 3118fastclose_tests() 3119{ 3120 if reset_check_counter "fastclose test" "MPTcpExtMPFastcloseTx"; then 3121 MPTCP_LIB_SUBTEST_FLAKY=1 3122 test_linkfail=1024 fastclose=client \ 3123 run_tests $ns1 $ns2 10.0.1.1 3124 chk_join_nr 0 0 0 3125 chk_fclose_nr 1 1 3126 chk_rst_nr 1 1 invert 3127 fi 3128 3129 if reset_check_counter "fastclose server test" "MPTcpExtMPFastcloseRx"; then 3130 MPTCP_LIB_SUBTEST_FLAKY=1 3131 test_linkfail=1024 fastclose=server \ 3132 run_tests $ns1 $ns2 10.0.1.1 3133 chk_join_nr 0 0 0 0 0 0 1 3134 chk_fclose_nr 1 1 invert 3135 chk_rst_nr 1 1 3136 fi 3137} 3138 3139pedit_action_pkts() 3140{ 3141 tc -n $ns2 -j -s action show action pedit index 100 | \ 3142 mptcp_lib_get_info_value \"packets\" packets 3143} 3144 3145fail_tests() 3146{ 3147 # single subflow 3148 if reset_with_fail "Infinite map" 1; then 3149 MPTCP_LIB_SUBTEST_FLAKY=1 3150 test_linkfail=128 \ 3151 run_tests $ns1 $ns2 10.0.1.1 3152 chk_join_nr 0 0 0 +1 +0 1 0 1 "$(pedit_action_pkts)" 3153 chk_fail_nr 1 -1 invert 3154 fi 3155 3156 # multiple subflows 3157 if reset_with_fail "MP_FAIL MP_RST" 2; then 3158 MPTCP_LIB_SUBTEST_FLAKY=1 3159 tc -n $ns2 qdisc add dev ns2eth1 root netem rate 1mbit delay 5ms 3160 pm_nl_set_limits $ns1 0 1 3161 pm_nl_set_limits $ns2 0 1 3162 pm_nl_add_endpoint $ns2 10.0.2.2 dev ns2eth2 flags subflow 3163 test_linkfail=1024 \ 3164 run_tests $ns1 $ns2 10.0.1.1 3165 chk_join_nr 1 1 1 1 0 1 1 0 "$(pedit_action_pkts)" 3166 fi 3167} 3168 3169# $1: ns ; $2: addr ; $3: id 3170userspace_pm_add_addr() 3171{ 3172 local evts=$evts_ns1 3173 local tk 3174 3175 [ "$1" == "$ns2" ] && evts=$evts_ns2 3176 tk=$(mptcp_lib_evts_get_info token "$evts") 3177 3178 ip netns exec $1 ./pm_nl_ctl ann $2 token $tk id $3 3179 sleep 1 3180} 3181 3182# $1: ns ; $2: id 3183userspace_pm_rm_addr() 3184{ 3185 local evts=$evts_ns1 3186 local tk 3187 local cnt 3188 3189 [ "$1" == "$ns2" ] && evts=$evts_ns2 3190 tk=$(mptcp_lib_evts_get_info token "$evts") 3191 3192 cnt=$(rm_addr_count ${1}) 3193 ip netns exec $1 ./pm_nl_ctl rem token $tk id $2 3194 wait_rm_addr $1 "${cnt}" 3195} 3196 3197# $1: ns ; $2: addr ; $3: id 3198userspace_pm_add_sf() 3199{ 3200 local evts=$evts_ns1 3201 local tk da dp 3202 3203 [ "$1" == "$ns2" ] && evts=$evts_ns2 3204 tk=$(mptcp_lib_evts_get_info token "$evts") 3205 da=$(mptcp_lib_evts_get_info daddr4 "$evts") 3206 dp=$(mptcp_lib_evts_get_info dport "$evts") 3207 3208 ip netns exec $1 ./pm_nl_ctl csf lip $2 lid $3 \ 3209 rip $da rport $dp token $tk 3210 sleep 1 3211} 3212 3213# $1: ns ; $2: addr $3: event type 3214userspace_pm_rm_sf() 3215{ 3216 local evts=$evts_ns1 3217 local t=${3:-1} 3218 local ip 3219 local tk da dp sp 3220 local cnt 3221 3222 [ "$1" == "$ns2" ] && evts=$evts_ns2 3223 [ -n "$(mptcp_lib_evts_get_info "saddr4" "$evts" $t)" ] && ip=4 3224 [ -n "$(mptcp_lib_evts_get_info "saddr6" "$evts" $t)" ] && ip=6 3225 tk=$(mptcp_lib_evts_get_info token "$evts") 3226 da=$(mptcp_lib_evts_get_info "daddr$ip" "$evts" $t $2) 3227 dp=$(mptcp_lib_evts_get_info dport "$evts" $t $2) 3228 sp=$(mptcp_lib_evts_get_info sport "$evts" $t $2) 3229 3230 cnt=$(rm_sf_count ${1}) 3231 ip netns exec $1 ./pm_nl_ctl dsf lip $2 lport $sp \ 3232 rip $da rport $dp token $tk 3233 wait_rm_sf $1 "${cnt}" 3234} 3235 3236check_output() 3237{ 3238 local cmd="$1" 3239 local expected="$2" 3240 local msg="$3" 3241 local rc=0 3242 3243 mptcp_lib_check_output "${err}" "${cmd}" "${expected}" || rc=${?} 3244 if [ ${rc} -eq 2 ]; then 3245 fail_test "fail to check output # error ${rc}" 3246 elif [ ${rc} -eq 0 ]; then 3247 print_ok 3248 elif [ ${rc} -eq 1 ]; then 3249 fail_test "fail to check output # different output" 3250 fi 3251} 3252 3253# $1: ns 3254userspace_pm_dump() 3255{ 3256 local evts=$evts_ns1 3257 local tk 3258 3259 [ "$1" == "$ns2" ] && evts=$evts_ns2 3260 tk=$(mptcp_lib_evts_get_info token "$evts") 3261 3262 ip netns exec $1 ./pm_nl_ctl dump token $tk 3263} 3264 3265# $1: ns ; $2: id 3266userspace_pm_get_addr() 3267{ 3268 local evts=$evts_ns1 3269 local tk 3270 3271 [ "$1" == "$ns2" ] && evts=$evts_ns2 3272 tk=$(mptcp_lib_evts_get_info token "$evts") 3273 3274 ip netns exec $1 ./pm_nl_ctl get $2 token $tk 3275} 3276 3277userspace_pm_chk_dump_addr() 3278{ 3279 local ns="${1}" 3280 local exp="${2}" 3281 local check="${3}" 3282 3283 print_check "dump addrs ${check}" 3284 3285 if mptcp_lib_kallsyms_has "mptcp_userspace_pm_dump_addr$"; then 3286 check_output "userspace_pm_dump ${ns}" "${exp}" 3287 else 3288 print_skip 3289 fi 3290} 3291 3292userspace_pm_chk_get_addr() 3293{ 3294 local ns="${1}" 3295 local id="${2}" 3296 local exp="${3}" 3297 3298 print_check "get id ${id} addr" 3299 3300 if mptcp_lib_kallsyms_has "mptcp_userspace_pm_get_addr$"; then 3301 check_output "userspace_pm_get_addr ${ns} ${id}" "${exp}" 3302 else 3303 print_skip 3304 fi 3305} 3306 3307userspace_tests() 3308{ 3309 # userspace pm type prevents add_addr 3310 if reset "userspace pm type prevents add_addr" && 3311 continue_if mptcp_lib_has_file '/proc/sys/net/mptcp/pm_type'; then 3312 set_userspace_pm $ns1 3313 pm_nl_set_limits $ns1 0 2 3314 pm_nl_set_limits $ns2 0 2 3315 pm_nl_add_endpoint $ns1 10.0.2.1 flags signal 3316 run_tests $ns1 $ns2 10.0.1.1 3317 chk_join_nr 0 0 0 3318 chk_add_nr 0 0 3319 fi 3320 3321 # userspace pm type does not echo add_addr without daemon 3322 if reset "userspace pm no echo w/o daemon" && 3323 continue_if mptcp_lib_has_file '/proc/sys/net/mptcp/pm_type'; then 3324 set_userspace_pm $ns2 3325 pm_nl_set_limits $ns1 0 2 3326 pm_nl_set_limits $ns2 0 2 3327 pm_nl_add_endpoint $ns1 10.0.2.1 flags signal 3328 run_tests $ns1 $ns2 10.0.1.1 3329 chk_join_nr 0 0 0 3330 chk_add_nr 1 0 3331 fi 3332 3333 # userspace pm type rejects join 3334 if reset "userspace pm type rejects join" && 3335 continue_if mptcp_lib_has_file '/proc/sys/net/mptcp/pm_type'; then 3336 set_userspace_pm $ns1 3337 pm_nl_set_limits $ns1 1 1 3338 pm_nl_set_limits $ns2 1 1 3339 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow 3340 run_tests $ns1 $ns2 10.0.1.1 3341 chk_join_nr 1 1 0 3342 fi 3343 3344 # userspace pm type does not send join 3345 if reset "userspace pm type does not send join" && 3346 continue_if mptcp_lib_has_file '/proc/sys/net/mptcp/pm_type'; then 3347 set_userspace_pm $ns2 3348 pm_nl_set_limits $ns1 1 1 3349 pm_nl_set_limits $ns2 1 1 3350 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow 3351 run_tests $ns1 $ns2 10.0.1.1 3352 chk_join_nr 0 0 0 3353 fi 3354 3355 # userspace pm type prevents mp_prio 3356 if reset "userspace pm type prevents mp_prio" && 3357 continue_if mptcp_lib_has_file '/proc/sys/net/mptcp/pm_type'; then 3358 set_userspace_pm $ns1 3359 pm_nl_set_limits $ns1 1 1 3360 pm_nl_set_limits $ns2 1 1 3361 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow 3362 sflags=backup speed=slow \ 3363 run_tests $ns1 $ns2 10.0.1.1 3364 chk_join_nr 1 1 0 3365 chk_prio_nr 0 0 0 0 3366 fi 3367 3368 # userspace pm type prevents rm_addr 3369 if reset "userspace pm type prevents rm_addr" && 3370 continue_if mptcp_lib_has_file '/proc/sys/net/mptcp/pm_type'; then 3371 set_userspace_pm $ns1 3372 set_userspace_pm $ns2 3373 pm_nl_set_limits $ns1 0 1 3374 pm_nl_set_limits $ns2 0 1 3375 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow 3376 addr_nr_ns2=-1 speed=slow \ 3377 run_tests $ns1 $ns2 10.0.1.1 3378 chk_join_nr 0 0 0 3379 chk_rm_nr 0 0 3380 fi 3381 3382 # userspace pm add & remove address 3383 if reset_with_events "userspace pm add & remove address" && 3384 continue_if mptcp_lib_has_file '/proc/sys/net/mptcp/pm_type'; then 3385 set_userspace_pm $ns1 3386 pm_nl_set_limits $ns2 2 2 3387 speed=5 \ 3388 run_tests $ns1 $ns2 10.0.1.1 & 3389 local tests_pid=$! 3390 wait_mpj $ns1 3391 userspace_pm_add_addr $ns1 10.0.2.1 10 3392 userspace_pm_add_addr $ns1 10.0.3.1 20 3393 chk_join_nr 2 2 2 3394 chk_add_nr 2 2 3395 chk_mptcp_info subflows 2 subflows 2 3396 chk_subflows_total 3 3 3397 chk_mptcp_info add_addr_signal 2 add_addr_accepted 2 3398 userspace_pm_chk_dump_addr "${ns1}" \ 3399 $'id 10 flags signal 10.0.2.1\nid 20 flags signal 10.0.3.1' \ 3400 "signal" 3401 userspace_pm_chk_get_addr "${ns1}" "10" "id 10 flags signal 10.0.2.1" 3402 userspace_pm_chk_get_addr "${ns1}" "20" "id 20 flags signal 10.0.3.1" 3403 userspace_pm_rm_addr $ns1 10 3404 userspace_pm_rm_sf $ns1 "::ffff:10.0.2.1" $MPTCP_LIB_EVENT_SUB_ESTABLISHED 3405 userspace_pm_chk_dump_addr "${ns1}" \ 3406 "id 20 flags signal 10.0.3.1" "after rm_addr 10" 3407 userspace_pm_rm_addr $ns1 20 3408 userspace_pm_rm_sf $ns1 10.0.3.1 $MPTCP_LIB_EVENT_SUB_ESTABLISHED 3409 userspace_pm_chk_dump_addr "${ns1}" "" "after rm_addr 20" 3410 chk_rm_nr 2 2 invert 3411 chk_mptcp_info subflows 0 subflows 0 3412 chk_subflows_total 1 1 3413 kill_events_pids 3414 mptcp_lib_kill_wait $tests_pid 3415 fi 3416 3417 # userspace pm create destroy subflow 3418 if reset_with_events "userspace pm create destroy subflow" && 3419 continue_if mptcp_lib_has_file '/proc/sys/net/mptcp/pm_type'; then 3420 set_userspace_pm $ns2 3421 pm_nl_set_limits $ns1 0 1 3422 speed=5 \ 3423 run_tests $ns1 $ns2 10.0.1.1 & 3424 local tests_pid=$! 3425 wait_mpj $ns2 3426 userspace_pm_add_sf $ns2 10.0.3.2 20 3427 chk_join_nr 1 1 1 3428 chk_mptcp_info subflows 1 subflows 1 3429 chk_subflows_total 2 2 3430 userspace_pm_chk_dump_addr "${ns2}" \ 3431 "id 20 flags subflow 10.0.3.2" \ 3432 "subflow" 3433 userspace_pm_chk_get_addr "${ns2}" "20" "id 20 flags subflow 10.0.3.2" 3434 userspace_pm_rm_addr $ns2 20 3435 userspace_pm_rm_sf $ns2 10.0.3.2 $MPTCP_LIB_EVENT_SUB_ESTABLISHED 3436 userspace_pm_chk_dump_addr "${ns2}" \ 3437 "" \ 3438 "after rm_addr 20" 3439 chk_rm_nr 1 1 3440 chk_mptcp_info subflows 0 subflows 0 3441 chk_subflows_total 1 1 3442 kill_events_pids 3443 mptcp_lib_kill_wait $tests_pid 3444 fi 3445 3446 # userspace pm create id 0 subflow 3447 if reset_with_events "userspace pm create id 0 subflow" && 3448 continue_if mptcp_lib_has_file '/proc/sys/net/mptcp/pm_type'; then 3449 set_userspace_pm $ns2 3450 pm_nl_set_limits $ns1 0 1 3451 speed=5 \ 3452 run_tests $ns1 $ns2 10.0.1.1 & 3453 local tests_pid=$! 3454 wait_mpj $ns2 3455 chk_mptcp_info subflows 0 subflows 0 3456 chk_subflows_total 1 1 3457 userspace_pm_add_sf $ns2 10.0.3.2 0 3458 userspace_pm_chk_dump_addr "${ns2}" \ 3459 "id 0 flags subflow 10.0.3.2" "id 0 subflow" 3460 chk_join_nr 1 1 1 3461 chk_mptcp_info subflows 1 subflows 1 3462 chk_subflows_total 2 2 3463 kill_events_pids 3464 mptcp_lib_kill_wait $tests_pid 3465 fi 3466 3467 # userspace pm remove initial subflow 3468 if reset_with_events "userspace pm remove initial subflow" && 3469 continue_if mptcp_lib_has_file '/proc/sys/net/mptcp/pm_type'; then 3470 set_userspace_pm $ns2 3471 pm_nl_set_limits $ns1 0 1 3472 speed=5 \ 3473 run_tests $ns1 $ns2 10.0.1.1 & 3474 local tests_pid=$! 3475 wait_mpj $ns2 3476 userspace_pm_add_sf $ns2 10.0.3.2 20 3477 chk_join_nr 1 1 1 3478 chk_mptcp_info subflows 1 subflows 1 3479 chk_subflows_total 2 2 3480 userspace_pm_rm_sf $ns2 10.0.1.2 3481 # we don't look at the counter linked to the RM_ADDR but 3482 # to the one linked to the subflows that have been removed 3483 chk_rm_nr 0 1 3484 chk_rst_nr 0 0 invert 3485 chk_mptcp_info subflows 1 subflows 1 3486 chk_subflows_total 1 1 3487 kill_events_pids 3488 mptcp_lib_kill_wait $tests_pid 3489 fi 3490 3491 # userspace pm send RM_ADDR for ID 0 3492 if reset_with_events "userspace pm send RM_ADDR for ID 0" && 3493 continue_if mptcp_lib_has_file '/proc/sys/net/mptcp/pm_type'; then 3494 set_userspace_pm $ns1 3495 pm_nl_set_limits $ns2 1 1 3496 speed=5 \ 3497 run_tests $ns1 $ns2 10.0.1.1 & 3498 local tests_pid=$! 3499 wait_mpj $ns1 3500 userspace_pm_add_addr $ns1 10.0.2.1 10 3501 chk_join_nr 1 1 1 3502 chk_add_nr 1 1 3503 chk_mptcp_info subflows 1 subflows 1 3504 chk_subflows_total 2 2 3505 chk_mptcp_info add_addr_signal 1 add_addr_accepted 1 3506 userspace_pm_rm_addr $ns1 0 3507 # we don't look at the counter linked to the subflows that 3508 # have been removed but to the one linked to the RM_ADDR 3509 chk_rm_nr 1 0 invert 3510 chk_rst_nr 0 0 invert 3511 chk_mptcp_info subflows 1 subflows 1 3512 chk_subflows_total 1 1 3513 kill_events_pids 3514 mptcp_lib_kill_wait $tests_pid 3515 fi 3516} 3517 3518endpoint_tests() 3519{ 3520 # subflow_rebuild_header is needed to support the implicit flag 3521 # userspace pm type prevents add_addr 3522 if reset "implicit EP" && 3523 mptcp_lib_kallsyms_has "subflow_rebuild_header$"; then 3524 pm_nl_set_limits $ns1 2 2 3525 pm_nl_set_limits $ns2 2 2 3526 pm_nl_add_endpoint $ns1 10.0.2.1 flags signal 3527 speed=slow \ 3528 run_tests $ns1 $ns2 10.0.1.1 & 3529 local tests_pid=$! 3530 3531 wait_mpj $ns1 3532 pm_nl_check_endpoint "creation" \ 3533 $ns2 10.0.2.2 id 1 flags implicit 3534 chk_mptcp_info subflows 1 subflows 1 3535 chk_mptcp_info add_addr_signal 1 add_addr_accepted 1 3536 3537 pm_nl_add_endpoint $ns2 10.0.2.2 id 33 2>/dev/null 3538 pm_nl_check_endpoint "ID change is prevented" \ 3539 $ns2 10.0.2.2 id 1 flags implicit 3540 3541 pm_nl_add_endpoint $ns2 10.0.2.2 flags signal 3542 pm_nl_check_endpoint "modif is allowed" \ 3543 $ns2 10.0.2.2 id 1 flags signal 3544 mptcp_lib_kill_wait $tests_pid 3545 fi 3546 3547 if reset "delete and re-add" && 3548 mptcp_lib_kallsyms_has "subflow_rebuild_header$"; then 3549 pm_nl_set_limits $ns1 1 1 3550 pm_nl_set_limits $ns2 1 1 3551 pm_nl_add_endpoint $ns2 10.0.2.2 id 2 dev ns2eth2 flags subflow 3552 test_linkfail=4 speed=20 \ 3553 run_tests $ns1 $ns2 10.0.1.1 & 3554 local tests_pid=$! 3555 3556 wait_mpj $ns2 3557 pm_nl_check_endpoint "creation" \ 3558 $ns2 10.0.2.2 id 2 flags subflow dev ns2eth2 3559 chk_subflow_nr "before delete" 2 3560 chk_mptcp_info subflows 1 subflows 1 3561 3562 pm_nl_del_endpoint $ns2 2 10.0.2.2 3563 sleep 0.5 3564 chk_subflow_nr "after delete" 1 3565 chk_mptcp_info subflows 0 subflows 0 3566 3567 pm_nl_add_endpoint $ns2 10.0.2.2 dev ns2eth2 flags subflow 3568 wait_mpj $ns2 3569 chk_subflow_nr "after re-add" 2 3570 chk_mptcp_info subflows 1 subflows 1 3571 mptcp_lib_kill_wait $tests_pid 3572 fi 3573 3574 # remove and re-add 3575 if reset "delete re-add signal" && 3576 mptcp_lib_kallsyms_has "subflow_rebuild_header$"; then 3577 pm_nl_set_limits $ns1 1 1 3578 pm_nl_set_limits $ns2 1 1 3579 pm_nl_add_endpoint $ns1 10.0.2.1 id 1 flags signal 3580 test_linkfail=4 speed=20 \ 3581 run_tests $ns1 $ns2 10.0.1.1 & 3582 local tests_pid=$! 3583 3584 wait_mpj $ns2 3585 pm_nl_check_endpoint "creation" \ 3586 $ns1 10.0.2.1 id 1 flags signal 3587 chk_subflow_nr "before delete" 2 3588 chk_mptcp_info subflows 1 subflows 1 3589 3590 pm_nl_del_endpoint $ns1 1 10.0.2.1 3591 sleep 0.5 3592 chk_subflow_nr "after delete" 1 3593 chk_mptcp_info subflows 0 subflows 0 3594 3595 pm_nl_add_endpoint $ns1 10.0.2.1 flags signal 3596 wait_mpj $ns2 3597 chk_subflow_nr "after re-add" 2 3598 chk_mptcp_info subflows 1 subflows 1 3599 mptcp_lib_kill_wait $tests_pid 3600 fi 3601 3602} 3603 3604# [$1: error message] 3605usage() 3606{ 3607 if [ -n "${1}" ]; then 3608 echo "${1}" 3609 ret=${KSFT_FAIL} 3610 fi 3611 3612 echo "mptcp_join usage:" 3613 3614 local key 3615 for key in "${!all_tests[@]}"; do 3616 echo " -${key} ${all_tests[${key}]}" 3617 done 3618 3619 echo " -c capture pcap files" 3620 echo " -C enable data checksum" 3621 echo " -i use ip mptcp" 3622 echo " -h help" 3623 3624 echo "[test ids|names]" 3625 3626 exit ${ret} 3627} 3628 3629 3630# Use a "simple" array to force an specific order we cannot have with an associative one 3631all_tests_sorted=( 3632 f@subflows_tests 3633 e@subflows_error_tests 3634 s@signal_address_tests 3635 l@link_failure_tests 3636 t@add_addr_timeout_tests 3637 r@remove_tests 3638 a@add_tests 3639 6@ipv6_tests 3640 4@v4mapped_tests 3641 M@mixed_tests 3642 b@backup_tests 3643 p@add_addr_ports_tests 3644 k@syncookies_tests 3645 S@checksum_tests 3646 d@deny_join_id0_tests 3647 m@fullmesh_tests 3648 z@fastclose_tests 3649 F@fail_tests 3650 u@userspace_tests 3651 I@endpoint_tests 3652) 3653 3654all_tests_args="" 3655all_tests_names=() 3656for subtests in "${all_tests_sorted[@]}"; do 3657 key="${subtests%@*}" 3658 value="${subtests#*@}" 3659 3660 all_tests_args+="${key}" 3661 all_tests_names+=("${value}") 3662 all_tests[${key}]="${value}" 3663done 3664 3665tests=() 3666while getopts "${all_tests_args}cCih" opt; do 3667 case $opt in 3668 ["${all_tests_args}"]) 3669 tests+=("${all_tests[${opt}]}") 3670 ;; 3671 c) 3672 capture=true 3673 ;; 3674 C) 3675 checksum=true 3676 ;; 3677 i) 3678 mptcp_lib_set_ip_mptcp 3679 ;; 3680 h) 3681 usage 3682 ;; 3683 *) 3684 usage "Unknown option: -${opt}" 3685 ;; 3686 esac 3687done 3688 3689shift $((OPTIND - 1)) 3690 3691for arg in "${@}"; do 3692 if [[ "${arg}" =~ ^[0-9]+$ ]]; then 3693 only_tests_ids+=("${arg}") 3694 else 3695 only_tests_names+=("${arg}") 3696 fi 3697done 3698 3699if [ ${#tests[@]} -eq 0 ]; then 3700 tests=("${all_tests_names[@]}") 3701fi 3702 3703for subtests in "${tests[@]}"; do 3704 "${subtests}" 3705done 3706 3707if [ ${ret} -ne 0 ]; then 3708 echo 3709 echo "${#failed_tests[@]} failure(s) has(ve) been detected:" 3710 for i in $(get_failed_tests_ids); do 3711 echo -e "\t- ${i}: ${failed_tests[${i}]}" 3712 done 3713 echo 3714fi 3715 3716append_prev_results 3717mptcp_lib_result_print_all_tap 3718 3719exit $ret 3720