recv.c 35 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349
  1. /*
  2. * Copyright (c) 2008-2011 Atheros Communications Inc.
  3. *
  4. * Permission to use, copy, modify, and/or distribute this software for any
  5. * purpose with or without fee is hereby granted, provided that the above
  6. * copyright notice and this permission notice appear in all copies.
  7. *
  8. * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
  9. * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
  10. * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
  11. * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
  12. * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
  13. * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
  14. * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
  15. */
  16. #include <linux/dma-mapping.h>
  17. #include <linux/relay.h>
  18. #include "ath9k.h"
  19. #include "ar9003_mac.h"
  20. #define SKB_CB_ATHBUF(__skb) (*((struct ath_buf **)__skb->cb))
  21. static inline bool ath9k_check_auto_sleep(struct ath_softc *sc)
  22. {
  23. return sc->ps_enabled &&
  24. (sc->sc_ah->caps.hw_caps & ATH9K_HW_CAP_AUTOSLEEP);
  25. }
  26. /*
  27. * Setup and link descriptors.
  28. *
  29. * 11N: we can no longer afford to self link the last descriptor.
  30. * MAC acknowledges BA status as long as it copies frames to host
  31. * buffer (or rx fifo). This can incorrectly acknowledge packets
  32. * to a sender if last desc is self-linked.
  33. */
  34. static void ath_rx_buf_link(struct ath_softc *sc, struct ath_buf *bf)
  35. {
  36. struct ath_hw *ah = sc->sc_ah;
  37. struct ath_common *common = ath9k_hw_common(ah);
  38. struct ath_desc *ds;
  39. struct sk_buff *skb;
  40. ATH_RXBUF_RESET(bf);
  41. ds = bf->bf_desc;
  42. ds->ds_link = 0; /* link to null */
  43. ds->ds_data = bf->bf_buf_addr;
  44. /* virtual addr of the beginning of the buffer. */
  45. skb = bf->bf_mpdu;
  46. BUG_ON(skb == NULL);
  47. ds->ds_vdata = skb->data;
  48. /*
  49. * setup rx descriptors. The rx_bufsize here tells the hardware
  50. * how much data it can DMA to us and that we are prepared
  51. * to process
  52. */
  53. ath9k_hw_setuprxdesc(ah, ds,
  54. common->rx_bufsize,
  55. 0);
  56. if (sc->rx.rxlink == NULL)
  57. ath9k_hw_putrxbuf(ah, bf->bf_daddr);
  58. else
  59. *sc->rx.rxlink = bf->bf_daddr;
  60. sc->rx.rxlink = &ds->ds_link;
  61. }
  62. static void ath_setdefantenna(struct ath_softc *sc, u32 antenna)
  63. {
  64. /* XXX block beacon interrupts */
  65. ath9k_hw_setantenna(sc->sc_ah, antenna);
  66. sc->rx.defant = antenna;
  67. sc->rx.rxotherant = 0;
  68. }
  69. static void ath_opmode_init(struct ath_softc *sc)
  70. {
  71. struct ath_hw *ah = sc->sc_ah;
  72. struct ath_common *common = ath9k_hw_common(ah);
  73. u32 rfilt, mfilt[2];
  74. /* configure rx filter */
  75. rfilt = ath_calcrxfilter(sc);
  76. ath9k_hw_setrxfilter(ah, rfilt);
  77. /* configure bssid mask */
  78. ath_hw_setbssidmask(common);
  79. /* configure operational mode */
  80. ath9k_hw_setopmode(ah);
  81. /* calculate and install multicast filter */
  82. mfilt[0] = mfilt[1] = ~0;
  83. ath9k_hw_setmcastfilter(ah, mfilt[0], mfilt[1]);
  84. }
  85. static bool ath_rx_edma_buf_link(struct ath_softc *sc,
  86. enum ath9k_rx_qtype qtype)
  87. {
  88. struct ath_hw *ah = sc->sc_ah;
  89. struct ath_rx_edma *rx_edma;
  90. struct sk_buff *skb;
  91. struct ath_buf *bf;
  92. rx_edma = &sc->rx.rx_edma[qtype];
  93. if (skb_queue_len(&rx_edma->rx_fifo) >= rx_edma->rx_fifo_hwsize)
  94. return false;
  95. bf = list_first_entry(&sc->rx.rxbuf, struct ath_buf, list);
  96. list_del_init(&bf->list);
  97. skb = bf->bf_mpdu;
  98. ATH_RXBUF_RESET(bf);
  99. memset(skb->data, 0, ah->caps.rx_status_len);
  100. dma_sync_single_for_device(sc->dev, bf->bf_buf_addr,
  101. ah->caps.rx_status_len, DMA_TO_DEVICE);
  102. SKB_CB_ATHBUF(skb) = bf;
  103. ath9k_hw_addrxbuf_edma(ah, bf->bf_buf_addr, qtype);
  104. skb_queue_tail(&rx_edma->rx_fifo, skb);
  105. return true;
  106. }
  107. static void ath_rx_addbuffer_edma(struct ath_softc *sc,
  108. enum ath9k_rx_qtype qtype, int size)
  109. {
  110. struct ath_common *common = ath9k_hw_common(sc->sc_ah);
  111. struct ath_buf *bf, *tbf;
  112. if (list_empty(&sc->rx.rxbuf)) {
  113. ath_dbg(common, QUEUE, "No free rx buf available\n");
  114. return;
  115. }
  116. list_for_each_entry_safe(bf, tbf, &sc->rx.rxbuf, list)
  117. if (!ath_rx_edma_buf_link(sc, qtype))
  118. break;
  119. }
  120. static void ath_rx_remove_buffer(struct ath_softc *sc,
  121. enum ath9k_rx_qtype qtype)
  122. {
  123. struct ath_buf *bf;
  124. struct ath_rx_edma *rx_edma;
  125. struct sk_buff *skb;
  126. rx_edma = &sc->rx.rx_edma[qtype];
  127. while ((skb = skb_dequeue(&rx_edma->rx_fifo)) != NULL) {
  128. bf = SKB_CB_ATHBUF(skb);
  129. BUG_ON(!bf);
  130. list_add_tail(&bf->list, &sc->rx.rxbuf);
  131. }
  132. }
  133. static void ath_rx_edma_cleanup(struct ath_softc *sc)
  134. {
  135. struct ath_hw *ah = sc->sc_ah;
  136. struct ath_common *common = ath9k_hw_common(ah);
  137. struct ath_buf *bf;
  138. ath_rx_remove_buffer(sc, ATH9K_RX_QUEUE_LP);
  139. ath_rx_remove_buffer(sc, ATH9K_RX_QUEUE_HP);
  140. list_for_each_entry(bf, &sc->rx.rxbuf, list) {
  141. if (bf->bf_mpdu) {
  142. dma_unmap_single(sc->dev, bf->bf_buf_addr,
  143. common->rx_bufsize,
  144. DMA_BIDIRECTIONAL);
  145. dev_kfree_skb_any(bf->bf_mpdu);
  146. bf->bf_buf_addr = 0;
  147. bf->bf_mpdu = NULL;
  148. }
  149. }
  150. }
  151. static void ath_rx_edma_init_queue(struct ath_rx_edma *rx_edma, int size)
  152. {
  153. skb_queue_head_init(&rx_edma->rx_fifo);
  154. rx_edma->rx_fifo_hwsize = size;
  155. }
  156. static int ath_rx_edma_init(struct ath_softc *sc, int nbufs)
  157. {
  158. struct ath_common *common = ath9k_hw_common(sc->sc_ah);
  159. struct ath_hw *ah = sc->sc_ah;
  160. struct sk_buff *skb;
  161. struct ath_buf *bf;
  162. int error = 0, i;
  163. u32 size;
  164. ath9k_hw_set_rx_bufsize(ah, common->rx_bufsize -
  165. ah->caps.rx_status_len);
  166. ath_rx_edma_init_queue(&sc->rx.rx_edma[ATH9K_RX_QUEUE_LP],
  167. ah->caps.rx_lp_qdepth);
  168. ath_rx_edma_init_queue(&sc->rx.rx_edma[ATH9K_RX_QUEUE_HP],
  169. ah->caps.rx_hp_qdepth);
  170. size = sizeof(struct ath_buf) * nbufs;
  171. bf = devm_kzalloc(sc->dev, size, GFP_KERNEL);
  172. if (!bf)
  173. return -ENOMEM;
  174. INIT_LIST_HEAD(&sc->rx.rxbuf);
  175. for (i = 0; i < nbufs; i++, bf++) {
  176. skb = ath_rxbuf_alloc(common, common->rx_bufsize, GFP_KERNEL);
  177. if (!skb) {
  178. error = -ENOMEM;
  179. goto rx_init_fail;
  180. }
  181. memset(skb->data, 0, common->rx_bufsize);
  182. bf->bf_mpdu = skb;
  183. bf->bf_buf_addr = dma_map_single(sc->dev, skb->data,
  184. common->rx_bufsize,
  185. DMA_BIDIRECTIONAL);
  186. if (unlikely(dma_mapping_error(sc->dev,
  187. bf->bf_buf_addr))) {
  188. dev_kfree_skb_any(skb);
  189. bf->bf_mpdu = NULL;
  190. bf->bf_buf_addr = 0;
  191. ath_err(common,
  192. "dma_mapping_error() on RX init\n");
  193. error = -ENOMEM;
  194. goto rx_init_fail;
  195. }
  196. list_add_tail(&bf->list, &sc->rx.rxbuf);
  197. }
  198. return 0;
  199. rx_init_fail:
  200. ath_rx_edma_cleanup(sc);
  201. return error;
  202. }
  203. static void ath_edma_start_recv(struct ath_softc *sc)
  204. {
  205. ath9k_hw_rxena(sc->sc_ah);
  206. ath_rx_addbuffer_edma(sc, ATH9K_RX_QUEUE_HP,
  207. sc->rx.rx_edma[ATH9K_RX_QUEUE_HP].rx_fifo_hwsize);
  208. ath_rx_addbuffer_edma(sc, ATH9K_RX_QUEUE_LP,
  209. sc->rx.rx_edma[ATH9K_RX_QUEUE_LP].rx_fifo_hwsize);
  210. ath_opmode_init(sc);
  211. ath9k_hw_startpcureceive(sc->sc_ah, !!(sc->hw->conf.flags & IEEE80211_CONF_OFFCHANNEL));
  212. }
  213. static void ath_edma_stop_recv(struct ath_softc *sc)
  214. {
  215. ath_rx_remove_buffer(sc, ATH9K_RX_QUEUE_HP);
  216. ath_rx_remove_buffer(sc, ATH9K_RX_QUEUE_LP);
  217. }
  218. int ath_rx_init(struct ath_softc *sc, int nbufs)
  219. {
  220. struct ath_common *common = ath9k_hw_common(sc->sc_ah);
  221. struct sk_buff *skb;
  222. struct ath_buf *bf;
  223. int error = 0;
  224. spin_lock_init(&sc->sc_pcu_lock);
  225. common->rx_bufsize = IEEE80211_MAX_MPDU_LEN / 2 +
  226. sc->sc_ah->caps.rx_status_len;
  227. if (sc->sc_ah->caps.hw_caps & ATH9K_HW_CAP_EDMA) {
  228. return ath_rx_edma_init(sc, nbufs);
  229. } else {
  230. ath_dbg(common, CONFIG, "cachelsz %u rxbufsize %u\n",
  231. common->cachelsz, common->rx_bufsize);
  232. /* Initialize rx descriptors */
  233. error = ath_descdma_setup(sc, &sc->rx.rxdma, &sc->rx.rxbuf,
  234. "rx", nbufs, 1, 0);
  235. if (error != 0) {
  236. ath_err(common,
  237. "failed to allocate rx descriptors: %d\n",
  238. error);
  239. goto err;
  240. }
  241. list_for_each_entry(bf, &sc->rx.rxbuf, list) {
  242. skb = ath_rxbuf_alloc(common, common->rx_bufsize,
  243. GFP_KERNEL);
  244. if (skb == NULL) {
  245. error = -ENOMEM;
  246. goto err;
  247. }
  248. bf->bf_mpdu = skb;
  249. bf->bf_buf_addr = dma_map_single(sc->dev, skb->data,
  250. common->rx_bufsize,
  251. DMA_FROM_DEVICE);
  252. if (unlikely(dma_mapping_error(sc->dev,
  253. bf->bf_buf_addr))) {
  254. dev_kfree_skb_any(skb);
  255. bf->bf_mpdu = NULL;
  256. bf->bf_buf_addr = 0;
  257. ath_err(common,
  258. "dma_mapping_error() on RX init\n");
  259. error = -ENOMEM;
  260. goto err;
  261. }
  262. }
  263. sc->rx.rxlink = NULL;
  264. }
  265. err:
  266. if (error)
  267. ath_rx_cleanup(sc);
  268. return error;
  269. }
  270. void ath_rx_cleanup(struct ath_softc *sc)
  271. {
  272. struct ath_hw *ah = sc->sc_ah;
  273. struct ath_common *common = ath9k_hw_common(ah);
  274. struct sk_buff *skb;
  275. struct ath_buf *bf;
  276. if (sc->sc_ah->caps.hw_caps & ATH9K_HW_CAP_EDMA) {
  277. ath_rx_edma_cleanup(sc);
  278. return;
  279. } else {
  280. list_for_each_entry(bf, &sc->rx.rxbuf, list) {
  281. skb = bf->bf_mpdu;
  282. if (skb) {
  283. dma_unmap_single(sc->dev, bf->bf_buf_addr,
  284. common->rx_bufsize,
  285. DMA_FROM_DEVICE);
  286. dev_kfree_skb(skb);
  287. bf->bf_buf_addr = 0;
  288. bf->bf_mpdu = NULL;
  289. }
  290. }
  291. }
  292. }
  293. /*
  294. * Calculate the receive filter according to the
  295. * operating mode and state:
  296. *
  297. * o always accept unicast, broadcast, and multicast traffic
  298. * o maintain current state of phy error reception (the hal
  299. * may enable phy error frames for noise immunity work)
  300. * o probe request frames are accepted only when operating in
  301. * hostap, adhoc, or monitor modes
  302. * o enable promiscuous mode according to the interface state
  303. * o accept beacons:
  304. * - when operating in adhoc mode so the 802.11 layer creates
  305. * node table entries for peers,
  306. * - when operating in station mode for collecting rssi data when
  307. * the station is otherwise quiet, or
  308. * - when operating as a repeater so we see repeater-sta beacons
  309. * - when scanning
  310. */
  311. u32 ath_calcrxfilter(struct ath_softc *sc)
  312. {
  313. u32 rfilt;
  314. rfilt = ATH9K_RX_FILTER_UCAST | ATH9K_RX_FILTER_BCAST
  315. | ATH9K_RX_FILTER_MCAST;
  316. if (sc->rx.rxfilter & FIF_PROBE_REQ)
  317. rfilt |= ATH9K_RX_FILTER_PROBEREQ;
  318. /*
  319. * Set promiscuous mode when FIF_PROMISC_IN_BSS is enabled for station
  320. * mode interface or when in monitor mode. AP mode does not need this
  321. * since it receives all in-BSS frames anyway.
  322. */
  323. if (sc->sc_ah->is_monitoring)
  324. rfilt |= ATH9K_RX_FILTER_PROM;
  325. if (sc->rx.rxfilter & FIF_CONTROL)
  326. rfilt |= ATH9K_RX_FILTER_CONTROL;
  327. if ((sc->sc_ah->opmode == NL80211_IFTYPE_STATION) &&
  328. (sc->nvifs <= 1) &&
  329. !(sc->rx.rxfilter & FIF_BCN_PRBRESP_PROMISC))
  330. rfilt |= ATH9K_RX_FILTER_MYBEACON;
  331. else
  332. rfilt |= ATH9K_RX_FILTER_BEACON;
  333. if ((sc->sc_ah->opmode == NL80211_IFTYPE_AP) ||
  334. (sc->rx.rxfilter & FIF_PSPOLL))
  335. rfilt |= ATH9K_RX_FILTER_PSPOLL;
  336. if (conf_is_ht(&sc->hw->conf))
  337. rfilt |= ATH9K_RX_FILTER_COMP_BAR;
  338. if (sc->nvifs > 1 || (sc->rx.rxfilter & FIF_OTHER_BSS)) {
  339. /* This is needed for older chips */
  340. if (sc->sc_ah->hw_version.macVersion <= AR_SREV_VERSION_9160)
  341. rfilt |= ATH9K_RX_FILTER_PROM;
  342. rfilt |= ATH9K_RX_FILTER_MCAST_BCAST_ALL;
  343. }
  344. if (AR_SREV_9550(sc->sc_ah))
  345. rfilt |= ATH9K_RX_FILTER_4ADDRESS;
  346. return rfilt;
  347. }
  348. int ath_startrecv(struct ath_softc *sc)
  349. {
  350. struct ath_hw *ah = sc->sc_ah;
  351. struct ath_buf *bf, *tbf;
  352. if (ah->caps.hw_caps & ATH9K_HW_CAP_EDMA) {
  353. ath_edma_start_recv(sc);
  354. return 0;
  355. }
  356. if (list_empty(&sc->rx.rxbuf))
  357. goto start_recv;
  358. sc->rx.rxlink = NULL;
  359. list_for_each_entry_safe(bf, tbf, &sc->rx.rxbuf, list) {
  360. ath_rx_buf_link(sc, bf);
  361. }
  362. /* We could have deleted elements so the list may be empty now */
  363. if (list_empty(&sc->rx.rxbuf))
  364. goto start_recv;
  365. bf = list_first_entry(&sc->rx.rxbuf, struct ath_buf, list);
  366. ath9k_hw_putrxbuf(ah, bf->bf_daddr);
  367. ath9k_hw_rxena(ah);
  368. start_recv:
  369. ath_opmode_init(sc);
  370. ath9k_hw_startpcureceive(ah, !!(sc->hw->conf.flags & IEEE80211_CONF_OFFCHANNEL));
  371. return 0;
  372. }
  373. static void ath_flushrecv(struct ath_softc *sc)
  374. {
  375. if (sc->sc_ah->caps.hw_caps & ATH9K_HW_CAP_EDMA)
  376. ath_rx_tasklet(sc, 1, true);
  377. ath_rx_tasklet(sc, 1, false);
  378. }
  379. bool ath_stoprecv(struct ath_softc *sc)
  380. {
  381. struct ath_hw *ah = sc->sc_ah;
  382. bool stopped, reset = false;
  383. ath9k_hw_abortpcurecv(ah);
  384. ath9k_hw_setrxfilter(ah, 0);
  385. stopped = ath9k_hw_stopdmarecv(ah, &reset);
  386. ath_flushrecv(sc);
  387. if (sc->sc_ah->caps.hw_caps & ATH9K_HW_CAP_EDMA)
  388. ath_edma_stop_recv(sc);
  389. else
  390. sc->rx.rxlink = NULL;
  391. if (!(ah->ah_flags & AH_UNPLUGGED) &&
  392. unlikely(!stopped)) {
  393. ath_err(ath9k_hw_common(sc->sc_ah),
  394. "Could not stop RX, we could be "
  395. "confusing the DMA engine when we start RX up\n");
  396. ATH_DBG_WARN_ON_ONCE(!stopped);
  397. }
  398. return stopped && !reset;
  399. }
  400. static bool ath_beacon_dtim_pending_cab(struct sk_buff *skb)
  401. {
  402. /* Check whether the Beacon frame has DTIM indicating buffered bc/mc */
  403. struct ieee80211_mgmt *mgmt;
  404. u8 *pos, *end, id, elen;
  405. struct ieee80211_tim_ie *tim;
  406. mgmt = (struct ieee80211_mgmt *)skb->data;
  407. pos = mgmt->u.beacon.variable;
  408. end = skb->data + skb->len;
  409. while (pos + 2 < end) {
  410. id = *pos++;
  411. elen = *pos++;
  412. if (pos + elen > end)
  413. break;
  414. if (id == WLAN_EID_TIM) {
  415. if (elen < sizeof(*tim))
  416. break;
  417. tim = (struct ieee80211_tim_ie *) pos;
  418. if (tim->dtim_count != 0)
  419. break;
  420. return tim->bitmap_ctrl & 0x01;
  421. }
  422. pos += elen;
  423. }
  424. return false;
  425. }
  426. static void ath_rx_ps_beacon(struct ath_softc *sc, struct sk_buff *skb)
  427. {
  428. struct ath_common *common = ath9k_hw_common(sc->sc_ah);
  429. if (skb->len < 24 + 8 + 2 + 2)
  430. return;
  431. sc->ps_flags &= ~PS_WAIT_FOR_BEACON;
  432. if (sc->ps_flags & PS_BEACON_SYNC) {
  433. sc->ps_flags &= ~PS_BEACON_SYNC;
  434. ath_dbg(common, PS,
  435. "Reconfigure Beacon timers based on timestamp from the AP\n");
  436. ath9k_set_beacon(sc);
  437. }
  438. if (ath_beacon_dtim_pending_cab(skb)) {
  439. /*
  440. * Remain awake waiting for buffered broadcast/multicast
  441. * frames. If the last broadcast/multicast frame is not
  442. * received properly, the next beacon frame will work as
  443. * a backup trigger for returning into NETWORK SLEEP state,
  444. * so we are waiting for it as well.
  445. */
  446. ath_dbg(common, PS,
  447. "Received DTIM beacon indicating buffered broadcast/multicast frame(s)\n");
  448. sc->ps_flags |= PS_WAIT_FOR_CAB | PS_WAIT_FOR_BEACON;
  449. return;
  450. }
  451. if (sc->ps_flags & PS_WAIT_FOR_CAB) {
  452. /*
  453. * This can happen if a broadcast frame is dropped or the AP
  454. * fails to send a frame indicating that all CAB frames have
  455. * been delivered.
  456. */
  457. sc->ps_flags &= ~PS_WAIT_FOR_CAB;
  458. ath_dbg(common, PS, "PS wait for CAB frames timed out\n");
  459. }
  460. }
  461. static void ath_rx_ps(struct ath_softc *sc, struct sk_buff *skb, bool mybeacon)
  462. {
  463. struct ieee80211_hdr *hdr;
  464. struct ath_common *common = ath9k_hw_common(sc->sc_ah);
  465. hdr = (struct ieee80211_hdr *)skb->data;
  466. /* Process Beacon and CAB receive in PS state */
  467. if (((sc->ps_flags & PS_WAIT_FOR_BEACON) || ath9k_check_auto_sleep(sc))
  468. && mybeacon) {
  469. ath_rx_ps_beacon(sc, skb);
  470. } else if ((sc->ps_flags & PS_WAIT_FOR_CAB) &&
  471. (ieee80211_is_data(hdr->frame_control) ||
  472. ieee80211_is_action(hdr->frame_control)) &&
  473. is_multicast_ether_addr(hdr->addr1) &&
  474. !ieee80211_has_moredata(hdr->frame_control)) {
  475. /*
  476. * No more broadcast/multicast frames to be received at this
  477. * point.
  478. */
  479. sc->ps_flags &= ~(PS_WAIT_FOR_CAB | PS_WAIT_FOR_BEACON);
  480. ath_dbg(common, PS,
  481. "All PS CAB frames received, back to sleep\n");
  482. } else if ((sc->ps_flags & PS_WAIT_FOR_PSPOLL_DATA) &&
  483. !is_multicast_ether_addr(hdr->addr1) &&
  484. !ieee80211_has_morefrags(hdr->frame_control)) {
  485. sc->ps_flags &= ~PS_WAIT_FOR_PSPOLL_DATA;
  486. ath_dbg(common, PS,
  487. "Going back to sleep after having received PS-Poll data (0x%lx)\n",
  488. sc->ps_flags & (PS_WAIT_FOR_BEACON |
  489. PS_WAIT_FOR_CAB |
  490. PS_WAIT_FOR_PSPOLL_DATA |
  491. PS_WAIT_FOR_TX_ACK));
  492. }
  493. }
  494. static bool ath_edma_get_buffers(struct ath_softc *sc,
  495. enum ath9k_rx_qtype qtype,
  496. struct ath_rx_status *rs,
  497. struct ath_buf **dest)
  498. {
  499. struct ath_rx_edma *rx_edma = &sc->rx.rx_edma[qtype];
  500. struct ath_hw *ah = sc->sc_ah;
  501. struct ath_common *common = ath9k_hw_common(ah);
  502. struct sk_buff *skb;
  503. struct ath_buf *bf;
  504. int ret;
  505. skb = skb_peek(&rx_edma->rx_fifo);
  506. if (!skb)
  507. return false;
  508. bf = SKB_CB_ATHBUF(skb);
  509. BUG_ON(!bf);
  510. dma_sync_single_for_cpu(sc->dev, bf->bf_buf_addr,
  511. common->rx_bufsize, DMA_FROM_DEVICE);
  512. ret = ath9k_hw_process_rxdesc_edma(ah, rs, skb->data);
  513. if (ret == -EINPROGRESS) {
  514. /*let device gain the buffer again*/
  515. dma_sync_single_for_device(sc->dev, bf->bf_buf_addr,
  516. common->rx_bufsize, DMA_FROM_DEVICE);
  517. return false;
  518. }
  519. __skb_unlink(skb, &rx_edma->rx_fifo);
  520. if (ret == -EINVAL) {
  521. /* corrupt descriptor, skip this one and the following one */
  522. list_add_tail(&bf->list, &sc->rx.rxbuf);
  523. ath_rx_edma_buf_link(sc, qtype);
  524. skb = skb_peek(&rx_edma->rx_fifo);
  525. if (skb) {
  526. bf = SKB_CB_ATHBUF(skb);
  527. BUG_ON(!bf);
  528. __skb_unlink(skb, &rx_edma->rx_fifo);
  529. list_add_tail(&bf->list, &sc->rx.rxbuf);
  530. ath_rx_edma_buf_link(sc, qtype);
  531. }
  532. bf = NULL;
  533. }
  534. *dest = bf;
  535. return true;
  536. }
  537. static struct ath_buf *ath_edma_get_next_rx_buf(struct ath_softc *sc,
  538. struct ath_rx_status *rs,
  539. enum ath9k_rx_qtype qtype)
  540. {
  541. struct ath_buf *bf = NULL;
  542. while (ath_edma_get_buffers(sc, qtype, rs, &bf)) {
  543. if (!bf)
  544. continue;
  545. return bf;
  546. }
  547. return NULL;
  548. }
  549. static struct ath_buf *ath_get_next_rx_buf(struct ath_softc *sc,
  550. struct ath_rx_status *rs)
  551. {
  552. struct ath_hw *ah = sc->sc_ah;
  553. struct ath_common *common = ath9k_hw_common(ah);
  554. struct ath_desc *ds;
  555. struct ath_buf *bf;
  556. int ret;
  557. if (list_empty(&sc->rx.rxbuf)) {
  558. sc->rx.rxlink = NULL;
  559. return NULL;
  560. }
  561. bf = list_first_entry(&sc->rx.rxbuf, struct ath_buf, list);
  562. ds = bf->bf_desc;
  563. /*
  564. * Must provide the virtual address of the current
  565. * descriptor, the physical address, and the virtual
  566. * address of the next descriptor in the h/w chain.
  567. * This allows the HAL to look ahead to see if the
  568. * hardware is done with a descriptor by checking the
  569. * done bit in the following descriptor and the address
  570. * of the current descriptor the DMA engine is working
  571. * on. All this is necessary because of our use of
  572. * a self-linked list to avoid rx overruns.
  573. */
  574. ret = ath9k_hw_rxprocdesc(ah, ds, rs);
  575. if (ret == -EINPROGRESS) {
  576. struct ath_rx_status trs;
  577. struct ath_buf *tbf;
  578. struct ath_desc *tds;
  579. memset(&trs, 0, sizeof(trs));
  580. if (list_is_last(&bf->list, &sc->rx.rxbuf)) {
  581. sc->rx.rxlink = NULL;
  582. return NULL;
  583. }
  584. tbf = list_entry(bf->list.next, struct ath_buf, list);
  585. /*
  586. * On some hardware the descriptor status words could
  587. * get corrupted, including the done bit. Because of
  588. * this, check if the next descriptor's done bit is
  589. * set or not.
  590. *
  591. * If the next descriptor's done bit is set, the current
  592. * descriptor has been corrupted. Force s/w to discard
  593. * this descriptor and continue...
  594. */
  595. tds = tbf->bf_desc;
  596. ret = ath9k_hw_rxprocdesc(ah, tds, &trs);
  597. if (ret == -EINPROGRESS)
  598. return NULL;
  599. }
  600. list_del(&bf->list);
  601. if (!bf->bf_mpdu)
  602. return bf;
  603. /*
  604. * Synchronize the DMA transfer with CPU before
  605. * 1. accessing the frame
  606. * 2. requeueing the same buffer to h/w
  607. */
  608. dma_sync_single_for_cpu(sc->dev, bf->bf_buf_addr,
  609. common->rx_bufsize,
  610. DMA_FROM_DEVICE);
  611. return bf;
  612. }
  613. /* Assumes you've already done the endian to CPU conversion */
  614. static bool ath9k_rx_accept(struct ath_common *common,
  615. struct ieee80211_hdr *hdr,
  616. struct ieee80211_rx_status *rxs,
  617. struct ath_rx_status *rx_stats,
  618. bool *decrypt_error)
  619. {
  620. struct ath_softc *sc = (struct ath_softc *) common->priv;
  621. bool is_mc, is_valid_tkip, strip_mic, mic_error;
  622. struct ath_hw *ah = common->ah;
  623. __le16 fc;
  624. u8 rx_status_len = ah->caps.rx_status_len;
  625. fc = hdr->frame_control;
  626. is_mc = !!is_multicast_ether_addr(hdr->addr1);
  627. is_valid_tkip = rx_stats->rs_keyix != ATH9K_RXKEYIX_INVALID &&
  628. test_bit(rx_stats->rs_keyix, common->tkip_keymap);
  629. strip_mic = is_valid_tkip && ieee80211_is_data(fc) &&
  630. ieee80211_has_protected(fc) &&
  631. !(rx_stats->rs_status &
  632. (ATH9K_RXERR_DECRYPT | ATH9K_RXERR_CRC | ATH9K_RXERR_MIC |
  633. ATH9K_RXERR_KEYMISS));
  634. /*
  635. * Key miss events are only relevant for pairwise keys where the
  636. * descriptor does contain a valid key index. This has been observed
  637. * mostly with CCMP encryption.
  638. */
  639. if (rx_stats->rs_keyix == ATH9K_RXKEYIX_INVALID ||
  640. !test_bit(rx_stats->rs_keyix, common->ccmp_keymap))
  641. rx_stats->rs_status &= ~ATH9K_RXERR_KEYMISS;
  642. if (!rx_stats->rs_datalen) {
  643. RX_STAT_INC(rx_len_err);
  644. return false;
  645. }
  646. /*
  647. * rs_status follows rs_datalen so if rs_datalen is too large
  648. * we can take a hint that hardware corrupted it, so ignore
  649. * those frames.
  650. */
  651. if (rx_stats->rs_datalen > (common->rx_bufsize - rx_status_len)) {
  652. RX_STAT_INC(rx_len_err);
  653. return false;
  654. }
  655. /* Only use error bits from the last fragment */
  656. if (rx_stats->rs_more)
  657. return true;
  658. mic_error = is_valid_tkip && !ieee80211_is_ctl(fc) &&
  659. !ieee80211_has_morefrags(fc) &&
  660. !(le16_to_cpu(hdr->seq_ctrl) & IEEE80211_SCTL_FRAG) &&
  661. (rx_stats->rs_status & ATH9K_RXERR_MIC);
  662. /*
  663. * The rx_stats->rs_status will not be set until the end of the
  664. * chained descriptors so it can be ignored if rs_more is set. The
  665. * rs_more will be false at the last element of the chained
  666. * descriptors.
  667. */
  668. if (rx_stats->rs_status != 0) {
  669. u8 status_mask;
  670. if (rx_stats->rs_status & ATH9K_RXERR_CRC) {
  671. rxs->flag |= RX_FLAG_FAILED_FCS_CRC;
  672. mic_error = false;
  673. }
  674. if (rx_stats->rs_status & ATH9K_RXERR_PHY)
  675. return false;
  676. if ((rx_stats->rs_status & ATH9K_RXERR_DECRYPT) ||
  677. (!is_mc && (rx_stats->rs_status & ATH9K_RXERR_KEYMISS))) {
  678. *decrypt_error = true;
  679. mic_error = false;
  680. }
  681. /*
  682. * Reject error frames with the exception of
  683. * decryption and MIC failures. For monitor mode,
  684. * we also ignore the CRC error.
  685. */
  686. status_mask = ATH9K_RXERR_DECRYPT | ATH9K_RXERR_MIC |
  687. ATH9K_RXERR_KEYMISS;
  688. if (ah->is_monitoring && (sc->rx.rxfilter & FIF_FCSFAIL))
  689. status_mask |= ATH9K_RXERR_CRC;
  690. if (rx_stats->rs_status & ~status_mask)
  691. return false;
  692. }
  693. /*
  694. * For unicast frames the MIC error bit can have false positives,
  695. * so all MIC error reports need to be validated in software.
  696. * False negatives are not common, so skip software verification
  697. * if the hardware considers the MIC valid.
  698. */
  699. if (strip_mic)
  700. rxs->flag |= RX_FLAG_MMIC_STRIPPED;
  701. else if (is_mc && mic_error)
  702. rxs->flag |= RX_FLAG_MMIC_ERROR;
  703. return true;
  704. }
  705. static int ath9k_process_rate(struct ath_common *common,
  706. struct ieee80211_hw *hw,
  707. struct ath_rx_status *rx_stats,
  708. struct ieee80211_rx_status *rxs)
  709. {
  710. struct ieee80211_supported_band *sband;
  711. enum ieee80211_band band;
  712. unsigned int i = 0;
  713. struct ath_softc __maybe_unused *sc = common->priv;
  714. band = hw->conf.channel->band;
  715. sband = hw->wiphy->bands[band];
  716. if (rx_stats->rs_rate & 0x80) {
  717. /* HT rate */
  718. rxs->flag |= RX_FLAG_HT;
  719. if (rx_stats->rs_flags & ATH9K_RX_2040)
  720. rxs->flag |= RX_FLAG_40MHZ;
  721. if (rx_stats->rs_flags & ATH9K_RX_GI)
  722. rxs->flag |= RX_FLAG_SHORT_GI;
  723. rxs->rate_idx = rx_stats->rs_rate & 0x7f;
  724. return 0;
  725. }
  726. for (i = 0; i < sband->n_bitrates; i++) {
  727. if (sband->bitrates[i].hw_value == rx_stats->rs_rate) {
  728. rxs->rate_idx = i;
  729. return 0;
  730. }
  731. if (sband->bitrates[i].hw_value_short == rx_stats->rs_rate) {
  732. rxs->flag |= RX_FLAG_SHORTPRE;
  733. rxs->rate_idx = i;
  734. return 0;
  735. }
  736. }
  737. /*
  738. * No valid hardware bitrate found -- we should not get here
  739. * because hardware has already validated this frame as OK.
  740. */
  741. ath_dbg(common, ANY,
  742. "unsupported hw bitrate detected 0x%02x using 1 Mbit\n",
  743. rx_stats->rs_rate);
  744. RX_STAT_INC(rx_rate_err);
  745. return -EINVAL;
  746. }
  747. static void ath9k_process_rssi(struct ath_common *common,
  748. struct ieee80211_hw *hw,
  749. struct ieee80211_hdr *hdr,
  750. struct ath_rx_status *rx_stats)
  751. {
  752. struct ath_softc *sc = hw->priv;
  753. struct ath_hw *ah = common->ah;
  754. int last_rssi;
  755. int rssi = rx_stats->rs_rssi;
  756. if (!rx_stats->is_mybeacon ||
  757. ((ah->opmode != NL80211_IFTYPE_STATION) &&
  758. (ah->opmode != NL80211_IFTYPE_ADHOC)))
  759. return;
  760. if (rx_stats->rs_rssi != ATH9K_RSSI_BAD && !rx_stats->rs_moreaggr)
  761. ATH_RSSI_LPF(sc->last_rssi, rx_stats->rs_rssi);
  762. last_rssi = sc->last_rssi;
  763. if (likely(last_rssi != ATH_RSSI_DUMMY_MARKER))
  764. rssi = ATH_EP_RND(last_rssi, ATH_RSSI_EP_MULTIPLIER);
  765. if (rssi < 0)
  766. rssi = 0;
  767. /* Update Beacon RSSI, this is used by ANI. */
  768. ah->stats.avgbrssi = rssi;
  769. }
  770. /*
  771. * For Decrypt or Demic errors, we only mark packet status here and always push
  772. * up the frame up to let mac80211 handle the actual error case, be it no
  773. * decryption key or real decryption error. This let us keep statistics there.
  774. */
  775. static int ath9k_rx_skb_preprocess(struct ath_common *common,
  776. struct ieee80211_hw *hw,
  777. struct ieee80211_hdr *hdr,
  778. struct ath_rx_status *rx_stats,
  779. struct ieee80211_rx_status *rx_status,
  780. bool *decrypt_error)
  781. {
  782. struct ath_hw *ah = common->ah;
  783. /*
  784. * everything but the rate is checked here, the rate check is done
  785. * separately to avoid doing two lookups for a rate for each frame.
  786. */
  787. if (!ath9k_rx_accept(common, hdr, rx_status, rx_stats, decrypt_error))
  788. return -EINVAL;
  789. /* Only use status info from the last fragment */
  790. if (rx_stats->rs_more)
  791. return 0;
  792. ath9k_process_rssi(common, hw, hdr, rx_stats);
  793. if (ath9k_process_rate(common, hw, rx_stats, rx_status))
  794. return -EINVAL;
  795. rx_status->band = hw->conf.channel->band;
  796. rx_status->freq = hw->conf.channel->center_freq;
  797. rx_status->signal = ah->noise + rx_stats->rs_rssi;
  798. rx_status->antenna = rx_stats->rs_antenna;
  799. rx_status->flag |= RX_FLAG_MACTIME_END;
  800. if (rx_stats->rs_moreaggr)
  801. rx_status->flag |= RX_FLAG_NO_SIGNAL_VAL;
  802. return 0;
  803. }
  804. static void ath9k_rx_skb_postprocess(struct ath_common *common,
  805. struct sk_buff *skb,
  806. struct ath_rx_status *rx_stats,
  807. struct ieee80211_rx_status *rxs,
  808. bool decrypt_error)
  809. {
  810. struct ath_hw *ah = common->ah;
  811. struct ieee80211_hdr *hdr;
  812. int hdrlen, padpos, padsize;
  813. u8 keyix;
  814. __le16 fc;
  815. /* see if any padding is done by the hw and remove it */
  816. hdr = (struct ieee80211_hdr *) skb->data;
  817. hdrlen = ieee80211_get_hdrlen_from_skb(skb);
  818. fc = hdr->frame_control;
  819. padpos = ath9k_cmn_padpos(hdr->frame_control);
  820. /* The MAC header is padded to have 32-bit boundary if the
  821. * packet payload is non-zero. The general calculation for
  822. * padsize would take into account odd header lengths:
  823. * padsize = (4 - padpos % 4) % 4; However, since only
  824. * even-length headers are used, padding can only be 0 or 2
  825. * bytes and we can optimize this a bit. In addition, we must
  826. * not try to remove padding from short control frames that do
  827. * not have payload. */
  828. padsize = padpos & 3;
  829. if (padsize && skb->len>=padpos+padsize+FCS_LEN) {
  830. memmove(skb->data + padsize, skb->data, padpos);
  831. skb_pull(skb, padsize);
  832. }
  833. keyix = rx_stats->rs_keyix;
  834. if (!(keyix == ATH9K_RXKEYIX_INVALID) && !decrypt_error &&
  835. ieee80211_has_protected(fc)) {
  836. rxs->flag |= RX_FLAG_DECRYPTED;
  837. } else if (ieee80211_has_protected(fc)
  838. && !decrypt_error && skb->len >= hdrlen + 4) {
  839. keyix = skb->data[hdrlen + 3] >> 6;
  840. if (test_bit(keyix, common->keymap))
  841. rxs->flag |= RX_FLAG_DECRYPTED;
  842. }
  843. if (ah->sw_mgmt_crypto &&
  844. (rxs->flag & RX_FLAG_DECRYPTED) &&
  845. ieee80211_is_mgmt(fc))
  846. /* Use software decrypt for management frames. */
  847. rxs->flag &= ~RX_FLAG_DECRYPTED;
  848. }
  849. static s8 fix_rssi_inv_only(u8 rssi_val)
  850. {
  851. if (rssi_val == 128)
  852. rssi_val = 0;
  853. return (s8) rssi_val;
  854. }
  855. static void ath_process_fft(struct ath_softc *sc, struct ieee80211_hdr *hdr,
  856. struct ath_rx_status *rs, u64 tsf)
  857. {
  858. #ifdef CONFIG_ATH_DEBUG
  859. struct ath_hw *ah = sc->sc_ah;
  860. u8 bins[SPECTRAL_HT20_NUM_BINS];
  861. u8 *vdata = (u8 *)hdr;
  862. struct fft_sample_ht20 fft_sample;
  863. struct ath_radar_info *radar_info;
  864. struct ath_ht20_mag_info *mag_info;
  865. int len = rs->rs_datalen;
  866. int i, dc_pos;
  867. /* AR9280 and before report via ATH9K_PHYERR_RADAR, AR93xx and newer
  868. * via ATH9K_PHYERR_SPECTRAL. Haven't seen ATH9K_PHYERR_FALSE_RADAR_EXT
  869. * yet, but this is supposed to be possible as well.
  870. */
  871. if (rs->rs_phyerr != ATH9K_PHYERR_RADAR &&
  872. rs->rs_phyerr != ATH9K_PHYERR_FALSE_RADAR_EXT &&
  873. rs->rs_phyerr != ATH9K_PHYERR_SPECTRAL)
  874. return;
  875. /* Variation in the data length is possible and will be fixed later.
  876. * Note that we only support HT20 for now.
  877. *
  878. * TODO: add HT20_40 support as well.
  879. */
  880. if ((len > SPECTRAL_HT20_TOTAL_DATA_LEN + 2) ||
  881. (len < SPECTRAL_HT20_TOTAL_DATA_LEN - 1))
  882. return;
  883. /* check if spectral scan bit is set. This does not have to be checked
  884. * if received through a SPECTRAL phy error, but shouldn't hurt.
  885. */
  886. radar_info = ((struct ath_radar_info *)&vdata[len]) - 1;
  887. if (!(radar_info->pulse_bw_info & SPECTRAL_SCAN_BITMASK))
  888. return;
  889. fft_sample.tlv.type = ATH_FFT_SAMPLE_HT20;
  890. fft_sample.tlv.length = sizeof(fft_sample) - sizeof(fft_sample.tlv);
  891. fft_sample.freq = ah->curchan->chan->center_freq;
  892. fft_sample.rssi = fix_rssi_inv_only(rs->rs_rssi_ctl0);
  893. fft_sample.noise = ah->noise;
  894. switch (len - SPECTRAL_HT20_TOTAL_DATA_LEN) {
  895. case 0:
  896. /* length correct, nothing to do. */
  897. memcpy(bins, vdata, SPECTRAL_HT20_NUM_BINS);
  898. break;
  899. case -1:
  900. /* first byte missing, duplicate it. */
  901. memcpy(&bins[1], vdata, SPECTRAL_HT20_NUM_BINS - 1);
  902. bins[0] = vdata[0];
  903. break;
  904. case 2:
  905. /* MAC added 2 extra bytes at bin 30 and 32, remove them. */
  906. memcpy(bins, vdata, 30);
  907. bins[30] = vdata[31];
  908. memcpy(&bins[31], &vdata[33], SPECTRAL_HT20_NUM_BINS - 31);
  909. break;
  910. case 1:
  911. /* MAC added 2 extra bytes AND first byte is missing. */
  912. bins[0] = vdata[0];
  913. memcpy(&bins[0], vdata, 30);
  914. bins[31] = vdata[31];
  915. memcpy(&bins[32], &vdata[33], SPECTRAL_HT20_NUM_BINS - 32);
  916. break;
  917. default:
  918. return;
  919. }
  920. /* DC value (value in the middle) is the blind spot of the spectral
  921. * sample and invalid, interpolate it.
  922. */
  923. dc_pos = SPECTRAL_HT20_NUM_BINS / 2;
  924. bins[dc_pos] = (bins[dc_pos + 1] + bins[dc_pos - 1]) / 2;
  925. /* mag data is at the end of the frame, in front of radar_info */
  926. mag_info = ((struct ath_ht20_mag_info *)radar_info) - 1;
  927. /* Apply exponent and grab further auxiliary information. */
  928. for (i = 0; i < SPECTRAL_HT20_NUM_BINS; i++)
  929. fft_sample.data[i] = bins[i] << mag_info->max_exp;
  930. fft_sample.max_magnitude = spectral_max_magnitude(mag_info->all_bins);
  931. fft_sample.max_index = spectral_max_index(mag_info->all_bins);
  932. fft_sample.bitmap_weight = spectral_bitmap_weight(mag_info->all_bins);
  933. fft_sample.tsf = tsf;
  934. ath_debug_send_fft_sample(sc, &fft_sample.tlv);
  935. #endif
  936. }
  937. int ath_rx_tasklet(struct ath_softc *sc, int flush, bool hp)
  938. {
  939. struct ath_buf *bf;
  940. struct sk_buff *skb = NULL, *requeue_skb, *hdr_skb;
  941. struct ieee80211_rx_status *rxs;
  942. struct ath_hw *ah = sc->sc_ah;
  943. struct ath_common *common = ath9k_hw_common(ah);
  944. struct ieee80211_hw *hw = sc->hw;
  945. struct ieee80211_hdr *hdr;
  946. int retval;
  947. struct ath_rx_status rs;
  948. enum ath9k_rx_qtype qtype;
  949. bool edma = !!(ah->caps.hw_caps & ATH9K_HW_CAP_EDMA);
  950. int dma_type;
  951. u8 rx_status_len = ah->caps.rx_status_len;
  952. u64 tsf = 0;
  953. u32 tsf_lower = 0;
  954. unsigned long flags;
  955. if (edma)
  956. dma_type = DMA_BIDIRECTIONAL;
  957. else
  958. dma_type = DMA_FROM_DEVICE;
  959. qtype = hp ? ATH9K_RX_QUEUE_HP : ATH9K_RX_QUEUE_LP;
  960. tsf = ath9k_hw_gettsf64(ah);
  961. tsf_lower = tsf & 0xffffffff;
  962. do {
  963. bool decrypt_error = false;
  964. memset(&rs, 0, sizeof(rs));
  965. if (edma)
  966. bf = ath_edma_get_next_rx_buf(sc, &rs, qtype);
  967. else
  968. bf = ath_get_next_rx_buf(sc, &rs);
  969. if (!bf)
  970. break;
  971. skb = bf->bf_mpdu;
  972. if (!skb)
  973. continue;
  974. /*
  975. * Take frame header from the first fragment and RX status from
  976. * the last one.
  977. */
  978. if (sc->rx.frag)
  979. hdr_skb = sc->rx.frag;
  980. else
  981. hdr_skb = skb;
  982. hdr = (struct ieee80211_hdr *) (hdr_skb->data + rx_status_len);
  983. rxs = IEEE80211_SKB_RXCB(hdr_skb);
  984. if (ieee80211_is_beacon(hdr->frame_control)) {
  985. RX_STAT_INC(rx_beacons);
  986. if (!is_zero_ether_addr(common->curbssid) &&
  987. ether_addr_equal(hdr->addr3, common->curbssid))
  988. rs.is_mybeacon = true;
  989. else
  990. rs.is_mybeacon = false;
  991. }
  992. else
  993. rs.is_mybeacon = false;
  994. if (ieee80211_is_data_present(hdr->frame_control) &&
  995. !ieee80211_is_qos_nullfunc(hdr->frame_control))
  996. sc->rx.num_pkts++;
  997. ath_debug_stat_rx(sc, &rs);
  998. memset(rxs, 0, sizeof(struct ieee80211_rx_status));
  999. rxs->mactime = (tsf & ~0xffffffffULL) | rs.rs_tstamp;
  1000. if (rs.rs_tstamp > tsf_lower &&
  1001. unlikely(rs.rs_tstamp - tsf_lower > 0x10000000))
  1002. rxs->mactime -= 0x100000000ULL;
  1003. if (rs.rs_tstamp < tsf_lower &&
  1004. unlikely(tsf_lower - rs.rs_tstamp > 0x10000000))
  1005. rxs->mactime += 0x100000000ULL;
  1006. if ((rs.rs_status & ATH9K_RXERR_PHY))
  1007. ath_process_fft(sc, hdr, &rs, rxs->mactime);
  1008. retval = ath9k_rx_skb_preprocess(common, hw, hdr, &rs,
  1009. rxs, &decrypt_error);
  1010. if (retval)
  1011. goto requeue_drop_frag;
  1012. if (rs.is_mybeacon) {
  1013. sc->hw_busy_count = 0;
  1014. ath_start_rx_poll(sc, 3);
  1015. }
  1016. /* Ensure we always have an skb to requeue once we are done
  1017. * processing the current buffer's skb */
  1018. requeue_skb = ath_rxbuf_alloc(common, common->rx_bufsize, GFP_ATOMIC);
  1019. /* If there is no memory we ignore the current RX'd frame,
  1020. * tell hardware it can give us a new frame using the old
  1021. * skb and put it at the tail of the sc->rx.rxbuf list for
  1022. * processing. */
  1023. if (!requeue_skb) {
  1024. RX_STAT_INC(rx_oom_err);
  1025. goto requeue_drop_frag;
  1026. }
  1027. /* Unmap the frame */
  1028. dma_unmap_single(sc->dev, bf->bf_buf_addr,
  1029. common->rx_bufsize,
  1030. dma_type);
  1031. skb_put(skb, rs.rs_datalen + ah->caps.rx_status_len);
  1032. if (ah->caps.rx_status_len)
  1033. skb_pull(skb, ah->caps.rx_status_len);
  1034. if (!rs.rs_more)
  1035. ath9k_rx_skb_postprocess(common, hdr_skb, &rs,
  1036. rxs, decrypt_error);
  1037. /* We will now give hardware our shiny new allocated skb */
  1038. bf->bf_mpdu = requeue_skb;
  1039. bf->bf_buf_addr = dma_map_single(sc->dev, requeue_skb->data,
  1040. common->rx_bufsize,
  1041. dma_type);
  1042. if (unlikely(dma_mapping_error(sc->dev,
  1043. bf->bf_buf_addr))) {
  1044. dev_kfree_skb_any(requeue_skb);
  1045. bf->bf_mpdu = NULL;
  1046. bf->bf_buf_addr = 0;
  1047. ath_err(common, "dma_mapping_error() on RX\n");
  1048. ieee80211_rx(hw, skb);
  1049. break;
  1050. }
  1051. if (rs.rs_more) {
  1052. RX_STAT_INC(rx_frags);
  1053. /*
  1054. * rs_more indicates chained descriptors which can be
  1055. * used to link buffers together for a sort of
  1056. * scatter-gather operation.
  1057. */
  1058. if (sc->rx.frag) {
  1059. /* too many fragments - cannot handle frame */
  1060. dev_kfree_skb_any(sc->rx.frag);
  1061. dev_kfree_skb_any(skb);
  1062. RX_STAT_INC(rx_too_many_frags_err);
  1063. skb = NULL;
  1064. }
  1065. sc->rx.frag = skb;
  1066. goto requeue;
  1067. }
  1068. if (sc->rx.frag) {
  1069. int space = skb->len - skb_tailroom(hdr_skb);
  1070. if (pskb_expand_head(hdr_skb, 0, space, GFP_ATOMIC) < 0) {
  1071. dev_kfree_skb(skb);
  1072. RX_STAT_INC(rx_oom_err);
  1073. goto requeue_drop_frag;
  1074. }
  1075. sc->rx.frag = NULL;
  1076. skb_copy_from_linear_data(skb, skb_put(hdr_skb, skb->len),
  1077. skb->len);
  1078. dev_kfree_skb_any(skb);
  1079. skb = hdr_skb;
  1080. }
  1081. if (ah->caps.hw_caps & ATH9K_HW_CAP_ANT_DIV_COMB) {
  1082. /*
  1083. * change the default rx antenna if rx diversity
  1084. * chooses the other antenna 3 times in a row.
  1085. */
  1086. if (sc->rx.defant != rs.rs_antenna) {
  1087. if (++sc->rx.rxotherant >= 3)
  1088. ath_setdefantenna(sc, rs.rs_antenna);
  1089. } else {
  1090. sc->rx.rxotherant = 0;
  1091. }
  1092. }
  1093. if (rxs->flag & RX_FLAG_MMIC_STRIPPED)
  1094. skb_trim(skb, skb->len - 8);
  1095. spin_lock_irqsave(&sc->sc_pm_lock, flags);
  1096. if ((sc->ps_flags & (PS_WAIT_FOR_BEACON |
  1097. PS_WAIT_FOR_CAB |
  1098. PS_WAIT_FOR_PSPOLL_DATA)) ||
  1099. ath9k_check_auto_sleep(sc))
  1100. ath_rx_ps(sc, skb, rs.is_mybeacon);
  1101. spin_unlock_irqrestore(&sc->sc_pm_lock, flags);
  1102. if ((ah->caps.hw_caps & ATH9K_HW_CAP_ANT_DIV_COMB) && sc->ant_rx == 3)
  1103. ath_ant_comb_scan(sc, &rs);
  1104. ieee80211_rx(hw, skb);
  1105. requeue_drop_frag:
  1106. if (sc->rx.frag) {
  1107. dev_kfree_skb_any(sc->rx.frag);
  1108. sc->rx.frag = NULL;
  1109. }
  1110. requeue:
  1111. list_add_tail(&bf->list, &sc->rx.rxbuf);
  1112. if (flush)
  1113. continue;
  1114. if (edma) {
  1115. ath_rx_edma_buf_link(sc, qtype);
  1116. } else {
  1117. ath_rx_buf_link(sc, bf);
  1118. ath9k_hw_rxena(ah);
  1119. }
  1120. } while (1);
  1121. if (!(ah->imask & ATH9K_INT_RXEOL)) {
  1122. ah->imask |= (ATH9K_INT_RXEOL | ATH9K_INT_RXORN);
  1123. ath9k_hw_set_interrupts(ah);
  1124. }
  1125. return 0;
  1126. }