Lines Matching refs:ca
140 struct cdg *ca = inet_csk_ca(sk); in tcp_cdg_hystart_update() local
143 ca->delay_min = min_not_zero(ca->delay_min, ca->rtt.min); in tcp_cdg_hystart_update()
144 if (ca->delay_min == 0) in tcp_cdg_hystart_update()
150 if (ca->last_ack == 0 || !tcp_is_cwnd_limited(sk)) { in tcp_cdg_hystart_update()
151 ca->last_ack = now_us; in tcp_cdg_hystart_update()
152 ca->round_start = now_us; in tcp_cdg_hystart_update()
153 } else if (before(now_us, ca->last_ack + 3000)) { in tcp_cdg_hystart_update()
154 u32 base_owd = max(ca->delay_min / 2U, 125U); in tcp_cdg_hystart_update()
156 ca->last_ack = now_us; in tcp_cdg_hystart_update()
157 if (after(now_us, ca->round_start + base_owd)) { in tcp_cdg_hystart_update()
170 if (ca->sample_cnt < 8) { in tcp_cdg_hystart_update()
171 ca->sample_cnt++; in tcp_cdg_hystart_update()
173 s32 thresh = max(ca->delay_min + ca->delay_min / 8U, in tcp_cdg_hystart_update()
176 if (ca->rtt.min > thresh) { in tcp_cdg_hystart_update()
188 static s32 tcp_cdg_grad(struct cdg *ca) in tcp_cdg_grad() argument
190 s32 gmin = ca->rtt.min - ca->rtt_prev.min; in tcp_cdg_grad()
191 s32 gmax = ca->rtt.max - ca->rtt_prev.max; in tcp_cdg_grad()
194 if (ca->gradients) { in tcp_cdg_grad()
195 ca->gsum.min += gmin - ca->gradients[ca->tail].min; in tcp_cdg_grad()
196 ca->gsum.max += gmax - ca->gradients[ca->tail].max; in tcp_cdg_grad()
197 ca->gradients[ca->tail].min = gmin; in tcp_cdg_grad()
198 ca->gradients[ca->tail].max = gmax; in tcp_cdg_grad()
199 ca->tail = (ca->tail + 1) & (window - 1); in tcp_cdg_grad()
200 gmin = ca->gsum.min; in tcp_cdg_grad()
201 gmax = ca->gsum.max; in tcp_cdg_grad()
213 if (!ca->gfilled) { in tcp_cdg_grad()
214 if (!ca->gradients && window > 1) in tcp_cdg_grad()
216 else if (ca->tail == 0) in tcp_cdg_grad()
217 ca->gfilled = true; in tcp_cdg_grad()
219 grad = (grad * window) / (int)ca->tail; in tcp_cdg_grad()
224 ca->backoff_cnt = 0; in tcp_cdg_grad()
232 ca->state = CDG_FULL; in tcp_cdg_grad()
234 ca->state = CDG_NONFULL; in tcp_cdg_grad()
241 struct cdg *ca = inet_csk_ca(sk); in tcp_cdg_backoff() local
248 ca->backoff_cnt++; in tcp_cdg_backoff()
249 if (ca->backoff_cnt > use_ineff) in tcp_cdg_backoff()
253 ca->shadow_wnd = max(ca->shadow_wnd, tp->snd_cwnd); in tcp_cdg_backoff()
254 ca->state = CDG_BACKOFF; in tcp_cdg_backoff()
262 struct cdg *ca = inet_csk_ca(sk); in tcp_cdg_cong_avoid() local
270 if (after(ack, ca->rtt_seq) && ca->rtt.v64) { in tcp_cdg_cong_avoid()
273 if (ca->rtt_prev.v64) in tcp_cdg_cong_avoid()
274 grad = tcp_cdg_grad(ca); in tcp_cdg_cong_avoid()
275 ca->rtt_seq = tp->snd_nxt; in tcp_cdg_cong_avoid()
276 ca->rtt_prev = ca->rtt; in tcp_cdg_cong_avoid()
277 ca->rtt.v64 = 0; in tcp_cdg_cong_avoid()
278 ca->last_ack = 0; in tcp_cdg_cong_avoid()
279 ca->sample_cnt = 0; in tcp_cdg_cong_avoid()
286 ca->shadow_wnd = min(ca->shadow_wnd, tp->snd_cwnd); in tcp_cdg_cong_avoid()
294 ca->shadow_wnd = max(ca->shadow_wnd, ca->shadow_wnd + incr); in tcp_cdg_cong_avoid()
299 struct cdg *ca = inet_csk_ca(sk); in tcp_cdg_acked() local
310 if (num_acked == 1 && ca->delack) { in tcp_cdg_acked()
314 ca->rtt.min = min(ca->rtt.min, rtt_us); in tcp_cdg_acked()
315 ca->delack--; in tcp_cdg_acked()
317 } else if (num_acked > 1 && ca->delack < 5) { in tcp_cdg_acked()
318 ca->delack++; in tcp_cdg_acked()
322 ca->rtt.min = min_not_zero(ca->rtt.min, rtt_us); in tcp_cdg_acked()
323 ca->rtt.max = max(ca->rtt.max, rtt_us); in tcp_cdg_acked()
328 struct cdg *ca = inet_csk_ca(sk); in tcp_cdg_ssthresh() local
331 ca->undo_cwnd = tp->snd_cwnd; in tcp_cdg_ssthresh()
333 if (ca->state == CDG_BACKOFF) in tcp_cdg_ssthresh()
336 if (ca->state == CDG_NONFULL && use_tolerance) in tcp_cdg_ssthresh()
339 ca->shadow_wnd = min(ca->shadow_wnd >> 1, tp->snd_cwnd); in tcp_cdg_ssthresh()
341 return max3(2U, ca->shadow_wnd, tp->snd_cwnd >> 1); in tcp_cdg_ssthresh()
347 struct cdg *ca = inet_csk_ca(sk); in tcp_cdg_undo_cwnd() local
349 return max(tcp_sk(sk)->snd_cwnd, ca->undo_cwnd); in tcp_cdg_undo_cwnd()
354 struct cdg *ca = inet_csk_ca(sk); in tcp_cdg_cwnd_event() local
360 gradients = ca->gradients; in tcp_cdg_cwnd_event()
363 memset(ca, 0, sizeof(*ca)); in tcp_cdg_cwnd_event()
365 ca->gradients = gradients; in tcp_cdg_cwnd_event()
366 ca->rtt_seq = tp->snd_nxt; in tcp_cdg_cwnd_event()
367 ca->shadow_wnd = tp->snd_cwnd; in tcp_cdg_cwnd_event()
370 ca->state = CDG_UNKNOWN; in tcp_cdg_cwnd_event()
371 ca->rtt_seq = tp->snd_nxt; in tcp_cdg_cwnd_event()
372 ca->rtt_prev = ca->rtt; in tcp_cdg_cwnd_event()
373 ca->rtt.v64 = 0; in tcp_cdg_cwnd_event()
382 struct cdg *ca = inet_csk_ca(sk); in tcp_cdg_init() local
387 ca->gradients = kcalloc(window, sizeof(ca->gradients[0]), in tcp_cdg_init()
389 ca->rtt_seq = tp->snd_nxt; in tcp_cdg_init()
390 ca->shadow_wnd = tp->snd_cwnd; in tcp_cdg_init()
395 struct cdg *ca = inet_csk_ca(sk); in tcp_cdg_release() local
397 kfree(ca->gradients); in tcp_cdg_release()