104 static inline void bictcp_reset(struct bictcp *ca)  in bictcp_reset()  argument
106 	ca->cnt = 0;  in bictcp_reset()
107 	ca->last_max_cwnd = 0;  in bictcp_reset()
108 	ca->last_cwnd = 0;  in bictcp_reset()
109 	ca->last_time = 0;  in bictcp_reset()
110 	ca->bic_origin_point = 0;  in bictcp_reset()
111 	ca->bic_K = 0;  in bictcp_reset()
112 	ca->delay_min = 0;  in bictcp_reset()
113 	ca->epoch_start = 0;  in bictcp_reset()
114 	ca->ack_cnt = 0;  in bictcp_reset()
115 	ca->tcp_cwnd = 0;  in bictcp_reset()
116 	ca->found = 0;  in bictcp_reset()
131 	struct bictcp *ca = inet_csk_ca(sk);  in bictcp_hystart_reset()  local
133 	ca->round_start = ca->last_ack = bictcp_clock();  in bictcp_hystart_reset()
134 	ca->end_seq = tp->snd_nxt;  in bictcp_hystart_reset()
135 	ca->curr_rtt = 0;  in bictcp_hystart_reset()
136 	ca->sample_cnt = 0;  in bictcp_hystart_reset()
141 	struct bictcp *ca = inet_csk_ca(sk);  in bictcp_init()  local
143 	bictcp_reset(ca);  in bictcp_init()
155 		struct bictcp *ca = inet_csk_ca(sk);  in bictcp_cwnd_event()  local
164 		if (ca->epoch_start && delta > 0) {  in bictcp_cwnd_event()
165 			ca->epoch_start += delta;  in bictcp_cwnd_event()
166 			if (after(ca->epoch_start, now))  in bictcp_cwnd_event()
167 				ca->epoch_start = now;  in bictcp_cwnd_event()
224 static inline void bictcp_update(struct bictcp *ca, u32 cwnd, u32 acked)  in bictcp_update()  argument
229 	ca->ack_cnt += acked;	/* count the number of ACKed packets */  in bictcp_update()
231 	if (ca->last_cwnd == cwnd &&  in bictcp_update()
232 	    (s32)(tcp_jiffies32 - ca->last_time) <= HZ / 32)  in bictcp_update()
239 	if (ca->epoch_start && tcp_jiffies32 == ca->last_time)  in bictcp_update()
242 	ca->last_cwnd = cwnd;  in bictcp_update()
243 	ca->last_time = tcp_jiffies32;  in bictcp_update()
245 	if (ca->epoch_start == 0) {  in bictcp_update()
246 		ca->epoch_start = tcp_jiffies32;	/* record beginning */  in bictcp_update()
247 		ca->ack_cnt = acked;			/* start counting */  in bictcp_update()
248 		ca->tcp_cwnd = cwnd;			/* syn with cubic */  in bictcp_update()
250 		if (ca->last_max_cwnd <= cwnd) {  in bictcp_update()
251 			ca->bic_K = 0;  in bictcp_update()
252 			ca->bic_origin_point = cwnd;  in bictcp_update()
257 			ca->bic_K = cubic_root(cube_factor  in bictcp_update()
258 					       * (ca->last_max_cwnd - cwnd));  in bictcp_update()
259 			ca->bic_origin_point = ca->last_max_cwnd;  in bictcp_update()
277 	t = (s32)(tcp_jiffies32 - ca->epoch_start);  in bictcp_update()
278 	t += msecs_to_jiffies(ca->delay_min >> 3);  in bictcp_update()
283 	if (t < ca->bic_K)		/* t - K */  in bictcp_update()
284 		offs = ca->bic_K - t;  in bictcp_update()
286 		offs = t - ca->bic_K;  in bictcp_update()
290 	if (t < ca->bic_K)                            /* below origin*/  in bictcp_update()
291 		bic_target = ca->bic_origin_point - delta;  in bictcp_update()
293 		bic_target = ca->bic_origin_point + delta;  in bictcp_update()
297 		ca->cnt = cwnd / (bic_target - cwnd);  in bictcp_update()
299 		ca->cnt = 100 * cwnd;              /* very small increment*/  in bictcp_update()
306 	if (ca->last_max_cwnd == 0 && ca->cnt > 20)  in bictcp_update()
307 		ca->cnt = 20;	/* increase cwnd 5% per RTT */  in bictcp_update()
315 		while (ca->ack_cnt > delta) {		/* update tcp cwnd */  in bictcp_update()
316 			ca->ack_cnt -= delta;  in bictcp_update()
317 			ca->tcp_cwnd++;  in bictcp_update()
320 		if (ca->tcp_cwnd > cwnd) {	/* if bic is slower than tcp */  in bictcp_update()
321 			delta = ca->tcp_cwnd - cwnd;  in bictcp_update()
323 			if (ca->cnt > max_cnt)  in bictcp_update()
324 				ca->cnt = max_cnt;  in bictcp_update()
331 	ca->cnt = max(ca->cnt, 2U);  in bictcp_update()
337 	struct bictcp *ca = inet_csk_ca(sk);  in bictcp_cong_avoid()  local
343 		if (hystart && after(ack, ca->end_seq))  in bictcp_cong_avoid()
349 	bictcp_update(ca, tp->snd_cwnd, acked);  in bictcp_cong_avoid()
350 	tcp_cong_avoid_ai(tp, ca->cnt, acked);  in bictcp_cong_avoid()
356 	struct bictcp *ca = inet_csk_ca(sk);  in bictcp_recalc_ssthresh()  local
358 	ca->epoch_start = 0;	/* end of epoch */  in bictcp_recalc_ssthresh()
361 	if (tp->snd_cwnd < ca->last_max_cwnd && fast_convergence)  in bictcp_recalc_ssthresh()
362 		ca->last_max_cwnd = (tp->snd_cwnd * (BICTCP_BETA_SCALE + beta))  in bictcp_recalc_ssthresh()
365 		ca->last_max_cwnd = tp->snd_cwnd;  in bictcp_recalc_ssthresh()
381 	struct bictcp *ca = inet_csk_ca(sk);  in hystart_update()  local
383 	if (ca->found & hystart_detect)  in hystart_update()
390 		if ((s32)(now - ca->last_ack) <= hystart_ack_delta) {  in hystart_update()
391 			ca->last_ack = now;  in hystart_update()
392 			if ((s32)(now - ca->round_start) > ca->delay_min >> 4) {  in hystart_update()
393 				ca->found |= HYSTART_ACK_TRAIN;  in hystart_update()
406 		if (ca->sample_cnt < HYSTART_MIN_SAMPLES) {  in hystart_update()
407 			if (ca->curr_rtt == 0 || ca->curr_rtt > delay)  in hystart_update()
408 				ca->curr_rtt = delay;  in hystart_update()
410 			ca->sample_cnt++;  in hystart_update()
412 			if (ca->curr_rtt > ca->delay_min +  in hystart_update()
413 			    HYSTART_DELAY_THRESH(ca->delay_min >> 3)) {  in hystart_update()
414 				ca->found |= HYSTART_DELAY;  in hystart_update()
432 	struct bictcp *ca = inet_csk_ca(sk);  in bictcp_acked()  local
440 	if (ca->epoch_start && (s32)(tcp_jiffies32 - ca->epoch_start) < HZ)  in bictcp_acked()
448 	if (ca->delay_min == 0 || ca->delay_min > delay)  in bictcp_acked()
449 		ca->delay_min = delay;  in bictcp_acked()