Merge remote-tracking branches 'spi/topic/altera', 'spi/topic/at79', 'spi/topic/bcm...
[sfrench/cifs-2.6.git] / drivers / net / wireless / intel / iwlwifi / mvm / rxmq.c
1 /******************************************************************************
2  *
3  * This file is provided under a dual BSD/GPLv2 license.  When using or
4  * redistributing this file, you may do so under either license.
5  *
6  * GPL LICENSE SUMMARY
7  *
8  * Copyright(c) 2012 - 2014 Intel Corporation. All rights reserved.
9  * Copyright(c) 2013 - 2015 Intel Mobile Communications GmbH
10  * Copyright(c) 2015 - 2017 Intel Deutschland GmbH
11  *
12  * This program is free software; you can redistribute it and/or modify
13  * it under the terms of version 2 of the GNU General Public License as
14  * published by the Free Software Foundation.
15  *
16  * This program is distributed in the hope that it will be useful, but
17  * WITHOUT ANY WARRANTY; without even the implied warranty of
18  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
19  * General Public License for more details.
20  *
21  * The full GNU General Public License is included in this distribution
22  * in the file called COPYING.
23  *
24  * Contact Information:
25  *  Intel Linux Wireless <ilw@linux.intel.com>
26  * Intel Corporation, 5200 N.E. Elam Young Parkway, Hillsboro, OR 97124-6497
27  *
28  * BSD LICENSE
29  *
30  * Copyright(c) 2012 - 2014 Intel Corporation. All rights reserved.
31  * Copyright(c) 2013 - 2015 Intel Mobile Communications GmbH
32  * Copyright(c) 2015 - 2017 Intel Deutschland GmbH
33  * All rights reserved.
34  *
35  * Redistribution and use in source and binary forms, with or without
36  * modification, are permitted provided that the following conditions
37  * are met:
38  *
39  *  * Redistributions of source code must retain the above copyright
40  *    notice, this list of conditions and the following disclaimer.
41  *  * Redistributions in binary form must reproduce the above copyright
42  *    notice, this list of conditions and the following disclaimer in
43  *    the documentation and/or other materials provided with the
44  *    distribution.
45  *  * Neither the name Intel Corporation nor the names of its
46  *    contributors may be used to endorse or promote products derived
47  *    from this software without specific prior written permission.
48  *
49  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
50  * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
51  * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
52  * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
53  * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
54  * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
55  * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
56  * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
57  * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
58  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
59  * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
60  *****************************************************************************/
61 #include <linux/etherdevice.h>
62 #include <linux/skbuff.h>
63 #include "iwl-trans.h"
64 #include "mvm.h"
65 #include "fw-api.h"
66 #include "fw-dbg.h"
67
68 static inline int iwl_mvm_check_pn(struct iwl_mvm *mvm, struct sk_buff *skb,
69                                    int queue, struct ieee80211_sta *sta)
70 {
71         struct iwl_mvm_sta *mvmsta;
72         struct ieee80211_hdr *hdr = (struct ieee80211_hdr *)skb->data;
73         struct ieee80211_rx_status *stats = IEEE80211_SKB_RXCB(skb);
74         struct iwl_mvm_key_pn *ptk_pn;
75         u8 tid, keyidx;
76         u8 pn[IEEE80211_CCMP_PN_LEN];
77         u8 *extiv;
78
79         /* do PN checking */
80
81         /* multicast and non-data only arrives on default queue */
82         if (!ieee80211_is_data(hdr->frame_control) ||
83             is_multicast_ether_addr(hdr->addr1))
84                 return 0;
85
86         /* do not check PN for open AP */
87         if (!(stats->flag & RX_FLAG_DECRYPTED))
88                 return 0;
89
90         /*
91          * avoid checking for default queue - we don't want to replicate
92          * all the logic that's necessary for checking the PN on fragmented
93          * frames, leave that to mac80211
94          */
95         if (queue == 0)
96                 return 0;
97
98         /* if we are here - this for sure is either CCMP or GCMP */
99         if (IS_ERR_OR_NULL(sta)) {
100                 IWL_ERR(mvm,
101                         "expected hw-decrypted unicast frame for station\n");
102                 return -1;
103         }
104
105         mvmsta = iwl_mvm_sta_from_mac80211(sta);
106
107         extiv = (u8 *)hdr + ieee80211_hdrlen(hdr->frame_control);
108         keyidx = extiv[3] >> 6;
109
110         ptk_pn = rcu_dereference(mvmsta->ptk_pn[keyidx]);
111         if (!ptk_pn)
112                 return -1;
113
114         if (ieee80211_is_data_qos(hdr->frame_control))
115                 tid = *ieee80211_get_qos_ctl(hdr) & IEEE80211_QOS_CTL_TID_MASK;
116         else
117                 tid = 0;
118
119         /* we don't use HCCA/802.11 QoS TSPECs, so drop such frames */
120         if (tid >= IWL_MAX_TID_COUNT)
121                 return -1;
122
123         /* load pn */
124         pn[0] = extiv[7];
125         pn[1] = extiv[6];
126         pn[2] = extiv[5];
127         pn[3] = extiv[4];
128         pn[4] = extiv[1];
129         pn[5] = extiv[0];
130
131         if (memcmp(pn, ptk_pn->q[queue].pn[tid],
132                    IEEE80211_CCMP_PN_LEN) <= 0)
133                 return -1;
134
135         if (!(stats->flag & RX_FLAG_AMSDU_MORE))
136                 memcpy(ptk_pn->q[queue].pn[tid], pn, IEEE80211_CCMP_PN_LEN);
137         stats->flag |= RX_FLAG_PN_VALIDATED;
138
139         return 0;
140 }
141
142 /* iwl_mvm_create_skb Adds the rxb to a new skb */
143 static void iwl_mvm_create_skb(struct sk_buff *skb, struct ieee80211_hdr *hdr,
144                                u16 len, u8 crypt_len,
145                                struct iwl_rx_cmd_buffer *rxb)
146 {
147         struct iwl_rx_packet *pkt = rxb_addr(rxb);
148         struct iwl_rx_mpdu_desc *desc = (void *)pkt->data;
149         unsigned int headlen, fraglen, pad_len = 0;
150         unsigned int hdrlen = ieee80211_hdrlen(hdr->frame_control);
151
152         if (desc->mac_flags2 & IWL_RX_MPDU_MFLG2_PAD) {
153                 pad_len = 2;
154
155                 /*
156                  * If the device inserted padding it means that (it thought)
157                  * the 802.11 header wasn't a multiple of 4 bytes long. In
158                  * this case, reserve two bytes at the start of the SKB to
159                  * align the payload properly in case we end up copying it.
160                  */
161                 skb_reserve(skb, pad_len);
162         }
163         len -= pad_len;
164
165         /* If frame is small enough to fit in skb->head, pull it completely.
166          * If not, only pull ieee80211_hdr (including crypto if present, and
167          * an additional 8 bytes for SNAP/ethertype, see below) so that
168          * splice() or TCP coalesce are more efficient.
169          *
170          * Since, in addition, ieee80211_data_to_8023() always pull in at
171          * least 8 bytes (possibly more for mesh) we can do the same here
172          * to save the cost of doing it later. That still doesn't pull in
173          * the actual IP header since the typical case has a SNAP header.
174          * If the latter changes (there are efforts in the standards group
175          * to do so) we should revisit this and ieee80211_data_to_8023().
176          */
177         headlen = (len <= skb_tailroom(skb)) ? len :
178                                                hdrlen + crypt_len + 8;
179
180         /* The firmware may align the packet to DWORD.
181          * The padding is inserted after the IV.
182          * After copying the header + IV skip the padding if
183          * present before copying packet data.
184          */
185         hdrlen += crypt_len;
186         skb_put_data(skb, hdr, hdrlen);
187         skb_put_data(skb, (u8 *)hdr + hdrlen + pad_len, headlen - hdrlen);
188
189         fraglen = len - headlen;
190
191         if (fraglen) {
192                 int offset = (void *)hdr + headlen + pad_len -
193                              rxb_addr(rxb) + rxb_offset(rxb);
194
195                 skb_add_rx_frag(skb, 0, rxb_steal_page(rxb), offset,
196                                 fraglen, rxb->truesize);
197         }
198 }
199
200 /* iwl_mvm_pass_packet_to_mac80211 - passes the packet for mac80211 */
201 static void iwl_mvm_pass_packet_to_mac80211(struct iwl_mvm *mvm,
202                                             struct napi_struct *napi,
203                                             struct sk_buff *skb, int queue,
204                                             struct ieee80211_sta *sta)
205 {
206         if (iwl_mvm_check_pn(mvm, skb, queue, sta))
207                 kfree_skb(skb);
208         else
209                 ieee80211_rx_napi(mvm->hw, sta, skb, napi);
210 }
211
212 static void iwl_mvm_get_signal_strength(struct iwl_mvm *mvm,
213                                         struct iwl_rx_mpdu_desc *desc,
214                                         struct ieee80211_rx_status *rx_status)
215 {
216         int energy_a, energy_b, max_energy;
217
218         energy_a = desc->energy_a;
219         energy_a = energy_a ? -energy_a : S8_MIN;
220         energy_b = desc->energy_b;
221         energy_b = energy_b ? -energy_b : S8_MIN;
222         max_energy = max(energy_a, energy_b);
223
224         IWL_DEBUG_STATS(mvm, "energy In A %d B %d, and max %d\n",
225                         energy_a, energy_b, max_energy);
226
227         rx_status->signal = max_energy;
228         rx_status->chains = 0; /* TODO: phy info */
229         rx_status->chain_signal[0] = energy_a;
230         rx_status->chain_signal[1] = energy_b;
231         rx_status->chain_signal[2] = S8_MIN;
232 }
233
234 static int iwl_mvm_rx_crypto(struct iwl_mvm *mvm, struct ieee80211_hdr *hdr,
235                              struct ieee80211_rx_status *stats,
236                              struct iwl_rx_mpdu_desc *desc, int queue,
237                              u8 *crypt_len)
238 {
239         u16 status = le16_to_cpu(desc->status);
240
241         if (!ieee80211_has_protected(hdr->frame_control) ||
242             (status & IWL_RX_MPDU_STATUS_SEC_MASK) ==
243             IWL_RX_MPDU_STATUS_SEC_NONE)
244                 return 0;
245
246         /* TODO: handle packets encrypted with unknown alg */
247
248         switch (status & IWL_RX_MPDU_STATUS_SEC_MASK) {
249         case IWL_RX_MPDU_STATUS_SEC_CCM:
250         case IWL_RX_MPDU_STATUS_SEC_GCM:
251                 BUILD_BUG_ON(IEEE80211_CCMP_PN_LEN != IEEE80211_GCMP_PN_LEN);
252                 /* alg is CCM: check MIC only */
253                 if (!(status & IWL_RX_MPDU_STATUS_MIC_OK))
254                         return -1;
255
256                 stats->flag |= RX_FLAG_DECRYPTED;
257                 *crypt_len = IEEE80211_CCMP_HDR_LEN;
258                 return 0;
259         case IWL_RX_MPDU_STATUS_SEC_TKIP:
260                 /* Don't drop the frame and decrypt it in SW */
261                 if (!(status & IWL_RX_MPDU_RES_STATUS_TTAK_OK))
262                         return 0;
263
264                 *crypt_len = IEEE80211_TKIP_IV_LEN;
265                 /* fall through if TTAK OK */
266         case IWL_RX_MPDU_STATUS_SEC_WEP:
267                 if (!(status & IWL_RX_MPDU_STATUS_ICV_OK))
268                         return -1;
269
270                 stats->flag |= RX_FLAG_DECRYPTED;
271                 if ((status & IWL_RX_MPDU_STATUS_SEC_MASK) ==
272                                 IWL_RX_MPDU_STATUS_SEC_WEP)
273                         *crypt_len = IEEE80211_WEP_IV_LEN;
274                 return 0;
275         case IWL_RX_MPDU_STATUS_SEC_EXT_ENC:
276                 if (!(status & IWL_RX_MPDU_STATUS_MIC_OK))
277                         return -1;
278                 stats->flag |= RX_FLAG_DECRYPTED;
279                 return 0;
280         default:
281                 IWL_ERR(mvm, "Unhandled alg: 0x%x\n", status);
282         }
283
284         return 0;
285 }
286
287 static void iwl_mvm_rx_csum(struct ieee80211_sta *sta,
288                             struct sk_buff *skb,
289                             struct iwl_rx_mpdu_desc *desc)
290 {
291         struct iwl_mvm_sta *mvmsta = iwl_mvm_sta_from_mac80211(sta);
292         struct iwl_mvm_vif *mvmvif = iwl_mvm_vif_from_mac80211(mvmsta->vif);
293         u16 flags = le16_to_cpu(desc->l3l4_flags);
294         u8 l3_prot = (u8)((flags & IWL_RX_L3L4_L3_PROTO_MASK) >>
295                           IWL_RX_L3_PROTO_POS);
296
297         if (mvmvif->features & NETIF_F_RXCSUM &&
298             flags & IWL_RX_L3L4_TCP_UDP_CSUM_OK &&
299             (flags & IWL_RX_L3L4_IP_HDR_CSUM_OK ||
300              l3_prot == IWL_RX_L3_TYPE_IPV6 ||
301              l3_prot == IWL_RX_L3_TYPE_IPV6_FRAG))
302                 skb->ip_summed = CHECKSUM_UNNECESSARY;
303 }
304
305 /*
306  * returns true if a packet outside BA session is a duplicate and
307  * should be dropped
308  */
309 static bool iwl_mvm_is_nonagg_dup(struct ieee80211_sta *sta, int queue,
310                                   struct ieee80211_rx_status *rx_status,
311                                   struct ieee80211_hdr *hdr,
312                                   struct iwl_rx_mpdu_desc *desc)
313 {
314         struct iwl_mvm_sta *mvm_sta;
315         struct iwl_mvm_rxq_dup_data *dup_data;
316         u8 baid, tid, sub_frame_idx;
317
318         if (WARN_ON(IS_ERR_OR_NULL(sta)))
319                 return false;
320
321         baid = (le32_to_cpu(desc->reorder_data) &
322                 IWL_RX_MPDU_REORDER_BAID_MASK) >>
323                 IWL_RX_MPDU_REORDER_BAID_SHIFT;
324
325         if (baid != IWL_RX_REORDER_DATA_INVALID_BAID)
326                 return false;
327
328         mvm_sta = iwl_mvm_sta_from_mac80211(sta);
329         dup_data = &mvm_sta->dup_data[queue];
330
331         /*
332          * Drop duplicate 802.11 retransmissions
333          * (IEEE 802.11-2012: 9.3.2.10 "Duplicate detection and recovery")
334          */
335         if (ieee80211_is_ctl(hdr->frame_control) ||
336             ieee80211_is_qos_nullfunc(hdr->frame_control) ||
337             is_multicast_ether_addr(hdr->addr1)) {
338                 rx_status->flag |= RX_FLAG_DUP_VALIDATED;
339                 return false;
340         }
341
342         if (ieee80211_is_data_qos(hdr->frame_control))
343                 /* frame has qos control */
344                 tid = *ieee80211_get_qos_ctl(hdr) &
345                         IEEE80211_QOS_CTL_TID_MASK;
346         else
347                 tid = IWL_MAX_TID_COUNT;
348
349         /* If this wasn't a part of an A-MSDU the sub-frame index will be 0 */
350         sub_frame_idx = desc->amsdu_info & IWL_RX_MPDU_AMSDU_SUBFRAME_IDX_MASK;
351
352         if (unlikely(ieee80211_has_retry(hdr->frame_control) &&
353                      dup_data->last_seq[tid] == hdr->seq_ctrl &&
354                      dup_data->last_sub_frame[tid] >= sub_frame_idx))
355                 return true;
356
357         dup_data->last_seq[tid] = hdr->seq_ctrl;
358         dup_data->last_sub_frame[tid] = sub_frame_idx;
359
360         rx_status->flag |= RX_FLAG_DUP_VALIDATED;
361
362         return false;
363 }
364
365 int iwl_mvm_notify_rx_queue(struct iwl_mvm *mvm, u32 rxq_mask,
366                             const u8 *data, u32 count)
367 {
368         struct iwl_rxq_sync_cmd *cmd;
369         u32 data_size = sizeof(*cmd) + count;
370         int ret;
371
372         /* should be DWORD aligned */
373         if (WARN_ON(count & 3 || count > IWL_MULTI_QUEUE_SYNC_MSG_MAX_SIZE))
374                 return -EINVAL;
375
376         cmd = kzalloc(data_size, GFP_KERNEL);
377         if (!cmd)
378                 return -ENOMEM;
379
380         cmd->rxq_mask = cpu_to_le32(rxq_mask);
381         cmd->count =  cpu_to_le32(count);
382         cmd->flags = 0;
383         memcpy(cmd->payload, data, count);
384
385         ret = iwl_mvm_send_cmd_pdu(mvm,
386                                    WIDE_ID(DATA_PATH_GROUP,
387                                            TRIGGER_RX_QUEUES_NOTIF_CMD),
388                                    0, data_size, cmd);
389
390         kfree(cmd);
391         return ret;
392 }
393
394 /*
395  * Returns true if sn2 - buffer_size < sn1 < sn2.
396  * To be used only in order to compare reorder buffer head with NSSN.
397  * We fully trust NSSN unless it is behind us due to reorder timeout.
398  * Reorder timeout can only bring us up to buffer_size SNs ahead of NSSN.
399  */
400 static bool iwl_mvm_is_sn_less(u16 sn1, u16 sn2, u16 buffer_size)
401 {
402         return ieee80211_sn_less(sn1, sn2) &&
403                !ieee80211_sn_less(sn1, sn2 - buffer_size);
404 }
405
406 #define RX_REORDER_BUF_TIMEOUT_MQ (HZ / 10)
407
408 static void iwl_mvm_release_frames(struct iwl_mvm *mvm,
409                                    struct ieee80211_sta *sta,
410                                    struct napi_struct *napi,
411                                    struct iwl_mvm_reorder_buffer *reorder_buf,
412                                    u16 nssn)
413 {
414         u16 ssn = reorder_buf->head_sn;
415
416         lockdep_assert_held(&reorder_buf->lock);
417
418         /* ignore nssn smaller than head sn - this can happen due to timeout */
419         if (iwl_mvm_is_sn_less(nssn, ssn, reorder_buf->buf_size))
420                 goto set_timer;
421
422         while (iwl_mvm_is_sn_less(ssn, nssn, reorder_buf->buf_size)) {
423                 int index = ssn % reorder_buf->buf_size;
424                 struct sk_buff_head *skb_list = &reorder_buf->entries[index];
425                 struct sk_buff *skb;
426
427                 ssn = ieee80211_sn_inc(ssn);
428
429                 /*
430                  * Empty the list. Will have more than one frame for A-MSDU.
431                  * Empty list is valid as well since nssn indicates frames were
432                  * received.
433                  */
434                 while ((skb = __skb_dequeue(skb_list))) {
435                         iwl_mvm_pass_packet_to_mac80211(mvm, napi, skb,
436                                                         reorder_buf->queue,
437                                                         sta);
438                         reorder_buf->num_stored--;
439                 }
440         }
441         reorder_buf->head_sn = nssn;
442
443 set_timer:
444         if (reorder_buf->num_stored && !reorder_buf->removed) {
445                 u16 index = reorder_buf->head_sn % reorder_buf->buf_size;
446
447                 while (skb_queue_empty(&reorder_buf->entries[index]))
448                         index = (index + 1) % reorder_buf->buf_size;
449                 /* modify timer to match next frame's expiration time */
450                 mod_timer(&reorder_buf->reorder_timer,
451                           reorder_buf->reorder_time[index] + 1 +
452                           RX_REORDER_BUF_TIMEOUT_MQ);
453         } else {
454                 del_timer(&reorder_buf->reorder_timer);
455         }
456 }
457
458 void iwl_mvm_reorder_timer_expired(unsigned long data)
459 {
460         struct iwl_mvm_reorder_buffer *buf = (void *)data;
461         int i;
462         u16 sn = 0, index = 0;
463         bool expired = false;
464         bool cont = false;
465
466         spin_lock(&buf->lock);
467
468         if (!buf->num_stored || buf->removed) {
469                 spin_unlock(&buf->lock);
470                 return;
471         }
472
473         for (i = 0; i < buf->buf_size ; i++) {
474                 index = (buf->head_sn + i) % buf->buf_size;
475
476                 if (skb_queue_empty(&buf->entries[index])) {
477                         /*
478                          * If there is a hole and the next frame didn't expire
479                          * we want to break and not advance SN
480                          */
481                         cont = false;
482                         continue;
483                 }
484                 if (!cont && !time_after(jiffies, buf->reorder_time[index] +
485                                          RX_REORDER_BUF_TIMEOUT_MQ))
486                         break;
487
488                 expired = true;
489                 /* continue until next hole after this expired frames */
490                 cont = true;
491                 sn = ieee80211_sn_add(buf->head_sn, i + 1);
492         }
493
494         if (expired) {
495                 struct ieee80211_sta *sta;
496
497                 rcu_read_lock();
498                 sta = rcu_dereference(buf->mvm->fw_id_to_mac_id[buf->sta_id]);
499                 /* SN is set to the last expired frame + 1 */
500                 IWL_DEBUG_HT(buf->mvm,
501                              "Releasing expired frames for sta %u, sn %d\n",
502                              buf->sta_id, sn);
503                 iwl_mvm_release_frames(buf->mvm, sta, NULL, buf, sn);
504                 rcu_read_unlock();
505         } else {
506                 /*
507                  * If no frame expired and there are stored frames, index is now
508                  * pointing to the first unexpired frame - modify timer
509                  * accordingly to this frame.
510                  */
511                 mod_timer(&buf->reorder_timer,
512                           buf->reorder_time[index] +
513                           1 + RX_REORDER_BUF_TIMEOUT_MQ);
514         }
515         spin_unlock(&buf->lock);
516 }
517
518 static void iwl_mvm_del_ba(struct iwl_mvm *mvm, int queue,
519                            struct iwl_mvm_delba_data *data)
520 {
521         struct iwl_mvm_baid_data *ba_data;
522         struct ieee80211_sta *sta;
523         struct iwl_mvm_reorder_buffer *reorder_buf;
524         u8 baid = data->baid;
525
526         if (WARN_ONCE(baid >= IWL_MAX_BAID, "invalid BAID: %x\n", baid))
527                 return;
528
529         rcu_read_lock();
530
531         ba_data = rcu_dereference(mvm->baid_map[baid]);
532         if (WARN_ON_ONCE(!ba_data))
533                 goto out;
534
535         sta = rcu_dereference(mvm->fw_id_to_mac_id[ba_data->sta_id]);
536         if (WARN_ON_ONCE(IS_ERR_OR_NULL(sta)))
537                 goto out;
538
539         reorder_buf = &ba_data->reorder_buf[queue];
540
541         /* release all frames that are in the reorder buffer to the stack */
542         spin_lock_bh(&reorder_buf->lock);
543         iwl_mvm_release_frames(mvm, sta, NULL, reorder_buf,
544                                ieee80211_sn_add(reorder_buf->head_sn,
545                                                 reorder_buf->buf_size));
546         spin_unlock_bh(&reorder_buf->lock);
547         del_timer_sync(&reorder_buf->reorder_timer);
548
549 out:
550         rcu_read_unlock();
551 }
552
553 void iwl_mvm_rx_queue_notif(struct iwl_mvm *mvm, struct iwl_rx_cmd_buffer *rxb,
554                             int queue)
555 {
556         struct iwl_rx_packet *pkt = rxb_addr(rxb);
557         struct iwl_rxq_sync_notification *notif;
558         struct iwl_mvm_internal_rxq_notif *internal_notif;
559
560         notif = (void *)pkt->data;
561         internal_notif = (void *)notif->payload;
562
563         if (internal_notif->sync) {
564                 if (mvm->queue_sync_cookie != internal_notif->cookie) {
565                         WARN_ONCE(1,
566                                   "Received expired RX queue sync message\n");
567                         return;
568                 }
569                 if (!atomic_dec_return(&mvm->queue_sync_counter))
570                         wake_up(&mvm->rx_sync_waitq);
571         }
572
573         switch (internal_notif->type) {
574         case IWL_MVM_RXQ_EMPTY:
575                 break;
576         case IWL_MVM_RXQ_NOTIF_DEL_BA:
577                 iwl_mvm_del_ba(mvm, queue, (void *)internal_notif->data);
578                 break;
579         default:
580                 WARN_ONCE(1, "Invalid identifier %d", internal_notif->type);
581         }
582 }
583
584 /*
585  * Returns true if the MPDU was buffered\dropped, false if it should be passed
586  * to upper layer.
587  */
588 static bool iwl_mvm_reorder(struct iwl_mvm *mvm,
589                             struct napi_struct *napi,
590                             int queue,
591                             struct ieee80211_sta *sta,
592                             struct sk_buff *skb,
593                             struct iwl_rx_mpdu_desc *desc)
594 {
595         struct ieee80211_hdr *hdr = (struct ieee80211_hdr *)skb->data;
596         struct iwl_mvm_sta *mvm_sta;
597         struct iwl_mvm_baid_data *baid_data;
598         struct iwl_mvm_reorder_buffer *buffer;
599         struct sk_buff *tail;
600         u32 reorder = le32_to_cpu(desc->reorder_data);
601         bool amsdu = desc->mac_flags2 & IWL_RX_MPDU_MFLG2_AMSDU;
602         bool last_subframe =
603                 desc->amsdu_info & IWL_RX_MPDU_AMSDU_LAST_SUBFRAME;
604         u8 tid = *ieee80211_get_qos_ctl(hdr) & IEEE80211_QOS_CTL_TID_MASK;
605         u8 sub_frame_idx = desc->amsdu_info &
606                            IWL_RX_MPDU_AMSDU_SUBFRAME_IDX_MASK;
607         int index;
608         u16 nssn, sn;
609         u8 baid;
610
611         baid = (reorder & IWL_RX_MPDU_REORDER_BAID_MASK) >>
612                 IWL_RX_MPDU_REORDER_BAID_SHIFT;
613
614         /*
615          * This also covers the case of receiving a Block Ack Request
616          * outside a BA session; we'll pass it to mac80211 and that
617          * then sends a delBA action frame.
618          */
619         if (baid == IWL_RX_REORDER_DATA_INVALID_BAID)
620                 return false;
621
622         /* no sta yet */
623         if (WARN_ON(IS_ERR_OR_NULL(sta)))
624                 return false;
625
626         mvm_sta = iwl_mvm_sta_from_mac80211(sta);
627
628         /* not a data packet or a bar */
629         if (!ieee80211_is_back_req(hdr->frame_control) &&
630             (!ieee80211_is_data_qos(hdr->frame_control) ||
631              is_multicast_ether_addr(hdr->addr1)))
632                 return false;
633
634         if (unlikely(!ieee80211_is_data_present(hdr->frame_control)))
635                 return false;
636
637         baid_data = rcu_dereference(mvm->baid_map[baid]);
638         if (!baid_data) {
639                 IWL_DEBUG_RX(mvm,
640                              "Got valid BAID but no baid allocated, bypass the re-ordering buffer. Baid %d reorder 0x%x\n",
641                               baid, reorder);
642                 return false;
643         }
644
645         if (WARN(tid != baid_data->tid || mvm_sta->sta_id != baid_data->sta_id,
646                  "baid 0x%x is mapped to sta:%d tid:%d, but was received for sta:%d tid:%d\n",
647                  baid, baid_data->sta_id, baid_data->tid, mvm_sta->sta_id,
648                  tid))
649                 return false;
650
651         nssn = reorder & IWL_RX_MPDU_REORDER_NSSN_MASK;
652         sn = (reorder & IWL_RX_MPDU_REORDER_SN_MASK) >>
653                 IWL_RX_MPDU_REORDER_SN_SHIFT;
654
655         buffer = &baid_data->reorder_buf[queue];
656
657         spin_lock_bh(&buffer->lock);
658
659         if (!buffer->valid) {
660                 if (reorder & IWL_RX_MPDU_REORDER_BA_OLD_SN) {
661                         spin_unlock_bh(&buffer->lock);
662                         return false;
663                 }
664                 buffer->valid = true;
665         }
666
667         if (ieee80211_is_back_req(hdr->frame_control)) {
668                 iwl_mvm_release_frames(mvm, sta, napi, buffer, nssn);
669                 goto drop;
670         }
671
672         /*
673          * If there was a significant jump in the nssn - adjust.
674          * If the SN is smaller than the NSSN it might need to first go into
675          * the reorder buffer, in which case we just release up to it and the
676          * rest of the function will take of storing it and releasing up to the
677          * nssn
678          */
679         if (!iwl_mvm_is_sn_less(nssn, buffer->head_sn + buffer->buf_size,
680                                 buffer->buf_size)) {
681                 u16 min_sn = ieee80211_sn_less(sn, nssn) ? sn : nssn;
682
683                 iwl_mvm_release_frames(mvm, sta, napi, buffer, min_sn);
684         }
685
686         /* drop any oudated packets */
687         if (ieee80211_sn_less(sn, buffer->head_sn))
688                 goto drop;
689
690         /* release immediately if allowed by nssn and no stored frames */
691         if (!buffer->num_stored && ieee80211_sn_less(sn, nssn)) {
692                 if (iwl_mvm_is_sn_less(buffer->head_sn, nssn,
693                                        buffer->buf_size) &&
694                    (!amsdu || last_subframe))
695                         buffer->head_sn = nssn;
696                 /* No need to update AMSDU last SN - we are moving the head */
697                 spin_unlock_bh(&buffer->lock);
698                 return false;
699         }
700
701         index = sn % buffer->buf_size;
702
703         /*
704          * Check if we already stored this frame
705          * As AMSDU is either received or not as whole, logic is simple:
706          * If we have frames in that position in the buffer and the last frame
707          * originated from AMSDU had a different SN then it is a retransmission.
708          * If it is the same SN then if the subframe index is incrementing it
709          * is the same AMSDU - otherwise it is a retransmission.
710          */
711         tail = skb_peek_tail(&buffer->entries[index]);
712         if (tail && !amsdu)
713                 goto drop;
714         else if (tail && (sn != buffer->last_amsdu ||
715                           buffer->last_sub_index >= sub_frame_idx))
716                 goto drop;
717
718         /* put in reorder buffer */
719         __skb_queue_tail(&buffer->entries[index], skb);
720         buffer->num_stored++;
721         buffer->reorder_time[index] = jiffies;
722
723         if (amsdu) {
724                 buffer->last_amsdu = sn;
725                 buffer->last_sub_index = sub_frame_idx;
726         }
727
728         /*
729          * We cannot trust NSSN for AMSDU sub-frames that are not the last.
730          * The reason is that NSSN advances on the first sub-frame, and may
731          * cause the reorder buffer to advance before all the sub-frames arrive.
732          * Example: reorder buffer contains SN 0 & 2, and we receive AMSDU with
733          * SN 1. NSSN for first sub frame will be 3 with the result of driver
734          * releasing SN 0,1, 2. When sub-frame 1 arrives - reorder buffer is
735          * already ahead and it will be dropped.
736          * If the last sub-frame is not on this queue - we will get frame
737          * release notification with up to date NSSN.
738          */
739         if (!amsdu || last_subframe)
740                 iwl_mvm_release_frames(mvm, sta, napi, buffer, nssn);
741
742         spin_unlock_bh(&buffer->lock);
743         return true;
744
745 drop:
746         kfree_skb(skb);
747         spin_unlock_bh(&buffer->lock);
748         return true;
749 }
750
751 static void iwl_mvm_agg_rx_received(struct iwl_mvm *mvm,
752                                     u32 reorder_data, u8 baid)
753 {
754         unsigned long now = jiffies;
755         unsigned long timeout;
756         struct iwl_mvm_baid_data *data;
757
758         rcu_read_lock();
759
760         data = rcu_dereference(mvm->baid_map[baid]);
761         if (!data) {
762                 IWL_DEBUG_RX(mvm,
763                              "Got valid BAID but no baid allocated, bypass the re-ordering buffer. Baid %d reorder 0x%x\n",
764                               baid, reorder_data);
765                 goto out;
766         }
767
768         if (!data->timeout)
769                 goto out;
770
771         timeout = data->timeout;
772         /*
773          * Do not update last rx all the time to avoid cache bouncing
774          * between the rx queues.
775          * Update it every timeout. Worst case is the session will
776          * expire after ~ 2 * timeout, which doesn't matter that much.
777          */
778         if (time_before(data->last_rx + TU_TO_JIFFIES(timeout), now))
779                 /* Update is atomic */
780                 data->last_rx = now;
781
782 out:
783         rcu_read_unlock();
784 }
785
786 void iwl_mvm_rx_mpdu_mq(struct iwl_mvm *mvm, struct napi_struct *napi,
787                         struct iwl_rx_cmd_buffer *rxb, int queue)
788 {
789         struct ieee80211_rx_status *rx_status;
790         struct iwl_rx_packet *pkt = rxb_addr(rxb);
791         struct iwl_rx_mpdu_desc *desc = (void *)pkt->data;
792         struct ieee80211_hdr *hdr = (void *)(pkt->data + sizeof(*desc));
793         u32 len = le16_to_cpu(desc->mpdu_len);
794         u32 rate_n_flags = le32_to_cpu(desc->rate_n_flags);
795         u16 phy_info = le16_to_cpu(desc->phy_info);
796         struct ieee80211_sta *sta = NULL;
797         struct sk_buff *skb;
798         u8 crypt_len = 0;
799
800         /* Dont use dev_alloc_skb(), we'll have enough headroom once
801          * ieee80211_hdr pulled.
802          */
803         skb = alloc_skb(128, GFP_ATOMIC);
804         if (!skb) {
805                 IWL_ERR(mvm, "alloc_skb failed\n");
806                 return;
807         }
808
809         rx_status = IEEE80211_SKB_RXCB(skb);
810
811         if (iwl_mvm_rx_crypto(mvm, hdr, rx_status, desc, queue, &crypt_len)) {
812                 kfree_skb(skb);
813                 return;
814         }
815
816         /*
817          * Keep packets with CRC errors (and with overrun) for monitor mode
818          * (otherwise the firmware discards them) but mark them as bad.
819          */
820         if (!(desc->status & cpu_to_le16(IWL_RX_MPDU_STATUS_CRC_OK)) ||
821             !(desc->status & cpu_to_le16(IWL_RX_MPDU_STATUS_OVERRUN_OK))) {
822                 IWL_DEBUG_RX(mvm, "Bad CRC or FIFO: 0x%08X.\n",
823                              le16_to_cpu(desc->status));
824                 rx_status->flag |= RX_FLAG_FAILED_FCS_CRC;
825         }
826         /* set the preamble flag if appropriate */
827         if (phy_info & IWL_RX_MPDU_PHY_SHORT_PREAMBLE)
828                 rx_status->enc_flags |= RX_ENC_FLAG_SHORTPRE;
829
830         if (likely(!(phy_info & IWL_RX_MPDU_PHY_TSF_OVERLOAD))) {
831                 rx_status->mactime = le64_to_cpu(desc->tsf_on_air_rise);
832                 /* TSF as indicated by the firmware is at INA time */
833                 rx_status->flag |= RX_FLAG_MACTIME_PLCP_START;
834         }
835         rx_status->device_timestamp = le32_to_cpu(desc->gp2_on_air_rise);
836         rx_status->band = desc->channel > 14 ? NL80211_BAND_5GHZ :
837                                                NL80211_BAND_2GHZ;
838         rx_status->freq = ieee80211_channel_to_frequency(desc->channel,
839                                                          rx_status->band);
840         iwl_mvm_get_signal_strength(mvm, desc, rx_status);
841
842         /* update aggregation data for monitor sake on default queue */
843         if (!queue && (phy_info & IWL_RX_MPDU_PHY_AMPDU)) {
844                 bool toggle_bit = phy_info & IWL_RX_MPDU_PHY_AMPDU_TOGGLE;
845
846                 rx_status->flag |= RX_FLAG_AMPDU_DETAILS;
847                 rx_status->ampdu_reference = mvm->ampdu_ref;
848                 /* toggle is switched whenever new aggregation starts */
849                 if (toggle_bit != mvm->ampdu_toggle) {
850                         mvm->ampdu_ref++;
851                         mvm->ampdu_toggle = toggle_bit;
852                 }
853         }
854
855         rcu_read_lock();
856
857         if (le16_to_cpu(desc->status) & IWL_RX_MPDU_STATUS_SRC_STA_FOUND) {
858                 u8 id = desc->sta_id_flags & IWL_RX_MPDU_SIF_STA_ID_MASK;
859
860                 if (!WARN_ON_ONCE(id >= ARRAY_SIZE(mvm->fw_id_to_mac_id))) {
861                         sta = rcu_dereference(mvm->fw_id_to_mac_id[id]);
862                         if (IS_ERR(sta))
863                                 sta = NULL;
864                 }
865         } else if (!is_multicast_ether_addr(hdr->addr2)) {
866                 /*
867                  * This is fine since we prevent two stations with the same
868                  * address from being added.
869                  */
870                 sta = ieee80211_find_sta_by_ifaddr(mvm->hw, hdr->addr2, NULL);
871         }
872
873         if (sta) {
874                 struct iwl_mvm_sta *mvmsta = iwl_mvm_sta_from_mac80211(sta);
875                 struct ieee80211_vif *tx_blocked_vif =
876                         rcu_dereference(mvm->csa_tx_blocked_vif);
877                 u8 baid = (u8)((le32_to_cpu(desc->reorder_data) &
878                                IWL_RX_MPDU_REORDER_BAID_MASK) >>
879                                IWL_RX_MPDU_REORDER_BAID_SHIFT);
880
881                 /*
882                  * We have tx blocked stations (with CS bit). If we heard
883                  * frames from a blocked station on a new channel we can
884                  * TX to it again.
885                  */
886                 if (unlikely(tx_blocked_vif) &&
887                     tx_blocked_vif == mvmsta->vif) {
888                         struct iwl_mvm_vif *mvmvif =
889                                 iwl_mvm_vif_from_mac80211(tx_blocked_vif);
890
891                         if (mvmvif->csa_target_freq == rx_status->freq)
892                                 iwl_mvm_sta_modify_disable_tx_ap(mvm, sta,
893                                                                  false);
894                 }
895
896                 rs_update_last_rssi(mvm, &mvmsta->lq_sta, rx_status);
897
898                 if (iwl_fw_dbg_trigger_enabled(mvm->fw, FW_DBG_TRIGGER_RSSI) &&
899                     ieee80211_is_beacon(hdr->frame_control)) {
900                         struct iwl_fw_dbg_trigger_tlv *trig;
901                         struct iwl_fw_dbg_trigger_low_rssi *rssi_trig;
902                         bool trig_check;
903                         s32 rssi;
904
905                         trig = iwl_fw_dbg_get_trigger(mvm->fw,
906                                                       FW_DBG_TRIGGER_RSSI);
907                         rssi_trig = (void *)trig->data;
908                         rssi = le32_to_cpu(rssi_trig->rssi);
909
910                         trig_check =
911                                 iwl_fw_dbg_trigger_check_stop(mvm, mvmsta->vif,
912                                                               trig);
913                         if (trig_check && rx_status->signal < rssi)
914                                 iwl_mvm_fw_dbg_collect_trig(mvm, trig, NULL);
915                 }
916
917                 if (ieee80211_is_data(hdr->frame_control))
918                         iwl_mvm_rx_csum(sta, skb, desc);
919
920                 if (iwl_mvm_is_nonagg_dup(sta, queue, rx_status, hdr, desc)) {
921                         kfree_skb(skb);
922                         goto out;
923                 }
924
925                 /*
926                  * Our hardware de-aggregates AMSDUs but copies the mac header
927                  * as it to the de-aggregated MPDUs. We need to turn off the
928                  * AMSDU bit in the QoS control ourselves.
929                  * In addition, HW reverses addr3 and addr4 - reverse it back.
930                  */
931                 if ((desc->mac_flags2 & IWL_RX_MPDU_MFLG2_AMSDU) &&
932                     !WARN_ON(!ieee80211_is_data_qos(hdr->frame_control))) {
933                         int i;
934                         u8 *qc = ieee80211_get_qos_ctl(hdr);
935                         u8 mac_addr[ETH_ALEN];
936
937                         *qc &= ~IEEE80211_QOS_CTL_A_MSDU_PRESENT;
938
939                         for (i = 0; i < ETH_ALEN; i++)
940                                 mac_addr[i] = hdr->addr3[ETH_ALEN - i - 1];
941                         ether_addr_copy(hdr->addr3, mac_addr);
942
943                         if (ieee80211_has_a4(hdr->frame_control)) {
944                                 for (i = 0; i < ETH_ALEN; i++)
945                                         mac_addr[i] =
946                                                 hdr->addr4[ETH_ALEN - i - 1];
947                                 ether_addr_copy(hdr->addr4, mac_addr);
948                         }
949                 }
950                 if (baid != IWL_RX_REORDER_DATA_INVALID_BAID) {
951                         u32 reorder_data = le32_to_cpu(desc->reorder_data);
952
953                         iwl_mvm_agg_rx_received(mvm, reorder_data, baid);
954                 }
955         }
956
957         /* Set up the HT phy flags */
958         switch (rate_n_flags & RATE_MCS_CHAN_WIDTH_MSK) {
959         case RATE_MCS_CHAN_WIDTH_20:
960                 break;
961         case RATE_MCS_CHAN_WIDTH_40:
962                 rx_status->bw = RATE_INFO_BW_40;
963                 break;
964         case RATE_MCS_CHAN_WIDTH_80:
965                 rx_status->bw = RATE_INFO_BW_80;
966                 break;
967         case RATE_MCS_CHAN_WIDTH_160:
968                 rx_status->bw = RATE_INFO_BW_160;
969                 break;
970         }
971         if (rate_n_flags & RATE_MCS_SGI_MSK)
972                 rx_status->enc_flags |= RX_ENC_FLAG_SHORT_GI;
973         if (rate_n_flags & RATE_HT_MCS_GF_MSK)
974                 rx_status->enc_flags |= RX_ENC_FLAG_HT_GF;
975         if (rate_n_flags & RATE_MCS_LDPC_MSK)
976                 rx_status->enc_flags |= RX_ENC_FLAG_LDPC;
977         if (rate_n_flags & RATE_MCS_HT_MSK) {
978                 u8 stbc = (rate_n_flags & RATE_MCS_STBC_MSK) >>
979                                 RATE_MCS_STBC_POS;
980                 rx_status->encoding = RX_ENC_HT;
981                 rx_status->rate_idx = rate_n_flags & RATE_HT_MCS_INDEX_MSK;
982                 rx_status->enc_flags |= stbc << RX_ENC_FLAG_STBC_SHIFT;
983         } else if (rate_n_flags & RATE_MCS_VHT_MSK) {
984                 u8 stbc = (rate_n_flags & RATE_MCS_STBC_MSK) >>
985                                 RATE_MCS_STBC_POS;
986                 rx_status->nss =
987                         ((rate_n_flags & RATE_VHT_MCS_NSS_MSK) >>
988                                                 RATE_VHT_MCS_NSS_POS) + 1;
989                 rx_status->rate_idx = rate_n_flags & RATE_VHT_MCS_RATE_CODE_MSK;
990                 rx_status->encoding = RX_ENC_VHT;
991                 rx_status->enc_flags |= stbc << RX_ENC_FLAG_STBC_SHIFT;
992                 if (rate_n_flags & RATE_MCS_BF_MSK)
993                         rx_status->enc_flags |= RX_ENC_FLAG_BF;
994         } else {
995                 int rate = iwl_mvm_legacy_rate_to_mac80211_idx(rate_n_flags,
996                                                                rx_status->band);
997
998                 if (WARN(rate < 0 || rate > 0xFF,
999                          "Invalid rate flags 0x%x, band %d,\n",
1000                          rate_n_flags, rx_status->band)) {
1001                         kfree_skb(skb);
1002                         goto out;
1003                 }
1004                 rx_status->rate_idx = rate;
1005
1006         }
1007
1008         /* management stuff on default queue */
1009         if (!queue) {
1010                 if (unlikely((ieee80211_is_beacon(hdr->frame_control) ||
1011                               ieee80211_is_probe_resp(hdr->frame_control)) &&
1012                              mvm->sched_scan_pass_all ==
1013                              SCHED_SCAN_PASS_ALL_ENABLED))
1014                         mvm->sched_scan_pass_all = SCHED_SCAN_PASS_ALL_FOUND;
1015
1016                 if (unlikely(ieee80211_is_beacon(hdr->frame_control) ||
1017                              ieee80211_is_probe_resp(hdr->frame_control)))
1018                         rx_status->boottime_ns = ktime_get_boot_ns();
1019         }
1020
1021         iwl_mvm_create_skb(skb, hdr, len, crypt_len, rxb);
1022         if (!iwl_mvm_reorder(mvm, napi, queue, sta, skb, desc))
1023                 iwl_mvm_pass_packet_to_mac80211(mvm, napi, skb, queue, sta);
1024 out:
1025         rcu_read_unlock();
1026 }
1027
1028 void iwl_mvm_rx_frame_release(struct iwl_mvm *mvm, struct napi_struct *napi,
1029                               struct iwl_rx_cmd_buffer *rxb, int queue)
1030 {
1031         struct iwl_rx_packet *pkt = rxb_addr(rxb);
1032         struct iwl_frame_release *release = (void *)pkt->data;
1033         struct ieee80211_sta *sta;
1034         struct iwl_mvm_reorder_buffer *reorder_buf;
1035         struct iwl_mvm_baid_data *ba_data;
1036
1037         int baid = release->baid;
1038
1039         IWL_DEBUG_HT(mvm, "Frame release notification for BAID %u, NSSN %d\n",
1040                      release->baid, le16_to_cpu(release->nssn));
1041
1042         if (WARN_ON_ONCE(baid == IWL_RX_REORDER_DATA_INVALID_BAID))
1043                 return;
1044
1045         rcu_read_lock();
1046
1047         ba_data = rcu_dereference(mvm->baid_map[baid]);
1048         if (WARN_ON_ONCE(!ba_data))
1049                 goto out;
1050
1051         sta = rcu_dereference(mvm->fw_id_to_mac_id[ba_data->sta_id]);
1052         if (WARN_ON_ONCE(IS_ERR_OR_NULL(sta)))
1053                 goto out;
1054
1055         reorder_buf = &ba_data->reorder_buf[queue];
1056
1057         spin_lock_bh(&reorder_buf->lock);
1058         iwl_mvm_release_frames(mvm, sta, napi, reorder_buf,
1059                                le16_to_cpu(release->nssn));
1060         spin_unlock_bh(&reorder_buf->lock);
1061
1062 out:
1063         rcu_read_unlock();
1064 }