xref: /linux/net/mac80211/tx.c (revision 3932b9ca55b0be314a36d3e84faff3e823c081f5)
1 /*
2  * Copyright 2002-2005, Instant802 Networks, Inc.
3  * Copyright 2005-2006, Devicescape Software, Inc.
4  * Copyright 2006-2007	Jiri Benc <jbenc@suse.cz>
5  * Copyright 2007	Johannes Berg <johannes@sipsolutions.net>
6  *
7  * This program is free software; you can redistribute it and/or modify
8  * it under the terms of the GNU General Public License version 2 as
9  * published by the Free Software Foundation.
10  *
11  *
12  * Transmit and frame generation functions.
13  */
14 
15 #include <linux/kernel.h>
16 #include <linux/slab.h>
17 #include <linux/skbuff.h>
18 #include <linux/etherdevice.h>
19 #include <linux/bitmap.h>
20 #include <linux/rcupdate.h>
21 #include <linux/export.h>
22 #include <linux/time.h>
23 #include <net/net_namespace.h>
24 #include <net/ieee80211_radiotap.h>
25 #include <net/cfg80211.h>
26 #include <net/mac80211.h>
27 #include <asm/unaligned.h>
28 
29 #include "ieee80211_i.h"
30 #include "driver-ops.h"
31 #include "led.h"
32 #include "mesh.h"
33 #include "wep.h"
34 #include "wpa.h"
35 #include "wme.h"
36 #include "rate.h"
37 
38 /* misc utils */
39 
40 static __le16 ieee80211_duration(struct ieee80211_tx_data *tx,
41 				 struct sk_buff *skb, int group_addr,
42 				 int next_frag_len)
43 {
44 	int rate, mrate, erp, dur, i, shift = 0;
45 	struct ieee80211_rate *txrate;
46 	struct ieee80211_local *local = tx->local;
47 	struct ieee80211_supported_band *sband;
48 	struct ieee80211_hdr *hdr;
49 	struct ieee80211_tx_info *info = IEEE80211_SKB_CB(skb);
50 	struct ieee80211_chanctx_conf *chanctx_conf;
51 	u32 rate_flags = 0;
52 
53 	rcu_read_lock();
54 	chanctx_conf = rcu_dereference(tx->sdata->vif.chanctx_conf);
55 	if (chanctx_conf) {
56 		shift = ieee80211_chandef_get_shift(&chanctx_conf->def);
57 		rate_flags = ieee80211_chandef_rate_flags(&chanctx_conf->def);
58 	}
59 	rcu_read_unlock();
60 
61 	/* assume HW handles this */
62 	if (tx->rate.flags & IEEE80211_TX_RC_MCS)
63 		return 0;
64 
65 	/* uh huh? */
66 	if (WARN_ON_ONCE(tx->rate.idx < 0))
67 		return 0;
68 
69 	sband = local->hw.wiphy->bands[info->band];
70 	txrate = &sband->bitrates[tx->rate.idx];
71 
72 	erp = txrate->flags & IEEE80211_RATE_ERP_G;
73 
74 	/*
75 	 * data and mgmt (except PS Poll):
76 	 * - during CFP: 32768
77 	 * - during contention period:
78 	 *   if addr1 is group address: 0
79 	 *   if more fragments = 0 and addr1 is individual address: time to
80 	 *      transmit one ACK plus SIFS
81 	 *   if more fragments = 1 and addr1 is individual address: time to
82 	 *      transmit next fragment plus 2 x ACK plus 3 x SIFS
83 	 *
84 	 * IEEE 802.11, 9.6:
85 	 * - control response frame (CTS or ACK) shall be transmitted using the
86 	 *   same rate as the immediately previous frame in the frame exchange
87 	 *   sequence, if this rate belongs to the PHY mandatory rates, or else
88 	 *   at the highest possible rate belonging to the PHY rates in the
89 	 *   BSSBasicRateSet
90 	 */
91 	hdr = (struct ieee80211_hdr *)skb->data;
92 	if (ieee80211_is_ctl(hdr->frame_control)) {
93 		/* TODO: These control frames are not currently sent by
94 		 * mac80211, but should they be implemented, this function
95 		 * needs to be updated to support duration field calculation.
96 		 *
97 		 * RTS: time needed to transmit pending data/mgmt frame plus
98 		 *    one CTS frame plus one ACK frame plus 3 x SIFS
99 		 * CTS: duration of immediately previous RTS minus time
100 		 *    required to transmit CTS and its SIFS
101 		 * ACK: 0 if immediately previous directed data/mgmt had
102 		 *    more=0, with more=1 duration in ACK frame is duration
103 		 *    from previous frame minus time needed to transmit ACK
104 		 *    and its SIFS
105 		 * PS Poll: BIT(15) | BIT(14) | aid
106 		 */
107 		return 0;
108 	}
109 
110 	/* data/mgmt */
111 	if (0 /* FIX: data/mgmt during CFP */)
112 		return cpu_to_le16(32768);
113 
114 	if (group_addr) /* Group address as the destination - no ACK */
115 		return 0;
116 
117 	/* Individual destination address:
118 	 * IEEE 802.11, Ch. 9.6 (after IEEE 802.11g changes)
119 	 * CTS and ACK frames shall be transmitted using the highest rate in
120 	 * basic rate set that is less than or equal to the rate of the
121 	 * immediately previous frame and that is using the same modulation
122 	 * (CCK or OFDM). If no basic rate set matches with these requirements,
123 	 * the highest mandatory rate of the PHY that is less than or equal to
124 	 * the rate of the previous frame is used.
125 	 * Mandatory rates for IEEE 802.11g PHY: 1, 2, 5.5, 11, 6, 12, 24 Mbps
126 	 */
127 	rate = -1;
128 	/* use lowest available if everything fails */
129 	mrate = sband->bitrates[0].bitrate;
130 	for (i = 0; i < sband->n_bitrates; i++) {
131 		struct ieee80211_rate *r = &sband->bitrates[i];
132 
133 		if (r->bitrate > txrate->bitrate)
134 			break;
135 
136 		if ((rate_flags & r->flags) != rate_flags)
137 			continue;
138 
139 		if (tx->sdata->vif.bss_conf.basic_rates & BIT(i))
140 			rate = DIV_ROUND_UP(r->bitrate, 1 << shift);
141 
142 		switch (sband->band) {
143 		case IEEE80211_BAND_2GHZ: {
144 			u32 flag;
145 			if (tx->sdata->flags & IEEE80211_SDATA_OPERATING_GMODE)
146 				flag = IEEE80211_RATE_MANDATORY_G;
147 			else
148 				flag = IEEE80211_RATE_MANDATORY_B;
149 			if (r->flags & flag)
150 				mrate = r->bitrate;
151 			break;
152 		}
153 		case IEEE80211_BAND_5GHZ:
154 			if (r->flags & IEEE80211_RATE_MANDATORY_A)
155 				mrate = r->bitrate;
156 			break;
157 		case IEEE80211_BAND_60GHZ:
158 			/* TODO, for now fall through */
159 		case IEEE80211_NUM_BANDS:
160 			WARN_ON(1);
161 			break;
162 		}
163 	}
164 	if (rate == -1) {
165 		/* No matching basic rate found; use highest suitable mandatory
166 		 * PHY rate */
167 		rate = DIV_ROUND_UP(mrate, 1 << shift);
168 	}
169 
170 	/* Don't calculate ACKs for QoS Frames with NoAck Policy set */
171 	if (ieee80211_is_data_qos(hdr->frame_control) &&
172 	    *(ieee80211_get_qos_ctl(hdr)) & IEEE80211_QOS_CTL_ACK_POLICY_NOACK)
173 		dur = 0;
174 	else
175 		/* Time needed to transmit ACK
176 		 * (10 bytes + 4-byte FCS = 112 bits) plus SIFS; rounded up
177 		 * to closest integer */
178 		dur = ieee80211_frame_duration(sband->band, 10, rate, erp,
179 				tx->sdata->vif.bss_conf.use_short_preamble,
180 				shift);
181 
182 	if (next_frag_len) {
183 		/* Frame is fragmented: duration increases with time needed to
184 		 * transmit next fragment plus ACK and 2 x SIFS. */
185 		dur *= 2; /* ACK + SIFS */
186 		/* next fragment */
187 		dur += ieee80211_frame_duration(sband->band, next_frag_len,
188 				txrate->bitrate, erp,
189 				tx->sdata->vif.bss_conf.use_short_preamble,
190 				shift);
191 	}
192 
193 	return cpu_to_le16(dur);
194 }
195 
196 /* tx handlers */
197 static ieee80211_tx_result debug_noinline
198 ieee80211_tx_h_dynamic_ps(struct ieee80211_tx_data *tx)
199 {
200 	struct ieee80211_local *local = tx->local;
201 	struct ieee80211_if_managed *ifmgd;
202 
203 	/* driver doesn't support power save */
204 	if (!(local->hw.flags & IEEE80211_HW_SUPPORTS_PS))
205 		return TX_CONTINUE;
206 
207 	/* hardware does dynamic power save */
208 	if (local->hw.flags & IEEE80211_HW_SUPPORTS_DYNAMIC_PS)
209 		return TX_CONTINUE;
210 
211 	/* dynamic power save disabled */
212 	if (local->hw.conf.dynamic_ps_timeout <= 0)
213 		return TX_CONTINUE;
214 
215 	/* we are scanning, don't enable power save */
216 	if (local->scanning)
217 		return TX_CONTINUE;
218 
219 	if (!local->ps_sdata)
220 		return TX_CONTINUE;
221 
222 	/* No point if we're going to suspend */
223 	if (local->quiescing)
224 		return TX_CONTINUE;
225 
226 	/* dynamic ps is supported only in managed mode */
227 	if (tx->sdata->vif.type != NL80211_IFTYPE_STATION)
228 		return TX_CONTINUE;
229 
230 	ifmgd = &tx->sdata->u.mgd;
231 
232 	/*
233 	 * Don't wakeup from power save if u-apsd is enabled, voip ac has
234 	 * u-apsd enabled and the frame is in voip class. This effectively
235 	 * means that even if all access categories have u-apsd enabled, in
236 	 * practise u-apsd is only used with the voip ac. This is a
237 	 * workaround for the case when received voip class packets do not
238 	 * have correct qos tag for some reason, due the network or the
239 	 * peer application.
240 	 *
241 	 * Note: ifmgd->uapsd_queues access is racy here. If the value is
242 	 * changed via debugfs, user needs to reassociate manually to have
243 	 * everything in sync.
244 	 */
245 	if ((ifmgd->flags & IEEE80211_STA_UAPSD_ENABLED) &&
246 	    (ifmgd->uapsd_queues & IEEE80211_WMM_IE_STA_QOSINFO_AC_VO) &&
247 	    skb_get_queue_mapping(tx->skb) == IEEE80211_AC_VO)
248 		return TX_CONTINUE;
249 
250 	if (local->hw.conf.flags & IEEE80211_CONF_PS) {
251 		ieee80211_stop_queues_by_reason(&local->hw,
252 						IEEE80211_MAX_QUEUE_MAP,
253 						IEEE80211_QUEUE_STOP_REASON_PS,
254 						false);
255 		ifmgd->flags &= ~IEEE80211_STA_NULLFUNC_ACKED;
256 		ieee80211_queue_work(&local->hw,
257 				     &local->dynamic_ps_disable_work);
258 	}
259 
260 	/* Don't restart the timer if we're not disassociated */
261 	if (!ifmgd->associated)
262 		return TX_CONTINUE;
263 
264 	mod_timer(&local->dynamic_ps_timer, jiffies +
265 		  msecs_to_jiffies(local->hw.conf.dynamic_ps_timeout));
266 
267 	return TX_CONTINUE;
268 }
269 
270 static ieee80211_tx_result debug_noinline
271 ieee80211_tx_h_check_assoc(struct ieee80211_tx_data *tx)
272 {
273 
274 	struct ieee80211_hdr *hdr = (struct ieee80211_hdr *)tx->skb->data;
275 	struct ieee80211_tx_info *info = IEEE80211_SKB_CB(tx->skb);
276 	bool assoc = false;
277 
278 	if (unlikely(info->flags & IEEE80211_TX_CTL_INJECTED))
279 		return TX_CONTINUE;
280 
281 	if (unlikely(test_bit(SCAN_SW_SCANNING, &tx->local->scanning)) &&
282 	    test_bit(SDATA_STATE_OFFCHANNEL, &tx->sdata->state) &&
283 	    !ieee80211_is_probe_req(hdr->frame_control) &&
284 	    !ieee80211_is_nullfunc(hdr->frame_control))
285 		/*
286 		 * When software scanning only nullfunc frames (to notify
287 		 * the sleep state to the AP) and probe requests (for the
288 		 * active scan) are allowed, all other frames should not be
289 		 * sent and we should not get here, but if we do
290 		 * nonetheless, drop them to avoid sending them
291 		 * off-channel. See the link below and
292 		 * ieee80211_start_scan() for more.
293 		 *
294 		 * http://article.gmane.org/gmane.linux.kernel.wireless.general/30089
295 		 */
296 		return TX_DROP;
297 
298 	if (tx->sdata->vif.type == NL80211_IFTYPE_WDS)
299 		return TX_CONTINUE;
300 
301 	if (tx->sdata->vif.type == NL80211_IFTYPE_MESH_POINT)
302 		return TX_CONTINUE;
303 
304 	if (tx->flags & IEEE80211_TX_PS_BUFFERED)
305 		return TX_CONTINUE;
306 
307 	if (tx->sta)
308 		assoc = test_sta_flag(tx->sta, WLAN_STA_ASSOC);
309 
310 	if (likely(tx->flags & IEEE80211_TX_UNICAST)) {
311 		if (unlikely(!assoc &&
312 			     ieee80211_is_data(hdr->frame_control))) {
313 #ifdef CONFIG_MAC80211_VERBOSE_DEBUG
314 			sdata_info(tx->sdata,
315 				   "dropped data frame to not associated station %pM\n",
316 				   hdr->addr1);
317 #endif
318 			I802_DEBUG_INC(tx->local->tx_handlers_drop_not_assoc);
319 			return TX_DROP;
320 		}
321 	} else if (unlikely(tx->sdata->vif.type == NL80211_IFTYPE_AP &&
322 			    ieee80211_is_data(hdr->frame_control) &&
323 			    !atomic_read(&tx->sdata->u.ap.num_mcast_sta))) {
324 		/*
325 		 * No associated STAs - no need to send multicast
326 		 * frames.
327 		 */
328 		return TX_DROP;
329 	}
330 
331 	return TX_CONTINUE;
332 }
333 
334 /* This function is called whenever the AP is about to exceed the maximum limit
335  * of buffered frames for power saving STAs. This situation should not really
336  * happen often during normal operation, so dropping the oldest buffered packet
337  * from each queue should be OK to make some room for new frames. */
338 static void purge_old_ps_buffers(struct ieee80211_local *local)
339 {
340 	int total = 0, purged = 0;
341 	struct sk_buff *skb;
342 	struct ieee80211_sub_if_data *sdata;
343 	struct sta_info *sta;
344 
345 	list_for_each_entry_rcu(sdata, &local->interfaces, list) {
346 		struct ps_data *ps;
347 
348 		if (sdata->vif.type == NL80211_IFTYPE_AP)
349 			ps = &sdata->u.ap.ps;
350 		else if (ieee80211_vif_is_mesh(&sdata->vif))
351 			ps = &sdata->u.mesh.ps;
352 		else
353 			continue;
354 
355 		skb = skb_dequeue(&ps->bc_buf);
356 		if (skb) {
357 			purged++;
358 			dev_kfree_skb(skb);
359 		}
360 		total += skb_queue_len(&ps->bc_buf);
361 	}
362 
363 	/*
364 	 * Drop one frame from each station from the lowest-priority
365 	 * AC that has frames at all.
366 	 */
367 	list_for_each_entry_rcu(sta, &local->sta_list, list) {
368 		int ac;
369 
370 		for (ac = IEEE80211_AC_BK; ac >= IEEE80211_AC_VO; ac--) {
371 			skb = skb_dequeue(&sta->ps_tx_buf[ac]);
372 			total += skb_queue_len(&sta->ps_tx_buf[ac]);
373 			if (skb) {
374 				purged++;
375 				ieee80211_free_txskb(&local->hw, skb);
376 				break;
377 			}
378 		}
379 	}
380 
381 	local->total_ps_buffered = total;
382 	ps_dbg_hw(&local->hw, "PS buffers full - purged %d frames\n", purged);
383 }
384 
385 static ieee80211_tx_result
386 ieee80211_tx_h_multicast_ps_buf(struct ieee80211_tx_data *tx)
387 {
388 	struct ieee80211_tx_info *info = IEEE80211_SKB_CB(tx->skb);
389 	struct ieee80211_hdr *hdr = (struct ieee80211_hdr *)tx->skb->data;
390 	struct ps_data *ps;
391 
392 	/*
393 	 * broadcast/multicast frame
394 	 *
395 	 * If any of the associated/peer stations is in power save mode,
396 	 * the frame is buffered to be sent after DTIM beacon frame.
397 	 * This is done either by the hardware or us.
398 	 */
399 
400 	/* powersaving STAs currently only in AP/VLAN/mesh mode */
401 	if (tx->sdata->vif.type == NL80211_IFTYPE_AP ||
402 	    tx->sdata->vif.type == NL80211_IFTYPE_AP_VLAN) {
403 		if (!tx->sdata->bss)
404 			return TX_CONTINUE;
405 
406 		ps = &tx->sdata->bss->ps;
407 	} else if (ieee80211_vif_is_mesh(&tx->sdata->vif)) {
408 		ps = &tx->sdata->u.mesh.ps;
409 	} else {
410 		return TX_CONTINUE;
411 	}
412 
413 
414 	/* no buffering for ordered frames */
415 	if (ieee80211_has_order(hdr->frame_control))
416 		return TX_CONTINUE;
417 
418 	if (ieee80211_is_probe_req(hdr->frame_control))
419 		return TX_CONTINUE;
420 
421 	if (tx->local->hw.flags & IEEE80211_HW_QUEUE_CONTROL)
422 		info->hw_queue = tx->sdata->vif.cab_queue;
423 
424 	/* no stations in PS mode */
425 	if (!atomic_read(&ps->num_sta_ps))
426 		return TX_CONTINUE;
427 
428 	info->flags |= IEEE80211_TX_CTL_SEND_AFTER_DTIM;
429 
430 	/* device releases frame after DTIM beacon */
431 	if (!(tx->local->hw.flags & IEEE80211_HW_HOST_BROADCAST_PS_BUFFERING))
432 		return TX_CONTINUE;
433 
434 	/* buffered in mac80211 */
435 	if (tx->local->total_ps_buffered >= TOTAL_MAX_TX_BUFFER)
436 		purge_old_ps_buffers(tx->local);
437 
438 	if (skb_queue_len(&ps->bc_buf) >= AP_MAX_BC_BUFFER) {
439 		ps_dbg(tx->sdata,
440 		       "BC TX buffer full - dropping the oldest frame\n");
441 		dev_kfree_skb(skb_dequeue(&ps->bc_buf));
442 	} else
443 		tx->local->total_ps_buffered++;
444 
445 	skb_queue_tail(&ps->bc_buf, tx->skb);
446 
447 	return TX_QUEUED;
448 }
449 
450 static int ieee80211_use_mfp(__le16 fc, struct sta_info *sta,
451 			     struct sk_buff *skb)
452 {
453 	if (!ieee80211_is_mgmt(fc))
454 		return 0;
455 
456 	if (sta == NULL || !test_sta_flag(sta, WLAN_STA_MFP))
457 		return 0;
458 
459 	if (!ieee80211_is_robust_mgmt_frame(skb))
460 		return 0;
461 
462 	return 1;
463 }
464 
465 static ieee80211_tx_result
466 ieee80211_tx_h_unicast_ps_buf(struct ieee80211_tx_data *tx)
467 {
468 	struct sta_info *sta = tx->sta;
469 	struct ieee80211_tx_info *info = IEEE80211_SKB_CB(tx->skb);
470 	struct ieee80211_hdr *hdr = (struct ieee80211_hdr *)tx->skb->data;
471 	struct ieee80211_local *local = tx->local;
472 
473 	if (unlikely(!sta))
474 		return TX_CONTINUE;
475 
476 	if (unlikely((test_sta_flag(sta, WLAN_STA_PS_STA) ||
477 		      test_sta_flag(sta, WLAN_STA_PS_DRIVER) ||
478 		      test_sta_flag(sta, WLAN_STA_PS_DELIVER)) &&
479 		     !(info->flags & IEEE80211_TX_CTL_NO_PS_BUFFER))) {
480 		int ac = skb_get_queue_mapping(tx->skb);
481 
482 		if (ieee80211_is_mgmt(hdr->frame_control) &&
483 		    !ieee80211_is_bufferable_mmpdu(hdr->frame_control)) {
484 			info->flags |= IEEE80211_TX_CTL_NO_PS_BUFFER;
485 			return TX_CONTINUE;
486 		}
487 
488 		ps_dbg(sta->sdata, "STA %pM aid %d: PS buffer for AC %d\n",
489 		       sta->sta.addr, sta->sta.aid, ac);
490 		if (tx->local->total_ps_buffered >= TOTAL_MAX_TX_BUFFER)
491 			purge_old_ps_buffers(tx->local);
492 
493 		/* sync with ieee80211_sta_ps_deliver_wakeup */
494 		spin_lock(&sta->ps_lock);
495 		/*
496 		 * STA woke up the meantime and all the frames on ps_tx_buf have
497 		 * been queued to pending queue. No reordering can happen, go
498 		 * ahead and Tx the packet.
499 		 */
500 		if (!test_sta_flag(sta, WLAN_STA_PS_STA) &&
501 		    !test_sta_flag(sta, WLAN_STA_PS_DRIVER) &&
502 		    !test_sta_flag(sta, WLAN_STA_PS_DELIVER)) {
503 			spin_unlock(&sta->ps_lock);
504 			return TX_CONTINUE;
505 		}
506 
507 		if (skb_queue_len(&sta->ps_tx_buf[ac]) >= STA_MAX_TX_BUFFER) {
508 			struct sk_buff *old = skb_dequeue(&sta->ps_tx_buf[ac]);
509 			ps_dbg(tx->sdata,
510 			       "STA %pM TX buffer for AC %d full - dropping oldest frame\n",
511 			       sta->sta.addr, ac);
512 			ieee80211_free_txskb(&local->hw, old);
513 		} else
514 			tx->local->total_ps_buffered++;
515 
516 		info->control.jiffies = jiffies;
517 		info->control.vif = &tx->sdata->vif;
518 		info->flags |= IEEE80211_TX_INTFL_NEED_TXPROCESSING;
519 		info->flags &= ~IEEE80211_TX_TEMPORARY_FLAGS;
520 		skb_queue_tail(&sta->ps_tx_buf[ac], tx->skb);
521 		spin_unlock(&sta->ps_lock);
522 
523 		if (!timer_pending(&local->sta_cleanup))
524 			mod_timer(&local->sta_cleanup,
525 				  round_jiffies(jiffies +
526 						STA_INFO_CLEANUP_INTERVAL));
527 
528 		/*
529 		 * We queued up some frames, so the TIM bit might
530 		 * need to be set, recalculate it.
531 		 */
532 		sta_info_recalc_tim(sta);
533 
534 		return TX_QUEUED;
535 	} else if (unlikely(test_sta_flag(sta, WLAN_STA_PS_STA))) {
536 		ps_dbg(tx->sdata,
537 		       "STA %pM in PS mode, but polling/in SP -> send frame\n",
538 		       sta->sta.addr);
539 	}
540 
541 	return TX_CONTINUE;
542 }
543 
544 static ieee80211_tx_result debug_noinline
545 ieee80211_tx_h_ps_buf(struct ieee80211_tx_data *tx)
546 {
547 	if (unlikely(tx->flags & IEEE80211_TX_PS_BUFFERED))
548 		return TX_CONTINUE;
549 
550 	if (tx->flags & IEEE80211_TX_UNICAST)
551 		return ieee80211_tx_h_unicast_ps_buf(tx);
552 	else
553 		return ieee80211_tx_h_multicast_ps_buf(tx);
554 }
555 
556 static ieee80211_tx_result debug_noinline
557 ieee80211_tx_h_check_control_port_protocol(struct ieee80211_tx_data *tx)
558 {
559 	struct ieee80211_tx_info *info = IEEE80211_SKB_CB(tx->skb);
560 
561 	if (unlikely(tx->sdata->control_port_protocol == tx->skb->protocol)) {
562 		if (tx->sdata->control_port_no_encrypt)
563 			info->flags |= IEEE80211_TX_INTFL_DONT_ENCRYPT;
564 		info->control.flags |= IEEE80211_TX_CTRL_PORT_CTRL_PROTO;
565 	}
566 
567 	return TX_CONTINUE;
568 }
569 
570 static ieee80211_tx_result debug_noinline
571 ieee80211_tx_h_select_key(struct ieee80211_tx_data *tx)
572 {
573 	struct ieee80211_key *key;
574 	struct ieee80211_tx_info *info = IEEE80211_SKB_CB(tx->skb);
575 	struct ieee80211_hdr *hdr = (struct ieee80211_hdr *)tx->skb->data;
576 
577 	if (unlikely(info->flags & IEEE80211_TX_INTFL_DONT_ENCRYPT))
578 		tx->key = NULL;
579 	else if (tx->sta &&
580 		 (key = rcu_dereference(tx->sta->ptk[tx->sta->ptk_idx])))
581 		tx->key = key;
582 	else if (ieee80211_is_mgmt(hdr->frame_control) &&
583 		 is_multicast_ether_addr(hdr->addr1) &&
584 		 ieee80211_is_robust_mgmt_frame(tx->skb) &&
585 		 (key = rcu_dereference(tx->sdata->default_mgmt_key)))
586 		tx->key = key;
587 	else if (is_multicast_ether_addr(hdr->addr1) &&
588 		 (key = rcu_dereference(tx->sdata->default_multicast_key)))
589 		tx->key = key;
590 	else if (!is_multicast_ether_addr(hdr->addr1) &&
591 		 (key = rcu_dereference(tx->sdata->default_unicast_key)))
592 		tx->key = key;
593 	else if (info->flags & IEEE80211_TX_CTL_INJECTED)
594 		tx->key = NULL;
595 	else if (!tx->sdata->drop_unencrypted)
596 		tx->key = NULL;
597 	else if (tx->skb->protocol == tx->sdata->control_port_protocol)
598 		tx->key = NULL;
599 	else if (ieee80211_is_robust_mgmt_frame(tx->skb) &&
600 		 !(ieee80211_is_action(hdr->frame_control) &&
601 		   tx->sta && test_sta_flag(tx->sta, WLAN_STA_MFP)))
602 		tx->key = NULL;
603 	else if (ieee80211_is_mgmt(hdr->frame_control) &&
604 		 !ieee80211_is_robust_mgmt_frame(tx->skb))
605 		tx->key = NULL;
606 	else {
607 		I802_DEBUG_INC(tx->local->tx_handlers_drop_unencrypted);
608 		return TX_DROP;
609 	}
610 
611 	if (tx->key) {
612 		bool skip_hw = false;
613 
614 		tx->key->tx_rx_count++;
615 		/* TODO: add threshold stuff again */
616 
617 		switch (tx->key->conf.cipher) {
618 		case WLAN_CIPHER_SUITE_WEP40:
619 		case WLAN_CIPHER_SUITE_WEP104:
620 		case WLAN_CIPHER_SUITE_TKIP:
621 			if (!ieee80211_is_data_present(hdr->frame_control))
622 				tx->key = NULL;
623 			break;
624 		case WLAN_CIPHER_SUITE_CCMP:
625 			if (!ieee80211_is_data_present(hdr->frame_control) &&
626 			    !ieee80211_use_mfp(hdr->frame_control, tx->sta,
627 					       tx->skb))
628 				tx->key = NULL;
629 			else
630 				skip_hw = (tx->key->conf.flags &
631 					   IEEE80211_KEY_FLAG_SW_MGMT_TX) &&
632 					ieee80211_is_mgmt(hdr->frame_control);
633 			break;
634 		case WLAN_CIPHER_SUITE_AES_CMAC:
635 			if (!ieee80211_is_mgmt(hdr->frame_control))
636 				tx->key = NULL;
637 			break;
638 		}
639 
640 		if (unlikely(tx->key && tx->key->flags & KEY_FLAG_TAINTED &&
641 			     !ieee80211_is_deauth(hdr->frame_control)))
642 			return TX_DROP;
643 
644 		if (!skip_hw && tx->key &&
645 		    tx->key->flags & KEY_FLAG_UPLOADED_TO_HARDWARE)
646 			info->control.hw_key = &tx->key->conf;
647 	}
648 
649 	return TX_CONTINUE;
650 }
651 
652 static ieee80211_tx_result debug_noinline
653 ieee80211_tx_h_rate_ctrl(struct ieee80211_tx_data *tx)
654 {
655 	struct ieee80211_tx_info *info = IEEE80211_SKB_CB(tx->skb);
656 	struct ieee80211_hdr *hdr = (void *)tx->skb->data;
657 	struct ieee80211_supported_band *sband;
658 	u32 len;
659 	struct ieee80211_tx_rate_control txrc;
660 	struct ieee80211_sta_rates *ratetbl = NULL;
661 	bool assoc = false;
662 
663 	memset(&txrc, 0, sizeof(txrc));
664 
665 	sband = tx->local->hw.wiphy->bands[info->band];
666 
667 	len = min_t(u32, tx->skb->len + FCS_LEN,
668 			 tx->local->hw.wiphy->frag_threshold);
669 
670 	/* set up the tx rate control struct we give the RC algo */
671 	txrc.hw = &tx->local->hw;
672 	txrc.sband = sband;
673 	txrc.bss_conf = &tx->sdata->vif.bss_conf;
674 	txrc.skb = tx->skb;
675 	txrc.reported_rate.idx = -1;
676 	txrc.rate_idx_mask = tx->sdata->rc_rateidx_mask[info->band];
677 	if (txrc.rate_idx_mask == (1 << sband->n_bitrates) - 1)
678 		txrc.max_rate_idx = -1;
679 	else
680 		txrc.max_rate_idx = fls(txrc.rate_idx_mask) - 1;
681 
682 	if (tx->sdata->rc_has_mcs_mask[info->band])
683 		txrc.rate_idx_mcs_mask =
684 			tx->sdata->rc_rateidx_mcs_mask[info->band];
685 
686 	txrc.bss = (tx->sdata->vif.type == NL80211_IFTYPE_AP ||
687 		    tx->sdata->vif.type == NL80211_IFTYPE_MESH_POINT ||
688 		    tx->sdata->vif.type == NL80211_IFTYPE_ADHOC);
689 
690 	/* set up RTS protection if desired */
691 	if (len > tx->local->hw.wiphy->rts_threshold) {
692 		txrc.rts = true;
693 	}
694 
695 	info->control.use_rts = txrc.rts;
696 	info->control.use_cts_prot = tx->sdata->vif.bss_conf.use_cts_prot;
697 
698 	/*
699 	 * Use short preamble if the BSS can handle it, but not for
700 	 * management frames unless we know the receiver can handle
701 	 * that -- the management frame might be to a station that
702 	 * just wants a probe response.
703 	 */
704 	if (tx->sdata->vif.bss_conf.use_short_preamble &&
705 	    (ieee80211_is_data(hdr->frame_control) ||
706 	     (tx->sta && test_sta_flag(tx->sta, WLAN_STA_SHORT_PREAMBLE))))
707 		txrc.short_preamble = true;
708 
709 	info->control.short_preamble = txrc.short_preamble;
710 
711 	if (tx->sta)
712 		assoc = test_sta_flag(tx->sta, WLAN_STA_ASSOC);
713 
714 	/*
715 	 * Lets not bother rate control if we're associated and cannot
716 	 * talk to the sta. This should not happen.
717 	 */
718 	if (WARN(test_bit(SCAN_SW_SCANNING, &tx->local->scanning) && assoc &&
719 		 !rate_usable_index_exists(sband, &tx->sta->sta),
720 		 "%s: Dropped data frame as no usable bitrate found while "
721 		 "scanning and associated. Target station: "
722 		 "%pM on %d GHz band\n",
723 		 tx->sdata->name, hdr->addr1,
724 		 info->band ? 5 : 2))
725 		return TX_DROP;
726 
727 	/*
728 	 * If we're associated with the sta at this point we know we can at
729 	 * least send the frame at the lowest bit rate.
730 	 */
731 	rate_control_get_rate(tx->sdata, tx->sta, &txrc);
732 
733 	if (tx->sta && !info->control.skip_table)
734 		ratetbl = rcu_dereference(tx->sta->sta.rates);
735 
736 	if (unlikely(info->control.rates[0].idx < 0)) {
737 		if (ratetbl) {
738 			struct ieee80211_tx_rate rate = {
739 				.idx = ratetbl->rate[0].idx,
740 				.flags = ratetbl->rate[0].flags,
741 				.count = ratetbl->rate[0].count
742 			};
743 
744 			if (ratetbl->rate[0].idx < 0)
745 				return TX_DROP;
746 
747 			tx->rate = rate;
748 		} else {
749 			return TX_DROP;
750 		}
751 	} else {
752 		tx->rate = info->control.rates[0];
753 	}
754 
755 	if (txrc.reported_rate.idx < 0) {
756 		txrc.reported_rate = tx->rate;
757 		if (tx->sta && ieee80211_is_data(hdr->frame_control))
758 			tx->sta->last_tx_rate = txrc.reported_rate;
759 	} else if (tx->sta)
760 		tx->sta->last_tx_rate = txrc.reported_rate;
761 
762 	if (ratetbl)
763 		return TX_CONTINUE;
764 
765 	if (unlikely(!info->control.rates[0].count))
766 		info->control.rates[0].count = 1;
767 
768 	if (WARN_ON_ONCE((info->control.rates[0].count > 1) &&
769 			 (info->flags & IEEE80211_TX_CTL_NO_ACK)))
770 		info->control.rates[0].count = 1;
771 
772 	return TX_CONTINUE;
773 }
774 
775 static ieee80211_tx_result debug_noinline
776 ieee80211_tx_h_sequence(struct ieee80211_tx_data *tx)
777 {
778 	struct ieee80211_tx_info *info = IEEE80211_SKB_CB(tx->skb);
779 	struct ieee80211_hdr *hdr = (struct ieee80211_hdr *)tx->skb->data;
780 	u16 *seq;
781 	u8 *qc;
782 	int tid;
783 
784 	/*
785 	 * Packet injection may want to control the sequence
786 	 * number, if we have no matching interface then we
787 	 * neither assign one ourselves nor ask the driver to.
788 	 */
789 	if (unlikely(info->control.vif->type == NL80211_IFTYPE_MONITOR))
790 		return TX_CONTINUE;
791 
792 	if (unlikely(ieee80211_is_ctl(hdr->frame_control)))
793 		return TX_CONTINUE;
794 
795 	if (ieee80211_hdrlen(hdr->frame_control) < 24)
796 		return TX_CONTINUE;
797 
798 	if (ieee80211_is_qos_nullfunc(hdr->frame_control))
799 		return TX_CONTINUE;
800 
801 	/*
802 	 * Anything but QoS data that has a sequence number field
803 	 * (is long enough) gets a sequence number from the global
804 	 * counter.  QoS data frames with a multicast destination
805 	 * also use the global counter (802.11-2012 9.3.2.10).
806 	 */
807 	if (!ieee80211_is_data_qos(hdr->frame_control) ||
808 	    is_multicast_ether_addr(hdr->addr1)) {
809 		/* driver should assign sequence number */
810 		info->flags |= IEEE80211_TX_CTL_ASSIGN_SEQ;
811 		/* for pure STA mode without beacons, we can do it */
812 		hdr->seq_ctrl = cpu_to_le16(tx->sdata->sequence_number);
813 		tx->sdata->sequence_number += 0x10;
814 		return TX_CONTINUE;
815 	}
816 
817 	/*
818 	 * This should be true for injected/management frames only, for
819 	 * management frames we have set the IEEE80211_TX_CTL_ASSIGN_SEQ
820 	 * above since they are not QoS-data frames.
821 	 */
822 	if (!tx->sta)
823 		return TX_CONTINUE;
824 
825 	/* include per-STA, per-TID sequence counter */
826 
827 	qc = ieee80211_get_qos_ctl(hdr);
828 	tid = *qc & IEEE80211_QOS_CTL_TID_MASK;
829 	seq = &tx->sta->tid_seq[tid];
830 
831 	hdr->seq_ctrl = cpu_to_le16(*seq);
832 
833 	/* Increase the sequence number. */
834 	*seq = (*seq + 0x10) & IEEE80211_SCTL_SEQ;
835 
836 	return TX_CONTINUE;
837 }
838 
839 static int ieee80211_fragment(struct ieee80211_tx_data *tx,
840 			      struct sk_buff *skb, int hdrlen,
841 			      int frag_threshold)
842 {
843 	struct ieee80211_local *local = tx->local;
844 	struct ieee80211_tx_info *info;
845 	struct sk_buff *tmp;
846 	int per_fragm = frag_threshold - hdrlen - FCS_LEN;
847 	int pos = hdrlen + per_fragm;
848 	int rem = skb->len - hdrlen - per_fragm;
849 
850 	if (WARN_ON(rem < 0))
851 		return -EINVAL;
852 
853 	/* first fragment was already added to queue by caller */
854 
855 	while (rem) {
856 		int fraglen = per_fragm;
857 
858 		if (fraglen > rem)
859 			fraglen = rem;
860 		rem -= fraglen;
861 		tmp = dev_alloc_skb(local->tx_headroom +
862 				    frag_threshold +
863 				    tx->sdata->encrypt_headroom +
864 				    IEEE80211_ENCRYPT_TAILROOM);
865 		if (!tmp)
866 			return -ENOMEM;
867 
868 		__skb_queue_tail(&tx->skbs, tmp);
869 
870 		skb_reserve(tmp,
871 			    local->tx_headroom + tx->sdata->encrypt_headroom);
872 
873 		/* copy control information */
874 		memcpy(tmp->cb, skb->cb, sizeof(tmp->cb));
875 
876 		info = IEEE80211_SKB_CB(tmp);
877 		info->flags &= ~(IEEE80211_TX_CTL_CLEAR_PS_FILT |
878 				 IEEE80211_TX_CTL_FIRST_FRAGMENT);
879 
880 		if (rem)
881 			info->flags |= IEEE80211_TX_CTL_MORE_FRAMES;
882 
883 		skb_copy_queue_mapping(tmp, skb);
884 		tmp->priority = skb->priority;
885 		tmp->dev = skb->dev;
886 
887 		/* copy header and data */
888 		memcpy(skb_put(tmp, hdrlen), skb->data, hdrlen);
889 		memcpy(skb_put(tmp, fraglen), skb->data + pos, fraglen);
890 
891 		pos += fraglen;
892 	}
893 
894 	/* adjust first fragment's length */
895 	skb_trim(skb, hdrlen + per_fragm);
896 	return 0;
897 }
898 
899 static ieee80211_tx_result debug_noinline
900 ieee80211_tx_h_fragment(struct ieee80211_tx_data *tx)
901 {
902 	struct sk_buff *skb = tx->skb;
903 	struct ieee80211_tx_info *info = IEEE80211_SKB_CB(skb);
904 	struct ieee80211_hdr *hdr = (void *)skb->data;
905 	int frag_threshold = tx->local->hw.wiphy->frag_threshold;
906 	int hdrlen;
907 	int fragnum;
908 
909 	/* no matter what happens, tx->skb moves to tx->skbs */
910 	__skb_queue_tail(&tx->skbs, skb);
911 	tx->skb = NULL;
912 
913 	if (info->flags & IEEE80211_TX_CTL_DONTFRAG)
914 		return TX_CONTINUE;
915 
916 	if (tx->local->ops->set_frag_threshold)
917 		return TX_CONTINUE;
918 
919 	/*
920 	 * Warn when submitting a fragmented A-MPDU frame and drop it.
921 	 * This scenario is handled in ieee80211_tx_prepare but extra
922 	 * caution taken here as fragmented ampdu may cause Tx stop.
923 	 */
924 	if (WARN_ON(info->flags & IEEE80211_TX_CTL_AMPDU))
925 		return TX_DROP;
926 
927 	hdrlen = ieee80211_hdrlen(hdr->frame_control);
928 
929 	/* internal error, why isn't DONTFRAG set? */
930 	if (WARN_ON(skb->len + FCS_LEN <= frag_threshold))
931 		return TX_DROP;
932 
933 	/*
934 	 * Now fragment the frame. This will allocate all the fragments and
935 	 * chain them (using skb as the first fragment) to skb->next.
936 	 * During transmission, we will remove the successfully transmitted
937 	 * fragments from this list. When the low-level driver rejects one
938 	 * of the fragments then we will simply pretend to accept the skb
939 	 * but store it away as pending.
940 	 */
941 	if (ieee80211_fragment(tx, skb, hdrlen, frag_threshold))
942 		return TX_DROP;
943 
944 	/* update duration/seq/flags of fragments */
945 	fragnum = 0;
946 
947 	skb_queue_walk(&tx->skbs, skb) {
948 		const __le16 morefrags = cpu_to_le16(IEEE80211_FCTL_MOREFRAGS);
949 
950 		hdr = (void *)skb->data;
951 		info = IEEE80211_SKB_CB(skb);
952 
953 		if (!skb_queue_is_last(&tx->skbs, skb)) {
954 			hdr->frame_control |= morefrags;
955 			/*
956 			 * No multi-rate retries for fragmented frames, that
957 			 * would completely throw off the NAV at other STAs.
958 			 */
959 			info->control.rates[1].idx = -1;
960 			info->control.rates[2].idx = -1;
961 			info->control.rates[3].idx = -1;
962 			BUILD_BUG_ON(IEEE80211_TX_MAX_RATES != 4);
963 			info->flags &= ~IEEE80211_TX_CTL_RATE_CTRL_PROBE;
964 		} else {
965 			hdr->frame_control &= ~morefrags;
966 		}
967 		hdr->seq_ctrl |= cpu_to_le16(fragnum & IEEE80211_SCTL_FRAG);
968 		fragnum++;
969 	}
970 
971 	return TX_CONTINUE;
972 }
973 
974 static ieee80211_tx_result debug_noinline
975 ieee80211_tx_h_stats(struct ieee80211_tx_data *tx)
976 {
977 	struct sk_buff *skb;
978 	int ac = -1;
979 
980 	if (!tx->sta)
981 		return TX_CONTINUE;
982 
983 	skb_queue_walk(&tx->skbs, skb) {
984 		ac = skb_get_queue_mapping(skb);
985 		tx->sta->tx_fragments++;
986 		tx->sta->tx_bytes[ac] += skb->len;
987 	}
988 	if (ac >= 0)
989 		tx->sta->tx_packets[ac]++;
990 
991 	return TX_CONTINUE;
992 }
993 
994 static ieee80211_tx_result debug_noinline
995 ieee80211_tx_h_encrypt(struct ieee80211_tx_data *tx)
996 {
997 	if (!tx->key)
998 		return TX_CONTINUE;
999 
1000 	switch (tx->key->conf.cipher) {
1001 	case WLAN_CIPHER_SUITE_WEP40:
1002 	case WLAN_CIPHER_SUITE_WEP104:
1003 		return ieee80211_crypto_wep_encrypt(tx);
1004 	case WLAN_CIPHER_SUITE_TKIP:
1005 		return ieee80211_crypto_tkip_encrypt(tx);
1006 	case WLAN_CIPHER_SUITE_CCMP:
1007 		return ieee80211_crypto_ccmp_encrypt(tx);
1008 	case WLAN_CIPHER_SUITE_AES_CMAC:
1009 		return ieee80211_crypto_aes_cmac_encrypt(tx);
1010 	default:
1011 		return ieee80211_crypto_hw_encrypt(tx);
1012 	}
1013 
1014 	return TX_DROP;
1015 }
1016 
1017 static ieee80211_tx_result debug_noinline
1018 ieee80211_tx_h_calculate_duration(struct ieee80211_tx_data *tx)
1019 {
1020 	struct sk_buff *skb;
1021 	struct ieee80211_hdr *hdr;
1022 	int next_len;
1023 	bool group_addr;
1024 
1025 	skb_queue_walk(&tx->skbs, skb) {
1026 		hdr = (void *) skb->data;
1027 		if (unlikely(ieee80211_is_pspoll(hdr->frame_control)))
1028 			break; /* must not overwrite AID */
1029 		if (!skb_queue_is_last(&tx->skbs, skb)) {
1030 			struct sk_buff *next = skb_queue_next(&tx->skbs, skb);
1031 			next_len = next->len;
1032 		} else
1033 			next_len = 0;
1034 		group_addr = is_multicast_ether_addr(hdr->addr1);
1035 
1036 		hdr->duration_id =
1037 			ieee80211_duration(tx, skb, group_addr, next_len);
1038 	}
1039 
1040 	return TX_CONTINUE;
1041 }
1042 
1043 /* actual transmit path */
1044 
1045 static bool ieee80211_tx_prep_agg(struct ieee80211_tx_data *tx,
1046 				  struct sk_buff *skb,
1047 				  struct ieee80211_tx_info *info,
1048 				  struct tid_ampdu_tx *tid_tx,
1049 				  int tid)
1050 {
1051 	bool queued = false;
1052 	bool reset_agg_timer = false;
1053 	struct sk_buff *purge_skb = NULL;
1054 
1055 	if (test_bit(HT_AGG_STATE_OPERATIONAL, &tid_tx->state)) {
1056 		info->flags |= IEEE80211_TX_CTL_AMPDU;
1057 		reset_agg_timer = true;
1058 	} else if (test_bit(HT_AGG_STATE_WANT_START, &tid_tx->state)) {
1059 		/*
1060 		 * nothing -- this aggregation session is being started
1061 		 * but that might still fail with the driver
1062 		 */
1063 	} else {
1064 		spin_lock(&tx->sta->lock);
1065 		/*
1066 		 * Need to re-check now, because we may get here
1067 		 *
1068 		 *  1) in the window during which the setup is actually
1069 		 *     already done, but not marked yet because not all
1070 		 *     packets are spliced over to the driver pending
1071 		 *     queue yet -- if this happened we acquire the lock
1072 		 *     either before or after the splice happens, but
1073 		 *     need to recheck which of these cases happened.
1074 		 *
1075 		 *  2) during session teardown, if the OPERATIONAL bit
1076 		 *     was cleared due to the teardown but the pointer
1077 		 *     hasn't been assigned NULL yet (or we loaded it
1078 		 *     before it was assigned) -- in this case it may
1079 		 *     now be NULL which means we should just let the
1080 		 *     packet pass through because splicing the frames
1081 		 *     back is already done.
1082 		 */
1083 		tid_tx = rcu_dereference_protected_tid_tx(tx->sta, tid);
1084 
1085 		if (!tid_tx) {
1086 			/* do nothing, let packet pass through */
1087 		} else if (test_bit(HT_AGG_STATE_OPERATIONAL, &tid_tx->state)) {
1088 			info->flags |= IEEE80211_TX_CTL_AMPDU;
1089 			reset_agg_timer = true;
1090 		} else {
1091 			queued = true;
1092 			info->control.vif = &tx->sdata->vif;
1093 			info->flags |= IEEE80211_TX_INTFL_NEED_TXPROCESSING;
1094 			info->flags &= ~IEEE80211_TX_TEMPORARY_FLAGS;
1095 			__skb_queue_tail(&tid_tx->pending, skb);
1096 			if (skb_queue_len(&tid_tx->pending) > STA_MAX_TX_BUFFER)
1097 				purge_skb = __skb_dequeue(&tid_tx->pending);
1098 		}
1099 		spin_unlock(&tx->sta->lock);
1100 
1101 		if (purge_skb)
1102 			ieee80211_free_txskb(&tx->local->hw, purge_skb);
1103 	}
1104 
1105 	/* reset session timer */
1106 	if (reset_agg_timer && tid_tx->timeout)
1107 		tid_tx->last_tx = jiffies;
1108 
1109 	return queued;
1110 }
1111 
1112 /*
1113  * initialises @tx
1114  */
1115 static ieee80211_tx_result
1116 ieee80211_tx_prepare(struct ieee80211_sub_if_data *sdata,
1117 		     struct ieee80211_tx_data *tx,
1118 		     struct sk_buff *skb)
1119 {
1120 	struct ieee80211_local *local = sdata->local;
1121 	struct ieee80211_hdr *hdr;
1122 	struct ieee80211_tx_info *info = IEEE80211_SKB_CB(skb);
1123 	int tid;
1124 	u8 *qc;
1125 
1126 	memset(tx, 0, sizeof(*tx));
1127 	tx->skb = skb;
1128 	tx->local = local;
1129 	tx->sdata = sdata;
1130 	__skb_queue_head_init(&tx->skbs);
1131 
1132 	/*
1133 	 * If this flag is set to true anywhere, and we get here,
1134 	 * we are doing the needed processing, so remove the flag
1135 	 * now.
1136 	 */
1137 	info->flags &= ~IEEE80211_TX_INTFL_NEED_TXPROCESSING;
1138 
1139 	hdr = (struct ieee80211_hdr *) skb->data;
1140 
1141 	if (sdata->vif.type == NL80211_IFTYPE_AP_VLAN) {
1142 		tx->sta = rcu_dereference(sdata->u.vlan.sta);
1143 		if (!tx->sta && sdata->dev->ieee80211_ptr->use_4addr)
1144 			return TX_DROP;
1145 	} else if (info->flags & (IEEE80211_TX_CTL_INJECTED |
1146 				  IEEE80211_TX_INTFL_NL80211_FRAME_TX) ||
1147 		   tx->sdata->control_port_protocol == tx->skb->protocol) {
1148 		tx->sta = sta_info_get_bss(sdata, hdr->addr1);
1149 	}
1150 	if (!tx->sta)
1151 		tx->sta = sta_info_get(sdata, hdr->addr1);
1152 
1153 	if (tx->sta && ieee80211_is_data_qos(hdr->frame_control) &&
1154 	    !ieee80211_is_qos_nullfunc(hdr->frame_control) &&
1155 	    (local->hw.flags & IEEE80211_HW_AMPDU_AGGREGATION) &&
1156 	    !(local->hw.flags & IEEE80211_HW_TX_AMPDU_SETUP_IN_HW)) {
1157 		struct tid_ampdu_tx *tid_tx;
1158 
1159 		qc = ieee80211_get_qos_ctl(hdr);
1160 		tid = *qc & IEEE80211_QOS_CTL_TID_MASK;
1161 
1162 		tid_tx = rcu_dereference(tx->sta->ampdu_mlme.tid_tx[tid]);
1163 		if (tid_tx) {
1164 			bool queued;
1165 
1166 			queued = ieee80211_tx_prep_agg(tx, skb, info,
1167 						       tid_tx, tid);
1168 
1169 			if (unlikely(queued))
1170 				return TX_QUEUED;
1171 		}
1172 	}
1173 
1174 	if (is_multicast_ether_addr(hdr->addr1)) {
1175 		tx->flags &= ~IEEE80211_TX_UNICAST;
1176 		info->flags |= IEEE80211_TX_CTL_NO_ACK;
1177 	} else
1178 		tx->flags |= IEEE80211_TX_UNICAST;
1179 
1180 	if (!(info->flags & IEEE80211_TX_CTL_DONTFRAG)) {
1181 		if (!(tx->flags & IEEE80211_TX_UNICAST) ||
1182 		    skb->len + FCS_LEN <= local->hw.wiphy->frag_threshold ||
1183 		    info->flags & IEEE80211_TX_CTL_AMPDU)
1184 			info->flags |= IEEE80211_TX_CTL_DONTFRAG;
1185 	}
1186 
1187 	if (!tx->sta)
1188 		info->flags |= IEEE80211_TX_CTL_CLEAR_PS_FILT;
1189 	else if (test_and_clear_sta_flag(tx->sta, WLAN_STA_CLEAR_PS_FILT))
1190 		info->flags |= IEEE80211_TX_CTL_CLEAR_PS_FILT;
1191 
1192 	info->flags |= IEEE80211_TX_CTL_FIRST_FRAGMENT;
1193 
1194 	return TX_CONTINUE;
1195 }
1196 
1197 static bool ieee80211_tx_frags(struct ieee80211_local *local,
1198 			       struct ieee80211_vif *vif,
1199 			       struct ieee80211_sta *sta,
1200 			       struct sk_buff_head *skbs,
1201 			       bool txpending)
1202 {
1203 	struct ieee80211_tx_control control;
1204 	struct sk_buff *skb, *tmp;
1205 	unsigned long flags;
1206 
1207 	skb_queue_walk_safe(skbs, skb, tmp) {
1208 		struct ieee80211_tx_info *info = IEEE80211_SKB_CB(skb);
1209 		int q = info->hw_queue;
1210 
1211 #ifdef CONFIG_MAC80211_VERBOSE_DEBUG
1212 		if (WARN_ON_ONCE(q >= local->hw.queues)) {
1213 			__skb_unlink(skb, skbs);
1214 			ieee80211_free_txskb(&local->hw, skb);
1215 			continue;
1216 		}
1217 #endif
1218 
1219 		spin_lock_irqsave(&local->queue_stop_reason_lock, flags);
1220 		if (local->queue_stop_reasons[q] ||
1221 		    (!txpending && !skb_queue_empty(&local->pending[q]))) {
1222 			if (unlikely(info->flags &
1223 				     IEEE80211_TX_INTFL_OFFCHAN_TX_OK)) {
1224 				if (local->queue_stop_reasons[q] &
1225 				    ~BIT(IEEE80211_QUEUE_STOP_REASON_OFFCHANNEL)) {
1226 					/*
1227 					 * Drop off-channel frames if queues
1228 					 * are stopped for any reason other
1229 					 * than off-channel operation. Never
1230 					 * queue them.
1231 					 */
1232 					spin_unlock_irqrestore(
1233 						&local->queue_stop_reason_lock,
1234 						flags);
1235 					ieee80211_purge_tx_queue(&local->hw,
1236 								 skbs);
1237 					return true;
1238 				}
1239 			} else {
1240 
1241 				/*
1242 				 * Since queue is stopped, queue up frames for
1243 				 * later transmission from the tx-pending
1244 				 * tasklet when the queue is woken again.
1245 				 */
1246 				if (txpending)
1247 					skb_queue_splice_init(skbs,
1248 							      &local->pending[q]);
1249 				else
1250 					skb_queue_splice_tail_init(skbs,
1251 								   &local->pending[q]);
1252 
1253 				spin_unlock_irqrestore(&local->queue_stop_reason_lock,
1254 						       flags);
1255 				return false;
1256 			}
1257 		}
1258 		spin_unlock_irqrestore(&local->queue_stop_reason_lock, flags);
1259 
1260 		info->control.vif = vif;
1261 		control.sta = sta;
1262 
1263 		__skb_unlink(skb, skbs);
1264 		drv_tx(local, &control, skb);
1265 	}
1266 
1267 	return true;
1268 }
1269 
1270 /*
1271  * Returns false if the frame couldn't be transmitted but was queued instead.
1272  */
1273 static bool __ieee80211_tx(struct ieee80211_local *local,
1274 			   struct sk_buff_head *skbs, int led_len,
1275 			   struct sta_info *sta, bool txpending)
1276 {
1277 	struct ieee80211_tx_info *info;
1278 	struct ieee80211_sub_if_data *sdata;
1279 	struct ieee80211_vif *vif;
1280 	struct ieee80211_sta *pubsta;
1281 	struct sk_buff *skb;
1282 	bool result = true;
1283 	__le16 fc;
1284 
1285 	if (WARN_ON(skb_queue_empty(skbs)))
1286 		return true;
1287 
1288 	skb = skb_peek(skbs);
1289 	fc = ((struct ieee80211_hdr *)skb->data)->frame_control;
1290 	info = IEEE80211_SKB_CB(skb);
1291 	sdata = vif_to_sdata(info->control.vif);
1292 	if (sta && !sta->uploaded)
1293 		sta = NULL;
1294 
1295 	if (sta)
1296 		pubsta = &sta->sta;
1297 	else
1298 		pubsta = NULL;
1299 
1300 	switch (sdata->vif.type) {
1301 	case NL80211_IFTYPE_MONITOR:
1302 		if (sdata->u.mntr_flags & MONITOR_FLAG_ACTIVE) {
1303 			vif = &sdata->vif;
1304 			break;
1305 		}
1306 		sdata = rcu_dereference(local->monitor_sdata);
1307 		if (sdata) {
1308 			vif = &sdata->vif;
1309 			info->hw_queue =
1310 				vif->hw_queue[skb_get_queue_mapping(skb)];
1311 		} else if (local->hw.flags & IEEE80211_HW_QUEUE_CONTROL) {
1312 			dev_kfree_skb(skb);
1313 			return true;
1314 		} else
1315 			vif = NULL;
1316 		break;
1317 	case NL80211_IFTYPE_AP_VLAN:
1318 		sdata = container_of(sdata->bss,
1319 				     struct ieee80211_sub_if_data, u.ap);
1320 		/* fall through */
1321 	default:
1322 		vif = &sdata->vif;
1323 		break;
1324 	}
1325 
1326 	result = ieee80211_tx_frags(local, vif, pubsta, skbs,
1327 				    txpending);
1328 
1329 	ieee80211_tpt_led_trig_tx(local, fc, led_len);
1330 
1331 	WARN_ON_ONCE(!skb_queue_empty(skbs));
1332 
1333 	return result;
1334 }
1335 
1336 /*
1337  * Invoke TX handlers, return 0 on success and non-zero if the
1338  * frame was dropped or queued.
1339  */
1340 static int invoke_tx_handlers(struct ieee80211_tx_data *tx)
1341 {
1342 	struct ieee80211_tx_info *info = IEEE80211_SKB_CB(tx->skb);
1343 	ieee80211_tx_result res = TX_DROP;
1344 
1345 #define CALL_TXH(txh) \
1346 	do {				\
1347 		res = txh(tx);		\
1348 		if (res != TX_CONTINUE)	\
1349 			goto txh_done;	\
1350 	} while (0)
1351 
1352 	CALL_TXH(ieee80211_tx_h_dynamic_ps);
1353 	CALL_TXH(ieee80211_tx_h_check_assoc);
1354 	CALL_TXH(ieee80211_tx_h_ps_buf);
1355 	CALL_TXH(ieee80211_tx_h_check_control_port_protocol);
1356 	CALL_TXH(ieee80211_tx_h_select_key);
1357 	if (!(tx->local->hw.flags & IEEE80211_HW_HAS_RATE_CONTROL))
1358 		CALL_TXH(ieee80211_tx_h_rate_ctrl);
1359 
1360 	if (unlikely(info->flags & IEEE80211_TX_INTFL_RETRANSMISSION)) {
1361 		__skb_queue_tail(&tx->skbs, tx->skb);
1362 		tx->skb = NULL;
1363 		goto txh_done;
1364 	}
1365 
1366 	CALL_TXH(ieee80211_tx_h_michael_mic_add);
1367 	CALL_TXH(ieee80211_tx_h_sequence);
1368 	CALL_TXH(ieee80211_tx_h_fragment);
1369 	/* handlers after fragment must be aware of tx info fragmentation! */
1370 	CALL_TXH(ieee80211_tx_h_stats);
1371 	CALL_TXH(ieee80211_tx_h_encrypt);
1372 	if (!(tx->local->hw.flags & IEEE80211_HW_HAS_RATE_CONTROL))
1373 		CALL_TXH(ieee80211_tx_h_calculate_duration);
1374 #undef CALL_TXH
1375 
1376  txh_done:
1377 	if (unlikely(res == TX_DROP)) {
1378 		I802_DEBUG_INC(tx->local->tx_handlers_drop);
1379 		if (tx->skb)
1380 			ieee80211_free_txskb(&tx->local->hw, tx->skb);
1381 		else
1382 			ieee80211_purge_tx_queue(&tx->local->hw, &tx->skbs);
1383 		return -1;
1384 	} else if (unlikely(res == TX_QUEUED)) {
1385 		I802_DEBUG_INC(tx->local->tx_handlers_queued);
1386 		return -1;
1387 	}
1388 
1389 	return 0;
1390 }
1391 
1392 bool ieee80211_tx_prepare_skb(struct ieee80211_hw *hw,
1393 			      struct ieee80211_vif *vif, struct sk_buff *skb,
1394 			      int band, struct ieee80211_sta **sta)
1395 {
1396 	struct ieee80211_sub_if_data *sdata = vif_to_sdata(vif);
1397 	struct ieee80211_tx_info *info = IEEE80211_SKB_CB(skb);
1398 	struct ieee80211_tx_data tx;
1399 
1400 	if (ieee80211_tx_prepare(sdata, &tx, skb) == TX_DROP)
1401 		return false;
1402 
1403 	info->band = band;
1404 	info->control.vif = vif;
1405 	info->hw_queue = vif->hw_queue[skb_get_queue_mapping(skb)];
1406 
1407 	if (invoke_tx_handlers(&tx))
1408 		return false;
1409 
1410 	if (sta) {
1411 		if (tx.sta)
1412 			*sta = &tx.sta->sta;
1413 		else
1414 			*sta = NULL;
1415 	}
1416 
1417 	return true;
1418 }
1419 EXPORT_SYMBOL(ieee80211_tx_prepare_skb);
1420 
1421 /*
1422  * Returns false if the frame couldn't be transmitted but was queued instead.
1423  */
1424 static bool ieee80211_tx(struct ieee80211_sub_if_data *sdata,
1425 			 struct sk_buff *skb, bool txpending,
1426 			 enum ieee80211_band band)
1427 {
1428 	struct ieee80211_local *local = sdata->local;
1429 	struct ieee80211_tx_data tx;
1430 	ieee80211_tx_result res_prepare;
1431 	struct ieee80211_tx_info *info = IEEE80211_SKB_CB(skb);
1432 	bool result = true;
1433 	int led_len;
1434 
1435 	if (unlikely(skb->len < 10)) {
1436 		dev_kfree_skb(skb);
1437 		return true;
1438 	}
1439 
1440 	/* initialises tx */
1441 	led_len = skb->len;
1442 	res_prepare = ieee80211_tx_prepare(sdata, &tx, skb);
1443 
1444 	if (unlikely(res_prepare == TX_DROP)) {
1445 		ieee80211_free_txskb(&local->hw, skb);
1446 		return true;
1447 	} else if (unlikely(res_prepare == TX_QUEUED)) {
1448 		return true;
1449 	}
1450 
1451 	info->band = band;
1452 
1453 	/* set up hw_queue value early */
1454 	if (!(info->flags & IEEE80211_TX_CTL_TX_OFFCHAN) ||
1455 	    !(local->hw.flags & IEEE80211_HW_QUEUE_CONTROL))
1456 		info->hw_queue =
1457 			sdata->vif.hw_queue[skb_get_queue_mapping(skb)];
1458 
1459 	if (!invoke_tx_handlers(&tx))
1460 		result = __ieee80211_tx(local, &tx.skbs, led_len,
1461 					tx.sta, txpending);
1462 
1463 	return result;
1464 }
1465 
1466 /* device xmit handlers */
1467 
1468 static int ieee80211_skb_resize(struct ieee80211_sub_if_data *sdata,
1469 				struct sk_buff *skb,
1470 				int head_need, bool may_encrypt)
1471 {
1472 	struct ieee80211_local *local = sdata->local;
1473 	int tail_need = 0;
1474 
1475 	if (may_encrypt && sdata->crypto_tx_tailroom_needed_cnt) {
1476 		tail_need = IEEE80211_ENCRYPT_TAILROOM;
1477 		tail_need -= skb_tailroom(skb);
1478 		tail_need = max_t(int, tail_need, 0);
1479 	}
1480 
1481 	if (skb_cloned(skb))
1482 		I802_DEBUG_INC(local->tx_expand_skb_head_cloned);
1483 	else if (head_need || tail_need)
1484 		I802_DEBUG_INC(local->tx_expand_skb_head);
1485 	else
1486 		return 0;
1487 
1488 	if (pskb_expand_head(skb, head_need, tail_need, GFP_ATOMIC)) {
1489 		wiphy_debug(local->hw.wiphy,
1490 			    "failed to reallocate TX buffer\n");
1491 		return -ENOMEM;
1492 	}
1493 
1494 	return 0;
1495 }
1496 
1497 void ieee80211_xmit(struct ieee80211_sub_if_data *sdata, struct sk_buff *skb,
1498 		    enum ieee80211_band band)
1499 {
1500 	struct ieee80211_local *local = sdata->local;
1501 	struct ieee80211_tx_info *info = IEEE80211_SKB_CB(skb);
1502 	struct ieee80211_hdr *hdr = (struct ieee80211_hdr *) skb->data;
1503 	int headroom;
1504 	bool may_encrypt;
1505 
1506 	may_encrypt = !(info->flags & IEEE80211_TX_INTFL_DONT_ENCRYPT);
1507 
1508 	headroom = local->tx_headroom;
1509 	if (may_encrypt)
1510 		headroom += sdata->encrypt_headroom;
1511 	headroom -= skb_headroom(skb);
1512 	headroom = max_t(int, 0, headroom);
1513 
1514 	if (ieee80211_skb_resize(sdata, skb, headroom, may_encrypt)) {
1515 		ieee80211_free_txskb(&local->hw, skb);
1516 		return;
1517 	}
1518 
1519 	hdr = (struct ieee80211_hdr *) skb->data;
1520 	info->control.vif = &sdata->vif;
1521 
1522 	if (ieee80211_vif_is_mesh(&sdata->vif)) {
1523 		if (ieee80211_is_data(hdr->frame_control) &&
1524 		    is_unicast_ether_addr(hdr->addr1)) {
1525 			if (mesh_nexthop_resolve(sdata, skb))
1526 				return; /* skb queued: don't free */
1527 		} else {
1528 			ieee80211_mps_set_frame_flags(sdata, NULL, hdr);
1529 		}
1530 	}
1531 
1532 	ieee80211_set_qos_hdr(sdata, skb);
1533 	ieee80211_tx(sdata, skb, false, band);
1534 }
1535 
1536 static bool ieee80211_parse_tx_radiotap(struct sk_buff *skb)
1537 {
1538 	struct ieee80211_radiotap_iterator iterator;
1539 	struct ieee80211_radiotap_header *rthdr =
1540 		(struct ieee80211_radiotap_header *) skb->data;
1541 	struct ieee80211_tx_info *info = IEEE80211_SKB_CB(skb);
1542 	int ret = ieee80211_radiotap_iterator_init(&iterator, rthdr, skb->len,
1543 						   NULL);
1544 	u16 txflags;
1545 
1546 	info->flags |= IEEE80211_TX_INTFL_DONT_ENCRYPT |
1547 		       IEEE80211_TX_CTL_DONTFRAG;
1548 
1549 	/*
1550 	 * for every radiotap entry that is present
1551 	 * (ieee80211_radiotap_iterator_next returns -ENOENT when no more
1552 	 * entries present, or -EINVAL on error)
1553 	 */
1554 
1555 	while (!ret) {
1556 		ret = ieee80211_radiotap_iterator_next(&iterator);
1557 
1558 		if (ret)
1559 			continue;
1560 
1561 		/* see if this argument is something we can use */
1562 		switch (iterator.this_arg_index) {
1563 		/*
1564 		 * You must take care when dereferencing iterator.this_arg
1565 		 * for multibyte types... the pointer is not aligned.  Use
1566 		 * get_unaligned((type *)iterator.this_arg) to dereference
1567 		 * iterator.this_arg for type "type" safely on all arches.
1568 		*/
1569 		case IEEE80211_RADIOTAP_FLAGS:
1570 			if (*iterator.this_arg & IEEE80211_RADIOTAP_F_FCS) {
1571 				/*
1572 				 * this indicates that the skb we have been
1573 				 * handed has the 32-bit FCS CRC at the end...
1574 				 * we should react to that by snipping it off
1575 				 * because it will be recomputed and added
1576 				 * on transmission
1577 				 */
1578 				if (skb->len < (iterator._max_length + FCS_LEN))
1579 					return false;
1580 
1581 				skb_trim(skb, skb->len - FCS_LEN);
1582 			}
1583 			if (*iterator.this_arg & IEEE80211_RADIOTAP_F_WEP)
1584 				info->flags &= ~IEEE80211_TX_INTFL_DONT_ENCRYPT;
1585 			if (*iterator.this_arg & IEEE80211_RADIOTAP_F_FRAG)
1586 				info->flags &= ~IEEE80211_TX_CTL_DONTFRAG;
1587 			break;
1588 
1589 		case IEEE80211_RADIOTAP_TX_FLAGS:
1590 			txflags = get_unaligned_le16(iterator.this_arg);
1591 			if (txflags & IEEE80211_RADIOTAP_F_TX_NOACK)
1592 				info->flags |= IEEE80211_TX_CTL_NO_ACK;
1593 			break;
1594 
1595 		/*
1596 		 * Please update the file
1597 		 * Documentation/networking/mac80211-injection.txt
1598 		 * when parsing new fields here.
1599 		 */
1600 
1601 		default:
1602 			break;
1603 		}
1604 	}
1605 
1606 	if (ret != -ENOENT) /* ie, if we didn't simply run out of fields */
1607 		return false;
1608 
1609 	/*
1610 	 * remove the radiotap header
1611 	 * iterator->_max_length was sanity-checked against
1612 	 * skb->len by iterator init
1613 	 */
1614 	skb_pull(skb, iterator._max_length);
1615 
1616 	return true;
1617 }
1618 
1619 netdev_tx_t ieee80211_monitor_start_xmit(struct sk_buff *skb,
1620 					 struct net_device *dev)
1621 {
1622 	struct ieee80211_local *local = wdev_priv(dev->ieee80211_ptr);
1623 	struct ieee80211_chanctx_conf *chanctx_conf;
1624 	struct ieee80211_radiotap_header *prthdr =
1625 		(struct ieee80211_radiotap_header *)skb->data;
1626 	struct ieee80211_tx_info *info = IEEE80211_SKB_CB(skb);
1627 	struct ieee80211_hdr *hdr;
1628 	struct ieee80211_sub_if_data *tmp_sdata, *sdata;
1629 	struct cfg80211_chan_def *chandef;
1630 	u16 len_rthdr;
1631 	int hdrlen;
1632 
1633 	/* check for not even having the fixed radiotap header part */
1634 	if (unlikely(skb->len < sizeof(struct ieee80211_radiotap_header)))
1635 		goto fail; /* too short to be possibly valid */
1636 
1637 	/* is it a header version we can trust to find length from? */
1638 	if (unlikely(prthdr->it_version))
1639 		goto fail; /* only version 0 is supported */
1640 
1641 	/* then there must be a radiotap header with a length we can use */
1642 	len_rthdr = ieee80211_get_radiotap_len(skb->data);
1643 
1644 	/* does the skb contain enough to deliver on the alleged length? */
1645 	if (unlikely(skb->len < len_rthdr))
1646 		goto fail; /* skb too short for claimed rt header extent */
1647 
1648 	/*
1649 	 * fix up the pointers accounting for the radiotap
1650 	 * header still being in there.  We are being given
1651 	 * a precooked IEEE80211 header so no need for
1652 	 * normal processing
1653 	 */
1654 	skb_set_mac_header(skb, len_rthdr);
1655 	/*
1656 	 * these are just fixed to the end of the rt area since we
1657 	 * don't have any better information and at this point, nobody cares
1658 	 */
1659 	skb_set_network_header(skb, len_rthdr);
1660 	skb_set_transport_header(skb, len_rthdr);
1661 
1662 	if (skb->len < len_rthdr + 2)
1663 		goto fail;
1664 
1665 	hdr = (struct ieee80211_hdr *)(skb->data + len_rthdr);
1666 	hdrlen = ieee80211_hdrlen(hdr->frame_control);
1667 
1668 	if (skb->len < len_rthdr + hdrlen)
1669 		goto fail;
1670 
1671 	/*
1672 	 * Initialize skb->protocol if the injected frame is a data frame
1673 	 * carrying a rfc1042 header
1674 	 */
1675 	if (ieee80211_is_data(hdr->frame_control) &&
1676 	    skb->len >= len_rthdr + hdrlen + sizeof(rfc1042_header) + 2) {
1677 		u8 *payload = (u8 *)hdr + hdrlen;
1678 
1679 		if (ether_addr_equal(payload, rfc1042_header))
1680 			skb->protocol = cpu_to_be16((payload[6] << 8) |
1681 						    payload[7]);
1682 	}
1683 
1684 	memset(info, 0, sizeof(*info));
1685 
1686 	info->flags = IEEE80211_TX_CTL_REQ_TX_STATUS |
1687 		      IEEE80211_TX_CTL_INJECTED;
1688 
1689 	/* process and remove the injection radiotap header */
1690 	if (!ieee80211_parse_tx_radiotap(skb))
1691 		goto fail;
1692 
1693 	rcu_read_lock();
1694 
1695 	/*
1696 	 * We process outgoing injected frames that have a local address
1697 	 * we handle as though they are non-injected frames.
1698 	 * This code here isn't entirely correct, the local MAC address
1699 	 * isn't always enough to find the interface to use; for proper
1700 	 * VLAN/WDS support we will need a different mechanism (which
1701 	 * likely isn't going to be monitor interfaces).
1702 	 */
1703 	sdata = IEEE80211_DEV_TO_SUB_IF(dev);
1704 
1705 	list_for_each_entry_rcu(tmp_sdata, &local->interfaces, list) {
1706 		if (!ieee80211_sdata_running(tmp_sdata))
1707 			continue;
1708 		if (tmp_sdata->vif.type == NL80211_IFTYPE_MONITOR ||
1709 		    tmp_sdata->vif.type == NL80211_IFTYPE_AP_VLAN ||
1710 		    tmp_sdata->vif.type == NL80211_IFTYPE_WDS)
1711 			continue;
1712 		if (ether_addr_equal(tmp_sdata->vif.addr, hdr->addr2)) {
1713 			sdata = tmp_sdata;
1714 			break;
1715 		}
1716 	}
1717 
1718 	chanctx_conf = rcu_dereference(sdata->vif.chanctx_conf);
1719 	if (!chanctx_conf) {
1720 		tmp_sdata = rcu_dereference(local->monitor_sdata);
1721 		if (tmp_sdata)
1722 			chanctx_conf =
1723 				rcu_dereference(tmp_sdata->vif.chanctx_conf);
1724 	}
1725 
1726 	if (chanctx_conf)
1727 		chandef = &chanctx_conf->def;
1728 	else if (!local->use_chanctx)
1729 		chandef = &local->_oper_chandef;
1730 	else
1731 		goto fail_rcu;
1732 
1733 	/*
1734 	 * Frame injection is not allowed if beaconing is not allowed
1735 	 * or if we need radar detection. Beaconing is usually not allowed when
1736 	 * the mode or operation (Adhoc, AP, Mesh) does not support DFS.
1737 	 * Passive scan is also used in world regulatory domains where
1738 	 * your country is not known and as such it should be treated as
1739 	 * NO TX unless the channel is explicitly allowed in which case
1740 	 * your current regulatory domain would not have the passive scan
1741 	 * flag.
1742 	 *
1743 	 * Since AP mode uses monitor interfaces to inject/TX management
1744 	 * frames we can make AP mode the exception to this rule once it
1745 	 * supports radar detection as its implementation can deal with
1746 	 * radar detection by itself. We can do that later by adding a
1747 	 * monitor flag interfaces used for AP support.
1748 	 */
1749 	if (!cfg80211_reg_can_beacon(local->hw.wiphy, chandef,
1750 				     sdata->vif.type))
1751 		goto fail_rcu;
1752 
1753 	ieee80211_xmit(sdata, skb, chandef->chan->band);
1754 	rcu_read_unlock();
1755 
1756 	return NETDEV_TX_OK;
1757 
1758 fail_rcu:
1759 	rcu_read_unlock();
1760 fail:
1761 	dev_kfree_skb(skb);
1762 	return NETDEV_TX_OK; /* meaning, we dealt with the skb */
1763 }
1764 
1765 /*
1766  * Measure Tx frame arrival time for Tx latency statistics calculation
1767  * A single Tx frame latency should be measured from when it is entering the
1768  * Kernel until we receive Tx complete confirmation indication and the skb is
1769  * freed.
1770  */
1771 static void ieee80211_tx_latency_start_msrmnt(struct ieee80211_local *local,
1772 					      struct sk_buff *skb)
1773 {
1774 	struct ieee80211_tx_latency_bin_ranges *tx_latency;
1775 
1776 	tx_latency = rcu_dereference(local->tx_latency);
1777 	if (!tx_latency)
1778 		return;
1779 	skb->tstamp = ktime_get();
1780 }
1781 
1782 /**
1783  * ieee80211_subif_start_xmit - netif start_xmit function for Ethernet-type
1784  * subinterfaces (wlan#, WDS, and VLAN interfaces)
1785  * @skb: packet to be sent
1786  * @dev: incoming interface
1787  *
1788  * Returns: 0 on success (and frees skb in this case) or 1 on failure (skb will
1789  * not be freed, and caller is responsible for either retrying later or freeing
1790  * skb).
1791  *
1792  * This function takes in an Ethernet header and encapsulates it with suitable
1793  * IEEE 802.11 header based on which interface the packet is coming in. The
1794  * encapsulated packet will then be passed to master interface, wlan#.11, for
1795  * transmission (through low-level driver).
1796  */
1797 netdev_tx_t ieee80211_subif_start_xmit(struct sk_buff *skb,
1798 				    struct net_device *dev)
1799 {
1800 	struct ieee80211_sub_if_data *sdata = IEEE80211_DEV_TO_SUB_IF(dev);
1801 	struct ieee80211_local *local = sdata->local;
1802 	struct ieee80211_tx_info *info;
1803 	int head_need;
1804 	u16 ethertype, hdrlen,  meshhdrlen = 0;
1805 	__le16 fc;
1806 	struct ieee80211_hdr hdr;
1807 	struct ieee80211s_hdr mesh_hdr __maybe_unused;
1808 	struct mesh_path __maybe_unused *mppath = NULL, *mpath = NULL;
1809 	const u8 *encaps_data;
1810 	int encaps_len, skip_header_bytes;
1811 	int nh_pos, h_pos;
1812 	struct sta_info *sta = NULL;
1813 	bool wme_sta = false, authorized = false, tdls_auth = false;
1814 	bool tdls_peer = false, tdls_setup_frame = false;
1815 	bool multicast;
1816 	u32 info_flags = 0;
1817 	u16 info_id = 0;
1818 	struct ieee80211_chanctx_conf *chanctx_conf;
1819 	struct ieee80211_sub_if_data *ap_sdata;
1820 	enum ieee80211_band band;
1821 
1822 	if (unlikely(skb->len < ETH_HLEN))
1823 		goto fail;
1824 
1825 	/* convert Ethernet header to proper 802.11 header (based on
1826 	 * operation mode) */
1827 	ethertype = (skb->data[12] << 8) | skb->data[13];
1828 	fc = cpu_to_le16(IEEE80211_FTYPE_DATA | IEEE80211_STYPE_DATA);
1829 
1830 	rcu_read_lock();
1831 
1832 	/* Measure frame arrival for Tx latency statistics calculation */
1833 	ieee80211_tx_latency_start_msrmnt(local, skb);
1834 
1835 	switch (sdata->vif.type) {
1836 	case NL80211_IFTYPE_AP_VLAN:
1837 		sta = rcu_dereference(sdata->u.vlan.sta);
1838 		if (sta) {
1839 			fc |= cpu_to_le16(IEEE80211_FCTL_FROMDS | IEEE80211_FCTL_TODS);
1840 			/* RA TA DA SA */
1841 			memcpy(hdr.addr1, sta->sta.addr, ETH_ALEN);
1842 			memcpy(hdr.addr2, sdata->vif.addr, ETH_ALEN);
1843 			memcpy(hdr.addr3, skb->data, ETH_ALEN);
1844 			memcpy(hdr.addr4, skb->data + ETH_ALEN, ETH_ALEN);
1845 			hdrlen = 30;
1846 			authorized = test_sta_flag(sta, WLAN_STA_AUTHORIZED);
1847 			wme_sta = test_sta_flag(sta, WLAN_STA_WME);
1848 		}
1849 		ap_sdata = container_of(sdata->bss, struct ieee80211_sub_if_data,
1850 					u.ap);
1851 		chanctx_conf = rcu_dereference(ap_sdata->vif.chanctx_conf);
1852 		if (!chanctx_conf)
1853 			goto fail_rcu;
1854 		band = chanctx_conf->def.chan->band;
1855 		if (sta)
1856 			break;
1857 		/* fall through */
1858 	case NL80211_IFTYPE_AP:
1859 		if (sdata->vif.type == NL80211_IFTYPE_AP)
1860 			chanctx_conf = rcu_dereference(sdata->vif.chanctx_conf);
1861 		if (!chanctx_conf)
1862 			goto fail_rcu;
1863 		fc |= cpu_to_le16(IEEE80211_FCTL_FROMDS);
1864 		/* DA BSSID SA */
1865 		memcpy(hdr.addr1, skb->data, ETH_ALEN);
1866 		memcpy(hdr.addr2, sdata->vif.addr, ETH_ALEN);
1867 		memcpy(hdr.addr3, skb->data + ETH_ALEN, ETH_ALEN);
1868 		hdrlen = 24;
1869 		band = chanctx_conf->def.chan->band;
1870 		break;
1871 	case NL80211_IFTYPE_WDS:
1872 		fc |= cpu_to_le16(IEEE80211_FCTL_FROMDS | IEEE80211_FCTL_TODS);
1873 		/* RA TA DA SA */
1874 		memcpy(hdr.addr1, sdata->u.wds.remote_addr, ETH_ALEN);
1875 		memcpy(hdr.addr2, sdata->vif.addr, ETH_ALEN);
1876 		memcpy(hdr.addr3, skb->data, ETH_ALEN);
1877 		memcpy(hdr.addr4, skb->data + ETH_ALEN, ETH_ALEN);
1878 		hdrlen = 30;
1879 		/*
1880 		 * This is the exception! WDS style interfaces are prohibited
1881 		 * when channel contexts are in used so this must be valid
1882 		 */
1883 		band = local->hw.conf.chandef.chan->band;
1884 		break;
1885 #ifdef CONFIG_MAC80211_MESH
1886 	case NL80211_IFTYPE_MESH_POINT:
1887 		if (!is_multicast_ether_addr(skb->data)) {
1888 			struct sta_info *next_hop;
1889 			bool mpp_lookup = true;
1890 
1891 			mpath = mesh_path_lookup(sdata, skb->data);
1892 			if (mpath) {
1893 				mpp_lookup = false;
1894 				next_hop = rcu_dereference(mpath->next_hop);
1895 				if (!next_hop ||
1896 				    !(mpath->flags & (MESH_PATH_ACTIVE |
1897 						      MESH_PATH_RESOLVING)))
1898 					mpp_lookup = true;
1899 			}
1900 
1901 			if (mpp_lookup)
1902 				mppath = mpp_path_lookup(sdata, skb->data);
1903 
1904 			if (mppath && mpath)
1905 				mesh_path_del(mpath->sdata, mpath->dst);
1906 		}
1907 
1908 		/*
1909 		 * Use address extension if it is a packet from
1910 		 * another interface or if we know the destination
1911 		 * is being proxied by a portal (i.e. portal address
1912 		 * differs from proxied address)
1913 		 */
1914 		if (ether_addr_equal(sdata->vif.addr, skb->data + ETH_ALEN) &&
1915 		    !(mppath && !ether_addr_equal(mppath->mpp, skb->data))) {
1916 			hdrlen = ieee80211_fill_mesh_addresses(&hdr, &fc,
1917 					skb->data, skb->data + ETH_ALEN);
1918 			meshhdrlen = ieee80211_new_mesh_header(sdata, &mesh_hdr,
1919 							       NULL, NULL);
1920 		} else {
1921 			/* DS -> MBSS (802.11-2012 13.11.3.3).
1922 			 * For unicast with unknown forwarding information,
1923 			 * destination might be in the MBSS or if that fails
1924 			 * forwarded to another mesh gate. In either case
1925 			 * resolution will be handled in ieee80211_xmit(), so
1926 			 * leave the original DA. This also works for mcast */
1927 			const u8 *mesh_da = skb->data;
1928 
1929 			if (mppath)
1930 				mesh_da = mppath->mpp;
1931 			else if (mpath)
1932 				mesh_da = mpath->dst;
1933 
1934 			hdrlen = ieee80211_fill_mesh_addresses(&hdr, &fc,
1935 					mesh_da, sdata->vif.addr);
1936 			if (is_multicast_ether_addr(mesh_da))
1937 				/* DA TA mSA AE:SA */
1938 				meshhdrlen = ieee80211_new_mesh_header(
1939 						sdata, &mesh_hdr,
1940 						skb->data + ETH_ALEN, NULL);
1941 			else
1942 				/* RA TA mDA mSA AE:DA SA */
1943 				meshhdrlen = ieee80211_new_mesh_header(
1944 						sdata, &mesh_hdr, skb->data,
1945 						skb->data + ETH_ALEN);
1946 
1947 		}
1948 		chanctx_conf = rcu_dereference(sdata->vif.chanctx_conf);
1949 		if (!chanctx_conf)
1950 			goto fail_rcu;
1951 		band = chanctx_conf->def.chan->band;
1952 		break;
1953 #endif
1954 	case NL80211_IFTYPE_STATION:
1955 		if (sdata->wdev.wiphy->flags & WIPHY_FLAG_SUPPORTS_TDLS) {
1956 			sta = sta_info_get(sdata, skb->data);
1957 			if (sta) {
1958 				authorized = test_sta_flag(sta,
1959 							WLAN_STA_AUTHORIZED);
1960 				wme_sta = test_sta_flag(sta, WLAN_STA_WME);
1961 				tdls_peer = test_sta_flag(sta,
1962 							  WLAN_STA_TDLS_PEER);
1963 				tdls_auth = test_sta_flag(sta,
1964 						WLAN_STA_TDLS_PEER_AUTH);
1965 			}
1966 
1967 			if (tdls_peer)
1968 				tdls_setup_frame =
1969 					ethertype == ETH_P_TDLS &&
1970 					skb->len > 14 &&
1971 					skb->data[14] == WLAN_TDLS_SNAP_RFTYPE;
1972 		}
1973 
1974 		/*
1975 		 * TDLS link during setup - throw out frames to peer. We allow
1976 		 * TDLS-setup frames to unauthorized peers for the special case
1977 		 * of a link teardown after a TDLS sta is removed due to being
1978 		 * unreachable.
1979 		 */
1980 		if (tdls_peer && !tdls_auth && !tdls_setup_frame)
1981 			goto fail_rcu;
1982 
1983 		/* send direct packets to authorized TDLS peers */
1984 		if (tdls_peer && tdls_auth) {
1985 			/* DA SA BSSID */
1986 			memcpy(hdr.addr1, skb->data, ETH_ALEN);
1987 			memcpy(hdr.addr2, skb->data + ETH_ALEN, ETH_ALEN);
1988 			memcpy(hdr.addr3, sdata->u.mgd.bssid, ETH_ALEN);
1989 			hdrlen = 24;
1990 		}  else if (sdata->u.mgd.use_4addr &&
1991 			    cpu_to_be16(ethertype) != sdata->control_port_protocol) {
1992 			fc |= cpu_to_le16(IEEE80211_FCTL_FROMDS |
1993 					  IEEE80211_FCTL_TODS);
1994 			/* RA TA DA SA */
1995 			memcpy(hdr.addr1, sdata->u.mgd.bssid, ETH_ALEN);
1996 			memcpy(hdr.addr2, sdata->vif.addr, ETH_ALEN);
1997 			memcpy(hdr.addr3, skb->data, ETH_ALEN);
1998 			memcpy(hdr.addr4, skb->data + ETH_ALEN, ETH_ALEN);
1999 			hdrlen = 30;
2000 		} else {
2001 			fc |= cpu_to_le16(IEEE80211_FCTL_TODS);
2002 			/* BSSID SA DA */
2003 			memcpy(hdr.addr1, sdata->u.mgd.bssid, ETH_ALEN);
2004 			memcpy(hdr.addr2, skb->data + ETH_ALEN, ETH_ALEN);
2005 			memcpy(hdr.addr3, skb->data, ETH_ALEN);
2006 			hdrlen = 24;
2007 		}
2008 		chanctx_conf = rcu_dereference(sdata->vif.chanctx_conf);
2009 		if (!chanctx_conf)
2010 			goto fail_rcu;
2011 		band = chanctx_conf->def.chan->band;
2012 		break;
2013 	case NL80211_IFTYPE_ADHOC:
2014 		/* DA SA BSSID */
2015 		memcpy(hdr.addr1, skb->data, ETH_ALEN);
2016 		memcpy(hdr.addr2, skb->data + ETH_ALEN, ETH_ALEN);
2017 		memcpy(hdr.addr3, sdata->u.ibss.bssid, ETH_ALEN);
2018 		hdrlen = 24;
2019 		chanctx_conf = rcu_dereference(sdata->vif.chanctx_conf);
2020 		if (!chanctx_conf)
2021 			goto fail_rcu;
2022 		band = chanctx_conf->def.chan->band;
2023 		break;
2024 	default:
2025 		goto fail_rcu;
2026 	}
2027 
2028 	/*
2029 	 * There's no need to try to look up the destination
2030 	 * if it is a multicast address (which can only happen
2031 	 * in AP mode)
2032 	 */
2033 	multicast = is_multicast_ether_addr(hdr.addr1);
2034 	if (!multicast) {
2035 		sta = sta_info_get(sdata, hdr.addr1);
2036 		if (sta) {
2037 			authorized = test_sta_flag(sta, WLAN_STA_AUTHORIZED);
2038 			wme_sta = test_sta_flag(sta, WLAN_STA_WME);
2039 		}
2040 	}
2041 
2042 	/* For mesh, the use of the QoS header is mandatory */
2043 	if (ieee80211_vif_is_mesh(&sdata->vif))
2044 		wme_sta = true;
2045 
2046 	/* receiver and we are QoS enabled, use a QoS type frame */
2047 	if (wme_sta && local->hw.queues >= IEEE80211_NUM_ACS) {
2048 		fc |= cpu_to_le16(IEEE80211_STYPE_QOS_DATA);
2049 		hdrlen += 2;
2050 	}
2051 
2052 	/*
2053 	 * Drop unicast frames to unauthorised stations unless they are
2054 	 * EAPOL frames from the local station.
2055 	 */
2056 	if (unlikely(!ieee80211_vif_is_mesh(&sdata->vif) &&
2057 		     !multicast && !authorized &&
2058 		     (cpu_to_be16(ethertype) != sdata->control_port_protocol ||
2059 		      !ether_addr_equal(sdata->vif.addr, skb->data + ETH_ALEN)))) {
2060 #ifdef CONFIG_MAC80211_VERBOSE_DEBUG
2061 		net_info_ratelimited("%s: dropped frame to %pM (unauthorized port)\n",
2062 				    dev->name, hdr.addr1);
2063 #endif
2064 
2065 		I802_DEBUG_INC(local->tx_handlers_drop_unauth_port);
2066 
2067 		goto fail_rcu;
2068 	}
2069 
2070 	if (unlikely(!multicast && skb->sk &&
2071 		     skb_shinfo(skb)->tx_flags & SKBTX_WIFI_STATUS)) {
2072 		struct sk_buff *orig_skb = skb;
2073 
2074 		skb = skb_clone(skb, GFP_ATOMIC);
2075 		if (skb) {
2076 			unsigned long flags;
2077 			int id;
2078 
2079 			spin_lock_irqsave(&local->ack_status_lock, flags);
2080 			id = idr_alloc(&local->ack_status_frames, orig_skb,
2081 				       1, 0x10000, GFP_ATOMIC);
2082 			spin_unlock_irqrestore(&local->ack_status_lock, flags);
2083 
2084 			if (id >= 0) {
2085 				info_id = id;
2086 				info_flags |= IEEE80211_TX_CTL_REQ_TX_STATUS;
2087 			} else if (skb_shared(skb)) {
2088 				kfree_skb(orig_skb);
2089 			} else {
2090 				kfree_skb(skb);
2091 				skb = orig_skb;
2092 			}
2093 		} else {
2094 			/* couldn't clone -- lose tx status ... */
2095 			skb = orig_skb;
2096 		}
2097 	}
2098 
2099 	/*
2100 	 * If the skb is shared we need to obtain our own copy.
2101 	 */
2102 	if (skb_shared(skb)) {
2103 		struct sk_buff *tmp_skb = skb;
2104 
2105 		/* can't happen -- skb is a clone if info_id != 0 */
2106 		WARN_ON(info_id);
2107 
2108 		skb = skb_clone(skb, GFP_ATOMIC);
2109 		kfree_skb(tmp_skb);
2110 
2111 		if (!skb)
2112 			goto fail_rcu;
2113 	}
2114 
2115 	hdr.frame_control = fc;
2116 	hdr.duration_id = 0;
2117 	hdr.seq_ctrl = 0;
2118 
2119 	skip_header_bytes = ETH_HLEN;
2120 	if (ethertype == ETH_P_AARP || ethertype == ETH_P_IPX) {
2121 		encaps_data = bridge_tunnel_header;
2122 		encaps_len = sizeof(bridge_tunnel_header);
2123 		skip_header_bytes -= 2;
2124 	} else if (ethertype >= ETH_P_802_3_MIN) {
2125 		encaps_data = rfc1042_header;
2126 		encaps_len = sizeof(rfc1042_header);
2127 		skip_header_bytes -= 2;
2128 	} else {
2129 		encaps_data = NULL;
2130 		encaps_len = 0;
2131 	}
2132 
2133 	nh_pos = skb_network_header(skb) - skb->data;
2134 	h_pos = skb_transport_header(skb) - skb->data;
2135 
2136 	skb_pull(skb, skip_header_bytes);
2137 	nh_pos -= skip_header_bytes;
2138 	h_pos -= skip_header_bytes;
2139 
2140 	head_need = hdrlen + encaps_len + meshhdrlen - skb_headroom(skb);
2141 
2142 	/*
2143 	 * So we need to modify the skb header and hence need a copy of
2144 	 * that. The head_need variable above doesn't, so far, include
2145 	 * the needed header space that we don't need right away. If we
2146 	 * can, then we don't reallocate right now but only after the
2147 	 * frame arrives at the master device (if it does...)
2148 	 *
2149 	 * If we cannot, however, then we will reallocate to include all
2150 	 * the ever needed space. Also, if we need to reallocate it anyway,
2151 	 * make it big enough for everything we may ever need.
2152 	 */
2153 
2154 	if (head_need > 0 || skb_cloned(skb)) {
2155 		head_need += sdata->encrypt_headroom;
2156 		head_need += local->tx_headroom;
2157 		head_need = max_t(int, 0, head_need);
2158 		if (ieee80211_skb_resize(sdata, skb, head_need, true)) {
2159 			ieee80211_free_txskb(&local->hw, skb);
2160 			skb = NULL;
2161 			goto fail_rcu;
2162 		}
2163 	}
2164 
2165 	if (encaps_data) {
2166 		memcpy(skb_push(skb, encaps_len), encaps_data, encaps_len);
2167 		nh_pos += encaps_len;
2168 		h_pos += encaps_len;
2169 	}
2170 
2171 #ifdef CONFIG_MAC80211_MESH
2172 	if (meshhdrlen > 0) {
2173 		memcpy(skb_push(skb, meshhdrlen), &mesh_hdr, meshhdrlen);
2174 		nh_pos += meshhdrlen;
2175 		h_pos += meshhdrlen;
2176 	}
2177 #endif
2178 
2179 	if (ieee80211_is_data_qos(fc)) {
2180 		__le16 *qos_control;
2181 
2182 		qos_control = (__le16 *) skb_push(skb, 2);
2183 		memcpy(skb_push(skb, hdrlen - 2), &hdr, hdrlen - 2);
2184 		/*
2185 		 * Maybe we could actually set some fields here, for now just
2186 		 * initialise to zero to indicate no special operation.
2187 		 */
2188 		*qos_control = 0;
2189 	} else
2190 		memcpy(skb_push(skb, hdrlen), &hdr, hdrlen);
2191 
2192 	nh_pos += hdrlen;
2193 	h_pos += hdrlen;
2194 
2195 	dev->stats.tx_packets++;
2196 	dev->stats.tx_bytes += skb->len;
2197 
2198 	/* Update skb pointers to various headers since this modified frame
2199 	 * is going to go through Linux networking code that may potentially
2200 	 * need things like pointer to IP header. */
2201 	skb_set_mac_header(skb, 0);
2202 	skb_set_network_header(skb, nh_pos);
2203 	skb_set_transport_header(skb, h_pos);
2204 
2205 	info = IEEE80211_SKB_CB(skb);
2206 	memset(info, 0, sizeof(*info));
2207 
2208 	dev->trans_start = jiffies;
2209 
2210 	info->flags = info_flags;
2211 	info->ack_frame_id = info_id;
2212 
2213 	ieee80211_xmit(sdata, skb, band);
2214 	rcu_read_unlock();
2215 
2216 	return NETDEV_TX_OK;
2217 
2218  fail_rcu:
2219 	rcu_read_unlock();
2220  fail:
2221 	dev_kfree_skb(skb);
2222 	return NETDEV_TX_OK;
2223 }
2224 
2225 
2226 /*
2227  * ieee80211_clear_tx_pending may not be called in a context where
2228  * it is possible that it packets could come in again.
2229  */
2230 void ieee80211_clear_tx_pending(struct ieee80211_local *local)
2231 {
2232 	struct sk_buff *skb;
2233 	int i;
2234 
2235 	for (i = 0; i < local->hw.queues; i++) {
2236 		while ((skb = skb_dequeue(&local->pending[i])) != NULL)
2237 			ieee80211_free_txskb(&local->hw, skb);
2238 	}
2239 }
2240 
2241 /*
2242  * Returns false if the frame couldn't be transmitted but was queued instead,
2243  * which in this case means re-queued -- take as an indication to stop sending
2244  * more pending frames.
2245  */
2246 static bool ieee80211_tx_pending_skb(struct ieee80211_local *local,
2247 				     struct sk_buff *skb)
2248 {
2249 	struct ieee80211_tx_info *info = IEEE80211_SKB_CB(skb);
2250 	struct ieee80211_sub_if_data *sdata;
2251 	struct sta_info *sta;
2252 	struct ieee80211_hdr *hdr;
2253 	bool result;
2254 	struct ieee80211_chanctx_conf *chanctx_conf;
2255 
2256 	sdata = vif_to_sdata(info->control.vif);
2257 
2258 	if (info->flags & IEEE80211_TX_INTFL_NEED_TXPROCESSING) {
2259 		chanctx_conf = rcu_dereference(sdata->vif.chanctx_conf);
2260 		if (unlikely(!chanctx_conf)) {
2261 			dev_kfree_skb(skb);
2262 			return true;
2263 		}
2264 		result = ieee80211_tx(sdata, skb, true,
2265 				      chanctx_conf->def.chan->band);
2266 	} else {
2267 		struct sk_buff_head skbs;
2268 
2269 		__skb_queue_head_init(&skbs);
2270 		__skb_queue_tail(&skbs, skb);
2271 
2272 		hdr = (struct ieee80211_hdr *)skb->data;
2273 		sta = sta_info_get(sdata, hdr->addr1);
2274 
2275 		result = __ieee80211_tx(local, &skbs, skb->len, sta, true);
2276 	}
2277 
2278 	return result;
2279 }
2280 
2281 /*
2282  * Transmit all pending packets. Called from tasklet.
2283  */
2284 void ieee80211_tx_pending(unsigned long data)
2285 {
2286 	struct ieee80211_local *local = (struct ieee80211_local *)data;
2287 	unsigned long flags;
2288 	int i;
2289 	bool txok;
2290 
2291 	rcu_read_lock();
2292 
2293 	spin_lock_irqsave(&local->queue_stop_reason_lock, flags);
2294 	for (i = 0; i < local->hw.queues; i++) {
2295 		/*
2296 		 * If queue is stopped by something other than due to pending
2297 		 * frames, or we have no pending frames, proceed to next queue.
2298 		 */
2299 		if (local->queue_stop_reasons[i] ||
2300 		    skb_queue_empty(&local->pending[i]))
2301 			continue;
2302 
2303 		while (!skb_queue_empty(&local->pending[i])) {
2304 			struct sk_buff *skb = __skb_dequeue(&local->pending[i]);
2305 			struct ieee80211_tx_info *info = IEEE80211_SKB_CB(skb);
2306 
2307 			if (WARN_ON(!info->control.vif)) {
2308 				ieee80211_free_txskb(&local->hw, skb);
2309 				continue;
2310 			}
2311 
2312 			spin_unlock_irqrestore(&local->queue_stop_reason_lock,
2313 						flags);
2314 
2315 			txok = ieee80211_tx_pending_skb(local, skb);
2316 			spin_lock_irqsave(&local->queue_stop_reason_lock,
2317 					  flags);
2318 			if (!txok)
2319 				break;
2320 		}
2321 
2322 		if (skb_queue_empty(&local->pending[i]))
2323 			ieee80211_propagate_queue_wake(local, i);
2324 	}
2325 	spin_unlock_irqrestore(&local->queue_stop_reason_lock, flags);
2326 
2327 	rcu_read_unlock();
2328 }
2329 
2330 /* functions for drivers to get certain frames */
2331 
2332 static void __ieee80211_beacon_add_tim(struct ieee80211_sub_if_data *sdata,
2333 				       struct ps_data *ps, struct sk_buff *skb,
2334 				       bool is_template)
2335 {
2336 	u8 *pos, *tim;
2337 	int aid0 = 0;
2338 	int i, have_bits = 0, n1, n2;
2339 
2340 	/* Generate bitmap for TIM only if there are any STAs in power save
2341 	 * mode. */
2342 	if (atomic_read(&ps->num_sta_ps) > 0)
2343 		/* in the hope that this is faster than
2344 		 * checking byte-for-byte */
2345 		have_bits = !bitmap_empty((unsigned long *)ps->tim,
2346 					  IEEE80211_MAX_AID+1);
2347 	if (!is_template) {
2348 		if (ps->dtim_count == 0)
2349 			ps->dtim_count = sdata->vif.bss_conf.dtim_period - 1;
2350 		else
2351 			ps->dtim_count--;
2352 	}
2353 
2354 	tim = pos = (u8 *) skb_put(skb, 6);
2355 	*pos++ = WLAN_EID_TIM;
2356 	*pos++ = 4;
2357 	*pos++ = ps->dtim_count;
2358 	*pos++ = sdata->vif.bss_conf.dtim_period;
2359 
2360 	if (ps->dtim_count == 0 && !skb_queue_empty(&ps->bc_buf))
2361 		aid0 = 1;
2362 
2363 	ps->dtim_bc_mc = aid0 == 1;
2364 
2365 	if (have_bits) {
2366 		/* Find largest even number N1 so that bits numbered 1 through
2367 		 * (N1 x 8) - 1 in the bitmap are 0 and number N2 so that bits
2368 		 * (N2 + 1) x 8 through 2007 are 0. */
2369 		n1 = 0;
2370 		for (i = 0; i < IEEE80211_MAX_TIM_LEN; i++) {
2371 			if (ps->tim[i]) {
2372 				n1 = i & 0xfe;
2373 				break;
2374 			}
2375 		}
2376 		n2 = n1;
2377 		for (i = IEEE80211_MAX_TIM_LEN - 1; i >= n1; i--) {
2378 			if (ps->tim[i]) {
2379 				n2 = i;
2380 				break;
2381 			}
2382 		}
2383 
2384 		/* Bitmap control */
2385 		*pos++ = n1 | aid0;
2386 		/* Part Virt Bitmap */
2387 		skb_put(skb, n2 - n1);
2388 		memcpy(pos, ps->tim + n1, n2 - n1 + 1);
2389 
2390 		tim[1] = n2 - n1 + 4;
2391 	} else {
2392 		*pos++ = aid0; /* Bitmap control */
2393 		*pos++ = 0; /* Part Virt Bitmap */
2394 	}
2395 }
2396 
2397 static int ieee80211_beacon_add_tim(struct ieee80211_sub_if_data *sdata,
2398 				    struct ps_data *ps, struct sk_buff *skb,
2399 				    bool is_template)
2400 {
2401 	struct ieee80211_local *local = sdata->local;
2402 
2403 	/*
2404 	 * Not very nice, but we want to allow the driver to call
2405 	 * ieee80211_beacon_get() as a response to the set_tim()
2406 	 * callback. That, however, is already invoked under the
2407 	 * sta_lock to guarantee consistent and race-free update
2408 	 * of the tim bitmap in mac80211 and the driver.
2409 	 */
2410 	if (local->tim_in_locked_section) {
2411 		__ieee80211_beacon_add_tim(sdata, ps, skb, is_template);
2412 	} else {
2413 		spin_lock_bh(&local->tim_lock);
2414 		__ieee80211_beacon_add_tim(sdata, ps, skb, is_template);
2415 		spin_unlock_bh(&local->tim_lock);
2416 	}
2417 
2418 	return 0;
2419 }
2420 
2421 static void ieee80211_set_csa(struct ieee80211_sub_if_data *sdata,
2422 			      struct beacon_data *beacon)
2423 {
2424 	struct probe_resp *resp;
2425 	u8 *beacon_data;
2426 	size_t beacon_data_len;
2427 	int i;
2428 	u8 count = beacon->csa_current_counter;
2429 
2430 	switch (sdata->vif.type) {
2431 	case NL80211_IFTYPE_AP:
2432 		beacon_data = beacon->tail;
2433 		beacon_data_len = beacon->tail_len;
2434 		break;
2435 	case NL80211_IFTYPE_ADHOC:
2436 		beacon_data = beacon->head;
2437 		beacon_data_len = beacon->head_len;
2438 		break;
2439 	case NL80211_IFTYPE_MESH_POINT:
2440 		beacon_data = beacon->head;
2441 		beacon_data_len = beacon->head_len;
2442 		break;
2443 	default:
2444 		return;
2445 	}
2446 
2447 	rcu_read_lock();
2448 	for (i = 0; i < IEEE80211_MAX_CSA_COUNTERS_NUM; ++i) {
2449 		resp = rcu_dereference(sdata->u.ap.probe_resp);
2450 
2451 		if (beacon->csa_counter_offsets[i]) {
2452 			if (WARN_ON_ONCE(beacon->csa_counter_offsets[i] >=
2453 					 beacon_data_len)) {
2454 				rcu_read_unlock();
2455 				return;
2456 			}
2457 
2458 			beacon_data[beacon->csa_counter_offsets[i]] = count;
2459 		}
2460 
2461 		if (sdata->vif.type == NL80211_IFTYPE_AP && resp)
2462 			resp->data[resp->csa_counter_offsets[i]] = count;
2463 	}
2464 	rcu_read_unlock();
2465 }
2466 
2467 u8 ieee80211_csa_update_counter(struct ieee80211_vif *vif)
2468 {
2469 	struct ieee80211_sub_if_data *sdata = vif_to_sdata(vif);
2470 	struct beacon_data *beacon = NULL;
2471 	u8 count = 0;
2472 
2473 	rcu_read_lock();
2474 
2475 	if (sdata->vif.type == NL80211_IFTYPE_AP)
2476 		beacon = rcu_dereference(sdata->u.ap.beacon);
2477 	else if (sdata->vif.type == NL80211_IFTYPE_ADHOC)
2478 		beacon = rcu_dereference(sdata->u.ibss.presp);
2479 	else if (ieee80211_vif_is_mesh(&sdata->vif))
2480 		beacon = rcu_dereference(sdata->u.mesh.beacon);
2481 
2482 	if (!beacon)
2483 		goto unlock;
2484 
2485 	beacon->csa_current_counter--;
2486 
2487 	/* the counter should never reach 0 */
2488 	WARN_ON_ONCE(!beacon->csa_current_counter);
2489 	count = beacon->csa_current_counter;
2490 
2491 unlock:
2492 	rcu_read_unlock();
2493 	return count;
2494 }
2495 EXPORT_SYMBOL(ieee80211_csa_update_counter);
2496 
2497 bool ieee80211_csa_is_complete(struct ieee80211_vif *vif)
2498 {
2499 	struct ieee80211_sub_if_data *sdata = vif_to_sdata(vif);
2500 	struct beacon_data *beacon = NULL;
2501 	u8 *beacon_data;
2502 	size_t beacon_data_len;
2503 	int ret = false;
2504 
2505 	if (!ieee80211_sdata_running(sdata))
2506 		return false;
2507 
2508 	rcu_read_lock();
2509 	if (vif->type == NL80211_IFTYPE_AP) {
2510 		struct ieee80211_if_ap *ap = &sdata->u.ap;
2511 
2512 		beacon = rcu_dereference(ap->beacon);
2513 		if (WARN_ON(!beacon || !beacon->tail))
2514 			goto out;
2515 		beacon_data = beacon->tail;
2516 		beacon_data_len = beacon->tail_len;
2517 	} else if (vif->type == NL80211_IFTYPE_ADHOC) {
2518 		struct ieee80211_if_ibss *ifibss = &sdata->u.ibss;
2519 
2520 		beacon = rcu_dereference(ifibss->presp);
2521 		if (!beacon)
2522 			goto out;
2523 
2524 		beacon_data = beacon->head;
2525 		beacon_data_len = beacon->head_len;
2526 	} else if (vif->type == NL80211_IFTYPE_MESH_POINT) {
2527 		struct ieee80211_if_mesh *ifmsh = &sdata->u.mesh;
2528 
2529 		beacon = rcu_dereference(ifmsh->beacon);
2530 		if (!beacon)
2531 			goto out;
2532 
2533 		beacon_data = beacon->head;
2534 		beacon_data_len = beacon->head_len;
2535 	} else {
2536 		WARN_ON(1);
2537 		goto out;
2538 	}
2539 
2540 	if (!beacon->csa_counter_offsets[0])
2541 		goto out;
2542 
2543 	if (WARN_ON_ONCE(beacon->csa_counter_offsets[0] > beacon_data_len))
2544 		goto out;
2545 
2546 	if (beacon_data[beacon->csa_counter_offsets[0]] == 1)
2547 		ret = true;
2548  out:
2549 	rcu_read_unlock();
2550 
2551 	return ret;
2552 }
2553 EXPORT_SYMBOL(ieee80211_csa_is_complete);
2554 
2555 static struct sk_buff *
2556 __ieee80211_beacon_get(struct ieee80211_hw *hw,
2557 		       struct ieee80211_vif *vif,
2558 		       struct ieee80211_mutable_offsets *offs,
2559 		       bool is_template)
2560 {
2561 	struct ieee80211_local *local = hw_to_local(hw);
2562 	struct beacon_data *beacon = NULL;
2563 	struct sk_buff *skb = NULL;
2564 	struct ieee80211_tx_info *info;
2565 	struct ieee80211_sub_if_data *sdata = NULL;
2566 	enum ieee80211_band band;
2567 	struct ieee80211_tx_rate_control txrc;
2568 	struct ieee80211_chanctx_conf *chanctx_conf;
2569 	int csa_off_base = 0;
2570 
2571 	rcu_read_lock();
2572 
2573 	sdata = vif_to_sdata(vif);
2574 	chanctx_conf = rcu_dereference(sdata->vif.chanctx_conf);
2575 
2576 	if (!ieee80211_sdata_running(sdata) || !chanctx_conf)
2577 		goto out;
2578 
2579 	if (offs)
2580 		memset(offs, 0, sizeof(*offs));
2581 
2582 	if (sdata->vif.type == NL80211_IFTYPE_AP) {
2583 		struct ieee80211_if_ap *ap = &sdata->u.ap;
2584 
2585 		beacon = rcu_dereference(ap->beacon);
2586 		if (beacon) {
2587 			if (beacon->csa_counter_offsets[0]) {
2588 				if (!is_template)
2589 					ieee80211_csa_update_counter(vif);
2590 
2591 				ieee80211_set_csa(sdata, beacon);
2592 			}
2593 
2594 			/*
2595 			 * headroom, head length,
2596 			 * tail length and maximum TIM length
2597 			 */
2598 			skb = dev_alloc_skb(local->tx_headroom +
2599 					    beacon->head_len +
2600 					    beacon->tail_len + 256 +
2601 					    local->hw.extra_beacon_tailroom);
2602 			if (!skb)
2603 				goto out;
2604 
2605 			skb_reserve(skb, local->tx_headroom);
2606 			memcpy(skb_put(skb, beacon->head_len), beacon->head,
2607 			       beacon->head_len);
2608 
2609 			ieee80211_beacon_add_tim(sdata, &ap->ps, skb,
2610 						 is_template);
2611 
2612 			if (offs) {
2613 				offs->tim_offset = beacon->head_len;
2614 				offs->tim_length = skb->len - beacon->head_len;
2615 
2616 				/* for AP the csa offsets are from tail */
2617 				csa_off_base = skb->len;
2618 			}
2619 
2620 			if (beacon->tail)
2621 				memcpy(skb_put(skb, beacon->tail_len),
2622 				       beacon->tail, beacon->tail_len);
2623 		} else
2624 			goto out;
2625 	} else if (sdata->vif.type == NL80211_IFTYPE_ADHOC) {
2626 		struct ieee80211_if_ibss *ifibss = &sdata->u.ibss;
2627 		struct ieee80211_hdr *hdr;
2628 
2629 		beacon = rcu_dereference(ifibss->presp);
2630 		if (!beacon)
2631 			goto out;
2632 
2633 		if (beacon->csa_counter_offsets[0]) {
2634 			if (!is_template)
2635 				ieee80211_csa_update_counter(vif);
2636 
2637 			ieee80211_set_csa(sdata, beacon);
2638 		}
2639 
2640 		skb = dev_alloc_skb(local->tx_headroom + beacon->head_len +
2641 				    local->hw.extra_beacon_tailroom);
2642 		if (!skb)
2643 			goto out;
2644 		skb_reserve(skb, local->tx_headroom);
2645 		memcpy(skb_put(skb, beacon->head_len), beacon->head,
2646 		       beacon->head_len);
2647 
2648 		hdr = (struct ieee80211_hdr *) skb->data;
2649 		hdr->frame_control = cpu_to_le16(IEEE80211_FTYPE_MGMT |
2650 						 IEEE80211_STYPE_BEACON);
2651 	} else if (ieee80211_vif_is_mesh(&sdata->vif)) {
2652 		struct ieee80211_if_mesh *ifmsh = &sdata->u.mesh;
2653 
2654 		beacon = rcu_dereference(ifmsh->beacon);
2655 		if (!beacon)
2656 			goto out;
2657 
2658 		if (beacon->csa_counter_offsets[0]) {
2659 			if (!is_template)
2660 				/* TODO: For mesh csa_counter is in TU, so
2661 				 * decrementing it by one isn't correct, but
2662 				 * for now we leave it consistent with overall
2663 				 * mac80211's behavior.
2664 				 */
2665 				ieee80211_csa_update_counter(vif);
2666 
2667 			ieee80211_set_csa(sdata, beacon);
2668 		}
2669 
2670 		if (ifmsh->sync_ops)
2671 			ifmsh->sync_ops->adjust_tbtt(sdata, beacon);
2672 
2673 		skb = dev_alloc_skb(local->tx_headroom +
2674 				    beacon->head_len +
2675 				    256 + /* TIM IE */
2676 				    beacon->tail_len +
2677 				    local->hw.extra_beacon_tailroom);
2678 		if (!skb)
2679 			goto out;
2680 		skb_reserve(skb, local->tx_headroom);
2681 		memcpy(skb_put(skb, beacon->head_len), beacon->head,
2682 		       beacon->head_len);
2683 		ieee80211_beacon_add_tim(sdata, &ifmsh->ps, skb, is_template);
2684 
2685 		if (offs) {
2686 			offs->tim_offset = beacon->head_len;
2687 			offs->tim_length = skb->len - beacon->head_len;
2688 		}
2689 
2690 		memcpy(skb_put(skb, beacon->tail_len), beacon->tail,
2691 		       beacon->tail_len);
2692 	} else {
2693 		WARN_ON(1);
2694 		goto out;
2695 	}
2696 
2697 	/* CSA offsets */
2698 	if (offs && beacon) {
2699 		int i;
2700 
2701 		for (i = 0; i < IEEE80211_MAX_CSA_COUNTERS_NUM; i++) {
2702 			u16 csa_off = beacon->csa_counter_offsets[i];
2703 
2704 			if (!csa_off)
2705 				continue;
2706 
2707 			offs->csa_counter_offs[i] = csa_off_base + csa_off;
2708 		}
2709 	}
2710 
2711 	band = chanctx_conf->def.chan->band;
2712 
2713 	info = IEEE80211_SKB_CB(skb);
2714 
2715 	info->flags |= IEEE80211_TX_INTFL_DONT_ENCRYPT;
2716 	info->flags |= IEEE80211_TX_CTL_NO_ACK;
2717 	info->band = band;
2718 
2719 	memset(&txrc, 0, sizeof(txrc));
2720 	txrc.hw = hw;
2721 	txrc.sband = local->hw.wiphy->bands[band];
2722 	txrc.bss_conf = &sdata->vif.bss_conf;
2723 	txrc.skb = skb;
2724 	txrc.reported_rate.idx = -1;
2725 	txrc.rate_idx_mask = sdata->rc_rateidx_mask[band];
2726 	if (txrc.rate_idx_mask == (1 << txrc.sband->n_bitrates) - 1)
2727 		txrc.max_rate_idx = -1;
2728 	else
2729 		txrc.max_rate_idx = fls(txrc.rate_idx_mask) - 1;
2730 	txrc.bss = true;
2731 	rate_control_get_rate(sdata, NULL, &txrc);
2732 
2733 	info->control.vif = vif;
2734 
2735 	info->flags |= IEEE80211_TX_CTL_CLEAR_PS_FILT |
2736 			IEEE80211_TX_CTL_ASSIGN_SEQ |
2737 			IEEE80211_TX_CTL_FIRST_FRAGMENT;
2738  out:
2739 	rcu_read_unlock();
2740 	return skb;
2741 
2742 }
2743 
2744 struct sk_buff *
2745 ieee80211_beacon_get_template(struct ieee80211_hw *hw,
2746 			      struct ieee80211_vif *vif,
2747 			      struct ieee80211_mutable_offsets *offs)
2748 {
2749 	return __ieee80211_beacon_get(hw, vif, offs, true);
2750 }
2751 EXPORT_SYMBOL(ieee80211_beacon_get_template);
2752 
2753 struct sk_buff *ieee80211_beacon_get_tim(struct ieee80211_hw *hw,
2754 					 struct ieee80211_vif *vif,
2755 					 u16 *tim_offset, u16 *tim_length)
2756 {
2757 	struct ieee80211_mutable_offsets offs = {};
2758 	struct sk_buff *bcn = __ieee80211_beacon_get(hw, vif, &offs, false);
2759 
2760 	if (tim_offset)
2761 		*tim_offset = offs.tim_offset;
2762 
2763 	if (tim_length)
2764 		*tim_length = offs.tim_length;
2765 
2766 	return bcn;
2767 }
2768 EXPORT_SYMBOL(ieee80211_beacon_get_tim);
2769 
2770 struct sk_buff *ieee80211_proberesp_get(struct ieee80211_hw *hw,
2771 					struct ieee80211_vif *vif)
2772 {
2773 	struct ieee80211_if_ap *ap = NULL;
2774 	struct sk_buff *skb = NULL;
2775 	struct probe_resp *presp = NULL;
2776 	struct ieee80211_hdr *hdr;
2777 	struct ieee80211_sub_if_data *sdata = vif_to_sdata(vif);
2778 
2779 	if (sdata->vif.type != NL80211_IFTYPE_AP)
2780 		return NULL;
2781 
2782 	rcu_read_lock();
2783 
2784 	ap = &sdata->u.ap;
2785 	presp = rcu_dereference(ap->probe_resp);
2786 	if (!presp)
2787 		goto out;
2788 
2789 	skb = dev_alloc_skb(presp->len);
2790 	if (!skb)
2791 		goto out;
2792 
2793 	memcpy(skb_put(skb, presp->len), presp->data, presp->len);
2794 
2795 	hdr = (struct ieee80211_hdr *) skb->data;
2796 	memset(hdr->addr1, 0, sizeof(hdr->addr1));
2797 
2798 out:
2799 	rcu_read_unlock();
2800 	return skb;
2801 }
2802 EXPORT_SYMBOL(ieee80211_proberesp_get);
2803 
2804 struct sk_buff *ieee80211_pspoll_get(struct ieee80211_hw *hw,
2805 				     struct ieee80211_vif *vif)
2806 {
2807 	struct ieee80211_sub_if_data *sdata;
2808 	struct ieee80211_if_managed *ifmgd;
2809 	struct ieee80211_pspoll *pspoll;
2810 	struct ieee80211_local *local;
2811 	struct sk_buff *skb;
2812 
2813 	if (WARN_ON(vif->type != NL80211_IFTYPE_STATION))
2814 		return NULL;
2815 
2816 	sdata = vif_to_sdata(vif);
2817 	ifmgd = &sdata->u.mgd;
2818 	local = sdata->local;
2819 
2820 	skb = dev_alloc_skb(local->hw.extra_tx_headroom + sizeof(*pspoll));
2821 	if (!skb)
2822 		return NULL;
2823 
2824 	skb_reserve(skb, local->hw.extra_tx_headroom);
2825 
2826 	pspoll = (struct ieee80211_pspoll *) skb_put(skb, sizeof(*pspoll));
2827 	memset(pspoll, 0, sizeof(*pspoll));
2828 	pspoll->frame_control = cpu_to_le16(IEEE80211_FTYPE_CTL |
2829 					    IEEE80211_STYPE_PSPOLL);
2830 	pspoll->aid = cpu_to_le16(ifmgd->aid);
2831 
2832 	/* aid in PS-Poll has its two MSBs each set to 1 */
2833 	pspoll->aid |= cpu_to_le16(1 << 15 | 1 << 14);
2834 
2835 	memcpy(pspoll->bssid, ifmgd->bssid, ETH_ALEN);
2836 	memcpy(pspoll->ta, vif->addr, ETH_ALEN);
2837 
2838 	return skb;
2839 }
2840 EXPORT_SYMBOL(ieee80211_pspoll_get);
2841 
2842 struct sk_buff *ieee80211_nullfunc_get(struct ieee80211_hw *hw,
2843 				       struct ieee80211_vif *vif)
2844 {
2845 	struct ieee80211_hdr_3addr *nullfunc;
2846 	struct ieee80211_sub_if_data *sdata;
2847 	struct ieee80211_if_managed *ifmgd;
2848 	struct ieee80211_local *local;
2849 	struct sk_buff *skb;
2850 
2851 	if (WARN_ON(vif->type != NL80211_IFTYPE_STATION))
2852 		return NULL;
2853 
2854 	sdata = vif_to_sdata(vif);
2855 	ifmgd = &sdata->u.mgd;
2856 	local = sdata->local;
2857 
2858 	skb = dev_alloc_skb(local->hw.extra_tx_headroom + sizeof(*nullfunc));
2859 	if (!skb)
2860 		return NULL;
2861 
2862 	skb_reserve(skb, local->hw.extra_tx_headroom);
2863 
2864 	nullfunc = (struct ieee80211_hdr_3addr *) skb_put(skb,
2865 							  sizeof(*nullfunc));
2866 	memset(nullfunc, 0, sizeof(*nullfunc));
2867 	nullfunc->frame_control = cpu_to_le16(IEEE80211_FTYPE_DATA |
2868 					      IEEE80211_STYPE_NULLFUNC |
2869 					      IEEE80211_FCTL_TODS);
2870 	memcpy(nullfunc->addr1, ifmgd->bssid, ETH_ALEN);
2871 	memcpy(nullfunc->addr2, vif->addr, ETH_ALEN);
2872 	memcpy(nullfunc->addr3, ifmgd->bssid, ETH_ALEN);
2873 
2874 	return skb;
2875 }
2876 EXPORT_SYMBOL(ieee80211_nullfunc_get);
2877 
2878 struct sk_buff *ieee80211_probereq_get(struct ieee80211_hw *hw,
2879 				       struct ieee80211_vif *vif,
2880 				       const u8 *ssid, size_t ssid_len,
2881 				       size_t tailroom)
2882 {
2883 	struct ieee80211_sub_if_data *sdata;
2884 	struct ieee80211_local *local;
2885 	struct ieee80211_hdr_3addr *hdr;
2886 	struct sk_buff *skb;
2887 	size_t ie_ssid_len;
2888 	u8 *pos;
2889 
2890 	sdata = vif_to_sdata(vif);
2891 	local = sdata->local;
2892 	ie_ssid_len = 2 + ssid_len;
2893 
2894 	skb = dev_alloc_skb(local->hw.extra_tx_headroom + sizeof(*hdr) +
2895 			    ie_ssid_len + tailroom);
2896 	if (!skb)
2897 		return NULL;
2898 
2899 	skb_reserve(skb, local->hw.extra_tx_headroom);
2900 
2901 	hdr = (struct ieee80211_hdr_3addr *) skb_put(skb, sizeof(*hdr));
2902 	memset(hdr, 0, sizeof(*hdr));
2903 	hdr->frame_control = cpu_to_le16(IEEE80211_FTYPE_MGMT |
2904 					 IEEE80211_STYPE_PROBE_REQ);
2905 	eth_broadcast_addr(hdr->addr1);
2906 	memcpy(hdr->addr2, vif->addr, ETH_ALEN);
2907 	eth_broadcast_addr(hdr->addr3);
2908 
2909 	pos = skb_put(skb, ie_ssid_len);
2910 	*pos++ = WLAN_EID_SSID;
2911 	*pos++ = ssid_len;
2912 	if (ssid_len)
2913 		memcpy(pos, ssid, ssid_len);
2914 	pos += ssid_len;
2915 
2916 	return skb;
2917 }
2918 EXPORT_SYMBOL(ieee80211_probereq_get);
2919 
2920 void ieee80211_rts_get(struct ieee80211_hw *hw, struct ieee80211_vif *vif,
2921 		       const void *frame, size_t frame_len,
2922 		       const struct ieee80211_tx_info *frame_txctl,
2923 		       struct ieee80211_rts *rts)
2924 {
2925 	const struct ieee80211_hdr *hdr = frame;
2926 
2927 	rts->frame_control =
2928 	    cpu_to_le16(IEEE80211_FTYPE_CTL | IEEE80211_STYPE_RTS);
2929 	rts->duration = ieee80211_rts_duration(hw, vif, frame_len,
2930 					       frame_txctl);
2931 	memcpy(rts->ra, hdr->addr1, sizeof(rts->ra));
2932 	memcpy(rts->ta, hdr->addr2, sizeof(rts->ta));
2933 }
2934 EXPORT_SYMBOL(ieee80211_rts_get);
2935 
2936 void ieee80211_ctstoself_get(struct ieee80211_hw *hw, struct ieee80211_vif *vif,
2937 			     const void *frame, size_t frame_len,
2938 			     const struct ieee80211_tx_info *frame_txctl,
2939 			     struct ieee80211_cts *cts)
2940 {
2941 	const struct ieee80211_hdr *hdr = frame;
2942 
2943 	cts->frame_control =
2944 	    cpu_to_le16(IEEE80211_FTYPE_CTL | IEEE80211_STYPE_CTS);
2945 	cts->duration = ieee80211_ctstoself_duration(hw, vif,
2946 						     frame_len, frame_txctl);
2947 	memcpy(cts->ra, hdr->addr1, sizeof(cts->ra));
2948 }
2949 EXPORT_SYMBOL(ieee80211_ctstoself_get);
2950 
2951 struct sk_buff *
2952 ieee80211_get_buffered_bc(struct ieee80211_hw *hw,
2953 			  struct ieee80211_vif *vif)
2954 {
2955 	struct ieee80211_local *local = hw_to_local(hw);
2956 	struct sk_buff *skb = NULL;
2957 	struct ieee80211_tx_data tx;
2958 	struct ieee80211_sub_if_data *sdata;
2959 	struct ps_data *ps;
2960 	struct ieee80211_tx_info *info;
2961 	struct ieee80211_chanctx_conf *chanctx_conf;
2962 
2963 	sdata = vif_to_sdata(vif);
2964 
2965 	rcu_read_lock();
2966 	chanctx_conf = rcu_dereference(sdata->vif.chanctx_conf);
2967 
2968 	if (!chanctx_conf)
2969 		goto out;
2970 
2971 	if (sdata->vif.type == NL80211_IFTYPE_AP) {
2972 		struct beacon_data *beacon =
2973 				rcu_dereference(sdata->u.ap.beacon);
2974 
2975 		if (!beacon || !beacon->head)
2976 			goto out;
2977 
2978 		ps = &sdata->u.ap.ps;
2979 	} else if (ieee80211_vif_is_mesh(&sdata->vif)) {
2980 		ps = &sdata->u.mesh.ps;
2981 	} else {
2982 		goto out;
2983 	}
2984 
2985 	if (ps->dtim_count != 0 || !ps->dtim_bc_mc)
2986 		goto out; /* send buffered bc/mc only after DTIM beacon */
2987 
2988 	while (1) {
2989 		skb = skb_dequeue(&ps->bc_buf);
2990 		if (!skb)
2991 			goto out;
2992 		local->total_ps_buffered--;
2993 
2994 		if (!skb_queue_empty(&ps->bc_buf) && skb->len >= 2) {
2995 			struct ieee80211_hdr *hdr =
2996 				(struct ieee80211_hdr *) skb->data;
2997 			/* more buffered multicast/broadcast frames ==> set
2998 			 * MoreData flag in IEEE 802.11 header to inform PS
2999 			 * STAs */
3000 			hdr->frame_control |=
3001 				cpu_to_le16(IEEE80211_FCTL_MOREDATA);
3002 		}
3003 
3004 		if (sdata->vif.type == NL80211_IFTYPE_AP)
3005 			sdata = IEEE80211_DEV_TO_SUB_IF(skb->dev);
3006 		if (!ieee80211_tx_prepare(sdata, &tx, skb))
3007 			break;
3008 		dev_kfree_skb_any(skb);
3009 	}
3010 
3011 	info = IEEE80211_SKB_CB(skb);
3012 
3013 	tx.flags |= IEEE80211_TX_PS_BUFFERED;
3014 	info->band = chanctx_conf->def.chan->band;
3015 
3016 	if (invoke_tx_handlers(&tx))
3017 		skb = NULL;
3018  out:
3019 	rcu_read_unlock();
3020 
3021 	return skb;
3022 }
3023 EXPORT_SYMBOL(ieee80211_get_buffered_bc);
3024 
3025 void __ieee80211_tx_skb_tid_band(struct ieee80211_sub_if_data *sdata,
3026 				 struct sk_buff *skb, int tid,
3027 				 enum ieee80211_band band)
3028 {
3029 	int ac = ieee802_1d_to_ac[tid & 7];
3030 
3031 	skb_set_mac_header(skb, 0);
3032 	skb_set_network_header(skb, 0);
3033 	skb_set_transport_header(skb, 0);
3034 
3035 	skb_set_queue_mapping(skb, ac);
3036 	skb->priority = tid;
3037 
3038 	skb->dev = sdata->dev;
3039 
3040 	/*
3041 	 * The other path calling ieee80211_xmit is from the tasklet,
3042 	 * and while we can handle concurrent transmissions locking
3043 	 * requirements are that we do not come into tx with bhs on.
3044 	 */
3045 	local_bh_disable();
3046 	ieee80211_xmit(sdata, skb, band);
3047 	local_bh_enable();
3048 }
3049