| /linux-4.4.14/net/ipv4/ |
| H A D | tcp_highspeed.c | 126 * snd_cwnd <= hstcp_cong_avoid()
129 if (tp->snd_cwnd > hstcp_aimd_vals[ca->ai].cwnd) { hstcp_cong_avoid()
130 while (tp->snd_cwnd > hstcp_aimd_vals[ca->ai].cwnd && hstcp_cong_avoid()
133 } else if (ca->ai && tp->snd_cwnd <= hstcp_aimd_vals[ca->ai-1].cwnd) { hstcp_cong_avoid()
134 while (ca->ai && tp->snd_cwnd <= hstcp_aimd_vals[ca->ai-1].cwnd) hstcp_cong_avoid()
139 if (tp->snd_cwnd < tp->snd_cwnd_clamp) { hstcp_cong_avoid()
142 if (tp->snd_cwnd_cnt >= tp->snd_cwnd) { hstcp_cong_avoid()
143 tp->snd_cwnd_cnt -= tp->snd_cwnd; hstcp_cong_avoid()
144 tp->snd_cwnd++; hstcp_cong_avoid()
156 return max(tp->snd_cwnd - ((tp->snd_cwnd * hstcp_aimd_vals[ca->ai].md) >> 8), 2U); hstcp_ssthresh()
|
| H A D | tcp_scalable.c | 28 tcp_cong_avoid_ai(tp, min(tp->snd_cwnd, TCP_SCALABLE_AI_CNT), tcp_scalable_cong_avoid()
36 return max(tp->snd_cwnd - (tp->snd_cwnd>>TCP_SCALABLE_MD_SCALE), 2U); tcp_scalable_ssthresh()
|
| H A D | tcp_yeah.c | 78 if (tp->snd_cwnd <= tp->snd_ssthresh) tcp_yeah_cong_avoid()
85 if (tp->snd_cwnd_cnt > min(tp->snd_cwnd, TCP_SCALABLE_AI_CNT)) { tcp_yeah_cong_avoid()
86 if (tp->snd_cwnd < tp->snd_cwnd_clamp) tcp_yeah_cong_avoid()
87 tp->snd_cwnd++; tcp_yeah_cong_avoid()
95 tcp_cong_avoid_ai(tp, tp->snd_cwnd, 1); tcp_yeah_cong_avoid()
150 bw = tp->snd_cwnd; tcp_yeah_cong_avoid()
158 tp->snd_cwnd > yeah->reno_count) { tcp_yeah_cong_avoid()
160 tp->snd_cwnd >> TCP_YEAH_EPSILON); tcp_yeah_cong_avoid()
162 tp->snd_cwnd -= reduction; tcp_yeah_cong_avoid()
164 tp->snd_cwnd = max(tp->snd_cwnd, tcp_yeah_cong_avoid()
167 tp->snd_ssthresh = tp->snd_cwnd; tcp_yeah_cong_avoid()
171 yeah->reno_count = max(tp->snd_cwnd>>1, 2U); tcp_yeah_cong_avoid()
196 yeah->vegas.beg_snd_cwnd = tp->snd_cwnd; tcp_yeah_cong_avoid()
213 reduction = min(reduction, max(tp->snd_cwnd>>1, 2U)); tcp_yeah_ssthresh()
215 reduction = max(reduction, tp->snd_cwnd >> TCP_YEAH_DELTA); tcp_yeah_ssthresh()
217 reduction = max(tp->snd_cwnd>>1, 2U); tcp_yeah_ssthresh()
222 return max_t(int, tp->snd_cwnd - reduction, 2); tcp_yeah_ssthresh()
|
| H A D | tcp_hybla.c | 56 tp->snd_cwnd = 2; hybla_init()
64 tp->snd_cwnd = ca->rho; hybla_init()
139 increment = ca->rho2_7ls / tp->snd_cwnd; hybla_cong_avoid()
145 tp->snd_cwnd += increment >> 7; hybla_cong_avoid()
150 tp->snd_cwnd++; hybla_cong_avoid()
155 if (increment == 0 && odd == 0 && tp->snd_cwnd_cnt >= tp->snd_cwnd) { hybla_cong_avoid()
156 tp->snd_cwnd++; hybla_cong_avoid()
161 tp->snd_cwnd = min(tp->snd_cwnd, tp->snd_ssthresh); hybla_cong_avoid()
163 tp->snd_cwnd = min_t(u32, tp->snd_cwnd, tp->snd_cwnd_clamp); hybla_cong_avoid()
|
| H A D | tcp_cdg.c | 162 tp->snd_cwnd); tcp_cdg_hystart_update()
163 tp->snd_ssthresh = tp->snd_cwnd; tcp_cdg_hystart_update()
181 tp->snd_cwnd); tcp_cdg_hystart_update()
182 tp->snd_ssthresh = tp->snd_cwnd; tcp_cdg_hystart_update()
253 ca->shadow_wnd = max(ca->shadow_wnd, tp->snd_cwnd); tcp_cdg_backoff()
286 ca->shadow_wnd = min(ca->shadow_wnd, tp->snd_cwnd); tcp_cdg_cong_avoid()
290 prior_snd_cwnd = tp->snd_cwnd; tcp_cdg_cong_avoid()
293 incr = tp->snd_cwnd - prior_snd_cwnd; tcp_cdg_cong_avoid()
331 ca->undo_cwnd = tp->snd_cwnd; tcp_cdg_ssthresh()
334 return max(2U, (tp->snd_cwnd * min(1024U, backoff_beta)) >> 10); tcp_cdg_ssthresh()
337 return tp->snd_cwnd; tcp_cdg_ssthresh()
339 ca->shadow_wnd = min(ca->shadow_wnd >> 1, tp->snd_cwnd); tcp_cdg_ssthresh()
341 return max3(2U, ca->shadow_wnd, tp->snd_cwnd >> 1); tcp_cdg_ssthresh()
342 return max(2U, tp->snd_cwnd >> 1); tcp_cdg_ssthresh()
349 return max(tcp_sk(sk)->snd_cwnd, ca->undo_cwnd); tcp_cdg_undo_cwnd()
367 ca->shadow_wnd = tp->snd_cwnd; tcp_cdg_cwnd_event()
390 ca->shadow_wnd = tp->snd_cwnd; tcp_cdg_init()
|
| H A D | tcp_bic.c | 21 * max_cwnd = snd_cwnd * beta
51 u32 last_max_cwnd; /* last maximum snd_cwnd */
53 u32 last_cwnd; /* the last snd_cwnd */
152 bictcp_update(ca, tp->snd_cwnd); bictcp_cong_avoid()
169 if (tp->snd_cwnd < ca->last_max_cwnd && fast_convergence) bictcp_recalc_ssthresh()
170 ca->last_max_cwnd = (tp->snd_cwnd * (BICTCP_BETA_SCALE + beta)) bictcp_recalc_ssthresh()
173 ca->last_max_cwnd = tp->snd_cwnd; bictcp_recalc_ssthresh()
175 ca->loss_cwnd = tp->snd_cwnd; bictcp_recalc_ssthresh()
177 if (tp->snd_cwnd <= low_window) bictcp_recalc_ssthresh()
178 return max(tp->snd_cwnd >> 1U, 2U); bictcp_recalc_ssthresh()
180 return max((tp->snd_cwnd * beta) / BICTCP_BETA_SCALE, 2U); bictcp_recalc_ssthresh()
188 return max(tp->snd_cwnd, ca->loss_cwnd); bictcp_undo_cwnd()
|
| H A D | tcp_veno.c | 147 target_cwnd = (u64)tp->snd_cwnd * veno->basertt; tcp_veno_cong_avoid()
151 veno->diff = (tp->snd_cwnd << V_PARAM_SHIFT) - target_cwnd; tcp_veno_cong_avoid()
162 tcp_cong_avoid_ai(tp, tp->snd_cwnd, 1); tcp_veno_cong_avoid()
167 if (tp->snd_cwnd_cnt >= tp->snd_cwnd) { tcp_veno_cong_avoid()
169 tp->snd_cwnd < tp->snd_cwnd_clamp) { tcp_veno_cong_avoid()
170 tp->snd_cwnd++; tcp_veno_cong_avoid()
179 if (tp->snd_cwnd < 2) tcp_veno_cong_avoid()
180 tp->snd_cwnd = 2; tcp_veno_cong_avoid()
181 else if (tp->snd_cwnd > tp->snd_cwnd_clamp) tcp_veno_cong_avoid()
182 tp->snd_cwnd = tp->snd_cwnd_clamp; tcp_veno_cong_avoid()
197 return max(tp->snd_cwnd * 4 / 5, 2U); tcp_veno_ssthresh()
200 return max(tp->snd_cwnd >> 1U, 2U); tcp_veno_ssthresh()
|
| H A D | tcp_illinois.c | 225 if (tp->snd_cwnd < win_thresh) { update_params()
282 * tp->snd_cwnd += alpha/tp->snd_cwnd tcp_illinois_cong_avoid()
285 if (delta >= tp->snd_cwnd) { tcp_illinois_cong_avoid()
286 tp->snd_cwnd = min(tp->snd_cwnd + delta / tp->snd_cwnd, tcp_illinois_cong_avoid()
299 return max(tp->snd_cwnd - ((tp->snd_cwnd * ca->beta) >> BETA_SHIFT), 2U); tcp_illinois_ssthresh()
|
| H A D | tcp_cubic.c | 32 * max_cwnd = snd_cwnd * beta
85 u32 last_max_cwnd; /* last maximum snd_cwnd */
87 u32 last_cwnd; /* the last snd_cwnd */
351 bictcp_update(ca, tp->snd_cwnd, acked); bictcp_cong_avoid()
363 if (tp->snd_cwnd < ca->last_max_cwnd && fast_convergence) bictcp_recalc_ssthresh()
364 ca->last_max_cwnd = (tp->snd_cwnd * (BICTCP_BETA_SCALE + beta)) bictcp_recalc_ssthresh()
367 ca->last_max_cwnd = tp->snd_cwnd; bictcp_recalc_ssthresh()
369 ca->loss_cwnd = tp->snd_cwnd; bictcp_recalc_ssthresh()
371 return max((tp->snd_cwnd * beta) / BICTCP_BETA_SCALE, 2U); bictcp_recalc_ssthresh()
378 return max(tcp_sk(sk)->snd_cwnd, ca->loss_cwnd); bictcp_undo_cwnd()
409 tp->snd_cwnd); hystart_update()
410 tp->snd_ssthresh = tp->snd_cwnd; hystart_update()
430 tp->snd_cwnd); hystart_update()
431 tp->snd_ssthresh = tp->snd_cwnd; hystart_update()
464 tp->snd_cwnd >= hystart_low_window) bictcp_acked()
|
| H A D | tcp_cong.c | 379 u32 cwnd = min(tp->snd_cwnd + acked, tp->snd_ssthresh); tcp_slow_start()
381 acked -= cwnd - tp->snd_cwnd; tcp_slow_start()
382 tp->snd_cwnd = min(cwnd, tp->snd_cwnd_clamp); tcp_slow_start()
388 /* In theory this is tp->snd_cwnd += 1 / tp->snd_cwnd (or alternative w),
396 tp->snd_cwnd++; tcp_cong_avoid_ai()
404 tp->snd_cwnd += delta; tcp_cong_avoid_ai()
406 tp->snd_cwnd = min(tp->snd_cwnd, tp->snd_cwnd_clamp); tcp_cong_avoid_ai()
431 tcp_cong_avoid_ai(tp, tp->snd_cwnd, acked); tcp_reno_cong_avoid()
440 return max(tp->snd_cwnd >> 1U, 2U); tcp_reno_ssthresh()
|
| H A D | tcp_vegas.c | 161 return min(tp->snd_ssthresh, tp->snd_cwnd-1); tcp_vegas_ssthresh()
219 target_cwnd = (u64)tp->snd_cwnd * vegas->baseRTT; tcp_vegas_cong_avoid()
226 diff = tp->snd_cwnd * (rtt-vegas->baseRTT) / vegas->baseRTT; tcp_vegas_cong_avoid()
240 tp->snd_cwnd = min(tp->snd_cwnd, (u32)target_cwnd+1); tcp_vegas_cong_avoid()
256 tp->snd_cwnd--; tcp_vegas_cong_avoid()
263 tp->snd_cwnd++; tcp_vegas_cong_avoid()
271 if (tp->snd_cwnd < 2) tcp_vegas_cong_avoid()
272 tp->snd_cwnd = 2; tcp_vegas_cong_avoid()
273 else if (tp->snd_cwnd > tp->snd_cwnd_clamp) tcp_vegas_cong_avoid()
274 tp->snd_cwnd = tp->snd_cwnd_clamp; tcp_vegas_cong_avoid()
|
| H A D | tcp_htcp.c | 79 return max(tp->snd_cwnd, (tp->snd_ssthresh << 7) / ca->beta); htcp_cwnd_undo()
127 if (ca->packetcount >= tp->snd_cwnd - (ca->alpha >> 7 ? : 1) && measure_achieved_throughput()
228 return max((tp->snd_cwnd * ca->beta) >> 7, 2U); htcp_recalc_ssthresh()
243 * In theory this is tp->snd_cwnd += alpha / tp->snd_cwnd htcp_cong_avoid()
245 if ((tp->snd_cwnd_cnt * ca->alpha)>>7 >= tp->snd_cwnd) { htcp_cong_avoid()
246 if (tp->snd_cwnd < tp->snd_cwnd_clamp) htcp_cong_avoid()
247 tp->snd_cwnd++; htcp_cong_avoid()
|
| H A D | tcp_probe.c | 71 u32 snd_cwnd; member in struct:tcp_log
118 (full || tp->snd_cwnd != tcp_probe.lastcwnd)) { jtcp_rcv_established()
151 p->snd_cwnd = tp->snd_cwnd; jtcp_rcv_established()
159 tcp_probe.lastcwnd = tp->snd_cwnd; jtcp_rcv_established()
198 p->snd_cwnd, p->ssthresh, p->snd_wnd, p->srtt, p->rcv_wnd); tcpprobe_sprint()
|
| H A D | tcp_lp.c | 289 tp->snd_cwnd, lp->remote_hz, lp->owd_min, lp->owd_max, tcp_lp_pkts_acked()
303 * drop snd_cwnd into 1 */ tcp_lp_pkts_acked()
305 tp->snd_cwnd = 1U; tcp_lp_pkts_acked()
308 * cut snd_cwnd into half */ tcp_lp_pkts_acked()
310 tp->snd_cwnd = max(tp->snd_cwnd >> 1U, 1U); tcp_lp_pkts_acked()
|
| H A D | tcp_metrics.c | 438 if (val && (tp->snd_cwnd >> 1) > val) tcp_update_metrics()
440 tp->snd_cwnd >> 1); tcp_update_metrics()
444 if (tp->snd_cwnd > val) tcp_update_metrics()
446 tp->snd_cwnd); tcp_update_metrics()
453 max(tp->snd_cwnd >> 1, tp->snd_ssthresh)); tcp_update_metrics()
456 tcp_metric_set(tm, TCP_METRIC_CWND, (val + tp->snd_cwnd) >> 1); tcp_update_metrics()
573 tp->snd_cwnd = 1; tcp_init_metrics()
575 tp->snd_cwnd = tcp_init_cwnd(tp, dst); tcp_init_metrics()
|
| H A D | tcp_dctcp.c | 117 return max(tp->snd_cwnd - ((tp->snd_cwnd * ca->dctcp_alpha) >> 11U), 2U); dctcp_ssthresh()
|
| H A D | tcp_input.c | 303 nr_segs = max_t(u32, TCP_INIT_CWND, tp->snd_cwnd); tcp_sndbuf_expand()
628 * he can only send snd_cwnd unacked packets at any given time. For
629 * each ACK we send, he increments snd_cwnd and transmits more of his
772 * [1] : Normal Slow Start condition is (tp->snd_cwnd < tp->snd_ssthresh) tcp_update_pacing_rate()
773 * If snd_cwnd >= (tp->snd_ssthresh / 2), we are approaching tcp_update_pacing_rate()
776 if (tp->snd_cwnd < tp->snd_ssthresh / 2) tcp_update_pacing_rate()
781 rate *= max(tp->snd_cwnd, tp->packets_out); tcp_update_pacing_rate()
1889 tp->snd_cwnd = 1; tcp_enter_loss()
2250 tp->snd_cwnd = min(tp->snd_cwnd, tcp_moderate_cwnd()
2321 tp->snd_cwnd, tcp_left_out(tp), DBGUNDO()
2331 tp->snd_cwnd, tcp_left_out(tp), DBGUNDO()
2361 tp->snd_cwnd = icsk->icsk_ca_ops->undo_cwnd(sk);
2363 tp->snd_cwnd = max(tp->snd_cwnd, tp->snd_ssthresh << 1);
2370 tp->snd_cwnd = max(tp->snd_cwnd, tp->snd_ssthresh);
2465 tp->prior_cwnd = tp->snd_cwnd; tcp_init_cwnd_reduction()
2498 tp->snd_cwnd = tcp_packets_in_flight(tp) + sndcnt; tcp_cwnd_reduction()
2508 tp->snd_cwnd = tp->snd_ssthresh; tcp_end_cwnd_reduction()
2577 tp->snd_cwnd = tp->snd_cwnd * tcp_mtup_probe_success()
2863 tp->snd_cwnd++; tcp_fastretrans_alert()
4907 if (tcp_packets_in_flight(tp) >= tp->snd_cwnd) tcp_should_expand_sndbuf()
|
| H A D | tcp_westwood.c | 245 tp->snd_cwnd = tp->snd_ssthresh = tcp_westwood_bw_rttmin(sk); tcp_westwood_event()
|
| H A D | tcp_output.c | 146 u32 cwnd = tp->snd_cwnd; tcp_cwnd_restart()
155 tp->snd_cwnd = max(cwnd, restart_cwnd); tcp_cwnd_restart()
1455 if (win_used < tp->snd_cwnd) { tcp_cwnd_application_limited()
1457 tp->snd_cwnd = (tp->snd_cwnd + win_used) >> 1; tcp_cwnd_application_limited()
1596 cwnd = tp->snd_cwnd; tcp_cwnd_test()
1779 BUG_ON(tcp_skb_pcount(skb) <= 1 || (tp->snd_cwnd <= in_flight)); tcp_tso_should_defer()
1784 cong_win = (tp->snd_cwnd - in_flight) * tp->mss_cache; tcp_tso_should_defer()
1798 u32 chunk = min(tp->snd_wnd, tp->snd_cwnd * tp->mss_cache); tcp_tso_should_defer()
1888 tp->snd_cwnd < 11 || tcp_mtu_probe()
1924 if (tcp_packets_in_flight(tp) + 2 > tp->snd_cwnd) { tcp_mtu_probe()
1993 tp->snd_cwnd--;
2139 is_cwnd_limited |= (tcp_packets_in_flight(tp) >= tp->snd_cwnd); tcp_write_xmit()
2177 if ((tp->snd_cwnd > tcp_packets_in_flight(tp)) && tcp_schedule_loss_probe()
2757 if (tcp_packets_in_flight(tp) >= tp->snd_cwnd) tcp_for_write_queue_from()
|
| H A D | tcp.c | 399 tp->snd_cwnd = TCP_INIT_CWND; tcp_init_sock()
2245 tp->snd_cwnd = 2; tcp_disconnect()
2697 info->tcpi_snd_cwnd = tp->snd_cwnd; tcp_get_info()
|
| H A D | tcp_minisocks.c | 493 newtp->snd_cwnd = TCP_INIT_CWND; tcp_create_openreq_child()
|
| H A D | tcp_ipv4.c | 2211 tp->snd_cwnd, get_tcp4_sock()
|
| /linux-4.4.14/include/linux/ |
| H A D | tcp.h | 217 is_cwnd_limited:1;/* forward progress limited by snd_cwnd? */
250 u32 snd_cwnd; /* Sending congestion window */ member in struct:tcp_sock
252 u32 snd_cwnd_clamp; /* Do not allow snd_cwnd to grow above this */
|
| /linux-4.4.14/include/net/ |
| H A D | tcp.h | 1006 return tp->snd_cwnd < tp->snd_ssthresh; tcp_in_slow_start()
1032 ((tp->snd_cwnd >> 1) + tcp_current_ssthresh()
1033 (tp->snd_cwnd >> 2))); tcp_current_ssthresh()
1086 return tp->snd_cwnd < 2 * tp->max_packets_out; tcp_is_cwnd_limited()
|
| /linux-4.4.14/net/ipv6/ |
| H A D | tcp_ipv6.c | 1755 tp->snd_cwnd, get_tcp6_sock()
|
| /linux-4.4.14/drivers/infiniband/hw/nes/ |
| H A D | nes_cm.c | 2986 nes_debug(NES_DBG_CM, " snd_cwnd = 0x%08X.\n", le32_to_cpu(nesqp->nesqp_context->cwnd)); nes_cm_init_tsa_conn()
|