netinet/cc/cc_chd.c

92 static void	chd_ack_received(struct cc_var *ccv, ccsignal_t ack_type);
93 static void	chd_cb_destroy(struct cc_var *ccv);
94 static int	chd_cb_init(struct cc_var *ccv, void *ptr);
95 static void	chd_cong_signal(struct cc_var *ccv, ccsignal_t signal_type);
96 static void	chd_conn_init(struct cc_var *ccv);
147 chd_window_decrease(struct cc_var *ccv)
151 	win = min(CCV(ccv, snd_wnd), CCV(ccv, snd_cwnd)) / CCV(ccv, t_maxseg);
153 	CCV(ccv, snd_ssthresh) = max(win, 2) * CCV(ccv, t_maxseg);
189 chd_window_increase(struct cc_var *ccv, int new_measurement)
194 	chd_data = ccv->cc_data;
197 	if (CCV(ccv, snd_cwnd) <= CCV(ccv, snd_ssthresh)) {
201 			if (CCV(ccv, snd_nxt) == CCV(ccv, snd_max)) {
203 				incr = min(ccv->bytes_this_ack,
204 				    V_tcp_abc_l_var * CCV(ccv, t_maxseg));
207 				incr = min(ccv->bytes_this_ack,
208 				    CCV(ccv, t_maxseg));
211 			incr = CCV(ccv, t_maxseg);
215 			if (ccv->flags & CCF_ABC_SENTAWND) {
216 				ccv->flags &= ~CCF_ABC_SENTAWND;
217 				incr = CCV(ccv, t_maxseg);
220 			incr = CCV(ccv, t_maxseg);
226 		    TCP_MAXWIN << CCV(ccv, snd_scale));
229 	CCV(ccv,snd_cwnd) = min(CCV(ccv, snd_cwnd) + incr,
230 	    TCP_MAXWIN << CCV(ccv, snd_scale));
239 chd_ack_received(struct cc_var *ccv, ccsignal_t ack_type)
245 	e_t = khelp_get_osd(&CCV(ccv, t_osd), ertt_id);
246 	chd_data = ccv->cc_data;
260 		if (rtt && e_t->minrtt && !IN_RECOVERY(CCV(ccv, t_flags))) {
287 			chd_data->shadow_w = max(CCV(ccv, snd_cwnd),
302 		chd_cong_signal(ccv, CC_CHD_DELAY);
305 		chd_window_increase(ccv, new_measurement);
309 chd_cb_destroy(struct cc_var *ccv)
311 	free(ccv->cc_data, M_CC_MEM);
321 chd_cb_init(struct cc_var *ccv, void *ptr)
325 	INP_WLOCK_ASSERT(tptoinpcb(ccv->ccvc.tcp));
334 	ccv->cc_data = chd_data;
340 chd_cong_signal(struct cc_var *ccv, ccsignal_t signal_type)
346 	e_t = khelp_get_osd(&CCV(ccv, t_osd), ertt_id);
347 	chd_data = ccv->cc_data;
352 		chd_window_decrease(ccv); /* Set new ssthresh. */
353 		CCV(ccv, snd_cwnd) = CCV(ccv, snd_ssthresh);
354 		CCV(ccv, snd_recover) = CCV(ccv, snd_max);
355 		ENTER_CONGRECOVERY(CCV(ccv, t_flags));
367 		if (!IN_RECOVERY(CCV(ccv, t_flags)) && qdly > V_chd_qthresh) {
369 				CCV(ccv, snd_cwnd) = max(CCV(ccv, snd_cwnd),
372 			chd_window_decrease(ccv);
378 			CCV(ccv, snd_ssthresh) = CCV(ccv, snd_cwnd);
379 			CCV(ccv, snd_recover) = CCV(ccv, snd_max);
384 			    CCV(ccv, t_maxseg) / 2, 2) * CCV(ccv, t_maxseg);
386 		ENTER_FASTRECOVERY(CCV(ccv, t_flags));
390 		newreno_cc_cong_signal(ccv, signal_type);
396 chd_conn_init(struct cc_var *ccv)
400 	chd_data = ccv->cc_data;
408 	chd_data->shadow_w = CCV(ccv, snd_cwnd);