Page MenuHomeFreeBSD
Differential D3609

rum(4): create few wrappers
ClosedPublic
Actions

Authored by avos on Sep 8 2015, 11:48 PM.
Tags
None
Referenced Files
Unknown Object (File)
Jan 14 2025, 12:57 AM
Unknown Object (File)
Jan 3 2025, 3:20 PM
Unknown Object (File)
Jan 2 2025, 4:03 PM
Unknown Object (File)
Dec 26 2024, 12:59 PM
Unknown Object (File)
Dec 18 2024, 9:09 AM
Unknown Object (File)
Dec 17 2024, 4:54 PM
Unknown Object (File)
Nov 22 2024, 7:41 AM
Unknown Object (File)
Nov 22 2024, 7:41 AM
View All 67 Files
Subscribers
imp

Details

Reviewers
adrian
Group Reviewers
Contributor Reviewers (ports)
Commits
rS288503: rum(4): create few wrappers.
Summary

Add new functions:

  • rum_setbits();
  • rum_clrbits();
  • rum_modbits();

and switch to them.

Test Plan

Tested on WUSB54GC, STA mode.

Diff Detail

Repository
rS FreeBSD src repository - subversion
Lint
Lint Skipped
Unit
Tests Skipped

Revision Contents
Changeset List

PathSize
sys/
dev/
usb/
wlan/
97 lines

Diff 8613

View Options

sys/dev/usb/wlan/if_rum.c

Show First 20 Lines • Show All 88 Lines • ▼ Show 20 Lines
static int ieee80211_ffppsmin = 2; /* pps threshold for ff aggregation */ static int ieee80211_ffppsmin = 2; /* pps threshold for ff aggregation */
SYSCTL_INT(_net_wlan, OID_AUTO, ffppsmin, CTLFLAG_RW, SYSCTL_INT(_net_wlan, OID_AUTO, ffppsmin, CTLFLAG_RW,
&ieee80211_ffppsmin, 0, "min packet rate before fast-frame staging"); &ieee80211_ffppsmin, 0, "min packet rate before fast-frame staging");
static int ieee80211_ffagemax = -1; /* max time frames held on stage q */ static int ieee80211_ffagemax = -1; /* max time frames held on stage q */
SYSCTL_PROC(_net_wlan, OID_AUTO, ffagemax, CTLTYPE_INT | CTLFLAG_RW, SYSCTL_PROC(_net_wlan, OID_AUTO, ffagemax, CTLTYPE_INT | CTLFLAG_RW,
&ieee80211_ffagemax, 0, ieee80211_sysctl_msecs_ticks, "I", &ieee80211_ffagemax, 0, ieee80211_sysctl_msecs_ticks, "I",
"max hold time for fast-frame staging (ms)"); "max hold time for fast-frame staging (ms)");
static void
ff_age_all(void *arg, int npending)
{
struct ieee80211com *ic = arg;
/* XXX cache timer value somewhere (racy) */
ieee80211_ff_age_all(ic, ieee80211_ffagemax + 1);
}
static void
ff_check_cancel_age_timer(struct ieee80211com *ic)
{
struct ieee80211_superg *sg = ic->ic_superg;
IEEE80211_FF_LOCK_ASSERT(ic);
if (sg->ff_stageq[WME_AC_VO].depth == 0 &&
sg->ff_stageq[WME_AC_VI].depth == 0 &&
sg->ff_stageq[WME_AC_BE].depth == 0 &&
sg->ff_stageq[WME_AC_BK].depth == 0) {
struct timeout_task *qtask = &sg->ff_qtimer;
/* NB: may be called from the task itself */
(void) taskqueue_cancel_timeout(ic->ic_tq, qtask, NULL);
}
}
void void
ieee80211_superg_attach(struct ieee80211com *ic) ieee80211_superg_attach(struct ieee80211com *ic)
{ {
struct ieee80211_superg *sg; struct ieee80211_superg *sg;
IEEE80211_FF_LOCK_INIT(ic, ic->ic_name); IEEE80211_FF_LOCK_INIT(ic, ic->ic_name);
sg = (struct ieee80211_superg *) IEEE80211_MALLOC( sg = (struct ieee80211_superg *) IEEE80211_MALLOC(
sizeof(struct ieee80211_superg), M_80211_VAP, sizeof(struct ieee80211_superg), M_80211_VAP,
IEEE80211_M_NOWAIT | IEEE80211_M_ZERO); IEEE80211_M_NOWAIT | IEEE80211_M_ZERO);
if (sg == NULL) { if (sg == NULL) {
printf("%s: cannot allocate SuperG state block\n", printf("%s: cannot allocate SuperG state block\n",
__func__); __func__);
return; return;
} }
TIMEOUT_TASK_INIT(ic->ic_tq, &sg->ff_qtimer, 0, ff_age_all, ic);
ic->ic_superg = sg; ic->ic_superg = sg;
/* /*
* Default to not being so aggressive for FF/AMSDU * Default to not being so aggressive for FF/AMSDU
* aging, otherwise we may hold a frame around * aging, otherwise we may hold a frame around
* for way too long before we expire it out. * for way too long before we expire it out.
*/ */
ieee80211_ffagemax = msecs_to_ticks(2); ieee80211_ffagemax = msecs_to_ticks(2);
} }
void void
ieee80211_superg_detach(struct ieee80211com *ic) ieee80211_superg_detach(struct ieee80211com *ic)
{ {
IEEE80211_FF_LOCK_DESTROY(ic);
if (ic->ic_superg != NULL) { if (ic->ic_superg != NULL) {
struct timeout_task *qtask = &ic->ic_superg->ff_qtimer;
while (taskqueue_cancel_timeout(ic->ic_tq, qtask, NULL) != 0)
taskqueue_drain_timeout(ic->ic_tq, qtask);
IEEE80211_FREE(ic->ic_superg, M_80211_VAP); IEEE80211_FREE(ic->ic_superg, M_80211_VAP);
ic->ic_superg = NULL; ic->ic_superg = NULL;
} }
IEEE80211_FF_LOCK_DESTROY(ic);
} }
void void
ieee80211_superg_vattach(struct ieee80211vap *vap) ieee80211_superg_vattach(struct ieee80211vap *vap)
{ {
struct ieee80211com *ic = vap->iv_ic; struct ieee80211com *ic = vap->iv_ic;
if (ic->ic_superg == NULL) /* NB: can't do fast-frames w/o state */ if (ic->ic_superg == NULL) /* NB: can't do fast-frames w/o state */
▲ Show 20 Lines • Show All 503 Lines • ▼ Show 20 Lines while ((m = sq->head) != NULL && M_AGE_GET(m) < quanta) {
/* clear staging ref to frame */ /* clear staging ref to frame */
ni = (struct ieee80211_node *) m->m_pkthdr.rcvif; ni = (struct ieee80211_node *) m->m_pkthdr.rcvif;
KASSERT(ni->ni_tx_superg[tid] == m, ("staging queue empty")); KASSERT(ni->ni_tx_superg[tid] == m, ("staging queue empty"));
ni->ni_tx_superg[tid] = NULL; ni->ni_tx_superg[tid] = NULL;
sq->head = m->m_nextpkt; sq->head = m->m_nextpkt;
sq->depth--; sq->depth--;
} }
if (m == NULL) if (m == NULL) {
sq->tail = NULL; sq->tail = NULL;
else ff_check_cancel_age_timer(ic);
} else
M_AGE_SUB(m, quanta); M_AGE_SUB(m, quanta);
IEEE80211_FF_UNLOCK(ic); IEEE80211_FF_UNLOCK(ic);
IEEE80211_TX_LOCK(ic); IEEE80211_TX_LOCK(ic);
ff_flush(head, m); ff_flush(head, m);
IEEE80211_TX_UNLOCK(ic); IEEE80211_TX_UNLOCK(ic);
} }
static void static void
stageq_add(struct ieee80211com *ic, struct ieee80211_stageq *sq, struct mbuf *m) stageq_add(struct ieee80211com *ic, struct ieee80211_stageq *sq, struct mbuf *m)
{ {
int age = ieee80211_ffagemax; int age = ieee80211_ffagemax;
IEEE80211_FF_LOCK_ASSERT(ic); IEEE80211_FF_LOCK_ASSERT(ic);
if (sq->tail != NULL) { if (sq->tail != NULL) {
sq->tail->m_nextpkt = m; sq->tail->m_nextpkt = m;
age -= M_AGE_GET(sq->head); age -= M_AGE_GET(sq->head);
} else } else {
sq->head = m; sq->head = m;
/* Do not restart the timer if task was already scheduled. */
struct timeout_task *qtask = &ic->ic_superg->ff_qtimer;
taskqueue_enqueue_timeout(ic->ic_tq, qtask, -age);
}
KASSERT(age >= 0, ("age %d", age)); KASSERT(age >= 0, ("age %d", age));
M_AGE_SET(m, age); M_AGE_SET(m, age);
m->m_nextpkt = NULL; m->m_nextpkt = NULL;
sq->tail = m; sq->tail = m;
sq->depth++; sq->depth++;
} }
static void static void
stageq_remove(struct ieee80211com *ic, struct ieee80211_stageq *sq, struct mbuf *mstaged) stageq_remove(struct ieee80211com *ic, struct ieee80211_stageq *sq, struct mbuf *mstaged)
{ {
struct mbuf *m, *mprev; struct mbuf *m, *mprev;
IEEE80211_FF_LOCK_ASSERT(ic); IEEE80211_FF_LOCK_ASSERT(ic);
mprev = NULL; mprev = NULL;
for (m = sq->head; m != NULL; m = m->m_nextpkt) { for (m = sq->head; m != NULL; m = m->m_nextpkt) {
if (m == mstaged) { if (m == mstaged) {
if (mprev == NULL) if (mprev == NULL)
sq->head = m->m_nextpkt; sq->head = m->m_nextpkt;
else else
mprev->m_nextpkt = m->m_nextpkt; mprev->m_nextpkt = m->m_nextpkt;
if (sq->tail == m) if (sq->tail == m)
sq->tail = mprev; sq->tail = mprev;
sq->depth--; sq->depth--;
ff_check_cancel_age_timer(ic);
return; return;
} }
mprev = m; mprev = m;
} }
printf("%s: packet not found\n", __func__); printf("%s: packet not found\n", __func__);
} }
static uint32_t static uint32_t
▲ Show 20 Lines • Show All 343 Lines • Show Last 20 Lines