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)  in cdg_cb_init()  argument
298 	INP_WLOCK_ASSERT(tptoinpcb(ccv->tp));  in cdg_cb_init()
322 	ccv->cc_data = cdg_data;  in cdg_cb_init()
328 cdg_conn_init(struct cc_var *ccv)  in cdg_conn_init()  argument
330 	struct cdg *cdg_data = ccv->cc_data;  in cdg_conn_init()
336 	cdg_data->shadow_w = CCV(ccv, snd_cwnd);  in cdg_conn_init()
340 cdg_cb_destroy(struct cc_var *ccv)  in cdg_cb_destroy()  argument
345 	cdg_data = ccv->cc_data;  in cdg_cb_destroy()
361 	free(ccv->cc_data, M_CC_MEM);  in cdg_cb_destroy()
401 cdg_window_decrease(struct cc_var *ccv, unsigned long owin, unsigned int beta)  in cdg_window_decrease()  argument
404 	return ((ulmin(CCV(ccv, snd_wnd), owin) * beta) / 100);  in cdg_window_decrease()
415 cdg_window_increase(struct cc_var *ccv, int new_measurement)  in cdg_window_increase()  argument
419 	uint32_t mss = tcp_fixed_maxseg(ccv->tp);  in cdg_window_increase()
421 	cdg_data = ccv->cc_data;  in cdg_window_increase()
424 	if (CCV(ccv, snd_cwnd) <= CCV(ccv, snd_ssthresh)) {  in cdg_window_increase()
448 		    TCP_MAXWIN << CCV(ccv, snd_scale));  in cdg_window_increase()
450 	CCV(ccv, snd_cwnd) = ulmin(CCV(ccv, snd_cwnd) + incr,  in cdg_window_increase()
451 	    TCP_MAXWIN << CCV(ccv, snd_scale));  in cdg_window_increase()
455 cdg_cong_signal(struct cc_var *ccv, ccsignal_t signal_type)  in cdg_cong_signal()  argument
457 	struct cdg *cdg_data = ccv->cc_data;  in cdg_cong_signal()
461 		CCV(ccv, snd_ssthresh) = cdg_window_decrease(ccv,  in cdg_cong_signal()
462 		    CCV(ccv, snd_cwnd), V_cdg_beta_delay);  in cdg_cong_signal()
463 		CCV(ccv, snd_cwnd) = CCV(ccv, snd_ssthresh);  in cdg_cong_signal()
464 		CCV(ccv, snd_recover) = CCV(ccv, snd_max);  in cdg_cong_signal()
466 		ENTER_CONGRECOVERY(CCV(ccv, t_flags));  in cdg_cong_signal()
473 		if (IN_CONGRECOVERY(CCV(ccv, t_flags)) ||  in cdg_cong_signal()
475 			CCV(ccv, snd_ssthresh) = CCV(ccv, snd_cwnd);  in cdg_cong_signal()
476 			CCV(ccv, snd_recover) = CCV(ccv, snd_max);  in cdg_cong_signal()
484 				cdg_data->shadow_w = cdg_window_decrease(ccv,  in cdg_cong_signal()
487 			CCV(ccv, snd_ssthresh) = max(cdg_data->shadow_w,  in cdg_cong_signal()
488 			    cdg_window_decrease(ccv, CCV(ccv, snd_cwnd),  in cdg_cong_signal()
493 		ENTER_RECOVERY(CCV(ccv, t_flags));  in cdg_cong_signal()
496 		newreno_cc_cong_signal(ccv, signal_type);  in cdg_cong_signal()
577 cdg_ack_received(struct cc_var *ccv, ccsignal_t ack_type)  in cdg_ack_received()  argument
584 	cdg_data = ccv->cc_data;  in cdg_ack_received()
585 	e_t = (struct ertt *)khelp_get_osd(&CCV(ccv, t_osd), ertt_id);  in cdg_ack_received()
592 		slowstart = (CCV(ccv, snd_cwnd) <= CCV(ccv, snd_ssthresh));  in cdg_ack_received()
651 		if (!IN_RECOVERY(CCV(ccv, t_flags))) {  in cdg_ack_received()
653 				cdg_cong_signal(ccv, CC_CDG_DELAY);  in cdg_ack_received()
671 			cdg_data->shadow_w = ulmax(CCV(ccv, snd_cwnd),  in cdg_ack_received()
675 		cdg_window_increase(ccv, new_measurement);  in cdg_ack_received()