@@ -630,7 +630,7 @@ if (choose_sk) {
630
630
if (count_set_init_rate == 5 ) {
631
631
//printk("");
632
632
last_rate = init_rate ;
633
- trigger_threshold = 15 * last_rate / 100 ;
633
+ trigger_threshold = 25 * last_rate / 100 ;
634
634
loop_counter = 0 ;
635
635
meta_tp -> buffer_trigger_threshold = 0 ;
636
636
mptcp_for_each_sub (mpcb , mptcp ) {
@@ -641,7 +641,7 @@ if (choose_sk) {
641
641
last_buffer_size [loop_counter ] = init_buffer_size [loop_counter ];
642
642
loop_counter ++ ;
643
643
}
644
- meta_tp -> buffer_trigger_threshold = -15 * meta_tp -> buffer_trigger_threshold / 100 ;
644
+ meta_tp -> buffer_trigger_threshold = -5 * meta_tp -> buffer_trigger_threshold / 100 ;
645
645
count_set_init_rate = 0 ;
646
646
} else {
647
647
init_rate = (init_rate * (count_set_init_rate - 1 ) + meta_tp -> rate_delivered ) / count_set_init_rate ;
@@ -906,7 +906,7 @@ if (!meta_tp->init_search) {
906
906
}
907
907
908
908
// YES
909
- if (buffer_threshold_cnt == 5 || threshold_cnt == 3 ) {
909
+ if (buffer_threshold_cnt == 3 || threshold_cnt == 5 ) {
910
910
mptcp_for_each_sub (mpcb , mptcp ) {
911
911
struct sock * sk_it = mptcp_to_sock (mptcp );
912
912
if (tcp_in_slow_start (tcp_sk (sk_it ))) {
@@ -921,11 +921,11 @@ if (buffer_threshold_cnt == 5 || threshold_cnt == 3) {
921
921
}
922
922
search_start :
923
923
printk ("SEARCH START:\n" );
924
- if (buffer_threshold_cnt == 5 )
924
+ if (buffer_threshold_cnt == 3 )
925
925
{
926
926
printk ("DECREASED SEND QUEUE\n" );
927
927
}
928
- else if (threshold_cnt == 3 )
928
+ else if (threshold_cnt == 5 )
929
929
{
930
930
printk ("DECREASED THROUGHPUT\n" );
931
931
}
0 commit comments