Page MenuHomeFreeBSD
Differential D8225 Diff 21575 sys/netinet/cc/cc_htcp.c

Changeset View

Standalone View

View Options

sys/netinet/cc/cc_htcp.c

Show First 20 Lines • Show All 265 Lines • ▼ Show 20 Lines
/* /*
* Perform any necessary tasks before we enter congestion recovery. * Perform any necessary tasks before we enter congestion recovery.
*/ */
static void static void
htcp_cong_signal(struct cc_var *ccv, uint32_t type) htcp_cong_signal(struct cc_var *ccv, uint32_t type)
{ {
struct htcp *htcp_data; struct htcp *htcp_data;
uint32_t cwin;
u_int mss;
htcp_data = ccv->cc_data; htcp_data = ccv->cc_data;
cwin = CCV(ccv, snd_cwnd);
mss = CCV(ccv, t_maxseg);
switch (type) { switch (type) {
case CC_NDUPACK: case CC_NDUPACK:
if (!IN_FASTRECOVERY(CCV(ccv, t_flags))) { if (!IN_FASTRECOVERY(CCV(ccv, t_flags))) {
if (!IN_CONGRECOVERY(CCV(ccv, t_flags))) { if (!IN_CONGRECOVERY(CCV(ccv, t_flags))) {
/* /*
* Apply hysteresis to maxrtt to ensure * Apply hysteresis to maxrtt to ensure
* reductions in the RTT are reflected in our * reductions in the RTT are reflected in our
* measurements. * measurements.
*/ */
htcp_data->maxrtt = (htcp_data->minrtt + htcp_data->maxrtt = (htcp_data->minrtt +
(htcp_data->maxrtt - htcp_data->minrtt) * (htcp_data->maxrtt - htcp_data->minrtt) *
95) / 100; 95) / 100;
htcp_ssthresh_update(ccv); htcp_ssthresh_update(ccv);
CCV(ccv, snd_cwnd) = CCV(ccv, snd_ssthresh);
htcp_data->t_last_cong = ticks; htcp_data->t_last_cong = ticks;
htcp_data->prev_cwnd = CCV(ccv, snd_cwnd); htcp_data->prev_cwnd = cwin;
} }
ENTER_RECOVERY(CCV(ccv, t_flags)); ENTER_RECOVERY(CCV(ccv, t_flags));
} }
break; break;
case CC_ECN: case CC_ECN:
if (!IN_CONGRECOVERY(CCV(ccv, t_flags))) { if (!IN_CONGRECOVERY(CCV(ccv, t_flags))) {
/* /*
* Apply hysteresis to maxrtt to ensure reductions in * Apply hysteresis to maxrtt to ensure reductions in
* the RTT are reflected in our measurements. * the RTT are reflected in our measurements.
*/ */
htcp_data->maxrtt = (htcp_data->minrtt + (htcp_data->maxrtt - htcp_data->maxrtt = (htcp_data->minrtt + (htcp_data->maxrtt -
htcp_data->minrtt) * 95) / 100; htcp_data->minrtt) * 95) / 100;
htcp_ssthresh_update(ccv); htcp_ssthresh_update(ccv);
CCV(ccv, snd_cwnd) = CCV(ccv, snd_ssthresh); CCV(ccv, snd_cwnd) = CCV(ccv, snd_ssthresh);
htcp_data->t_last_cong = ticks; htcp_data->t_last_cong = ticks;
htcp_data->prev_cwnd = CCV(ccv, snd_cwnd); htcp_data->prev_cwnd = cwin;
ENTER_CONGRECOVERY(CCV(ccv, t_flags)); ENTER_CONGRECOVERY(CCV(ccv, t_flags));
} }
break; break;
case CC_RTO: case CC_RTO:
/* /*
* Grab the current time and record it so we know when the * Grab the current time and record it so we know when the
* most recent congestion event was. Only record it when the * most recent congestion event was. Only record it when the
* timeout has fired more than once, as there is a reasonable * timeout has fired more than once, as there is a reasonable
* chance the first one is a false alarm and may not indicate * chance the first one is a false alarm and may not indicate
* congestion. * congestion.
*/ */
if (CCV(ccv, t_rxtshift) >= 2) if (CCV(ccv, t_rxtshift) >= 2)
htcp_data->t_last_cong = ticks; htcp_data->t_last_cong = ticks;
CCV(ccv, snd_ssthresh) = max(2 * mss, cwin / 2);
CCV(ccv, snd_cwnd) = mss;
break; break;
} }
} }
static int static int
htcp_mod_init(void) htcp_mod_init(void)
{ {
▲ Show 20 Lines • Show All 197 Lines • Show Last 20 Lines