netinet/cc/cc_cdg.c

229 static void cdg_conn_init(struct cc_var *ccv);
230 static int cdg_cb_init(struct cc_var *ccv);
231 static void cdg_cb_destroy(struct cc_var *ccv);
232 static void cdg_cong_signal(struct cc_var *ccv, uint32_t signal_type);
233 static void cdg_ack_received(struct cc_var *ccv, uint16_t ack_type);
286 cdg_cb_init(struct cc_var *ccv)
310 	ccv->cc_data = cdg_data;
316 cdg_conn_init(struct cc_var *ccv)
318 	struct cdg *cdg_data = ccv->cc_data;
324 	cdg_data->shadow_w = CCV(ccv, snd_cwnd);
328 cdg_cb_destroy(struct cc_var *ccv)
333 	cdg_data = ccv->cc_data;
349 	free(ccv->cc_data, M_CDG);
374 cdg_window_decrease(struct cc_var *ccv, unsigned long owin, unsigned int beta)
377 	return ((ulmin(CCV(ccv, snd_wnd), owin) * beta) / 100);
388 cdg_window_increase(struct cc_var *ccv, int new_measurement)
393 	cdg_data = ccv->cc_data;
396 	if (CCV(ccv, snd_cwnd) <= CCV(ccv, snd_ssthresh)) {
398 		incr = CCV(ccv, t_maxseg);
404 			s_w_incr = CCV(ccv, t_maxseg);
406 				incr = CCV(ccv, t_maxseg);
412 				incr = CCV(ccv, t_maxseg) *
420 		    TCP_MAXWIN << CCV(ccv, snd_scale));
422 	CCV(ccv, snd_cwnd) = ulmin(CCV(ccv, snd_cwnd) + incr,
423 	    TCP_MAXWIN << CCV(ccv, snd_scale));
427 cdg_cong_signal(struct cc_var *ccv, uint32_t signal_type)
429 	struct cdg *cdg_data = ccv->cc_data;
433 		CCV(ccv, snd_ssthresh) = cdg_window_decrease(ccv,
434 		    CCV(ccv, snd_cwnd), V_cdg_beta_delay);
435 		CCV(ccv, snd_cwnd) = CCV(ccv, snd_ssthresh);
436 		CCV(ccv, snd_recover) = CCV(ccv, snd_max);
438 		ENTER_CONGRECOVERY(CCV(ccv, t_flags));
445 		if (IN_CONGRECOVERY(CCV(ccv, t_flags)) ||
447 			CCV(ccv, snd_ssthresh) = CCV(ccv, snd_cwnd);
448 			CCV(ccv, snd_recover) = CCV(ccv, snd_max);
456 				cdg_data->shadow_w = cdg_window_decrease(ccv,
459 			CCV(ccv, snd_ssthresh) = ulmax(cdg_data->shadow_w,
460 			    cdg_window_decrease(ccv, CCV(ccv, snd_cwnd),
465 		ENTER_RECOVERY(CCV(ccv, t_flags));
468 		newreno_cc_algo.cong_signal(ccv, signal_type);
548 cdg_ack_received(struct cc_var *ccv, uint16_t ack_type)
555 	cdg_data = ccv->cc_data;
556 	e_t = (struct ertt *)khelp_get_osd(CCV(ccv, osd), ertt_id);
563 		slowstart = (CCV(ccv, snd_cwnd) <= CCV(ccv, snd_ssthresh));
618 		if (!IN_RECOVERY(CCV(ccv, t_flags))) {
620 				cdg_cong_signal(ccv, CC_CDG_DELAY);
638 			cdg_data->shadow_w = ulmax(CCV(ccv, snd_cwnd),
642 		cdg_window_increase(ccv, new_measurement);