| /net/ipv4/ |
| D | tcp_bic.c | 86 static inline void bictcp_update(struct bictcp *ca, u32 cwnd) in bictcp_update() argument
88 if (ca->last_cwnd == cwnd && in bictcp_update()
92 ca->last_cwnd = cwnd; in bictcp_update()
99 if (cwnd <= low_window) { in bictcp_update()
100 ca->cnt = cwnd; in bictcp_update()
105 if (cwnd < ca->last_max_cwnd) { in bictcp_update()
106 __u32 dist = (ca->last_max_cwnd - cwnd) in bictcp_update()
111 ca->cnt = cwnd / max_increment; in bictcp_update()
114 ca->cnt = (cwnd * smooth_part) / BICTCP_B; in bictcp_update()
117 ca->cnt = cwnd / dist; in bictcp_update()
[all …]
|
| D | tcp_cubic.c | 207 static inline void bictcp_update(struct bictcp *ca, u32 cwnd) in bictcp_update() argument
214 if (ca->last_cwnd == cwnd && in bictcp_update()
218 ca->last_cwnd = cwnd; in bictcp_update()
224 ca->tcp_cwnd = cwnd; /* syn with cubic */ in bictcp_update()
226 if (ca->last_max_cwnd <= cwnd) { in bictcp_update()
228 ca->bic_origin_point = cwnd; in bictcp_update()
234 * (ca->last_max_cwnd - cwnd)); in bictcp_update()
270 if (bic_target > cwnd) { in bictcp_update()
271 ca->cnt = cwnd / (bic_target - cwnd); in bictcp_update()
273 ca->cnt = 100 * cwnd; /* very small increment*/ in bictcp_update()
[all …]
|
| D | tcp_highspeed.c | 17 unsigned int cwnd; member
130 if (tp->snd_cwnd > hstcp_aimd_vals[ca->ai].cwnd) { in hstcp_cong_avoid()
131 while (tp->snd_cwnd > hstcp_aimd_vals[ca->ai].cwnd && in hstcp_cong_avoid()
134 } else if (ca->ai && tp->snd_cwnd <= hstcp_aimd_vals[ca->ai-1].cwnd) { in hstcp_cong_avoid()
135 while (ca->ai && tp->snd_cwnd <= hstcp_aimd_vals[ca->ai-1].cwnd) in hstcp_cong_avoid()
|
| D | tcp_output.c | 143 u32 cwnd = tp->snd_cwnd; in tcp_cwnd_restart() local
148 restart_cwnd = min(restart_cwnd, cwnd); in tcp_cwnd_restart()
150 while ((delta -= inet_csk(sk)->icsk_rto) > 0 && cwnd > restart_cwnd) in tcp_cwnd_restart()
151 cwnd >>= 1; in tcp_cwnd_restart()
152 tp->snd_cwnd = max(cwnd, restart_cwnd); in tcp_cwnd_restart()
1409 u32 in_flight, cwnd; in tcp_cwnd_test() local
1417 cwnd = tp->snd_cwnd; in tcp_cwnd_test()
1418 if (in_flight < cwnd) in tcp_cwnd_test()
1419 return (cwnd - in_flight); in tcp_cwnd_test()
|
| D | tcp_input.c | 736 __u32 cwnd = (dst ? dst_metric(dst, RTAX_INITCWND) : 0); in tcp_init_cwnd() local
738 if (!cwnd) in tcp_init_cwnd()
739 cwnd = TCP_INIT_CWND; in tcp_init_cwnd()
740 return min_t(__u32, cwnd, tp->snd_cwnd_clamp); in tcp_init_cwnd()
|
| /net/sctp/ |
| D | transport.c | 392 __u32 cwnd, ssthresh, flight_size, pba, pmtu; in sctp_transport_raise_cwnd() local
394 cwnd = transport->cwnd; in sctp_transport_raise_cwnd()
407 (flight_size < cwnd)) in sctp_transport_raise_cwnd()
414 if (cwnd <= ssthresh) { in sctp_transport_raise_cwnd()
433 cwnd += pmtu; in sctp_transport_raise_cwnd()
435 cwnd += bytes_acked; in sctp_transport_raise_cwnd()
440 transport, bytes_acked, cwnd, in sctp_transport_raise_cwnd()
458 if (pba >= cwnd) { in sctp_transport_raise_cwnd()
459 cwnd += pmtu; in sctp_transport_raise_cwnd()
460 pba = ((cwnd < pba) ? (pba - cwnd) : 0); in sctp_transport_raise_cwnd()
[all …]
|
| D | probe.c | 138 if ((full || sp->cwnd != lcwnd) && in jsctp_sf_eat_sack()
141 lcwnd = sp->cwnd; in jsctp_sf_eat_sack()
164 sp->state, sp->cwnd, sp->ssthresh, in jsctp_sf_eat_sack()
|
| D | outqueue.c | 467 transport->cwnd, transport->ssthresh, in sctp_retransmit_mark()
1767 __func__, transport, transport->cwnd, in sctp_mark_missing()
|
| D | output.c | 702 if (flight_size >= transport->cwnd) { in sctp_packet_can_append_data()
|
| D | associola.c | 740 peer->cwnd = min(4*asoc->pathmtu, max_t(__u32, 2*asoc->pathmtu, 4380)); in sctp_assoc_add_peer()
863 transport->cwnd = 1; in sctp_assoc_control_transport()
|
| D | socket.c | 610 trans->cwnd = min(4*asoc->pathmtu, max_t(__u32, in sctp_send_asconf_add_ip()
4111 status.sstat_primary.spinfo_cwnd = transport->cwnd; in sctp_getsockopt_sctp_status()
4171 pinfo.spinfo_cwnd = transport->cwnd; in sctp_getsockopt_peer_addr_info()
|
| /net/sunrpc/ |
| D | xprt.c | 90 #define RPCXPRT_CONGESTED(xprt) ((xprt)->cong >= (xprt)->cwnd)
403 task->tk_pid, xprt->cong, xprt->cwnd); in __xprt_get_cong()
450 unsigned long cwnd = xprt->cwnd; in xprt_adjust_cwnd() local
452 if (result >= 0 && cwnd <= xprt->cong) { in xprt_adjust_cwnd()
455 cwnd += (RPC_CWNDSCALE * RPC_CWNDSCALE + (cwnd >> 1)) / cwnd; in xprt_adjust_cwnd()
456 if (cwnd > RPC_MAXCWND(xprt)) in xprt_adjust_cwnd()
457 cwnd = RPC_MAXCWND(xprt); in xprt_adjust_cwnd()
460 cwnd >>= 1; in xprt_adjust_cwnd()
461 if (cwnd < RPC_CWNDSCALE) in xprt_adjust_cwnd()
462 cwnd = RPC_CWNDSCALE; in xprt_adjust_cwnd()
[all …]
|
| /net/dccp/ccids/ |
| D | ccid2.c | 216 u32 cwnd = hc->tx_cwnd, restart_cwnd, in ccid2_cwnd_restart() local
219 hc->tx_ssthresh = max(hc->tx_ssthresh, (cwnd >> 1) + (cwnd >> 2)); in ccid2_cwnd_restart()
222 restart_cwnd = min(cwnd, iwnd); in ccid2_cwnd_restart()
223 cwnd >>= (now - hc->tx_lsndtime) / hc->tx_rto; in ccid2_cwnd_restart()
224 hc->tx_cwnd = max(cwnd, restart_cwnd); in ccid2_cwnd_restart()
|
| /net/sunrpc/xprtrdma/ |
| D | transport.c | 458 r_xprt->rx_buf.rb_cwndscale = xprt->cwnd; in xprt_rdma_reserve_xprt()
463 xprt->cwnd = credits * r_xprt->rx_buf.rb_cwndscale; in xprt_rdma_reserve_xprt()
|