105 static inline void bictcp_reset(struct bictcp *ca)  in bictcp_reset()  argument
107 	ca->cnt = 0;  in bictcp_reset()
108 	ca->last_max_cwnd = 0;  in bictcp_reset()
109 	ca->last_cwnd = 0;  in bictcp_reset()
110 	ca->last_time = 0;  in bictcp_reset()
111 	ca->bic_origin_point = 0;  in bictcp_reset()
112 	ca->bic_K = 0;  in bictcp_reset()
113 	ca->delay_min = 0;  in bictcp_reset()
114 	ca->epoch_start = 0;  in bictcp_reset()
115 	ca->ack_cnt = 0;  in bictcp_reset()
116 	ca->tcp_cwnd = 0;  in bictcp_reset()
117 	ca->found = 0;  in bictcp_reset()
132 	struct bictcp *ca = inet_csk_ca(sk);  in bictcp_hystart_reset()  local
134 	ca->round_start = ca->last_ack = bictcp_clock();  in bictcp_hystart_reset()
135 	ca->end_seq = tp->snd_nxt;  in bictcp_hystart_reset()
136 	ca->curr_rtt = 0;  in bictcp_hystart_reset()
137 	ca->sample_cnt = 0;  in bictcp_hystart_reset()
142 	struct bictcp *ca = inet_csk_ca(sk);  in bictcp_init()  local
144 	bictcp_reset(ca);  in bictcp_init()
156 		struct bictcp *ca = inet_csk_ca(sk);  in bictcp_cwnd_event()  local
165 		if (ca->epoch_start && delta > 0) {  in bictcp_cwnd_event()
166 			ca->epoch_start += delta;  in bictcp_cwnd_event()
167 			if (after(ca->epoch_start, now))  in bictcp_cwnd_event()
168 				ca->epoch_start = now;  in bictcp_cwnd_event()
225 static inline void bictcp_update(struct bictcp *ca, u32 cwnd, u32 acked)  in bictcp_update()  argument
230 	ca->ack_cnt += acked;	/* count the number of ACKed packets */  in bictcp_update()
232 	if (ca->last_cwnd == cwnd &&  in bictcp_update()
233 	    (s32)(tcp_jiffies32 - ca->last_time) <= HZ / 32)  in bictcp_update()
240 	if (ca->epoch_start && tcp_jiffies32 == ca->last_time)  in bictcp_update()
243 	ca->last_cwnd = cwnd;  in bictcp_update()
244 	ca->last_time = tcp_jiffies32;  in bictcp_update()
246 	if (ca->epoch_start == 0) {  in bictcp_update()
247 		ca->epoch_start = tcp_jiffies32;	/* record beginning */  in bictcp_update()
248 		ca->ack_cnt = acked;			/* start counting */  in bictcp_update()
249 		ca->tcp_cwnd = cwnd;			/* syn with cubic */  in bictcp_update()
251 		if (ca->last_max_cwnd <= cwnd) {  in bictcp_update()
252 			ca->bic_K = 0;  in bictcp_update()
253 			ca->bic_origin_point = cwnd;  in bictcp_update()
258 			ca->bic_K = cubic_root(cube_factor  in bictcp_update()
259 					       * (ca->last_max_cwnd - cwnd));  in bictcp_update()
260 			ca->bic_origin_point = ca->last_max_cwnd;  in bictcp_update()
278 	t = (s32)(tcp_jiffies32 - ca->epoch_start);  in bictcp_update()
279 	t += msecs_to_jiffies(ca->delay_min >> 3);  in bictcp_update()
284 	if (t < ca->bic_K)		/* t - K */  in bictcp_update()
285 		offs = ca->bic_K - t;  in bictcp_update()
287 		offs = t - ca->bic_K;  in bictcp_update()
291 	if (t < ca->bic_K)                            /* below origin*/  in bictcp_update()
292 		bic_target = ca->bic_origin_point - delta;  in bictcp_update()
294 		bic_target = ca->bic_origin_point + delta;  in bictcp_update()
298 		ca->cnt = cwnd / (bic_target - cwnd);  in bictcp_update()
300 		ca->cnt = 100 * cwnd;              /* very small increment*/  in bictcp_update()
307 	if (ca->last_max_cwnd == 0 && ca->cnt > 20)  in bictcp_update()
308 		ca->cnt = 20;	/* increase cwnd 5% per RTT */  in bictcp_update()
316 		while (ca->ack_cnt > delta) {		/* update tcp cwnd */  in bictcp_update()
317 			ca->ack_cnt -= delta;  in bictcp_update()
318 			ca->tcp_cwnd++;  in bictcp_update()
321 		if (ca->tcp_cwnd > cwnd) {	/* if bic is slower than tcp */  in bictcp_update()
322 			delta = ca->tcp_cwnd - cwnd;  in bictcp_update()
324 			if (ca->cnt > max_cnt)  in bictcp_update()
325 				ca->cnt = max_cnt;  in bictcp_update()
332 	ca->cnt = max(ca->cnt, 2U);  in bictcp_update()
338 	struct bictcp *ca = inet_csk_ca(sk);  in bictcp_cong_avoid()  local
344 		if (hystart && after(ack, ca->end_seq))  in bictcp_cong_avoid()
350 	bictcp_update(ca, tp->snd_cwnd, acked);  in bictcp_cong_avoid()
351 	tcp_cong_avoid_ai(tp, ca->cnt, acked);  in bictcp_cong_avoid()
357 	struct bictcp *ca = inet_csk_ca(sk);  in bictcp_recalc_ssthresh()  local
359 	ca->epoch_start = 0;	/* end of epoch */  in bictcp_recalc_ssthresh()
362 	if (tp->snd_cwnd < ca->last_max_cwnd && fast_convergence)  in bictcp_recalc_ssthresh()
363 		ca->last_max_cwnd = (tp->snd_cwnd * (BICTCP_BETA_SCALE + beta))  in bictcp_recalc_ssthresh()
366 		ca->last_max_cwnd = tp->snd_cwnd;  in bictcp_recalc_ssthresh()
382 	struct bictcp *ca = inet_csk_ca(sk);  in hystart_update()  local
384 	if (ca->found & hystart_detect)  in hystart_update()
391 		if ((s32)(now - ca->last_ack) <= hystart_ack_delta) {  in hystart_update()
392 			ca->last_ack = now;  in hystart_update()
393 			if ((s32)(now - ca->round_start) > ca->delay_min >> 4) {  in hystart_update()
394 				ca->found |= HYSTART_ACK_TRAIN;  in hystart_update()
407 		if (ca->sample_cnt < HYSTART_MIN_SAMPLES) {  in hystart_update()
408 			if (ca->curr_rtt == 0 || ca->curr_rtt > delay)  in hystart_update()
409 				ca->curr_rtt = delay;  in hystart_update()
411 			ca->sample_cnt++;  in hystart_update()
413 			if (ca->curr_rtt > ca->delay_min +  in hystart_update()
414 			    HYSTART_DELAY_THRESH(ca->delay_min >> 3)) {  in hystart_update()
415 				ca->found |= HYSTART_DELAY;  in hystart_update()
433 	struct bictcp *ca = inet_csk_ca(sk);  in bictcp_acked()  local
441 	if (ca->epoch_start && (s32)(tcp_jiffies32 - ca->epoch_start) < HZ)  in bictcp_acked()
449 	if (ca->delay_min == 0 || ca->delay_min > delay)  in bictcp_acked()
450 		ca->delay_min = delay;  in bictcp_acked()