tx.c 74 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695269626972698269927002701270227032704270527062707270827092710271127122713271427152716
  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. #include <linux/kernel.h>
  15. #include <linux/slab.h>
  16. #include <linux/skbuff.h>
  17. #include <linux/etherdevice.h>
  18. #include <linux/bitmap.h>
  19. #include <linux/rcupdate.h>
  20. #include <linux/export.h>
  21. #include <net/net_namespace.h>
  22. #include <net/ieee80211_radiotap.h>
  23. #include <net/cfg80211.h>
  24. #include <net/mac80211.h>
  25. #include <asm/unaligned.h>
  26. #include "ieee80211_i.h"
  27. #include "driver-ops.h"
  28. #include "led.h"
  29. #include "mesh.h"
  30. #include "wep.h"
  31. #include "wpa.h"
  32. #include "wme.h"
  33. #include "rate.h"
  34. /* misc utils */
  35. static __le16 ieee80211_duration(struct ieee80211_tx_data *tx,
  36. struct sk_buff *skb, int group_addr,
  37. int next_frag_len)
  38. {
  39. int rate, mrate, erp, dur, i;
  40. struct ieee80211_rate *txrate;
  41. struct ieee80211_local *local = tx->local;
  42. struct ieee80211_supported_band *sband;
  43. struct ieee80211_hdr *hdr;
  44. struct ieee80211_tx_info *info = IEEE80211_SKB_CB(skb);
  45. /* assume HW handles this */
  46. if (info->control.rates[0].flags & IEEE80211_TX_RC_MCS)
  47. return 0;
  48. /* uh huh? */
  49. if (WARN_ON_ONCE(info->control.rates[0].idx < 0))
  50. return 0;
  51. sband = local->hw.wiphy->bands[tx->channel->band];
  52. txrate = &sband->bitrates[info->control.rates[0].idx];
  53. erp = txrate->flags & IEEE80211_RATE_ERP_G;
  54. /*
  55. * data and mgmt (except PS Poll):
  56. * - during CFP: 32768
  57. * - during contention period:
  58. * if addr1 is group address: 0
  59. * if more fragments = 0 and addr1 is individual address: time to
  60. * transmit one ACK plus SIFS
  61. * if more fragments = 1 and addr1 is individual address: time to
  62. * transmit next fragment plus 2 x ACK plus 3 x SIFS
  63. *
  64. * IEEE 802.11, 9.6:
  65. * - control response frame (CTS or ACK) shall be transmitted using the
  66. * same rate as the immediately previous frame in the frame exchange
  67. * sequence, if this rate belongs to the PHY mandatory rates, or else
  68. * at the highest possible rate belonging to the PHY rates in the
  69. * BSSBasicRateSet
  70. */
  71. hdr = (struct ieee80211_hdr *)skb->data;
  72. if (ieee80211_is_ctl(hdr->frame_control)) {
  73. /* TODO: These control frames are not currently sent by
  74. * mac80211, but should they be implemented, this function
  75. * needs to be updated to support duration field calculation.
  76. *
  77. * RTS: time needed to transmit pending data/mgmt frame plus
  78. * one CTS frame plus one ACK frame plus 3 x SIFS
  79. * CTS: duration of immediately previous RTS minus time
  80. * required to transmit CTS and its SIFS
  81. * ACK: 0 if immediately previous directed data/mgmt had
  82. * more=0, with more=1 duration in ACK frame is duration
  83. * from previous frame minus time needed to transmit ACK
  84. * and its SIFS
  85. * PS Poll: BIT(15) | BIT(14) | aid
  86. */
  87. return 0;
  88. }
  89. /* data/mgmt */
  90. if (0 /* FIX: data/mgmt during CFP */)
  91. return cpu_to_le16(32768);
  92. if (group_addr) /* Group address as the destination - no ACK */
  93. return 0;
  94. /* Individual destination address:
  95. * IEEE 802.11, Ch. 9.6 (after IEEE 802.11g changes)
  96. * CTS and ACK frames shall be transmitted using the highest rate in
  97. * basic rate set that is less than or equal to the rate of the
  98. * immediately previous frame and that is using the same modulation
  99. * (CCK or OFDM). If no basic rate set matches with these requirements,
  100. * the highest mandatory rate of the PHY that is less than or equal to
  101. * the rate of the previous frame is used.
  102. * Mandatory rates for IEEE 802.11g PHY: 1, 2, 5.5, 11, 6, 12, 24 Mbps
  103. */
  104. rate = -1;
  105. /* use lowest available if everything fails */
  106. mrate = sband->bitrates[0].bitrate;
  107. for (i = 0; i < sband->n_bitrates; i++) {
  108. struct ieee80211_rate *r = &sband->bitrates[i];
  109. if (r->bitrate > txrate->bitrate)
  110. break;
  111. if (tx->sdata->vif.bss_conf.basic_rates & BIT(i))
  112. rate = r->bitrate;
  113. switch (sband->band) {
  114. case IEEE80211_BAND_2GHZ: {
  115. u32 flag;
  116. if (tx->sdata->flags & IEEE80211_SDATA_OPERATING_GMODE)
  117. flag = IEEE80211_RATE_MANDATORY_G;
  118. else
  119. flag = IEEE80211_RATE_MANDATORY_B;
  120. if (r->flags & flag)
  121. mrate = r->bitrate;
  122. break;
  123. }
  124. case IEEE80211_BAND_5GHZ:
  125. if (r->flags & IEEE80211_RATE_MANDATORY_A)
  126. mrate = r->bitrate;
  127. break;
  128. case IEEE80211_NUM_BANDS:
  129. WARN_ON(1);
  130. break;
  131. }
  132. }
  133. if (rate == -1) {
  134. /* No matching basic rate found; use highest suitable mandatory
  135. * PHY rate */
  136. rate = mrate;
  137. }
  138. /* Don't calculate ACKs for QoS Frames with NoAck Policy set */
  139. if (ieee80211_is_data_qos(hdr->frame_control) &&
  140. *(ieee80211_get_qos_ctl(hdr)) | IEEE80211_QOS_CTL_ACK_POLICY_NOACK)
  141. dur = 0;
  142. else
  143. /* Time needed to transmit ACK
  144. * (10 bytes + 4-byte FCS = 112 bits) plus SIFS; rounded up
  145. * to closest integer */
  146. dur = ieee80211_frame_duration(local, 10, rate, erp,
  147. tx->sdata->vif.bss_conf.use_short_preamble);
  148. if (next_frag_len) {
  149. /* Frame is fragmented: duration increases with time needed to
  150. * transmit next fragment plus ACK and 2 x SIFS. */
  151. dur *= 2; /* ACK + SIFS */
  152. /* next fragment */
  153. dur += ieee80211_frame_duration(local, next_frag_len,
  154. txrate->bitrate, erp,
  155. tx->sdata->vif.bss_conf.use_short_preamble);
  156. }
  157. return cpu_to_le16(dur);
  158. }
  159. static inline int is_ieee80211_device(struct ieee80211_local *local,
  160. struct net_device *dev)
  161. {
  162. return local == wdev_priv(dev->ieee80211_ptr);
  163. }
  164. /* tx handlers */
  165. static ieee80211_tx_result debug_noinline
  166. ieee80211_tx_h_dynamic_ps(struct ieee80211_tx_data *tx)
  167. {
  168. struct ieee80211_local *local = tx->local;
  169. struct ieee80211_if_managed *ifmgd;
  170. /* driver doesn't support power save */
  171. if (!(local->hw.flags & IEEE80211_HW_SUPPORTS_PS))
  172. return TX_CONTINUE;
  173. /* hardware does dynamic power save */
  174. if (local->hw.flags & IEEE80211_HW_SUPPORTS_DYNAMIC_PS)
  175. return TX_CONTINUE;
  176. /* dynamic power save disabled */
  177. if (local->hw.conf.dynamic_ps_timeout <= 0)
  178. return TX_CONTINUE;
  179. /* we are scanning, don't enable power save */
  180. if (local->scanning)
  181. return TX_CONTINUE;
  182. if (!local->ps_sdata)
  183. return TX_CONTINUE;
  184. /* No point if we're going to suspend */
  185. if (local->quiescing)
  186. return TX_CONTINUE;
  187. /* dynamic ps is supported only in managed mode */
  188. if (tx->sdata->vif.type != NL80211_IFTYPE_STATION)
  189. return TX_CONTINUE;
  190. ifmgd = &tx->sdata->u.mgd;
  191. /*
  192. * Don't wakeup from power save if u-apsd is enabled, voip ac has
  193. * u-apsd enabled and the frame is in voip class. This effectively
  194. * means that even if all access categories have u-apsd enabled, in
  195. * practise u-apsd is only used with the voip ac. This is a
  196. * workaround for the case when received voip class packets do not
  197. * have correct qos tag for some reason, due the network or the
  198. * peer application.
  199. *
  200. * Note: local->uapsd_queues access is racy here. If the value is
  201. * changed via debugfs, user needs to reassociate manually to have
  202. * everything in sync.
  203. */
  204. if ((ifmgd->flags & IEEE80211_STA_UAPSD_ENABLED)
  205. && (local->uapsd_queues & IEEE80211_WMM_IE_STA_QOSINFO_AC_VO)
  206. && skb_get_queue_mapping(tx->skb) == 0)
  207. return TX_CONTINUE;
  208. if (local->hw.conf.flags & IEEE80211_CONF_PS) {
  209. ieee80211_stop_queues_by_reason(&local->hw,
  210. IEEE80211_QUEUE_STOP_REASON_PS);
  211. ifmgd->flags &= ~IEEE80211_STA_NULLFUNC_ACKED;
  212. ieee80211_queue_work(&local->hw,
  213. &local->dynamic_ps_disable_work);
  214. }
  215. /* Don't restart the timer if we're not disassociated */
  216. if (!ifmgd->associated)
  217. return TX_CONTINUE;
  218. mod_timer(&local->dynamic_ps_timer, jiffies +
  219. msecs_to_jiffies(local->hw.conf.dynamic_ps_timeout));
  220. return TX_CONTINUE;
  221. }
  222. static ieee80211_tx_result debug_noinline
  223. ieee80211_tx_h_check_assoc(struct ieee80211_tx_data *tx)
  224. {
  225. struct ieee80211_hdr *hdr = (struct ieee80211_hdr *)tx->skb->data;
  226. struct ieee80211_tx_info *info = IEEE80211_SKB_CB(tx->skb);
  227. bool assoc = false;
  228. if (unlikely(info->flags & IEEE80211_TX_CTL_INJECTED))
  229. return TX_CONTINUE;
  230. if (unlikely(test_bit(SCAN_SW_SCANNING, &tx->local->scanning)) &&
  231. test_bit(SDATA_STATE_OFFCHANNEL, &tx->sdata->state) &&
  232. !ieee80211_is_probe_req(hdr->frame_control) &&
  233. !ieee80211_is_nullfunc(hdr->frame_control))
  234. /*
  235. * When software scanning only nullfunc frames (to notify
  236. * the sleep state to the AP) and probe requests (for the
  237. * active scan) are allowed, all other frames should not be
  238. * sent and we should not get here, but if we do
  239. * nonetheless, drop them to avoid sending them
  240. * off-channel. See the link below and
  241. * ieee80211_start_scan() for more.
  242. *
  243. * http://article.gmane.org/gmane.linux.kernel.wireless.general/30089
  244. */
  245. return TX_DROP;
  246. if (tx->sdata->vif.type == NL80211_IFTYPE_WDS)
  247. return TX_CONTINUE;
  248. if (tx->sdata->vif.type == NL80211_IFTYPE_MESH_POINT)
  249. return TX_CONTINUE;
  250. if (tx->flags & IEEE80211_TX_PS_BUFFERED)
  251. return TX_CONTINUE;
  252. if (tx->sta)
  253. assoc = test_sta_flag(tx->sta, WLAN_STA_ASSOC);
  254. if (likely(tx->flags & IEEE80211_TX_UNICAST)) {
  255. if (unlikely(!assoc &&
  256. tx->sdata->vif.type != NL80211_IFTYPE_ADHOC &&
  257. ieee80211_is_data(hdr->frame_control))) {
  258. #ifdef CONFIG_MAC80211_VERBOSE_DEBUG
  259. printk(KERN_DEBUG "%s: dropped data frame to not "
  260. "associated station %pM\n",
  261. tx->sdata->name, hdr->addr1);
  262. #endif /* CONFIG_MAC80211_VERBOSE_DEBUG */
  263. I802_DEBUG_INC(tx->local->tx_handlers_drop_not_assoc);
  264. return TX_DROP;
  265. }
  266. } else {
  267. if (unlikely(ieee80211_is_data(hdr->frame_control) &&
  268. tx->local->num_sta == 0 &&
  269. tx->sdata->vif.type != NL80211_IFTYPE_ADHOC)) {
  270. /*
  271. * No associated STAs - no need to send multicast
  272. * frames.
  273. */
  274. return TX_DROP;
  275. }
  276. return TX_CONTINUE;
  277. }
  278. return TX_CONTINUE;
  279. }
  280. /* This function is called whenever the AP is about to exceed the maximum limit
  281. * of buffered frames for power saving STAs. This situation should not really
  282. * happen often during normal operation, so dropping the oldest buffered packet
  283. * from each queue should be OK to make some room for new frames. */
  284. static void purge_old_ps_buffers(struct ieee80211_local *local)
  285. {
  286. int total = 0, purged = 0;
  287. struct sk_buff *skb;
  288. struct ieee80211_sub_if_data *sdata;
  289. struct sta_info *sta;
  290. /*
  291. * virtual interfaces are protected by RCU
  292. */
  293. rcu_read_lock();
  294. list_for_each_entry_rcu(sdata, &local->interfaces, list) {
  295. struct ieee80211_if_ap *ap;
  296. if (sdata->vif.type != NL80211_IFTYPE_AP)
  297. continue;
  298. ap = &sdata->u.ap;
  299. skb = skb_dequeue(&ap->ps_bc_buf);
  300. if (skb) {
  301. purged++;
  302. dev_kfree_skb(skb);
  303. }
  304. total += skb_queue_len(&ap->ps_bc_buf);
  305. }
  306. /*
  307. * Drop one frame from each station from the lowest-priority
  308. * AC that has frames at all.
  309. */
  310. list_for_each_entry_rcu(sta, &local->sta_list, list) {
  311. int ac;
  312. for (ac = IEEE80211_AC_BK; ac >= IEEE80211_AC_VO; ac--) {
  313. skb = skb_dequeue(&sta->ps_tx_buf[ac]);
  314. total += skb_queue_len(&sta->ps_tx_buf[ac]);
  315. if (skb) {
  316. purged++;
  317. dev_kfree_skb(skb);
  318. break;
  319. }
  320. }
  321. }
  322. rcu_read_unlock();
  323. local->total_ps_buffered = total;
  324. #ifdef CONFIG_MAC80211_VERBOSE_PS_DEBUG
  325. wiphy_debug(local->hw.wiphy, "PS buffers full - purged %d frames\n",
  326. purged);
  327. #endif
  328. }
  329. static ieee80211_tx_result
  330. ieee80211_tx_h_multicast_ps_buf(struct ieee80211_tx_data *tx)
  331. {
  332. struct ieee80211_tx_info *info = IEEE80211_SKB_CB(tx->skb);
  333. struct ieee80211_hdr *hdr = (struct ieee80211_hdr *)tx->skb->data;
  334. /*
  335. * broadcast/multicast frame
  336. *
  337. * If any of the associated stations is in power save mode,
  338. * the frame is buffered to be sent after DTIM beacon frame.
  339. * This is done either by the hardware or us.
  340. */
  341. /* powersaving STAs only in AP/VLAN mode */
  342. if (!tx->sdata->bss)
  343. return TX_CONTINUE;
  344. /* no buffering for ordered frames */
  345. if (ieee80211_has_order(hdr->frame_control))
  346. return TX_CONTINUE;
  347. /* no stations in PS mode */
  348. if (!atomic_read(&tx->sdata->bss->num_sta_ps))
  349. return TX_CONTINUE;
  350. info->flags |= IEEE80211_TX_CTL_SEND_AFTER_DTIM;
  351. /* device releases frame after DTIM beacon */
  352. if (!(tx->local->hw.flags & IEEE80211_HW_HOST_BROADCAST_PS_BUFFERING))
  353. return TX_CONTINUE;
  354. /* buffered in mac80211 */
  355. if (tx->local->total_ps_buffered >= TOTAL_MAX_TX_BUFFER)
  356. purge_old_ps_buffers(tx->local);
  357. if (skb_queue_len(&tx->sdata->bss->ps_bc_buf) >= AP_MAX_BC_BUFFER) {
  358. #ifdef CONFIG_MAC80211_VERBOSE_PS_DEBUG
  359. if (net_ratelimit())
  360. printk(KERN_DEBUG "%s: BC TX buffer full - dropping the oldest frame\n",
  361. tx->sdata->name);
  362. #endif
  363. dev_kfree_skb(skb_dequeue(&tx->sdata->bss->ps_bc_buf));
  364. } else
  365. tx->local->total_ps_buffered++;
  366. skb_queue_tail(&tx->sdata->bss->ps_bc_buf, tx->skb);
  367. return TX_QUEUED;
  368. }
  369. static int ieee80211_use_mfp(__le16 fc, struct sta_info *sta,
  370. struct sk_buff *skb)
  371. {
  372. if (!ieee80211_is_mgmt(fc))
  373. return 0;
  374. if (sta == NULL || !test_sta_flag(sta, WLAN_STA_MFP))
  375. return 0;
  376. if (!ieee80211_is_robust_mgmt_frame((struct ieee80211_hdr *)
  377. skb->data))
  378. return 0;
  379. return 1;
  380. }
  381. static ieee80211_tx_result
  382. ieee80211_tx_h_unicast_ps_buf(struct ieee80211_tx_data *tx)
  383. {
  384. struct sta_info *sta = tx->sta;
  385. struct ieee80211_tx_info *info = IEEE80211_SKB_CB(tx->skb);
  386. struct ieee80211_hdr *hdr = (struct ieee80211_hdr *)tx->skb->data;
  387. struct ieee80211_local *local = tx->local;
  388. if (unlikely(!sta ||
  389. ieee80211_is_probe_resp(hdr->frame_control) ||
  390. ieee80211_is_auth(hdr->frame_control) ||
  391. ieee80211_is_assoc_resp(hdr->frame_control) ||
  392. ieee80211_is_reassoc_resp(hdr->frame_control)))
  393. return TX_CONTINUE;
  394. if (unlikely((test_sta_flag(sta, WLAN_STA_PS_STA) ||
  395. test_sta_flag(sta, WLAN_STA_PS_DRIVER)) &&
  396. !(info->flags & IEEE80211_TX_CTL_POLL_RESPONSE))) {
  397. int ac = skb_get_queue_mapping(tx->skb);
  398. #ifdef CONFIG_MAC80211_VERBOSE_PS_DEBUG
  399. printk(KERN_DEBUG "STA %pM aid %d: PS buffer for AC %d\n",
  400. sta->sta.addr, sta->sta.aid, ac);
  401. #endif /* CONFIG_MAC80211_VERBOSE_PS_DEBUG */
  402. if (tx->local->total_ps_buffered >= TOTAL_MAX_TX_BUFFER)
  403. purge_old_ps_buffers(tx->local);
  404. if (skb_queue_len(&sta->ps_tx_buf[ac]) >= STA_MAX_TX_BUFFER) {
  405. struct sk_buff *old = skb_dequeue(&sta->ps_tx_buf[ac]);
  406. #ifdef CONFIG_MAC80211_VERBOSE_PS_DEBUG
  407. if (net_ratelimit())
  408. printk(KERN_DEBUG "%s: STA %pM TX buffer for "
  409. "AC %d full - dropping oldest frame\n",
  410. tx->sdata->name, sta->sta.addr, ac);
  411. #endif
  412. dev_kfree_skb(old);
  413. } else
  414. tx->local->total_ps_buffered++;
  415. info->control.jiffies = jiffies;
  416. info->control.vif = &tx->sdata->vif;
  417. info->flags |= IEEE80211_TX_INTFL_NEED_TXPROCESSING;
  418. skb_queue_tail(&sta->ps_tx_buf[ac], tx->skb);
  419. if (!timer_pending(&local->sta_cleanup))
  420. mod_timer(&local->sta_cleanup,
  421. round_jiffies(jiffies +
  422. STA_INFO_CLEANUP_INTERVAL));
  423. /*
  424. * We queued up some frames, so the TIM bit might
  425. * need to be set, recalculate it.
  426. */
  427. sta_info_recalc_tim(sta);
  428. return TX_QUEUED;
  429. }
  430. #ifdef CONFIG_MAC80211_VERBOSE_PS_DEBUG
  431. else if (unlikely(test_sta_flag(sta, WLAN_STA_PS_STA))) {
  432. printk(KERN_DEBUG
  433. "%s: STA %pM in PS mode, but polling/in SP -> send frame\n",
  434. tx->sdata->name, sta->sta.addr);
  435. }
  436. #endif /* CONFIG_MAC80211_VERBOSE_PS_DEBUG */
  437. return TX_CONTINUE;
  438. }
  439. static ieee80211_tx_result debug_noinline
  440. ieee80211_tx_h_ps_buf(struct ieee80211_tx_data *tx)
  441. {
  442. if (unlikely(tx->flags & IEEE80211_TX_PS_BUFFERED))
  443. return TX_CONTINUE;
  444. if (tx->flags & IEEE80211_TX_UNICAST)
  445. return ieee80211_tx_h_unicast_ps_buf(tx);
  446. else
  447. return ieee80211_tx_h_multicast_ps_buf(tx);
  448. }
  449. static ieee80211_tx_result debug_noinline
  450. ieee80211_tx_h_check_control_port_protocol(struct ieee80211_tx_data *tx)
  451. {
  452. struct ieee80211_tx_info *info = IEEE80211_SKB_CB(tx->skb);
  453. if (unlikely(tx->sdata->control_port_protocol == tx->skb->protocol &&
  454. tx->sdata->control_port_no_encrypt))
  455. info->flags |= IEEE80211_TX_INTFL_DONT_ENCRYPT;
  456. return TX_CONTINUE;
  457. }
  458. static ieee80211_tx_result debug_noinline
  459. ieee80211_tx_h_select_key(struct ieee80211_tx_data *tx)
  460. {
  461. struct ieee80211_key *key = NULL;
  462. struct ieee80211_tx_info *info = IEEE80211_SKB_CB(tx->skb);
  463. struct ieee80211_hdr *hdr = (struct ieee80211_hdr *)tx->skb->data;
  464. if (unlikely(info->flags & IEEE80211_TX_INTFL_DONT_ENCRYPT))
  465. tx->key = NULL;
  466. else if (tx->sta && (key = rcu_dereference(tx->sta->ptk)))
  467. tx->key = key;
  468. else if (ieee80211_is_mgmt(hdr->frame_control) &&
  469. is_multicast_ether_addr(hdr->addr1) &&
  470. ieee80211_is_robust_mgmt_frame(hdr) &&
  471. (key = rcu_dereference(tx->sdata->default_mgmt_key)))
  472. tx->key = key;
  473. else if (is_multicast_ether_addr(hdr->addr1) &&
  474. (key = rcu_dereference(tx->sdata->default_multicast_key)))
  475. tx->key = key;
  476. else if (!is_multicast_ether_addr(hdr->addr1) &&
  477. (key = rcu_dereference(tx->sdata->default_unicast_key)))
  478. tx->key = key;
  479. else if (tx->sdata->drop_unencrypted &&
  480. (tx->skb->protocol != tx->sdata->control_port_protocol) &&
  481. !(info->flags & IEEE80211_TX_CTL_INJECTED) &&
  482. (!ieee80211_is_robust_mgmt_frame(hdr) ||
  483. (ieee80211_is_action(hdr->frame_control) &&
  484. tx->sta && test_sta_flag(tx->sta, WLAN_STA_MFP)))) {
  485. I802_DEBUG_INC(tx->local->tx_handlers_drop_unencrypted);
  486. return TX_DROP;
  487. } else
  488. tx->key = NULL;
  489. if (tx->key) {
  490. bool skip_hw = false;
  491. tx->key->tx_rx_count++;
  492. /* TODO: add threshold stuff again */
  493. switch (tx->key->conf.cipher) {
  494. case WLAN_CIPHER_SUITE_WEP40:
  495. case WLAN_CIPHER_SUITE_WEP104:
  496. case WLAN_CIPHER_SUITE_TKIP:
  497. if (!ieee80211_is_data_present(hdr->frame_control))
  498. tx->key = NULL;
  499. break;
  500. case WLAN_CIPHER_SUITE_CCMP:
  501. if (!ieee80211_is_data_present(hdr->frame_control) &&
  502. !ieee80211_use_mfp(hdr->frame_control, tx->sta,
  503. tx->skb))
  504. tx->key = NULL;
  505. else
  506. skip_hw = (tx->key->conf.flags &
  507. IEEE80211_KEY_FLAG_SW_MGMT) &&
  508. ieee80211_is_mgmt(hdr->frame_control);
  509. break;
  510. case WLAN_CIPHER_SUITE_AES_CMAC:
  511. if (!ieee80211_is_mgmt(hdr->frame_control))
  512. tx->key = NULL;
  513. break;
  514. }
  515. if (unlikely(tx->key && tx->key->flags & KEY_FLAG_TAINTED))
  516. return TX_DROP;
  517. if (!skip_hw && tx->key &&
  518. tx->key->flags & KEY_FLAG_UPLOADED_TO_HARDWARE)
  519. info->control.hw_key = &tx->key->conf;
  520. }
  521. return TX_CONTINUE;
  522. }
  523. static ieee80211_tx_result debug_noinline
  524. ieee80211_tx_h_rate_ctrl(struct ieee80211_tx_data *tx)
  525. {
  526. struct ieee80211_tx_info *info = IEEE80211_SKB_CB(tx->skb);
  527. struct ieee80211_hdr *hdr = (void *)tx->skb->data;
  528. struct ieee80211_supported_band *sband;
  529. struct ieee80211_rate *rate;
  530. int i;
  531. u32 len;
  532. bool inval = false, rts = false, short_preamble = false;
  533. struct ieee80211_tx_rate_control txrc;
  534. bool assoc = false;
  535. memset(&txrc, 0, sizeof(txrc));
  536. sband = tx->local->hw.wiphy->bands[tx->channel->band];
  537. len = min_t(u32, tx->skb->len + FCS_LEN,
  538. tx->local->hw.wiphy->frag_threshold);
  539. /* set up the tx rate control struct we give the RC algo */
  540. txrc.hw = local_to_hw(tx->local);
  541. txrc.sband = sband;
  542. txrc.bss_conf = &tx->sdata->vif.bss_conf;
  543. txrc.skb = tx->skb;
  544. txrc.reported_rate.idx = -1;
  545. txrc.rate_idx_mask = tx->sdata->rc_rateidx_mask[tx->channel->band];
  546. if (txrc.rate_idx_mask == (1 << sband->n_bitrates) - 1)
  547. txrc.max_rate_idx = -1;
  548. else
  549. txrc.max_rate_idx = fls(txrc.rate_idx_mask) - 1;
  550. txrc.bss = (tx->sdata->vif.type == NL80211_IFTYPE_AP ||
  551. tx->sdata->vif.type == NL80211_IFTYPE_ADHOC);
  552. /* set up RTS protection if desired */
  553. if (len > tx->local->hw.wiphy->rts_threshold) {
  554. txrc.rts = rts = true;
  555. }
  556. /*
  557. * Use short preamble if the BSS can handle it, but not for
  558. * management frames unless we know the receiver can handle
  559. * that -- the management frame might be to a station that
  560. * just wants a probe response.
  561. */
  562. if (tx->sdata->vif.bss_conf.use_short_preamble &&
  563. (ieee80211_is_data(hdr->frame_control) ||
  564. (tx->sta && test_sta_flag(tx->sta, WLAN_STA_SHORT_PREAMBLE))))
  565. txrc.short_preamble = short_preamble = true;
  566. if (tx->sta)
  567. assoc = test_sta_flag(tx->sta, WLAN_STA_ASSOC);
  568. /*
  569. * Lets not bother rate control if we're associated and cannot
  570. * talk to the sta. This should not happen.
  571. */
  572. if (WARN(test_bit(SCAN_SW_SCANNING, &tx->local->scanning) && assoc &&
  573. !rate_usable_index_exists(sband, &tx->sta->sta),
  574. "%s: Dropped data frame as no usable bitrate found while "
  575. "scanning and associated. Target station: "
  576. "%pM on %d GHz band\n",
  577. tx->sdata->name, hdr->addr1,
  578. tx->channel->band ? 5 : 2))
  579. return TX_DROP;
  580. /*
  581. * If we're associated with the sta at this point we know we can at
  582. * least send the frame at the lowest bit rate.
  583. */
  584. rate_control_get_rate(tx->sdata, tx->sta, &txrc);
  585. if (unlikely(info->control.rates[0].idx < 0))
  586. return TX_DROP;
  587. if (txrc.reported_rate.idx < 0) {
  588. txrc.reported_rate = info->control.rates[0];
  589. if (tx->sta && ieee80211_is_data(hdr->frame_control))
  590. tx->sta->last_tx_rate = txrc.reported_rate;
  591. } else if (tx->sta)
  592. tx->sta->last_tx_rate = txrc.reported_rate;
  593. if (unlikely(!info->control.rates[0].count))
  594. info->control.rates[0].count = 1;
  595. if (WARN_ON_ONCE((info->control.rates[0].count > 1) &&
  596. (info->flags & IEEE80211_TX_CTL_NO_ACK)))
  597. info->control.rates[0].count = 1;
  598. if (is_multicast_ether_addr(hdr->addr1)) {
  599. /*
  600. * XXX: verify the rate is in the basic rateset
  601. */
  602. return TX_CONTINUE;
  603. }
  604. /*
  605. * set up the RTS/CTS rate as the fastest basic rate
  606. * that is not faster than the data rate
  607. *
  608. * XXX: Should this check all retry rates?
  609. */
  610. if (!(info->control.rates[0].flags & IEEE80211_TX_RC_MCS)) {
  611. s8 baserate = 0;
  612. rate = &sband->bitrates[info->control.rates[0].idx];
  613. for (i = 0; i < sband->n_bitrates; i++) {
  614. /* must be a basic rate */
  615. if (!(tx->sdata->vif.bss_conf.basic_rates & BIT(i)))
  616. continue;
  617. /* must not be faster than the data rate */
  618. if (sband->bitrates[i].bitrate > rate->bitrate)
  619. continue;
  620. /* maximum */
  621. if (sband->bitrates[baserate].bitrate <
  622. sband->bitrates[i].bitrate)
  623. baserate = i;
  624. }
  625. info->control.rts_cts_rate_idx = baserate;
  626. }
  627. for (i = 0; i < IEEE80211_TX_MAX_RATES; i++) {
  628. /*
  629. * make sure there's no valid rate following
  630. * an invalid one, just in case drivers don't
  631. * take the API seriously to stop at -1.
  632. */
  633. if (inval) {
  634. info->control.rates[i].idx = -1;
  635. continue;
  636. }
  637. if (info->control.rates[i].idx < 0) {
  638. inval = true;
  639. continue;
  640. }
  641. /*
  642. * For now assume MCS is already set up correctly, this
  643. * needs to be fixed.
  644. */
  645. if (info->control.rates[i].flags & IEEE80211_TX_RC_MCS) {
  646. WARN_ON(info->control.rates[i].idx > 76);
  647. continue;
  648. }
  649. /* set up RTS protection if desired */
  650. if (rts)
  651. info->control.rates[i].flags |=
  652. IEEE80211_TX_RC_USE_RTS_CTS;
  653. /* RC is busted */
  654. if (WARN_ON_ONCE(info->control.rates[i].idx >=
  655. sband->n_bitrates)) {
  656. info->control.rates[i].idx = -1;
  657. continue;
  658. }
  659. rate = &sband->bitrates[info->control.rates[i].idx];
  660. /* set up short preamble */
  661. if (short_preamble &&
  662. rate->flags & IEEE80211_RATE_SHORT_PREAMBLE)
  663. info->control.rates[i].flags |=
  664. IEEE80211_TX_RC_USE_SHORT_PREAMBLE;
  665. /* set up G protection */
  666. if (!rts && tx->sdata->vif.bss_conf.use_cts_prot &&
  667. rate->flags & IEEE80211_RATE_ERP_G)
  668. info->control.rates[i].flags |=
  669. IEEE80211_TX_RC_USE_CTS_PROTECT;
  670. }
  671. return TX_CONTINUE;
  672. }
  673. static ieee80211_tx_result debug_noinline
  674. ieee80211_tx_h_sequence(struct ieee80211_tx_data *tx)
  675. {
  676. struct ieee80211_tx_info *info = IEEE80211_SKB_CB(tx->skb);
  677. struct ieee80211_hdr *hdr = (struct ieee80211_hdr *)tx->skb->data;
  678. u16 *seq;
  679. u8 *qc;
  680. int tid;
  681. /*
  682. * Packet injection may want to control the sequence
  683. * number, if we have no matching interface then we
  684. * neither assign one ourselves nor ask the driver to.
  685. */
  686. if (unlikely(info->control.vif->type == NL80211_IFTYPE_MONITOR))
  687. return TX_CONTINUE;
  688. if (unlikely(ieee80211_is_ctl(hdr->frame_control)))
  689. return TX_CONTINUE;
  690. if (ieee80211_hdrlen(hdr->frame_control) < 24)
  691. return TX_CONTINUE;
  692. if (ieee80211_is_qos_nullfunc(hdr->frame_control))
  693. return TX_CONTINUE;
  694. /*
  695. * Anything but QoS data that has a sequence number field
  696. * (is long enough) gets a sequence number from the global
  697. * counter.
  698. */
  699. if (!ieee80211_is_data_qos(hdr->frame_control)) {
  700. /* driver should assign sequence number */
  701. info->flags |= IEEE80211_TX_CTL_ASSIGN_SEQ;
  702. /* for pure STA mode without beacons, we can do it */
  703. hdr->seq_ctrl = cpu_to_le16(tx->sdata->sequence_number);
  704. tx->sdata->sequence_number += 0x10;
  705. return TX_CONTINUE;
  706. }
  707. /*
  708. * This should be true for injected/management frames only, for
  709. * management frames we have set the IEEE80211_TX_CTL_ASSIGN_SEQ
  710. * above since they are not QoS-data frames.
  711. */
  712. if (!tx->sta)
  713. return TX_CONTINUE;
  714. /* include per-STA, per-TID sequence counter */
  715. qc = ieee80211_get_qos_ctl(hdr);
  716. tid = *qc & IEEE80211_QOS_CTL_TID_MASK;
  717. seq = &tx->sta->tid_seq[tid];
  718. hdr->seq_ctrl = cpu_to_le16(*seq);
  719. /* Increase the sequence number. */
  720. *seq = (*seq + 0x10) & IEEE80211_SCTL_SEQ;
  721. return TX_CONTINUE;
  722. }
  723. static int ieee80211_fragment(struct ieee80211_tx_data *tx,
  724. struct sk_buff *skb, int hdrlen,
  725. int frag_threshold)
  726. {
  727. struct ieee80211_local *local = tx->local;
  728. struct ieee80211_tx_info *info;
  729. struct sk_buff *tmp;
  730. int per_fragm = frag_threshold - hdrlen - FCS_LEN;
  731. int pos = hdrlen + per_fragm;
  732. int rem = skb->len - hdrlen - per_fragm;
  733. if (WARN_ON(rem < 0))
  734. return -EINVAL;
  735. /* first fragment was already added to queue by caller */
  736. while (rem) {
  737. int fraglen = per_fragm;
  738. if (fraglen > rem)
  739. fraglen = rem;
  740. rem -= fraglen;
  741. tmp = dev_alloc_skb(local->tx_headroom +
  742. frag_threshold +
  743. IEEE80211_ENCRYPT_HEADROOM +
  744. IEEE80211_ENCRYPT_TAILROOM);
  745. if (!tmp)
  746. return -ENOMEM;
  747. __skb_queue_tail(&tx->skbs, tmp);
  748. skb_reserve(tmp, local->tx_headroom +
  749. IEEE80211_ENCRYPT_HEADROOM);
  750. /* copy control information */
  751. memcpy(tmp->cb, skb->cb, sizeof(tmp->cb));
  752. info = IEEE80211_SKB_CB(tmp);
  753. info->flags &= ~(IEEE80211_TX_CTL_CLEAR_PS_FILT |
  754. IEEE80211_TX_CTL_FIRST_FRAGMENT);
  755. if (rem)
  756. info->flags |= IEEE80211_TX_CTL_MORE_FRAMES;
  757. skb_copy_queue_mapping(tmp, skb);
  758. tmp->priority = skb->priority;
  759. tmp->dev = skb->dev;
  760. /* copy header and data */
  761. memcpy(skb_put(tmp, hdrlen), skb->data, hdrlen);
  762. memcpy(skb_put(tmp, fraglen), skb->data + pos, fraglen);
  763. pos += fraglen;
  764. }
  765. /* adjust first fragment's length */
  766. skb->len = hdrlen + per_fragm;
  767. return 0;
  768. }
  769. static ieee80211_tx_result debug_noinline
  770. ieee80211_tx_h_fragment(struct ieee80211_tx_data *tx)
  771. {
  772. struct sk_buff *skb = tx->skb;
  773. struct ieee80211_tx_info *info = IEEE80211_SKB_CB(skb);
  774. struct ieee80211_hdr *hdr = (void *)skb->data;
  775. int frag_threshold = tx->local->hw.wiphy->frag_threshold;
  776. int hdrlen;
  777. int fragnum;
  778. /* no matter what happens, tx->skb moves to tx->skbs */
  779. __skb_queue_tail(&tx->skbs, skb);
  780. tx->skb = NULL;
  781. if (info->flags & IEEE80211_TX_CTL_DONTFRAG)
  782. return TX_CONTINUE;
  783. if (tx->local->ops->set_frag_threshold)
  784. return TX_CONTINUE;
  785. /*
  786. * Warn when submitting a fragmented A-MPDU frame and drop it.
  787. * This scenario is handled in ieee80211_tx_prepare but extra
  788. * caution taken here as fragmented ampdu may cause Tx stop.
  789. */
  790. if (WARN_ON(info->flags & IEEE80211_TX_CTL_AMPDU))
  791. return TX_DROP;
  792. hdrlen = ieee80211_hdrlen(hdr->frame_control);
  793. /* internal error, why isn't DONTFRAG set? */
  794. if (WARN_ON(skb->len + FCS_LEN <= frag_threshold))
  795. return TX_DROP;
  796. /*
  797. * Now fragment the frame. This will allocate all the fragments and
  798. * chain them (using skb as the first fragment) to skb->next.
  799. * During transmission, we will remove the successfully transmitted
  800. * fragments from this list. When the low-level driver rejects one
  801. * of the fragments then we will simply pretend to accept the skb
  802. * but store it away as pending.
  803. */
  804. if (ieee80211_fragment(tx, skb, hdrlen, frag_threshold))
  805. return TX_DROP;
  806. /* update duration/seq/flags of fragments */
  807. fragnum = 0;
  808. skb_queue_walk(&tx->skbs, skb) {
  809. int next_len;
  810. const __le16 morefrags = cpu_to_le16(IEEE80211_FCTL_MOREFRAGS);
  811. hdr = (void *)skb->data;
  812. info = IEEE80211_SKB_CB(skb);
  813. if (!skb_queue_is_last(&tx->skbs, skb)) {
  814. hdr->frame_control |= morefrags;
  815. /*
  816. * No multi-rate retries for fragmented frames, that
  817. * would completely throw off the NAV at other STAs.
  818. */
  819. info->control.rates[1].idx = -1;
  820. info->control.rates[2].idx = -1;
  821. info->control.rates[3].idx = -1;
  822. info->control.rates[4].idx = -1;
  823. BUILD_BUG_ON(IEEE80211_TX_MAX_RATES != 5);
  824. info->flags &= ~IEEE80211_TX_CTL_RATE_CTRL_PROBE;
  825. } else {
  826. hdr->frame_control &= ~morefrags;
  827. next_len = 0;
  828. }
  829. hdr->seq_ctrl |= cpu_to_le16(fragnum & IEEE80211_SCTL_FRAG);
  830. fragnum++;
  831. }
  832. return TX_CONTINUE;
  833. }
  834. static ieee80211_tx_result debug_noinline
  835. ieee80211_tx_h_stats(struct ieee80211_tx_data *tx)
  836. {
  837. struct sk_buff *skb;
  838. if (!tx->sta)
  839. return TX_CONTINUE;
  840. tx->sta->tx_packets++;
  841. skb_queue_walk(&tx->skbs, skb) {
  842. tx->sta->tx_fragments++;
  843. tx->sta->tx_bytes += skb->len;
  844. }
  845. return TX_CONTINUE;
  846. }
  847. static ieee80211_tx_result debug_noinline
  848. ieee80211_tx_h_encrypt(struct ieee80211_tx_data *tx)
  849. {
  850. struct ieee80211_tx_info *info = IEEE80211_SKB_CB(tx->skb);
  851. if (!tx->key)
  852. return TX_CONTINUE;
  853. switch (tx->key->conf.cipher) {
  854. case WLAN_CIPHER_SUITE_WEP40:
  855. case WLAN_CIPHER_SUITE_WEP104:
  856. return ieee80211_crypto_wep_encrypt(tx);
  857. case WLAN_CIPHER_SUITE_TKIP:
  858. return ieee80211_crypto_tkip_encrypt(tx);
  859. case WLAN_CIPHER_SUITE_CCMP:
  860. return ieee80211_crypto_ccmp_encrypt(tx);
  861. case WLAN_CIPHER_SUITE_AES_CMAC:
  862. return ieee80211_crypto_aes_cmac_encrypt(tx);
  863. default:
  864. /* handle hw-only algorithm */
  865. if (info->control.hw_key) {
  866. ieee80211_tx_set_protected(tx);
  867. return TX_CONTINUE;
  868. }
  869. break;
  870. }
  871. return TX_DROP;
  872. }
  873. static ieee80211_tx_result debug_noinline
  874. ieee80211_tx_h_calculate_duration(struct ieee80211_tx_data *tx)
  875. {
  876. struct sk_buff *skb;
  877. struct ieee80211_hdr *hdr;
  878. int next_len;
  879. bool group_addr;
  880. skb_queue_walk(&tx->skbs, skb) {
  881. hdr = (void *) skb->data;
  882. if (unlikely(ieee80211_is_pspoll(hdr->frame_control)))
  883. break; /* must not overwrite AID */
  884. if (!skb_queue_is_last(&tx->skbs, skb)) {
  885. struct sk_buff *next = skb_queue_next(&tx->skbs, skb);
  886. next_len = next->len;
  887. } else
  888. next_len = 0;
  889. group_addr = is_multicast_ether_addr(hdr->addr1);
  890. hdr->duration_id =
  891. ieee80211_duration(tx, skb, group_addr, next_len);
  892. }
  893. return TX_CONTINUE;
  894. }
  895. /* actual transmit path */
  896. static bool ieee80211_tx_prep_agg(struct ieee80211_tx_data *tx,
  897. struct sk_buff *skb,
  898. struct ieee80211_tx_info *info,
  899. struct tid_ampdu_tx *tid_tx,
  900. int tid)
  901. {
  902. bool queued = false;
  903. bool reset_agg_timer = false;
  904. if (test_bit(HT_AGG_STATE_OPERATIONAL, &tid_tx->state)) {
  905. info->flags |= IEEE80211_TX_CTL_AMPDU;
  906. reset_agg_timer = true;
  907. } else if (test_bit(HT_AGG_STATE_WANT_START, &tid_tx->state)) {
  908. /*
  909. * nothing -- this aggregation session is being started
  910. * but that might still fail with the driver
  911. */
  912. } else {
  913. spin_lock(&tx->sta->lock);
  914. /*
  915. * Need to re-check now, because we may get here
  916. *
  917. * 1) in the window during which the setup is actually
  918. * already done, but not marked yet because not all
  919. * packets are spliced over to the driver pending
  920. * queue yet -- if this happened we acquire the lock
  921. * either before or after the splice happens, but
  922. * need to recheck which of these cases happened.
  923. *
  924. * 2) during session teardown, if the OPERATIONAL bit
  925. * was cleared due to the teardown but the pointer
  926. * hasn't been assigned NULL yet (or we loaded it
  927. * before it was assigned) -- in this case it may
  928. * now be NULL which means we should just let the
  929. * packet pass through because splicing the frames
  930. * back is already done.
  931. */
  932. tid_tx = rcu_dereference_protected_tid_tx(tx->sta, tid);
  933. if (!tid_tx) {
  934. /* do nothing, let packet pass through */
  935. } else if (test_bit(HT_AGG_STATE_OPERATIONAL, &tid_tx->state)) {
  936. info->flags |= IEEE80211_TX_CTL_AMPDU;
  937. reset_agg_timer = true;
  938. } else {
  939. queued = true;
  940. info->control.vif = &tx->sdata->vif;
  941. info->flags |= IEEE80211_TX_INTFL_NEED_TXPROCESSING;
  942. __skb_queue_tail(&tid_tx->pending, skb);
  943. }
  944. spin_unlock(&tx->sta->lock);
  945. }
  946. /* reset session timer */
  947. if (reset_agg_timer && tid_tx->timeout)
  948. mod_timer(&tid_tx->session_timer,
  949. TU_TO_EXP_TIME(tid_tx->timeout));
  950. return queued;
  951. }
  952. /*
  953. * initialises @tx
  954. */
  955. static ieee80211_tx_result
  956. ieee80211_tx_prepare(struct ieee80211_sub_if_data *sdata,
  957. struct ieee80211_tx_data *tx,
  958. struct sk_buff *skb)
  959. {
  960. struct ieee80211_local *local = sdata->local;
  961. struct ieee80211_hdr *hdr;
  962. struct ieee80211_tx_info *info = IEEE80211_SKB_CB(skb);
  963. int tid;
  964. u8 *qc;
  965. memset(tx, 0, sizeof(*tx));
  966. tx->skb = skb;
  967. tx->local = local;
  968. tx->sdata = sdata;
  969. tx->channel = local->hw.conf.channel;
  970. __skb_queue_head_init(&tx->skbs);
  971. /*
  972. * If this flag is set to true anywhere, and we get here,
  973. * we are doing the needed processing, so remove the flag
  974. * now.
  975. */
  976. info->flags &= ~IEEE80211_TX_INTFL_NEED_TXPROCESSING;
  977. hdr = (struct ieee80211_hdr *) skb->data;
  978. if (sdata->vif.type == NL80211_IFTYPE_AP_VLAN) {
  979. tx->sta = rcu_dereference(sdata->u.vlan.sta);
  980. if (!tx->sta && sdata->dev->ieee80211_ptr->use_4addr)
  981. return TX_DROP;
  982. } else if (info->flags & IEEE80211_TX_CTL_INJECTED) {
  983. tx->sta = sta_info_get_bss(sdata, hdr->addr1);
  984. }
  985. if (!tx->sta)
  986. tx->sta = sta_info_get(sdata, hdr->addr1);
  987. if (tx->sta && ieee80211_is_data_qos(hdr->frame_control) &&
  988. !ieee80211_is_qos_nullfunc(hdr->frame_control) &&
  989. (local->hw.flags & IEEE80211_HW_AMPDU_AGGREGATION) &&
  990. !(local->hw.flags & IEEE80211_HW_TX_AMPDU_SETUP_IN_HW)) {
  991. struct tid_ampdu_tx *tid_tx;
  992. qc = ieee80211_get_qos_ctl(hdr);
  993. tid = *qc & IEEE80211_QOS_CTL_TID_MASK;
  994. tid_tx = rcu_dereference(tx->sta->ampdu_mlme.tid_tx[tid]);
  995. if (tid_tx) {
  996. bool queued;
  997. queued = ieee80211_tx_prep_agg(tx, skb, info,
  998. tid_tx, tid);
  999. if (unlikely(queued))
  1000. return TX_QUEUED;
  1001. }
  1002. }
  1003. if (is_multicast_ether_addr(hdr->addr1)) {
  1004. tx->flags &= ~IEEE80211_TX_UNICAST;
  1005. info->flags |= IEEE80211_TX_CTL_NO_ACK;
  1006. } else
  1007. tx->flags |= IEEE80211_TX_UNICAST;
  1008. if (!(info->flags & IEEE80211_TX_CTL_DONTFRAG)) {
  1009. if (!(tx->flags & IEEE80211_TX_UNICAST) ||
  1010. skb->len + FCS_LEN <= local->hw.wiphy->frag_threshold ||
  1011. info->flags & IEEE80211_TX_CTL_AMPDU)
  1012. info->flags |= IEEE80211_TX_CTL_DONTFRAG;
  1013. }
  1014. if (!tx->sta)
  1015. info->flags |= IEEE80211_TX_CTL_CLEAR_PS_FILT;
  1016. else if (test_and_clear_sta_flag(tx->sta, WLAN_STA_CLEAR_PS_FILT))
  1017. info->flags |= IEEE80211_TX_CTL_CLEAR_PS_FILT;
  1018. info->flags |= IEEE80211_TX_CTL_FIRST_FRAGMENT;
  1019. return TX_CONTINUE;
  1020. }
  1021. static bool ieee80211_tx_frags(struct ieee80211_local *local,
  1022. struct ieee80211_vif *vif,
  1023. struct ieee80211_sta *sta,
  1024. struct sk_buff_head *skbs,
  1025. bool txpending)
  1026. {
  1027. struct sk_buff *skb, *tmp;
  1028. struct ieee80211_tx_info *info;
  1029. unsigned long flags;
  1030. skb_queue_walk_safe(skbs, skb, tmp) {
  1031. int q = skb_get_queue_mapping(skb);
  1032. spin_lock_irqsave(&local->queue_stop_reason_lock, flags);
  1033. if (local->queue_stop_reasons[q] ||
  1034. (!txpending && !skb_queue_empty(&local->pending[q]))) {
  1035. /*
  1036. * Since queue is stopped, queue up frames for later
  1037. * transmission from the tx-pending tasklet when the
  1038. * queue is woken again.
  1039. */
  1040. if (txpending)
  1041. skb_queue_splice(skbs, &local->pending[q]);
  1042. else
  1043. skb_queue_splice_tail(skbs, &local->pending[q]);
  1044. spin_unlock_irqrestore(&local->queue_stop_reason_lock,
  1045. flags);
  1046. return false;
  1047. }
  1048. spin_unlock_irqrestore(&local->queue_stop_reason_lock, flags);
  1049. info = IEEE80211_SKB_CB(skb);
  1050. info->control.vif = vif;
  1051. info->control.sta = sta;
  1052. __skb_unlink(skb, skbs);
  1053. drv_tx(local, skb);
  1054. }
  1055. return true;
  1056. }
  1057. /*
  1058. * Returns false if the frame couldn't be transmitted but was queued instead.
  1059. */
  1060. static bool __ieee80211_tx(struct ieee80211_local *local,
  1061. struct sk_buff_head *skbs, int led_len,
  1062. struct sta_info *sta, bool txpending)
  1063. {
  1064. struct ieee80211_tx_info *info;
  1065. struct ieee80211_sub_if_data *sdata;
  1066. struct ieee80211_vif *vif;
  1067. struct ieee80211_sta *pubsta;
  1068. struct sk_buff *skb;
  1069. bool result = true;
  1070. __le16 fc;
  1071. if (WARN_ON(skb_queue_empty(skbs)))
  1072. return true;
  1073. skb = skb_peek(skbs);
  1074. fc = ((struct ieee80211_hdr *)skb->data)->frame_control;
  1075. info = IEEE80211_SKB_CB(skb);
  1076. sdata = vif_to_sdata(info->control.vif);
  1077. if (sta && !sta->uploaded)
  1078. sta = NULL;
  1079. if (sta)
  1080. pubsta = &sta->sta;
  1081. else
  1082. pubsta = NULL;
  1083. switch (sdata->vif.type) {
  1084. case NL80211_IFTYPE_MONITOR:
  1085. sdata = NULL;
  1086. vif = NULL;
  1087. break;
  1088. case NL80211_IFTYPE_AP_VLAN:
  1089. sdata = container_of(sdata->bss,
  1090. struct ieee80211_sub_if_data, u.ap);
  1091. /* fall through */
  1092. default:
  1093. vif = &sdata->vif;
  1094. break;
  1095. }
  1096. if (local->ops->tx_frags)
  1097. drv_tx_frags(local, vif, pubsta, skbs);
  1098. else
  1099. result = ieee80211_tx_frags(local, vif, pubsta, skbs,
  1100. txpending);
  1101. ieee80211_tpt_led_trig_tx(local, fc, led_len);
  1102. ieee80211_led_tx(local, 1);
  1103. WARN_ON(!skb_queue_empty(skbs));
  1104. return result;
  1105. }
  1106. /*
  1107. * Invoke TX handlers, return 0 on success and non-zero if the
  1108. * frame was dropped or queued.
  1109. */
  1110. static int invoke_tx_handlers(struct ieee80211_tx_data *tx)
  1111. {
  1112. struct ieee80211_tx_info *info = IEEE80211_SKB_CB(tx->skb);
  1113. ieee80211_tx_result res = TX_DROP;
  1114. #define CALL_TXH(txh) \
  1115. do { \
  1116. res = txh(tx); \
  1117. if (res != TX_CONTINUE) \
  1118. goto txh_done; \
  1119. } while (0)
  1120. CALL_TXH(ieee80211_tx_h_dynamic_ps);
  1121. CALL_TXH(ieee80211_tx_h_check_assoc);
  1122. CALL_TXH(ieee80211_tx_h_ps_buf);
  1123. CALL_TXH(ieee80211_tx_h_check_control_port_protocol);
  1124. CALL_TXH(ieee80211_tx_h_select_key);
  1125. if (!(tx->local->hw.flags & IEEE80211_HW_HAS_RATE_CONTROL))
  1126. CALL_TXH(ieee80211_tx_h_rate_ctrl);
  1127. if (unlikely(info->flags & IEEE80211_TX_INTFL_RETRANSMISSION))
  1128. goto txh_done;
  1129. CALL_TXH(ieee80211_tx_h_michael_mic_add);
  1130. CALL_TXH(ieee80211_tx_h_sequence);
  1131. CALL_TXH(ieee80211_tx_h_fragment);
  1132. /* handlers after fragment must be aware of tx info fragmentation! */
  1133. CALL_TXH(ieee80211_tx_h_stats);
  1134. CALL_TXH(ieee80211_tx_h_encrypt);
  1135. if (!(tx->local->hw.flags & IEEE80211_HW_HAS_RATE_CONTROL))
  1136. CALL_TXH(ieee80211_tx_h_calculate_duration);
  1137. #undef CALL_TXH
  1138. txh_done:
  1139. if (unlikely(res == TX_DROP)) {
  1140. I802_DEBUG_INC(tx->local->tx_handlers_drop);
  1141. if (tx->skb)
  1142. dev_kfree_skb(tx->skb);
  1143. else
  1144. __skb_queue_purge(&tx->skbs);
  1145. return -1;
  1146. } else if (unlikely(res == TX_QUEUED)) {
  1147. I802_DEBUG_INC(tx->local->tx_handlers_queued);
  1148. return -1;
  1149. }
  1150. return 0;
  1151. }
  1152. /*
  1153. * Returns false if the frame couldn't be transmitted but was queued instead.
  1154. */
  1155. static bool ieee80211_tx(struct ieee80211_sub_if_data *sdata,
  1156. struct sk_buff *skb, bool txpending)
  1157. {
  1158. struct ieee80211_local *local = sdata->local;
  1159. struct ieee80211_tx_data tx;
  1160. ieee80211_tx_result res_prepare;
  1161. struct ieee80211_tx_info *info = IEEE80211_SKB_CB(skb);
  1162. bool result = true;
  1163. int led_len;
  1164. if (unlikely(skb->len < 10)) {
  1165. dev_kfree_skb(skb);
  1166. return true;
  1167. }
  1168. rcu_read_lock();
  1169. /* initialises tx */
  1170. led_len = skb->len;
  1171. res_prepare = ieee80211_tx_prepare(sdata, &tx, skb);
  1172. if (unlikely(res_prepare == TX_DROP)) {
  1173. dev_kfree_skb(skb);
  1174. goto out;
  1175. } else if (unlikely(res_prepare == TX_QUEUED)) {
  1176. goto out;
  1177. }
  1178. tx.channel = local->hw.conf.channel;
  1179. info->band = tx.channel->band;
  1180. if (!invoke_tx_handlers(&tx))
  1181. result = __ieee80211_tx(local, &tx.skbs, led_len,
  1182. tx.sta, txpending);
  1183. out:
  1184. rcu_read_unlock();
  1185. return result;
  1186. }
  1187. /* device xmit handlers */
  1188. static int ieee80211_skb_resize(struct ieee80211_sub_if_data *sdata,
  1189. struct sk_buff *skb,
  1190. int head_need, bool may_encrypt)
  1191. {
  1192. struct ieee80211_local *local = sdata->local;
  1193. int tail_need = 0;
  1194. if (may_encrypt && sdata->crypto_tx_tailroom_needed_cnt) {
  1195. tail_need = IEEE80211_ENCRYPT_TAILROOM;
  1196. tail_need -= skb_tailroom(skb);
  1197. tail_need = max_t(int, tail_need, 0);
  1198. }
  1199. if (skb_cloned(skb))
  1200. I802_DEBUG_INC(local->tx_expand_skb_head_cloned);
  1201. else if (head_need || tail_need)
  1202. I802_DEBUG_INC(local->tx_expand_skb_head);
  1203. else
  1204. return 0;
  1205. if (pskb_expand_head(skb, head_need, tail_need, GFP_ATOMIC)) {
  1206. wiphy_debug(local->hw.wiphy,
  1207. "failed to reallocate TX buffer\n");
  1208. return -ENOMEM;
  1209. }
  1210. return 0;
  1211. }
  1212. void ieee80211_xmit(struct ieee80211_sub_if_data *sdata, struct sk_buff *skb)
  1213. {
  1214. struct ieee80211_local *local = sdata->local;
  1215. struct ieee80211_tx_info *info = IEEE80211_SKB_CB(skb);
  1216. struct ieee80211_hdr *hdr = (struct ieee80211_hdr *) skb->data;
  1217. int headroom;
  1218. bool may_encrypt;
  1219. rcu_read_lock();
  1220. may_encrypt = !(info->flags & IEEE80211_TX_INTFL_DONT_ENCRYPT);
  1221. headroom = local->tx_headroom;
  1222. if (may_encrypt)
  1223. headroom += IEEE80211_ENCRYPT_HEADROOM;
  1224. headroom -= skb_headroom(skb);
  1225. headroom = max_t(int, 0, headroom);
  1226. if (ieee80211_skb_resize(sdata, skb, headroom, may_encrypt)) {
  1227. dev_kfree_skb(skb);
  1228. rcu_read_unlock();
  1229. return;
  1230. }
  1231. hdr = (struct ieee80211_hdr *) skb->data;
  1232. info->control.vif = &sdata->vif;
  1233. if (ieee80211_vif_is_mesh(&sdata->vif) &&
  1234. ieee80211_is_data(hdr->frame_control) &&
  1235. !is_multicast_ether_addr(hdr->addr1))
  1236. if (mesh_nexthop_lookup(skb, sdata)) {
  1237. /* skb queued: don't free */
  1238. rcu_read_unlock();
  1239. return;
  1240. }
  1241. ieee80211_set_qos_hdr(sdata, skb);
  1242. ieee80211_tx(sdata, skb, false);
  1243. rcu_read_unlock();
  1244. }
  1245. static bool ieee80211_parse_tx_radiotap(struct sk_buff *skb)
  1246. {
  1247. struct ieee80211_radiotap_iterator iterator;
  1248. struct ieee80211_radiotap_header *rthdr =
  1249. (struct ieee80211_radiotap_header *) skb->data;
  1250. struct ieee80211_tx_info *info = IEEE80211_SKB_CB(skb);
  1251. int ret = ieee80211_radiotap_iterator_init(&iterator, rthdr, skb->len,
  1252. NULL);
  1253. u16 txflags;
  1254. info->flags |= IEEE80211_TX_INTFL_DONT_ENCRYPT |
  1255. IEEE80211_TX_CTL_DONTFRAG;
  1256. /*
  1257. * for every radiotap entry that is present
  1258. * (ieee80211_radiotap_iterator_next returns -ENOENT when no more
  1259. * entries present, or -EINVAL on error)
  1260. */
  1261. while (!ret) {
  1262. ret = ieee80211_radiotap_iterator_next(&iterator);
  1263. if (ret)
  1264. continue;
  1265. /* see if this argument is something we can use */
  1266. switch (iterator.this_arg_index) {
  1267. /*
  1268. * You must take care when dereferencing iterator.this_arg
  1269. * for multibyte types... the pointer is not aligned. Use
  1270. * get_unaligned((type *)iterator.this_arg) to dereference
  1271. * iterator.this_arg for type "type" safely on all arches.
  1272. */
  1273. case IEEE80211_RADIOTAP_FLAGS:
  1274. if (*iterator.this_arg & IEEE80211_RADIOTAP_F_FCS) {
  1275. /*
  1276. * this indicates that the skb we have been
  1277. * handed has the 32-bit FCS CRC at the end...
  1278. * we should react to that by snipping it off
  1279. * because it will be recomputed and added
  1280. * on transmission
  1281. */
  1282. if (skb->len < (iterator._max_length + FCS_LEN))
  1283. return false;
  1284. skb_trim(skb, skb->len - FCS_LEN);
  1285. }
  1286. if (*iterator.this_arg & IEEE80211_RADIOTAP_F_WEP)
  1287. info->flags &= ~IEEE80211_TX_INTFL_DONT_ENCRYPT;
  1288. if (*iterator.this_arg & IEEE80211_RADIOTAP_F_FRAG)
  1289. info->flags &= ~IEEE80211_TX_CTL_DONTFRAG;
  1290. break;
  1291. case IEEE80211_RADIOTAP_TX_FLAGS:
  1292. txflags = get_unaligned_le16(iterator.this_arg);
  1293. if (txflags & IEEE80211_RADIOTAP_F_TX_NOACK)
  1294. info->flags |= IEEE80211_TX_CTL_NO_ACK;
  1295. break;
  1296. /*
  1297. * Please update the file
  1298. * Documentation/networking/mac80211-injection.txt
  1299. * when parsing new fields here.
  1300. */
  1301. default:
  1302. break;
  1303. }
  1304. }
  1305. if (ret != -ENOENT) /* ie, if we didn't simply run out of fields */
  1306. return false;
  1307. /*
  1308. * remove the radiotap header
  1309. * iterator->_max_length was sanity-checked against
  1310. * skb->len by iterator init
  1311. */
  1312. skb_pull(skb, iterator._max_length);
  1313. return true;
  1314. }
  1315. netdev_tx_t ieee80211_monitor_start_xmit(struct sk_buff *skb,
  1316. struct net_device *dev)
  1317. {
  1318. struct ieee80211_local *local = wdev_priv(dev->ieee80211_ptr);
  1319. struct ieee80211_channel *chan = local->hw.conf.channel;
  1320. struct ieee80211_radiotap_header *prthdr =
  1321. (struct ieee80211_radiotap_header *)skb->data;
  1322. struct ieee80211_tx_info *info = IEEE80211_SKB_CB(skb);
  1323. struct ieee80211_hdr *hdr;
  1324. struct ieee80211_sub_if_data *tmp_sdata, *sdata;
  1325. u16 len_rthdr;
  1326. int hdrlen;
  1327. /*
  1328. * Frame injection is not allowed if beaconing is not allowed
  1329. * or if we need radar detection. Beaconing is usually not allowed when
  1330. * the mode or operation (Adhoc, AP, Mesh) does not support DFS.
  1331. * Passive scan is also used in world regulatory domains where
  1332. * your country is not known and as such it should be treated as
  1333. * NO TX unless the channel is explicitly allowed in which case
  1334. * your current regulatory domain would not have the passive scan
  1335. * flag.
  1336. *
  1337. * Since AP mode uses monitor interfaces to inject/TX management
  1338. * frames we can make AP mode the exception to this rule once it
  1339. * supports radar detection as its implementation can deal with
  1340. * radar detection by itself. We can do that later by adding a
  1341. * monitor flag interfaces used for AP support.
  1342. */
  1343. if ((chan->flags & (IEEE80211_CHAN_NO_IBSS | IEEE80211_CHAN_RADAR |
  1344. IEEE80211_CHAN_PASSIVE_SCAN)))
  1345. goto fail;
  1346. /* check for not even having the fixed radiotap header part */
  1347. if (unlikely(skb->len < sizeof(struct ieee80211_radiotap_header)))
  1348. goto fail; /* too short to be possibly valid */
  1349. /* is it a header version we can trust to find length from? */
  1350. if (unlikely(prthdr->it_version))
  1351. goto fail; /* only version 0 is supported */
  1352. /* then there must be a radiotap header with a length we can use */
  1353. len_rthdr = ieee80211_get_radiotap_len(skb->data);
  1354. /* does the skb contain enough to deliver on the alleged length? */
  1355. if (unlikely(skb->len < len_rthdr))
  1356. goto fail; /* skb too short for claimed rt header extent */
  1357. /*
  1358. * fix up the pointers accounting for the radiotap
  1359. * header still being in there. We are being given
  1360. * a precooked IEEE80211 header so no need for
  1361. * normal processing
  1362. */
  1363. skb_set_mac_header(skb, len_rthdr);
  1364. /*
  1365. * these are just fixed to the end of the rt area since we
  1366. * don't have any better information and at this point, nobody cares
  1367. */
  1368. skb_set_network_header(skb, len_rthdr);
  1369. skb_set_transport_header(skb, len_rthdr);
  1370. if (skb->len < len_rthdr + 2)
  1371. goto fail;
  1372. hdr = (struct ieee80211_hdr *)(skb->data + len_rthdr);
  1373. hdrlen = ieee80211_hdrlen(hdr->frame_control);
  1374. if (skb->len < len_rthdr + hdrlen)
  1375. goto fail;
  1376. /*
  1377. * Initialize skb->protocol if the injected frame is a data frame
  1378. * carrying a rfc1042 header
  1379. */
  1380. if (ieee80211_is_data(hdr->frame_control) &&
  1381. skb->len >= len_rthdr + hdrlen + sizeof(rfc1042_header) + 2) {
  1382. u8 *payload = (u8 *)hdr + hdrlen;
  1383. if (compare_ether_addr(payload, rfc1042_header) == 0)
  1384. skb->protocol = cpu_to_be16((payload[6] << 8) |
  1385. payload[7]);
  1386. }
  1387. memset(info, 0, sizeof(*info));
  1388. info->flags = IEEE80211_TX_CTL_REQ_TX_STATUS |
  1389. IEEE80211_TX_CTL_INJECTED;
  1390. /* process and remove the injection radiotap header */
  1391. if (!ieee80211_parse_tx_radiotap(skb))
  1392. goto fail;
  1393. rcu_read_lock();
  1394. /*
  1395. * We process outgoing injected frames that have a local address
  1396. * we handle as though they are non-injected frames.
  1397. * This code here isn't entirely correct, the local MAC address
  1398. * isn't always enough to find the interface to use; for proper
  1399. * VLAN/WDS support we will need a different mechanism (which
  1400. * likely isn't going to be monitor interfaces).
  1401. */
  1402. sdata = IEEE80211_DEV_TO_SUB_IF(dev);
  1403. list_for_each_entry_rcu(tmp_sdata, &local->interfaces, list) {
  1404. if (!ieee80211_sdata_running(tmp_sdata))
  1405. continue;
  1406. if (tmp_sdata->vif.type == NL80211_IFTYPE_MONITOR ||
  1407. tmp_sdata->vif.type == NL80211_IFTYPE_AP_VLAN ||
  1408. tmp_sdata->vif.type == NL80211_IFTYPE_WDS)
  1409. continue;
  1410. if (compare_ether_addr(tmp_sdata->vif.addr, hdr->addr2) == 0) {
  1411. sdata = tmp_sdata;
  1412. break;
  1413. }
  1414. }
  1415. ieee80211_xmit(sdata, skb);
  1416. rcu_read_unlock();
  1417. return NETDEV_TX_OK;
  1418. fail:
  1419. dev_kfree_skb(skb);
  1420. return NETDEV_TX_OK; /* meaning, we dealt with the skb */
  1421. }
  1422. /**
  1423. * ieee80211_subif_start_xmit - netif start_xmit function for Ethernet-type
  1424. * subinterfaces (wlan#, WDS, and VLAN interfaces)
  1425. * @skb: packet to be sent
  1426. * @dev: incoming interface
  1427. *
  1428. * Returns: 0 on success (and frees skb in this case) or 1 on failure (skb will
  1429. * not be freed, and caller is responsible for either retrying later or freeing
  1430. * skb).
  1431. *
  1432. * This function takes in an Ethernet header and encapsulates it with suitable
  1433. * IEEE 802.11 header based on which interface the packet is coming in. The
  1434. * encapsulated packet will then be passed to master interface, wlan#.11, for
  1435. * transmission (through low-level driver).
  1436. */
  1437. netdev_tx_t ieee80211_subif_start_xmit(struct sk_buff *skb,
  1438. struct net_device *dev)
  1439. {
  1440. struct ieee80211_sub_if_data *sdata = IEEE80211_DEV_TO_SUB_IF(dev);
  1441. struct ieee80211_local *local = sdata->local;
  1442. struct ieee80211_tx_info *info;
  1443. int ret = NETDEV_TX_BUSY, head_need;
  1444. u16 ethertype, hdrlen, meshhdrlen = 0;
  1445. __le16 fc;
  1446. struct ieee80211_hdr hdr;
  1447. struct ieee80211s_hdr mesh_hdr __maybe_unused;
  1448. struct mesh_path __maybe_unused *mppath = NULL;
  1449. const u8 *encaps_data;
  1450. int encaps_len, skip_header_bytes;
  1451. int nh_pos, h_pos;
  1452. struct sta_info *sta = NULL;
  1453. bool wme_sta = false, authorized = false, tdls_auth = false;
  1454. bool tdls_direct = false;
  1455. bool multicast;
  1456. u32 info_flags = 0;
  1457. u16 info_id = 0;
  1458. if (unlikely(skb->len < ETH_HLEN)) {
  1459. ret = NETDEV_TX_OK;
  1460. goto fail;
  1461. }
  1462. /* convert Ethernet header to proper 802.11 header (based on
  1463. * operation mode) */
  1464. ethertype = (skb->data[12] << 8) | skb->data[13];
  1465. fc = cpu_to_le16(IEEE80211_FTYPE_DATA | IEEE80211_STYPE_DATA);
  1466. switch (sdata->vif.type) {
  1467. case NL80211_IFTYPE_AP_VLAN:
  1468. rcu_read_lock();
  1469. sta = rcu_dereference(sdata->u.vlan.sta);
  1470. if (sta) {
  1471. fc |= cpu_to_le16(IEEE80211_FCTL_FROMDS | IEEE80211_FCTL_TODS);
  1472. /* RA TA DA SA */
  1473. memcpy(hdr.addr1, sta->sta.addr, ETH_ALEN);
  1474. memcpy(hdr.addr2, sdata->vif.addr, ETH_ALEN);
  1475. memcpy(hdr.addr3, skb->data, ETH_ALEN);
  1476. memcpy(hdr.addr4, skb->data + ETH_ALEN, ETH_ALEN);
  1477. hdrlen = 30;
  1478. authorized = test_sta_flag(sta, WLAN_STA_AUTHORIZED);
  1479. wme_sta = test_sta_flag(sta, WLAN_STA_WME);
  1480. }
  1481. rcu_read_unlock();
  1482. if (sta)
  1483. break;
  1484. /* fall through */
  1485. case NL80211_IFTYPE_AP:
  1486. fc |= cpu_to_le16(IEEE80211_FCTL_FROMDS);
  1487. /* DA BSSID SA */
  1488. memcpy(hdr.addr1, skb->data, ETH_ALEN);
  1489. memcpy(hdr.addr2, sdata->vif.addr, ETH_ALEN);
  1490. memcpy(hdr.addr3, skb->data + ETH_ALEN, ETH_ALEN);
  1491. hdrlen = 24;
  1492. break;
  1493. case NL80211_IFTYPE_WDS:
  1494. fc |= cpu_to_le16(IEEE80211_FCTL_FROMDS | IEEE80211_FCTL_TODS);
  1495. /* RA TA DA SA */
  1496. memcpy(hdr.addr1, sdata->u.wds.remote_addr, ETH_ALEN);
  1497. memcpy(hdr.addr2, sdata->vif.addr, ETH_ALEN);
  1498. memcpy(hdr.addr3, skb->data, ETH_ALEN);
  1499. memcpy(hdr.addr4, skb->data + ETH_ALEN, ETH_ALEN);
  1500. hdrlen = 30;
  1501. break;
  1502. #ifdef CONFIG_MAC80211_MESH
  1503. case NL80211_IFTYPE_MESH_POINT:
  1504. if (!sdata->u.mesh.mshcfg.dot11MeshTTL) {
  1505. /* Do not send frames with mesh_ttl == 0 */
  1506. sdata->u.mesh.mshstats.dropped_frames_ttl++;
  1507. ret = NETDEV_TX_OK;
  1508. goto fail;
  1509. }
  1510. rcu_read_lock();
  1511. if (!is_multicast_ether_addr(skb->data))
  1512. mppath = mpp_path_lookup(skb->data, sdata);
  1513. /*
  1514. * Use address extension if it is a packet from
  1515. * another interface or if we know the destination
  1516. * is being proxied by a portal (i.e. portal address
  1517. * differs from proxied address)
  1518. */
  1519. if (compare_ether_addr(sdata->vif.addr,
  1520. skb->data + ETH_ALEN) == 0 &&
  1521. !(mppath && compare_ether_addr(mppath->mpp, skb->data))) {
  1522. hdrlen = ieee80211_fill_mesh_addresses(&hdr, &fc,
  1523. skb->data, skb->data + ETH_ALEN);
  1524. rcu_read_unlock();
  1525. meshhdrlen = ieee80211_new_mesh_header(&mesh_hdr,
  1526. sdata, NULL, NULL);
  1527. } else {
  1528. int is_mesh_mcast = 1;
  1529. const u8 *mesh_da;
  1530. if (is_multicast_ether_addr(skb->data))
  1531. /* DA TA mSA AE:SA */
  1532. mesh_da = skb->data;
  1533. else {
  1534. static const u8 bcast[ETH_ALEN] =
  1535. { 0xff, 0xff, 0xff, 0xff, 0xff, 0xff };
  1536. if (mppath) {
  1537. /* RA TA mDA mSA AE:DA SA */
  1538. mesh_da = mppath->mpp;
  1539. is_mesh_mcast = 0;
  1540. } else {
  1541. /* DA TA mSA AE:SA */
  1542. mesh_da = bcast;
  1543. }
  1544. }
  1545. hdrlen = ieee80211_fill_mesh_addresses(&hdr, &fc,
  1546. mesh_da, sdata->vif.addr);
  1547. rcu_read_unlock();
  1548. if (is_mesh_mcast)
  1549. meshhdrlen =
  1550. ieee80211_new_mesh_header(&mesh_hdr,
  1551. sdata,
  1552. skb->data + ETH_ALEN,
  1553. NULL);
  1554. else
  1555. meshhdrlen =
  1556. ieee80211_new_mesh_header(&mesh_hdr,
  1557. sdata,
  1558. skb->data,
  1559. skb->data + ETH_ALEN);
  1560. }
  1561. break;
  1562. #endif
  1563. case NL80211_IFTYPE_STATION:
  1564. if (sdata->wdev.wiphy->flags & WIPHY_FLAG_SUPPORTS_TDLS) {
  1565. bool tdls_peer = false;
  1566. rcu_read_lock();
  1567. sta = sta_info_get(sdata, skb->data);
  1568. if (sta) {
  1569. authorized = test_sta_flag(sta,
  1570. WLAN_STA_AUTHORIZED);
  1571. wme_sta = test_sta_flag(sta, WLAN_STA_WME);
  1572. tdls_peer = test_sta_flag(sta,
  1573. WLAN_STA_TDLS_PEER);
  1574. tdls_auth = test_sta_flag(sta,
  1575. WLAN_STA_TDLS_PEER_AUTH);
  1576. }
  1577. rcu_read_unlock();
  1578. /*
  1579. * If the TDLS link is enabled, send everything
  1580. * directly. Otherwise, allow TDLS setup frames
  1581. * to be transmitted indirectly.
  1582. */
  1583. tdls_direct = tdls_peer && (tdls_auth ||
  1584. !(ethertype == ETH_P_TDLS && skb->len > 14 &&
  1585. skb->data[14] == WLAN_TDLS_SNAP_RFTYPE));
  1586. }
  1587. if (tdls_direct) {
  1588. /* link during setup - throw out frames to peer */
  1589. if (!tdls_auth) {
  1590. ret = NETDEV_TX_OK;
  1591. goto fail;
  1592. }
  1593. /* DA SA BSSID */
  1594. memcpy(hdr.addr1, skb->data, ETH_ALEN);
  1595. memcpy(hdr.addr2, skb->data + ETH_ALEN, ETH_ALEN);
  1596. memcpy(hdr.addr3, sdata->u.mgd.bssid, ETH_ALEN);
  1597. hdrlen = 24;
  1598. } else if (sdata->u.mgd.use_4addr &&
  1599. cpu_to_be16(ethertype) != sdata->control_port_protocol) {
  1600. fc |= cpu_to_le16(IEEE80211_FCTL_FROMDS |
  1601. IEEE80211_FCTL_TODS);
  1602. /* RA TA DA SA */
  1603. memcpy(hdr.addr1, sdata->u.mgd.bssid, ETH_ALEN);
  1604. memcpy(hdr.addr2, sdata->vif.addr, ETH_ALEN);
  1605. memcpy(hdr.addr3, skb->data, ETH_ALEN);
  1606. memcpy(hdr.addr4, skb->data + ETH_ALEN, ETH_ALEN);
  1607. hdrlen = 30;
  1608. } else {
  1609. fc |= cpu_to_le16(IEEE80211_FCTL_TODS);
  1610. /* BSSID SA DA */
  1611. memcpy(hdr.addr1, sdata->u.mgd.bssid, ETH_ALEN);
  1612. memcpy(hdr.addr2, skb->data + ETH_ALEN, ETH_ALEN);
  1613. memcpy(hdr.addr3, skb->data, ETH_ALEN);
  1614. hdrlen = 24;
  1615. }
  1616. break;
  1617. case NL80211_IFTYPE_ADHOC:
  1618. /* DA SA BSSID */
  1619. memcpy(hdr.addr1, skb->data, ETH_ALEN);
  1620. memcpy(hdr.addr2, skb->data + ETH_ALEN, ETH_ALEN);
  1621. memcpy(hdr.addr3, sdata->u.ibss.bssid, ETH_ALEN);
  1622. hdrlen = 24;
  1623. break;
  1624. default:
  1625. ret = NETDEV_TX_OK;
  1626. goto fail;
  1627. }
  1628. /*
  1629. * There's no need to try to look up the destination
  1630. * if it is a multicast address (which can only happen
  1631. * in AP mode)
  1632. */
  1633. multicast = is_multicast_ether_addr(hdr.addr1);
  1634. if (!multicast) {
  1635. rcu_read_lock();
  1636. sta = sta_info_get(sdata, hdr.addr1);
  1637. if (sta) {
  1638. authorized = test_sta_flag(sta, WLAN_STA_AUTHORIZED);
  1639. wme_sta = test_sta_flag(sta, WLAN_STA_WME);
  1640. }
  1641. rcu_read_unlock();
  1642. }
  1643. /* For mesh, the use of the QoS header is mandatory */
  1644. if (ieee80211_vif_is_mesh(&sdata->vif))
  1645. wme_sta = true;
  1646. /* receiver and we are QoS enabled, use a QoS type frame */
  1647. if (wme_sta && local->hw.queues >= 4) {
  1648. fc |= cpu_to_le16(IEEE80211_STYPE_QOS_DATA);
  1649. hdrlen += 2;
  1650. }
  1651. /*
  1652. * Drop unicast frames to unauthorised stations unless they are
  1653. * EAPOL frames from the local station.
  1654. */
  1655. if (unlikely(!ieee80211_vif_is_mesh(&sdata->vif) &&
  1656. !is_multicast_ether_addr(hdr.addr1) && !authorized &&
  1657. (cpu_to_be16(ethertype) != sdata->control_port_protocol ||
  1658. compare_ether_addr(sdata->vif.addr, skb->data + ETH_ALEN)))) {
  1659. #ifdef CONFIG_MAC80211_VERBOSE_DEBUG
  1660. if (net_ratelimit())
  1661. printk(KERN_DEBUG "%s: dropped frame to %pM"
  1662. " (unauthorized port)\n", dev->name,
  1663. hdr.addr1);
  1664. #endif
  1665. I802_DEBUG_INC(local->tx_handlers_drop_unauth_port);
  1666. ret = NETDEV_TX_OK;
  1667. goto fail;
  1668. }
  1669. if (unlikely(!multicast && skb->sk &&
  1670. skb_shinfo(skb)->tx_flags & SKBTX_WIFI_STATUS)) {
  1671. struct sk_buff *orig_skb = skb;
  1672. skb = skb_clone(skb, GFP_ATOMIC);
  1673. if (skb) {
  1674. unsigned long flags;
  1675. int id, r;
  1676. spin_lock_irqsave(&local->ack_status_lock, flags);
  1677. r = idr_get_new_above(&local->ack_status_frames,
  1678. orig_skb, 1, &id);
  1679. if (r == -EAGAIN) {
  1680. idr_pre_get(&local->ack_status_frames,
  1681. GFP_ATOMIC);
  1682. r = idr_get_new_above(&local->ack_status_frames,
  1683. orig_skb, 1, &id);
  1684. }
  1685. if (WARN_ON(!id) || id > 0xffff) {
  1686. idr_remove(&local->ack_status_frames, id);
  1687. r = -ERANGE;
  1688. }
  1689. spin_unlock_irqrestore(&local->ack_status_lock, flags);
  1690. if (!r) {
  1691. info_id = id;
  1692. info_flags |= IEEE80211_TX_CTL_REQ_TX_STATUS;
  1693. } else if (skb_shared(skb)) {
  1694. kfree_skb(orig_skb);
  1695. } else {
  1696. kfree_skb(skb);
  1697. skb = orig_skb;
  1698. }
  1699. } else {
  1700. /* couldn't clone -- lose tx status ... */
  1701. skb = orig_skb;
  1702. }
  1703. }
  1704. /*
  1705. * If the skb is shared we need to obtain our own copy.
  1706. */
  1707. if (skb_shared(skb)) {
  1708. struct sk_buff *tmp_skb = skb;
  1709. /* can't happen -- skb is a clone if info_id != 0 */
  1710. WARN_ON(info_id);
  1711. skb = skb_clone(skb, GFP_ATOMIC);
  1712. kfree_skb(tmp_skb);
  1713. if (!skb) {
  1714. ret = NETDEV_TX_OK;
  1715. goto fail;
  1716. }
  1717. }
  1718. hdr.frame_control = fc;
  1719. hdr.duration_id = 0;
  1720. hdr.seq_ctrl = 0;
  1721. skip_header_bytes = ETH_HLEN;
  1722. if (ethertype == ETH_P_AARP || ethertype == ETH_P_IPX) {
  1723. encaps_data = bridge_tunnel_header;
  1724. encaps_len = sizeof(bridge_tunnel_header);
  1725. skip_header_bytes -= 2;
  1726. } else if (ethertype >= 0x600) {
  1727. encaps_data = rfc1042_header;
  1728. encaps_len = sizeof(rfc1042_header);
  1729. skip_header_bytes -= 2;
  1730. } else {
  1731. encaps_data = NULL;
  1732. encaps_len = 0;
  1733. }
  1734. nh_pos = skb_network_header(skb) - skb->data;
  1735. h_pos = skb_transport_header(skb) - skb->data;
  1736. skb_pull(skb, skip_header_bytes);
  1737. nh_pos -= skip_header_bytes;
  1738. h_pos -= skip_header_bytes;
  1739. head_need = hdrlen + encaps_len + meshhdrlen - skb_headroom(skb);
  1740. /*
  1741. * So we need to modify the skb header and hence need a copy of
  1742. * that. The head_need variable above doesn't, so far, include
  1743. * the needed header space that we don't need right away. If we
  1744. * can, then we don't reallocate right now but only after the
  1745. * frame arrives at the master device (if it does...)
  1746. *
  1747. * If we cannot, however, then we will reallocate to include all
  1748. * the ever needed space. Also, if we need to reallocate it anyway,
  1749. * make it big enough for everything we may ever need.
  1750. */
  1751. if (head_need > 0 || skb_cloned(skb)) {
  1752. head_need += IEEE80211_ENCRYPT_HEADROOM;
  1753. head_need += local->tx_headroom;
  1754. head_need = max_t(int, 0, head_need);
  1755. if (ieee80211_skb_resize(sdata, skb, head_need, true))
  1756. goto fail;
  1757. }
  1758. if (encaps_data) {
  1759. memcpy(skb_push(skb, encaps_len), encaps_data, encaps_len);
  1760. nh_pos += encaps_len;
  1761. h_pos += encaps_len;
  1762. }
  1763. #ifdef CONFIG_MAC80211_MESH
  1764. if (meshhdrlen > 0) {
  1765. memcpy(skb_push(skb, meshhdrlen), &mesh_hdr, meshhdrlen);
  1766. nh_pos += meshhdrlen;
  1767. h_pos += meshhdrlen;
  1768. }
  1769. #endif
  1770. if (ieee80211_is_data_qos(fc)) {
  1771. __le16 *qos_control;
  1772. qos_control = (__le16*) skb_push(skb, 2);
  1773. memcpy(skb_push(skb, hdrlen - 2), &hdr, hdrlen - 2);
  1774. /*
  1775. * Maybe we could actually set some fields here, for now just
  1776. * initialise to zero to indicate no special operation.
  1777. */
  1778. *qos_control = 0;
  1779. } else
  1780. memcpy(skb_push(skb, hdrlen), &hdr, hdrlen);
  1781. nh_pos += hdrlen;
  1782. h_pos += hdrlen;
  1783. dev->stats.tx_packets++;
  1784. dev->stats.tx_bytes += skb->len;
  1785. /* Update skb pointers to various headers since this modified frame
  1786. * is going to go through Linux networking code that may potentially
  1787. * need things like pointer to IP header. */
  1788. skb_set_mac_header(skb, 0);
  1789. skb_set_network_header(skb, nh_pos);
  1790. skb_set_transport_header(skb, h_pos);
  1791. info = IEEE80211_SKB_CB(skb);
  1792. memset(info, 0, sizeof(*info));
  1793. dev->trans_start = jiffies;
  1794. info->flags = info_flags;
  1795. info->ack_frame_id = info_id;
  1796. ieee80211_xmit(sdata, skb);
  1797. return NETDEV_TX_OK;
  1798. fail:
  1799. if (ret == NETDEV_TX_OK)
  1800. dev_kfree_skb(skb);
  1801. return ret;
  1802. }
  1803. /*
  1804. * ieee80211_clear_tx_pending may not be called in a context where
  1805. * it is possible that it packets could come in again.
  1806. */
  1807. void ieee80211_clear_tx_pending(struct ieee80211_local *local)
  1808. {
  1809. int i;
  1810. for (i = 0; i < local->hw.queues; i++)
  1811. skb_queue_purge(&local->pending[i]);
  1812. }
  1813. /*
  1814. * Returns false if the frame couldn't be transmitted but was queued instead,
  1815. * which in this case means re-queued -- take as an indication to stop sending
  1816. * more pending frames.
  1817. */
  1818. static bool ieee80211_tx_pending_skb(struct ieee80211_local *local,
  1819. struct sk_buff *skb)
  1820. {
  1821. struct ieee80211_tx_info *info = IEEE80211_SKB_CB(skb);
  1822. struct ieee80211_sub_if_data *sdata;
  1823. struct sta_info *sta;
  1824. struct ieee80211_hdr *hdr;
  1825. bool result;
  1826. sdata = vif_to_sdata(info->control.vif);
  1827. if (info->flags & IEEE80211_TX_INTFL_NEED_TXPROCESSING) {
  1828. result = ieee80211_tx(sdata, skb, true);
  1829. } else {
  1830. struct sk_buff_head skbs;
  1831. __skb_queue_head_init(&skbs);
  1832. __skb_queue_tail(&skbs, skb);
  1833. hdr = (struct ieee80211_hdr *)skb->data;
  1834. sta = sta_info_get(sdata, hdr->addr1);
  1835. result = __ieee80211_tx(local, &skbs, skb->len, sta, true);
  1836. }
  1837. return result;
  1838. }
  1839. /*
  1840. * Transmit all pending packets. Called from tasklet.
  1841. */
  1842. void ieee80211_tx_pending(unsigned long data)
  1843. {
  1844. struct ieee80211_local *local = (struct ieee80211_local *)data;
  1845. struct ieee80211_sub_if_data *sdata;
  1846. unsigned long flags;
  1847. int i;
  1848. bool txok;
  1849. rcu_read_lock();
  1850. spin_lock_irqsave(&local->queue_stop_reason_lock, flags);
  1851. for (i = 0; i < local->hw.queues; i++) {
  1852. /*
  1853. * If queue is stopped by something other than due to pending
  1854. * frames, or we have no pending frames, proceed to next queue.
  1855. */
  1856. if (local->queue_stop_reasons[i] ||
  1857. skb_queue_empty(&local->pending[i]))
  1858. continue;
  1859. while (!skb_queue_empty(&local->pending[i])) {
  1860. struct sk_buff *skb = __skb_dequeue(&local->pending[i]);
  1861. struct ieee80211_tx_info *info = IEEE80211_SKB_CB(skb);
  1862. if (WARN_ON(!info->control.vif)) {
  1863. kfree_skb(skb);
  1864. continue;
  1865. }
  1866. spin_unlock_irqrestore(&local->queue_stop_reason_lock,
  1867. flags);
  1868. txok = ieee80211_tx_pending_skb(local, skb);
  1869. spin_lock_irqsave(&local->queue_stop_reason_lock,
  1870. flags);
  1871. if (!txok)
  1872. break;
  1873. }
  1874. if (skb_queue_empty(&local->pending[i]))
  1875. list_for_each_entry_rcu(sdata, &local->interfaces, list)
  1876. netif_wake_subqueue(sdata->dev, i);
  1877. }
  1878. spin_unlock_irqrestore(&local->queue_stop_reason_lock, flags);
  1879. rcu_read_unlock();
  1880. }
  1881. /* functions for drivers to get certain frames */
  1882. static void ieee80211_beacon_add_tim(struct ieee80211_if_ap *bss,
  1883. struct sk_buff *skb,
  1884. struct beacon_data *beacon)
  1885. {
  1886. u8 *pos, *tim;
  1887. int aid0 = 0;
  1888. int i, have_bits = 0, n1, n2;
  1889. /* Generate bitmap for TIM only if there are any STAs in power save
  1890. * mode. */
  1891. if (atomic_read(&bss->num_sta_ps) > 0)
  1892. /* in the hope that this is faster than
  1893. * checking byte-for-byte */
  1894. have_bits = !bitmap_empty((unsigned long*)bss->tim,
  1895. IEEE80211_MAX_AID+1);
  1896. if (bss->dtim_count == 0)
  1897. bss->dtim_count = beacon->dtim_period - 1;
  1898. else
  1899. bss->dtim_count--;
  1900. tim = pos = (u8 *) skb_put(skb, 6);
  1901. *pos++ = WLAN_EID_TIM;
  1902. *pos++ = 4;
  1903. *pos++ = bss->dtim_count;
  1904. *pos++ = beacon->dtim_period;
  1905. if (bss->dtim_count == 0 && !skb_queue_empty(&bss->ps_bc_buf))
  1906. aid0 = 1;
  1907. bss->dtim_bc_mc = aid0 == 1;
  1908. if (have_bits) {
  1909. /* Find largest even number N1 so that bits numbered 1 through
  1910. * (N1 x 8) - 1 in the bitmap are 0 and number N2 so that bits
  1911. * (N2 + 1) x 8 through 2007 are 0. */
  1912. n1 = 0;
  1913. for (i = 0; i < IEEE80211_MAX_TIM_LEN; i++) {
  1914. if (bss->tim[i]) {
  1915. n1 = i & 0xfe;
  1916. break;
  1917. }
  1918. }
  1919. n2 = n1;
  1920. for (i = IEEE80211_MAX_TIM_LEN - 1; i >= n1; i--) {
  1921. if (bss->tim[i]) {
  1922. n2 = i;
  1923. break;
  1924. }
  1925. }
  1926. /* Bitmap control */
  1927. *pos++ = n1 | aid0;
  1928. /* Part Virt Bitmap */
  1929. memcpy(pos, bss->tim + n1, n2 - n1 + 1);
  1930. tim[1] = n2 - n1 + 4;
  1931. skb_put(skb, n2 - n1);
  1932. } else {
  1933. *pos++ = aid0; /* Bitmap control */
  1934. *pos++ = 0; /* Part Virt Bitmap */
  1935. }
  1936. }
  1937. struct sk_buff *ieee80211_beacon_get_tim(struct ieee80211_hw *hw,
  1938. struct ieee80211_vif *vif,
  1939. u16 *tim_offset, u16 *tim_length)
  1940. {
  1941. struct ieee80211_local *local = hw_to_local(hw);
  1942. struct sk_buff *skb = NULL;
  1943. struct ieee80211_tx_info *info;
  1944. struct ieee80211_sub_if_data *sdata = NULL;
  1945. struct ieee80211_if_ap *ap = NULL;
  1946. struct beacon_data *beacon;
  1947. struct ieee80211_supported_band *sband;
  1948. enum ieee80211_band band = local->hw.conf.channel->band;
  1949. struct ieee80211_tx_rate_control txrc;
  1950. sband = local->hw.wiphy->bands[band];
  1951. rcu_read_lock();
  1952. sdata = vif_to_sdata(vif);
  1953. if (!ieee80211_sdata_running(sdata))
  1954. goto out;
  1955. if (tim_offset)
  1956. *tim_offset = 0;
  1957. if (tim_length)
  1958. *tim_length = 0;
  1959. if (sdata->vif.type == NL80211_IFTYPE_AP) {
  1960. ap = &sdata->u.ap;
  1961. beacon = rcu_dereference(ap->beacon);
  1962. if (beacon) {
  1963. /*
  1964. * headroom, head length,
  1965. * tail length and maximum TIM length
  1966. */
  1967. skb = dev_alloc_skb(local->tx_headroom +
  1968. beacon->head_len +
  1969. beacon->tail_len + 256);
  1970. if (!skb)
  1971. goto out;
  1972. skb_reserve(skb, local->tx_headroom);
  1973. memcpy(skb_put(skb, beacon->head_len), beacon->head,
  1974. beacon->head_len);
  1975. /*
  1976. * Not very nice, but we want to allow the driver to call
  1977. * ieee80211_beacon_get() as a response to the set_tim()
  1978. * callback. That, however, is already invoked under the
  1979. * sta_lock to guarantee consistent and race-free update
  1980. * of the tim bitmap in mac80211 and the driver.
  1981. */
  1982. if (local->tim_in_locked_section) {
  1983. ieee80211_beacon_add_tim(ap, skb, beacon);
  1984. } else {
  1985. unsigned long flags;
  1986. spin_lock_irqsave(&local->sta_lock, flags);
  1987. ieee80211_beacon_add_tim(ap, skb, beacon);
  1988. spin_unlock_irqrestore(&local->sta_lock, flags);
  1989. }
  1990. if (tim_offset)
  1991. *tim_offset = beacon->head_len;
  1992. if (tim_length)
  1993. *tim_length = skb->len - beacon->head_len;
  1994. if (beacon->tail)
  1995. memcpy(skb_put(skb, beacon->tail_len),
  1996. beacon->tail, beacon->tail_len);
  1997. } else
  1998. goto out;
  1999. } else if (sdata->vif.type == NL80211_IFTYPE_ADHOC) {
  2000. struct ieee80211_if_ibss *ifibss = &sdata->u.ibss;
  2001. struct ieee80211_hdr *hdr;
  2002. struct sk_buff *presp = rcu_dereference(ifibss->presp);
  2003. if (!presp)
  2004. goto out;
  2005. skb = skb_copy(presp, GFP_ATOMIC);
  2006. if (!skb)
  2007. goto out;
  2008. hdr = (struct ieee80211_hdr *) skb->data;
  2009. hdr->frame_control = cpu_to_le16(IEEE80211_FTYPE_MGMT |
  2010. IEEE80211_STYPE_BEACON);
  2011. } else if (ieee80211_vif_is_mesh(&sdata->vif)) {
  2012. struct ieee80211_mgmt *mgmt;
  2013. u8 *pos;
  2014. int hdr_len = offsetof(struct ieee80211_mgmt, u.beacon) +
  2015. sizeof(mgmt->u.beacon);
  2016. #ifdef CONFIG_MAC80211_MESH
  2017. if (!sdata->u.mesh.mesh_id_len)
  2018. goto out;
  2019. #endif
  2020. skb = dev_alloc_skb(local->tx_headroom +
  2021. hdr_len +
  2022. 2 + /* NULL SSID */
  2023. 2 + 8 + /* supported rates */
  2024. 2 + 3 + /* DS params */
  2025. 2 + (IEEE80211_MAX_SUPP_RATES - 8) +
  2026. 2 + sizeof(struct ieee80211_ht_cap) +
  2027. 2 + sizeof(struct ieee80211_ht_info) +
  2028. 2 + sdata->u.mesh.mesh_id_len +
  2029. 2 + sizeof(struct ieee80211_meshconf_ie) +
  2030. sdata->u.mesh.ie_len);
  2031. if (!skb)
  2032. goto out;
  2033. skb_reserve(skb, local->hw.extra_tx_headroom);
  2034. mgmt = (struct ieee80211_mgmt *) skb_put(skb, hdr_len);
  2035. memset(mgmt, 0, hdr_len);
  2036. mgmt->frame_control =
  2037. cpu_to_le16(IEEE80211_FTYPE_MGMT | IEEE80211_STYPE_BEACON);
  2038. memset(mgmt->da, 0xff, ETH_ALEN);
  2039. memcpy(mgmt->sa, sdata->vif.addr, ETH_ALEN);
  2040. memcpy(mgmt->bssid, sdata->vif.addr, ETH_ALEN);
  2041. mgmt->u.beacon.beacon_int =
  2042. cpu_to_le16(sdata->vif.bss_conf.beacon_int);
  2043. mgmt->u.beacon.capab_info |= cpu_to_le16(
  2044. sdata->u.mesh.security ? WLAN_CAPABILITY_PRIVACY : 0);
  2045. pos = skb_put(skb, 2);
  2046. *pos++ = WLAN_EID_SSID;
  2047. *pos++ = 0x0;
  2048. if (ieee80211_add_srates_ie(&sdata->vif, skb) ||
  2049. mesh_add_ds_params_ie(skb, sdata) ||
  2050. ieee80211_add_ext_srates_ie(&sdata->vif, skb) ||
  2051. mesh_add_rsn_ie(skb, sdata) ||
  2052. mesh_add_ht_cap_ie(skb, sdata) ||
  2053. mesh_add_ht_info_ie(skb, sdata) ||
  2054. mesh_add_meshid_ie(skb, sdata) ||
  2055. mesh_add_meshconf_ie(skb, sdata) ||
  2056. mesh_add_vendor_ies(skb, sdata)) {
  2057. pr_err("o11s: couldn't add ies!\n");
  2058. goto out;
  2059. }
  2060. } else {
  2061. WARN_ON(1);
  2062. goto out;
  2063. }
  2064. info = IEEE80211_SKB_CB(skb);
  2065. info->flags |= IEEE80211_TX_INTFL_DONT_ENCRYPT;
  2066. info->flags |= IEEE80211_TX_CTL_NO_ACK;
  2067. info->band = band;
  2068. memset(&txrc, 0, sizeof(txrc));
  2069. txrc.hw = hw;
  2070. txrc.sband = sband;
  2071. txrc.bss_conf = &sdata->vif.bss_conf;
  2072. txrc.skb = skb;
  2073. txrc.reported_rate.idx = -1;
  2074. txrc.rate_idx_mask = sdata->rc_rateidx_mask[band];
  2075. if (txrc.rate_idx_mask == (1 << sband->n_bitrates) - 1)
  2076. txrc.max_rate_idx = -1;
  2077. else
  2078. txrc.max_rate_idx = fls(txrc.rate_idx_mask) - 1;
  2079. txrc.bss = true;
  2080. rate_control_get_rate(sdata, NULL, &txrc);
  2081. info->control.vif = vif;
  2082. info->flags |= IEEE80211_TX_CTL_CLEAR_PS_FILT |
  2083. IEEE80211_TX_CTL_ASSIGN_SEQ |
  2084. IEEE80211_TX_CTL_FIRST_FRAGMENT;
  2085. out:
  2086. rcu_read_unlock();
  2087. return skb;
  2088. }
  2089. EXPORT_SYMBOL(ieee80211_beacon_get_tim);
  2090. struct sk_buff *ieee80211_proberesp_get(struct ieee80211_hw *hw,
  2091. struct ieee80211_vif *vif)
  2092. {
  2093. struct ieee80211_if_ap *ap = NULL;
  2094. struct sk_buff *presp = NULL, *skb = NULL;
  2095. struct ieee80211_hdr *hdr;
  2096. struct ieee80211_sub_if_data *sdata = vif_to_sdata(vif);
  2097. if (sdata->vif.type != NL80211_IFTYPE_AP)
  2098. return NULL;
  2099. rcu_read_lock();
  2100. ap = &sdata->u.ap;
  2101. presp = rcu_dereference(ap->probe_resp);
  2102. if (!presp)
  2103. goto out;
  2104. skb = skb_copy(presp, GFP_ATOMIC);
  2105. if (!skb)
  2106. goto out;
  2107. hdr = (struct ieee80211_hdr *) skb->data;
  2108. memset(hdr->addr1, 0, sizeof(hdr->addr1));
  2109. out:
  2110. rcu_read_unlock();
  2111. return skb;
  2112. }
  2113. EXPORT_SYMBOL(ieee80211_proberesp_get);
  2114. struct sk_buff *ieee80211_pspoll_get(struct ieee80211_hw *hw,
  2115. struct ieee80211_vif *vif)
  2116. {
  2117. struct ieee80211_sub_if_data *sdata;
  2118. struct ieee80211_if_managed *ifmgd;
  2119. struct ieee80211_pspoll *pspoll;
  2120. struct ieee80211_local *local;
  2121. struct sk_buff *skb;
  2122. if (WARN_ON(vif->type != NL80211_IFTYPE_STATION))
  2123. return NULL;
  2124. sdata = vif_to_sdata(vif);
  2125. ifmgd = &sdata->u.mgd;
  2126. local = sdata->local;
  2127. skb = dev_alloc_skb(local->hw.extra_tx_headroom + sizeof(*pspoll));
  2128. if (!skb)
  2129. return NULL;
  2130. skb_reserve(skb, local->hw.extra_tx_headroom);
  2131. pspoll = (struct ieee80211_pspoll *) skb_put(skb, sizeof(*pspoll));
  2132. memset(pspoll, 0, sizeof(*pspoll));
  2133. pspoll->frame_control = cpu_to_le16(IEEE80211_FTYPE_CTL |
  2134. IEEE80211_STYPE_PSPOLL);
  2135. pspoll->aid = cpu_to_le16(ifmgd->aid);
  2136. /* aid in PS-Poll has its two MSBs each set to 1 */
  2137. pspoll->aid |= cpu_to_le16(1 << 15 | 1 << 14);
  2138. memcpy(pspoll->bssid, ifmgd->bssid, ETH_ALEN);
  2139. memcpy(pspoll->ta, vif->addr, ETH_ALEN);
  2140. return skb;
  2141. }
  2142. EXPORT_SYMBOL(ieee80211_pspoll_get);
  2143. struct sk_buff *ieee80211_nullfunc_get(struct ieee80211_hw *hw,
  2144. struct ieee80211_vif *vif)
  2145. {
  2146. struct ieee80211_hdr_3addr *nullfunc;
  2147. struct ieee80211_sub_if_data *sdata;
  2148. struct ieee80211_if_managed *ifmgd;
  2149. struct ieee80211_local *local;
  2150. struct sk_buff *skb;
  2151. if (WARN_ON(vif->type != NL80211_IFTYPE_STATION))
  2152. return NULL;
  2153. sdata = vif_to_sdata(vif);
  2154. ifmgd = &sdata->u.mgd;
  2155. local = sdata->local;
  2156. skb = dev_alloc_skb(local->hw.extra_tx_headroom + sizeof(*nullfunc));
  2157. if (!skb)
  2158. return NULL;
  2159. skb_reserve(skb, local->hw.extra_tx_headroom);
  2160. nullfunc = (struct ieee80211_hdr_3addr *) skb_put(skb,
  2161. sizeof(*nullfunc));
  2162. memset(nullfunc, 0, sizeof(*nullfunc));
  2163. nullfunc->frame_control = cpu_to_le16(IEEE80211_FTYPE_DATA |
  2164. IEEE80211_STYPE_NULLFUNC |
  2165. IEEE80211_FCTL_TODS);
  2166. memcpy(nullfunc->addr1, ifmgd->bssid, ETH_ALEN);
  2167. memcpy(nullfunc->addr2, vif->addr, ETH_ALEN);
  2168. memcpy(nullfunc->addr3, ifmgd->bssid, ETH_ALEN);
  2169. return skb;
  2170. }
  2171. EXPORT_SYMBOL(ieee80211_nullfunc_get);
  2172. struct sk_buff *ieee80211_probereq_get(struct ieee80211_hw *hw,
  2173. struct ieee80211_vif *vif,
  2174. const u8 *ssid, size_t ssid_len,
  2175. const u8 *ie, size_t ie_len)
  2176. {
  2177. struct ieee80211_sub_if_data *sdata;
  2178. struct ieee80211_local *local;
  2179. struct ieee80211_hdr_3addr *hdr;
  2180. struct sk_buff *skb;
  2181. size_t ie_ssid_len;
  2182. u8 *pos;
  2183. sdata = vif_to_sdata(vif);
  2184. local = sdata->local;
  2185. ie_ssid_len = 2 + ssid_len;
  2186. skb = dev_alloc_skb(local->hw.extra_tx_headroom + sizeof(*hdr) +
  2187. ie_ssid_len + ie_len);
  2188. if (!skb)
  2189. return NULL;
  2190. skb_reserve(skb, local->hw.extra_tx_headroom);
  2191. hdr = (struct ieee80211_hdr_3addr *) skb_put(skb, sizeof(*hdr));
  2192. memset(hdr, 0, sizeof(*hdr));
  2193. hdr->frame_control = cpu_to_le16(IEEE80211_FTYPE_MGMT |
  2194. IEEE80211_STYPE_PROBE_REQ);
  2195. memset(hdr->addr1, 0xff, ETH_ALEN);
  2196. memcpy(hdr->addr2, vif->addr, ETH_ALEN);
  2197. memset(hdr->addr3, 0xff, ETH_ALEN);
  2198. pos = skb_put(skb, ie_ssid_len);
  2199. *pos++ = WLAN_EID_SSID;
  2200. *pos++ = ssid_len;
  2201. if (ssid)
  2202. memcpy(pos, ssid, ssid_len);
  2203. pos += ssid_len;
  2204. if (ie) {
  2205. pos = skb_put(skb, ie_len);
  2206. memcpy(pos, ie, ie_len);
  2207. }
  2208. return skb;
  2209. }
  2210. EXPORT_SYMBOL(ieee80211_probereq_get);
  2211. void ieee80211_rts_get(struct ieee80211_hw *hw, struct ieee80211_vif *vif,
  2212. const void *frame, size_t frame_len,
  2213. const struct ieee80211_tx_info *frame_txctl,
  2214. struct ieee80211_rts *rts)
  2215. {
  2216. const struct ieee80211_hdr *hdr = frame;
  2217. rts->frame_control =
  2218. cpu_to_le16(IEEE80211_FTYPE_CTL | IEEE80211_STYPE_RTS);
  2219. rts->duration = ieee80211_rts_duration(hw, vif, frame_len,
  2220. frame_txctl);
  2221. memcpy(rts->ra, hdr->addr1, sizeof(rts->ra));
  2222. memcpy(rts->ta, hdr->addr2, sizeof(rts->ta));
  2223. }
  2224. EXPORT_SYMBOL(ieee80211_rts_get);
  2225. void ieee80211_ctstoself_get(struct ieee80211_hw *hw, struct ieee80211_vif *vif,
  2226. const void *frame, size_t frame_len,
  2227. const struct ieee80211_tx_info *frame_txctl,
  2228. struct ieee80211_cts *cts)
  2229. {
  2230. const struct ieee80211_hdr *hdr = frame;
  2231. cts->frame_control =
  2232. cpu_to_le16(IEEE80211_FTYPE_CTL | IEEE80211_STYPE_CTS);
  2233. cts->duration = ieee80211_ctstoself_duration(hw, vif,
  2234. frame_len, frame_txctl);
  2235. memcpy(cts->ra, hdr->addr1, sizeof(cts->ra));
  2236. }
  2237. EXPORT_SYMBOL(ieee80211_ctstoself_get);
  2238. struct sk_buff *
  2239. ieee80211_get_buffered_bc(struct ieee80211_hw *hw,
  2240. struct ieee80211_vif *vif)
  2241. {
  2242. struct ieee80211_local *local = hw_to_local(hw);
  2243. struct sk_buff *skb = NULL;
  2244. struct ieee80211_tx_data tx;
  2245. struct ieee80211_sub_if_data *sdata;
  2246. struct ieee80211_if_ap *bss = NULL;
  2247. struct beacon_data *beacon;
  2248. struct ieee80211_tx_info *info;
  2249. sdata = vif_to_sdata(vif);
  2250. bss = &sdata->u.ap;
  2251. rcu_read_lock();
  2252. beacon = rcu_dereference(bss->beacon);
  2253. if (sdata->vif.type != NL80211_IFTYPE_AP || !beacon || !beacon->head)
  2254. goto out;
  2255. if (bss->dtim_count != 0 || !bss->dtim_bc_mc)
  2256. goto out; /* send buffered bc/mc only after DTIM beacon */
  2257. while (1) {
  2258. skb = skb_dequeue(&bss->ps_bc_buf);
  2259. if (!skb)
  2260. goto out;
  2261. local->total_ps_buffered--;
  2262. if (!skb_queue_empty(&bss->ps_bc_buf) && skb->len >= 2) {
  2263. struct ieee80211_hdr *hdr =
  2264. (struct ieee80211_hdr *) skb->data;
  2265. /* more buffered multicast/broadcast frames ==> set
  2266. * MoreData flag in IEEE 802.11 header to inform PS
  2267. * STAs */
  2268. hdr->frame_control |=
  2269. cpu_to_le16(IEEE80211_FCTL_MOREDATA);
  2270. }
  2271. if (!ieee80211_tx_prepare(sdata, &tx, skb))
  2272. break;
  2273. dev_kfree_skb_any(skb);
  2274. }
  2275. info = IEEE80211_SKB_CB(skb);
  2276. tx.flags |= IEEE80211_TX_PS_BUFFERED;
  2277. tx.channel = local->hw.conf.channel;
  2278. info->band = tx.channel->band;
  2279. if (invoke_tx_handlers(&tx))
  2280. skb = NULL;
  2281. out:
  2282. rcu_read_unlock();
  2283. return skb;
  2284. }
  2285. EXPORT_SYMBOL(ieee80211_get_buffered_bc);
  2286. void ieee80211_tx_skb(struct ieee80211_sub_if_data *sdata, struct sk_buff *skb)
  2287. {
  2288. skb_set_mac_header(skb, 0);
  2289. skb_set_network_header(skb, 0);
  2290. skb_set_transport_header(skb, 0);
  2291. /* Send all internal mgmt frames on VO. Accordingly set TID to 7. */
  2292. skb_set_queue_mapping(skb, IEEE80211_AC_VO);
  2293. skb->priority = 7;
  2294. /*
  2295. * The other path calling ieee80211_xmit is from the tasklet,
  2296. * and while we can handle concurrent transmissions locking
  2297. * requirements are that we do not come into tx with bhs on.
  2298. */
  2299. local_bh_disable();
  2300. ieee80211_xmit(sdata, skb);
  2301. local_bh_enable();
  2302. }