netinet/cc/cc_cdg.c

222 static void cdg_conn_init(struct cc_var *ccv);
223 static int cdg_cb_init(struct cc_var *ccv, void *ptr);
224 static void cdg_cb_destroy(struct cc_var *ccv);
225 static void cdg_cong_signal(struct cc_var *ccv, ccsignal_t signal_type);
226 static void cdg_ack_received(struct cc_var *ccv, ccsignal_t ack_type);
294 cdg_cb_init(struct cc_var *ccv, void *ptr)
298 	INP_WLOCK_ASSERT(tptoinpcb(ccv->ccvc.tcp));
322 	ccv->cc_data = cdg_data;
328 cdg_conn_init(struct cc_var *ccv)
330 	struct cdg *cdg_data = ccv->cc_data;
336 	cdg_data->shadow_w = CCV(ccv, snd_cwnd);
340 cdg_cb_destroy(struct cc_var *ccv)
345 	cdg_data = ccv->cc_data;
361 	free(ccv->cc_data, M_CC_MEM);
401 cdg_window_decrease(struct cc_var *ccv, unsigned long owin, unsigned int beta)
404 	return ((ulmin(CCV(ccv, snd_wnd), owin) * beta) / 100);
415 cdg_window_increase(struct cc_var *ccv, int new_measurement)
420 	cdg_data = ccv->cc_data;
423 	if (CCV(ccv, snd_cwnd) <= CCV(ccv, snd_ssthresh)) {
425 		incr = CCV(ccv, t_maxseg);
431 			s_w_incr = CCV(ccv, t_maxseg);
433 				incr = CCV(ccv, t_maxseg);
439 				incr = CCV(ccv, t_maxseg) *
447 		    TCP_MAXWIN << CCV(ccv, snd_scale));
449 	CCV(ccv, snd_cwnd) = ulmin(CCV(ccv, snd_cwnd) + incr,
450 	    TCP_MAXWIN << CCV(ccv, snd_scale));
454 cdg_cong_signal(struct cc_var *ccv, ccsignal_t signal_type)
456 	struct cdg *cdg_data = ccv->cc_data;
460 		CCV(ccv, snd_ssthresh) = cdg_window_decrease(ccv,
461 		    CCV(ccv, snd_cwnd), V_cdg_beta_delay);
462 		CCV(ccv, snd_cwnd) = CCV(ccv, snd_ssthresh);
463 		CCV(ccv, snd_recover) = CCV(ccv, snd_max);
465 		ENTER_CONGRECOVERY(CCV(ccv, t_flags));
472 		if (IN_CONGRECOVERY(CCV(ccv, t_flags)) ||
474 			CCV(ccv, snd_ssthresh) = CCV(ccv, snd_cwnd);
475 			CCV(ccv, snd_recover) = CCV(ccv, snd_max);
483 				cdg_data->shadow_w = cdg_window_decrease(ccv,
486 			CCV(ccv, snd_ssthresh) = max(cdg_data->shadow_w,
487 			    cdg_window_decrease(ccv, CCV(ccv, snd_cwnd),
492 		ENTER_RECOVERY(CCV(ccv, t_flags));
495 		newreno_cc_cong_signal(ccv, signal_type);
576 cdg_ack_received(struct cc_var *ccv, ccsignal_t ack_type)
583 	cdg_data = ccv->cc_data;
584 	e_t = (struct ertt *)khelp_get_osd(&CCV(ccv, t_osd), ertt_id);
591 		slowstart = (CCV(ccv, snd_cwnd) <= CCV(ccv, snd_ssthresh));
650 		if (!IN_RECOVERY(CCV(ccv, t_flags))) {
652 				cdg_cong_signal(ccv, CC_CDG_DELAY);
670 			cdg_data->shadow_w = ulmax(CCV(ccv, snd_cwnd),
674 		cdg_window_increase(ccv, new_measurement);