util.c 88.1 KB
Newer Older
J
Johannes Berg 已提交
1 2 3 4 5
/*
 * Copyright 2002-2005, Instant802 Networks, Inc.
 * Copyright 2005-2006, Devicescape Software, Inc.
 * Copyright 2006-2007	Jiri Benc <jbenc@suse.cz>
 * Copyright 2007	Johannes Berg <johannes@sipsolutions.net>
6
 * Copyright 2013-2014  Intel Mobile Communications GmbH
7
 * Copyright (C) 2015-2016	Intel Deutschland GmbH
J
Johannes Berg 已提交
8 9 10 11 12 13 14 15 16 17
 *
 * 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.
 *
 * utilities for mac80211
 */

#include <net/mac80211.h>
#include <linux/netdevice.h>
18
#include <linux/export.h>
J
Johannes Berg 已提交
19 20 21 22 23 24
#include <linux/types.h>
#include <linux/slab.h>
#include <linux/skbuff.h>
#include <linux/etherdevice.h>
#include <linux/if_arp.h>
#include <linux/bitmap.h>
25
#include <linux/crc32.h>
26
#include <net/net_namespace.h>
J
Johannes Berg 已提交
27
#include <net/cfg80211.h>
28
#include <net/rtnetlink.h>
J
Johannes Berg 已提交
29 30

#include "ieee80211_i.h"
31
#include "driver-ops.h"
J
Johannes Berg 已提交
32
#include "rate.h"
33
#include "mesh.h"
J
Johannes Berg 已提交
34
#include "wme.h"
35
#include "led.h"
J
Johannes Berg 已提交
36
#include "wep.h"
J
Johannes Berg 已提交
37 38

/* privid for wiphys to determine whether they belong to us or not */
39
const void *const mac80211_wiphy_privid = &mac80211_wiphy_privid;
J
Johannes Berg 已提交
40

41 42 43 44 45 46 47 48 49
struct ieee80211_hw *wiphy_to_ieee80211_hw(struct wiphy *wiphy)
{
	struct ieee80211_local *local;
	BUG_ON(!wiphy);

	local = wiphy_priv(wiphy);
	return &local->hw;
}
EXPORT_SYMBOL(wiphy_to_ieee80211_hw);
J
Johannes Berg 已提交
50

51
void ieee80211_tx_set_protected(struct ieee80211_tx_data *tx)
J
Johannes Berg 已提交
52
{
53
	struct sk_buff *skb;
J
Johannes Berg 已提交
54 55
	struct ieee80211_hdr *hdr;

56
	skb_queue_walk(&tx->skbs, skb) {
J
Johannes Berg 已提交
57 58
		hdr = (struct ieee80211_hdr *) skb->data;
		hdr->frame_control |= cpu_to_le16(IEEE80211_FCTL_PROTECTED);
59
	}
J
Johannes Berg 已提交
60 61
}

62
int ieee80211_frame_duration(enum ieee80211_band band, size_t len,
63 64
			     int rate, int erp, int short_preamble,
			     int shift)
J
Johannes Berg 已提交
65 66 67 68 69 70 71 72 73 74
{
	int dur;

	/* calculate duration (in microseconds, rounded up to next higher
	 * integer if it includes a fractional microsecond) to send frame of
	 * len bytes (does not include FCS) at the given rate. Duration will
	 * also include SIFS.
	 *
	 * rate is in 100 kbps, so divident is multiplied by 10 in the
	 * DIV_ROUND_UP() operations.
75 76 77
	 *
	 * shift may be 2 for 5 MHz channels or 1 for 10 MHz channels, and
	 * is assumed to be 0 otherwise.
J
Johannes Berg 已提交
78 79
	 */

80
	if (band == IEEE80211_BAND_5GHZ || erp) {
J
Johannes Berg 已提交
81 82 83 84 85 86 87 88 89
		/*
		 * OFDM:
		 *
		 * N_DBPS = DATARATE x 4
		 * N_SYM = Ceiling((16+8xLENGTH+6) / N_DBPS)
		 *	(16 = SIGNAL time, 6 = tail bits)
		 * TXTIME = T_PREAMBLE + T_SIGNAL + T_SYM x N_SYM + Signal Ext
		 *
		 * T_SYM = 4 usec
90
		 * 802.11a - 18.5.2: aSIFSTime = 16 usec
J
Johannes Berg 已提交
91 92 93 94
		 * 802.11g - 19.8.4: aSIFSTime = 10 usec +
		 *	signal ext = 6 usec
		 */
		dur = 16; /* SIFS + signal ext */
95 96 97 98 99 100 101 102
		dur += 16; /* IEEE 802.11-2012 18.3.2.4: T_PREAMBLE = 16 usec */
		dur += 4; /* IEEE 802.11-2012 18.3.2.4: T_SIGNAL = 4 usec */

		/* IEEE 802.11-2012 18.3.2.4: all values above are:
		 *  * times 4 for 5 MHz
		 *  * times 2 for 10 MHz
		 */
		dur *= 1 << shift;
103 104 105 106 107 108

		/* rates should already consider the channel bandwidth,
		 * don't apply divisor again.
		 */
		dur += 4 * DIV_ROUND_UP((16 + 8 * (len + 4) + 6) * 10,
					4 * rate); /* T_SYM x N_SYM */
J
Johannes Berg 已提交
109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129
	} else {
		/*
		 * 802.11b or 802.11g with 802.11b compatibility:
		 * 18.3.4: TXTIME = PreambleLength + PLCPHeaderTime +
		 * Ceiling(((LENGTH+PBCC)x8)/DATARATE). PBCC=0.
		 *
		 * 802.11 (DS): 15.3.3, 802.11b: 18.3.4
		 * aSIFSTime = 10 usec
		 * aPreambleLength = 144 usec or 72 usec with short preamble
		 * aPLCPHeaderLength = 48 usec or 24 usec with short preamble
		 */
		dur = 10; /* aSIFSTime = 10 usec */
		dur += short_preamble ? (72 + 24) : (144 + 48);

		dur += DIV_ROUND_UP(8 * (len + 4) * 10, rate);
	}

	return dur;
}

/* Exported duration function for driver use */
130 131
__le16 ieee80211_generic_frame_duration(struct ieee80211_hw *hw,
					struct ieee80211_vif *vif,
132
					enum ieee80211_band band,
133 134
					size_t frame_len,
					struct ieee80211_rate *rate)
J
Johannes Berg 已提交
135
{
136
	struct ieee80211_sub_if_data *sdata;
J
Johannes Berg 已提交
137
	u16 dur;
138
	int erp, shift = 0;
139
	bool short_preamble = false;
J
Johannes Berg 已提交
140

141
	erp = 0;
142 143
	if (vif) {
		sdata = vif_to_sdata(vif);
J
Johannes Berg 已提交
144
		short_preamble = sdata->vif.bss_conf.use_short_preamble;
145 146
		if (sdata->flags & IEEE80211_SDATA_OPERATING_GMODE)
			erp = rate->flags & IEEE80211_RATE_ERP_G;
147
		shift = ieee80211_vif_get_shift(vif);
148
	}
149

150
	dur = ieee80211_frame_duration(band, frame_len, rate->bitrate, erp,
151
				       short_preamble, shift);
J
Johannes Berg 已提交
152 153 154 155 156

	return cpu_to_le16(dur);
}
EXPORT_SYMBOL(ieee80211_generic_frame_duration);

157 158
__le16 ieee80211_rts_duration(struct ieee80211_hw *hw,
			      struct ieee80211_vif *vif, size_t frame_len,
159
			      const struct ieee80211_tx_info *frame_txctl)
J
Johannes Berg 已提交
160 161 162
{
	struct ieee80211_local *local = hw_to_local(hw);
	struct ieee80211_rate *rate;
163
	struct ieee80211_sub_if_data *sdata;
164
	bool short_preamble;
165
	int erp, shift = 0, bitrate;
J
Johannes Berg 已提交
166
	u16 dur;
167 168
	struct ieee80211_supported_band *sband;

169
	sband = local->hw.wiphy->bands[frame_txctl->band];
J
Johannes Berg 已提交
170

171
	short_preamble = false;
172

173
	rate = &sband->bitrates[frame_txctl->control.rts_cts_rate_idx];
174 175

	erp = 0;
176 177
	if (vif) {
		sdata = vif_to_sdata(vif);
J
Johannes Berg 已提交
178
		short_preamble = sdata->vif.bss_conf.use_short_preamble;
179 180
		if (sdata->flags & IEEE80211_SDATA_OPERATING_GMODE)
			erp = rate->flags & IEEE80211_RATE_ERP_G;
181
		shift = ieee80211_vif_get_shift(vif);
182
	}
J
Johannes Berg 已提交
183

184 185
	bitrate = DIV_ROUND_UP(rate->bitrate, 1 << shift);

J
Johannes Berg 已提交
186
	/* CTS duration */
187
	dur = ieee80211_frame_duration(sband->band, 10, bitrate,
188
				       erp, short_preamble, shift);
J
Johannes Berg 已提交
189
	/* Data frame duration */
190
	dur += ieee80211_frame_duration(sband->band, frame_len, bitrate,
191
					erp, short_preamble, shift);
J
Johannes Berg 已提交
192
	/* ACK duration */
193
	dur += ieee80211_frame_duration(sband->band, 10, bitrate,
194
					erp, short_preamble, shift);
J
Johannes Berg 已提交
195 196 197 198 199

	return cpu_to_le16(dur);
}
EXPORT_SYMBOL(ieee80211_rts_duration);

200 201
__le16 ieee80211_ctstoself_duration(struct ieee80211_hw *hw,
				    struct ieee80211_vif *vif,
J
Johannes Berg 已提交
202
				    size_t frame_len,
203
				    const struct ieee80211_tx_info *frame_txctl)
J
Johannes Berg 已提交
204 205 206
{
	struct ieee80211_local *local = hw_to_local(hw);
	struct ieee80211_rate *rate;
207
	struct ieee80211_sub_if_data *sdata;
208
	bool short_preamble;
209
	int erp, shift = 0, bitrate;
J
Johannes Berg 已提交
210
	u16 dur;
211 212
	struct ieee80211_supported_band *sband;

213
	sband = local->hw.wiphy->bands[frame_txctl->band];
J
Johannes Berg 已提交
214

215
	short_preamble = false;
216

217
	rate = &sband->bitrates[frame_txctl->control.rts_cts_rate_idx];
218
	erp = 0;
219 220
	if (vif) {
		sdata = vif_to_sdata(vif);
J
Johannes Berg 已提交
221
		short_preamble = sdata->vif.bss_conf.use_short_preamble;
222 223
		if (sdata->flags & IEEE80211_SDATA_OPERATING_GMODE)
			erp = rate->flags & IEEE80211_RATE_ERP_G;
224
		shift = ieee80211_vif_get_shift(vif);
225
	}
J
Johannes Berg 已提交
226

227 228
	bitrate = DIV_ROUND_UP(rate->bitrate, 1 << shift);

J
Johannes Berg 已提交
229
	/* Data frame duration */
230
	dur = ieee80211_frame_duration(sband->band, frame_len, bitrate,
231
				       erp, short_preamble, shift);
232
	if (!(frame_txctl->flags & IEEE80211_TX_CTL_NO_ACK)) {
J
Johannes Berg 已提交
233
		/* ACK duration */
234
		dur += ieee80211_frame_duration(sband->band, 10, bitrate,
235
						erp, short_preamble, shift);
J
Johannes Berg 已提交
236 237 238 239 240 241
	}

	return cpu_to_le16(dur);
}
EXPORT_SYMBOL(ieee80211_ctstoself_duration);

242 243 244
void ieee80211_propagate_queue_wake(struct ieee80211_local *local, int queue)
{
	struct ieee80211_sub_if_data *sdata;
245 246 247 248
	int n_acs = IEEE80211_NUM_ACS;

	if (local->hw.queues < IEEE80211_NUM_ACS)
		n_acs = 1;
249 250 251 252

	list_for_each_entry_rcu(sdata, &local->interfaces, list) {
		int ac;

253 254 255
		if (!sdata->dev)
			continue;

256 257 258 259
		if (sdata->vif.cab_queue != IEEE80211_INVAL_HW_QUEUE &&
		    local->queue_stop_reasons[sdata->vif.cab_queue] != 0)
			continue;

260
		for (ac = 0; ac < n_acs; ac++) {
261 262
			int ac_queue = sdata->vif.hw_queue[ac];

263 264 265 266 267
			if (local->ops->wake_tx_queue &&
			    (atomic_read(&sdata->txqs_len[ac]) >
			     local->hw.txq_ac_max_pending))
				continue;

268 269 270 271 272 273 274 275 276
			if (ac_queue == queue ||
			    (sdata->vif.cab_queue == queue &&
			     local->queue_stop_reasons[ac_queue] == 0 &&
			     skb_queue_empty(&local->pending[ac_queue])))
				netif_wake_subqueue(sdata->dev, ac);
		}
	}
}

K
Kalle Valo 已提交
277
static void __ieee80211_wake_queue(struct ieee80211_hw *hw, int queue,
278 279
				   enum queue_stop_reason reason,
				   bool refcounted)
J
Johannes Berg 已提交
280 281 282
{
	struct ieee80211_local *local = hw_to_local(hw);

J
Johannes Berg 已提交
283 284
	trace_wake_queue(local, queue, reason);

285 286
	if (WARN_ON(queue >= hw->queues))
		return;
K
Kalle Valo 已提交
287

288 289 290
	if (!test_bit(reason, &local->queue_stop_reasons[queue]))
		return;

291
	if (!refcounted) {
292
		local->q_stop_reasons[queue][reason] = 0;
293
	} else {
294
		local->q_stop_reasons[queue][reason]--;
295 296 297
		if (WARN_ON(local->q_stop_reasons[queue][reason] < 0))
			local->q_stop_reasons[queue][reason] = 0;
	}
298 299 300

	if (local->q_stop_reasons[queue][reason] == 0)
		__clear_bit(reason, &local->queue_stop_reasons[queue]);
301 302 303 304 305

	if (local->queue_stop_reasons[queue] != 0)
		/* someone still has this queue stopped */
		return;

306 307
	if (skb_queue_empty(&local->pending[queue])) {
		rcu_read_lock();
308
		ieee80211_propagate_queue_wake(local, queue);
309 310
		rcu_read_unlock();
	} else
J
Johannes Berg 已提交
311
		tasklet_schedule(&local->tx_pending_tasklet);
J
Johannes Berg 已提交
312
}
K
Kalle Valo 已提交
313

314
void ieee80211_wake_queue_by_reason(struct ieee80211_hw *hw, int queue,
315 316
				    enum queue_stop_reason reason,
				    bool refcounted)
K
Kalle Valo 已提交
317 318 319 320 321
{
	struct ieee80211_local *local = hw_to_local(hw);
	unsigned long flags;

	spin_lock_irqsave(&local->queue_stop_reason_lock, flags);
322
	__ieee80211_wake_queue(hw, queue, reason, refcounted);
K
Kalle Valo 已提交
323 324 325 326 327 328
	spin_unlock_irqrestore(&local->queue_stop_reason_lock, flags);
}

void ieee80211_wake_queue(struct ieee80211_hw *hw, int queue)
{
	ieee80211_wake_queue_by_reason(hw, queue,
329 330
				       IEEE80211_QUEUE_STOP_REASON_DRIVER,
				       false);
K
Kalle Valo 已提交
331
}
J
Johannes Berg 已提交
332 333
EXPORT_SYMBOL(ieee80211_wake_queue);

K
Kalle Valo 已提交
334
static void __ieee80211_stop_queue(struct ieee80211_hw *hw, int queue,
335 336
				   enum queue_stop_reason reason,
				   bool refcounted)
J
Johannes Berg 已提交
337 338
{
	struct ieee80211_local *local = hw_to_local(hw);
339
	struct ieee80211_sub_if_data *sdata;
340
	int n_acs = IEEE80211_NUM_ACS;
J
Johannes Berg 已提交
341

J
Johannes Berg 已提交
342 343
	trace_stop_queue(local, queue, reason);

344 345
	if (WARN_ON(queue >= hw->queues))
		return;
346

347 348 349 350
	if (!refcounted)
		local->q_stop_reasons[queue][reason] = 1;
	else
		local->q_stop_reasons[queue][reason]++;
351

352 353
	if (__test_and_set_bit(reason, &local->queue_stop_reasons[queue]))
		return;
354

355 356 357
	if (local->hw.queues < IEEE80211_NUM_ACS)
		n_acs = 1;

358
	rcu_read_lock();
359 360 361
	list_for_each_entry_rcu(sdata, &local->interfaces, list) {
		int ac;

362 363 364
		if (!sdata->dev)
			continue;

365
		for (ac = 0; ac < n_acs; ac++) {
366 367 368 369 370
			if (sdata->vif.hw_queue[ac] == queue ||
			    sdata->vif.cab_queue == queue)
				netif_stop_subqueue(sdata->dev, ac);
		}
	}
371
	rcu_read_unlock();
J
Johannes Berg 已提交
372
}
K
Kalle Valo 已提交
373

374
void ieee80211_stop_queue_by_reason(struct ieee80211_hw *hw, int queue,
375 376
				    enum queue_stop_reason reason,
				    bool refcounted)
K
Kalle Valo 已提交
377 378 379 380 381
{
	struct ieee80211_local *local = hw_to_local(hw);
	unsigned long flags;

	spin_lock_irqsave(&local->queue_stop_reason_lock, flags);
382
	__ieee80211_stop_queue(hw, queue, reason, refcounted);
K
Kalle Valo 已提交
383 384 385 386 387 388
	spin_unlock_irqrestore(&local->queue_stop_reason_lock, flags);
}

void ieee80211_stop_queue(struct ieee80211_hw *hw, int queue)
{
	ieee80211_stop_queue_by_reason(hw, queue,
389 390
				       IEEE80211_QUEUE_STOP_REASON_DRIVER,
				       false);
K
Kalle Valo 已提交
391
}
J
Johannes Berg 已提交
392 393
EXPORT_SYMBOL(ieee80211_stop_queue);

394 395 396 397 398
void ieee80211_add_pending_skb(struct ieee80211_local *local,
			       struct sk_buff *skb)
{
	struct ieee80211_hw *hw = &local->hw;
	unsigned long flags;
399
	struct ieee80211_tx_info *info = IEEE80211_SKB_CB(skb);
400
	int queue = info->hw_queue;
401 402

	if (WARN_ON(!info->control.vif)) {
403
		ieee80211_free_txskb(&local->hw, skb);
404 405
		return;
	}
406 407

	spin_lock_irqsave(&local->queue_stop_reason_lock, flags);
408 409
	__ieee80211_stop_queue(hw, queue, IEEE80211_QUEUE_STOP_REASON_SKB_ADD,
			       false);
J
Johannes Berg 已提交
410
	__skb_queue_tail(&local->pending[queue], skb);
411 412
	__ieee80211_wake_queue(hw, queue, IEEE80211_QUEUE_STOP_REASON_SKB_ADD,
			       false);
413 414 415
	spin_unlock_irqrestore(&local->queue_stop_reason_lock, flags);
}

416 417
void ieee80211_add_pending_skbs(struct ieee80211_local *local,
				struct sk_buff_head *skbs)
418 419 420 421
{
	struct ieee80211_hw *hw = &local->hw;
	struct sk_buff *skb;
	unsigned long flags;
422
	int queue, i;
423 424 425

	spin_lock_irqsave(&local->queue_stop_reason_lock, flags);
	while ((skb = skb_dequeue(skbs))) {
426 427 428
		struct ieee80211_tx_info *info = IEEE80211_SKB_CB(skb);

		if (WARN_ON(!info->control.vif)) {
429
			ieee80211_free_txskb(&local->hw, skb);
430 431 432
			continue;
		}

433
		queue = info->hw_queue;
434 435

		__ieee80211_stop_queue(hw, queue,
436 437
				IEEE80211_QUEUE_STOP_REASON_SKB_ADD,
				false);
438

J
Johannes Berg 已提交
439
		__skb_queue_tail(&local->pending[queue], skb);
440 441
	}

J
Johannes Berg 已提交
442
	for (i = 0; i < hw->queues; i++)
443
		__ieee80211_wake_queue(hw, i,
444 445
			IEEE80211_QUEUE_STOP_REASON_SKB_ADD,
			false);
446 447 448
	spin_unlock_irqrestore(&local->queue_stop_reason_lock, flags);
}

K
Kalle Valo 已提交
449
void ieee80211_stop_queues_by_reason(struct ieee80211_hw *hw,
450
				     unsigned long queues,
451 452
				     enum queue_stop_reason reason,
				     bool refcounted)
J
Johannes Berg 已提交
453
{
K
Kalle Valo 已提交
454 455
	struct ieee80211_local *local = hw_to_local(hw);
	unsigned long flags;
J
Johannes Berg 已提交
456 457
	int i;

K
Kalle Valo 已提交
458 459
	spin_lock_irqsave(&local->queue_stop_reason_lock, flags);

460
	for_each_set_bit(i, &queues, hw->queues)
461
		__ieee80211_stop_queue(hw, i, reason, refcounted);
K
Kalle Valo 已提交
462 463 464 465 466 467

	spin_unlock_irqrestore(&local->queue_stop_reason_lock, flags);
}

void ieee80211_stop_queues(struct ieee80211_hw *hw)
{
468
	ieee80211_stop_queues_by_reason(hw, IEEE80211_MAX_QUEUE_MAP,
469 470
					IEEE80211_QUEUE_STOP_REASON_DRIVER,
					false);
J
Johannes Berg 已提交
471 472 473
}
EXPORT_SYMBOL(ieee80211_stop_queues);

474 475 476
int ieee80211_queue_stopped(struct ieee80211_hw *hw, int queue)
{
	struct ieee80211_local *local = hw_to_local(hw);
J
Johannes Berg 已提交
477 478
	unsigned long flags;
	int ret;
479

480 481
	if (WARN_ON(queue >= hw->queues))
		return true;
482

J
Johannes Berg 已提交
483
	spin_lock_irqsave(&local->queue_stop_reason_lock, flags);
484 485
	ret = test_bit(IEEE80211_QUEUE_STOP_REASON_DRIVER,
		       &local->queue_stop_reasons[queue]);
J
Johannes Berg 已提交
486 487
	spin_unlock_irqrestore(&local->queue_stop_reason_lock, flags);
	return ret;
488 489 490
}
EXPORT_SYMBOL(ieee80211_queue_stopped);

K
Kalle Valo 已提交
491
void ieee80211_wake_queues_by_reason(struct ieee80211_hw *hw,
492
				     unsigned long queues,
493 494
				     enum queue_stop_reason reason,
				     bool refcounted)
J
Johannes Berg 已提交
495
{
K
Kalle Valo 已提交
496 497
	struct ieee80211_local *local = hw_to_local(hw);
	unsigned long flags;
J
Johannes Berg 已提交
498 499
	int i;

K
Kalle Valo 已提交
500 501
	spin_lock_irqsave(&local->queue_stop_reason_lock, flags);

502
	for_each_set_bit(i, &queues, hw->queues)
503
		__ieee80211_wake_queue(hw, i, reason, refcounted);
K
Kalle Valo 已提交
504 505 506 507 508 509

	spin_unlock_irqrestore(&local->queue_stop_reason_lock, flags);
}

void ieee80211_wake_queues(struct ieee80211_hw *hw)
{
510
	ieee80211_wake_queues_by_reason(hw, IEEE80211_MAX_QUEUE_MAP,
511 512
					IEEE80211_QUEUE_STOP_REASON_DRIVER,
					false);
J
Johannes Berg 已提交
513 514
}
EXPORT_SYMBOL(ieee80211_wake_queues);
515

516 517 518
static unsigned int
ieee80211_get_vif_queues(struct ieee80211_local *local,
			 struct ieee80211_sub_if_data *sdata)
519
{
520
	unsigned int queues;
521

522
	if (sdata && ieee80211_hw_check(&local->hw, QUEUE_CONTROL)) {
523 524 525 526 527 528 529 530 531 532 533 534 535
		int ac;

		queues = 0;

		for (ac = 0; ac < IEEE80211_NUM_ACS; ac++)
			queues |= BIT(sdata->vif.hw_queue[ac]);
		if (sdata->vif.cab_queue != IEEE80211_INVAL_HW_QUEUE)
			queues |= BIT(sdata->vif.cab_queue);
	} else {
		/* all queues */
		queues = BIT(local->hw.queues) - 1;
	}

536 537 538
	return queues;
}

539 540
void __ieee80211_flush_queues(struct ieee80211_local *local,
			      struct ieee80211_sub_if_data *sdata,
541
			      unsigned int queues, bool drop)
542 543 544 545
{
	if (!local->ops->flush)
		return;

546 547 548 549
	/*
	 * If no queue was set, or if the HW doesn't support
	 * IEEE80211_HW_QUEUE_CONTROL - flush all queues
	 */
550
	if (!queues || !ieee80211_hw_check(&local->hw, QUEUE_CONTROL))
551
		queues = ieee80211_get_vif_queues(local, sdata);
552

553
	ieee80211_stop_queues_by_reason(&local->hw, queues,
554 555
					IEEE80211_QUEUE_STOP_REASON_FLUSH,
					false);
556

557
	drv_flush(local, sdata, queues, drop);
558

559
	ieee80211_wake_queues_by_reason(&local->hw, queues,
560 561
					IEEE80211_QUEUE_STOP_REASON_FLUSH,
					false);
562 563
}

564
void ieee80211_flush_queues(struct ieee80211_local *local,
565
			    struct ieee80211_sub_if_data *sdata, bool drop)
566
{
567
	__ieee80211_flush_queues(local, sdata, 0, drop);
568 569
}

570 571 572 573 574 575 576 577 578 579 580 581 582 583 584 585 586 587
void ieee80211_stop_vif_queues(struct ieee80211_local *local,
			       struct ieee80211_sub_if_data *sdata,
			       enum queue_stop_reason reason)
{
	ieee80211_stop_queues_by_reason(&local->hw,
					ieee80211_get_vif_queues(local, sdata),
					reason, true);
}

void ieee80211_wake_vif_queues(struct ieee80211_local *local,
			       struct ieee80211_sub_if_data *sdata,
			       enum queue_stop_reason reason)
{
	ieee80211_wake_queues_by_reason(&local->hw,
					ieee80211_get_vif_queues(local, sdata),
					reason, true);
}

588 589 590 591 592
static void __iterate_interfaces(struct ieee80211_local *local,
				 u32 iter_flags,
				 void (*iterator)(void *data, u8 *mac,
						  struct ieee80211_vif *vif),
				 void *data)
593 594
{
	struct ieee80211_sub_if_data *sdata;
595
	bool active_only = iter_flags & IEEE80211_IFACE_ITER_ACTIVE;
596

597
	list_for_each_entry_rcu(sdata, &local->interfaces, list) {
598
		switch (sdata->vif.type) {
599
		case NL80211_IFTYPE_MONITOR:
600 601 602
			if (!(sdata->u.mntr_flags & MONITOR_FLAG_ACTIVE))
				continue;
			break;
603
		case NL80211_IFTYPE_AP_VLAN:
604
			continue;
605
		default:
606 607
			break;
		}
608
		if (!(iter_flags & IEEE80211_IFACE_ITER_RESUME_ALL) &&
609
		    active_only && !(sdata->flags & IEEE80211_SDATA_IN_DRIVER))
610
			continue;
611
		if (ieee80211_sdata_running(sdata) || !active_only)
612
			iterator(data, sdata->vif.addr,
613 614 615
				 &sdata->vif);
	}

616 617 618
	sdata = rcu_dereference_check(local->monitor_sdata,
				      lockdep_is_held(&local->iflist_mtx) ||
				      lockdep_rtnl_is_held());
619
	if (sdata &&
620
	    (iter_flags & IEEE80211_IFACE_ITER_RESUME_ALL || !active_only ||
621
	     sdata->flags & IEEE80211_SDATA_IN_DRIVER))
622
		iterator(data, sdata->vif.addr, &sdata->vif);
623
}
624

625
void ieee80211_iterate_interfaces(
626 627 628 629 630 631 632 633
	struct ieee80211_hw *hw, u32 iter_flags,
	void (*iterator)(void *data, u8 *mac,
			 struct ieee80211_vif *vif),
	void *data)
{
	struct ieee80211_local *local = hw_to_local(hw);

	mutex_lock(&local->iflist_mtx);
634
	__iterate_interfaces(local, iter_flags, iterator, data);
635
	mutex_unlock(&local->iflist_mtx);
636
}
637
EXPORT_SYMBOL_GPL(ieee80211_iterate_interfaces);
638 639

void ieee80211_iterate_active_interfaces_atomic(
640
	struct ieee80211_hw *hw, u32 iter_flags,
641 642 643 644 645 646
	void (*iterator)(void *data, u8 *mac,
			 struct ieee80211_vif *vif),
	void *data)
{
	struct ieee80211_local *local = hw_to_local(hw);

647
	rcu_read_lock();
648 649
	__iterate_interfaces(local, iter_flags | IEEE80211_IFACE_ITER_ACTIVE,
			     iterator, data);
650 651 652
	rcu_read_unlock();
}
EXPORT_SYMBOL_GPL(ieee80211_iterate_active_interfaces_atomic);
653

654 655 656 657 658 659 660
void ieee80211_iterate_active_interfaces_rtnl(
	struct ieee80211_hw *hw, u32 iter_flags,
	void (*iterator)(void *data, u8 *mac,
			 struct ieee80211_vif *vif),
	void *data)
{
	struct ieee80211_local *local = hw_to_local(hw);
661

662
	ASSERT_RTNL();
663

664 665
	__iterate_interfaces(local, iter_flags | IEEE80211_IFACE_ITER_ACTIVE,
			     iterator, data);
666
}
667
EXPORT_SYMBOL_GPL(ieee80211_iterate_active_interfaces_rtnl);
668

669 670 671 672 673 674 675 676 677 678 679 680 681 682 683 684 685 686 687 688 689 690 691 692 693 694 695 696
static void __iterate_stations(struct ieee80211_local *local,
			       void (*iterator)(void *data,
						struct ieee80211_sta *sta),
			       void *data)
{
	struct sta_info *sta;

	list_for_each_entry_rcu(sta, &local->sta_list, list) {
		if (!sta->uploaded)
			continue;

		iterator(data, &sta->sta);
	}
}

void ieee80211_iterate_stations_atomic(struct ieee80211_hw *hw,
			void (*iterator)(void *data,
					 struct ieee80211_sta *sta),
			void *data)
{
	struct ieee80211_local *local = hw_to_local(hw);

	rcu_read_lock();
	__iterate_stations(local, iterator, data);
	rcu_read_unlock();
}
EXPORT_SYMBOL_GPL(ieee80211_iterate_stations_atomic);

J
Johannes Berg 已提交
697 698 699 700 701 702 703 704 705 706 707
struct ieee80211_vif *wdev_to_ieee80211_vif(struct wireless_dev *wdev)
{
	struct ieee80211_sub_if_data *sdata = IEEE80211_WDEV_TO_SUB_IF(wdev);

	if (!ieee80211_sdata_running(sdata) ||
	    !(sdata->flags & IEEE80211_SDATA_IN_DRIVER))
		return NULL;
	return &sdata->vif;
}
EXPORT_SYMBOL_GPL(wdev_to_ieee80211_vif);

708 709
struct wireless_dev *ieee80211_vif_to_wdev(struct ieee80211_vif *vif)
{
710 711 712 713 714 715
	struct ieee80211_sub_if_data *sdata;

	if (!vif)
		return NULL;

	sdata = vif_to_sdata(vif);
716 717 718 719 720 721 722 723 724

	if (!ieee80211_sdata_running(sdata) ||
	    !(sdata->flags & IEEE80211_SDATA_IN_DRIVER))
		return NULL;

	return &sdata->wdev;
}
EXPORT_SYMBOL_GPL(ieee80211_vif_to_wdev);

725 726
/*
 * Nothing should have been stuffed into the workqueue during
727 728 729 730 731 732
 * the suspend->resume cycle. Since we can't check each caller
 * of this function if we are already quiescing / suspended,
 * check here and don't WARN since this can actually happen when
 * the rx path (for example) is racing against __ieee80211_suspend
 * and suspending / quiescing was set after the rx path checked
 * them.
733 734 735
 */
static bool ieee80211_can_queue_work(struct ieee80211_local *local)
{
736 737
	if (local->quiescing || (local->suspended && !local->resuming)) {
		pr_warn("queueing ieee80211 work while going to suspend\n");
J
Johannes Berg 已提交
738
		return false;
739
	}
740 741 742 743 744 745 746 747 748 749 750 751 752 753 754 755 756 757 758 759 760 761 762 763 764 765 766 767

	return true;
}

void ieee80211_queue_work(struct ieee80211_hw *hw, struct work_struct *work)
{
	struct ieee80211_local *local = hw_to_local(hw);

	if (!ieee80211_can_queue_work(local))
		return;

	queue_work(local->workqueue, work);
}
EXPORT_SYMBOL(ieee80211_queue_work);

void ieee80211_queue_delayed_work(struct ieee80211_hw *hw,
				  struct delayed_work *dwork,
				  unsigned long delay)
{
	struct ieee80211_local *local = hw_to_local(hw);

	if (!ieee80211_can_queue_work(local))
		return;

	queue_delayed_work(local->workqueue, dwork, delay);
}
EXPORT_SYMBOL(ieee80211_queue_delayed_work);

768
u32 ieee802_11_parse_elems_crc(const u8 *start, size_t len, bool action,
769 770 771 772
			       struct ieee802_11_elems *elems,
			       u64 filter, u32 crc)
{
	size_t left = len;
773
	const u8 *pos = start;
774
	bool calc_crc = filter != 0;
P
Paul Stewart 已提交
775
	DECLARE_BITMAP(seen_elems, 256);
776
	const u8 *ie;
777

P
Paul Stewart 已提交
778
	bitmap_zero(seen_elems, 256);
779 780 781 782 783 784
	memset(elems, 0, sizeof(*elems));
	elems->ie_start = start;
	elems->total_len = len;

	while (left >= 2) {
		u8 id, elen;
P
Paul Stewart 已提交
785
		bool elem_parse_failed;
786 787 788 789 790

		id = *pos++;
		elen = *pos++;
		left -= 2;

P
Paul Stewart 已提交
791 792
		if (elen > left) {
			elems->parse_error = true;
793
			break;
P
Paul Stewart 已提交
794 795
		}

796 797 798 799 800 801 802 803 804 805 806 807 808 809 810 811 812 813 814 815 816 817 818 819 820 821 822 823
		switch (id) {
		case WLAN_EID_SSID:
		case WLAN_EID_SUPP_RATES:
		case WLAN_EID_FH_PARAMS:
		case WLAN_EID_DS_PARAMS:
		case WLAN_EID_CF_PARAMS:
		case WLAN_EID_TIM:
		case WLAN_EID_IBSS_PARAMS:
		case WLAN_EID_CHALLENGE:
		case WLAN_EID_RSN:
		case WLAN_EID_ERP_INFO:
		case WLAN_EID_EXT_SUPP_RATES:
		case WLAN_EID_HT_CAPABILITY:
		case WLAN_EID_HT_OPERATION:
		case WLAN_EID_VHT_CAPABILITY:
		case WLAN_EID_VHT_OPERATION:
		case WLAN_EID_MESH_ID:
		case WLAN_EID_MESH_CONFIG:
		case WLAN_EID_PEER_MGMT:
		case WLAN_EID_PREQ:
		case WLAN_EID_PREP:
		case WLAN_EID_PERR:
		case WLAN_EID_RANN:
		case WLAN_EID_CHANNEL_SWITCH:
		case WLAN_EID_EXT_CHANSWITCH_ANN:
		case WLAN_EID_COUNTRY:
		case WLAN_EID_PWR_CONSTRAINT:
		case WLAN_EID_TIMEOUT_INTERVAL:
824
		case WLAN_EID_SECONDARY_CHANNEL_OFFSET:
825
		case WLAN_EID_WIDE_BW_CHANNEL_SWITCH:
826
		case WLAN_EID_CHAN_SWITCH_PARAM:
827
		case WLAN_EID_EXT_CAPABILITY:
828 829
		case WLAN_EID_CHAN_SWITCH_TIMING:
		case WLAN_EID_LINK_ID:
830 831 832 833
		/*
		 * not listing WLAN_EID_CHANNEL_SWITCH_WRAPPER -- it seems possible
		 * that if the content gets bigger it might be needed more than once
		 */
834 835 836 837 838 839 840
			if (test_bit(id, seen_elems)) {
				elems->parse_error = true;
				left -= elen;
				pos += elen;
				continue;
			}
			break;
P
Paul Stewart 已提交
841
		}
842 843 844 845

		if (calc_crc && id < 64 && (filter & (1ULL << id)))
			crc = crc32_be(crc, pos - 2, elen + 2);

P
Paul Stewart 已提交
846 847
		elem_parse_failed = false;

848
		switch (id) {
849 850 851 852 853 854 855 856 857 858 859 860 861 862
		case WLAN_EID_LINK_ID:
			if (elen + 2 != sizeof(struct ieee80211_tdls_lnkie)) {
				elem_parse_failed = true;
				break;
			}
			elems->lnk_id = (void *)(pos - 2);
			break;
		case WLAN_EID_CHAN_SWITCH_TIMING:
			if (elen != sizeof(struct ieee80211_ch_switch_timing)) {
				elem_parse_failed = true;
				break;
			}
			elems->ch_sw_timing = (void *)pos;
			break;
863 864 865 866
		case WLAN_EID_EXT_CAPABILITY:
			elems->ext_capab = pos;
			elems->ext_capab_len = elen;
			break;
867 868 869 870 871 872 873 874 875
		case WLAN_EID_SSID:
			elems->ssid = pos;
			elems->ssid_len = elen;
			break;
		case WLAN_EID_SUPP_RATES:
			elems->supp_rates = pos;
			elems->supp_rates_len = elen;
			break;
		case WLAN_EID_DS_PARAMS:
876 877 878 879
			if (elen >= 1)
				elems->ds_params = pos;
			else
				elem_parse_failed = true;
880 881 882 883 884
			break;
		case WLAN_EID_TIM:
			if (elen >= sizeof(struct ieee80211_tim_ie)) {
				elems->tim = (void *)pos;
				elems->tim_len = elen;
P
Paul Stewart 已提交
885 886
			} else
				elem_parse_failed = true;
887 888 889 890 891 892 893 894 895 896 897 898 899
			break;
		case WLAN_EID_CHALLENGE:
			elems->challenge = pos;
			elems->challenge_len = elen;
			break;
		case WLAN_EID_VENDOR_SPECIFIC:
			if (elen >= 4 && pos[0] == 0x00 && pos[1] == 0x50 &&
			    pos[2] == 0xf2) {
				/* Microsoft OUI (00:50:F2) */

				if (calc_crc)
					crc = crc32_be(crc, pos - 2, elen + 2);

900
				if (elen >= 5 && pos[3] == 2) {
901 902 903 904 905 906 907 908 909 910 911 912 913 914 915 916
					/* OUI Type 2 - WMM IE */
					if (pos[4] == 0) {
						elems->wmm_info = pos;
						elems->wmm_info_len = elen;
					} else if (pos[4] == 1) {
						elems->wmm_param = pos;
						elems->wmm_param_len = elen;
					}
				}
			}
			break;
		case WLAN_EID_RSN:
			elems->rsn = pos;
			elems->rsn_len = elen;
			break;
		case WLAN_EID_ERP_INFO:
917 918 919 920
			if (elen >= 1)
				elems->erp_info = pos;
			else
				elem_parse_failed = true;
921 922 923 924 925 926 927 928
			break;
		case WLAN_EID_EXT_SUPP_RATES:
			elems->ext_supp_rates = pos;
			elems->ext_supp_rates_len = elen;
			break;
		case WLAN_EID_HT_CAPABILITY:
			if (elen >= sizeof(struct ieee80211_ht_cap))
				elems->ht_cap_elem = (void *)pos;
P
Paul Stewart 已提交
929 930
			else
				elem_parse_failed = true;
931
			break;
932 933 934
		case WLAN_EID_HT_OPERATION:
			if (elen >= sizeof(struct ieee80211_ht_operation))
				elems->ht_operation = (void *)pos;
P
Paul Stewart 已提交
935 936
			else
				elem_parse_failed = true;
937
			break;
M
Mahesh Palivela 已提交
938 939 940 941 942 943 944 945 946 947 948 949
		case WLAN_EID_VHT_CAPABILITY:
			if (elen >= sizeof(struct ieee80211_vht_cap))
				elems->vht_cap_elem = (void *)pos;
			else
				elem_parse_failed = true;
			break;
		case WLAN_EID_VHT_OPERATION:
			if (elen >= sizeof(struct ieee80211_vht_operation))
				elems->vht_operation = (void *)pos;
			else
				elem_parse_failed = true;
			break;
950 951 952 953 954 955
		case WLAN_EID_OPMODE_NOTIF:
			if (elen > 0)
				elems->opmode_notif = pos;
			else
				elem_parse_failed = true;
			break;
956 957 958 959 960 961 962
		case WLAN_EID_MESH_ID:
			elems->mesh_id = pos;
			elems->mesh_id_len = elen;
			break;
		case WLAN_EID_MESH_CONFIG:
			if (elen >= sizeof(struct ieee80211_meshconf_ie))
				elems->mesh_config = (void *)pos;
P
Paul Stewart 已提交
963 964
			else
				elem_parse_failed = true;
965 966 967 968 969
			break;
		case WLAN_EID_PEER_MGMT:
			elems->peering = pos;
			elems->peering_len = elen;
			break;
M
Marco Porsch 已提交
970 971 972 973
		case WLAN_EID_MESH_AWAKE_WINDOW:
			if (elen >= 2)
				elems->awake_window = (void *)pos;
			break;
974 975 976 977 978 979 980 981 982 983 984 985 986 987 988
		case WLAN_EID_PREQ:
			elems->preq = pos;
			elems->preq_len = elen;
			break;
		case WLAN_EID_PREP:
			elems->prep = pos;
			elems->prep_len = elen;
			break;
		case WLAN_EID_PERR:
			elems->perr = pos;
			elems->perr_len = elen;
			break;
		case WLAN_EID_RANN:
			if (elen >= sizeof(struct ieee80211_rann_ie))
				elems->rann = (void *)pos;
P
Paul Stewart 已提交
989 990
			else
				elem_parse_failed = true;
991 992
			break;
		case WLAN_EID_CHANNEL_SWITCH:
993 994 995 996 997
			if (elen != sizeof(struct ieee80211_channel_sw_ie)) {
				elem_parse_failed = true;
				break;
			}
			elems->ch_switch_ie = (void *)pos;
998
			break;
999 1000 1001 1002 1003 1004 1005
		case WLAN_EID_EXT_CHANSWITCH_ANN:
			if (elen != sizeof(struct ieee80211_ext_chansw_ie)) {
				elem_parse_failed = true;
				break;
			}
			elems->ext_chansw_ie = (void *)pos;
			break;
1006 1007 1008 1009 1010 1011 1012
		case WLAN_EID_SECONDARY_CHANNEL_OFFSET:
			if (elen != sizeof(struct ieee80211_sec_chan_offs_ie)) {
				elem_parse_failed = true;
				break;
			}
			elems->sec_chan_offs = (void *)pos;
			break;
1013 1014 1015 1016 1017 1018 1019 1020
		case WLAN_EID_CHAN_SWITCH_PARAM:
			if (elen !=
			    sizeof(*elems->mesh_chansw_params_ie)) {
				elem_parse_failed = true;
				break;
			}
			elems->mesh_chansw_params_ie = (void *)pos;
			break;
1021 1022 1023 1024 1025 1026 1027 1028 1029 1030 1031 1032 1033 1034 1035 1036 1037 1038 1039 1040 1041 1042 1043 1044 1045 1046 1047 1048
		case WLAN_EID_WIDE_BW_CHANNEL_SWITCH:
			if (!action ||
			    elen != sizeof(*elems->wide_bw_chansw_ie)) {
				elem_parse_failed = true;
				break;
			}
			elems->wide_bw_chansw_ie = (void *)pos;
			break;
		case WLAN_EID_CHANNEL_SWITCH_WRAPPER:
			if (action) {
				elem_parse_failed = true;
				break;
			}
			/*
			 * This is a bit tricky, but as we only care about
			 * the wide bandwidth channel switch element, so
			 * just parse it out manually.
			 */
			ie = cfg80211_find_ie(WLAN_EID_WIDE_BW_CHANNEL_SWITCH,
					      pos, elen);
			if (ie) {
				if (ie[1] == sizeof(*elems->wide_bw_chansw_ie))
					elems->wide_bw_chansw_ie =
						(void *)(ie + 2);
				else
					elem_parse_failed = true;
			}
			break;
1049 1050 1051 1052 1053
		case WLAN_EID_COUNTRY:
			elems->country_elem = pos;
			elems->country_elem_len = elen;
			break;
		case WLAN_EID_PWR_CONSTRAINT:
1054 1055 1056 1057
			if (elen != 1) {
				elem_parse_failed = true;
				break;
			}
1058 1059
			elems->pwr_constr_elem = pos;
			break;
1060 1061 1062 1063 1064 1065 1066 1067 1068 1069 1070 1071 1072 1073 1074 1075 1076 1077 1078 1079 1080 1081 1082 1083 1084
		case WLAN_EID_CISCO_VENDOR_SPECIFIC:
			/* Lots of different options exist, but we only care
			 * about the Dynamic Transmit Power Control element.
			 * First check for the Cisco OUI, then for the DTPC
			 * tag (0x00).
			 */
			if (elen < 4) {
				elem_parse_failed = true;
				break;
			}

			if (pos[0] != 0x00 || pos[1] != 0x40 ||
			    pos[2] != 0x96 || pos[3] != 0x00)
				break;

			if (elen != 6) {
				elem_parse_failed = true;
				break;
			}

			if (calc_crc)
				crc = crc32_be(crc, pos - 2, elen + 2);

			elems->cisco_dtpc_elem = pos;
			break;
1085
		case WLAN_EID_TIMEOUT_INTERVAL:
1086 1087 1088 1089
			if (elen >= sizeof(struct ieee80211_timeout_interval_ie))
				elems->timeout_int = (void *)pos;
			else
				elem_parse_failed = true;
1090 1091 1092 1093 1094
			break;
		default:
			break;
		}

P
Paul Stewart 已提交
1095 1096 1097
		if (elem_parse_failed)
			elems->parse_error = true;
		else
1098
			__set_bit(id, seen_elems);
P
Paul Stewart 已提交
1099

1100 1101 1102 1103
		left -= elen;
		pos += elen;
	}

P
Paul Stewart 已提交
1104 1105 1106
	if (left != 0)
		elems->parse_error = true;

1107 1108 1109
	return crc;
}

1110
void ieee80211_set_wmm_default(struct ieee80211_sub_if_data *sdata,
1111
			       bool bss_notify, bool enable_qos)
1112 1113 1114
{
	struct ieee80211_local *local = sdata->local;
	struct ieee80211_tx_queue_params qparam;
J
Johannes Berg 已提交
1115
	struct ieee80211_chanctx_conf *chanctx_conf;
1116
	int ac;
1117
	bool use_11b;
1118
	bool is_ocb; /* Use another EDCA parameters if dot11OCBActivated=true */
1119
	int aCWmin, aCWmax;
1120 1121 1122 1123

	if (!local->ops->conf_tx)
		return;

1124 1125 1126
	if (local->hw.queues < IEEE80211_NUM_ACS)
		return;

1127 1128
	memset(&qparam, 0, sizeof(qparam));

J
Johannes Berg 已提交
1129 1130 1131
	rcu_read_lock();
	chanctx_conf = rcu_dereference(sdata->vif.chanctx_conf);
	use_11b = (chanctx_conf &&
1132
		   chanctx_conf->def.chan->band == IEEE80211_BAND_2GHZ) &&
1133
		 !(sdata->flags & IEEE80211_SDATA_OPERATING_GMODE);
J
Johannes Berg 已提交
1134
	rcu_read_unlock();
1135

1136 1137
	is_ocb = (sdata->vif.type == NL80211_IFTYPE_OCB);

1138 1139 1140 1141 1142 1143 1144 1145 1146 1147 1148 1149
	/* Set defaults according to 802.11-2007 Table 7-37 */
	aCWmax = 1023;
	if (use_11b)
		aCWmin = 31;
	else
		aCWmin = 15;

	/* Confiure old 802.11b/g medium access rules. */
	qparam.cw_max = aCWmax;
	qparam.cw_min = aCWmin;
	qparam.txop = 0;
	qparam.aifs = 2;
1150

1151 1152
	for (ac = 0; ac < IEEE80211_NUM_ACS; ac++) {
		/* Update if QoS is enabled. */
1153 1154 1155 1156 1157 1158
		if (enable_qos) {
			switch (ac) {
			case IEEE80211_AC_BK:
				qparam.cw_max = aCWmax;
				qparam.cw_min = aCWmin;
				qparam.txop = 0;
1159 1160 1161 1162
				if (is_ocb)
					qparam.aifs = 9;
				else
					qparam.aifs = 7;
1163 1164 1165 1166 1167 1168 1169
				break;
			/* never happens but let's not leave undefined */
			default:
			case IEEE80211_AC_BE:
				qparam.cw_max = aCWmax;
				qparam.cw_min = aCWmin;
				qparam.txop = 0;
1170 1171 1172 1173
				if (is_ocb)
					qparam.aifs = 6;
				else
					qparam.aifs = 3;
1174 1175 1176 1177
				break;
			case IEEE80211_AC_VI:
				qparam.cw_max = aCWmin;
				qparam.cw_min = (aCWmin + 1) / 2 - 1;
1178 1179 1180
				if (is_ocb)
					qparam.txop = 0;
				else if (use_11b)
1181 1182 1183
					qparam.txop = 6016/32;
				else
					qparam.txop = 3008/32;
1184 1185 1186 1187 1188

				if (is_ocb)
					qparam.aifs = 3;
				else
					qparam.aifs = 2;
1189 1190 1191 1192
				break;
			case IEEE80211_AC_VO:
				qparam.cw_max = (aCWmin + 1) / 2 - 1;
				qparam.cw_min = (aCWmin + 1) / 4 - 1;
1193 1194 1195
				if (is_ocb)
					qparam.txop = 0;
				else if (use_11b)
1196 1197 1198 1199 1200 1201
					qparam.txop = 3264/32;
				else
					qparam.txop = 1504/32;
				qparam.aifs = 2;
				break;
			}
1202
		}
1203

K
Kalle Valo 已提交
1204 1205
		qparam.uapsd = false;

1206 1207
		sdata->tx_conf[ac] = qparam;
		drv_conf_tx(local, sdata, ac, &qparam);
1208
	}
1209

1210 1211
	if (sdata->vif.type != NL80211_IFTYPE_MONITOR &&
	    sdata->vif.type != NL80211_IFTYPE_P2P_DEVICE) {
1212
		sdata->vif.bss_conf.qos = enable_qos;
1213 1214 1215
		if (bss_notify)
			ieee80211_bss_info_change_notify(sdata,
							 BSS_CHANGED_QOS);
1216
	}
1217
}
J
Johannes Berg 已提交
1218

1219
void ieee80211_send_auth(struct ieee80211_sub_if_data *sdata,
1220
			 u16 transaction, u16 auth_alg, u16 status,
J
Johannes Berg 已提交
1221
			 const u8 *extra, size_t extra_len, const u8 *da,
1222 1223
			 const u8 *bssid, const u8 *key, u8 key_len, u8 key_idx,
			 u32 tx_flags)
1224 1225 1226 1227
{
	struct ieee80211_local *local = sdata->local;
	struct sk_buff *skb;
	struct ieee80211_mgmt *mgmt;
J
Johannes Berg 已提交
1228
	int err;
1229

1230
	/* 24 + 6 = header + auth_algo + auth_transaction + status_code */
1231 1232
	skb = dev_alloc_skb(local->hw.extra_tx_headroom + IEEE80211_WEP_IV_LEN +
			    24 + 6 + extra_len + IEEE80211_WEP_ICV_LEN);
1233
	if (!skb)
1234
		return;
1235

1236
	skb_reserve(skb, local->hw.extra_tx_headroom + IEEE80211_WEP_IV_LEN);
1237 1238 1239 1240 1241

	mgmt = (struct ieee80211_mgmt *) skb_put(skb, 24 + 6);
	memset(mgmt, 0, 24 + 6);
	mgmt->frame_control = cpu_to_le16(IEEE80211_FTYPE_MGMT |
					  IEEE80211_STYPE_AUTH);
1242
	memcpy(mgmt->da, da, ETH_ALEN);
1243
	memcpy(mgmt->sa, sdata->vif.addr, ETH_ALEN);
1244 1245 1246
	memcpy(mgmt->bssid, bssid, ETH_ALEN);
	mgmt->u.auth.auth_alg = cpu_to_le16(auth_alg);
	mgmt->u.auth.auth_transaction = cpu_to_le16(transaction);
1247
	mgmt->u.auth.status_code = cpu_to_le16(status);
1248 1249 1250
	if (extra)
		memcpy(skb_put(skb, extra_len), extra, extra_len);

J
Johannes Berg 已提交
1251 1252 1253 1254 1255 1256
	if (auth_alg == WLAN_AUTH_SHARED_KEY && transaction == 3) {
		mgmt->frame_control |= cpu_to_le16(IEEE80211_FCTL_PROTECTED);
		err = ieee80211_wep_encrypt(local, skb, key, key_len, key_idx);
		WARN_ON(err);
	}

1257 1258
	IEEE80211_SKB_CB(skb)->flags |= IEEE80211_TX_INTFL_DONT_ENCRYPT |
					tx_flags;
1259
	ieee80211_tx_skb(sdata, skb);
1260 1261
}

1262 1263 1264 1265 1266 1267 1268 1269 1270 1271 1272 1273 1274 1275 1276 1277 1278 1279 1280 1281 1282 1283 1284 1285 1286 1287 1288 1289 1290 1291 1292 1293 1294 1295 1296 1297 1298 1299 1300
void ieee80211_send_deauth_disassoc(struct ieee80211_sub_if_data *sdata,
				    const u8 *bssid, u16 stype, u16 reason,
				    bool send_frame, u8 *frame_buf)
{
	struct ieee80211_local *local = sdata->local;
	struct sk_buff *skb;
	struct ieee80211_mgmt *mgmt = (void *)frame_buf;

	/* build frame */
	mgmt->frame_control = cpu_to_le16(IEEE80211_FTYPE_MGMT | stype);
	mgmt->duration = 0; /* initialize only */
	mgmt->seq_ctrl = 0; /* initialize only */
	memcpy(mgmt->da, bssid, ETH_ALEN);
	memcpy(mgmt->sa, sdata->vif.addr, ETH_ALEN);
	memcpy(mgmt->bssid, bssid, ETH_ALEN);
	/* u.deauth.reason_code == u.disassoc.reason_code */
	mgmt->u.deauth.reason_code = cpu_to_le16(reason);

	if (send_frame) {
		skb = dev_alloc_skb(local->hw.extra_tx_headroom +
				    IEEE80211_DEAUTH_FRAME_LEN);
		if (!skb)
			return;

		skb_reserve(skb, local->hw.extra_tx_headroom);

		/* copy in frame */
		memcpy(skb_put(skb, IEEE80211_DEAUTH_FRAME_LEN),
		       mgmt, IEEE80211_DEAUTH_FRAME_LEN);

		if (sdata->vif.type != NL80211_IFTYPE_STATION ||
		    !(sdata->u.mgd.flags & IEEE80211_STA_MFP_ENABLED))
			IEEE80211_SKB_CB(skb)->flags |=
				IEEE80211_TX_INTFL_DONT_ENCRYPT;

		ieee80211_tx_skb(sdata, skb);
	}
}

1301 1302 1303 1304 1305 1306 1307
static int ieee80211_build_preq_ies_band(struct ieee80211_local *local,
					 u8 *buffer, size_t buffer_len,
					 const u8 *ie, size_t ie_len,
					 enum ieee80211_band band,
					 u32 rate_mask,
					 struct cfg80211_chan_def *chandef,
					 size_t *offset)
1308 1309
{
	struct ieee80211_supported_band *sband;
1310
	u8 *pos = buffer, *end = buffer + buffer_len;
1311
	size_t noffset;
1312
	int supp_rates_len, i;
1313 1314 1315
	u8 rates[32];
	int num_rates;
	int ext_rates_len;
1316 1317
	int shift;
	u32 rate_flags;
1318
	bool have_80mhz = false;
1319

1320 1321
	*offset = 0;

1322
	sband = local->hw.wiphy->bands[band];
1323 1324
	if (WARN_ON_ONCE(!sband))
		return 0;
1325

1326 1327 1328
	rate_flags = ieee80211_chandef_rate_flags(chandef);
	shift = ieee80211_chandef_get_shift(chandef);

1329 1330 1331 1332
	num_rates = 0;
	for (i = 0; i < sband->n_bitrates; i++) {
		if ((BIT(i) & rate_mask) == 0)
			continue; /* skip rate */
1333 1334 1335 1336 1337 1338
		if ((rate_flags & sband->bitrates[i].flags) != rate_flags)
			continue;

		rates[num_rates++] =
			(u8) DIV_ROUND_UP(sband->bitrates[i].bitrate,
					  (1 << shift) * 5);
1339 1340 1341
	}

	supp_rates_len = min_t(int, num_rates, 8);
1342

1343 1344
	if (end - pos < 2 + supp_rates_len)
		goto out_err;
1345
	*pos++ = WLAN_EID_SUPP_RATES;
1346
	*pos++ = supp_rates_len;
1347 1348
	memcpy(pos, rates, supp_rates_len);
	pos += supp_rates_len;
1349 1350 1351 1352 1353 1354 1355 1356 1357 1358 1359

	/* insert "request information" if in custom IEs */
	if (ie && ie_len) {
		static const u8 before_extrates[] = {
			WLAN_EID_SSID,
			WLAN_EID_SUPP_RATES,
			WLAN_EID_REQUEST,
		};
		noffset = ieee80211_ie_split(ie, ie_len,
					     before_extrates,
					     ARRAY_SIZE(before_extrates),
1360 1361
					     *offset);
		if (end - pos < noffset - *offset)
1362
			goto out_err;
1363 1364 1365
		memcpy(pos, ie + *offset, noffset - *offset);
		pos += noffset - *offset;
		*offset = noffset;
1366 1367
	}

1368 1369
	ext_rates_len = num_rates - supp_rates_len;
	if (ext_rates_len > 0) {
1370 1371
		if (end - pos < 2 + ext_rates_len)
			goto out_err;
1372
		*pos++ = WLAN_EID_EXT_SUPP_RATES;
1373 1374 1375
		*pos++ = ext_rates_len;
		memcpy(pos, rates + supp_rates_len, ext_rates_len);
		pos += ext_rates_len;
1376 1377
	}

1378
	if (chandef->chan && sband->band == IEEE80211_BAND_2GHZ) {
1379 1380
		if (end - pos < 3)
			goto out_err;
1381 1382
		*pos++ = WLAN_EID_DS_PARAMS;
		*pos++ = 1;
1383 1384
		*pos++ = ieee80211_frequency_to_channel(
				chandef->chan->center_freq);
1385 1386
	}

1387 1388 1389 1390 1391 1392 1393 1394 1395 1396 1397 1398
	/* insert custom IEs that go before HT */
	if (ie && ie_len) {
		static const u8 before_ht[] = {
			WLAN_EID_SSID,
			WLAN_EID_SUPP_RATES,
			WLAN_EID_REQUEST,
			WLAN_EID_EXT_SUPP_RATES,
			WLAN_EID_DS_PARAMS,
			WLAN_EID_SUPPORTED_REGULATORY_CLASSES,
		};
		noffset = ieee80211_ie_split(ie, ie_len,
					     before_ht, ARRAY_SIZE(before_ht),
1399 1400
					     *offset);
		if (end - pos < noffset - *offset)
1401
			goto out_err;
1402 1403 1404
		memcpy(pos, ie + *offset, noffset - *offset);
		pos += noffset - *offset;
		*offset = noffset;
1405 1406
	}

1407 1408 1409
	if (sband->ht_cap.ht_supported) {
		if (end - pos < 2 + sizeof(struct ieee80211_ht_cap))
			goto out_err;
B
Ben Greear 已提交
1410 1411
		pos = ieee80211_ie_build_ht_cap(pos, &sband->ht_cap,
						sband->ht_cap.cap);
1412
	}
1413

1414 1415 1416 1417 1418
	/*
	 * If adding more here, adjust code in main.c
	 * that calculates local->scan_ies_len.
	 */

1419
	/* insert custom IEs that go before VHT */
1420
	if (ie && ie_len) {
1421 1422 1423 1424 1425 1426 1427 1428 1429 1430 1431 1432 1433 1434 1435 1436 1437 1438
		static const u8 before_vht[] = {
			WLAN_EID_SSID,
			WLAN_EID_SUPP_RATES,
			WLAN_EID_REQUEST,
			WLAN_EID_EXT_SUPP_RATES,
			WLAN_EID_DS_PARAMS,
			WLAN_EID_SUPPORTED_REGULATORY_CLASSES,
			WLAN_EID_HT_CAPABILITY,
			WLAN_EID_BSS_COEX_2040,
			WLAN_EID_EXT_CAPABILITY,
			WLAN_EID_SSID_LIST,
			WLAN_EID_CHANNEL_USAGE,
			WLAN_EID_INTERWORKING,
			/* mesh ID can't happen here */
			/* 60 GHz can't happen here right now */
		};
		noffset = ieee80211_ie_split(ie, ie_len,
					     before_vht, ARRAY_SIZE(before_vht),
1439 1440
					     *offset);
		if (end - pos < noffset - *offset)
1441
			goto out_err;
1442 1443 1444
		memcpy(pos, ie + *offset, noffset - *offset);
		pos += noffset - *offset;
		*offset = noffset;
1445 1446
	}

1447 1448
	/* Check if any channel in this sband supports at least 80 MHz */
	for (i = 0; i < sband->n_channels; i++) {
1449 1450 1451 1452 1453 1454
		if (sband->channels[i].flags & (IEEE80211_CHAN_DISABLED |
						IEEE80211_CHAN_NO_80MHZ))
			continue;

		have_80mhz = true;
		break;
1455 1456 1457
	}

	if (sband->vht_cap.vht_supported && have_80mhz) {
1458 1459
		if (end - pos < 2 + sizeof(struct ieee80211_vht_cap))
			goto out_err;
1460 1461
		pos = ieee80211_ie_build_vht_cap(pos, &sband->vht_cap,
						 sband->vht_cap.cap);
1462
	}
1463

1464 1465 1466
	return pos - buffer;
 out_err:
	WARN_ONCE(1, "not enough space for preq IEs\n");
1467 1468 1469
	return pos - buffer;
}

1470 1471 1472 1473 1474 1475 1476 1477 1478 1479 1480 1481 1482 1483 1484 1485 1486 1487 1488 1489 1490 1491 1492 1493 1494 1495 1496 1497 1498 1499 1500 1501 1502 1503 1504 1505 1506 1507 1508 1509 1510 1511
int ieee80211_build_preq_ies(struct ieee80211_local *local, u8 *buffer,
			     size_t buffer_len,
			     struct ieee80211_scan_ies *ie_desc,
			     const u8 *ie, size_t ie_len,
			     u8 bands_used, u32 *rate_masks,
			     struct cfg80211_chan_def *chandef)
{
	size_t pos = 0, old_pos = 0, custom_ie_offset = 0;
	int i;

	memset(ie_desc, 0, sizeof(*ie_desc));

	for (i = 0; i < IEEE80211_NUM_BANDS; i++) {
		if (bands_used & BIT(i)) {
			pos += ieee80211_build_preq_ies_band(local,
							     buffer + pos,
							     buffer_len - pos,
							     ie, ie_len, i,
							     rate_masks[i],
							     chandef,
							     &custom_ie_offset);
			ie_desc->ies[i] = buffer + old_pos;
			ie_desc->len[i] = pos - old_pos;
			old_pos = pos;
		}
	}

	/* add any remaining custom IEs */
	if (ie && ie_len) {
		if (WARN_ONCE(buffer_len - pos < ie_len - custom_ie_offset,
			      "not enough space for preq custom IEs\n"))
			return pos;
		memcpy(buffer + pos, ie + custom_ie_offset,
		       ie_len - custom_ie_offset);
		ie_desc->common_ies = buffer + pos;
		ie_desc->common_ie_len = ie_len - custom_ie_offset;
		pos += ie_len - custom_ie_offset;
	}

	return pos;
};

1512
struct sk_buff *ieee80211_build_probe_req(struct ieee80211_sub_if_data *sdata,
1513 1514
					  const u8 *src, const u8 *dst,
					  u32 ratemask,
1515
					  struct ieee80211_channel *chan,
1516
					  const u8 *ssid, size_t ssid_len,
1517 1518
					  const u8 *ie, size_t ie_len,
					  bool directed)
1519 1520
{
	struct ieee80211_local *local = sdata->local;
1521
	struct cfg80211_chan_def chandef;
1522 1523
	struct sk_buff *skb;
	struct ieee80211_mgmt *mgmt;
1524
	int ies_len;
1525 1526
	u32 rate_masks[IEEE80211_NUM_BANDS] = {};
	struct ieee80211_scan_ies dummy_ie_desc;
1527

1528 1529 1530 1531 1532
	/*
	 * Do not send DS Channel parameter for directed probe requests
	 * in order to maximize the chance that we get a response.  Some
	 * badly-behaved APs don't respond when this parameter is included.
	 */
1533
	chandef.width = sdata->vif.bss_conf.chandef.width;
1534
	if (directed)
1535
		chandef.chan = NULL;
1536
	else
1537
		chandef.chan = chan;
1538

1539 1540
	skb = ieee80211_probereq_get(&local->hw, src, ssid, ssid_len,
				     100 + ie_len);
1541
	if (!skb)
1542 1543
		return NULL;

1544
	rate_masks[chan->band] = ratemask;
1545
	ies_len = ieee80211_build_preq_ies(local, skb_tail_pointer(skb),
1546 1547 1548
					   skb_tailroom(skb), &dummy_ie_desc,
					   ie, ie_len, BIT(chan->band),
					   rate_masks, &chandef);
1549
	skb_put(skb, ies_len);
1550

1551
	if (dst) {
1552
		mgmt = (struct ieee80211_mgmt *) skb->data;
1553 1554 1555 1556
		memcpy(mgmt->da, dst, ETH_ALEN);
		memcpy(mgmt->bssid, dst, ETH_ALEN);
	}

1557
	IEEE80211_SKB_CB(skb)->flags |= IEEE80211_TX_INTFL_DONT_ENCRYPT;
1558

1559 1560 1561
	return skb;
}

1562 1563
void ieee80211_send_probe_req(struct ieee80211_sub_if_data *sdata,
			      const u8 *src, const u8 *dst,
1564
			      const u8 *ssid, size_t ssid_len,
1565
			      const u8 *ie, size_t ie_len,
1566
			      u32 ratemask, bool directed, u32 tx_flags,
J
Johannes Berg 已提交
1567
			      struct ieee80211_channel *channel, bool scan)
1568 1569 1570
{
	struct sk_buff *skb;

1571
	skb = ieee80211_build_probe_req(sdata, src, dst, ratemask, channel,
1572
					ssid, ssid_len,
1573
					ie, ie_len, directed);
1574
	if (skb) {
1575
		IEEE80211_SKB_CB(skb)->flags |= tx_flags;
J
Johannes Berg 已提交
1576 1577 1578 1579
		if (scan)
			ieee80211_tx_skb_tid_band(sdata, skb, 7, channel->band);
		else
			ieee80211_tx_skb(sdata, skb);
1580
	}
1581 1582
}

1583
u32 ieee80211_sta_get_rates(struct ieee80211_sub_if_data *sdata,
1584
			    struct ieee802_11_elems *elems,
1585
			    enum ieee80211_band band, u32 *basic_rates)
1586 1587 1588
{
	struct ieee80211_supported_band *sband;
	size_t num_rates;
1589 1590 1591 1592 1593 1594
	u32 supp_rates, rate_flags;
	int i, j, shift;
	sband = sdata->local->hw.wiphy->bands[band];

	rate_flags = ieee80211_chandef_rate_flags(&sdata->vif.bss_conf.chandef);
	shift = ieee80211_vif_get_shift(&sdata->vif);
1595

1596 1597
	if (WARN_ON(!sband))
		return 1;
1598 1599 1600 1601 1602 1603 1604

	num_rates = sband->n_bitrates;
	supp_rates = 0;
	for (i = 0; i < elems->supp_rates_len +
		     elems->ext_supp_rates_len; i++) {
		u8 rate = 0;
		int own_rate;
1605
		bool is_basic;
1606 1607 1608 1609 1610 1611
		if (i < elems->supp_rates_len)
			rate = elems->supp_rates[i];
		else if (elems->ext_supp_rates)
			rate = elems->ext_supp_rates
				[i - elems->supp_rates_len];
		own_rate = 5 * (rate & 0x7f);
1612 1613 1614 1615 1616 1617
		is_basic = !!(rate & 0x80);

		if (is_basic && (rate & 0x7f) == BSS_MEMBERSHIP_SELECTOR_HT_PHY)
			continue;

		for (j = 0; j < num_rates; j++) {
1618 1619 1620 1621 1622 1623 1624 1625 1626
			int brate;
			if ((rate_flags & sband->bitrates[j].flags)
			    != rate_flags)
				continue;

			brate = DIV_ROUND_UP(sband->bitrates[j].bitrate,
					     1 << shift);

			if (brate == own_rate) {
1627
				supp_rates |= BIT(j);
1628 1629 1630 1631
				if (basic_rates && is_basic)
					*basic_rates |= BIT(j);
			}
		}
1632 1633 1634
	}
	return supp_rates;
}
1635

1636 1637 1638
void ieee80211_stop_device(struct ieee80211_local *local)
{
	ieee80211_led_radio(local, false);
1639
	ieee80211_mod_tpt_led_trig(local, 0, IEEE80211_TPT_LEDTRIG_FL_RADIO);
1640 1641 1642 1643

	cancel_work_sync(&local->reconfig_filter);

	flush_workqueue(local->workqueue);
1644
	drv_stop(local);
1645 1646
}

1647 1648 1649 1650 1651 1652 1653 1654 1655 1656 1657 1658 1659 1660 1661 1662 1663 1664 1665 1666 1667 1668 1669
static void ieee80211_flush_completed_scan(struct ieee80211_local *local,
					   bool aborted)
{
	/* It's possible that we don't handle the scan completion in
	 * time during suspend, so if it's still marked as completed
	 * here, queue the work and flush it to clean things up.
	 * Instead of calling the worker function directly here, we
	 * really queue it to avoid potential races with other flows
	 * scheduling the same work.
	 */
	if (test_bit(SCAN_COMPLETED, &local->scanning)) {
		/* If coming from reconfiguration failure, abort the scan so
		 * we don't attempt to continue a partial HW scan - which is
		 * possible otherwise if (e.g.) the 2.4 GHz portion was the
		 * completed scan, and a 5 GHz portion is still pending.
		 */
		if (aborted)
			set_bit(SCAN_ABORTED, &local->scanning);
		ieee80211_queue_delayed_work(&local->hw, &local->scan_work, 0);
		flush_delayed_work(&local->scan_work);
	}
}

1670 1671 1672 1673 1674 1675 1676 1677 1678 1679 1680 1681 1682 1683 1684 1685 1686
static void ieee80211_handle_reconfig_failure(struct ieee80211_local *local)
{
	struct ieee80211_sub_if_data *sdata;
	struct ieee80211_chanctx *ctx;

	/*
	 * We get here if during resume the device can't be restarted properly.
	 * We might also get here if this happens during HW reset, which is a
	 * slightly different situation and we need to drop all connections in
	 * the latter case.
	 *
	 * Ask cfg80211 to turn off all interfaces, this will result in more
	 * warnings but at least we'll then get into a clean stopped state.
	 */

	local->resuming = false;
	local->suspended = false;
1687
	local->in_reconfig = false;
1688

1689 1690
	ieee80211_flush_completed_scan(local, true);

1691 1692 1693 1694 1695 1696 1697 1698 1699 1700 1701 1702 1703 1704 1705 1706 1707 1708 1709
	/* scheduled scan clearly can't be running any more, but tell
	 * cfg80211 and clear local state
	 */
	ieee80211_sched_scan_end(local);

	list_for_each_entry(sdata, &local->interfaces, list)
		sdata->flags &= ~IEEE80211_SDATA_IN_DRIVER;

	/* Mark channel contexts as not being in the driver any more to avoid
	 * removing them from the driver during the shutdown process...
	 */
	mutex_lock(&local->chanctx_mtx);
	list_for_each_entry(ctx, &local->chanctx_list, list)
		ctx->driver_present = false;
	mutex_unlock(&local->chanctx_mtx);

	cfg80211_shutdown_all_interfaces(local->hw.wiphy);
}

1710 1711 1712 1713 1714 1715 1716 1717 1718 1719 1720 1721 1722 1723 1724 1725 1726 1727 1728
static void ieee80211_assign_chanctx(struct ieee80211_local *local,
				     struct ieee80211_sub_if_data *sdata)
{
	struct ieee80211_chanctx_conf *conf;
	struct ieee80211_chanctx *ctx;

	if (!local->use_chanctx)
		return;

	mutex_lock(&local->chanctx_mtx);
	conf = rcu_dereference_protected(sdata->vif.chanctx_conf,
					 lockdep_is_held(&local->chanctx_mtx));
	if (conf) {
		ctx = container_of(conf, struct ieee80211_chanctx, conf);
		drv_assign_vif_chanctx(local, sdata, ctx);
	}
	mutex_unlock(&local->chanctx_mtx);
}

1729 1730 1731 1732 1733 1734 1735 1736 1737 1738 1739 1740 1741 1742 1743 1744 1745 1746 1747 1748 1749
static void ieee80211_reconfig_stations(struct ieee80211_sub_if_data *sdata)
{
	struct ieee80211_local *local = sdata->local;
	struct sta_info *sta;

	/* add STAs back */
	mutex_lock(&local->sta_mtx);
	list_for_each_entry(sta, &local->sta_list, list) {
		enum ieee80211_sta_state state;

		if (!sta->uploaded || sta->sdata != sdata)
			continue;

		for (state = IEEE80211_STA_NOTEXIST;
		     state < sta->sta_state; state++)
			WARN_ON(drv_sta_state(local, sta->sdata, sta, state,
					      state + 1));
	}
	mutex_unlock(&local->sta_mtx);
}

1750 1751 1752 1753
int ieee80211_reconfig(struct ieee80211_local *local)
{
	struct ieee80211_hw *hw = &local->hw;
	struct ieee80211_sub_if_data *sdata;
J
Johannes Berg 已提交
1754
	struct ieee80211_chanctx *ctx;
1755
	struct sta_info *sta;
1756
	int res, i;
J
Johannes Berg 已提交
1757
	bool reconfig_due_to_wowlan = false;
1758
	struct ieee80211_sub_if_data *sched_scan_sdata;
1759
	struct cfg80211_sched_scan_request *sched_scan_req;
1760
	bool sched_scan_stopped = false;
1761
	bool suspended = local->suspended;
J
Johannes Berg 已提交
1762

1763 1764 1765 1766
	/* nothing to do if HW shouldn't run */
	if (!local->open_count)
		goto wake_up;

1767
#ifdef CONFIG_PM
1768
	if (suspended)
J
Johannes Berg 已提交
1769
		local->resuming = true;
1770

1771
	if (local->wowlan) {
1772 1773 1774 1775 1776 1777 1778
		/*
		 * In the wowlan case, both mac80211 and the device
		 * are functional when the resume op is called, so
		 * clear local->suspended so the device could operate
		 * normally (e.g. pass rx frames).
		 */
		local->suspended = false;
1779
		res = drv_resume(local);
1780
		local->wowlan = false;
1781 1782 1783 1784 1785 1786 1787 1788 1789 1790
		if (res < 0) {
			local->resuming = false;
			return res;
		}
		if (res == 0)
			goto wake_up;
		WARN_ON(res > 1);
		/*
		 * res is 1, which means the driver requested
		 * to go through a regular reset on wakeup.
1791
		 * restore local->suspended in this case.
1792
		 */
J
Johannes Berg 已提交
1793
		reconfig_due_to_wowlan = true;
1794
		local->suspended = true;
1795 1796
	}
#endif
1797

1798 1799 1800 1801 1802 1803 1804 1805 1806 1807
	/*
	 * In case of hw_restart during suspend (without wowlan),
	 * cancel restart work, as we are reconfiguring the device
	 * anyway.
	 * Note that restart_work is scheduled on a frozen workqueue,
	 * so we can't deadlock in this case.
	 */
	if (suspended && local->in_reconfig && !reconfig_due_to_wowlan)
		cancel_work_sync(&local->restart_work);

1808 1809
	local->started = false;

1810 1811 1812 1813 1814 1815 1816 1817
	/*
	 * Upon resume hardware can sometimes be goofy due to
	 * various platform / driver / bus issues, so restarting
	 * the device may at times not work immediately. Propagate
	 * the error.
	 */
	res = drv_start(local);
	if (res) {
1818
		if (suspended)
1819 1820 1821 1822
			WARN(1, "Hardware became unavailable upon resume. This could be a software issue prior to suspend or a hardware issue.\n");
		else
			WARN(1, "Hardware became unavailable during restart.\n");
		ieee80211_handle_reconfig_failure(local);
1823
		return res;
1824 1825
	}

1826 1827 1828 1829 1830 1831 1832 1833 1834
	/* setup fragmentation threshold */
	drv_set_frag_threshold(local, hw->wiphy->frag_threshold);

	/* setup RTS threshold */
	drv_set_rts_threshold(local, hw->wiphy->rts_threshold);

	/* reset coverage class */
	drv_set_coverage_class(local, hw->wiphy->coverage_class);

1835 1836 1837 1838
	ieee80211_led_radio(local, true);
	ieee80211_mod_tpt_led_trig(local,
				   IEEE80211_TPT_LEDTRIG_FL_RADIO, 0);

1839
	/* add interfaces */
1840 1841
	sdata = rtnl_dereference(local->monitor_sdata);
	if (sdata) {
1842 1843
		/* in HW restart it exists already */
		WARN_ON(local->resuming);
1844 1845
		res = drv_add_interface(local, sdata);
		if (WARN_ON(res)) {
M
Monam Agarwal 已提交
1846
			RCU_INIT_POINTER(local->monitor_sdata, NULL);
1847 1848 1849 1850 1851
			synchronize_net();
			kfree(sdata);
		}
	}

1852 1853 1854
	list_for_each_entry(sdata, &local->interfaces, list) {
		if (sdata->vif.type != NL80211_IFTYPE_AP_VLAN &&
		    sdata->vif.type != NL80211_IFTYPE_MONITOR &&
1855
		    ieee80211_sdata_running(sdata)) {
1856
			res = drv_add_interface(local, sdata);
1857 1858 1859 1860 1861 1862 1863 1864 1865 1866 1867 1868 1869 1870 1871 1872 1873
			if (WARN_ON(res))
				break;
		}
	}

	/* If adding any of the interfaces failed above, roll back and
	 * report failure.
	 */
	if (res) {
		list_for_each_entry_continue_reverse(sdata, &local->interfaces,
						     list)
			if (sdata->vif.type != NL80211_IFTYPE_AP_VLAN &&
			    sdata->vif.type != NL80211_IFTYPE_MONITOR &&
			    ieee80211_sdata_running(sdata))
				drv_remove_interface(local, sdata);
		ieee80211_handle_reconfig_failure(local);
		return res;
1874 1875
	}

J
Johannes Berg 已提交
1876
	/* add channel contexts */
1877 1878 1879
	if (local->use_chanctx) {
		mutex_lock(&local->chanctx_mtx);
		list_for_each_entry(ctx, &local->chanctx_list, list)
1880 1881 1882
			if (ctx->replace_state !=
			    IEEE80211_CHANCTX_REPLACES_OTHER)
				WARN_ON(drv_add_chanctx(local, ctx));
1883
		mutex_unlock(&local->chanctx_mtx);
J
Johannes Berg 已提交
1884

1885 1886 1887 1888
		sdata = rtnl_dereference(local->monitor_sdata);
		if (sdata && ieee80211_sdata_running(sdata))
			ieee80211_assign_chanctx(local, sdata);
	}
1889

1890 1891 1892 1893 1894 1895 1896
	/* reconfigure hardware */
	ieee80211_hw_config(local, ~0);

	ieee80211_configure_filter(local);

	/* Finally also reconfigure all the BSS information */
	list_for_each_entry(sdata, &local->interfaces, list) {
1897 1898
		u32 changed;

1899
		if (!ieee80211_sdata_running(sdata))
1900
			continue;
1901

1902 1903 1904 1905 1906 1907 1908 1909 1910 1911 1912 1913 1914 1915 1916 1917
		ieee80211_assign_chanctx(local, sdata);

		switch (sdata->vif.type) {
		case NL80211_IFTYPE_AP_VLAN:
		case NL80211_IFTYPE_MONITOR:
			break;
		default:
			ieee80211_reconfig_stations(sdata);
			/* fall through */
		case NL80211_IFTYPE_AP: /* AP stations are handled later */
			for (i = 0; i < IEEE80211_NUM_ACS; i++)
				drv_conf_tx(local, sdata, i,
					    &sdata->tx_conf[i]);
			break;
		}

1918 1919 1920 1921 1922 1923 1924 1925
		/* common change flags for all interface types */
		changed = BSS_CHANGED_ERP_CTS_PROT |
			  BSS_CHANGED_ERP_PREAMBLE |
			  BSS_CHANGED_ERP_SLOT |
			  BSS_CHANGED_HT |
			  BSS_CHANGED_BASIC_RATES |
			  BSS_CHANGED_BEACON_INT |
			  BSS_CHANGED_BSSID |
1926
			  BSS_CHANGED_CQM |
1927
			  BSS_CHANGED_QOS |
1928 1929
			  BSS_CHANGED_IDLE |
			  BSS_CHANGED_TXPOWER;
1930

1931 1932 1933
		if (sdata->flags & IEEE80211_SDATA_MU_MIMO_OWNER)
			changed |= BSS_CHANGED_MU_GROUPS;

1934 1935
		switch (sdata->vif.type) {
		case NL80211_IFTYPE_STATION:
1936
			changed |= BSS_CHANGED_ASSOC |
E
Eliad Peller 已提交
1937 1938
				   BSS_CHANGED_ARP_FILTER |
				   BSS_CHANGED_PS;
1939

1940 1941 1942
			/* Re-send beacon info report to the driver */
			if (sdata->u.mgd.have_beacon)
				changed |= BSS_CHANGED_BEACON_INFO;
1943

1944
			sdata_lock(sdata);
1945
			ieee80211_bss_info_change_notify(sdata, changed);
1946
			sdata_unlock(sdata);
1947
			break;
1948
		case NL80211_IFTYPE_OCB:
1949 1950
			changed |= BSS_CHANGED_OCB;
			ieee80211_bss_info_change_notify(sdata, changed);
1951
			break;
1952
		case NL80211_IFTYPE_ADHOC:
1953 1954
			changed |= BSS_CHANGED_IBSS;
			/* fall through */
1955
		case NL80211_IFTYPE_AP:
1956
			changed |= BSS_CHANGED_SSID | BSS_CHANGED_P2P_PS;
1957

1958
			if (sdata->vif.type == NL80211_IFTYPE_AP) {
1959 1960
				changed |= BSS_CHANGED_AP_PROBE_RESP;

1961 1962 1963 1964
				if (rcu_access_pointer(sdata->u.ap.beacon))
					drv_start_ap(local, sdata);
			}

1965
			/* fall through */
1966
		case NL80211_IFTYPE_MESH_POINT:
1967 1968 1969 1970 1971
			if (sdata->vif.bss_conf.enable_beacon) {
				changed |= BSS_CHANGED_BEACON |
					   BSS_CHANGED_BEACON_ENABLED;
				ieee80211_bss_info_change_notify(sdata, changed);
			}
1972 1973 1974 1975
			break;
		case NL80211_IFTYPE_WDS:
		case NL80211_IFTYPE_AP_VLAN:
		case NL80211_IFTYPE_MONITOR:
1976
		case NL80211_IFTYPE_P2P_DEVICE:
1977
			/* nothing to do */
1978
			break;
1979
		case NL80211_IFTYPE_UNSPECIFIED:
1980
		case NUM_NL80211_IFTYPES:
1981 1982
		case NL80211_IFTYPE_P2P_CLIENT:
		case NL80211_IFTYPE_P2P_GO:
1983 1984 1985 1986 1987
			WARN_ON(1);
			break;
		}
	}

J
Johannes Berg 已提交
1988
	ieee80211_recalc_ps(local);
1989

1990 1991 1992 1993 1994 1995 1996 1997 1998 1999
	/*
	 * The sta might be in psm against the ap (e.g. because
	 * this was the state before a hw restart), so we
	 * explicitly send a null packet in order to make sure
	 * it'll sync against the ap (and get out of psm).
	 */
	if (!(local->hw.conf.flags & IEEE80211_CONF_PS)) {
		list_for_each_entry(sdata, &local->interfaces, list) {
			if (sdata->vif.type != NL80211_IFTYPE_STATION)
				continue;
2000 2001
			if (!sdata->u.mgd.associated)
				continue;
2002

2003
			ieee80211_send_nullfunc(local, sdata, false);
2004 2005 2006
		}
	}

2007 2008 2009 2010 2011 2012 2013 2014 2015 2016 2017 2018 2019 2020 2021 2022 2023 2024
	/* APs are now beaconing, add back stations */
	mutex_lock(&local->sta_mtx);
	list_for_each_entry(sta, &local->sta_list, list) {
		enum ieee80211_sta_state state;

		if (!sta->uploaded)
			continue;

		if (sta->sdata->vif.type != NL80211_IFTYPE_AP)
			continue;

		for (state = IEEE80211_STA_NOTEXIST;
		     state < sta->sta_state; state++)
			WARN_ON(drv_sta_state(local, sta->sdata, sta, state,
					      state + 1));
	}
	mutex_unlock(&local->sta_mtx);

2025
	/* add back keys */
2026 2027 2028
	list_for_each_entry(sdata, &local->interfaces, list)
		ieee80211_reset_crypto_tx_tailroom(sdata);

2029 2030 2031 2032
	list_for_each_entry(sdata, &local->interfaces, list)
		if (ieee80211_sdata_running(sdata))
			ieee80211_enable_keys(sdata);

2033 2034 2035 2036 2037 2038 2039 2040 2041 2042 2043 2044 2045 2046 2047 2048 2049 2050 2051 2052 2053 2054 2055
	/* Reconfigure sched scan if it was interrupted by FW restart */
	mutex_lock(&local->mtx);
	sched_scan_sdata = rcu_dereference_protected(local->sched_scan_sdata,
						lockdep_is_held(&local->mtx));
	sched_scan_req = rcu_dereference_protected(local->sched_scan_req,
						lockdep_is_held(&local->mtx));
	if (sched_scan_sdata && sched_scan_req)
		/*
		 * Sched scan stopped, but we don't want to report it. Instead,
		 * we're trying to reschedule. However, if more than one scan
		 * plan was set, we cannot reschedule since we don't know which
		 * scan plan was currently running (and some scan plans may have
		 * already finished).
		 */
		if (sched_scan_req->n_scan_plans > 1 ||
		    __ieee80211_request_sched_scan_start(sched_scan_sdata,
							 sched_scan_req))
			sched_scan_stopped = true;
	mutex_unlock(&local->mtx);

	if (sched_scan_stopped)
		cfg80211_sched_scan_stopped_rtnl(local->hw.wiphy);

2056
 wake_up:
2057 2058 2059
	local->in_reconfig = false;
	barrier();

2060 2061 2062
	if (local->monitors == local->open_count && local->monitors > 0)
		ieee80211_add_virtual_monitor(local);

2063 2064 2065 2066 2067 2068 2069 2070 2071 2072
	/*
	 * Clear the WLAN_STA_BLOCK_BA flag so new aggregation
	 * sessions can be established after a resume.
	 *
	 * Also tear down aggregation sessions since reconfiguring
	 * them in a hardware restart scenario is not easily done
	 * right now, and the hardware will have lost information
	 * about the sessions, but we and the AP still think they
	 * are active. This is really a workaround though.
	 */
2073
	if (ieee80211_hw_check(hw, AMPDU_AGGREGATION)) {
2074 2075 2076
		mutex_lock(&local->sta_mtx);

		list_for_each_entry(sta, &local->sta_list, list) {
2077 2078 2079
			if (!local->resuming)
				ieee80211_sta_tear_down_BA_sessions(
						sta, AGG_STOP_LOCAL_REQUEST);
J
Johannes Berg 已提交
2080
			clear_sta_flag(sta, WLAN_STA_BLOCK_BA);
2081
		}
2082 2083

		mutex_unlock(&local->sta_mtx);
2084 2085
	}

2086
	ieee80211_wake_queues_by_reason(hw, IEEE80211_MAX_QUEUE_MAP,
2087 2088
					IEEE80211_QUEUE_STOP_REASON_SUSPEND,
					false);
2089

2090 2091 2092 2093
	/*
	 * If this is for hw restart things are still running.
	 * We may want to change that later, however.
	 */
2094
	if (local->open_count && (!suspended || reconfig_due_to_wowlan))
2095
		drv_reconfig_complete(local, IEEE80211_RECONFIG_TYPE_RESTART);
2096

2097
	if (!suspended)
2098 2099 2100
		return 0;

#ifdef CONFIG_PM
J
Johannes Berg 已提交
2101
	/* first set suspended false, then resuming */
2102
	local->suspended = false;
J
Johannes Berg 已提交
2103 2104
	mb();
	local->resuming = false;
2105

2106
	ieee80211_flush_completed_scan(local, false);
2107

2108
	if (local->open_count && !reconfig_due_to_wowlan)
2109 2110
		drv_reconfig_complete(local, IEEE80211_RECONFIG_TYPE_SUSPEND);

2111 2112 2113 2114 2115 2116 2117
	list_for_each_entry(sdata, &local->interfaces, list) {
		if (!ieee80211_sdata_running(sdata))
			continue;
		if (sdata->vif.type == NL80211_IFTYPE_STATION)
			ieee80211_sta_restart(sdata);
	}

2118
	mod_timer(&local->sta_cleanup, jiffies + 1);
2119 2120 2121
#else
	WARN_ON(1);
#endif
2122

2123 2124
	return 0;
}
2125

2126 2127 2128 2129 2130 2131 2132 2133 2134 2135 2136 2137 2138 2139 2140 2141 2142 2143 2144 2145 2146 2147 2148 2149 2150 2151 2152
void ieee80211_resume_disconnect(struct ieee80211_vif *vif)
{
	struct ieee80211_sub_if_data *sdata;
	struct ieee80211_local *local;
	struct ieee80211_key *key;

	if (WARN_ON(!vif))
		return;

	sdata = vif_to_sdata(vif);
	local = sdata->local;

	if (WARN_ON(!local->resuming))
		return;

	if (WARN_ON(vif->type != NL80211_IFTYPE_STATION))
		return;

	sdata->flags |= IEEE80211_SDATA_DISCONNECT_RESUME;

	mutex_lock(&local->key_mtx);
	list_for_each_entry(key, &sdata->key_list, list)
		key->flags |= KEY_FLAG_TAINTED;
	mutex_unlock(&local->key_mtx);
}
EXPORT_SYMBOL_GPL(ieee80211_resume_disconnect);

2153
void ieee80211_recalc_smps(struct ieee80211_sub_if_data *sdata)
2154
{
2155 2156 2157
	struct ieee80211_local *local = sdata->local;
	struct ieee80211_chanctx_conf *chanctx_conf;
	struct ieee80211_chanctx *chanctx;
2158

2159
	mutex_lock(&local->chanctx_mtx);
2160

2161 2162
	chanctx_conf = rcu_dereference_protected(sdata->vif.chanctx_conf,
					lockdep_is_held(&local->chanctx_mtx));
2163

2164 2165 2166 2167 2168 2169 2170
	/*
	 * This function can be called from a work, thus it may be possible
	 * that the chanctx_conf is removed (due to a disconnection, for
	 * example).
	 * So nothing should be done in such case.
	 */
	if (!chanctx_conf)
2171
		goto unlock;
2172

2173 2174
	chanctx = container_of(chanctx_conf, struct ieee80211_chanctx, conf);
	ieee80211_recalc_smps_chanctx(local, chanctx);
2175
 unlock:
2176
	mutex_unlock(&local->chanctx_mtx);
2177
}
2178

2179 2180 2181 2182 2183 2184 2185 2186 2187 2188 2189 2190 2191 2192 2193 2194 2195 2196 2197 2198
void ieee80211_recalc_min_chandef(struct ieee80211_sub_if_data *sdata)
{
	struct ieee80211_local *local = sdata->local;
	struct ieee80211_chanctx_conf *chanctx_conf;
	struct ieee80211_chanctx *chanctx;

	mutex_lock(&local->chanctx_mtx);

	chanctx_conf = rcu_dereference_protected(sdata->vif.chanctx_conf,
					lockdep_is_held(&local->chanctx_mtx));

	if (WARN_ON_ONCE(!chanctx_conf))
		goto unlock;

	chanctx = container_of(chanctx_conf, struct ieee80211_chanctx, conf);
	ieee80211_recalc_chanctx_min_def(local, chanctx);
 unlock:
	mutex_unlock(&local->chanctx_mtx);
}

2199 2200 2201 2202 2203 2204 2205 2206 2207
size_t ieee80211_ie_split_vendor(const u8 *ies, size_t ielen, size_t offset)
{
	size_t pos = offset;

	while (pos < ielen && ies[pos] != WLAN_EID_VENDOR_SPECIFIC)
		pos += 2 + ies[pos + 1];

	return pos;
}
2208 2209 2210 2211 2212 2213 2214 2215 2216 2217 2218 2219 2220 2221 2222 2223 2224 2225 2226 2227 2228 2229 2230 2231 2232 2233 2234 2235 2236 2237 2238 2239 2240 2241 2242 2243 2244 2245 2246 2247

static void _ieee80211_enable_rssi_reports(struct ieee80211_sub_if_data *sdata,
					    int rssi_min_thold,
					    int rssi_max_thold)
{
	trace_api_enable_rssi_reports(sdata, rssi_min_thold, rssi_max_thold);

	if (WARN_ON(sdata->vif.type != NL80211_IFTYPE_STATION))
		return;

	/*
	 * Scale up threshold values before storing it, as the RSSI averaging
	 * algorithm uses a scaled up value as well. Change this scaling
	 * factor if the RSSI averaging algorithm changes.
	 */
	sdata->u.mgd.rssi_min_thold = rssi_min_thold*16;
	sdata->u.mgd.rssi_max_thold = rssi_max_thold*16;
}

void ieee80211_enable_rssi_reports(struct ieee80211_vif *vif,
				    int rssi_min_thold,
				    int rssi_max_thold)
{
	struct ieee80211_sub_if_data *sdata = vif_to_sdata(vif);

	WARN_ON(rssi_min_thold == rssi_max_thold ||
		rssi_min_thold > rssi_max_thold);

	_ieee80211_enable_rssi_reports(sdata, rssi_min_thold,
				       rssi_max_thold);
}
EXPORT_SYMBOL(ieee80211_enable_rssi_reports);

void ieee80211_disable_rssi_reports(struct ieee80211_vif *vif)
{
	struct ieee80211_sub_if_data *sdata = vif_to_sdata(vif);

	_ieee80211_enable_rssi_reports(sdata, 0, 0);
}
EXPORT_SYMBOL(ieee80211_disable_rssi_reports);
2248

B
Ben Greear 已提交
2249
u8 *ieee80211_ie_build_ht_cap(u8 *pos, struct ieee80211_sta_ht_cap *ht_cap,
2250 2251 2252 2253 2254 2255 2256 2257 2258 2259 2260 2261 2262 2263
			      u16 cap)
{
	__le16 tmp;

	*pos++ = WLAN_EID_HT_CAPABILITY;
	*pos++ = sizeof(struct ieee80211_ht_cap);
	memset(pos, 0, sizeof(struct ieee80211_ht_cap));

	/* capability flags */
	tmp = cpu_to_le16(cap);
	memcpy(pos, &tmp, sizeof(u16));
	pos += sizeof(u16);

	/* AMPDU parameters */
B
Ben Greear 已提交
2264 2265
	*pos++ = ht_cap->ampdu_factor |
		 (ht_cap->ampdu_density <<
2266 2267 2268
			IEEE80211_HT_AMPDU_PARM_DENSITY_SHIFT);

	/* MCS set */
B
Ben Greear 已提交
2269 2270
	memcpy(pos, &ht_cap->mcs, sizeof(ht_cap->mcs));
	pos += sizeof(ht_cap->mcs);
2271 2272 2273 2274 2275 2276 2277 2278 2279 2280 2281 2282 2283

	/* extended capabilities */
	pos += sizeof(__le16);

	/* BF capabilities */
	pos += sizeof(__le32);

	/* antenna selection */
	pos += sizeof(u8);

	return pos;
}

2284
u8 *ieee80211_ie_build_vht_cap(u8 *pos, struct ieee80211_sta_vht_cap *vht_cap,
2285
			       u32 cap)
2286 2287 2288 2289
{
	__le32 tmp;

	*pos++ = WLAN_EID_VHT_CAPABILITY;
M
Mahesh Palivela 已提交
2290 2291
	*pos++ = sizeof(struct ieee80211_vht_cap);
	memset(pos, 0, sizeof(struct ieee80211_vht_cap));
2292 2293 2294 2295 2296 2297 2298 2299 2300 2301 2302 2303 2304

	/* capability flags */
	tmp = cpu_to_le32(cap);
	memcpy(pos, &tmp, sizeof(u32));
	pos += sizeof(u32);

	/* VHT MCS set */
	memcpy(pos, &vht_cap->vht_mcs, sizeof(vht_cap->vht_mcs));
	pos += sizeof(vht_cap->vht_mcs);

	return pos;
}

2305
u8 *ieee80211_ie_build_ht_oper(u8 *pos, struct ieee80211_sta_ht_cap *ht_cap,
2306
			       const struct cfg80211_chan_def *chandef,
2307
			       u16 prot_mode, bool rifs_mode)
2308
{
2309
	struct ieee80211_ht_operation *ht_oper;
2310
	/* Build HT Information */
2311 2312 2313
	*pos++ = WLAN_EID_HT_OPERATION;
	*pos++ = sizeof(struct ieee80211_ht_operation);
	ht_oper = (struct ieee80211_ht_operation *)pos;
2314 2315 2316 2317 2318 2319 2320 2321 2322 2323 2324
	ht_oper->primary_chan = ieee80211_frequency_to_channel(
					chandef->chan->center_freq);
	switch (chandef->width) {
	case NL80211_CHAN_WIDTH_160:
	case NL80211_CHAN_WIDTH_80P80:
	case NL80211_CHAN_WIDTH_80:
	case NL80211_CHAN_WIDTH_40:
		if (chandef->center_freq1 > chandef->chan->center_freq)
			ht_oper->ht_param = IEEE80211_HT_PARAM_CHA_SEC_ABOVE;
		else
			ht_oper->ht_param = IEEE80211_HT_PARAM_CHA_SEC_BELOW;
2325 2326
		break;
	default:
2327
		ht_oper->ht_param = IEEE80211_HT_PARAM_CHA_SEC_NONE;
2328 2329
		break;
	}
2330
	if (ht_cap->cap & IEEE80211_HT_CAP_SUP_WIDTH_20_40 &&
2331 2332
	    chandef->width != NL80211_CHAN_WIDTH_20_NOHT &&
	    chandef->width != NL80211_CHAN_WIDTH_20)
2333
		ht_oper->ht_param |= IEEE80211_HT_PARAM_CHAN_WIDTH_ANY;
2334

2335 2336 2337
	if (rifs_mode)
		ht_oper->ht_param |= IEEE80211_HT_PARAM_RIFS_MODE;

2338
	ht_oper->operation_mode = cpu_to_le16(prot_mode);
2339
	ht_oper->stbc_param = 0x0000;
2340 2341 2342

	/* It seems that Basic MCS set and Supported MCS set
	   are identical for the first 10 bytes */
2343 2344
	memset(&ht_oper->basic_set, 0, 16);
	memcpy(&ht_oper->basic_set, &ht_cap->mcs, 10);
2345

2346
	return pos + sizeof(struct ieee80211_ht_operation);
2347 2348
}

2349 2350 2351 2352 2353 2354 2355 2356 2357 2358 2359 2360 2361
u8 *ieee80211_ie_build_vht_oper(u8 *pos, struct ieee80211_sta_vht_cap *vht_cap,
				const struct cfg80211_chan_def *chandef)
{
	struct ieee80211_vht_operation *vht_oper;

	*pos++ = WLAN_EID_VHT_OPERATION;
	*pos++ = sizeof(struct ieee80211_vht_operation);
	vht_oper = (struct ieee80211_vht_operation *)pos;
	vht_oper->center_freq_seg1_idx = ieee80211_frequency_to_channel(
							chandef->center_freq1);
	if (chandef->center_freq2)
		vht_oper->center_freq_seg2_idx =
			ieee80211_frequency_to_channel(chandef->center_freq2);
2362 2363
	else
		vht_oper->center_freq_seg2_idx = 0x00;
2364 2365 2366

	switch (chandef->width) {
	case NL80211_CHAN_WIDTH_160:
2367 2368 2369 2370 2371 2372 2373 2374 2375 2376
		/*
		 * Convert 160 MHz channel width to new style as interop
		 * workaround.
		 */
		vht_oper->chan_width = IEEE80211_VHT_CHANWIDTH_80MHZ;
		vht_oper->center_freq_seg2_idx = vht_oper->center_freq_seg1_idx;
		if (chandef->chan->center_freq < chandef->center_freq1)
			vht_oper->center_freq_seg1_idx -= 8;
		else
			vht_oper->center_freq_seg1_idx += 8;
2377 2378
		break;
	case NL80211_CHAN_WIDTH_80P80:
2379 2380 2381 2382 2383
		/*
		 * Convert 80+80 MHz channel width to new style as interop
		 * workaround.
		 */
		vht_oper->chan_width = IEEE80211_VHT_CHANWIDTH_80MHZ;
2384 2385 2386 2387 2388 2389 2390 2391 2392 2393 2394 2395 2396 2397 2398
		break;
	case NL80211_CHAN_WIDTH_80:
		vht_oper->chan_width = IEEE80211_VHT_CHANWIDTH_80MHZ;
		break;
	default:
		vht_oper->chan_width = IEEE80211_VHT_CHANWIDTH_USE_HT;
		break;
	}

	/* don't require special VHT peer rates */
	vht_oper->basic_mcs_set = cpu_to_le16(0xffff);

	return pos + sizeof(struct ieee80211_vht_operation);
}

2399 2400
bool ieee80211_chandef_ht_oper(const struct ieee80211_ht_operation *ht_oper,
			       struct cfg80211_chan_def *chandef)
2401 2402 2403
{
	enum nl80211_channel_type channel_type;

2404 2405
	if (!ht_oper)
		return false;
2406

2407
	switch (ht_oper->ht_param & IEEE80211_HT_PARAM_CHA_SEC_OFFSET) {
2408 2409 2410 2411 2412 2413 2414 2415 2416 2417 2418
	case IEEE80211_HT_PARAM_CHA_SEC_NONE:
		channel_type = NL80211_CHAN_HT20;
		break;
	case IEEE80211_HT_PARAM_CHA_SEC_ABOVE:
		channel_type = NL80211_CHAN_HT40PLUS;
		break;
	case IEEE80211_HT_PARAM_CHA_SEC_BELOW:
		channel_type = NL80211_CHAN_HT40MINUS;
		break;
	default:
		channel_type = NL80211_CHAN_NO_HT;
2419
		return false;
2420 2421
	}

2422 2423
	cfg80211_chandef_create(chandef, chandef->chan, channel_type);
	return true;
2424 2425
}

2426 2427
bool ieee80211_chandef_vht_oper(const struct ieee80211_vht_operation *oper,
				struct cfg80211_chan_def *chandef)
2428
{
2429 2430 2431
	struct cfg80211_chan_def new = *chandef;
	int cf1, cf2;

2432
	if (!oper)
2433
		return false;
2434

2435 2436 2437 2438
	cf1 = ieee80211_channel_to_frequency(oper->center_freq_seg1_idx,
					     chandef->chan->band);
	cf2 = ieee80211_channel_to_frequency(oper->center_freq_seg2_idx,
					     chandef->chan->band);
2439 2440 2441 2442 2443

	switch (oper->chan_width) {
	case IEEE80211_VHT_CHANWIDTH_USE_HT:
		break;
	case IEEE80211_VHT_CHANWIDTH_80MHZ:
2444 2445
		new.width = NL80211_CHAN_WIDTH_80;
		new.center_freq1 = cf1;
2446 2447 2448 2449 2450 2451 2452 2453 2454 2455 2456 2457 2458 2459
		/* If needed, adjust based on the newer interop workaround. */
		if (oper->center_freq_seg2_idx) {
			unsigned int diff;

			diff = abs(oper->center_freq_seg2_idx -
				   oper->center_freq_seg1_idx);
			if (diff == 8) {
				new.width = NL80211_CHAN_WIDTH_160;
				new.center_freq1 = cf2;
			} else if (diff > 8) {
				new.width = NL80211_CHAN_WIDTH_80P80;
				new.center_freq2 = cf2;
			}
		}
2460 2461
		break;
	case IEEE80211_VHT_CHANWIDTH_160MHZ:
2462 2463
		new.width = NL80211_CHAN_WIDTH_160;
		new.center_freq1 = cf1;
2464 2465
		break;
	case IEEE80211_VHT_CHANWIDTH_80P80MHZ:
2466 2467 2468
		new.width = NL80211_CHAN_WIDTH_80P80;
		new.center_freq1 = cf1;
		new.center_freq2 = cf2;
2469 2470
		break;
	default:
2471
		return false;
2472 2473
	}

2474 2475 2476 2477 2478
	if (!cfg80211_chandef_valid(&new))
		return false;

	*chandef = new;
	return true;
2479 2480
}

2481 2482 2483 2484 2485 2486 2487 2488 2489 2490 2491 2492 2493 2494 2495 2496 2497 2498 2499 2500 2501 2502 2503 2504 2505 2506 2507 2508 2509 2510
int ieee80211_parse_bitrates(struct cfg80211_chan_def *chandef,
			     const struct ieee80211_supported_band *sband,
			     const u8 *srates, int srates_len, u32 *rates)
{
	u32 rate_flags = ieee80211_chandef_rate_flags(chandef);
	int shift = ieee80211_chandef_get_shift(chandef);
	struct ieee80211_rate *br;
	int brate, rate, i, j, count = 0;

	*rates = 0;

	for (i = 0; i < srates_len; i++) {
		rate = srates[i] & 0x7f;

		for (j = 0; j < sband->n_bitrates; j++) {
			br = &sband->bitrates[j];
			if ((rate_flags & br->flags) != rate_flags)
				continue;

			brate = DIV_ROUND_UP(br->bitrate, (1 << shift) * 5);
			if (brate == rate) {
				*rates |= BIT(j);
				count++;
				break;
			}
		}
	}
	return count;
}

2511
int ieee80211_add_srates_ie(struct ieee80211_sub_if_data *sdata,
2512 2513
			    struct sk_buff *skb, bool need_basic,
			    enum ieee80211_band band)
2514 2515 2516
{
	struct ieee80211_local *local = sdata->local;
	struct ieee80211_supported_band *sband;
2517
	int rate, shift;
2518
	u8 i, rates, *pos;
2519
	u32 basic_rates = sdata->vif.bss_conf.basic_rates;
2520
	u32 rate_flags;
2521

2522 2523
	shift = ieee80211_vif_get_shift(&sdata->vif);
	rate_flags = ieee80211_chandef_rate_flags(&sdata->vif.bss_conf.chandef);
2524
	sband = local->hw.wiphy->bands[band];
2525 2526 2527 2528 2529 2530
	rates = 0;
	for (i = 0; i < sband->n_bitrates; i++) {
		if ((rate_flags & sband->bitrates[i].flags) != rate_flags)
			continue;
		rates++;
	}
2531 2532 2533 2534 2535 2536 2537 2538 2539 2540
	if (rates > 8)
		rates = 8;

	if (skb_tailroom(skb) < rates + 2)
		return -ENOMEM;

	pos = skb_put(skb, rates + 2);
	*pos++ = WLAN_EID_SUPP_RATES;
	*pos++ = rates;
	for (i = 0; i < rates; i++) {
2541
		u8 basic = 0;
2542 2543 2544
		if ((rate_flags & sband->bitrates[i].flags) != rate_flags)
			continue;

2545 2546
		if (need_basic && basic_rates & BIT(i))
			basic = 0x80;
2547
		rate = sband->bitrates[i].bitrate;
2548 2549 2550
		rate = DIV_ROUND_UP(sband->bitrates[i].bitrate,
				    5 * (1 << shift));
		*pos++ = basic | (u8) rate;
2551 2552 2553 2554 2555
	}

	return 0;
}

2556
int ieee80211_add_ext_srates_ie(struct ieee80211_sub_if_data *sdata,
2557 2558
				struct sk_buff *skb, bool need_basic,
				enum ieee80211_band band)
2559 2560 2561
{
	struct ieee80211_local *local = sdata->local;
	struct ieee80211_supported_band *sband;
2562
	int rate, shift;
2563
	u8 i, exrates, *pos;
2564
	u32 basic_rates = sdata->vif.bss_conf.basic_rates;
2565 2566 2567 2568
	u32 rate_flags;

	rate_flags = ieee80211_chandef_rate_flags(&sdata->vif.bss_conf.chandef);
	shift = ieee80211_vif_get_shift(&sdata->vif);
2569

2570
	sband = local->hw.wiphy->bands[band];
2571 2572 2573 2574 2575 2576 2577
	exrates = 0;
	for (i = 0; i < sband->n_bitrates; i++) {
		if ((rate_flags & sband->bitrates[i].flags) != rate_flags)
			continue;
		exrates++;
	}

2578 2579 2580 2581 2582 2583 2584 2585 2586 2587 2588 2589 2590
	if (exrates > 8)
		exrates -= 8;
	else
		exrates = 0;

	if (skb_tailroom(skb) < exrates + 2)
		return -ENOMEM;

	if (exrates) {
		pos = skb_put(skb, exrates + 2);
		*pos++ = WLAN_EID_EXT_SUPP_RATES;
		*pos++ = exrates;
		for (i = 8; i < sband->n_bitrates; i++) {
2591
			u8 basic = 0;
2592 2593 2594
			if ((rate_flags & sband->bitrates[i].flags)
			    != rate_flags)
				continue;
2595 2596
			if (need_basic && basic_rates & BIT(i))
				basic = 0x80;
2597 2598 2599
			rate = DIV_ROUND_UP(sband->bitrates[i].bitrate,
					    5 * (1 << shift));
			*pos++ = basic | (u8) rate;
2600 2601 2602 2603
		}
	}
	return 0;
}
2604 2605 2606 2607 2608 2609

int ieee80211_ave_rssi(struct ieee80211_vif *vif)
{
	struct ieee80211_sub_if_data *sdata = vif_to_sdata(vif);
	struct ieee80211_if_managed *ifmgd = &sdata->u.mgd;

2610 2611 2612 2613
	if (WARN_ON_ONCE(sdata->vif.type != NL80211_IFTYPE_STATION)) {
		/* non-managed type inferfaces */
		return 0;
	}
2614
	return -ewma_beacon_signal_read(&ifmgd->ave_beacon_signal);
2615
}
2616
EXPORT_SYMBOL_GPL(ieee80211_ave_rssi);
2617 2618 2619 2620 2621 2622 2623 2624 2625 2626 2627 2628 2629 2630 2631 2632

u8 ieee80211_mcs_to_chains(const struct ieee80211_mcs_info *mcs)
{
	if (!mcs)
		return 1;

	/* TODO: consider rx_highest */

	if (mcs->rx_mask[3])
		return 4;
	if (mcs->rx_mask[2])
		return 3;
	if (mcs->rx_mask[1])
		return 2;
	return 1;
}
2633 2634 2635 2636 2637 2638 2639 2640 2641 2642 2643 2644 2645 2646 2647 2648 2649 2650 2651 2652 2653 2654 2655 2656 2657 2658 2659 2660 2661 2662 2663

/**
 * ieee80211_calculate_rx_timestamp - calculate timestamp in frame
 * @local: mac80211 hw info struct
 * @status: RX status
 * @mpdu_len: total MPDU length (including FCS)
 * @mpdu_offset: offset into MPDU to calculate timestamp at
 *
 * This function calculates the RX timestamp at the given MPDU offset, taking
 * into account what the RX timestamp was. An offset of 0 will just normalize
 * the timestamp to TSF at beginning of MPDU reception.
 */
u64 ieee80211_calculate_rx_timestamp(struct ieee80211_local *local,
				     struct ieee80211_rx_status *status,
				     unsigned int mpdu_len,
				     unsigned int mpdu_offset)
{
	u64 ts = status->mactime;
	struct rate_info ri;
	u16 rate;

	if (WARN_ON(!ieee80211_have_rx_timestamp(status)))
		return 0;

	memset(&ri, 0, sizeof(ri));

	/* Fill cfg80211 rate info */
	if (status->flag & RX_FLAG_HT) {
		ri.mcs = status->rate_idx;
		ri.flags |= RATE_INFO_FLAGS_MCS;
		if (status->flag & RX_FLAG_40MHZ)
2664 2665 2666
			ri.bw = RATE_INFO_BW_40;
		else
			ri.bw = RATE_INFO_BW_20;
2667 2668
		if (status->flag & RX_FLAG_SHORT_GI)
			ri.flags |= RATE_INFO_FLAGS_SHORT_GI;
2669 2670 2671 2672 2673
	} else if (status->flag & RX_FLAG_VHT) {
		ri.flags |= RATE_INFO_FLAGS_VHT_MCS;
		ri.mcs = status->rate_idx;
		ri.nss = status->vht_nss;
		if (status->flag & RX_FLAG_40MHZ)
2674 2675 2676 2677 2678 2679 2680
			ri.bw = RATE_INFO_BW_40;
		else if (status->vht_flag & RX_VHT_FLAG_80MHZ)
			ri.bw = RATE_INFO_BW_80;
		else if (status->vht_flag & RX_VHT_FLAG_160MHZ)
			ri.bw = RATE_INFO_BW_160;
		else
			ri.bw = RATE_INFO_BW_20;
2681 2682
		if (status->flag & RX_FLAG_SHORT_GI)
			ri.flags |= RATE_INFO_FLAGS_SHORT_GI;
2683 2684
	} else {
		struct ieee80211_supported_band *sband;
2685 2686 2687
		int shift = 0;
		int bitrate;

2688
		if (status->flag & RX_FLAG_10MHZ) {
2689
			shift = 1;
2690 2691
			ri.bw = RATE_INFO_BW_10;
		} else if (status->flag & RX_FLAG_5MHZ) {
2692
			shift = 2;
2693 2694 2695 2696
			ri.bw = RATE_INFO_BW_5;
		} else {
			ri.bw = RATE_INFO_BW_20;
		}
2697 2698

		sband = local->hw.wiphy->bands[status->band];
2699 2700
		bitrate = sband->bitrates[status->rate_idx].bitrate;
		ri.legacy = DIV_ROUND_UP(bitrate, (1 << shift));
2701 2702 2703 2704 2705 2706 2707 2708 2709 2710 2711 2712

		if (status->flag & RX_FLAG_MACTIME_PLCP_START) {
			/* TODO: handle HT/VHT preambles */
			if (status->band == IEEE80211_BAND_5GHZ) {
				ts += 20 << shift;
				mpdu_offset += 2;
			} else if (status->flag & RX_FLAG_SHORTPRE) {
				ts += 96;
			} else {
				ts += 192;
			}
		}
2713 2714 2715
	}

	rate = cfg80211_calculate_bitrate(&ri);
2716 2717 2718 2719
	if (WARN_ONCE(!rate,
		      "Invalid bitrate: flags=0x%x, idx=%d, vht_nss=%d\n",
		      status->flag, status->rate_idx, status->vht_nss))
		return 0;
2720 2721 2722 2723 2724 2725 2726 2727 2728

	/* rewind from end of MPDU */
	if (status->flag & RX_FLAG_MACTIME_END)
		ts -= mpdu_len * 8 * 10 / rate;

	ts += mpdu_offset * 8 * 10 / rate;

	return ts;
}
2729 2730 2731 2732

void ieee80211_dfs_cac_cancel(struct ieee80211_local *local)
{
	struct ieee80211_sub_if_data *sdata;
2733
	struct cfg80211_chan_def chandef;
2734

2735
	mutex_lock(&local->mtx);
2736 2737
	mutex_lock(&local->iflist_mtx);
	list_for_each_entry(sdata, &local->interfaces, list) {
2738 2739 2740 2741 2742
		/* it might be waiting for the local->mtx, but then
		 * by the time it gets it, sdata->wdev.cac_started
		 * will no longer be true
		 */
		cancel_delayed_work(&sdata->dfs_cac_timer_work);
2743 2744

		if (sdata->wdev.cac_started) {
2745
			chandef = sdata->vif.bss_conf.chandef;
2746 2747
			ieee80211_vif_release_channel(sdata);
			cfg80211_cac_event(sdata->dev,
2748
					   &chandef,
2749 2750 2751 2752 2753
					   NL80211_RADAR_CAC_ABORTED,
					   GFP_KERNEL);
		}
	}
	mutex_unlock(&local->iflist_mtx);
2754
	mutex_unlock(&local->mtx);
2755 2756 2757 2758 2759 2760
}

void ieee80211_dfs_radar_detected_work(struct work_struct *work)
{
	struct ieee80211_local *local =
		container_of(work, struct ieee80211_local, radar_detected_work);
2761
	struct cfg80211_chan_def chandef = local->hw.conf.chandef;
2762 2763 2764 2765 2766 2767 2768 2769 2770 2771 2772 2773
	struct ieee80211_chanctx *ctx;
	int num_chanctx = 0;

	mutex_lock(&local->chanctx_mtx);
	list_for_each_entry(ctx, &local->chanctx_list, list) {
		if (ctx->replace_state == IEEE80211_CHANCTX_REPLACES_OTHER)
			continue;

		num_chanctx++;
		chandef = ctx->conf.def;
	}
	mutex_unlock(&local->chanctx_mtx);
2774 2775 2776

	ieee80211_dfs_cac_cancel(local);

2777 2778
	if (num_chanctx > 1)
		/* XXX: multi-channel is not supported yet */
2779
		WARN_ON(1);
2780
	else
2781 2782 2783 2784 2785 2786 2787 2788 2789 2790 2791 2792
		cfg80211_radar_event(local->hw.wiphy, &chandef, GFP_KERNEL);
}

void ieee80211_radar_detected(struct ieee80211_hw *hw)
{
	struct ieee80211_local *local = hw_to_local(hw);

	trace_api_radar_detected(local);

	ieee80211_queue_work(hw, &local->radar_detected_work);
}
EXPORT_SYMBOL(ieee80211_radar_detected);
2793 2794 2795 2796 2797 2798 2799 2800 2801 2802 2803 2804 2805 2806 2807 2808 2809 2810 2811 2812 2813 2814 2815 2816 2817 2818 2819 2820 2821 2822 2823 2824 2825 2826 2827 2828 2829 2830 2831 2832 2833 2834 2835 2836 2837 2838 2839 2840 2841 2842 2843 2844 2845 2846 2847 2848 2849 2850 2851 2852

u32 ieee80211_chandef_downgrade(struct cfg80211_chan_def *c)
{
	u32 ret;
	int tmp;

	switch (c->width) {
	case NL80211_CHAN_WIDTH_20:
		c->width = NL80211_CHAN_WIDTH_20_NOHT;
		ret = IEEE80211_STA_DISABLE_HT | IEEE80211_STA_DISABLE_VHT;
		break;
	case NL80211_CHAN_WIDTH_40:
		c->width = NL80211_CHAN_WIDTH_20;
		c->center_freq1 = c->chan->center_freq;
		ret = IEEE80211_STA_DISABLE_40MHZ |
		      IEEE80211_STA_DISABLE_VHT;
		break;
	case NL80211_CHAN_WIDTH_80:
		tmp = (30 + c->chan->center_freq - c->center_freq1)/20;
		/* n_P40 */
		tmp /= 2;
		/* freq_P40 */
		c->center_freq1 = c->center_freq1 - 20 + 40 * tmp;
		c->width = NL80211_CHAN_WIDTH_40;
		ret = IEEE80211_STA_DISABLE_VHT;
		break;
	case NL80211_CHAN_WIDTH_80P80:
		c->center_freq2 = 0;
		c->width = NL80211_CHAN_WIDTH_80;
		ret = IEEE80211_STA_DISABLE_80P80MHZ |
		      IEEE80211_STA_DISABLE_160MHZ;
		break;
	case NL80211_CHAN_WIDTH_160:
		/* n_P20 */
		tmp = (70 + c->chan->center_freq - c->center_freq1)/20;
		/* n_P80 */
		tmp /= 4;
		c->center_freq1 = c->center_freq1 - 40 + 80 * tmp;
		c->width = NL80211_CHAN_WIDTH_80;
		ret = IEEE80211_STA_DISABLE_80P80MHZ |
		      IEEE80211_STA_DISABLE_160MHZ;
		break;
	default:
	case NL80211_CHAN_WIDTH_20_NOHT:
		WARN_ON_ONCE(1);
		c->width = NL80211_CHAN_WIDTH_20_NOHT;
		ret = IEEE80211_STA_DISABLE_HT | IEEE80211_STA_DISABLE_VHT;
		break;
	case NL80211_CHAN_WIDTH_5:
	case NL80211_CHAN_WIDTH_10:
		WARN_ON_ONCE(1);
		/* keep c->width */
		ret = IEEE80211_STA_DISABLE_HT | IEEE80211_STA_DISABLE_VHT;
		break;
	}

	WARN_ON_ONCE(!cfg80211_chandef_valid(c));

	return ret;
}
2853 2854 2855 2856 2857 2858 2859 2860 2861 2862 2863 2864 2865 2866 2867 2868 2869 2870 2871 2872 2873 2874 2875 2876 2877

/*
 * Returns true if smps_mode_new is strictly more restrictive than
 * smps_mode_old.
 */
bool ieee80211_smps_is_restrictive(enum ieee80211_smps_mode smps_mode_old,
				   enum ieee80211_smps_mode smps_mode_new)
{
	if (WARN_ON_ONCE(smps_mode_old == IEEE80211_SMPS_AUTOMATIC ||
			 smps_mode_new == IEEE80211_SMPS_AUTOMATIC))
		return false;

	switch (smps_mode_old) {
	case IEEE80211_SMPS_STATIC:
		return false;
	case IEEE80211_SMPS_DYNAMIC:
		return smps_mode_new == IEEE80211_SMPS_STATIC;
	case IEEE80211_SMPS_OFF:
		return smps_mode_new != IEEE80211_SMPS_OFF;
	default:
		WARN_ON(1);
	}

	return false;
}
2878 2879 2880 2881 2882 2883 2884 2885 2886 2887 2888 2889 2890 2891 2892 2893 2894 2895 2896 2897 2898 2899 2900 2901 2902 2903 2904 2905 2906 2907 2908 2909 2910 2911 2912 2913 2914 2915 2916 2917 2918 2919 2920 2921 2922 2923 2924 2925 2926 2927 2928 2929 2930 2931 2932 2933 2934 2935 2936 2937 2938 2939 2940 2941 2942 2943 2944 2945 2946 2947 2948 2949 2950

int ieee80211_send_action_csa(struct ieee80211_sub_if_data *sdata,
			      struct cfg80211_csa_settings *csa_settings)
{
	struct sk_buff *skb;
	struct ieee80211_mgmt *mgmt;
	struct ieee80211_local *local = sdata->local;
	int freq;
	int hdr_len = offsetof(struct ieee80211_mgmt, u.action.u.chan_switch) +
			       sizeof(mgmt->u.action.u.chan_switch);
	u8 *pos;

	if (sdata->vif.type != NL80211_IFTYPE_ADHOC &&
	    sdata->vif.type != NL80211_IFTYPE_MESH_POINT)
		return -EOPNOTSUPP;

	skb = dev_alloc_skb(local->tx_headroom + hdr_len +
			    5 + /* channel switch announcement element */
			    3 + /* secondary channel offset element */
			    8); /* mesh channel switch parameters element */
	if (!skb)
		return -ENOMEM;

	skb_reserve(skb, local->tx_headroom);
	mgmt = (struct ieee80211_mgmt *)skb_put(skb, hdr_len);
	memset(mgmt, 0, hdr_len);
	mgmt->frame_control = cpu_to_le16(IEEE80211_FTYPE_MGMT |
					  IEEE80211_STYPE_ACTION);

	eth_broadcast_addr(mgmt->da);
	memcpy(mgmt->sa, sdata->vif.addr, ETH_ALEN);
	if (ieee80211_vif_is_mesh(&sdata->vif)) {
		memcpy(mgmt->bssid, sdata->vif.addr, ETH_ALEN);
	} else {
		struct ieee80211_if_ibss *ifibss = &sdata->u.ibss;
		memcpy(mgmt->bssid, ifibss->bssid, ETH_ALEN);
	}
	mgmt->u.action.category = WLAN_CATEGORY_SPECTRUM_MGMT;
	mgmt->u.action.u.chan_switch.action_code = WLAN_ACTION_SPCT_CHL_SWITCH;
	pos = skb_put(skb, 5);
	*pos++ = WLAN_EID_CHANNEL_SWITCH;			/* EID */
	*pos++ = 3;						/* IE length */
	*pos++ = csa_settings->block_tx ? 1 : 0;		/* CSA mode */
	freq = csa_settings->chandef.chan->center_freq;
	*pos++ = ieee80211_frequency_to_channel(freq);		/* channel */
	*pos++ = csa_settings->count;				/* count */

	if (csa_settings->chandef.width == NL80211_CHAN_WIDTH_40) {
		enum nl80211_channel_type ch_type;

		skb_put(skb, 3);
		*pos++ = WLAN_EID_SECONDARY_CHANNEL_OFFSET;	/* EID */
		*pos++ = 1;					/* IE length */
		ch_type = cfg80211_get_chandef_type(&csa_settings->chandef);
		if (ch_type == NL80211_CHAN_HT40PLUS)
			*pos++ = IEEE80211_HT_PARAM_CHA_SEC_ABOVE;
		else
			*pos++ = IEEE80211_HT_PARAM_CHA_SEC_BELOW;
	}

	if (ieee80211_vif_is_mesh(&sdata->vif)) {
		struct ieee80211_if_mesh *ifmsh = &sdata->u.mesh;

		skb_put(skb, 8);
		*pos++ = WLAN_EID_CHAN_SWITCH_PARAM;		/* EID */
		*pos++ = 6;					/* IE length */
		*pos++ = sdata->u.mesh.mshcfg.dot11MeshTTL;	/* Mesh TTL */
		*pos = 0x00;	/* Mesh Flag: Tx Restrict, Initiator, Reason */
		*pos |= WLAN_EID_CHAN_SWITCH_PARAM_INITIATOR;
		*pos++ |= csa_settings->block_tx ?
			  WLAN_EID_CHAN_SWITCH_PARAM_TX_RESTRICT : 0x00;
		put_unaligned_le16(WLAN_REASON_MESH_CHAN, pos); /* Reason Cd */
		pos += 2;
2951
		put_unaligned_le16(ifmsh->pre_value, pos);/* Precedence Value */
2952 2953 2954 2955 2956 2957
		pos += 2;
	}

	ieee80211_tx_skb(sdata, skb);
	return 0;
}
2958 2959 2960 2961 2962 2963 2964 2965 2966 2967 2968 2969 2970 2971 2972 2973 2974 2975 2976 2977 2978 2979 2980 2981 2982 2983 2984 2985 2986 2987 2988 2989 2990 2991 2992 2993 2994 2995 2996 2997 2998 2999 3000 3001 3002 3003 3004 3005 3006 3007 3008 3009 3010 3011 3012 3013 3014 3015 3016 3017 3018 3019 3020 3021 3022 3023 3024 3025

bool ieee80211_cs_valid(const struct ieee80211_cipher_scheme *cs)
{
	return !(cs == NULL || cs->cipher == 0 ||
		 cs->hdr_len < cs->pn_len + cs->pn_off ||
		 cs->hdr_len <= cs->key_idx_off ||
		 cs->key_idx_shift > 7 ||
		 cs->key_idx_mask == 0);
}

bool ieee80211_cs_list_valid(const struct ieee80211_cipher_scheme *cs, int n)
{
	int i;

	/* Ensure we have enough iftype bitmap space for all iftype values */
	WARN_ON((NUM_NL80211_IFTYPES / 8 + 1) > sizeof(cs[0].iftype));

	for (i = 0; i < n; i++)
		if (!ieee80211_cs_valid(&cs[i]))
			return false;

	return true;
}

const struct ieee80211_cipher_scheme *
ieee80211_cs_get(struct ieee80211_local *local, u32 cipher,
		 enum nl80211_iftype iftype)
{
	const struct ieee80211_cipher_scheme *l = local->hw.cipher_schemes;
	int n = local->hw.n_cipher_schemes;
	int i;
	const struct ieee80211_cipher_scheme *cs = NULL;

	for (i = 0; i < n; i++) {
		if (l[i].cipher == cipher) {
			cs = &l[i];
			break;
		}
	}

	if (!cs || !(cs->iftype & BIT(iftype)))
		return NULL;

	return cs;
}

int ieee80211_cs_headroom(struct ieee80211_local *local,
			  struct cfg80211_crypto_settings *crypto,
			  enum nl80211_iftype iftype)
{
	const struct ieee80211_cipher_scheme *cs;
	int headroom = IEEE80211_ENCRYPT_HEADROOM;
	int i;

	for (i = 0; i < crypto->n_ciphers_pairwise; i++) {
		cs = ieee80211_cs_get(local, crypto->ciphers_pairwise[i],
				      iftype);

		if (cs && headroom < cs->hdr_len)
			headroom = cs->hdr_len;
	}

	cs = ieee80211_cs_get(local, crypto->cipher_group, iftype);
	if (cs && headroom < cs->hdr_len)
		headroom = cs->hdr_len;

	return headroom;
}
3026 3027 3028 3029 3030 3031 3032 3033 3034 3035

static bool
ieee80211_extend_noa_desc(struct ieee80211_noa_data *data, u32 tsf, int i)
{
	s32 end = data->desc[i].start + data->desc[i].duration - (tsf + 1);
	int skip;

	if (end > 0)
		return false;

3036 3037 3038 3039 3040 3041 3042
	/* One shot NOA  */
	if (data->count[i] == 1)
		return false;

	if (data->desc[i].interval == 0)
		return false;

3043 3044 3045 3046 3047 3048 3049 3050 3051 3052 3053 3054 3055 3056 3057 3058 3059 3060 3061 3062 3063 3064 3065 3066 3067 3068 3069 3070 3071 3072 3073 3074 3075 3076 3077 3078 3079 3080 3081 3082 3083 3084 3085 3086 3087 3088 3089 3090 3091 3092 3093 3094 3095 3096 3097 3098 3099 3100 3101 3102 3103 3104 3105 3106 3107 3108 3109 3110 3111 3112 3113 3114 3115 3116 3117 3118 3119 3120 3121 3122 3123 3124 3125 3126 3127 3128 3129 3130 3131 3132 3133 3134 3135 3136 3137 3138 3139 3140 3141 3142 3143 3144 3145 3146 3147 3148 3149 3150 3151 3152 3153 3154 3155 3156 3157 3158 3159 3160 3161 3162 3163 3164 3165 3166 3167 3168 3169 3170 3171 3172
	/* End time is in the past, check for repetitions */
	skip = DIV_ROUND_UP(-end, data->desc[i].interval);
	if (data->count[i] < 255) {
		if (data->count[i] <= skip) {
			data->count[i] = 0;
			return false;
		}

		data->count[i] -= skip;
	}

	data->desc[i].start += skip * data->desc[i].interval;

	return true;
}

static bool
ieee80211_extend_absent_time(struct ieee80211_noa_data *data, u32 tsf,
			     s32 *offset)
{
	bool ret = false;
	int i;

	for (i = 0; i < IEEE80211_P2P_NOA_DESC_MAX; i++) {
		s32 cur;

		if (!data->count[i])
			continue;

		if (ieee80211_extend_noa_desc(data, tsf + *offset, i))
			ret = true;

		cur = data->desc[i].start - tsf;
		if (cur > *offset)
			continue;

		cur = data->desc[i].start + data->desc[i].duration - tsf;
		if (cur > *offset)
			*offset = cur;
	}

	return ret;
}

static u32
ieee80211_get_noa_absent_time(struct ieee80211_noa_data *data, u32 tsf)
{
	s32 offset = 0;
	int tries = 0;
	/*
	 * arbitrary limit, used to avoid infinite loops when combined NoA
	 * descriptors cover the full time period.
	 */
	int max_tries = 5;

	ieee80211_extend_absent_time(data, tsf, &offset);
	do {
		if (!ieee80211_extend_absent_time(data, tsf, &offset))
			break;

		tries++;
	} while (tries < max_tries);

	return offset;
}

void ieee80211_update_p2p_noa(struct ieee80211_noa_data *data, u32 tsf)
{
	u32 next_offset = BIT(31) - 1;
	int i;

	data->absent = 0;
	data->has_next_tsf = false;
	for (i = 0; i < IEEE80211_P2P_NOA_DESC_MAX; i++) {
		s32 start;

		if (!data->count[i])
			continue;

		ieee80211_extend_noa_desc(data, tsf, i);
		start = data->desc[i].start - tsf;
		if (start <= 0)
			data->absent |= BIT(i);

		if (next_offset > start)
			next_offset = start;

		data->has_next_tsf = true;
	}

	if (data->absent)
		next_offset = ieee80211_get_noa_absent_time(data, tsf);

	data->next_tsf = tsf + next_offset;
}
EXPORT_SYMBOL(ieee80211_update_p2p_noa);

int ieee80211_parse_p2p_noa(const struct ieee80211_p2p_noa_attr *attr,
			    struct ieee80211_noa_data *data, u32 tsf)
{
	int ret = 0;
	int i;

	memset(data, 0, sizeof(*data));

	for (i = 0; i < IEEE80211_P2P_NOA_DESC_MAX; i++) {
		const struct ieee80211_p2p_noa_desc *desc = &attr->desc[i];

		if (!desc->count || !desc->duration)
			continue;

		data->count[i] = desc->count;
		data->desc[i].start = le32_to_cpu(desc->start_time);
		data->desc[i].duration = le32_to_cpu(desc->duration);
		data->desc[i].interval = le32_to_cpu(desc->interval);

		if (data->count[i] > 1 &&
		    data->desc[i].interval < data->desc[i].duration)
			continue;

		ieee80211_extend_noa_desc(data, tsf, i);
		ret++;
	}

	if (ret)
		ieee80211_update_p2p_noa(data, tsf);

	return ret;
}
EXPORT_SYMBOL(ieee80211_parse_p2p_noa);
3173 3174 3175 3176 3177 3178 3179 3180 3181 3182 3183 3184 3185 3186 3187 3188 3189 3190 3191 3192 3193 3194 3195 3196 3197 3198 3199 3200 3201 3202 3203 3204 3205 3206 3207 3208 3209 3210 3211 3212 3213

void ieee80211_recalc_dtim(struct ieee80211_local *local,
			   struct ieee80211_sub_if_data *sdata)
{
	u64 tsf = drv_get_tsf(local, sdata);
	u64 dtim_count = 0;
	u16 beacon_int = sdata->vif.bss_conf.beacon_int * 1024;
	u8 dtim_period = sdata->vif.bss_conf.dtim_period;
	struct ps_data *ps;
	u8 bcns_from_dtim;

	if (tsf == -1ULL || !beacon_int || !dtim_period)
		return;

	if (sdata->vif.type == NL80211_IFTYPE_AP ||
	    sdata->vif.type == NL80211_IFTYPE_AP_VLAN) {
		if (!sdata->bss)
			return;

		ps = &sdata->bss->ps;
	} else if (ieee80211_vif_is_mesh(&sdata->vif)) {
		ps = &sdata->u.mesh.ps;
	} else {
		return;
	}

	/*
	 * actually finds last dtim_count, mac80211 will update in
	 * __beacon_add_tim().
	 * dtim_count = dtim_period - (tsf / bcn_int) % dtim_period
	 */
	do_div(tsf, beacon_int);
	bcns_from_dtim = do_div(tsf, dtim_period);
	/* just had a DTIM */
	if (!bcns_from_dtim)
		dtim_count = 0;
	else
		dtim_count = dtim_period - bcns_from_dtim;

	ps->dtim_count = dtim_count;
}
3214

3215 3216 3217 3218 3219 3220 3221 3222 3223 3224 3225 3226 3227 3228 3229 3230 3231 3232 3233 3234 3235 3236 3237 3238 3239 3240 3241 3242 3243
static u8 ieee80211_chanctx_radar_detect(struct ieee80211_local *local,
					 struct ieee80211_chanctx *ctx)
{
	struct ieee80211_sub_if_data *sdata;
	u8 radar_detect = 0;

	lockdep_assert_held(&local->chanctx_mtx);

	if (WARN_ON(ctx->replace_state == IEEE80211_CHANCTX_WILL_BE_REPLACED))
		return 0;

	list_for_each_entry(sdata, &ctx->reserved_vifs, reserved_chanctx_list)
		if (sdata->reserved_radar_required)
			radar_detect |= BIT(sdata->reserved_chandef.width);

	/*
	 * An in-place reservation context should not have any assigned vifs
	 * until it replaces the other context.
	 */
	WARN_ON(ctx->replace_state == IEEE80211_CHANCTX_REPLACES_OTHER &&
		!list_empty(&ctx->assigned_vifs));

	list_for_each_entry(sdata, &ctx->assigned_vifs, assigned_chanctx_list)
		if (sdata->radar_required)
			radar_detect |= BIT(sdata->vif.bss_conf.chandef.width);

	return radar_detect;
}

3244 3245 3246 3247 3248 3249 3250 3251 3252 3253
int ieee80211_check_combinations(struct ieee80211_sub_if_data *sdata,
				 const struct cfg80211_chan_def *chandef,
				 enum ieee80211_chanctx_mode chanmode,
				 u8 radar_detect)
{
	struct ieee80211_local *local = sdata->local;
	struct ieee80211_sub_if_data *sdata_iter;
	enum nl80211_iftype iftype = sdata->wdev.iftype;
	int num[NUM_NL80211_IFTYPES];
	struct ieee80211_chanctx *ctx;
3254
	int num_different_channels = 0;
3255 3256 3257 3258 3259 3260 3261
	int total = 1;

	lockdep_assert_held(&local->chanctx_mtx);

	if (WARN_ON(hweight32(radar_detect) > 1))
		return -EINVAL;

3262 3263
	if (WARN_ON(chandef && chanmode == IEEE80211_CHANCTX_SHARED &&
		    !chandef->chan))
3264 3265
		return -EINVAL;

3266 3267 3268
	if (chandef)
		num_different_channels = 1;

3269 3270 3271 3272 3273 3274 3275 3276 3277 3278 3279 3280 3281 3282 3283 3284
	if (WARN_ON(iftype >= NUM_NL80211_IFTYPES))
		return -EINVAL;

	/* Always allow software iftypes */
	if (local->hw.wiphy->software_iftypes & BIT(iftype)) {
		if (radar_detect)
			return -EINVAL;
		return 0;
	}

	memset(num, 0, sizeof(num));

	if (iftype != NL80211_IFTYPE_UNSPECIFIED)
		num[iftype] = 1;

	list_for_each_entry(ctx, &local->chanctx_list, list) {
3285 3286
		if (ctx->replace_state == IEEE80211_CHANCTX_WILL_BE_REPLACED)
			continue;
3287
		radar_detect |= ieee80211_chanctx_radar_detect(local, ctx);
3288 3289 3290 3291
		if (ctx->mode == IEEE80211_CHANCTX_EXCLUSIVE) {
			num_different_channels++;
			continue;
		}
3292
		if (chandef && chanmode == IEEE80211_CHANCTX_SHARED &&
3293 3294 3295 3296 3297 3298 3299 3300 3301 3302 3303 3304
		    cfg80211_chandef_compatible(chandef,
						&ctx->conf.def))
			continue;
		num_different_channels++;
	}

	list_for_each_entry_rcu(sdata_iter, &local->interfaces, list) {
		struct wireless_dev *wdev_iter;

		wdev_iter = &sdata_iter->wdev;

		if (sdata_iter == sdata ||
3305
		    !ieee80211_sdata_running(sdata_iter) ||
3306 3307 3308 3309 3310 3311 3312 3313 3314 3315 3316 3317 3318 3319
		    local->hw.wiphy->software_iftypes & BIT(wdev_iter->iftype))
			continue;

		num[wdev_iter->iftype]++;
		total++;
	}

	if (total == 1 && !radar_detect)
		return 0;

	return cfg80211_check_combinations(local->hw.wiphy,
					   num_different_channels,
					   radar_detect, num);
}
3320 3321 3322 3323 3324 3325 3326 3327 3328 3329 3330 3331 3332 3333 3334 3335 3336 3337 3338 3339 3340 3341 3342 3343

static void
ieee80211_iter_max_chans(const struct ieee80211_iface_combination *c,
			 void *data)
{
	u32 *max_num_different_channels = data;

	*max_num_different_channels = max(*max_num_different_channels,
					  c->num_different_channels);
}

int ieee80211_max_num_channels(struct ieee80211_local *local)
{
	struct ieee80211_sub_if_data *sdata;
	int num[NUM_NL80211_IFTYPES] = {};
	struct ieee80211_chanctx *ctx;
	int num_different_channels = 0;
	u8 radar_detect = 0;
	u32 max_num_different_channels = 1;
	int err;

	lockdep_assert_held(&local->chanctx_mtx);

	list_for_each_entry(ctx, &local->chanctx_list, list) {
3344 3345 3346
		if (ctx->replace_state == IEEE80211_CHANCTX_WILL_BE_REPLACED)
			continue;

3347 3348
		num_different_channels++;

3349
		radar_detect |= ieee80211_chanctx_radar_detect(local, ctx);
3350 3351 3352 3353 3354 3355 3356 3357 3358 3359 3360 3361 3362 3363
	}

	list_for_each_entry_rcu(sdata, &local->interfaces, list)
		num[sdata->wdev.iftype]++;

	err = cfg80211_iter_combinations(local->hw.wiphy,
					 num_different_channels, radar_detect,
					 num, ieee80211_iter_max_chans,
					 &max_num_different_channels);
	if (err < 0)
		return err;

	return max_num_different_channels;
}
3364 3365 3366 3367 3368 3369 3370 3371 3372 3373 3374 3375 3376 3377 3378

u8 *ieee80211_add_wmm_info_ie(u8 *buf, u8 qosinfo)
{
	*buf++ = WLAN_EID_VENDOR_SPECIFIC;
	*buf++ = 7; /* len */
	*buf++ = 0x00; /* Microsoft OUI 00:50:F2 */
	*buf++ = 0x50;
	*buf++ = 0xf2;
	*buf++ = 2; /* WME */
	*buf++ = 0; /* WME info */
	*buf++ = 1; /* WME ver */
	*buf++ = qosinfo; /* U-APSD no in use */

	return buf;
}
3379 3380 3381 3382 3383 3384 3385 3386 3387 3388 3389

void ieee80211_init_tx_queue(struct ieee80211_sub_if_data *sdata,
			     struct sta_info *sta,
			     struct txq_info *txqi, int tid)
{
	skb_queue_head_init(&txqi->queue);
	txqi->txq.vif = &sdata->vif;

	if (sta) {
		txqi->txq.sta = &sta->sta;
		sta->sta.txq[tid] = &txqi->txq;
3390
		txqi->txq.tid = tid;
3391 3392 3393
		txqi->txq.ac = ieee802_1d_to_ac[tid & 7];
	} else {
		sdata->vif.txq = &txqi->txq;
3394
		txqi->txq.tid = 0;
3395 3396 3397
		txqi->txq.ac = IEEE80211_AC_BE;
	}
}
3398 3399 3400 3401 3402 3403 3404 3405 3406 3407 3408 3409 3410 3411

void ieee80211_txq_get_depth(struct ieee80211_txq *txq,
			     unsigned long *frame_cnt,
			     unsigned long *byte_cnt)
{
	struct txq_info *txqi = to_txq_info(txq);

	if (frame_cnt)
		*frame_cnt = txqi->queue.qlen;

	if (byte_cnt)
		*byte_cnt = txqi->byte_cnt;
}
EXPORT_SYMBOL(ieee80211_txq_get_depth);