netinet/cc/cc_vegas.c

90 static void	vegas_ack_received(struct cc_var *ccv, uint16_t ack_type);
91 static void	vegas_cb_destroy(struct cc_var *ccv);
92 static int	vegas_cb_init(struct cc_var *ccv);
93 static void	vegas_cong_signal(struct cc_var *ccv, uint32_t signal_type);
94 static void	vegas_conn_init(struct cc_var *ccv);
127 vegas_ack_received(struct cc_var *ccv, uint16_t ack_type)
133 	e_t = khelp_get_osd(CCV(ccv, osd), ertt_id);
134 	vegas_data = ccv->cc_data;
142 			    e_t->minrtt / CCV(ccv, t_maxseg);
145 				if (CCV(ccv, snd_cwnd) <=
146 				    CCV(ccv, snd_ssthresh)) {
152 					CCV(ccv, snd_cwnd) =
153 					    min(CCV(ccv, snd_cwnd) +
154 					    CCV(ccv, t_maxseg),
155 					    TCP_MAXWIN << CCV(ccv, snd_scale));
159 				vegas_cong_signal(ccv, CC_VEGAS_RATE);
167 		newreno_cc_algo.ack_received(ccv, ack_type);
171 vegas_cb_destroy(struct cc_var *ccv)
174 	if (ccv->cc_data != NULL)
175 		free(ccv->cc_data, M_VEGAS);
179 vegas_cb_init(struct cc_var *ccv)
189 	ccv->cc_data = vegas_data;
199 vegas_cong_signal(struct cc_var *ccv, uint32_t signal_type)
204 	vegas_data = ccv->cc_data;
206 	if (IN_RECOVERY(CCV(ccv, t_flags)))
213 		if (!IN_RECOVERY(CCV(ccv, t_flags))) {
214 			CCV(ccv, snd_cwnd) = max(2 * CCV(ccv, t_maxseg),
215 			    CCV(ccv, snd_cwnd) - CCV(ccv, t_maxseg));
216 			if (CCV(ccv, snd_cwnd) < CCV(ccv, snd_ssthresh))
218 				CCV(ccv, snd_ssthresh) = CCV(ccv, snd_cwnd);
223 		newreno_cc_algo.cong_signal(ccv, signal_type);
226 	if (IN_RECOVERY(CCV(ccv, t_flags)) && !presignalrecov)
228 		    (CCV(ccv, snd_cwnd) < CCV(ccv, snd_ssthresh)) ? 1 : 0;
232 vegas_conn_init(struct cc_var *ccv)
236 	vegas_data = ccv->cc_data;