@@ -218,7 +218,7 @@ set_ethtool_flags() {
218
218
local flags=" $3 "
219
219
220
220
if ip netns exec $ns ethtool -K $dev $flags 2> /dev/null; then
221
- echo " INFO: set $ns dev $dev : ethtool -K $flags "
221
+ mptcp_lib_pr_info " set $ns dev $dev : ethtool -K $flags "
222
222
fi
223
223
}
224
224
@@ -261,7 +261,7 @@ check_mptcp_disabled()
261
261
print_larger_title " New MPTCP socket can be blocked via sysctl"
262
262
# net.mptcp.enabled should be enabled by default
263
263
if [ " $( ip netns exec ${disabled_ns} sysctl net.mptcp.enabled | awk ' { print $3 }' ) " -ne 1 ]; then
264
- echo -e " net.mptcp.enabled sysctl is not 1 by default\t\t[ FAIL ] "
264
+ mptcp_lib_pr_fail " net.mptcp.enabled sysctl is not 1 by default"
265
265
mptcp_lib_result_fail " net.mptcp.enabled sysctl is not 1 by default"
266
266
ret=1
267
267
return 1
@@ -274,13 +274,13 @@ check_mptcp_disabled()
274
274
mptcp_lib_ns_exit " ${disabled_ns} "
275
275
276
276
if [ ${err} -eq 0 ]; then
277
- echo -e " New MPTCP socket cannot be blocked via sysctl\t\t[ FAIL ] "
277
+ mptcp_lib_pr_fail " New MPTCP socket cannot be blocked via sysctl"
278
278
mptcp_lib_result_fail " New MPTCP socket cannot be blocked via sysctl"
279
279
ret=1
280
280
return 1
281
281
fi
282
282
283
- echo " [ OK ] "
283
+ mptcp_lib_pr_ok
284
284
mptcp_lib_result_pass " New MPTCP socket can be blocked via sysctl"
285
285
return 0
286
286
}
@@ -301,7 +301,7 @@ do_ping()
301
301
ip netns exec ${connector_ns} ping ${ping_args} $connect_addr > /dev/null || rc=1
302
302
303
303
if [ $rc -ne 0 ] ; then
304
- echo " $listener_ns -> $connect_addr connectivity [ FAIL ] "
304
+ mptcp_lib_pr_fail " $listener_ns -> $connect_addr connectivity"
305
305
ret=1
306
306
307
307
return 1
@@ -335,7 +335,7 @@ do_transfer()
335
335
fi
336
336
337
337
if [ -n " $extra_args " ] && $options_log ; then
338
- echo " INFO: extra options: $extra_args "
338
+ mptcp_lib_pr_info " extra options: $extra_args "
339
339
fi
340
340
options_log=false
341
341
@@ -432,7 +432,7 @@ do_transfer()
432
432
result_msg+=" # time=${duration} ms"
433
433
printf " (duration %05sms) " " ${duration} "
434
434
if [ ${rets} -ne 0 ] || [ ${retc} -ne 0 ]; then
435
- echo " [ FAIL ] client exit code $retc , server $rets " 1>&2
435
+ mptcp_lib_pr_fail " client exit code $retc , server $rets "
436
436
echo -e " \nnetns ${listener_ns} socket stat for ${port} :" 1>&2
437
437
ip netns exec ${listener_ns} ss -Menita 1>&2 -o " sport = :$port "
438
438
cat /tmp/${listener_ns} .out
@@ -475,14 +475,14 @@ do_transfer()
475
475
fi
476
476
477
477
if [ ${stat_synrx_now_l} -lt ${expect_synrx} ]; then
478
- printf " [ FAIL ] lower MPC SYN rx (%d) than expected (%d)\n " \
479
- " ${stat_synrx_now_l} " " ${expect_synrx} "
478
+ mptcp_lib_pr_fail " lower MPC SYN rx (${stat_synrx_now_l} ) " \
479
+ " than expected ( ${expect_synrx} ) "
480
480
retc=1
481
481
fi
482
482
if [ ${stat_ackrx_now_l} -lt ${expect_ackrx} ] && [ ${stat_ooo_now} -eq 0 ]; then
483
483
if [ ${stat_ooo_now} -eq 0 ]; then
484
- printf " [ FAIL ] lower MPC ACK rx (%d) than expected (%d)\n " \
485
- " ${stat_ackrx_now_l} " " ${expect_ackrx} "
484
+ mptcp_lib_pr_fail " lower MPC ACK rx (${stat_ackrx_now_l} ) " \
485
+ " than expected ( ${expect_ackrx} ) "
486
486
rets=1
487
487
else
488
488
extra+=" [ Note ] fallback due to TCP OoO"
@@ -497,13 +497,13 @@ do_transfer()
497
497
498
498
local csum_err_s_nr=$(( csum_err_s - stat_csum_err_s))
499
499
if [ $csum_err_s_nr -gt 0 ]; then
500
- printf " [ FAIL ]\nserver got %d data checksum error[s]" ${csum_err_s_nr}
500
+ mptcp_lib_pr_fail " server got ${csum_err_s_nr} data checksum error[s]"
501
501
rets=1
502
502
fi
503
503
504
504
local csum_err_c_nr=$(( csum_err_c - stat_csum_err_c))
505
505
if [ $csum_err_c_nr -gt 0 ]; then
506
- printf " [ FAIL ]\nclient got %d data checksum error[s]" ${csum_err_c_nr}
506
+ mptcp_lib_pr_fail " client got ${csum_err_c_nr} data checksum error[s]"
507
507
retc=1
508
508
fi
509
509
fi
@@ -534,11 +534,11 @@ do_transfer()
534
534
fi
535
535
536
536
if [ $retc -eq 0 ] && [ $rets -eq 0 ]; then
537
- printf " [ OK ]%s\n " " ${extra: 1} "
537
+ mptcp_lib_pr_ok " ${extra: 1} "
538
538
mptcp_lib_result_pass " ${TEST_GROUP} : ${result_msg} "
539
539
else
540
540
if [ -n " ${extra} " ]; then
541
- printf " %s\n " " ${extra: 1} "
541
+ mptcp_lib_print_warn " ${extra: 1} "
542
542
fi
543
543
mptcp_lib_result_fail " ${TEST_GROUP} : ${result_msg} "
544
544
fi
@@ -668,7 +668,7 @@ run_test_transparent()
668
668
# following function has been exported (T). Not great but better than
669
669
# checking for a specific kernel version.
670
670
if ! mptcp_lib_kallsyms_has " T __ip_sock_set_tos$" ; then
671
- echo " INFO: ${msg} not supported by the kernel: SKIP "
671
+ mptcp_lib_pr_skip " ${msg} not supported by the kernel"
672
672
mptcp_lib_result_skip " ${TEST_GROUP} "
673
673
return
674
674
fi
@@ -685,7 +685,7 @@ table inet mangle {
685
685
}
686
686
EOF
687
687
then
688
- echo " SKIP: $msg , could not load nft ruleset"
688
+ mptcp_lib_pr_skip " $msg , could not load nft ruleset"
689
689
mptcp_lib_fail_if_expected_feature " nft rules"
690
690
mptcp_lib_result_skip " ${TEST_GROUP} "
691
691
return
701
701
702
702
if ! ip -net " $listener_ns " $r6flag rule add fwmark 1 lookup 100; then
703
703
ip netns exec " $listener_ns " nft flush ruleset
704
- echo " SKIP: $msg , ip $r6flag rule failed"
704
+ mptcp_lib_pr_skip " $msg , ip $r6flag rule failed"
705
705
mptcp_lib_fail_if_expected_feature " ip rule"
706
706
mptcp_lib_result_skip " ${TEST_GROUP} "
707
707
return
@@ -710,13 +710,13 @@ EOF
710
710
if ! ip -net " $listener_ns " route add local $local_addr /0 dev lo table 100; then
711
711
ip netns exec " $listener_ns " nft flush ruleset
712
712
ip -net " $listener_ns " $r6flag rule del fwmark 1 lookup 100
713
- echo " SKIP: $msg , ip route add local $local_addr failed"
713
+ mptcp_lib_pr_skip " $msg , ip route add local $local_addr failed"
714
714
mptcp_lib_fail_if_expected_feature " ip route"
715
715
mptcp_lib_result_skip " ${TEST_GROUP} "
716
716
return
717
717
fi
718
718
719
- echo " INFO: test $msg "
719
+ mptcp_lib_pr_info " test $msg "
720
720
721
721
port=$(( 20000 - 1 ))
722
722
local extra_args=" -o TRANSPARENT"
@@ -729,12 +729,12 @@ EOF
729
729
ip -net " $listener_ns " route del local $local_addr /0 dev lo table 100
730
730
731
731
if [ $lret -ne 0 ]; then
732
- echo " FAIL: $msg , mptcp connection error"
732
+ mptcp_lib_pr_fail " $msg , mptcp connection error"
733
733
ret=$lret
734
734
return 1
735
735
fi
736
736
737
- echo " PASS: $msg "
737
+ mptcp_lib_pr_info " $msg pass "
738
738
return 0
739
739
}
740
740
@@ -743,7 +743,7 @@ run_tests_peekmode()
743
743
local peekmode=" $1 "
744
744
745
745
TEST_GROUP=" peek mode: ${peekmode} "
746
- echo " INFO: with peek mode: ${peekmode} "
746
+ mptcp_lib_pr_info " with peek mode: ${peekmode} "
747
747
run_tests_lo " $ns1 " " $ns1 " 10.0.1.1 1 " -P ${peekmode} "
748
748
run_tests_lo " $ns1 " " $ns1 " dead:beef:1::1 1 " -P ${peekmode} "
749
749
}
@@ -753,12 +753,12 @@ run_tests_mptfo()
753
753
TEST_GROUP=" MPTFO"
754
754
755
755
if ! mptcp_lib_kallsyms_has " mptcp_fastopen_" ; then
756
- echo " INFO: TFO not supported by the kernel: SKIP "
756
+ mptcp_lib_pr_skip " TFO not supported by the kernel"
757
757
mptcp_lib_result_skip " ${TEST_GROUP} "
758
758
return
759
759
fi
760
760
761
- echo " INFO: with MPTFO start"
761
+ mptcp_lib_pr_info " with MPTFO start"
762
762
ip netns exec " $ns1 " sysctl -q net.ipv4.tcp_fastopen=2
763
763
ip netns exec " $ns2 " sysctl -q net.ipv4.tcp_fastopen=1
764
764
@@ -770,7 +770,7 @@ run_tests_mptfo()
770
770
771
771
ip netns exec " $ns1 " sysctl -q net.ipv4.tcp_fastopen=0
772
772
ip netns exec " $ns2 " sysctl -q net.ipv4.tcp_fastopen=0
773
- echo " INFO: with MPTFO end"
773
+ mptcp_lib_pr_info " with MPTFO end"
774
774
}
775
775
776
776
run_tests_disconnect ()
@@ -781,7 +781,7 @@ run_tests_disconnect()
781
781
TEST_GROUP=" full disconnect"
782
782
783
783
if ! mptcp_lib_kallsyms_has " mptcp_pm_data_reset$" ; then
784
- echo " INFO: Full disconnect not supported: SKIP "
784
+ mptcp_lib_pr_skip " Full disconnect not supported"
785
785
mptcp_lib_result_skip " ${TEST_GROUP} "
786
786
return
787
787
fi
@@ -794,7 +794,7 @@ run_tests_disconnect()
794
794
cin_disconnect=" $old_cin "
795
795
connect_per_transfer=3
796
796
797
- echo " INFO: disconnect"
797
+ mptcp_lib_pr_info " disconnect"
798
798
run_tests_lo " $ns1 " " $ns1 " 10.0.1.1 1 " -I 3 -i $old_cin "
799
799
run_tests_lo " $ns1 " " $ns1 " dead:beef:1::1 1 " -I 3 -i $old_cin "
800
800
@@ -818,7 +818,7 @@ log_if_error()
818
818
local msg=" $1 "
819
819
820
820
if [ ${ret} -ne 0 ]; then
821
- echo " FAIL: ${msg} "
821
+ mptcp_lib_pr_fail " ${msg} "
822
822
823
823
final_ret=${ret}
824
824
ret=0
865
865
mptcp_lib_result_code " ${ret} " " ping tests"
866
866
867
867
stop_if_error " Could not even run ping tests"
868
- echo " [ OK ] "
868
+ mptcp_lib_pr_ok
869
869
870
870
[ -n " $tc_loss " ] && tc -net " $ns2 " qdisc add dev ns2eth3 root netem loss random $tc_loss delay ${tc_delay} ms
871
871
tc_info=" loss of $tc_loss "
@@ -890,7 +890,7 @@ elif [ "$reorder_delay" -gt 0 ];then
890
890
tc_info+=" $tc_reorder with delay ${reorder_delay} ms "
891
891
fi
892
892
893
- echo " INFO: Using ${tc_info} on ns3eth4"
893
+ mptcp_lib_pr_info " Using ${tc_info} on ns3eth4"
894
894
895
895
tc -net " $ns3 " qdisc add dev ns3eth4 root netem delay ${reorder_delay} ms $tc_reorder
896
896
0 commit comments