File Manager

003 File Manager

Current Path: /usr/src/sys/net80211

📁 ..
📄 _ieee80211.h(25.44 KB)
📄 ieee80211.c(71.87 KB)
📄 ieee80211.h(48.7 KB)
📄 ieee80211_acl.c(8.64 KB)
📄 ieee80211_action.c(8.16 KB)
📄 ieee80211_action.h(2.27 KB)
📄 ieee80211_adhoc.c(30.5 KB)
📄 ieee80211_adhoc.h(1.65 KB)
📄 ieee80211_ageq.c(6.17 KB)
📄 ieee80211_ageq.h(2.36 KB)
📄 ieee80211_alq.c(4.85 KB)
📄 ieee80211_alq.h(2.26 KB)
📄 ieee80211_amrr.c(14.35 KB)
📄 ieee80211_amrr.h(1.89 KB)
📄 ieee80211_crypto.c(21.96 KB)
📄 ieee80211_crypto.h(10.35 KB)
📄 ieee80211_crypto_ccmp.c(18.27 KB)
📄 ieee80211_crypto_none.c(4.3 KB)
📄 ieee80211_crypto_tkip.c(30.23 KB)
📄 ieee80211_crypto_wep.c(15.13 KB)
📄 ieee80211_ddb.c(29.23 KB)
📄 ieee80211_dfs.c(12.5 KB)
📄 ieee80211_dfs.h(2.5 KB)
📄 ieee80211_freebsd.c(29.56 KB)
📄 ieee80211_freebsd.h(24.14 KB)
📄 ieee80211_hostap.c(70.12 KB)
📄 ieee80211_hostap.h(1.75 KB)
📄 ieee80211_ht.c(104.16 KB)
📄 ieee80211_ht.h(9.15 KB)
📄 ieee80211_hwmp.c(65.62 KB)
📄 ieee80211_input.c(27.5 KB)
📄 ieee80211_input.h(10.19 KB)
📄 ieee80211_ioctl.c(103.57 KB)
📄 ieee80211_ioctl.h(37.22 KB)
📄 ieee80211_mesh.c(104.89 KB)
📄 ieee80211_mesh.h(19.62 KB)
📄 ieee80211_monitor.c(3.87 KB)
📄 ieee80211_monitor.h(1.65 KB)
📄 ieee80211_node.c(86.68 KB)
📄 ieee80211_node.h(21.23 KB)
📄 ieee80211_output.c(119.38 KB)
📄 ieee80211_phy.c(21.24 KB)
📄 ieee80211_phy.h(7.16 KB)
📄 ieee80211_power.c(17.37 KB)
📄 ieee80211_power.h(3.47 KB)
📄 ieee80211_proto.c(81.17 KB)
📄 ieee80211_proto.h(18.49 KB)
📄 ieee80211_radiotap.c(10.36 KB)
📄 ieee80211_radiotap.h(14.32 KB)
📄 ieee80211_ratectl.c(4.06 KB)
📄 ieee80211_ratectl.h(5.49 KB)
📄 ieee80211_ratectl_none.c(3.15 KB)
📄 ieee80211_regdomain.c(14.23 KB)
📄 ieee80211_regdomain.h(10.49 KB)
📄 ieee80211_rssadapt.c(10.82 KB)
📄 ieee80211_rssadapt.h(2.91 KB)
📄 ieee80211_scan.c(18.27 KB)
📄 ieee80211_scan.h(14.65 KB)
📄 ieee80211_scan_sta.c(57.3 KB)
📄 ieee80211_scan_sw.c(30.55 KB)
📄 ieee80211_scan_sw.h(1.51 KB)
📄 ieee80211_sta.c(60.31 KB)
📄 ieee80211_sta.h(2 KB)
📄 ieee80211_superg.c(29.08 KB)
📄 ieee80211_superg.h(5.42 KB)
📄 ieee80211_tdma.c(24.46 KB)
📄 ieee80211_tdma.h(4.05 KB)
📄 ieee80211_var.h(45.45 KB)
📄 ieee80211_vht.c(24.16 KB)
📄 ieee80211_vht.h(2.85 KB)
📄 ieee80211_wds.c(23.31 KB)
📄 ieee80211_wds.h(1.81 KB)
📄 ieee80211_wps.h(6.59 KB)
📄 ieee80211_xauth.c(2.79 KB)

Editing: ieee80211_ageq.c

/*-
 * SPDX-License-Identifier: BSD-2-Clause-FreeBSD
 *
 * Copyright (c) 2009 Sam Leffler, Errno Consulting
 * All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions
 * are met:
 * 1. Redistributions of source code must retain the above copyright
 *    notice, this list of conditions and the following disclaimer.
 * 2. Redistributions in binary form must reproduce the above copyright
 *    notice, this list of conditions and the following disclaimer in the
 *    documentation and/or other materials provided with the distribution.
 *
 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
 * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 */

#include <sys/cdefs.h>
__FBSDID("$FreeBSD$");

/*
 * IEEE 802.11 age queue support.
 */
#include "opt_wlan.h"

#include <sys/param.h>
#include <sys/systm.h> 
#include <sys/kernel.h>
#include <sys/malloc.h>

#include <sys/socket.h>

#include <net/if.h>
#include <net/if_var.h>
#include <net/if_media.h>
#include <net/ethernet.h>

#include <net80211/ieee80211_var.h>

/*
 * Initialize an ageq.
 */
void
ieee80211_ageq_init(struct ieee80211_ageq *aq, int maxlen, const char *name)
{
	memset(aq, 0, sizeof(*aq));
	aq->aq_maxlen = maxlen;
	IEEE80211_AGEQ_INIT(aq, name);		/* OS-dependent setup */
}

/*
 * Cleanup an ageq initialized with ieee80211_ageq_init.  Note
 * the queue is assumed empty; this can be done with ieee80211_ageq_drain.
 */
void
ieee80211_ageq_cleanup(struct ieee80211_ageq *aq)
{
	KASSERT(aq->aq_len == 0, ("%d frames on ageq", aq->aq_len));
	IEEE80211_AGEQ_DESTROY(aq);		/* OS-dependent cleanup */
}

/*
 * Free an mbuf according to ageq rules: if marked as holding
 * and 802.11 frame then also reclaim a node reference from
 * the packet header; this handles packets q'd in the tx path.
 */
static void
ageq_mfree(struct mbuf *m)
{
	if (m->m_flags & M_ENCAP) {
		struct ieee80211_node *ni = (void *) m->m_pkthdr.rcvif;
		ieee80211_free_node(ni);
	}
	m->m_nextpkt = NULL;
	m_freem(m);
}

/*
 * Free a list of mbufs using ageq rules (see above).
 */
void
ieee80211_ageq_mfree(struct mbuf *m)
{
	struct mbuf *next;

for (; m != NULL; m = next) {
		next = m->m_nextpkt;
		ageq_mfree(m);
	}
}

/*
 * Append an mbuf to the ageq and mark it with the specified max age
 * If the frame is not removed before the age (in seconds) expires
 * then it is reclaimed (along with any node reference).
 */
int
ieee80211_ageq_append(struct ieee80211_ageq *aq, struct mbuf *m, int age)
{
	IEEE80211_AGEQ_LOCK(aq);
	if (__predict_true(aq->aq_len < aq->aq_maxlen)) {
		if (aq->aq_tail == NULL) {
			aq->aq_head = m;
		} else {
			aq->aq_tail->m_nextpkt = m;
			age -= M_AGE_GET(aq->aq_head);
		}
		KASSERT(age >= 0, ("age %d", age));
		M_AGE_SET(m, age);
		m->m_nextpkt = NULL;
		aq->aq_tail = m;
		aq->aq_len++;
		IEEE80211_AGEQ_UNLOCK(aq);
		return 0;
	} else {
		/*
		 * No space, drop and cleanup references.
		 */
		aq->aq_drops++;
		IEEE80211_AGEQ_UNLOCK(aq);
		/* XXX tail drop? */
		ageq_mfree(m);
		return ENOSPC;
	}
}

/*
 * Drain/reclaim all frames from an ageq.
 */
void
ieee80211_ageq_drain(struct ieee80211_ageq *aq)
{
	ieee80211_ageq_mfree(ieee80211_ageq_remove(aq, NULL));
}

/*
 * Drain/reclaim frames associated with a specific node from an ageq.
 */
void
ieee80211_ageq_drain_node(struct ieee80211_ageq *aq,
	struct ieee80211_node *ni)
{
	ieee80211_ageq_mfree(ieee80211_ageq_remove(aq, ni));
}

/*
 * Age frames on the age queue.  Ages are stored as time
 * deltas (in seconds) relative to the head so we can check
 * and/or adjust only the head of the list.  If a frame's age
 * exceeds the time quanta then remove it.  The list of removed
 * frames is returned to the caller joined by m_nextpkt.
 */
struct mbuf *
ieee80211_ageq_age(struct ieee80211_ageq *aq, int quanta)
{
	struct mbuf *head, **phead;
	struct mbuf *m;

phead = &head;
	if (aq->aq_len != 0) {
		IEEE80211_AGEQ_LOCK(aq);
		while ((m = aq->aq_head) != NULL && M_AGE_GET(m) < quanta) {
			if ((aq->aq_head = m->m_nextpkt) == NULL)
				aq->aq_tail = NULL;
			KASSERT(aq->aq_len > 0, ("aq len %d", aq->aq_len));
			aq->aq_len--;
			/* add to private list for return */
			*phead = m;
			phead = &m->m_nextpkt;
		}
		if (m != NULL)
			M_AGE_SUB(m, quanta);
		IEEE80211_AGEQ_UNLOCK(aq);
	}
	*phead = NULL;
	return head;
}

/*
 * Remove all frames matching the specified node identifier
 * (NULL matches all).  Frames are returned as a list joined
 * by m_nextpkt.
 */
struct mbuf *
ieee80211_ageq_remove(struct ieee80211_ageq *aq,
	struct ieee80211_node *match)
{
	struct mbuf *m, **prev, *ohead;
	struct mbuf *head, **phead;

IEEE80211_AGEQ_LOCK(aq);
	ohead = aq->aq_head;
	prev = &aq->aq_head;
	phead = &head;
	while ((m = *prev) != NULL) {
		if (match != NULL && m->m_pkthdr.rcvif != (void *) match) {
			prev = &m->m_nextpkt;
			continue;
		}
		/*
		 * Adjust q length.
		 */
		KASSERT(aq->aq_len > 0, ("aq len %d", aq->aq_len));
		aq->aq_len--;
		/*
		 * Remove from forward list; tail pointer is harder.
		 */
		if (aq->aq_tail == m) {
			KASSERT(m->m_nextpkt == NULL, ("not last"));
			if (aq->aq_head == m) {		/* list empty */
				KASSERT(aq->aq_len == 0,
				    ("not empty, len %d", aq->aq_len));
				aq->aq_tail = NULL;
			} else {			/* must be one before */
				aq->aq_tail = (struct mbuf *)((uintptr_t)prev -
				    offsetof(struct mbuf, m_nextpkt));
			}
		}
		*prev = m->m_nextpkt;

/* add to private list for return */
		*phead = m;
		phead = &m->m_nextpkt;
	}
	if (head == ohead && aq->aq_head != NULL)	/* correct age */
		M_AGE_SET(aq->aq_head, M_AGE_GET(head));
	IEEE80211_AGEQ_UNLOCK(aq);

*phead = NULL;
	return head;
}

003 File Manager

Editing: ieee80211_ageq.c

Upload File

Create Folder