tx.c 75 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360236123622363236423652366236723682369237023712372237323742375237623772378237923802381238223832384238523862387238823892390239123922393239423952396239723982399240024012402240324042405240624072408240924102411241224132414241524162417241824192420242124222423242424252426242724282429243024312432243324342435243624372438243924402441244224432444244524462447244824492450245124522453245424552456245724582459246024612462246324642465246624672468246924702471247224732474247524762477247824792480248124822483248424852486248724882489249024912492249324942495249624972498249925002501250225032504250525062507250825092510251125122513251425152516251725182519252025212522252325242525252625272528252925302531253225332534253525362537253825392540254125422543254425452546254725482549255025512552255325542555255625572558255925602561256225632564256525662567256825692570257125722573257425752576257725782579258025812582258325842585258625872588258925902591259225932594259525962597259825992600260126022603260426052606260726082609261026112612261326142615261626172618261926202621262226232624262526262627262826292630263126322633263426352636263726382639264026412642264326442645264626472648264926502651265226532654265526562657265826592660266126622663266426652666266726682669267026712672267326742675267626772678267926802681268226832684268526862687268826892690269126922693269426952696269726982699270027012702270327042705270627072708270927102711271227132714271527162717
  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_init(skbs, &local->pending[q]);
  1042. else
  1043. skb_queue_splice_tail_init(skbs,
  1044. &local->pending[q]);
  1045. spin_unlock_irqrestore(&local->queue_stop_reason_lock,
  1046. flags);
  1047. return false;
  1048. }
  1049. spin_unlock_irqrestore(&local->queue_stop_reason_lock, flags);
  1050. info = IEEE80211_SKB_CB(skb);
  1051. info->control.vif = vif;
  1052. info->control.sta = sta;
  1053. __skb_unlink(skb, skbs);
  1054. drv_tx(local, skb);
  1055. }
  1056. return true;
  1057. }
  1058. /*
  1059. * Returns false if the frame couldn't be transmitted but was queued instead.
  1060. */
  1061. static bool __ieee80211_tx(struct ieee80211_local *local,
  1062. struct sk_buff_head *skbs, int led_len,
  1063. struct sta_info *sta, bool txpending)
  1064. {
  1065. struct ieee80211_tx_info *info;
  1066. struct ieee80211_sub_if_data *sdata;
  1067. struct ieee80211_vif *vif;
  1068. struct ieee80211_sta *pubsta;
  1069. struct sk_buff *skb;
  1070. bool result = true;
  1071. __le16 fc;
  1072. if (WARN_ON(skb_queue_empty(skbs)))
  1073. return true;
  1074. skb = skb_peek(skbs);
  1075. fc = ((struct ieee80211_hdr *)skb->data)->frame_control;
  1076. info = IEEE80211_SKB_CB(skb);
  1077. sdata = vif_to_sdata(info->control.vif);
  1078. if (sta && !sta->uploaded)
  1079. sta = NULL;
  1080. if (sta)
  1081. pubsta = &sta->sta;
  1082. else
  1083. pubsta = NULL;
  1084. switch (sdata->vif.type) {
  1085. case NL80211_IFTYPE_MONITOR:
  1086. sdata = NULL;
  1087. vif = NULL;
  1088. break;
  1089. case NL80211_IFTYPE_AP_VLAN:
  1090. sdata = container_of(sdata->bss,
  1091. struct ieee80211_sub_if_data, u.ap);
  1092. /* fall through */
  1093. default:
  1094. vif = &sdata->vif;
  1095. break;
  1096. }
  1097. if (local->ops->tx_frags)
  1098. drv_tx_frags(local, vif, pubsta, skbs);
  1099. else
  1100. result = ieee80211_tx_frags(local, vif, pubsta, skbs,
  1101. txpending);
  1102. ieee80211_tpt_led_trig_tx(local, fc, led_len);
  1103. ieee80211_led_tx(local, 1);
  1104. WARN_ON_ONCE(!skb_queue_empty(skbs));
  1105. return result;
  1106. }
  1107. /*
  1108. * Invoke TX handlers, return 0 on success and non-zero if the
  1109. * frame was dropped or queued.
  1110. */
  1111. static int invoke_tx_handlers(struct ieee80211_tx_data *tx)
  1112. {
  1113. struct ieee80211_tx_info *info = IEEE80211_SKB_CB(tx->skb);
  1114. ieee80211_tx_result res = TX_DROP;
  1115. #define CALL_TXH(txh) \
  1116. do { \
  1117. res = txh(tx); \
  1118. if (res != TX_CONTINUE) \
  1119. goto txh_done; \
  1120. } while (0)
  1121. CALL_TXH(ieee80211_tx_h_dynamic_ps);
  1122. CALL_TXH(ieee80211_tx_h_check_assoc);
  1123. CALL_TXH(ieee80211_tx_h_ps_buf);
  1124. CALL_TXH(ieee80211_tx_h_check_control_port_protocol);
  1125. CALL_TXH(ieee80211_tx_h_select_key);
  1126. if (!(tx->local->hw.flags & IEEE80211_HW_HAS_RATE_CONTROL))
  1127. CALL_TXH(ieee80211_tx_h_rate_ctrl);
  1128. if (unlikely(info->flags & IEEE80211_TX_INTFL_RETRANSMISSION))
  1129. goto txh_done;
  1130. CALL_TXH(ieee80211_tx_h_michael_mic_add);
  1131. CALL_TXH(ieee80211_tx_h_sequence);
  1132. CALL_TXH(ieee80211_tx_h_fragment);
  1133. /* handlers after fragment must be aware of tx info fragmentation! */
  1134. CALL_TXH(ieee80211_tx_h_stats);
  1135. CALL_TXH(ieee80211_tx_h_encrypt);
  1136. if (!(tx->local->hw.flags & IEEE80211_HW_HAS_RATE_CONTROL))
  1137. CALL_TXH(ieee80211_tx_h_calculate_duration);
  1138. #undef CALL_TXH
  1139. txh_done:
  1140. if (unlikely(res == TX_DROP)) {
  1141. I802_DEBUG_INC(tx->local->tx_handlers_drop);
  1142. if (tx->skb)
  1143. dev_kfree_skb(tx->skb);
  1144. else
  1145. __skb_queue_purge(&tx->skbs);
  1146. return -1;
  1147. } else if (unlikely(res == TX_QUEUED)) {
  1148. I802_DEBUG_INC(tx->local->tx_handlers_queued);
  1149. return -1;
  1150. }
  1151. return 0;
  1152. }
  1153. /*
  1154. * Returns false if the frame couldn't be transmitted but was queued instead.
  1155. */
  1156. static bool ieee80211_tx(struct ieee80211_sub_if_data *sdata,
  1157. struct sk_buff *skb, bool txpending)
  1158. {
  1159. struct ieee80211_local *local = sdata->local;
  1160. struct ieee80211_tx_data tx;
  1161. ieee80211_tx_result res_prepare;
  1162. struct ieee80211_tx_info *info = IEEE80211_SKB_CB(skb);
  1163. bool result = true;
  1164. int led_len;
  1165. if (unlikely(skb->len < 10)) {
  1166. dev_kfree_skb(skb);
  1167. return true;
  1168. }
  1169. rcu_read_lock();
  1170. /* initialises tx */
  1171. led_len = skb->len;
  1172. res_prepare = ieee80211_tx_prepare(sdata, &tx, skb);
  1173. if (unlikely(res_prepare == TX_DROP)) {
  1174. dev_kfree_skb(skb);
  1175. goto out;
  1176. } else if (unlikely(res_prepare == TX_QUEUED)) {
  1177. goto out;
  1178. }
  1179. tx.channel = local->hw.conf.channel;
  1180. info->band = tx.channel->band;
  1181. if (!invoke_tx_handlers(&tx))
  1182. result = __ieee80211_tx(local, &tx.skbs, led_len,
  1183. tx.sta, txpending);
  1184. out:
  1185. rcu_read_unlock();
  1186. return result;
  1187. }
  1188. /* device xmit handlers */
  1189. static int ieee80211_skb_resize(struct ieee80211_sub_if_data *sdata,
  1190. struct sk_buff *skb,
  1191. int head_need, bool may_encrypt)
  1192. {
  1193. struct ieee80211_local *local = sdata->local;
  1194. int tail_need = 0;
  1195. if (may_encrypt && sdata->crypto_tx_tailroom_needed_cnt) {
  1196. tail_need = IEEE80211_ENCRYPT_TAILROOM;
  1197. tail_need -= skb_tailroom(skb);
  1198. tail_need = max_t(int, tail_need, 0);
  1199. }
  1200. if (skb_cloned(skb))
  1201. I802_DEBUG_INC(local->tx_expand_skb_head_cloned);
  1202. else if (head_need || tail_need)
  1203. I802_DEBUG_INC(local->tx_expand_skb_head);
  1204. else
  1205. return 0;
  1206. if (pskb_expand_head(skb, head_need, tail_need, GFP_ATOMIC)) {
  1207. wiphy_debug(local->hw.wiphy,
  1208. "failed to reallocate TX buffer\n");
  1209. return -ENOMEM;
  1210. }
  1211. return 0;
  1212. }
  1213. void ieee80211_xmit(struct ieee80211_sub_if_data *sdata, struct sk_buff *skb)
  1214. {
  1215. struct ieee80211_local *local = sdata->local;
  1216. struct ieee80211_tx_info *info = IEEE80211_SKB_CB(skb);
  1217. struct ieee80211_hdr *hdr = (struct ieee80211_hdr *) skb->data;
  1218. int headroom;
  1219. bool may_encrypt;
  1220. rcu_read_lock();
  1221. may_encrypt = !(info->flags & IEEE80211_TX_INTFL_DONT_ENCRYPT);
  1222. headroom = local->tx_headroom;
  1223. if (may_encrypt)
  1224. headroom += IEEE80211_ENCRYPT_HEADROOM;
  1225. headroom -= skb_headroom(skb);
  1226. headroom = max_t(int, 0, headroom);
  1227. if (ieee80211_skb_resize(sdata, skb, headroom, may_encrypt)) {
  1228. dev_kfree_skb(skb);
  1229. rcu_read_unlock();
  1230. return;
  1231. }
  1232. hdr = (struct ieee80211_hdr *) skb->data;
  1233. info->control.vif = &sdata->vif;
  1234. if (ieee80211_vif_is_mesh(&sdata->vif) &&
  1235. ieee80211_is_data(hdr->frame_control) &&
  1236. !is_multicast_ether_addr(hdr->addr1))
  1237. if (mesh_nexthop_lookup(skb, sdata)) {
  1238. /* skb queued: don't free */
  1239. rcu_read_unlock();
  1240. return;
  1241. }
  1242. ieee80211_set_qos_hdr(sdata, skb);
  1243. ieee80211_tx(sdata, skb, false);
  1244. rcu_read_unlock();
  1245. }
  1246. static bool ieee80211_parse_tx_radiotap(struct sk_buff *skb)
  1247. {
  1248. struct ieee80211_radiotap_iterator iterator;
  1249. struct ieee80211_radiotap_header *rthdr =
  1250. (struct ieee80211_radiotap_header *) skb->data;
  1251. struct ieee80211_tx_info *info = IEEE80211_SKB_CB(skb);
  1252. int ret = ieee80211_radiotap_iterator_init(&iterator, rthdr, skb->len,
  1253. NULL);
  1254. u16 txflags;
  1255. info->flags |= IEEE80211_TX_INTFL_DONT_ENCRYPT |
  1256. IEEE80211_TX_CTL_DONTFRAG;
  1257. /*
  1258. * for every radiotap entry that is present
  1259. * (ieee80211_radiotap_iterator_next returns -ENOENT when no more
  1260. * entries present, or -EINVAL on error)
  1261. */
  1262. while (!ret) {
  1263. ret = ieee80211_radiotap_iterator_next(&iterator);
  1264. if (ret)
  1265. continue;
  1266. /* see if this argument is something we can use */
  1267. switch (iterator.this_arg_index) {
  1268. /*
  1269. * You must take care when dereferencing iterator.this_arg
  1270. * for multibyte types... the pointer is not aligned. Use
  1271. * get_unaligned((type *)iterator.this_arg) to dereference
  1272. * iterator.this_arg for type "type" safely on all arches.
  1273. */
  1274. case IEEE80211_RADIOTAP_FLAGS:
  1275. if (*iterator.this_arg & IEEE80211_RADIOTAP_F_FCS) {
  1276. /*
  1277. * this indicates that the skb we have been
  1278. * handed has the 32-bit FCS CRC at the end...
  1279. * we should react to that by snipping it off
  1280. * because it will be recomputed and added
  1281. * on transmission
  1282. */
  1283. if (skb->len < (iterator._max_length + FCS_LEN))
  1284. return false;
  1285. skb_trim(skb, skb->len - FCS_LEN);
  1286. }
  1287. if (*iterator.this_arg & IEEE80211_RADIOTAP_F_WEP)
  1288. info->flags &= ~IEEE80211_TX_INTFL_DONT_ENCRYPT;
  1289. if (*iterator.this_arg & IEEE80211_RADIOTAP_F_FRAG)
  1290. info->flags &= ~IEEE80211_TX_CTL_DONTFRAG;
  1291. break;
  1292. case IEEE80211_RADIOTAP_TX_FLAGS:
  1293. txflags = get_unaligned_le16(iterator.this_arg);
  1294. if (txflags & IEEE80211_RADIOTAP_F_TX_NOACK)
  1295. info->flags |= IEEE80211_TX_CTL_NO_ACK;
  1296. break;
  1297. /*
  1298. * Please update the file
  1299. * Documentation/networking/mac80211-injection.txt
  1300. * when parsing new fields here.
  1301. */
  1302. default:
  1303. break;
  1304. }
  1305. }
  1306. if (ret != -ENOENT) /* ie, if we didn't simply run out of fields */
  1307. return false;
  1308. /*
  1309. * remove the radiotap header
  1310. * iterator->_max_length was sanity-checked against
  1311. * skb->len by iterator init
  1312. */
  1313. skb_pull(skb, iterator._max_length);
  1314. return true;
  1315. }
  1316. netdev_tx_t ieee80211_monitor_start_xmit(struct sk_buff *skb,
  1317. struct net_device *dev)
  1318. {
  1319. struct ieee80211_local *local = wdev_priv(dev->ieee80211_ptr);
  1320. struct ieee80211_channel *chan = local->hw.conf.channel;
  1321. struct ieee80211_radiotap_header *prthdr =
  1322. (struct ieee80211_radiotap_header *)skb->data;
  1323. struct ieee80211_tx_info *info = IEEE80211_SKB_CB(skb);
  1324. struct ieee80211_hdr *hdr;
  1325. struct ieee80211_sub_if_data *tmp_sdata, *sdata;
  1326. u16 len_rthdr;
  1327. int hdrlen;
  1328. /*
  1329. * Frame injection is not allowed if beaconing is not allowed
  1330. * or if we need radar detection. Beaconing is usually not allowed when
  1331. * the mode or operation (Adhoc, AP, Mesh) does not support DFS.
  1332. * Passive scan is also used in world regulatory domains where
  1333. * your country is not known and as such it should be treated as
  1334. * NO TX unless the channel is explicitly allowed in which case
  1335. * your current regulatory domain would not have the passive scan
  1336. * flag.
  1337. *
  1338. * Since AP mode uses monitor interfaces to inject/TX management
  1339. * frames we can make AP mode the exception to this rule once it
  1340. * supports radar detection as its implementation can deal with
  1341. * radar detection by itself. We can do that later by adding a
  1342. * monitor flag interfaces used for AP support.
  1343. */
  1344. if ((chan->flags & (IEEE80211_CHAN_NO_IBSS | IEEE80211_CHAN_RADAR |
  1345. IEEE80211_CHAN_PASSIVE_SCAN)))
  1346. goto fail;
  1347. /* check for not even having the fixed radiotap header part */
  1348. if (unlikely(skb->len < sizeof(struct ieee80211_radiotap_header)))
  1349. goto fail; /* too short to be possibly valid */
  1350. /* is it a header version we can trust to find length from? */
  1351. if (unlikely(prthdr->it_version))
  1352. goto fail; /* only version 0 is supported */
  1353. /* then there must be a radiotap header with a length we can use */
  1354. len_rthdr = ieee80211_get_radiotap_len(skb->data);
  1355. /* does the skb contain enough to deliver on the alleged length? */
  1356. if (unlikely(skb->len < len_rthdr))
  1357. goto fail; /* skb too short for claimed rt header extent */
  1358. /*
  1359. * fix up the pointers accounting for the radiotap
  1360. * header still being in there. We are being given
  1361. * a precooked IEEE80211 header so no need for
  1362. * normal processing
  1363. */
  1364. skb_set_mac_header(skb, len_rthdr);
  1365. /*
  1366. * these are just fixed to the end of the rt area since we
  1367. * don't have any better information and at this point, nobody cares
  1368. */
  1369. skb_set_network_header(skb, len_rthdr);
  1370. skb_set_transport_header(skb, len_rthdr);
  1371. if (skb->len < len_rthdr + 2)
  1372. goto fail;
  1373. hdr = (struct ieee80211_hdr *)(skb->data + len_rthdr);
  1374. hdrlen = ieee80211_hdrlen(hdr->frame_control);
  1375. if (skb->len < len_rthdr + hdrlen)
  1376. goto fail;
  1377. /*
  1378. * Initialize skb->protocol if the injected frame is a data frame
  1379. * carrying a rfc1042 header
  1380. */
  1381. if (ieee80211_is_data(hdr->frame_control) &&
  1382. skb->len >= len_rthdr + hdrlen + sizeof(rfc1042_header) + 2) {
  1383. u8 *payload = (u8 *)hdr + hdrlen;
  1384. if (compare_ether_addr(payload, rfc1042_header) == 0)
  1385. skb->protocol = cpu_to_be16((payload[6] << 8) |
  1386. payload[7]);
  1387. }
  1388. memset(info, 0, sizeof(*info));
  1389. info->flags = IEEE80211_TX_CTL_REQ_TX_STATUS |
  1390. IEEE80211_TX_CTL_INJECTED;
  1391. /* process and remove the injection radiotap header */
  1392. if (!ieee80211_parse_tx_radiotap(skb))
  1393. goto fail;
  1394. rcu_read_lock();
  1395. /*
  1396. * We process outgoing injected frames that have a local address
  1397. * we handle as though they are non-injected frames.
  1398. * This code here isn't entirely correct, the local MAC address
  1399. * isn't always enough to find the interface to use; for proper
  1400. * VLAN/WDS support we will need a different mechanism (which
  1401. * likely isn't going to be monitor interfaces).
  1402. */
  1403. sdata = IEEE80211_DEV_TO_SUB_IF(dev);
  1404. list_for_each_entry_rcu(tmp_sdata, &local->interfaces, list) {
  1405. if (!ieee80211_sdata_running(tmp_sdata))
  1406. continue;
  1407. if (tmp_sdata->vif.type == NL80211_IFTYPE_MONITOR ||
  1408. tmp_sdata->vif.type == NL80211_IFTYPE_AP_VLAN ||
  1409. tmp_sdata->vif.type == NL80211_IFTYPE_WDS)
  1410. continue;
  1411. if (compare_ether_addr(tmp_sdata->vif.addr, hdr->addr2) == 0) {
  1412. sdata = tmp_sdata;
  1413. break;
  1414. }
  1415. }
  1416. ieee80211_xmit(sdata, skb);
  1417. rcu_read_unlock();
  1418. return NETDEV_TX_OK;
  1419. fail:
  1420. dev_kfree_skb(skb);
  1421. return NETDEV_TX_OK; /* meaning, we dealt with the skb */
  1422. }
  1423. /**
  1424. * ieee80211_subif_start_xmit - netif start_xmit function for Ethernet-type
  1425. * subinterfaces (wlan#, WDS, and VLAN interfaces)
  1426. * @skb: packet to be sent
  1427. * @dev: incoming interface
  1428. *
  1429. * Returns: 0 on success (and frees skb in this case) or 1 on failure (skb will
  1430. * not be freed, and caller is responsible for either retrying later or freeing
  1431. * skb).
  1432. *
  1433. * This function takes in an Ethernet header and encapsulates it with suitable
  1434. * IEEE 802.11 header based on which interface the packet is coming in. The
  1435. * encapsulated packet will then be passed to master interface, wlan#.11, for
  1436. * transmission (through low-level driver).
  1437. */
  1438. netdev_tx_t ieee80211_subif_start_xmit(struct sk_buff *skb,
  1439. struct net_device *dev)
  1440. {
  1441. struct ieee80211_sub_if_data *sdata = IEEE80211_DEV_TO_SUB_IF(dev);
  1442. struct ieee80211_local *local = sdata->local;
  1443. struct ieee80211_tx_info *info;
  1444. int ret = NETDEV_TX_BUSY, head_need;
  1445. u16 ethertype, hdrlen, meshhdrlen = 0;
  1446. __le16 fc;
  1447. struct ieee80211_hdr hdr;
  1448. struct ieee80211s_hdr mesh_hdr __maybe_unused;
  1449. struct mesh_path __maybe_unused *mppath = NULL;
  1450. const u8 *encaps_data;
  1451. int encaps_len, skip_header_bytes;
  1452. int nh_pos, h_pos;
  1453. struct sta_info *sta = NULL;
  1454. bool wme_sta = false, authorized = false, tdls_auth = false;
  1455. bool tdls_direct = false;
  1456. bool multicast;
  1457. u32 info_flags = 0;
  1458. u16 info_id = 0;
  1459. if (unlikely(skb->len < ETH_HLEN)) {
  1460. ret = NETDEV_TX_OK;
  1461. goto fail;
  1462. }
  1463. /* convert Ethernet header to proper 802.11 header (based on
  1464. * operation mode) */
  1465. ethertype = (skb->data[12] << 8) | skb->data[13];
  1466. fc = cpu_to_le16(IEEE80211_FTYPE_DATA | IEEE80211_STYPE_DATA);
  1467. switch (sdata->vif.type) {
  1468. case NL80211_IFTYPE_AP_VLAN:
  1469. rcu_read_lock();
  1470. sta = rcu_dereference(sdata->u.vlan.sta);
  1471. if (sta) {
  1472. fc |= cpu_to_le16(IEEE80211_FCTL_FROMDS | IEEE80211_FCTL_TODS);
  1473. /* RA TA DA SA */
  1474. memcpy(hdr.addr1, sta->sta.addr, ETH_ALEN);
  1475. memcpy(hdr.addr2, sdata->vif.addr, ETH_ALEN);
  1476. memcpy(hdr.addr3, skb->data, ETH_ALEN);
  1477. memcpy(hdr.addr4, skb->data + ETH_ALEN, ETH_ALEN);
  1478. hdrlen = 30;
  1479. authorized = test_sta_flag(sta, WLAN_STA_AUTHORIZED);
  1480. wme_sta = test_sta_flag(sta, WLAN_STA_WME);
  1481. }
  1482. rcu_read_unlock();
  1483. if (sta)
  1484. break;
  1485. /* fall through */
  1486. case NL80211_IFTYPE_AP:
  1487. fc |= cpu_to_le16(IEEE80211_FCTL_FROMDS);
  1488. /* DA BSSID SA */
  1489. memcpy(hdr.addr1, skb->data, ETH_ALEN);
  1490. memcpy(hdr.addr2, sdata->vif.addr, ETH_ALEN);
  1491. memcpy(hdr.addr3, skb->data + ETH_ALEN, ETH_ALEN);
  1492. hdrlen = 24;
  1493. break;
  1494. case NL80211_IFTYPE_WDS:
  1495. fc |= cpu_to_le16(IEEE80211_FCTL_FROMDS | IEEE80211_FCTL_TODS);
  1496. /* RA TA DA SA */
  1497. memcpy(hdr.addr1, sdata->u.wds.remote_addr, ETH_ALEN);
  1498. memcpy(hdr.addr2, sdata->vif.addr, ETH_ALEN);
  1499. memcpy(hdr.addr3, skb->data, ETH_ALEN);
  1500. memcpy(hdr.addr4, skb->data + ETH_ALEN, ETH_ALEN);
  1501. hdrlen = 30;
  1502. break;
  1503. #ifdef CONFIG_MAC80211_MESH
  1504. case NL80211_IFTYPE_MESH_POINT:
  1505. if (!sdata->u.mesh.mshcfg.dot11MeshTTL) {
  1506. /* Do not send frames with mesh_ttl == 0 */
  1507. sdata->u.mesh.mshstats.dropped_frames_ttl++;
  1508. ret = NETDEV_TX_OK;
  1509. goto fail;
  1510. }
  1511. rcu_read_lock();
  1512. if (!is_multicast_ether_addr(skb->data))
  1513. mppath = mpp_path_lookup(skb->data, sdata);
  1514. /*
  1515. * Use address extension if it is a packet from
  1516. * another interface or if we know the destination
  1517. * is being proxied by a portal (i.e. portal address
  1518. * differs from proxied address)
  1519. */
  1520. if (compare_ether_addr(sdata->vif.addr,
  1521. skb->data + ETH_ALEN) == 0 &&
  1522. !(mppath && compare_ether_addr(mppath->mpp, skb->data))) {
  1523. hdrlen = ieee80211_fill_mesh_addresses(&hdr, &fc,
  1524. skb->data, skb->data + ETH_ALEN);
  1525. rcu_read_unlock();
  1526. meshhdrlen = ieee80211_new_mesh_header(&mesh_hdr,
  1527. sdata, NULL, NULL);
  1528. } else {
  1529. int is_mesh_mcast = 1;
  1530. const u8 *mesh_da;
  1531. if (is_multicast_ether_addr(skb->data))
  1532. /* DA TA mSA AE:SA */
  1533. mesh_da = skb->data;
  1534. else {
  1535. static const u8 bcast[ETH_ALEN] =
  1536. { 0xff, 0xff, 0xff, 0xff, 0xff, 0xff };
  1537. if (mppath) {
  1538. /* RA TA mDA mSA AE:DA SA */
  1539. mesh_da = mppath->mpp;
  1540. is_mesh_mcast = 0;
  1541. } else {
  1542. /* DA TA mSA AE:SA */
  1543. mesh_da = bcast;
  1544. }
  1545. }
  1546. hdrlen = ieee80211_fill_mesh_addresses(&hdr, &fc,
  1547. mesh_da, sdata->vif.addr);
  1548. rcu_read_unlock();
  1549. if (is_mesh_mcast)
  1550. meshhdrlen =
  1551. ieee80211_new_mesh_header(&mesh_hdr,
  1552. sdata,
  1553. skb->data + ETH_ALEN,
  1554. NULL);
  1555. else
  1556. meshhdrlen =
  1557. ieee80211_new_mesh_header(&mesh_hdr,
  1558. sdata,
  1559. skb->data,
  1560. skb->data + ETH_ALEN);
  1561. }
  1562. break;
  1563. #endif
  1564. case NL80211_IFTYPE_STATION:
  1565. if (sdata->wdev.wiphy->flags & WIPHY_FLAG_SUPPORTS_TDLS) {
  1566. bool tdls_peer = false;
  1567. rcu_read_lock();
  1568. sta = sta_info_get(sdata, skb->data);
  1569. if (sta) {
  1570. authorized = test_sta_flag(sta,
  1571. WLAN_STA_AUTHORIZED);
  1572. wme_sta = test_sta_flag(sta, WLAN_STA_WME);
  1573. tdls_peer = test_sta_flag(sta,
  1574. WLAN_STA_TDLS_PEER);
  1575. tdls_auth = test_sta_flag(sta,
  1576. WLAN_STA_TDLS_PEER_AUTH);
  1577. }
  1578. rcu_read_unlock();
  1579. /*
  1580. * If the TDLS link is enabled, send everything
  1581. * directly. Otherwise, allow TDLS setup frames
  1582. * to be transmitted indirectly.
  1583. */
  1584. tdls_direct = tdls_peer && (tdls_auth ||
  1585. !(ethertype == ETH_P_TDLS && skb->len > 14 &&
  1586. skb->data[14] == WLAN_TDLS_SNAP_RFTYPE));
  1587. }
  1588. if (tdls_direct) {
  1589. /* link during setup - throw out frames to peer */
  1590. if (!tdls_auth) {
  1591. ret = NETDEV_TX_OK;
  1592. goto fail;
  1593. }
  1594. /* DA SA BSSID */
  1595. memcpy(hdr.addr1, skb->data, ETH_ALEN);
  1596. memcpy(hdr.addr2, skb->data + ETH_ALEN, ETH_ALEN);
  1597. memcpy(hdr.addr3, sdata->u.mgd.bssid, ETH_ALEN);
  1598. hdrlen = 24;
  1599. } else if (sdata->u.mgd.use_4addr &&
  1600. cpu_to_be16(ethertype) != sdata->control_port_protocol) {
  1601. fc |= cpu_to_le16(IEEE80211_FCTL_FROMDS |
  1602. IEEE80211_FCTL_TODS);
  1603. /* RA TA DA SA */
  1604. memcpy(hdr.addr1, sdata->u.mgd.bssid, ETH_ALEN);
  1605. memcpy(hdr.addr2, sdata->vif.addr, ETH_ALEN);
  1606. memcpy(hdr.addr3, skb->data, ETH_ALEN);
  1607. memcpy(hdr.addr4, skb->data + ETH_ALEN, ETH_ALEN);
  1608. hdrlen = 30;
  1609. } else {
  1610. fc |= cpu_to_le16(IEEE80211_FCTL_TODS);
  1611. /* BSSID SA DA */
  1612. memcpy(hdr.addr1, sdata->u.mgd.bssid, ETH_ALEN);
  1613. memcpy(hdr.addr2, skb->data + ETH_ALEN, ETH_ALEN);
  1614. memcpy(hdr.addr3, skb->data, ETH_ALEN);
  1615. hdrlen = 24;
  1616. }
  1617. break;
  1618. case NL80211_IFTYPE_ADHOC:
  1619. /* DA SA BSSID */
  1620. memcpy(hdr.addr1, skb->data, ETH_ALEN);
  1621. memcpy(hdr.addr2, skb->data + ETH_ALEN, ETH_ALEN);
  1622. memcpy(hdr.addr3, sdata->u.ibss.bssid, ETH_ALEN);
  1623. hdrlen = 24;
  1624. break;
  1625. default:
  1626. ret = NETDEV_TX_OK;
  1627. goto fail;
  1628. }
  1629. /*
  1630. * There's no need to try to look up the destination
  1631. * if it is a multicast address (which can only happen
  1632. * in AP mode)
  1633. */
  1634. multicast = is_multicast_ether_addr(hdr.addr1);
  1635. if (!multicast) {
  1636. rcu_read_lock();
  1637. sta = sta_info_get(sdata, hdr.addr1);
  1638. if (sta) {
  1639. authorized = test_sta_flag(sta, WLAN_STA_AUTHORIZED);
  1640. wme_sta = test_sta_flag(sta, WLAN_STA_WME);
  1641. }
  1642. rcu_read_unlock();
  1643. }
  1644. /* For mesh, the use of the QoS header is mandatory */
  1645. if (ieee80211_vif_is_mesh(&sdata->vif))
  1646. wme_sta = true;
  1647. /* receiver and we are QoS enabled, use a QoS type frame */
  1648. if (wme_sta && local->hw.queues >= 4) {
  1649. fc |= cpu_to_le16(IEEE80211_STYPE_QOS_DATA);
  1650. hdrlen += 2;
  1651. }
  1652. /*
  1653. * Drop unicast frames to unauthorised stations unless they are
  1654. * EAPOL frames from the local station.
  1655. */
  1656. if (unlikely(!ieee80211_vif_is_mesh(&sdata->vif) &&
  1657. !is_multicast_ether_addr(hdr.addr1) && !authorized &&
  1658. (cpu_to_be16(ethertype) != sdata->control_port_protocol ||
  1659. compare_ether_addr(sdata->vif.addr, skb->data + ETH_ALEN)))) {
  1660. #ifdef CONFIG_MAC80211_VERBOSE_DEBUG
  1661. if (net_ratelimit())
  1662. printk(KERN_DEBUG "%s: dropped frame to %pM"
  1663. " (unauthorized port)\n", dev->name,
  1664. hdr.addr1);
  1665. #endif
  1666. I802_DEBUG_INC(local->tx_handlers_drop_unauth_port);
  1667. ret = NETDEV_TX_OK;
  1668. goto fail;
  1669. }
  1670. if (unlikely(!multicast && skb->sk &&
  1671. skb_shinfo(skb)->tx_flags & SKBTX_WIFI_STATUS)) {
  1672. struct sk_buff *orig_skb = skb;
  1673. skb = skb_clone(skb, GFP_ATOMIC);
  1674. if (skb) {
  1675. unsigned long flags;
  1676. int id, r;
  1677. spin_lock_irqsave(&local->ack_status_lock, flags);
  1678. r = idr_get_new_above(&local->ack_status_frames,
  1679. orig_skb, 1, &id);
  1680. if (r == -EAGAIN) {
  1681. idr_pre_get(&local->ack_status_frames,
  1682. GFP_ATOMIC);
  1683. r = idr_get_new_above(&local->ack_status_frames,
  1684. orig_skb, 1, &id);
  1685. }
  1686. if (WARN_ON(!id) || id > 0xffff) {
  1687. idr_remove(&local->ack_status_frames, id);
  1688. r = -ERANGE;
  1689. }
  1690. spin_unlock_irqrestore(&local->ack_status_lock, flags);
  1691. if (!r) {
  1692. info_id = id;
  1693. info_flags |= IEEE80211_TX_CTL_REQ_TX_STATUS;
  1694. } else if (skb_shared(skb)) {
  1695. kfree_skb(orig_skb);
  1696. } else {
  1697. kfree_skb(skb);
  1698. skb = orig_skb;
  1699. }
  1700. } else {
  1701. /* couldn't clone -- lose tx status ... */
  1702. skb = orig_skb;
  1703. }
  1704. }
  1705. /*
  1706. * If the skb is shared we need to obtain our own copy.
  1707. */
  1708. if (skb_shared(skb)) {
  1709. struct sk_buff *tmp_skb = skb;
  1710. /* can't happen -- skb is a clone if info_id != 0 */
  1711. WARN_ON(info_id);
  1712. skb = skb_clone(skb, GFP_ATOMIC);
  1713. kfree_skb(tmp_skb);
  1714. if (!skb) {
  1715. ret = NETDEV_TX_OK;
  1716. goto fail;
  1717. }
  1718. }
  1719. hdr.frame_control = fc;
  1720. hdr.duration_id = 0;
  1721. hdr.seq_ctrl = 0;
  1722. skip_header_bytes = ETH_HLEN;
  1723. if (ethertype == ETH_P_AARP || ethertype == ETH_P_IPX) {
  1724. encaps_data = bridge_tunnel_header;
  1725. encaps_len = sizeof(bridge_tunnel_header);
  1726. skip_header_bytes -= 2;
  1727. } else if (ethertype >= 0x600) {
  1728. encaps_data = rfc1042_header;
  1729. encaps_len = sizeof(rfc1042_header);
  1730. skip_header_bytes -= 2;
  1731. } else {
  1732. encaps_data = NULL;
  1733. encaps_len = 0;
  1734. }
  1735. nh_pos = skb_network_header(skb) - skb->data;
  1736. h_pos = skb_transport_header(skb) - skb->data;
  1737. skb_pull(skb, skip_header_bytes);
  1738. nh_pos -= skip_header_bytes;
  1739. h_pos -= skip_header_bytes;
  1740. head_need = hdrlen + encaps_len + meshhdrlen - skb_headroom(skb);
  1741. /*
  1742. * So we need to modify the skb header and hence need a copy of
  1743. * that. The head_need variable above doesn't, so far, include
  1744. * the needed header space that we don't need right away. If we
  1745. * can, then we don't reallocate right now but only after the
  1746. * frame arrives at the master device (if it does...)
  1747. *
  1748. * If we cannot, however, then we will reallocate to include all
  1749. * the ever needed space. Also, if we need to reallocate it anyway,
  1750. * make it big enough for everything we may ever need.
  1751. */
  1752. if (head_need > 0 || skb_cloned(skb)) {
  1753. head_need += IEEE80211_ENCRYPT_HEADROOM;
  1754. head_need += local->tx_headroom;
  1755. head_need = max_t(int, 0, head_need);
  1756. if (ieee80211_skb_resize(sdata, skb, head_need, true))
  1757. goto fail;
  1758. }
  1759. if (encaps_data) {
  1760. memcpy(skb_push(skb, encaps_len), encaps_data, encaps_len);
  1761. nh_pos += encaps_len;
  1762. h_pos += encaps_len;
  1763. }
  1764. #ifdef CONFIG_MAC80211_MESH
  1765. if (meshhdrlen > 0) {
  1766. memcpy(skb_push(skb, meshhdrlen), &mesh_hdr, meshhdrlen);
  1767. nh_pos += meshhdrlen;
  1768. h_pos += meshhdrlen;
  1769. }
  1770. #endif
  1771. if (ieee80211_is_data_qos(fc)) {
  1772. __le16 *qos_control;
  1773. qos_control = (__le16*) skb_push(skb, 2);
  1774. memcpy(skb_push(skb, hdrlen - 2), &hdr, hdrlen - 2);
  1775. /*
  1776. * Maybe we could actually set some fields here, for now just
  1777. * initialise to zero to indicate no special operation.
  1778. */
  1779. *qos_control = 0;
  1780. } else
  1781. memcpy(skb_push(skb, hdrlen), &hdr, hdrlen);
  1782. nh_pos += hdrlen;
  1783. h_pos += hdrlen;
  1784. dev->stats.tx_packets++;
  1785. dev->stats.tx_bytes += skb->len;
  1786. /* Update skb pointers to various headers since this modified frame
  1787. * is going to go through Linux networking code that may potentially
  1788. * need things like pointer to IP header. */
  1789. skb_set_mac_header(skb, 0);
  1790. skb_set_network_header(skb, nh_pos);
  1791. skb_set_transport_header(skb, h_pos);
  1792. info = IEEE80211_SKB_CB(skb);
  1793. memset(info, 0, sizeof(*info));
  1794. dev->trans_start = jiffies;
  1795. info->flags = info_flags;
  1796. info->ack_frame_id = info_id;
  1797. ieee80211_xmit(sdata, skb);
  1798. return NETDEV_TX_OK;
  1799. fail:
  1800. if (ret == NETDEV_TX_OK)
  1801. dev_kfree_skb(skb);
  1802. return ret;
  1803. }
  1804. /*
  1805. * ieee80211_clear_tx_pending may not be called in a context where
  1806. * it is possible that it packets could come in again.
  1807. */
  1808. void ieee80211_clear_tx_pending(struct ieee80211_local *local)
  1809. {
  1810. int i;
  1811. for (i = 0; i < local->hw.queues; i++)
  1812. skb_queue_purge(&local->pending[i]);
  1813. }
  1814. /*
  1815. * Returns false if the frame couldn't be transmitted but was queued instead,
  1816. * which in this case means re-queued -- take as an indication to stop sending
  1817. * more pending frames.
  1818. */
  1819. static bool ieee80211_tx_pending_skb(struct ieee80211_local *local,
  1820. struct sk_buff *skb)
  1821. {
  1822. struct ieee80211_tx_info *info = IEEE80211_SKB_CB(skb);
  1823. struct ieee80211_sub_if_data *sdata;
  1824. struct sta_info *sta;
  1825. struct ieee80211_hdr *hdr;
  1826. bool result;
  1827. sdata = vif_to_sdata(info->control.vif);
  1828. if (info->flags & IEEE80211_TX_INTFL_NEED_TXPROCESSING) {
  1829. result = ieee80211_tx(sdata, skb, true);
  1830. } else {
  1831. struct sk_buff_head skbs;
  1832. __skb_queue_head_init(&skbs);
  1833. __skb_queue_tail(&skbs, skb);
  1834. hdr = (struct ieee80211_hdr *)skb->data;
  1835. sta = sta_info_get(sdata, hdr->addr1);
  1836. result = __ieee80211_tx(local, &skbs, skb->len, sta, true);
  1837. }
  1838. return result;
  1839. }
  1840. /*
  1841. * Transmit all pending packets. Called from tasklet.
  1842. */
  1843. void ieee80211_tx_pending(unsigned long data)
  1844. {
  1845. struct ieee80211_local *local = (struct ieee80211_local *)data;
  1846. struct ieee80211_sub_if_data *sdata;
  1847. unsigned long flags;
  1848. int i;
  1849. bool txok;
  1850. rcu_read_lock();
  1851. spin_lock_irqsave(&local->queue_stop_reason_lock, flags);
  1852. for (i = 0; i < local->hw.queues; i++) {
  1853. /*
  1854. * If queue is stopped by something other than due to pending
  1855. * frames, or we have no pending frames, proceed to next queue.
  1856. */
  1857. if (local->queue_stop_reasons[i] ||
  1858. skb_queue_empty(&local->pending[i]))
  1859. continue;
  1860. while (!skb_queue_empty(&local->pending[i])) {
  1861. struct sk_buff *skb = __skb_dequeue(&local->pending[i]);
  1862. struct ieee80211_tx_info *info = IEEE80211_SKB_CB(skb);
  1863. if (WARN_ON(!info->control.vif)) {
  1864. kfree_skb(skb);
  1865. continue;
  1866. }
  1867. spin_unlock_irqrestore(&local->queue_stop_reason_lock,
  1868. flags);
  1869. txok = ieee80211_tx_pending_skb(local, skb);
  1870. spin_lock_irqsave(&local->queue_stop_reason_lock,
  1871. flags);
  1872. if (!txok)
  1873. break;
  1874. }
  1875. if (skb_queue_empty(&local->pending[i]))
  1876. list_for_each_entry_rcu(sdata, &local->interfaces, list)
  1877. netif_wake_subqueue(sdata->dev, i);
  1878. }
  1879. spin_unlock_irqrestore(&local->queue_stop_reason_lock, flags);
  1880. rcu_read_unlock();
  1881. }
  1882. /* functions for drivers to get certain frames */
  1883. static void ieee80211_beacon_add_tim(struct ieee80211_if_ap *bss,
  1884. struct sk_buff *skb,
  1885. struct beacon_data *beacon)
  1886. {
  1887. u8 *pos, *tim;
  1888. int aid0 = 0;
  1889. int i, have_bits = 0, n1, n2;
  1890. /* Generate bitmap for TIM only if there are any STAs in power save
  1891. * mode. */
  1892. if (atomic_read(&bss->num_sta_ps) > 0)
  1893. /* in the hope that this is faster than
  1894. * checking byte-for-byte */
  1895. have_bits = !bitmap_empty((unsigned long*)bss->tim,
  1896. IEEE80211_MAX_AID+1);
  1897. if (bss->dtim_count == 0)
  1898. bss->dtim_count = beacon->dtim_period - 1;
  1899. else
  1900. bss->dtim_count--;
  1901. tim = pos = (u8 *) skb_put(skb, 6);
  1902. *pos++ = WLAN_EID_TIM;
  1903. *pos++ = 4;
  1904. *pos++ = bss->dtim_count;
  1905. *pos++ = beacon->dtim_period;
  1906. if (bss->dtim_count == 0 && !skb_queue_empty(&bss->ps_bc_buf))
  1907. aid0 = 1;
  1908. bss->dtim_bc_mc = aid0 == 1;
  1909. if (have_bits) {
  1910. /* Find largest even number N1 so that bits numbered 1 through
  1911. * (N1 x 8) - 1 in the bitmap are 0 and number N2 so that bits
  1912. * (N2 + 1) x 8 through 2007 are 0. */
  1913. n1 = 0;
  1914. for (i = 0; i < IEEE80211_MAX_TIM_LEN; i++) {
  1915. if (bss->tim[i]) {
  1916. n1 = i & 0xfe;
  1917. break;
  1918. }
  1919. }
  1920. n2 = n1;
  1921. for (i = IEEE80211_MAX_TIM_LEN - 1; i >= n1; i--) {
  1922. if (bss->tim[i]) {
  1923. n2 = i;
  1924. break;
  1925. }
  1926. }
  1927. /* Bitmap control */
  1928. *pos++ = n1 | aid0;
  1929. /* Part Virt Bitmap */
  1930. memcpy(pos, bss->tim + n1, n2 - n1 + 1);
  1931. tim[1] = n2 - n1 + 4;
  1932. skb_put(skb, n2 - n1);
  1933. } else {
  1934. *pos++ = aid0; /* Bitmap control */
  1935. *pos++ = 0; /* Part Virt Bitmap */
  1936. }
  1937. }
  1938. struct sk_buff *ieee80211_beacon_get_tim(struct ieee80211_hw *hw,
  1939. struct ieee80211_vif *vif,
  1940. u16 *tim_offset, u16 *tim_length)
  1941. {
  1942. struct ieee80211_local *local = hw_to_local(hw);
  1943. struct sk_buff *skb = NULL;
  1944. struct ieee80211_tx_info *info;
  1945. struct ieee80211_sub_if_data *sdata = NULL;
  1946. struct ieee80211_if_ap *ap = NULL;
  1947. struct beacon_data *beacon;
  1948. struct ieee80211_supported_band *sband;
  1949. enum ieee80211_band band = local->hw.conf.channel->band;
  1950. struct ieee80211_tx_rate_control txrc;
  1951. sband = local->hw.wiphy->bands[band];
  1952. rcu_read_lock();
  1953. sdata = vif_to_sdata(vif);
  1954. if (!ieee80211_sdata_running(sdata))
  1955. goto out;
  1956. if (tim_offset)
  1957. *tim_offset = 0;
  1958. if (tim_length)
  1959. *tim_length = 0;
  1960. if (sdata->vif.type == NL80211_IFTYPE_AP) {
  1961. ap = &sdata->u.ap;
  1962. beacon = rcu_dereference(ap->beacon);
  1963. if (beacon) {
  1964. /*
  1965. * headroom, head length,
  1966. * tail length and maximum TIM length
  1967. */
  1968. skb = dev_alloc_skb(local->tx_headroom +
  1969. beacon->head_len +
  1970. beacon->tail_len + 256);
  1971. if (!skb)
  1972. goto out;
  1973. skb_reserve(skb, local->tx_headroom);
  1974. memcpy(skb_put(skb, beacon->head_len), beacon->head,
  1975. beacon->head_len);
  1976. /*
  1977. * Not very nice, but we want to allow the driver to call
  1978. * ieee80211_beacon_get() as a response to the set_tim()
  1979. * callback. That, however, is already invoked under the
  1980. * sta_lock to guarantee consistent and race-free update
  1981. * of the tim bitmap in mac80211 and the driver.
  1982. */
  1983. if (local->tim_in_locked_section) {
  1984. ieee80211_beacon_add_tim(ap, skb, beacon);
  1985. } else {
  1986. unsigned long flags;
  1987. spin_lock_irqsave(&local->sta_lock, flags);
  1988. ieee80211_beacon_add_tim(ap, skb, beacon);
  1989. spin_unlock_irqrestore(&local->sta_lock, flags);
  1990. }
  1991. if (tim_offset)
  1992. *tim_offset = beacon->head_len;
  1993. if (tim_length)
  1994. *tim_length = skb->len - beacon->head_len;
  1995. if (beacon->tail)
  1996. memcpy(skb_put(skb, beacon->tail_len),
  1997. beacon->tail, beacon->tail_len);
  1998. } else
  1999. goto out;
  2000. } else if (sdata->vif.type == NL80211_IFTYPE_ADHOC) {
  2001. struct ieee80211_if_ibss *ifibss = &sdata->u.ibss;
  2002. struct ieee80211_hdr *hdr;
  2003. struct sk_buff *presp = rcu_dereference(ifibss->presp);
  2004. if (!presp)
  2005. goto out;
  2006. skb = skb_copy(presp, GFP_ATOMIC);
  2007. if (!skb)
  2008. goto out;
  2009. hdr = (struct ieee80211_hdr *) skb->data;
  2010. hdr->frame_control = cpu_to_le16(IEEE80211_FTYPE_MGMT |
  2011. IEEE80211_STYPE_BEACON);
  2012. } else if (ieee80211_vif_is_mesh(&sdata->vif)) {
  2013. struct ieee80211_mgmt *mgmt;
  2014. u8 *pos;
  2015. int hdr_len = offsetof(struct ieee80211_mgmt, u.beacon) +
  2016. sizeof(mgmt->u.beacon);
  2017. #ifdef CONFIG_MAC80211_MESH
  2018. if (!sdata->u.mesh.mesh_id_len)
  2019. goto out;
  2020. #endif
  2021. skb = dev_alloc_skb(local->tx_headroom +
  2022. hdr_len +
  2023. 2 + /* NULL SSID */
  2024. 2 + 8 + /* supported rates */
  2025. 2 + 3 + /* DS params */
  2026. 2 + (IEEE80211_MAX_SUPP_RATES - 8) +
  2027. 2 + sizeof(struct ieee80211_ht_cap) +
  2028. 2 + sizeof(struct ieee80211_ht_info) +
  2029. 2 + sdata->u.mesh.mesh_id_len +
  2030. 2 + sizeof(struct ieee80211_meshconf_ie) +
  2031. sdata->u.mesh.ie_len);
  2032. if (!skb)
  2033. goto out;
  2034. skb_reserve(skb, local->hw.extra_tx_headroom);
  2035. mgmt = (struct ieee80211_mgmt *) skb_put(skb, hdr_len);
  2036. memset(mgmt, 0, hdr_len);
  2037. mgmt->frame_control =
  2038. cpu_to_le16(IEEE80211_FTYPE_MGMT | IEEE80211_STYPE_BEACON);
  2039. memset(mgmt->da, 0xff, ETH_ALEN);
  2040. memcpy(mgmt->sa, sdata->vif.addr, ETH_ALEN);
  2041. memcpy(mgmt->bssid, sdata->vif.addr, ETH_ALEN);
  2042. mgmt->u.beacon.beacon_int =
  2043. cpu_to_le16(sdata->vif.bss_conf.beacon_int);
  2044. mgmt->u.beacon.capab_info |= cpu_to_le16(
  2045. sdata->u.mesh.security ? WLAN_CAPABILITY_PRIVACY : 0);
  2046. pos = skb_put(skb, 2);
  2047. *pos++ = WLAN_EID_SSID;
  2048. *pos++ = 0x0;
  2049. if (ieee80211_add_srates_ie(&sdata->vif, skb) ||
  2050. mesh_add_ds_params_ie(skb, sdata) ||
  2051. ieee80211_add_ext_srates_ie(&sdata->vif, skb) ||
  2052. mesh_add_rsn_ie(skb, sdata) ||
  2053. mesh_add_ht_cap_ie(skb, sdata) ||
  2054. mesh_add_ht_info_ie(skb, sdata) ||
  2055. mesh_add_meshid_ie(skb, sdata) ||
  2056. mesh_add_meshconf_ie(skb, sdata) ||
  2057. mesh_add_vendor_ies(skb, sdata)) {
  2058. pr_err("o11s: couldn't add ies!\n");
  2059. goto out;
  2060. }
  2061. } else {
  2062. WARN_ON(1);
  2063. goto out;
  2064. }
  2065. info = IEEE80211_SKB_CB(skb);
  2066. info->flags |= IEEE80211_TX_INTFL_DONT_ENCRYPT;
  2067. info->flags |= IEEE80211_TX_CTL_NO_ACK;
  2068. info->band = band;
  2069. memset(&txrc, 0, sizeof(txrc));
  2070. txrc.hw = hw;
  2071. txrc.sband = sband;
  2072. txrc.bss_conf = &sdata->vif.bss_conf;
  2073. txrc.skb = skb;
  2074. txrc.reported_rate.idx = -1;
  2075. txrc.rate_idx_mask = sdata->rc_rateidx_mask[band];
  2076. if (txrc.rate_idx_mask == (1 << sband->n_bitrates) - 1)
  2077. txrc.max_rate_idx = -1;
  2078. else
  2079. txrc.max_rate_idx = fls(txrc.rate_idx_mask) - 1;
  2080. txrc.bss = true;
  2081. rate_control_get_rate(sdata, NULL, &txrc);
  2082. info->control.vif = vif;
  2083. info->flags |= IEEE80211_TX_CTL_CLEAR_PS_FILT |
  2084. IEEE80211_TX_CTL_ASSIGN_SEQ |
  2085. IEEE80211_TX_CTL_FIRST_FRAGMENT;
  2086. out:
  2087. rcu_read_unlock();
  2088. return skb;
  2089. }
  2090. EXPORT_SYMBOL(ieee80211_beacon_get_tim);
  2091. struct sk_buff *ieee80211_proberesp_get(struct ieee80211_hw *hw,
  2092. struct ieee80211_vif *vif)
  2093. {
  2094. struct ieee80211_if_ap *ap = NULL;
  2095. struct sk_buff *presp = NULL, *skb = NULL;
  2096. struct ieee80211_hdr *hdr;
  2097. struct ieee80211_sub_if_data *sdata = vif_to_sdata(vif);
  2098. if (sdata->vif.type != NL80211_IFTYPE_AP)
  2099. return NULL;
  2100. rcu_read_lock();
  2101. ap = &sdata->u.ap;
  2102. presp = rcu_dereference(ap->probe_resp);
  2103. if (!presp)
  2104. goto out;
  2105. skb = skb_copy(presp, GFP_ATOMIC);
  2106. if (!skb)
  2107. goto out;
  2108. hdr = (struct ieee80211_hdr *) skb->data;
  2109. memset(hdr->addr1, 0, sizeof(hdr->addr1));
  2110. out:
  2111. rcu_read_unlock();
  2112. return skb;
  2113. }
  2114. EXPORT_SYMBOL(ieee80211_proberesp_get);
  2115. struct sk_buff *ieee80211_pspoll_get(struct ieee80211_hw *hw,
  2116. struct ieee80211_vif *vif)
  2117. {
  2118. struct ieee80211_sub_if_data *sdata;
  2119. struct ieee80211_if_managed *ifmgd;
  2120. struct ieee80211_pspoll *pspoll;
  2121. struct ieee80211_local *local;
  2122. struct sk_buff *skb;
  2123. if (WARN_ON(vif->type != NL80211_IFTYPE_STATION))
  2124. return NULL;
  2125. sdata = vif_to_sdata(vif);
  2126. ifmgd = &sdata->u.mgd;
  2127. local = sdata->local;
  2128. skb = dev_alloc_skb(local->hw.extra_tx_headroom + sizeof(*pspoll));
  2129. if (!skb)
  2130. return NULL;
  2131. skb_reserve(skb, local->hw.extra_tx_headroom);
  2132. pspoll = (struct ieee80211_pspoll *) skb_put(skb, sizeof(*pspoll));
  2133. memset(pspoll, 0, sizeof(*pspoll));
  2134. pspoll->frame_control = cpu_to_le16(IEEE80211_FTYPE_CTL |
  2135. IEEE80211_STYPE_PSPOLL);
  2136. pspoll->aid = cpu_to_le16(ifmgd->aid);
  2137. /* aid in PS-Poll has its two MSBs each set to 1 */
  2138. pspoll->aid |= cpu_to_le16(1 << 15 | 1 << 14);
  2139. memcpy(pspoll->bssid, ifmgd->bssid, ETH_ALEN);
  2140. memcpy(pspoll->ta, vif->addr, ETH_ALEN);
  2141. return skb;
  2142. }
  2143. EXPORT_SYMBOL(ieee80211_pspoll_get);
  2144. struct sk_buff *ieee80211_nullfunc_get(struct ieee80211_hw *hw,
  2145. struct ieee80211_vif *vif)
  2146. {
  2147. struct ieee80211_hdr_3addr *nullfunc;
  2148. struct ieee80211_sub_if_data *sdata;
  2149. struct ieee80211_if_managed *ifmgd;
  2150. struct ieee80211_local *local;
  2151. struct sk_buff *skb;
  2152. if (WARN_ON(vif->type != NL80211_IFTYPE_STATION))
  2153. return NULL;
  2154. sdata = vif_to_sdata(vif);
  2155. ifmgd = &sdata->u.mgd;
  2156. local = sdata->local;
  2157. skb = dev_alloc_skb(local->hw.extra_tx_headroom + sizeof(*nullfunc));
  2158. if (!skb)
  2159. return NULL;
  2160. skb_reserve(skb, local->hw.extra_tx_headroom);
  2161. nullfunc = (struct ieee80211_hdr_3addr *) skb_put(skb,
  2162. sizeof(*nullfunc));
  2163. memset(nullfunc, 0, sizeof(*nullfunc));
  2164. nullfunc->frame_control = cpu_to_le16(IEEE80211_FTYPE_DATA |
  2165. IEEE80211_STYPE_NULLFUNC |
  2166. IEEE80211_FCTL_TODS);
  2167. memcpy(nullfunc->addr1, ifmgd->bssid, ETH_ALEN);
  2168. memcpy(nullfunc->addr2, vif->addr, ETH_ALEN);
  2169. memcpy(nullfunc->addr3, ifmgd->bssid, ETH_ALEN);
  2170. return skb;
  2171. }
  2172. EXPORT_SYMBOL(ieee80211_nullfunc_get);
  2173. struct sk_buff *ieee80211_probereq_get(struct ieee80211_hw *hw,
  2174. struct ieee80211_vif *vif,
  2175. const u8 *ssid, size_t ssid_len,
  2176. const u8 *ie, size_t ie_len)
  2177. {
  2178. struct ieee80211_sub_if_data *sdata;
  2179. struct ieee80211_local *local;
  2180. struct ieee80211_hdr_3addr *hdr;
  2181. struct sk_buff *skb;
  2182. size_t ie_ssid_len;
  2183. u8 *pos;
  2184. sdata = vif_to_sdata(vif);
  2185. local = sdata->local;
  2186. ie_ssid_len = 2 + ssid_len;
  2187. skb = dev_alloc_skb(local->hw.extra_tx_headroom + sizeof(*hdr) +
  2188. ie_ssid_len + ie_len);
  2189. if (!skb)
  2190. return NULL;
  2191. skb_reserve(skb, local->hw.extra_tx_headroom);
  2192. hdr = (struct ieee80211_hdr_3addr *) skb_put(skb, sizeof(*hdr));
  2193. memset(hdr, 0, sizeof(*hdr));
  2194. hdr->frame_control = cpu_to_le16(IEEE80211_FTYPE_MGMT |
  2195. IEEE80211_STYPE_PROBE_REQ);
  2196. memset(hdr->addr1, 0xff, ETH_ALEN);
  2197. memcpy(hdr->addr2, vif->addr, ETH_ALEN);
  2198. memset(hdr->addr3, 0xff, ETH_ALEN);
  2199. pos = skb_put(skb, ie_ssid_len);
  2200. *pos++ = WLAN_EID_SSID;
  2201. *pos++ = ssid_len;
  2202. if (ssid)
  2203. memcpy(pos, ssid, ssid_len);
  2204. pos += ssid_len;
  2205. if (ie) {
  2206. pos = skb_put(skb, ie_len);
  2207. memcpy(pos, ie, ie_len);
  2208. }
  2209. return skb;
  2210. }
  2211. EXPORT_SYMBOL(ieee80211_probereq_get);
  2212. void ieee80211_rts_get(struct ieee80211_hw *hw, struct ieee80211_vif *vif,
  2213. const void *frame, size_t frame_len,
  2214. const struct ieee80211_tx_info *frame_txctl,
  2215. struct ieee80211_rts *rts)
  2216. {
  2217. const struct ieee80211_hdr *hdr = frame;
  2218. rts->frame_control =
  2219. cpu_to_le16(IEEE80211_FTYPE_CTL | IEEE80211_STYPE_RTS);
  2220. rts->duration = ieee80211_rts_duration(hw, vif, frame_len,
  2221. frame_txctl);
  2222. memcpy(rts->ra, hdr->addr1, sizeof(rts->ra));
  2223. memcpy(rts->ta, hdr->addr2, sizeof(rts->ta));
  2224. }
  2225. EXPORT_SYMBOL(ieee80211_rts_get);
  2226. void ieee80211_ctstoself_get(struct ieee80211_hw *hw, struct ieee80211_vif *vif,
  2227. const void *frame, size_t frame_len,
  2228. const struct ieee80211_tx_info *frame_txctl,
  2229. struct ieee80211_cts *cts)
  2230. {
  2231. const struct ieee80211_hdr *hdr = frame;
  2232. cts->frame_control =
  2233. cpu_to_le16(IEEE80211_FTYPE_CTL | IEEE80211_STYPE_CTS);
  2234. cts->duration = ieee80211_ctstoself_duration(hw, vif,
  2235. frame_len, frame_txctl);
  2236. memcpy(cts->ra, hdr->addr1, sizeof(cts->ra));
  2237. }
  2238. EXPORT_SYMBOL(ieee80211_ctstoself_get);
  2239. struct sk_buff *
  2240. ieee80211_get_buffered_bc(struct ieee80211_hw *hw,
  2241. struct ieee80211_vif *vif)
  2242. {
  2243. struct ieee80211_local *local = hw_to_local(hw);
  2244. struct sk_buff *skb = NULL;
  2245. struct ieee80211_tx_data tx;
  2246. struct ieee80211_sub_if_data *sdata;
  2247. struct ieee80211_if_ap *bss = NULL;
  2248. struct beacon_data *beacon;
  2249. struct ieee80211_tx_info *info;
  2250. sdata = vif_to_sdata(vif);
  2251. bss = &sdata->u.ap;
  2252. rcu_read_lock();
  2253. beacon = rcu_dereference(bss->beacon);
  2254. if (sdata->vif.type != NL80211_IFTYPE_AP || !beacon || !beacon->head)
  2255. goto out;
  2256. if (bss->dtim_count != 0 || !bss->dtim_bc_mc)
  2257. goto out; /* send buffered bc/mc only after DTIM beacon */
  2258. while (1) {
  2259. skb = skb_dequeue(&bss->ps_bc_buf);
  2260. if (!skb)
  2261. goto out;
  2262. local->total_ps_buffered--;
  2263. if (!skb_queue_empty(&bss->ps_bc_buf) && skb->len >= 2) {
  2264. struct ieee80211_hdr *hdr =
  2265. (struct ieee80211_hdr *) skb->data;
  2266. /* more buffered multicast/broadcast frames ==> set
  2267. * MoreData flag in IEEE 802.11 header to inform PS
  2268. * STAs */
  2269. hdr->frame_control |=
  2270. cpu_to_le16(IEEE80211_FCTL_MOREDATA);
  2271. }
  2272. if (!ieee80211_tx_prepare(sdata, &tx, skb))
  2273. break;
  2274. dev_kfree_skb_any(skb);
  2275. }
  2276. info = IEEE80211_SKB_CB(skb);
  2277. tx.flags |= IEEE80211_TX_PS_BUFFERED;
  2278. tx.channel = local->hw.conf.channel;
  2279. info->band = tx.channel->band;
  2280. if (invoke_tx_handlers(&tx))
  2281. skb = NULL;
  2282. out:
  2283. rcu_read_unlock();
  2284. return skb;
  2285. }
  2286. EXPORT_SYMBOL(ieee80211_get_buffered_bc);
  2287. void ieee80211_tx_skb(struct ieee80211_sub_if_data *sdata, struct sk_buff *skb)
  2288. {
  2289. skb_set_mac_header(skb, 0);
  2290. skb_set_network_header(skb, 0);
  2291. skb_set_transport_header(skb, 0);
  2292. /* Send all internal mgmt frames on VO. Accordingly set TID to 7. */
  2293. skb_set_queue_mapping(skb, IEEE80211_AC_VO);
  2294. skb->priority = 7;
  2295. /*
  2296. * The other path calling ieee80211_xmit is from the tasklet,
  2297. * and while we can handle concurrent transmissions locking
  2298. * requirements are that we do not come into tx with bhs on.
  2299. */
  2300. local_bh_disable();
  2301. ieee80211_xmit(sdata, skb);
  2302. local_bh_enable();
  2303. }