141 rate_to_ndx(struct sample_node *sn, int rate) {  in rate_to_ndx()  argument
143 	for (x = 0; x < sn->num_rates; x++) {  in rate_to_ndx()
144 		if (sn->rates[x].rate == rate) {  in rate_to_ndx()
169 static inline int best_rate_ndx(struct sample_node *sn, int size_bin,   in best_rate_ndx()  argument
175         for (x = 0; x < sn->num_rates; x++) {  in best_rate_ndx()
176 		int tt = sn->stats[size_bin][x].average_tx_time;  in best_rate_ndx()
178 				!sn->stats[size_bin][x].packets_acked)) {  in best_rate_ndx()
183 		if (sn->rates[x].rate == 18)   in best_rate_ndx()
187 		if (sn->stats[size_bin][x].successive_failures > 3)  in best_rate_ndx()
202 pick_sample_ndx(struct sample_node *sn, int size_bin)   in pick_sample_ndx()  argument
208 	current_ndx = sn->current_rate[size_bin];  in pick_sample_ndx()
214 	current_tt = sn->stats[size_bin][current_ndx].average_tx_time;  in pick_sample_ndx()
216 	for (x = 0; x < sn->num_rates; x++) {  in pick_sample_ndx()
217 		int ndx = (sn->last_sample_ndx[size_bin]+1+x) % sn->num_rates;  in pick_sample_ndx()
224 		if (sn->stats[size_bin][ndx].perfect_tx_time > current_tt)   in pick_sample_ndx()
228 		if (ticks - sn->stats[size_bin][ndx].last_tx < ((hz * STALE_FAILURE_TIMEOUT_MS)/1000) &&  in pick_sample_ndx()
229 		    sn->stats[size_bin][ndx].successive_failures > 3)  in pick_sample_ndx()
235 		if (sn->rates[ndx].rate > 22 && ndx > current_ndx + 2)  in pick_sample_ndx()
239 		if (sn->rates[ndx].rate == 18)   in pick_sample_ndx()
244 		if (sn->rates[current_ndx].rate == 22 && ndx > current_ndx + 1)   in pick_sample_ndx()
247 		sn->last_sample_ndx[size_bin] = ndx;  in pick_sample_ndx()
258 	struct sample_node *sn = ATH_NODE_SAMPLE(an);  in ath_rate_findrate()  local
266 	best_ndx = best_rate_ndx(sn, size_bin, !mrr);  in ath_rate_findrate()
269 		average_tx_time = sn->stats[size_bin][best_ndx].average_tx_time;  in ath_rate_findrate()
274 	if (sn->static_rate_ndx != -1) {  in ath_rate_findrate()
275 		ndx = sn->static_rate_ndx;  in ath_rate_findrate()
280 …if (sn->sample_tt[size_bin] < average_tx_time * (sn->packets_since_sample[size_bin]*ssc->ath_sampl…  in ath_rate_findrate()
286 			ndx = pick_sample_ndx(sn, size_bin);  in ath_rate_findrate()
287 			if (ndx != sn->current_rate[size_bin]) {  in ath_rate_findrate()
288 				sn->current_sample_ndx[size_bin] = ndx;  in ath_rate_findrate()
290 				sn->current_sample_ndx[size_bin] = -1;  in ath_rate_findrate()
292 			sn->packets_since_sample[size_bin] = 0;  in ath_rate_findrate()
296 			if (!sn->packets_sent[size_bin] || best_ndx == -1) {  in ath_rate_findrate()
298 				for (ndx = sn->num_rates-1; ndx > 0; ndx--) {  in ath_rate_findrate()
303 					if (sn->rates[ndx].rate <= 72 &&   in ath_rate_findrate()
304 					    sn->stats[size_bin][ndx].successive_failures == 0) {  in ath_rate_findrate()
310 			} else if (sn->packets_sent[size_bin] < 20) {  in ath_rate_findrate()
313 			} else if (ticks - ((hz*MIN_SWITCH_MS)/1000) > sn->ticks_since_switch[size_bin]) {  in ath_rate_findrate()
316 …} else if (average_tx_time * 2 < sn->stats[size_bin][sn->current_rate[size_bin]].average_tx_time) {  in ath_rate_findrate()
321 			sn->packets_since_sample[size_bin]++;  in ath_rate_findrate()
324 				if (best_ndx != sn->current_rate[size_bin]) {  in ath_rate_findrate()
329 						sn->rates[sn->current_rate[size_bin]].rate,  in ath_rate_findrate()
330 						sn->stats[size_bin][sn->current_rate[size_bin]].average_tx_time,  in ath_rate_findrate()
331 						sn->stats[size_bin][sn->current_rate[size_bin]].perfect_tx_time,  in ath_rate_findrate()
332 						sn->rates[best_ndx].rate,  in ath_rate_findrate()
333 						sn->stats[size_bin][best_ndx].average_tx_time,  in ath_rate_findrate()
334 						sn->stats[size_bin][best_ndx].perfect_tx_time,  in ath_rate_findrate()
335 						sn->packets_since_switch[size_bin],  in ath_rate_findrate()
338 				sn->packets_since_switch[size_bin] = 0;  in ath_rate_findrate()
339 				sn->current_rate[size_bin] = best_ndx;  in ath_rate_findrate()
340 				sn->ticks_since_switch[size_bin] = ticks;  in ath_rate_findrate()
342 			ndx = sn->current_rate[size_bin];  in ath_rate_findrate()
343 			sn->packets_since_switch[size_bin]++;  in ath_rate_findrate()
354 	KASSERTMSG(ndx >= 0 && ndx < sn->num_rates, "ndx is %d", ndx);  in ath_rate_findrate()
356 	*rix = sn->rates[ndx].rix;  in ath_rate_findrate()
358 		*txrate = sn->rates[ndx].shortPreambleRateCode;  in ath_rate_findrate()
360 		*txrate = sn->rates[ndx].rateCode;  in ath_rate_findrate()
362 	sn->packets_sent[size_bin]++;  in ath_rate_findrate()
369 	struct sample_node *sn = ATH_NODE_SAMPLE(an);  in ath_rate_setupxtxdesc()  local
376 	ndx = sn->current_rate[size_bin]; /* retry at the current bit-rate */  in ath_rate_setupxtxdesc()
378 	if (!sn->stats[size_bin][ndx].packets_acked) {  in ath_rate_setupxtxdesc()
383 		rateCode = sn->rates[ndx].shortPreambleRateCode;  in ath_rate_setupxtxdesc()
385 		rateCode = sn->rates[ndx].rateCode;  in ath_rate_setupxtxdesc()
389 			     , sn->rates[0].rateCode, 3	/* series 2 */  in ath_rate_setupxtxdesc()
403 	struct sample_node *sn = ATH_NODE_SAMPLE(an);  in update_stats()  local
416 	rate = sn->rates[ndx0].rate;  in update_stats()
418 	tt += calc_usecs_unicast_packet(sc, size, sn->rates[ndx0].rix,  in update_stats()
423 		    ndx1 == -1 ? 0 : sn->rates[ndx1].rix, short_tries - 1,   in update_stats()
430 		    ndx2 == -1 ? 0 : sn->rates[ndx2].rix, short_tries - 1,   in update_stats()
438 		    ndx3 == -1 ? 0 : sn->rates[ndx3].rix, short_tries - 1,   in update_stats()
442 	if (sn->stats[size_bin][ndx0].total_packets < (100 / (100 - ssc->ath_smoothing_rate))) {  in update_stats()
444 		int avg_tx = sn->stats[size_bin][ndx0].average_tx_time;  in update_stats()
445 		int packets = sn->stats[size_bin][ndx0].total_packets;  in update_stats()
446 		sn->stats[size_bin][ndx0].average_tx_time = (tt+(avg_tx*packets))/(packets+1);  in update_stats()
449 		sn->stats[size_bin][ndx0].average_tx_time =   in update_stats()
450 			((sn->stats[size_bin][ndx0].average_tx_time * ssc->ath_smoothing_rate) +   in update_stats()
456 		sn->stats[size_bin][ndx0].successive_failures++;  in update_stats()
462 			sn->stats[y][ndx0].successive_failures++;  in update_stats()
463 			sn->stats[y][ndx0].last_tx = ticks;  in update_stats()
464 			sn->stats[y][ndx0].tries += tries;  in update_stats()
465 			sn->stats[y][ndx0].total_packets++;  in update_stats()
468 		sn->stats[size_bin][ndx0].packets_acked++;  in update_stats()
469 		sn->stats[size_bin][ndx0].successive_failures = 0;  in update_stats()
471 	sn->stats[size_bin][ndx0].tries += tries;  in update_stats()
472 	sn->stats[size_bin][ndx0].last_tx = ticks;  in update_stats()
473 	sn->stats[size_bin][ndx0].total_packets++;  in update_stats()
476 	if (ndx0 == sn->current_sample_ndx[size_bin]) {  in update_stats()
480 			sn->stats[size_bin][ndx0].average_tx_time,  in update_stats()
481 			sn->stats[size_bin][ndx0].perfect_tx_time,  in update_stats()
483 		sn->sample_tt[size_bin] = tt;  in update_stats()
484 		sn->current_sample_ndx[size_bin] = -1;  in update_stats()
493 	struct sample_node *sn = ATH_NODE_SAMPLE(an);  in ath_rate_tx_complete()  local
506 	if (sn->num_rates <= 0) {  in ath_rate_tx_complete()
539 		ndx = rate_to_ndx(sn, final_rate);  in ath_rate_tx_complete()
545 		if (ndx >= 0 && ndx < sn->num_rates) {  in ath_rate_tx_complete()
566 		ndx0 = rate_to_ndx(sn, rate0);  in ath_rate_tx_complete()
570 		ndx1 = rate_to_ndx(sn, rate1);  in ath_rate_tx_complete()
574 		ndx2 = rate_to_ndx(sn, rate2);  in ath_rate_tx_complete()
578 		ndx3 = rate_to_ndx(sn, rate3);  in ath_rate_tx_complete()
653 	struct sample_node *sn = ATH_NODE_SAMPLE(an);  in ath_rate_ctl_reset()  local
658         sn->static_rate_ndx = -1;  in ath_rate_ctl_reset()
676                 sn->static_rate_ndx = srate;  in ath_rate_ctl_reset()
681 	sn->num_rates = ni->ni_rates.rs_nrates;  in ath_rate_ctl_reset()
683 		sn->rates[x].rate = ni->ni_rates.rs_rates[x] & IEEE80211_RATE_VAL;  in ath_rate_ctl_reset()
684 		sn->rates[x].rix = sc->sc_rixmap[sn->rates[x].rate];  in ath_rate_ctl_reset()
685 		sn->rates[x].rateCode = rt->info[sn->rates[x].rix].rateCode;  in ath_rate_ctl_reset()
686 		sn->rates[x].shortPreambleRateCode =   in ath_rate_ctl_reset()
687 			rt->info[sn->rates[x].rix].rateCode |   in ath_rate_ctl_reset()
688 			rt->info[sn->rates[x].rix].shortPreamble;  in ath_rate_ctl_reset()
690 		DPRINTF(sc, " %d/%d", sn->rates[x].rate,  in ath_rate_ctl_reset()
691 			calc_usecs_unicast_packet(sc, 1600, sn->rates[x].rix,   in ath_rate_ctl_reset()
698 	sn->num_rates = ni->ni_rates.rs_nrates;  in ath_rate_ctl_reset()
703 		sn->packets_sent[y] = 0;  in ath_rate_ctl_reset()
704 		sn->current_sample_ndx[y] = -1;  in ath_rate_ctl_reset()
705 		sn->last_sample_ndx[y] = 0;  in ath_rate_ctl_reset()
708 			sn->stats[y][x].successive_failures = 0;  in ath_rate_ctl_reset()
709 			sn->stats[y][x].tries = 0;  in ath_rate_ctl_reset()
710 			sn->stats[y][x].total_packets = 0;  in ath_rate_ctl_reset()
711 			sn->stats[y][x].packets_acked = 0;  in ath_rate_ctl_reset()
712 			sn->stats[y][x].last_tx = 0;  in ath_rate_ctl_reset()
714 			sn->stats[y][x].perfect_tx_time =   in ath_rate_ctl_reset()
716 							  sn->rates[x].rix,  in ath_rate_ctl_reset()
718 			sn->stats[y][x].average_tx_time = sn->stats[y][x].perfect_tx_time;  in ath_rate_ctl_reset()
722 		for (ndx = sn->num_rates-1; ndx > 0; ndx--) {  in ath_rate_ctl_reset()
723 			if (sn->rates[ndx].rate <= 72) {  in ath_rate_ctl_reset()
727 		sn->current_rate[y] = ndx;  in ath_rate_ctl_reset()
732 		sn->num_rates,  in ath_rate_ctl_reset()
733 		sn->rates[0].rate/2, sn->rates[0].rate % 0x1 ? ".5" : "",  in ath_rate_ctl_reset()
734 		sn->stats[1][0].perfect_tx_time,  in ath_rate_ctl_reset()
735 		sn->rates[sn->num_rates-1].rate/2,  in ath_rate_ctl_reset()
736 			sn->rates[sn->num_rates-1].rate % 0x1 ? ".5" : "",  in ath_rate_ctl_reset()
737 		sn->stats[1][sn->num_rates-1].perfect_tx_time  in ath_rate_ctl_reset()
740 	ni->ni_txrate = sn->current_rate[0];  in ath_rate_ctl_reset()