tx.c 74 KB

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