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