[linux-block.git] / net / mac80211 / sta_info.c

/*
 * Copyright 2002-2005, Instant802 Networks, Inc.
 * Copyright 2006-2007	Jiri Benc <jbenc@suse.cz>
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License version 2 as
 * published by the Free Software Foundation.
 */

#include <linux/module.h>
#include <linux/init.h>
#include <linux/netdevice.h>
#include <linux/types.h>
#include <linux/slab.h>
#include <linux/skbuff.h>
#include <linux/if_arp.h>

#include <net/mac80211.h>
#include "ieee80211_i.h"
#include "ieee80211_rate.h"
#include "sta_info.h"
#include "debugfs_sta.h"

/* Caller must hold local->sta_lock */
static void sta_info_hash_add(struct ieee80211_local *local,
			      struct sta_info *sta)
{
	sta->hnext = local->sta_hash[STA_HASH(sta->addr)];
	local->sta_hash[STA_HASH(sta->addr)] = sta;
}


/* Caller must hold local->sta_lock */
static int sta_info_hash_del(struct ieee80211_local *local,
			     struct sta_info *sta)
{
	struct sta_info *s;

	s = local->sta_hash[STA_HASH(sta->addr)];
	if (!s)
		return -ENOENT;
	if (s == sta) {
		local->sta_hash[STA_HASH(sta->addr)] = s->hnext;
		return 0;
	}

	while (s->hnext && s->hnext != sta)
		s = s->hnext;
	if (s->hnext) {
		s->hnext = sta->hnext;
		return 0;
	}

	return -ENOENT;
}

struct sta_info *sta_info_get(struct ieee80211_local *local, u8 *addr)
{
	struct sta_info *sta;

	read_lock_bh(&local->sta_lock);
	sta = local->sta_hash[STA_HASH(addr)];
	while (sta) {
		if (memcmp(sta->addr, addr, ETH_ALEN) == 0) {
			__sta_info_get(sta);
			break;
		}
		sta = sta->hnext;
	}
	read_unlock_bh(&local->sta_lock);

	return sta;
}
EXPORT_SYMBOL(sta_info_get);

int sta_info_min_txrate_get(struct ieee80211_local *local)
{
	struct sta_info *sta;
	struct ieee80211_hw_mode *mode;
	int min_txrate = 9999999;
	int i;

	read_lock_bh(&local->sta_lock);
	mode = local->oper_hw_mode;
	for (i = 0; i < STA_HASH_SIZE; i++) {
		sta = local->sta_hash[i];
		while (sta) {
			if (sta->txrate < min_txrate)
				min_txrate = sta->txrate;
			sta = sta->hnext;
		}
	}
	read_unlock_bh(&local->sta_lock);
	if (min_txrate == 9999999)
		min_txrate = 0;

	return mode->rates[min_txrate].rate;
}


static void sta_info_release(struct kref *kref)
{
	struct sta_info *sta = container_of(kref, struct sta_info, kref);
	struct ieee80211_local *local = sta->local;
	struct sk_buff *skb;

	/* free sta structure; it has already been removed from
	 * hash table etc. external structures. Make sure that all
	 * buffered frames are release (one might have been added
	 * after sta_info_free() was called). */
	while ((skb = skb_dequeue(&sta->ps_tx_buf)) != NULL) {
		local->total_ps_buffered--;
		dev_kfree_skb_any(skb);
	}
	while ((skb = skb_dequeue(&sta->tx_filtered)) != NULL) {
		dev_kfree_skb_any(skb);
	}
	rate_control_free_sta(sta->rate_ctrl, sta->rate_ctrl_priv);
	rate_control_put(sta->rate_ctrl);
	kfree(sta);
}


void sta_info_put(struct sta_info *sta)
{
	kref_put(&sta->kref, sta_info_release);
}
EXPORT_SYMBOL(sta_info_put);


struct sta_info * sta_info_add(struct ieee80211_local *local,
			       struct net_device *dev, u8 *addr, gfp_t gfp)
{
	struct sta_info *sta;
	DECLARE_MAC_BUF(mac);

	sta = kzalloc(sizeof(*sta), gfp);
	if (!sta)
		return NULL;

	kref_init(&sta->kref);

	sta->rate_ctrl = rate_control_get(local->rate_ctrl);
	sta->rate_ctrl_priv = rate_control_alloc_sta(sta->rate_ctrl, gfp);
	if (!sta->rate_ctrl_priv) {
		rate_control_put(sta->rate_ctrl);
		kfree(sta);
		return NULL;
	}

	memcpy(sta->addr, addr, ETH_ALEN);
	sta->local = local;
	sta->dev = dev;
	skb_queue_head_init(&sta->ps_tx_buf);
	skb_queue_head_init(&sta->tx_filtered);
	__sta_info_get(sta);	/* sta used by caller, decremented by
				 * sta_info_put() */
	write_lock_bh(&local->sta_lock);
	list_add(&sta->list, &local->sta_list);
	local->num_sta++;
	sta_info_hash_add(local, sta);
	if (local->ops->sta_table_notification)
		local->ops->sta_table_notification(local_to_hw(local),
						  local->num_sta);
	write_unlock_bh(&local->sta_lock);

#ifdef CONFIG_MAC80211_VERBOSE_DEBUG
	printk(KERN_DEBUG "%s: Added STA %s\n",
	       wiphy_name(local->hw.wiphy), print_mac(mac, addr));
#endif /* CONFIG_MAC80211_VERBOSE_DEBUG */

#ifdef CONFIG_MAC80211_DEBUGFS
	/* debugfs entry adding might sleep, so schedule process
	 * context task for adding entry for STAs that do not yet
	 * have one. */
	queue_work(local->hw.workqueue, &local->sta_debugfs_add);
#endif

	return sta;
}

/* Caller must hold local->sta_lock */
void sta_info_remove(struct sta_info *sta)
{
	struct ieee80211_local *local = sta->local;
	struct ieee80211_sub_if_data *sdata;

	/* don't do anything if we've been removed already */
	if (sta_info_hash_del(local, sta))
		return;

	list_del(&sta->list);
	sdata = IEEE80211_DEV_TO_SUB_IF(sta->dev);
	if (sta->flags & WLAN_STA_PS) {
		sta->flags &= ~WLAN_STA_PS;
		if (sdata->bss)
			atomic_dec(&sdata->bss->num_sta_ps);
	}
	local->num_sta--;
	sta_info_remove_aid_ptr(sta);

	if (local->ops->sta_table_notification)
		local->ops->sta_table_notification(local_to_hw(local),
						   local->num_sta);
}

void sta_info_free(struct sta_info *sta)
{
	struct sk_buff *skb;
	struct ieee80211_local *local = sta->local;
	DECLARE_MAC_BUF(mac);

	might_sleep();

	write_lock_bh(&local->sta_lock);
	sta_info_remove(sta);
	write_unlock_bh(&local->sta_lock);

	while ((skb = skb_dequeue(&sta->ps_tx_buf)) != NULL) {
		local->total_ps_buffered--;
		dev_kfree_skb(skb);
	}
	while ((skb = skb_dequeue(&sta->tx_filtered)) != NULL) {
		dev_kfree_skb(skb);
	}

#ifdef CONFIG_MAC80211_VERBOSE_DEBUG
	printk(KERN_DEBUG "%s: Removed STA %s\n",
	       wiphy_name(local->hw.wiphy), print_mac(mac, sta->addr));
#endif /* CONFIG_MAC80211_VERBOSE_DEBUG */

	ieee80211_key_free(sta->key);
	sta->key = NULL;

	rate_control_remove_sta_debugfs(sta);
	ieee80211_sta_debugfs_remove(sta);

	sta_info_put(sta);
}


static inline int sta_info_buffer_expired(struct ieee80211_local *local,
					  struct sta_info *sta,
					  struct sk_buff *skb)
{
	struct ieee80211_tx_packet_data *pkt_data;
	int timeout;

	if (!skb)
		return 0;

	pkt_data = (struct ieee80211_tx_packet_data *) skb->cb;

	/* Timeout: (2 * listen_interval * beacon_int * 1024 / 1000000) sec */
	timeout = (sta->listen_interval * local->hw.conf.beacon_int * 32 /
		   15625) * HZ;
	if (timeout < STA_TX_BUFFER_EXPIRE)
		timeout = STA_TX_BUFFER_EXPIRE;
	return time_after(jiffies, pkt_data->jiffies + timeout);
}


static void sta_info_cleanup_expire_buffered(struct ieee80211_local *local,
					     struct sta_info *sta)
{
	unsigned long flags;
	struct sk_buff *skb;
	DECLARE_MAC_BUF(mac);

	if (skb_queue_empty(&sta->ps_tx_buf))
		return;

	for (;;) {
		spin_lock_irqsave(&sta->ps_tx_buf.lock, flags);
		skb = skb_peek(&sta->ps_tx_buf);
		if (sta_info_buffer_expired(local, sta, skb)) {
			skb = __skb_dequeue(&sta->ps_tx_buf);
			if (skb_queue_empty(&sta->ps_tx_buf))
				sta->flags &= ~WLAN_STA_TIM;
		} else
			skb = NULL;
		spin_unlock_irqrestore(&sta->ps_tx_buf.lock, flags);

		if (skb) {
			local->total_ps_buffered--;
			printk(KERN_DEBUG "Buffered frame expired (STA "
			       "%s)\n", print_mac(mac, sta->addr));
			dev_kfree_skb(skb);
		} else
			break;
	}
}


static void sta_info_cleanup(unsigned long data)
{
	struct ieee80211_local *local = (struct ieee80211_local *) data;
	struct sta_info *sta;

	read_lock_bh(&local->sta_lock);
	list_for_each_entry(sta, &local->sta_list, list) {
		__sta_info_get(sta);
		sta_info_cleanup_expire_buffered(local, sta);
		sta_info_put(sta);
	}
	read_unlock_bh(&local->sta_lock);

	local->sta_cleanup.expires = jiffies + STA_INFO_CLEANUP_INTERVAL;
	add_timer(&local->sta_cleanup);
}

#ifdef CONFIG_MAC80211_DEBUGFS
static void sta_info_debugfs_add_task(struct work_struct *work)
{
	struct ieee80211_local *local =
		container_of(work, struct ieee80211_local, sta_debugfs_add);
	struct sta_info *sta, *tmp;

	while (1) {
		sta = NULL;
		read_lock_bh(&local->sta_lock);
		list_for_each_entry(tmp, &local->sta_list, list) {
			if (!tmp->debugfs.dir) {
				sta = tmp;
				__sta_info_get(sta);
				break;
			}
		}
		read_unlock_bh(&local->sta_lock);

		if (!sta)
			break;

		ieee80211_sta_debugfs_add(sta);
		rate_control_add_sta_debugfs(sta);
		sta_info_put(sta);
	}
}
#endif

void sta_info_init(struct ieee80211_local *local)
{
	rwlock_init(&local->sta_lock);
	INIT_LIST_HEAD(&local->sta_list);

	init_timer(&local->sta_cleanup);
	local->sta_cleanup.expires = jiffies + STA_INFO_CLEANUP_INTERVAL;
	local->sta_cleanup.data = (unsigned long) local;
	local->sta_cleanup.function = sta_info_cleanup;

#ifdef CONFIG_MAC80211_DEBUGFS
	INIT_WORK(&local->sta_debugfs_add, sta_info_debugfs_add_task);
#endif
}

int sta_info_start(struct ieee80211_local *local)
{
	add_timer(&local->sta_cleanup);
	return 0;
}

void sta_info_stop(struct ieee80211_local *local)
{
	del_timer(&local->sta_cleanup);
	sta_info_flush(local, NULL);
}

void sta_info_remove_aid_ptr(struct sta_info *sta)
{
	struct ieee80211_sub_if_data *sdata;

	if (sta->aid <= 0)
		return;

	sdata = IEEE80211_DEV_TO_SUB_IF(sta->dev);

	if (sdata->local->ops->set_tim)
		sdata->local->ops->set_tim(local_to_hw(sdata->local),
					  sta->aid, 0);
	if (sdata->bss)
		__bss_tim_clear(sdata->bss, sta->aid);
}


/**
 * sta_info_flush - flush matching STA entries from the STA table
 * @local: local interface data
 * @dev: matching rule for the net device (sta->dev) or %NULL to match all STAs
 */
void sta_info_flush(struct ieee80211_local *local, struct net_device *dev)
{
	struct sta_info *sta, *tmp;
	LIST_HEAD(tmp_list);

	write_lock_bh(&local->sta_lock);
	list_for_each_entry_safe(sta, tmp, &local->sta_list, list)
		if (!dev || dev == sta->dev) {
			__sta_info_get(sta);
			sta_info_remove(sta);
			list_add_tail(&sta->list, &tmp_list);
		}
	write_unlock_bh(&local->sta_lock);

	list_for_each_entry_safe(sta, tmp, &tmp_list, list) {
		sta_info_free(sta);
		sta_info_put(sta);
	}
}
Commit	Line	Data
f0706e82 JB	1	/*
	2	* Copyright 2002-2005, Instant802 Networks, Inc.
	3	* Copyright 2006-2007 Jiri Benc <jbenc@suse.cz>
	4	*
	5	* This program is free software; you can redistribute it and/or modify
	6	* it under the terms of the GNU General Public License version 2 as
	7	* published by the Free Software Foundation.
	8	*/
	9
	10	#include <linux/module.h>
	11	#include <linux/init.h>
	12	#include <linux/netdevice.h>
	13	#include <linux/types.h>
	14	#include <linux/slab.h>
	15	#include <linux/skbuff.h>
	16	#include <linux/if_arp.h>
	17
	18	#include <net/mac80211.h>
	19	#include "ieee80211_i.h"
	20	#include "ieee80211_rate.h"
	21	#include "sta_info.h"
e9f207f0	22	#include "debugfs_sta.h"
f0706e82 JB	23
	24	/* Caller must hold local->sta_lock */
	25	static void sta_info_hash_add(struct ieee80211_local *local,
	26	struct sta_info *sta)
	27	{
	28	sta->hnext = local->sta_hash[STA_HASH(sta->addr)];
	29	local->sta_hash[STA_HASH(sta->addr)] = sta;
	30	}
	31
	32
	33	/* Caller must hold local->sta_lock */
be8755e1 MW	34	static int sta_info_hash_del(struct ieee80211_local *local,
be8755e1 MW	35	struct sta_info *sta)
f0706e82 JB	36	{
	37	struct sta_info *s;
	38
	39	s = local->sta_hash[STA_HASH(sta->addr)];
	40	if (!s)
be8755e1 MW	41	return -ENOENT;
be8755e1 MW	42	if (s == sta) {
f0706e82	43	local->sta_hash[STA_HASH(sta->addr)] = s->hnext;
be8755e1	44	return 0;
f0706e82 JB	45	}
f0706e82 JB	46
be8755e1	47	while (s->hnext && s->hnext != sta)
f0706e82	48	s = s->hnext;
be8755e1 MW	49	if (s->hnext) {
	50	s->hnext = sta->hnext;
	51	return 0;
	52	}
f0706e82	53
be8755e1	54	return -ENOENT;
f0706e82 JB	55	}
	56
	57	struct sta_info sta_info_get(struct ieee80211_local local, u8 *addr)
	58	{
	59	struct sta_info *sta;
	60
be8755e1	61	read_lock_bh(&local->sta_lock);
f0706e82 JB	62	sta = local->sta_hash[STA_HASH(addr)];
	63	while (sta) {
	64	if (memcmp(sta->addr, addr, ETH_ALEN) == 0) {
	65	__sta_info_get(sta);
	66	break;
	67	}
	68	sta = sta->hnext;
	69	}
be8755e1	70	read_unlock_bh(&local->sta_lock);
f0706e82 JB	71
	72	return sta;
	73	}
	74	EXPORT_SYMBOL(sta_info_get);
	75
	76	int sta_info_min_txrate_get(struct ieee80211_local *local)
	77	{
	78	struct sta_info *sta;
	79	struct ieee80211_hw_mode *mode;
	80	int min_txrate = 9999999;
	81	int i;
	82
be8755e1	83	read_lock_bh(&local->sta_lock);
f0706e82 JB	84	mode = local->oper_hw_mode;
	85	for (i = 0; i < STA_HASH_SIZE; i++) {
	86	sta = local->sta_hash[i];
	87	while (sta) {
	88	if (sta->txrate < min_txrate)
	89	min_txrate = sta->txrate;
	90	sta = sta->hnext;
	91	}
	92	}
be8755e1	93	read_unlock_bh(&local->sta_lock);
f0706e82 JB	94	if (min_txrate == 9999999)
	95	min_txrate = 0;
	96
	97	return mode->rates[min_txrate].rate;
	98	}
	99
	100
	101	static void sta_info_release(struct kref *kref)
	102	{
	103	struct sta_info *sta = container_of(kref, struct sta_info, kref);
	104	struct ieee80211_local *local = sta->local;
	105	struct sk_buff *skb;
	106
	107	/* free sta structure; it has already been removed from
	108	* hash table etc. external structures. Make sure that all
	109	* buffered frames are release (one might have been added
	110	* after sta_info_free() was called). */
	111	while ((skb = skb_dequeue(&sta->ps_tx_buf)) != NULL) {
	112	local->total_ps_buffered--;
	113	dev_kfree_skb_any(skb);
	114	}
	115	while ((skb = skb_dequeue(&sta->tx_filtered)) != NULL) {
	116	dev_kfree_skb_any(skb);
	117	}
	118	rate_control_free_sta(sta->rate_ctrl, sta->rate_ctrl_priv);
	119	rate_control_put(sta->rate_ctrl);
	120	kfree(sta);
	121	}
	122
	123
	124	void sta_info_put(struct sta_info *sta)
	125	{
	126	kref_put(&sta->kref, sta_info_release);
	127	}
	128	EXPORT_SYMBOL(sta_info_put);
	129
	130
	131	struct sta_info * sta_info_add(struct ieee80211_local *local,
	132	struct net_device dev, u8 addr, gfp_t gfp)
	133	{
	134	struct sta_info *sta;
0795af57	135	DECLARE_MAC_BUF(mac);
f0706e82 JB	136
	137	sta = kzalloc(sizeof(*sta), gfp);
	138	if (!sta)
	139	return NULL;
	140
	141	kref_init(&sta->kref);
	142
	143	sta->rate_ctrl = rate_control_get(local->rate_ctrl);
	144	sta->rate_ctrl_priv = rate_control_alloc_sta(sta->rate_ctrl, gfp);
	145	if (!sta->rate_ctrl_priv) {
	146	rate_control_put(sta->rate_ctrl);
f0706e82 JB	147	kfree(sta);
	148	return NULL;
	149	}
	150
	151	memcpy(sta->addr, addr, ETH_ALEN);
	152	sta->local = local;
	153	sta->dev = dev;
	154	skb_queue_head_init(&sta->ps_tx_buf);
	155	skb_queue_head_init(&sta->tx_filtered);
	156	__sta_info_get(sta); /* sta used by caller, decremented by
	157	* sta_info_put() */
be8755e1	158	write_lock_bh(&local->sta_lock);
f0706e82 JB	159	list_add(&sta->list, &local->sta_list);
	160	local->num_sta++;
	161	sta_info_hash_add(local, sta);
f0706e82 JB	162	if (local->ops->sta_table_notification)
	163	local->ops->sta_table_notification(local_to_hw(local),
	164	local->num_sta);
be8755e1	165	write_unlock_bh(&local->sta_lock);
f0706e82 JB	166
f0706e82 JB	167	#ifdef CONFIG_MAC80211_VERBOSE_DEBUG
0795af57	168	printk(KERN_DEBUG "%s: Added STA %s\n",
dd1cd4c6	169	wiphy_name(local->hw.wiphy), print_mac(mac, addr));
f0706e82 JB	170	#endif /* CONFIG_MAC80211_VERBOSE_DEBUG */
f0706e82 JB	171
e9f207f0	172	#ifdef CONFIG_MAC80211_DEBUGFS
be8755e1 MW	173	/* debugfs entry adding might sleep, so schedule process
	174	* context task for adding entry for STAs that do not yet
	175	* have one. */
	176	queue_work(local->hw.workqueue, &local->sta_debugfs_add);
e9f207f0 JB	177	#endif
e9f207f0 JB	178
f0706e82 JB	179	return sta;
	180	}
	181
be8755e1 MW	182	/* Caller must hold local->sta_lock */
be8755e1 MW	183	void sta_info_remove(struct sta_info *sta)
f0706e82 JB	184	{
	185	struct ieee80211_local *local = sta->local;
	186	struct ieee80211_sub_if_data *sdata;
	187
be8755e1 MW	188	/* don't do anything if we've been removed already */
	189	if (sta_info_hash_del(local, sta))
	190	return;
	191
f0706e82 JB	192	list_del(&sta->list);
	193	sdata = IEEE80211_DEV_TO_SUB_IF(sta->dev);
	194	if (sta->flags & WLAN_STA_PS) {
	195	sta->flags &= ~WLAN_STA_PS;
	196	if (sdata->bss)
	197	atomic_dec(&sdata->bss->num_sta_ps);
	198	}
	199	local->num_sta--;
	200	sta_info_remove_aid_ptr(sta);
be8755e1 MW	201
	202	if (local->ops->sta_table_notification)
	203	local->ops->sta_table_notification(local_to_hw(local),
	204	local->num_sta);
f0706e82 JB	205	}
f0706e82 JB	206
be8755e1	207	void sta_info_free(struct sta_info *sta)
f0706e82 JB	208	{
	209	struct sk_buff *skb;
	210	struct ieee80211_local *local = sta->local;
0795af57	211	DECLARE_MAC_BUF(mac);
f0706e82	212
be8755e1 MW	213	might_sleep();
	214
	215	write_lock_bh(&local->sta_lock);
	216	sta_info_remove(sta);
	217	write_unlock_bh(&local->sta_lock);
f0706e82 JB	218
	219	while ((skb = skb_dequeue(&sta->ps_tx_buf)) != NULL) {
	220	local->total_ps_buffered--;
be8755e1	221	dev_kfree_skb(skb);
f0706e82 JB	222	}
f0706e82 JB	223	while ((skb = skb_dequeue(&sta->tx_filtered)) != NULL) {
be8755e1	224	dev_kfree_skb(skb);
f0706e82 JB	225	}
f0706e82 JB	226
be8755e1	227	#ifdef CONFIG_MAC80211_VERBOSE_DEBUG
0795af57	228	printk(KERN_DEBUG "%s: Removed STA %s\n",
dd1cd4c6	229	wiphy_name(local->hw.wiphy), print_mac(mac, sta->addr));
be8755e1 MW	230	#endif /* CONFIG_MAC80211_VERBOSE_DEBUG */
be8755e1 MW	231
11a843b7 JB	232	ieee80211_key_free(sta->key);
11a843b7 JB	233	sta->key = NULL;
be8755e1 MW	234
	235	rate_control_remove_sta_debugfs(sta);
	236	ieee80211_sta_debugfs_remove(sta);
	237
	238	sta_info_put(sta);
f0706e82 JB	239	}
	240
	241
	242	static inline int sta_info_buffer_expired(struct ieee80211_local *local,
	243	struct sta_info *sta,
	244	struct sk_buff *skb)
	245	{
	246	struct ieee80211_tx_packet_data *pkt_data;
	247	int timeout;
	248
	249	if (!skb)
	250	return 0;
	251
	252	pkt_data = (struct ieee80211_tx_packet_data *) skb->cb;
	253
	254	/* Timeout: (2 * listen_interval * beacon_int * 1024 / 1000000) sec */
	255	timeout = (sta->listen_interval * local->hw.conf.beacon_int * 32 /
	256	15625) * HZ;
	257	if (timeout < STA_TX_BUFFER_EXPIRE)
	258	timeout = STA_TX_BUFFER_EXPIRE;
	259	return time_after(jiffies, pkt_data->jiffies + timeout);
	260	}
	261
	262
	263	static void sta_info_cleanup_expire_buffered(struct ieee80211_local *local,
	264	struct sta_info *sta)
	265	{
	266	unsigned long flags;
	267	struct sk_buff *skb;
0795af57	268	DECLARE_MAC_BUF(mac);
f0706e82 JB	269
	270	if (skb_queue_empty(&sta->ps_tx_buf))
	271	return;
	272
	273	for (;;) {
	274	spin_lock_irqsave(&sta->ps_tx_buf.lock, flags);
	275	skb = skb_peek(&sta->ps_tx_buf);
	276	if (sta_info_buffer_expired(local, sta, skb)) {
	277	skb = __skb_dequeue(&sta->ps_tx_buf);
	278	if (skb_queue_empty(&sta->ps_tx_buf))
	279	sta->flags &= ~WLAN_STA_TIM;
	280	} else
	281	skb = NULL;
	282	spin_unlock_irqrestore(&sta->ps_tx_buf.lock, flags);
	283
	284	if (skb) {
	285	local->total_ps_buffered--;
	286	printk(KERN_DEBUG "Buffered frame expired (STA "
0795af57	287	"%s)\n", print_mac(mac, sta->addr));
f0706e82 JB	288	dev_kfree_skb(skb);
	289	} else
	290	break;
	291	}
	292	}
	293
	294
	295	static void sta_info_cleanup(unsigned long data)
	296	{
	297	struct ieee80211_local local = (struct ieee80211_local ) data;
	298	struct sta_info *sta;
	299
be8755e1	300	read_lock_bh(&local->sta_lock);
f0706e82 JB	301	list_for_each_entry(sta, &local->sta_list, list) {
	302	__sta_info_get(sta);
	303	sta_info_cleanup_expire_buffered(local, sta);
	304	sta_info_put(sta);
	305	}
be8755e1	306	read_unlock_bh(&local->sta_lock);
f0706e82 JB	307
	308	local->sta_cleanup.expires = jiffies + STA_INFO_CLEANUP_INTERVAL;
	309	add_timer(&local->sta_cleanup);
	310	}
	311
e9f207f0 JB	312	#ifdef CONFIG_MAC80211_DEBUGFS
	313	static void sta_info_debugfs_add_task(struct work_struct *work)
	314	{
	315	struct ieee80211_local *local =
	316	container_of(work, struct ieee80211_local, sta_debugfs_add);
	317	struct sta_info sta, tmp;
	318
e9f207f0 JB	319	while (1) {
e9f207f0 JB	320	sta = NULL;
be8755e1	321	read_lock_bh(&local->sta_lock);
e9f207f0	322	list_for_each_entry(tmp, &local->sta_list, list) {
be8755e1	323	if (!tmp->debugfs.dir) {
e9f207f0 JB	324	sta = tmp;
	325	__sta_info_get(sta);
	326	break;
	327	}
	328	}
be8755e1	329	read_unlock_bh(&local->sta_lock);
e9f207f0 JB	330
	331	if (!sta)
	332	break;
	333
e9f207f0 JB	334	ieee80211_sta_debugfs_add(sta);
	335	rate_control_add_sta_debugfs(sta);
	336	sta_info_put(sta);
	337	}
	338	}
	339	#endif
	340
f0706e82 JB	341	void sta_info_init(struct ieee80211_local *local)
f0706e82 JB	342	{
be8755e1	343	rwlock_init(&local->sta_lock);
f0706e82	344	INIT_LIST_HEAD(&local->sta_list);
f0706e82 JB	345
	346	init_timer(&local->sta_cleanup);
	347	local->sta_cleanup.expires = jiffies + STA_INFO_CLEANUP_INTERVAL;
	348	local->sta_cleanup.data = (unsigned long) local;
	349	local->sta_cleanup.function = sta_info_cleanup;
e9f207f0 JB	350
	351	#ifdef CONFIG_MAC80211_DEBUGFS
	352	INIT_WORK(&local->sta_debugfs_add, sta_info_debugfs_add_task);
	353	#endif
f0706e82 JB	354	}
	355
	356	int sta_info_start(struct ieee80211_local *local)
	357	{
	358	add_timer(&local->sta_cleanup);
	359	return 0;
	360	}
	361
	362	void sta_info_stop(struct ieee80211_local *local)
	363	{
f0706e82	364	del_timer(&local->sta_cleanup);
be8755e1	365	sta_info_flush(local, NULL);
f0706e82 JB	366	}
	367
	368	void sta_info_remove_aid_ptr(struct sta_info *sta)
	369	{
	370	struct ieee80211_sub_if_data *sdata;
	371
	372	if (sta->aid <= 0)
	373	return;
	374
	375	sdata = IEEE80211_DEV_TO_SUB_IF(sta->dev);
	376
	377	if (sdata->local->ops->set_tim)
	378	sdata->local->ops->set_tim(local_to_hw(sdata->local),
	379	sta->aid, 0);
	380	if (sdata->bss)
	381	__bss_tim_clear(sdata->bss, sta->aid);
	382	}
	383
	384
	385	/**
	386	* sta_info_flush - flush matching STA entries from the STA table
	387	* @local: local interface data
	388	* @dev: matching rule for the net device (sta->dev) or %NULL to match all STAs
	389	*/
	390	void sta_info_flush(struct ieee80211_local local, struct net_device dev)
	391	{
	392	struct sta_info sta, tmp;
be8755e1	393	LIST_HEAD(tmp_list);
f0706e82	394
be8755e1	395	write_lock_bh(&local->sta_lock);
f0706e82	396	list_for_each_entry_safe(sta, tmp, &local->sta_list, list)
be8755e1 MW	397	if (!dev \|\| dev == sta->dev) {
	398	__sta_info_get(sta);
	399	sta_info_remove(sta);
	400	list_add_tail(&sta->list, &tmp_list);
	401	}
	402	write_unlock_bh(&local->sta_lock);
	403
	404	list_for_each_entry_safe(sta, tmp, &tmp_list, list) {
	405	sta_info_free(sta);
	406	sta_info_put(sta);
	407	}
f0706e82	408	}