Lines Matching refs:ca

141 	struct cdg *ca = inet_csk_ca(sk);  in tcp_cdg_hystart_update()  local
144 ca->delay_min = min_not_zero(ca->delay_min, ca->rtt.min); in tcp_cdg_hystart_update()
145 if (ca->delay_min == 0) in tcp_cdg_hystart_update()
151 if (ca->last_ack == 0 || !tcp_is_cwnd_limited(sk)) { in tcp_cdg_hystart_update()
152 ca->last_ack = now_us; in tcp_cdg_hystart_update()
153 ca->round_start = now_us; in tcp_cdg_hystart_update()
154 } else if (before(now_us, ca->last_ack + 3000)) { in tcp_cdg_hystart_update()
155 u32 base_owd = max(ca->delay_min / 2U, 125U); in tcp_cdg_hystart_update()
157 ca->last_ack = now_us; in tcp_cdg_hystart_update()
158 if (after(now_us, ca->round_start + base_owd)) { in tcp_cdg_hystart_update()
171 if (ca->sample_cnt < 8) { in tcp_cdg_hystart_update()
172 ca->sample_cnt++; in tcp_cdg_hystart_update()
174 s32 thresh = max(ca->delay_min + ca->delay_min / 8U, in tcp_cdg_hystart_update()
177 if (ca->rtt.min > thresh) { in tcp_cdg_hystart_update()
189 static s32 tcp_cdg_grad(struct cdg *ca) in tcp_cdg_grad() argument
191 s32 gmin = ca->rtt.min - ca->rtt_prev.min; in tcp_cdg_grad()
192 s32 gmax = ca->rtt.max - ca->rtt_prev.max; in tcp_cdg_grad()
195 if (ca->gradients) { in tcp_cdg_grad()
196 ca->gsum.min += gmin - ca->gradients[ca->tail].min; in tcp_cdg_grad()
197 ca->gsum.max += gmax - ca->gradients[ca->tail].max; in tcp_cdg_grad()
198 ca->gradients[ca->tail].min = gmin; in tcp_cdg_grad()
199 ca->gradients[ca->tail].max = gmax; in tcp_cdg_grad()
200 ca->tail = (ca->tail + 1) & (window - 1); in tcp_cdg_grad()
201 gmin = ca->gsum.min; in tcp_cdg_grad()
202 gmax = ca->gsum.max; in tcp_cdg_grad()
214 if (!ca->gfilled) { in tcp_cdg_grad()
215 if (!ca->gradients && window > 1) in tcp_cdg_grad()
217 else if (ca->tail == 0) in tcp_cdg_grad()
218 ca->gfilled = true; in tcp_cdg_grad()
220 grad = (grad * window) / (int)ca->tail; in tcp_cdg_grad()
225 ca->backoff_cnt = 0; in tcp_cdg_grad()
233 ca->state = CDG_FULL; in tcp_cdg_grad()
235 ca->state = CDG_NONFULL; in tcp_cdg_grad()
242 struct cdg *ca = inet_csk_ca(sk); in tcp_cdg_backoff() local
249 ca->backoff_cnt++; in tcp_cdg_backoff()
250 if (ca->backoff_cnt > use_ineff) in tcp_cdg_backoff()
254 ca->shadow_wnd = max(ca->shadow_wnd, tp->snd_cwnd); in tcp_cdg_backoff()
255 ca->state = CDG_BACKOFF; in tcp_cdg_backoff()
263 struct cdg *ca = inet_csk_ca(sk); in tcp_cdg_cong_avoid() local
271 if (after(ack, ca->rtt_seq) && ca->rtt.v64) { in tcp_cdg_cong_avoid()
274 if (ca->rtt_prev.v64) in tcp_cdg_cong_avoid()
275 grad = tcp_cdg_grad(ca); in tcp_cdg_cong_avoid()
276 ca->rtt_seq = tp->snd_nxt; in tcp_cdg_cong_avoid()
277 ca->rtt_prev = ca->rtt; in tcp_cdg_cong_avoid()
278 ca->rtt.v64 = 0; in tcp_cdg_cong_avoid()
279 ca->last_ack = 0; in tcp_cdg_cong_avoid()
280 ca->sample_cnt = 0; in tcp_cdg_cong_avoid()
287 ca->shadow_wnd = min(ca->shadow_wnd, tp->snd_cwnd); in tcp_cdg_cong_avoid()
295 ca->shadow_wnd = max(ca->shadow_wnd, ca->shadow_wnd + incr); in tcp_cdg_cong_avoid()
300 struct cdg *ca = inet_csk_ca(sk); in tcp_cdg_acked() local
311 if (sample->pkts_acked == 1 && ca->delack) { in tcp_cdg_acked()
315 ca->rtt.min = min(ca->rtt.min, sample->rtt_us); in tcp_cdg_acked()
316 ca->delack--; in tcp_cdg_acked()
318 } else if (sample->pkts_acked > 1 && ca->delack < 5) { in tcp_cdg_acked()
319 ca->delack++; in tcp_cdg_acked()
323 ca->rtt.min = min_not_zero(ca->rtt.min, sample->rtt_us); in tcp_cdg_acked()
324 ca->rtt.max = max(ca->rtt.max, sample->rtt_us); in tcp_cdg_acked()
329 struct cdg *ca = inet_csk_ca(sk); in tcp_cdg_ssthresh() local
332 if (ca->state == CDG_BACKOFF) in tcp_cdg_ssthresh()
335 if (ca->state == CDG_NONFULL && use_tolerance) in tcp_cdg_ssthresh()
338 ca->shadow_wnd = min(ca->shadow_wnd >> 1, tp->snd_cwnd); in tcp_cdg_ssthresh()
340 return max3(2U, ca->shadow_wnd, tp->snd_cwnd >> 1); in tcp_cdg_ssthresh()
346 struct cdg *ca = inet_csk_ca(sk); in tcp_cdg_cwnd_event() local
352 gradients = ca->gradients; in tcp_cdg_cwnd_event()
355 memset(ca, 0, sizeof(*ca)); in tcp_cdg_cwnd_event()
357 ca->gradients = gradients; in tcp_cdg_cwnd_event()
358 ca->rtt_seq = tp->snd_nxt; in tcp_cdg_cwnd_event()
359 ca->shadow_wnd = tp->snd_cwnd; in tcp_cdg_cwnd_event()
362 ca->state = CDG_UNKNOWN; in tcp_cdg_cwnd_event()
363 ca->rtt_seq = tp->snd_nxt; in tcp_cdg_cwnd_event()
364 ca->rtt_prev = ca->rtt; in tcp_cdg_cwnd_event()
365 ca->rtt.v64 = 0; in tcp_cdg_cwnd_event()
374 struct cdg *ca = inet_csk_ca(sk); in tcp_cdg_init() local
379 ca->gradients = kcalloc(window, sizeof(ca->gradients[0]), in tcp_cdg_init()
381 ca->rtt_seq = tp->snd_nxt; in tcp_cdg_init()
382 ca->shadow_wnd = tp->snd_cwnd; in tcp_cdg_init()
387 struct cdg *ca = inet_csk_ca(sk); in tcp_cdg_release() local
389 kfree(ca->gradients); in tcp_cdg_release()