drivers/net/wireless/ath/wil6210/txrx_edma.c

   1 /*
   2  * Copyright (c) 2012-2019 The Linux Foundation. All rights reserved.
   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
  17 #include <linux/etherdevice.h>
  18 #include <linux/moduleparam.h>
  19 #include <linux/prefetch.h>
  20 #include <linux/types.h>
  21 #include <linux/list.h>
  22 #include <linux/ip.h>
  23 #include <linux/ipv6.h>
  24 #include "wil6210.h"
  25 #include "txrx_edma.h"
  26 #include "txrx.h"
  27 #include "trace.h"
  28
  29 /* Max number of entries (packets to complete) to update the hwtail of tx
  30  * status ring. Should be power of 2
  31  */
  32 #define WIL_EDMA_TX_SRING_UPDATE_HW_TAIL 128
  33 #define WIL_EDMA_MAX_DATA_OFFSET (2)
  34 /* RX buffer size must be aligned to 4 bytes */
  35 #define WIL_EDMA_RX_BUF_LEN_DEFAULT (2048)
  36 #define MAX_INVALID_BUFF_ID_RETRY (3)
  37
  38 static void wil_tx_desc_unmap_edma(struct device *dev,
  39                                    union wil_tx_desc *desc,
  40                                    struct wil_ctx *ctx)
  41 {
  42         struct wil_tx_enhanced_desc *d = (struct wil_tx_enhanced_desc *)desc;
  43         dma_addr_t pa = wil_tx_desc_get_addr_edma(&d->dma);
  44         u16 dmalen = le16_to_cpu(d->dma.length);
  45
  46         switch (ctx->mapped_as) {
  47         case wil_mapped_as_single:
  48                 dma_unmap_single(dev, pa, dmalen, DMA_TO_DEVICE);
  49                 break;
  50         case wil_mapped_as_page:
  51                 dma_unmap_page(dev, pa, dmalen, DMA_TO_DEVICE);
  52                 break;
  53         default:
  54                 break;
  55         }
  56 }
  57
  58 static int wil_find_free_sring(struct wil6210_priv *wil)
  59 {
  60         int i;
  61
  62         for (i = 0; i < WIL6210_MAX_STATUS_RINGS; i++) {
  63                 if (!wil->srings[i].va)
  64                         return i;
  65         }
  66
  67         return -EINVAL;
  68 }
  69
  70 static void wil_sring_free(struct wil6210_priv *wil,
  71                            struct wil_status_ring *sring)
  72 {
  73         struct device *dev = wil_to_dev(wil);
  74         size_t sz;
  75
  76         if (!sring || !sring->va)
  77                 return;
  78
  79         sz = sring->elem_size * sring->size;
  80
  81         wil_dbg_misc(wil, "status_ring_free, size(bytes)=%zu, 0x%p:%pad\n",
  82                      sz, sring->va, &sring->pa);
  83
  84         dma_free_coherent(dev, sz, (void *)sring->va, sring->pa);
  85         sring->pa = 0;
  86         sring->va = NULL;
  87 }
  88
  89 static int wil_sring_alloc(struct wil6210_priv *wil,
  90                            struct wil_status_ring *sring)
  91 {
  92         struct device *dev = wil_to_dev(wil);
  93         size_t sz = sring->elem_size * sring->size;
  94
  95         wil_dbg_misc(wil, "status_ring_alloc: size=%zu\n", sz);
  96
  97         if (sz == 0) {
  98                 wil_err(wil, "Cannot allocate a zero size status ring\n");
  99                 return -EINVAL;
 100         }
 101
 102         sring->swhead = 0;
 103
 104         /* Status messages are allocated and initialized to 0. This is necessary
 105          * since DR bit should be initialized to 0.
 106          */
 107         sring->va = dma_alloc_coherent(dev, sz, &sring->pa, GFP_KERNEL);
 108         if (!sring->va)
 109                 return -ENOMEM;
 110
 111         wil_dbg_misc(wil, "status_ring[%d] 0x%p:%pad\n", sring->size, sring->va,
 112                      &sring->pa);
 113
 114         return 0;
 115 }
 116
 117 static int wil_tx_init_edma(struct wil6210_priv *wil)
 118 {
 119         int ring_id = wil_find_free_sring(wil);
 120         struct wil_status_ring *sring;
 121         int rc;
 122         u16 status_ring_size;
 123
 124         if (wil->tx_status_ring_order < WIL_SRING_SIZE_ORDER_MIN ||
 125             wil->tx_status_ring_order > WIL_SRING_SIZE_ORDER_MAX)
 126                 wil->tx_status_ring_order = WIL_TX_SRING_SIZE_ORDER_DEFAULT;
 127
 128         status_ring_size = 1 << wil->tx_status_ring_order;
 129
 130         wil_dbg_misc(wil, "init TX sring: size=%u, ring_id=%u\n",
 131                      status_ring_size, ring_id);
 132
 133         if (ring_id < 0)
 134                 return ring_id;
 135
 136         /* Allocate Tx status ring. Tx descriptor rings will be
 137          * allocated on WMI connect event
 138          */
 139         sring = &wil->srings[ring_id];
 140
 141         sring->is_rx = false;
 142         sring->size = status_ring_size;
 143         sring->elem_size = sizeof(struct wil_ring_tx_status);
 144         rc = wil_sring_alloc(wil, sring);
 145         if (rc)
 146                 return rc;
 147
 148         rc = wil_wmi_tx_sring_cfg(wil, ring_id);
 149         if (rc)
 150                 goto out_free;
 151
 152         sring->desc_rdy_pol = 1;
 153         wil->tx_sring_idx = ring_id;
 154
 155         return 0;
 156 out_free:
 157         wil_sring_free(wil, sring);
 158         return rc;
 159 }
 160
 161 /**
 162  * Allocate one skb for Rx descriptor RING
 163  */
 164 static int wil_ring_alloc_skb_edma(struct wil6210_priv *wil,
 165                                    struct wil_ring *ring, u32 i)
 166 {
 167         struct device *dev = wil_to_dev(wil);
 168         unsigned int sz = wil->rx_buf_len;
 169         dma_addr_t pa;
 170         u16 buff_id;
 171         struct list_head *active = &wil->rx_buff_mgmt.active;
 172         struct list_head *free = &wil->rx_buff_mgmt.free;
 173         struct wil_rx_buff *rx_buff;
 174         struct wil_rx_buff *buff_arr = wil->rx_buff_mgmt.buff_arr;
 175         struct sk_buff *skb;
 176         struct wil_rx_enhanced_desc dd, *d = &dd;
 177         struct wil_rx_enhanced_desc *_d = (struct wil_rx_enhanced_desc *)
 178                 &ring->va[i].rx.enhanced;
 179
 180         if (unlikely(list_empty(free))) {
 181                 wil->rx_buff_mgmt.free_list_empty_cnt++;
 182                 return -EAGAIN;
 183         }
 184
 185         skb = dev_alloc_skb(sz);
 186         if (unlikely(!skb))
 187                 return -ENOMEM;
 188
 189         skb_put(skb, sz);
 190
 191         /**
 192          * Make sure that the network stack calculates checksum for packets
 193          * which failed the HW checksum calculation
 194          */
 195         skb->ip_summed = CHECKSUM_NONE;
 196
 197         pa = dma_map_single(dev, skb->data, skb->len, DMA_FROM_DEVICE);
 198         if (unlikely(dma_mapping_error(dev, pa))) {
 199                 kfree_skb(skb);
 200                 return -ENOMEM;
 201         }
 202
 203         /* Get the buffer ID - the index of the rx buffer in the buff_arr */
 204         rx_buff = list_first_entry(free, struct wil_rx_buff, list);
 205         buff_id = rx_buff->id;
 206
 207         /* Move a buffer from the free list to the active list */
 208         list_move(&rx_buff->list, active);
 209
 210         buff_arr[buff_id].skb = skb;
 211
 212         wil_desc_set_addr_edma(&d->dma.addr, &d->dma.addr_high_high, pa);
 213         d->dma.length = cpu_to_le16(sz);
 214         d->mac.buff_id = cpu_to_le16(buff_id);
 215         *_d = *d;
 216
 217         /* Save the physical address in skb->cb for later use in dma_unmap */
 218         memcpy(skb->cb, &pa, sizeof(pa));
 219
 220         return 0;
 221 }
 222
 223 static inline
 224 void wil_get_next_rx_status_msg(struct wil_status_ring *sring, u8 *dr_bit,
 225                                 void *msg)
 226 {
 227         struct wil_rx_status_compressed *_msg;
 228
 229         _msg = (struct wil_rx_status_compressed *)
 230                 (sring->va + (sring->elem_size * sring->swhead));
 231         *dr_bit = WIL_GET_BITS(_msg->d0, 31, 31);
 232         /* make sure dr_bit is read before the rest of status msg */
 233         rmb();
 234         memcpy(msg, (void *)_msg, sring->elem_size);
 235 }
 236
 237 static inline void wil_sring_advance_swhead(struct wil_status_ring *sring)
 238 {
 239         sring->swhead = (sring->swhead + 1) % sring->size;
 240         if (sring->swhead == 0)
 241                 sring->desc_rdy_pol = 1 - sring->desc_rdy_pol;
 242 }
 243
 244 static int wil_rx_refill_edma(struct wil6210_priv *wil)
 245 {
 246         struct wil_ring *ring = &wil->ring_rx;
 247         u32 next_head;
 248         int rc = 0;
 249         ring->swtail = *ring->edma_rx_swtail.va;
 250
 251         for (; next_head = wil_ring_next_head(ring),
 252              (next_head != ring->swtail);
 253              ring->swhead = next_head) {
 254                 rc = wil_ring_alloc_skb_edma(wil, ring, ring->swhead);
 255                 if (unlikely(rc)) {
 256                         if (rc == -EAGAIN)
 257                                 wil_dbg_txrx(wil, "No free buffer ID found\n");
 258                         else
 259                                 wil_err_ratelimited(wil,
 260                                                     "Error %d in refill desc[%d]\n",
 261                                                     rc, ring->swhead);
 262                         break;
 263                 }
 264         }
 265
 266         /* make sure all writes to descriptors (shared memory) are done before
 267          * committing them to HW
 268          */
 269         wmb();
 270
 271         wil_w(wil, ring->hwtail, ring->swhead);
 272
 273         return rc;
 274 }
 275
 276 static void wil_move_all_rx_buff_to_free_list(struct wil6210_priv *wil,
 277                                               struct wil_ring *ring)
 278 {
 279         struct device *dev = wil_to_dev(wil);
 280         struct list_head *active = &wil->rx_buff_mgmt.active;
 281         dma_addr_t pa;
 282
 283         if (!wil->rx_buff_mgmt.buff_arr)
 284                 return;
 285
 286         while (!list_empty(active)) {
 287                 struct wil_rx_buff *rx_buff =
 288                         list_first_entry(active, struct wil_rx_buff, list);
 289                 struct sk_buff *skb = rx_buff->skb;
 290
 291                 if (unlikely(!skb)) {
 292                         wil_err(wil, "No Rx skb at buff_id %d\n", rx_buff->id);
 293                 } else {
 294                         rx_buff->skb = NULL;
 295                         memcpy(&pa, skb->cb, sizeof(pa));
 296                         dma_unmap_single(dev, pa, wil->rx_buf_len,
 297                                          DMA_FROM_DEVICE);
 298                         kfree_skb(skb);
 299                 }
 300
 301                 /* Move the buffer from the active to the free list */
 302                 list_move(&rx_buff->list, &wil->rx_buff_mgmt.free);
 303         }
 304 }
 305
 306 static void wil_free_rx_buff_arr(struct wil6210_priv *wil)
 307 {
 308         struct wil_ring *ring = &wil->ring_rx;
 309
 310         if (!wil->rx_buff_mgmt.buff_arr)
 311                 return;
 312
 313         /* Move all the buffers to the free list in case active list is
 314          * not empty in order to release all SKBs before deleting the array
 315          */
 316         wil_move_all_rx_buff_to_free_list(wil, ring);
 317
 318         kfree(wil->rx_buff_mgmt.buff_arr);
 319         wil->rx_buff_mgmt.buff_arr = NULL;
 320 }
 321
 322 static int wil_init_rx_buff_arr(struct wil6210_priv *wil,
 323                                 size_t size)
 324 {
 325         struct wil_rx_buff *buff_arr;
 326         struct list_head *active = &wil->rx_buff_mgmt.active;
 327         struct list_head *free = &wil->rx_buff_mgmt.free;
 328         int i;
 329
 330         wil->rx_buff_mgmt.buff_arr = kcalloc(size + 1,
 331                                              sizeof(struct wil_rx_buff),
 332                                              GFP_KERNEL);
 333         if (!wil->rx_buff_mgmt.buff_arr)
 334                 return -ENOMEM;
 335
 336         /* Set list heads */
 337         INIT_LIST_HEAD(active);
 338         INIT_LIST_HEAD(free);
 339
 340         /* Linkify the list.
 341          * buffer id 0 should not be used (marks invalid id).
 342          */
 343         buff_arr = wil->rx_buff_mgmt.buff_arr;
 344         for (i = 1; i <= size; i++) {
 345                 list_add(&buff_arr[i].list, free);
 346                 buff_arr[i].id = i;
 347         }
 348
 349         wil->rx_buff_mgmt.size = size + 1;
 350
 351         return 0;
 352 }
 353
 354 static int wil_init_rx_sring(struct wil6210_priv *wil,
 355                              u16 status_ring_size,
 356                              size_t elem_size,
 357                              u16 ring_id)
 358 {
 359         struct wil_status_ring *sring = &wil->srings[ring_id];
 360         int rc;
 361
 362         wil_dbg_misc(wil, "init RX sring: size=%u, ring_id=%u\n",
 363                      status_ring_size, ring_id);
 364
 365         memset(&sring->rx_data, 0, sizeof(sring->rx_data));
 366
 367         sring->is_rx = true;
 368         sring->size = status_ring_size;
 369         sring->elem_size = elem_size;
 370         rc = wil_sring_alloc(wil, sring);
 371         if (rc)
 372                 return rc;
 373
 374         rc = wil_wmi_rx_sring_add(wil, ring_id);
 375         if (rc)
 376                 goto out_free;
 377
 378         sring->desc_rdy_pol = 1;
 379
 380         return 0;
 381 out_free:
 382         wil_sring_free(wil, sring);
 383         return rc;
 384 }
 385
 386 static int wil_ring_alloc_desc_ring(struct wil6210_priv *wil,
 387                                     struct wil_ring *ring)
 388 {
 389         struct device *dev = wil_to_dev(wil);
 390         size_t sz = ring->size * sizeof(ring->va[0]);
 391
 392         wil_dbg_misc(wil, "alloc_desc_ring:\n");
 393
 394         BUILD_BUG_ON(sizeof(ring->va[0]) != 32);
 395
 396         ring->swhead = 0;
 397         ring->swtail = 0;
 398         ring->ctx = kcalloc(ring->size, sizeof(ring->ctx[0]), GFP_KERNEL);
 399         if (!ring->ctx)
 400                 goto err;
 401
 402         ring->va = dma_alloc_coherent(dev, sz, &ring->pa, GFP_KERNEL);
 403         if (!ring->va)
 404                 goto err_free_ctx;
 405
 406         if (ring->is_rx) {
 407                 sz = sizeof(*ring->edma_rx_swtail.va);
 408                 ring->edma_rx_swtail.va =
 409                         dma_alloc_coherent(dev, sz, &ring->edma_rx_swtail.pa,
 410                                            GFP_KERNEL);
 411                 if (!ring->edma_rx_swtail.va)
 412                         goto err_free_va;
 413         }
 414
 415         wil_dbg_misc(wil, "%s ring[%d] 0x%p:%pad 0x%p\n",
 416                      ring->is_rx ? "RX" : "TX",
 417                      ring->size, ring->va, &ring->pa, ring->ctx);
 418
 419         return 0;
 420 err_free_va:
 421         dma_free_coherent(dev, ring->size * sizeof(ring->va[0]),
 422                           (void *)ring->va, ring->pa);
 423         ring->va = NULL;
 424 err_free_ctx:
 425         kfree(ring->ctx);
 426         ring->ctx = NULL;
 427 err:
 428         return -ENOMEM;
 429 }
 430
 431 static void wil_ring_free_edma(struct wil6210_priv *wil, struct wil_ring *ring)
 432 {
 433         struct device *dev = wil_to_dev(wil);
 434         size_t sz;
 435         int ring_index = 0;
 436
 437         if (!ring->va)
 438                 return;
 439
 440         sz = ring->size * sizeof(ring->va[0]);
 441
 442         lockdep_assert_held(&wil->mutex);
 443         if (ring->is_rx) {
 444                 wil_dbg_misc(wil, "free Rx ring [%d] 0x%p:%pad 0x%p\n",
 445                              ring->size, ring->va,
 446                              &ring->pa, ring->ctx);
 447
 448                 wil_move_all_rx_buff_to_free_list(wil, ring);
 449                 dma_free_coherent(dev, sizeof(*ring->edma_rx_swtail.va),
 450                                   ring->edma_rx_swtail.va,
 451                                   ring->edma_rx_swtail.pa);
 452                 goto out;
 453         }
 454
 455         /* TX ring */
 456         ring_index = ring - wil->ring_tx;
 457
 458         wil_dbg_misc(wil, "free Tx ring %d [%d] 0x%p:%pad 0x%p\n",
 459                      ring_index, ring->size, ring->va,
 460                      &ring->pa, ring->ctx);
 461
 462         while (!wil_ring_is_empty(ring)) {
 463                 struct wil_ctx *ctx;
 464
 465                 struct wil_tx_enhanced_desc dd, *d = &dd;
 466                 struct wil_tx_enhanced_desc *_d =
 467                         (struct wil_tx_enhanced_desc *)
 468                         &ring->va[ring->swtail].tx.enhanced;
 469
 470                 ctx = &ring->ctx[ring->swtail];
 471                 if (!ctx) {
 472                         wil_dbg_txrx(wil,
 473                                      "ctx(%d) was already completed\n",
 474                                      ring->swtail);
 475                         ring->swtail = wil_ring_next_tail(ring);
 476                         continue;
 477                 }
 478                 *d = *_d;
 479                 wil_tx_desc_unmap_edma(dev, (union wil_tx_desc *)d, ctx);
 480                 if (ctx->skb)
 481                         dev_kfree_skb_any(ctx->skb);
 482                 ring->swtail = wil_ring_next_tail(ring);
 483         }
 484
 485 out:
 486         dma_free_coherent(dev, sz, (void *)ring->va, ring->pa);
 487         kfree(ring->ctx);
 488         ring->pa = 0;
 489         ring->va = NULL;
 490         ring->ctx = NULL;
 491 }
 492
 493 static int wil_init_rx_desc_ring(struct wil6210_priv *wil, u16 desc_ring_size,
 494                                  int status_ring_id)
 495 {
 496         struct wil_ring *ring = &wil->ring_rx;
 497         int rc;
 498
 499         wil_dbg_misc(wil, "init RX desc ring\n");
 500
 501         ring->size = desc_ring_size;
 502         ring->is_rx = true;
 503         rc = wil_ring_alloc_desc_ring(wil, ring);
 504         if (rc)
 505                 return rc;
 506
 507         rc = wil_wmi_rx_desc_ring_add(wil, status_ring_id);
 508         if (rc)
 509                 goto out_free;
 510
 511         return 0;
 512 out_free:
 513         wil_ring_free_edma(wil, ring);
 514         return rc;
 515 }
 516
 517 static void wil_get_reorder_params_edma(struct wil6210_priv *wil,
 518                                         struct sk_buff *skb, int *tid,
 519                                         int *cid, int *mid, u16 *seq,
 520                                         int *mcast, int *retry)
 521 {
 522         struct wil_rx_status_extended *s = wil_skb_rxstatus(skb);
 523
 524         *tid = wil_rx_status_get_tid(s);
 525         *cid = wil_rx_status_get_cid(s);
 526         *mid = wil_rx_status_get_mid(s);
 527         *seq = le16_to_cpu(wil_rx_status_get_seq(wil, s));
 528         *mcast = wil_rx_status_get_mcast(s);
 529         *retry = wil_rx_status_get_retry(s);
 530 }
 531
 532 static void wil_get_netif_rx_params_edma(struct sk_buff *skb, int *cid,
 533                                          int *security)
 534 {
 535         struct wil_rx_status_extended *s = wil_skb_rxstatus(skb);
 536
 537         *cid = wil_rx_status_get_cid(s);
 538         *security = wil_rx_status_get_security(s);
 539 }
 540
 541 static int wil_rx_crypto_check_edma(struct wil6210_priv *wil,
 542                                     struct sk_buff *skb)
 543 {
 544         struct wil_rx_status_extended *st;
 545         int cid, tid, key_id, mc;
 546         struct wil_sta_info *s;
 547         struct wil_tid_crypto_rx *c;
 548         struct wil_tid_crypto_rx_single *cc;
 549         const u8 *pn;
 550
 551         /* In HW reorder, HW is responsible for crypto check */
 552         if (wil->use_rx_hw_reordering)
 553                 return 0;
 554
 555         st = wil_skb_rxstatus(skb);
 556
 557         cid = wil_rx_status_get_cid(st);
 558         tid = wil_rx_status_get_tid(st);
 559         key_id = wil_rx_status_get_key_id(st);
 560         mc = wil_rx_status_get_mcast(st);
 561         s = &wil->sta[cid];
 562         c = mc ? &s->group_crypto_rx : &s->tid_crypto_rx[tid];
 563         cc = &c->key_id[key_id];
 564         pn = (u8 *)&st->ext.pn_15_0;
 565
 566         if (!cc->key_set) {
 567                 wil_err_ratelimited(wil,
 568                                     "Key missing. CID %d TID %d MCast %d KEY_ID %d\n",
 569                                     cid, tid, mc, key_id);
 570                 return -EINVAL;
 571         }
 572
 573         if (reverse_memcmp(pn, cc->pn, IEEE80211_GCMP_PN_LEN) <= 0) {
 574                 wil_err_ratelimited(wil,
 575                                     "Replay attack. CID %d TID %d MCast %d KEY_ID %d PN %6phN last %6phN\n",
 576                                     cid, tid, mc, key_id, pn, cc->pn);
 577                 return -EINVAL;
 578         }
 579         memcpy(cc->pn, pn, IEEE80211_GCMP_PN_LEN);
 580
 581         return 0;
 582 }
 583
 584 static bool wil_is_rx_idle_edma(struct wil6210_priv *wil)
 585 {
 586         struct wil_status_ring *sring;
 587         struct wil_rx_status_extended msg1;
 588         void *msg = &msg1;
 589         u8 dr_bit;
 590         int i;
 591
 592         for (i = 0; i < wil->num_rx_status_rings; i++) {
 593                 sring = &wil->srings[i];
 594                 if (!sring->va)
 595                         continue;
 596
 597                 wil_get_next_rx_status_msg(sring, &dr_bit, msg);
 598
 599                 /* Check if there are unhandled RX status messages */
 600                 if (dr_bit == sring->desc_rdy_pol)
 601                         return false;
 602         }
 603
 604         return true;
 605 }
 606
 607 static void wil_rx_buf_len_init_edma(struct wil6210_priv *wil)
 608 {
 609         /* RX buffer size must be aligned to 4 bytes */
 610         wil->rx_buf_len = rx_large_buf ?
 611                 WIL_MAX_ETH_MTU : WIL_EDMA_RX_BUF_LEN_DEFAULT;
 612 }
 613
 614 static int wil_rx_init_edma(struct wil6210_priv *wil, uint desc_ring_order)
 615 {
 616         u16 status_ring_size, desc_ring_size = 1 << desc_ring_order;
 617         struct wil_ring *ring = &wil->ring_rx;
 618         int rc;
 619         size_t elem_size = wil->use_compressed_rx_status ?
 620                 sizeof(struct wil_rx_status_compressed) :
 621                 sizeof(struct wil_rx_status_extended);
 622         int i;
 623
 624         /* In SW reorder one must use extended status messages */
 625         if (wil->use_compressed_rx_status && !wil->use_rx_hw_reordering) {
 626                 wil_err(wil,
 627                         "compressed RX status cannot be used with SW reorder\n");
 628                 return -EINVAL;
 629         }
 630         if (wil->rx_status_ring_order <= desc_ring_order)
 631                 /* make sure sring is larger than desc ring */
 632                 wil->rx_status_ring_order = desc_ring_order + 1;
 633         if (wil->rx_buff_id_count <= desc_ring_size)
 634                 /* make sure we will not run out of buff_ids */
 635                 wil->rx_buff_id_count = desc_ring_size + 512;
 636         if (wil->rx_status_ring_order < WIL_SRING_SIZE_ORDER_MIN ||
 637             wil->rx_status_ring_order > WIL_SRING_SIZE_ORDER_MAX)
 638                 wil->rx_status_ring_order = WIL_RX_SRING_SIZE_ORDER_DEFAULT;
 639
 640         status_ring_size = 1 << wil->rx_status_ring_order;
 641
 642         wil_dbg_misc(wil,
 643                      "rx_init, desc_ring_size=%u, status_ring_size=%u, elem_size=%zu\n",
 644                      desc_ring_size, status_ring_size, elem_size);
 645
 646         wil_rx_buf_len_init_edma(wil);
 647
 648         /* Use debugfs dbg_num_rx_srings if set, reserve one sring for TX */
 649         if (wil->num_rx_status_rings > WIL6210_MAX_STATUS_RINGS - 1)
 650                 wil->num_rx_status_rings = WIL6210_MAX_STATUS_RINGS - 1;
 651
 652         wil_dbg_misc(wil, "rx_init: allocate %d status rings\n",
 653                      wil->num_rx_status_rings);
 654
 655         rc = wil_wmi_cfg_def_rx_offload(wil, wil->rx_buf_len);
 656         if (rc)
 657                 return rc;
 658
 659         /* Allocate status ring */
 660         for (i = 0; i < wil->num_rx_status_rings; i++) {
 661                 int sring_id = wil_find_free_sring(wil);
 662
 663                 if (sring_id < 0) {
 664                         rc = -EFAULT;
 665                         goto err_free_status;
 666                 }
 667                 rc = wil_init_rx_sring(wil, status_ring_size, elem_size,
 668                                        sring_id);
 669                 if (rc)
 670                         goto err_free_status;
 671         }
 672
 673         /* Allocate descriptor ring */
 674         rc = wil_init_rx_desc_ring(wil, desc_ring_size,
 675                                    WIL_DEFAULT_RX_STATUS_RING_ID);
 676         if (rc)
 677                 goto err_free_status;
 678
 679         if (wil->rx_buff_id_count >= status_ring_size) {
 680                 wil_info(wil,
 681                          "rx_buff_id_count %d exceeds sring_size %d. set it to %d\n",
 682                          wil->rx_buff_id_count, status_ring_size,
 683                          status_ring_size - 1);
 684                 wil->rx_buff_id_count = status_ring_size - 1;
 685         }
 686
 687         /* Allocate Rx buffer array */
 688         rc = wil_init_rx_buff_arr(wil, wil->rx_buff_id_count);
 689         if (rc)
 690                 goto err_free_desc;
 691
 692         /* Fill descriptor ring with credits */
 693         rc = wil_rx_refill_edma(wil);
 694         if (rc)
 695                 goto err_free_rx_buff_arr;
 696
 697         return 0;
 698 err_free_rx_buff_arr:
 699         wil_free_rx_buff_arr(wil);
 700 err_free_desc:
 701         wil_ring_free_edma(wil, ring);
 702 err_free_status:
 703         for (i = 0; i < wil->num_rx_status_rings; i++)
 704                 wil_sring_free(wil, &wil->srings[i]);
 705
 706         return rc;
 707 }
 708
 709 static int wil_ring_init_tx_edma(struct wil6210_vif *vif, int ring_id,
 710                                  int size, int cid, int tid)
 711 {
 712         struct wil6210_priv *wil = vif_to_wil(vif);
 713         int rc;
 714         struct wil_ring *ring = &wil->ring_tx[ring_id];
 715         struct wil_ring_tx_data *txdata = &wil->ring_tx_data[ring_id];
 716
 717         lockdep_assert_held(&wil->mutex);
 718
 719         wil_dbg_misc(wil,
 720                      "init TX ring: ring_id=%u, cid=%u, tid=%u, sring_id=%u\n",
 721                      ring_id, cid, tid, wil->tx_sring_idx);
 722
 723         wil_tx_data_init(txdata);
 724         ring->size = size;
 725         rc = wil_ring_alloc_desc_ring(wil, ring);
 726         if (rc)
 727                 goto out;
 728
 729         wil->ring2cid_tid[ring_id][0] = cid;
 730         wil->ring2cid_tid[ring_id][1] = tid;
 731         if (!vif->privacy)
 732                 txdata->dot1x_open = true;
 733
 734         rc = wil_wmi_tx_desc_ring_add(vif, ring_id, cid, tid);
 735         if (rc) {
 736                 wil_err(wil, "WMI_TX_DESC_RING_ADD_CMD failed\n");
 737                 goto out_free;
 738         }
 739
 740         if (txdata->dot1x_open && agg_wsize >= 0)
 741                 wil_addba_tx_request(wil, ring_id, agg_wsize);
 742
 743         return 0;
 744  out_free:
 745         spin_lock_bh(&txdata->lock);
 746         txdata->dot1x_open = false;
 747         txdata->enabled = 0;
 748         spin_unlock_bh(&txdata->lock);
 749         wil_ring_free_edma(wil, ring);
 750         wil->ring2cid_tid[ring_id][0] = wil->max_assoc_sta;
 751         wil->ring2cid_tid[ring_id][1] = 0;
 752
 753  out:
 754         return rc;
 755 }
 756
 757 static int wil_tx_ring_modify_edma(struct wil6210_vif *vif, int ring_id,
 758                                    int cid, int tid)
 759 {
 760         struct wil6210_priv *wil = vif_to_wil(vif);
 761
 762         wil_err(wil, "ring modify is not supported for EDMA\n");
 763
 764         return -EOPNOTSUPP;
 765 }
 766
 767 /* This function is used only for RX SW reorder */
 768 static int wil_check_bar(struct wil6210_priv *wil, void *msg, int cid,
 769                          struct sk_buff *skb, struct wil_net_stats *stats)
 770 {
 771         u8 ftype;
 772         u8 fc1;
 773         int mid;
 774         int tid;
 775         u16 seq;
 776         struct wil6210_vif *vif;
 777
 778         ftype = wil_rx_status_get_frame_type(wil, msg);
 779         if (ftype == IEEE80211_FTYPE_DATA)
 780                 return 0;
 781
 782         fc1 = wil_rx_status_get_fc1(wil, msg);
 783         mid = wil_rx_status_get_mid(msg);
 784         tid = wil_rx_status_get_tid(msg);
 785         seq = le16_to_cpu(wil_rx_status_get_seq(wil, msg));
 786         vif = wil->vifs[mid];
 787
 788         if (unlikely(!vif)) {
 789                 wil_dbg_txrx(wil, "RX descriptor with invalid mid %d", mid);
 790                 return -EAGAIN;
 791         }
 792
 793         wil_dbg_txrx(wil,
 794                      "Non-data frame FC[7:0] 0x%02x MID %d CID %d TID %d Seq 0x%03x\n",
 795                      fc1, mid, cid, tid, seq);
 796         if (stats)
 797                 stats->rx_non_data_frame++;
 798         if (wil_is_back_req(fc1)) {
 799                 wil_dbg_txrx(wil,
 800                              "BAR: MID %d CID %d TID %d Seq 0x%03x\n",
 801                              mid, cid, tid, seq);
 802                 wil_rx_bar(wil, vif, cid, tid, seq);
 803         } else {
 804                 u32 sz = wil->use_compressed_rx_status ?
 805                         sizeof(struct wil_rx_status_compressed) :
 806                         sizeof(struct wil_rx_status_extended);
 807
 808                 /* print again all info. One can enable only this
 809                  * without overhead for printing every Rx frame
 810                  */
 811                 wil_dbg_txrx(wil,
 812                              "Unhandled non-data frame FC[7:0] 0x%02x MID %d CID %d TID %d Seq 0x%03x\n",
 813                              fc1, mid, cid, tid, seq);
 814                 wil_hex_dump_txrx("RxS ", DUMP_PREFIX_NONE, 32, 4,
 815                                   (const void *)msg, sz, false);
 816                 wil_hex_dump_txrx("Rx ", DUMP_PREFIX_OFFSET, 16, 1,
 817                                   skb->data, skb_headlen(skb), false);
 818         }
 819
 820         return -EAGAIN;
 821 }
 822
 823 static int wil_rx_error_check_edma(struct wil6210_priv *wil,
 824                                    struct sk_buff *skb,
 825                                    struct wil_net_stats *stats)
 826 {
 827         int l2_rx_status;
 828         void *msg = wil_skb_rxstatus(skb);
 829
 830         l2_rx_status = wil_rx_status_get_l2_rx_status(msg);
 831         if (l2_rx_status != 0) {
 832                 wil_dbg_txrx(wil, "L2 RX error, l2_rx_status=0x%x\n",
 833                              l2_rx_status);
 834                 /* Due to HW issue, KEY error will trigger a MIC error */
 835                 if (l2_rx_status == WIL_RX_EDMA_ERROR_MIC) {
 836                         wil_err_ratelimited(wil,
 837                                             "L2 MIC/KEY error, dropping packet\n");
 838                         stats->rx_mic_error++;
 839                 }
 840                 if (l2_rx_status == WIL_RX_EDMA_ERROR_KEY) {
 841                         wil_err_ratelimited(wil,
 842                                             "L2 KEY error, dropping packet\n");
 843                         stats->rx_key_error++;
 844                 }
 845                 if (l2_rx_status == WIL_RX_EDMA_ERROR_REPLAY) {
 846                         wil_err_ratelimited(wil,
 847                                             "L2 REPLAY error, dropping packet\n");
 848                         stats->rx_replay++;
 849                 }
 850                 if (l2_rx_status == WIL_RX_EDMA_ERROR_AMSDU) {
 851                         wil_err_ratelimited(wil,
 852                                             "L2 AMSDU error, dropping packet\n");
 853                         stats->rx_amsdu_error++;
 854                 }
 855                 return -EFAULT;
 856         }
 857
 858         skb->ip_summed = wil_rx_status_get_checksum(msg, stats);
 859
 860         return 0;
 861 }
 862
 863 static struct sk_buff *wil_sring_reap_rx_edma(struct wil6210_priv *wil,
 864                                               struct wil_status_ring *sring)
 865 {
 866         struct device *dev = wil_to_dev(wil);
 867         struct wil_rx_status_extended msg1;
 868         void *msg = &msg1;
 869         u16 buff_id;
 870         struct sk_buff *skb;
 871         dma_addr_t pa;
 872         struct wil_ring_rx_data *rxdata = &sring->rx_data;
 873         unsigned int sz = wil->rx_buf_len;
 874         struct wil_net_stats *stats = NULL;
 875         u16 dmalen;
 876         int cid;
 877         bool eop, headstolen;
 878         int delta;
 879         u8 dr_bit;
 880         u8 data_offset;
 881         struct wil_rx_status_extended *s;
 882         u16 sring_idx = sring - wil->srings;
 883         int invalid_buff_id_retry;
 884
 885         BUILD_BUG_ON(sizeof(struct wil_rx_status_extended) > sizeof(skb->cb));
 886
 887 again:
 888         wil_get_next_rx_status_msg(sring, &dr_bit, msg);
 889
 890         /* Completed handling all the ready status messages */
 891         if (dr_bit != sring->desc_rdy_pol)
 892                 return NULL;
 893
 894         /* Extract the buffer ID from the status message */
 895         buff_id = le16_to_cpu(wil_rx_status_get_buff_id(msg));
 896
 897         invalid_buff_id_retry = 0;
 898         while (!buff_id) {
 899                 struct wil_rx_status_extended *s;
 900
 901                 wil_dbg_txrx(wil,
 902                              "buff_id is not updated yet by HW, (swhead 0x%x)\n",
 903                              sring->swhead);
 904                 if (++invalid_buff_id_retry > MAX_INVALID_BUFF_ID_RETRY)
 905                         break;
 906
 907                 /* Read the status message again */
 908                 s = (struct wil_rx_status_extended *)
 909                         (sring->va + (sring->elem_size * sring->swhead));
 910                 *(struct wil_rx_status_extended *)msg = *s;
 911                 buff_id = le16_to_cpu(wil_rx_status_get_buff_id(msg));
 912         }
 913
 914         if (unlikely(!wil_val_in_range(buff_id, 1, wil->rx_buff_mgmt.size))) {
 915                 wil_err(wil, "Corrupt buff_id=%d, sring->swhead=%d\n",
 916                         buff_id, sring->swhead);
 917                 wil_rx_status_reset_buff_id(sring);
 918                 wil_sring_advance_swhead(sring);
 919                 sring->invalid_buff_id_cnt++;
 920                 goto again;
 921         }
 922
 923         /* Extract the SKB from the rx_buff management array */
 924         skb = wil->rx_buff_mgmt.buff_arr[buff_id].skb;
 925         wil->rx_buff_mgmt.buff_arr[buff_id].skb = NULL;
 926         if (!skb) {
 927                 wil_err(wil, "No Rx skb at buff_id %d\n", buff_id);
 928                 wil_rx_status_reset_buff_id(sring);
 929                 /* Move the buffer from the active list to the free list */
 930                 list_move_tail(&wil->rx_buff_mgmt.buff_arr[buff_id].list,
 931                                &wil->rx_buff_mgmt.free);
 932                 wil_sring_advance_swhead(sring);
 933                 sring->invalid_buff_id_cnt++;
 934                 goto again;
 935         }
 936
 937         wil_rx_status_reset_buff_id(sring);
 938         wil_sring_advance_swhead(sring);
 939
 940         memcpy(&pa, skb->cb, sizeof(pa));
 941         dma_unmap_single(dev, pa, sz, DMA_FROM_DEVICE);
 942         dmalen = le16_to_cpu(wil_rx_status_get_length(msg));
 943
 944         trace_wil6210_rx_status(wil, wil->use_compressed_rx_status, buff_id,
 945                                 msg);
 946         wil_dbg_txrx(wil, "Rx, buff_id=%u, sring_idx=%u, dmalen=%u bytes\n",
 947                      buff_id, sring_idx, dmalen);
 948         wil_hex_dump_txrx("RxS ", DUMP_PREFIX_NONE, 32, 4,
 949                           (const void *)msg, wil->use_compressed_rx_status ?
 950                           sizeof(struct wil_rx_status_compressed) :
 951                           sizeof(struct wil_rx_status_extended), false);
 952
 953         /* Move the buffer from the active list to the free list */
 954         list_move_tail(&wil->rx_buff_mgmt.buff_arr[buff_id].list,
 955                        &wil->rx_buff_mgmt.free);
 956
 957         eop = wil_rx_status_get_eop(msg);
 958
 959         cid = wil_rx_status_get_cid(msg);
 960         if (unlikely(!wil_val_in_range(cid, 0, wil->max_assoc_sta))) {
 961                 wil_err(wil, "Corrupt cid=%d, sring->swhead=%d\n",
 962                         cid, sring->swhead);
 963                 rxdata->skipping = true;
 964                 goto skipping;
 965         }
 966         stats = &wil->sta[cid].stats;
 967
 968         if (unlikely(dmalen < ETH_HLEN)) {
 969                 wil_dbg_txrx(wil, "Short frame, len = %d\n", dmalen);
 970                 stats->rx_short_frame++;
 971                 rxdata->skipping = true;
 972                 goto skipping;
 973         }
 974
 975         if (unlikely(dmalen > sz)) {
 976                 wil_err(wil, "Rx size too large: %d bytes!\n", dmalen);
 977                 stats->rx_large_frame++;
 978                 rxdata->skipping = true;
 979         }
 980
 981 skipping:
 982         /* skipping indicates if a certain SKB should be dropped.
 983          * It is set in case there is an error on the current SKB or in case
 984          * of RX chaining: as long as we manage to merge the SKBs it will
 985          * be false. once we have a bad SKB or we don't manage to merge SKBs
 986          * it will be set to the !EOP value of the current SKB.
 987          * This guarantees that all the following SKBs until EOP will also
 988          * get dropped.
 989          */
 990         if (unlikely(rxdata->skipping)) {
 991                 kfree_skb(skb);
 992                 if (rxdata->skb) {
 993                         kfree_skb(rxdata->skb);
 994                         rxdata->skb = NULL;
 995                 }
 996                 rxdata->skipping = !eop;
 997                 goto again;
 998         }
 999
1000         skb_trim(skb, dmalen);
1001
1002         prefetch(skb->data);
1003
1004         if (!rxdata->skb) {
1005                 rxdata->skb = skb;
1006         } else {
1007                 if (likely(skb_try_coalesce(rxdata->skb, skb, &headstolen,
1008                                             &delta))) {
1009                         kfree_skb_partial(skb, headstolen);
1010                 } else {
1011                         wil_err(wil, "failed to merge skbs!\n");
1012                         kfree_skb(skb);
1013                         kfree_skb(rxdata->skb);
1014                         rxdata->skb = NULL;
1015                         rxdata->skipping = !eop;
1016                         goto again;
1017                 }
1018         }
1019
1020         if (!eop)
1021                 goto again;
1022
1023         /* reaching here rxdata->skb always contains a full packet */
1024         skb = rxdata->skb;
1025         rxdata->skb = NULL;
1026         rxdata->skipping = false;
1027
1028         if (stats) {
1029                 stats->last_mcs_rx = wil_rx_status_get_mcs(msg);
1030                 if (stats->last_mcs_rx < ARRAY_SIZE(stats->rx_per_mcs))
1031                         stats->rx_per_mcs[stats->last_mcs_rx]++;
1032
1033                 stats->last_cb_mode_rx  = wil_rx_status_get_cb_mode(msg);
1034         }
1035
1036         if (!wil->use_rx_hw_reordering && !wil->use_compressed_rx_status &&
1037             wil_check_bar(wil, msg, cid, skb, stats) == -EAGAIN) {
1038                 kfree_skb(skb);
1039                 goto again;
1040         }
1041
1042         /* Compensate for the HW data alignment according to the status
1043          * message
1044          */
1045         data_offset = wil_rx_status_get_data_offset(msg);
1046         if (data_offset == 0xFF ||
1047             data_offset > WIL_EDMA_MAX_DATA_OFFSET) {
1048                 wil_err(wil, "Unexpected data offset %d\n", data_offset);
1049                 kfree_skb(skb);
1050                 goto again;
1051         }
1052
1053         skb_pull(skb, data_offset);
1054
1055         wil_hex_dump_txrx("Rx ", DUMP_PREFIX_OFFSET, 16, 1,
1056                           skb->data, skb_headlen(skb), false);
1057
1058         /* Has to be done after dma_unmap_single as skb->cb is also
1059          * used for holding the pa
1060          */
1061         s = wil_skb_rxstatus(skb);
1062         memcpy(s, msg, sring->elem_size);
1063
1064         return skb;
1065 }
1066
1067 void wil_rx_handle_edma(struct wil6210_priv *wil, int *quota)
1068 {
1069         struct net_device *ndev;
1070         struct wil_ring *ring = &wil->ring_rx;
1071         struct wil_status_ring *sring;
1072         struct sk_buff *skb;
1073         int i;
1074
1075         if (unlikely(!ring->va)) {
1076                 wil_err(wil, "Rx IRQ while Rx not yet initialized\n");
1077                 return;
1078         }
1079         wil_dbg_txrx(wil, "rx_handle\n");
1080
1081         for (i = 0; i < wil->num_rx_status_rings; i++) {
1082                 sring = &wil->srings[i];
1083                 if (unlikely(!sring->va)) {
1084                         wil_err(wil,
1085                                 "Rx IRQ while Rx status ring %d not yet initialized\n",
1086                                 i);
1087                         continue;
1088                 }
1089
1090                 while ((*quota > 0) &&
1091                        (NULL != (skb =
1092                         wil_sring_reap_rx_edma(wil, sring)))) {
1093                         (*quota)--;
1094                         if (wil->use_rx_hw_reordering) {
1095                                 void *msg = wil_skb_rxstatus(skb);
1096                                 int mid = wil_rx_status_get_mid(msg);
1097                                 struct wil6210_vif *vif = wil->vifs[mid];
1098
1099                                 if (unlikely(!vif)) {
1100                                         wil_dbg_txrx(wil,
1101                                                      "RX desc invalid mid %d",
1102                                                      mid);
1103                                         kfree_skb(skb);
1104                                         continue;
1105                                 }
1106                                 ndev = vif_to_ndev(vif);
1107                                 wil_netif_rx_any(skb, ndev);
1108                         } else {
1109                                 wil_rx_reorder(wil, skb);
1110                         }
1111                 }
1112
1113                 wil_w(wil, sring->hwtail, (sring->swhead - 1) % sring->size);
1114         }
1115
1116         wil_rx_refill_edma(wil);
1117 }
1118
1119 static int wil_tx_desc_map_edma(union wil_tx_desc *desc,
1120                                 dma_addr_t pa,
1121                                 u32 len,
1122                                 int ring_index)
1123 {
1124         struct wil_tx_enhanced_desc *d =
1125                 (struct wil_tx_enhanced_desc *)&desc->enhanced;
1126
1127         memset(d, 0, sizeof(struct wil_tx_enhanced_desc));
1128
1129         wil_desc_set_addr_edma(&d->dma.addr, &d->dma.addr_high_high, pa);
1130
1131         /* 0..6: mac_length; 7:ip_version 0-IP6 1-IP4*/
1132         d->dma.length = cpu_to_le16((u16)len);
1133         d->mac.d[0] = (ring_index << WIL_EDMA_DESC_TX_MAC_CFG_0_QID_POS);
1134         /* translation type:  0 - bypass; 1 - 802.3; 2 - native wifi;
1135          * 3 - eth mode
1136          */
1137         d->mac.d[2] = BIT(MAC_CFG_DESC_TX_2_SNAP_HDR_INSERTION_EN_POS) |
1138                       (0x3 << MAC_CFG_DESC_TX_2_L2_TRANSLATION_TYPE_POS);
1139
1140         return 0;
1141 }
1142
1143 static inline void
1144 wil_get_next_tx_status_msg(struct wil_status_ring *sring, u8 *dr_bit,
1145                            struct wil_ring_tx_status *msg)
1146 {
1147         struct wil_ring_tx_status *_msg = (struct wil_ring_tx_status *)
1148                 (sring->va + (sring->elem_size * sring->swhead));
1149
1150         *dr_bit = _msg->desc_ready >> TX_STATUS_DESC_READY_POS;
1151         /* make sure dr_bit is read before the rest of status msg */
1152         rmb();
1153         *msg = *_msg;
1154 }
1155
1156 /**
1157  * Clean up transmitted skb's from the Tx descriptor RING.
1158  * Return number of descriptors cleared.
1159  */
1160 int wil_tx_sring_handler(struct wil6210_priv *wil,
1161                          struct wil_status_ring *sring)
1162 {
1163         struct net_device *ndev;
1164         struct device *dev = wil_to_dev(wil);
1165         struct wil_ring *ring = NULL;
1166         struct wil_ring_tx_data *txdata;
1167         /* Total number of completed descriptors in all descriptor rings */
1168         int desc_cnt = 0;
1169         int cid;
1170         struct wil_net_stats *stats;
1171         struct wil_tx_enhanced_desc *_d;
1172         unsigned int ring_id;
1173         unsigned int num_descs, num_statuses = 0;
1174         int i;
1175         u8 dr_bit; /* Descriptor Ready bit */
1176         struct wil_ring_tx_status msg;
1177         struct wil6210_vif *vif;
1178         int used_before_complete;
1179         int used_new;
1180
1181         wil_get_next_tx_status_msg(sring, &dr_bit, &msg);
1182
1183         /* Process completion messages while DR bit has the expected polarity */
1184         while (dr_bit == sring->desc_rdy_pol) {
1185                 num_descs = msg.num_descriptors;
1186                 if (!num_descs) {
1187                         wil_err(wil, "invalid num_descs 0\n");
1188                         goto again;
1189                 }
1190
1191                 /* Find the corresponding descriptor ring */
1192                 ring_id = msg.ring_id;
1193
1194                 if (unlikely(ring_id >= WIL6210_MAX_TX_RINGS)) {
1195                         wil_err(wil, "invalid ring id %d\n", ring_id);
1196                         goto again;
1197                 }
1198                 ring = &wil->ring_tx[ring_id];
1199                 if (unlikely(!ring->va)) {
1200                         wil_err(wil, "Tx irq[%d]: ring not initialized\n",
1201                                 ring_id);
1202                         goto again;
1203                 }
1204                 txdata = &wil->ring_tx_data[ring_id];
1205                 if (unlikely(!txdata->enabled)) {
1206                         wil_info(wil, "Tx irq[%d]: ring disabled\n", ring_id);
1207                         goto again;
1208                 }
1209                 vif = wil->vifs[txdata->mid];
1210                 if (unlikely(!vif)) {
1211                         wil_dbg_txrx(wil, "invalid MID %d for ring %d\n",
1212                                      txdata->mid, ring_id);
1213                         goto again;
1214                 }
1215
1216                 ndev = vif_to_ndev(vif);
1217
1218                 cid = wil->ring2cid_tid[ring_id][0];
1219                 stats = (cid < wil->max_assoc_sta) ? &wil->sta[cid].stats :
1220                                                      NULL;
1221
1222                 wil_dbg_txrx(wil,
1223                              "tx_status: completed desc_ring (%d), num_descs (%d)\n",
1224                              ring_id, num_descs);
1225
1226                 used_before_complete = wil_ring_used_tx(ring);
1227
1228                 for (i = 0 ; i < num_descs; ++i) {
1229                         struct wil_ctx *ctx = &ring->ctx[ring->swtail];
1230                         struct wil_tx_enhanced_desc dd, *d = &dd;
1231                         u16 dmalen;
1232                         struct sk_buff *skb = ctx->skb;
1233
1234                         _d = (struct wil_tx_enhanced_desc *)
1235                                 &ring->va[ring->swtail].tx.enhanced;
1236                         *d = *_d;
1237
1238                         dmalen = le16_to_cpu(d->dma.length);
1239                         trace_wil6210_tx_status(&msg, ring->swtail, dmalen);
1240                         wil_dbg_txrx(wil,
1241                                      "TxC[%2d][%3d] : %d bytes, status 0x%02x\n",
1242                                      ring_id, ring->swtail, dmalen,
1243                                      msg.status);
1244                         wil_hex_dump_txrx("TxS ", DUMP_PREFIX_NONE, 32, 4,
1245                                           (const void *)&msg, sizeof(msg),
1246                                           false);
1247
1248                         wil_tx_desc_unmap_edma(dev,
1249                                                (union wil_tx_desc *)d,
1250                                                ctx);
1251
1252                         if (skb) {
1253                                 if (likely(msg.status == 0)) {
1254                                         ndev->stats.tx_packets++;
1255                                         ndev->stats.tx_bytes += skb->len;
1256                                         if (stats) {
1257                                                 stats->tx_packets++;
1258                                                 stats->tx_bytes += skb->len;
1259
1260                                                 wil_tx_latency_calc(wil, skb,
1261                                                         &wil->sta[cid]);
1262                                         }
1263                                 } else {
1264                                         ndev->stats.tx_errors++;
1265                                         if (stats)
1266                                                 stats->tx_errors++;
1267                                 }
1268
1269                                 if (skb->protocol == cpu_to_be16(ETH_P_PAE))
1270                                         wil_tx_complete_handle_eapol(vif, skb);
1271
1272                                 wil_consume_skb(skb, msg.status == 0);
1273                         }
1274                         memset(ctx, 0, sizeof(*ctx));
1275                         /* Make sure the ctx is zeroed before updating the tail
1276                          * to prevent a case where wil_tx_ring will see
1277                          * this descriptor as used and handle it before ctx zero
1278                          * is completed.
1279                          */
1280                         wmb();
1281
1282                         ring->swtail = wil_ring_next_tail(ring);
1283
1284                         desc_cnt++;
1285                 }
1286
1287                 /* performance monitoring */
1288                 used_new = wil_ring_used_tx(ring);
1289                 if (wil_val_in_range(wil->ring_idle_trsh,
1290                                      used_new, used_before_complete)) {
1291                         wil_dbg_txrx(wil, "Ring[%2d] idle %d -> %d\n",
1292                                      ring_id, used_before_complete, used_new);
1293                         txdata->last_idle = get_cycles();
1294                 }
1295
1296 again:
1297                 num_statuses++;
1298                 if (num_statuses % WIL_EDMA_TX_SRING_UPDATE_HW_TAIL == 0)
1299                         /* update HW tail to allow HW to push new statuses */
1300                         wil_w(wil, sring->hwtail, sring->swhead);
1301
1302                 wil_sring_advance_swhead(sring);
1303
1304                 wil_get_next_tx_status_msg(sring, &dr_bit, &msg);
1305         }
1306
1307         /* shall we wake net queues? */
1308         if (desc_cnt)
1309                 wil_update_net_queues(wil, vif, NULL, false);
1310
1311         if (num_statuses % WIL_EDMA_TX_SRING_UPDATE_HW_TAIL != 0)
1312                 /* Update the HW tail ptr (RD ptr) */
1313                 wil_w(wil, sring->hwtail, (sring->swhead - 1) % sring->size);
1314
1315         return desc_cnt;
1316 }
1317
1318 /**
1319  * Sets the descriptor @d up for csum and/or TSO offloading. The corresponding
1320  * @skb is used to obtain the protocol and headers length.
1321  * @tso_desc_type is a descriptor type for TSO: 0 - a header, 1 - first data,
1322  * 2 - middle, 3 - last descriptor.
1323  */
1324 static void wil_tx_desc_offload_setup_tso_edma(struct wil_tx_enhanced_desc *d,
1325                                                int tso_desc_type, bool is_ipv4,
1326                                                int tcp_hdr_len,
1327                                                int skb_net_hdr_len,
1328                                                int mss)
1329 {
1330         /* Number of descriptors */
1331         d->mac.d[2] |= 1;
1332         /* Maximum Segment Size */
1333         d->mac.tso_mss |= cpu_to_le16(mss >> 2);
1334         /* L4 header len: TCP header length */
1335         d->dma.l4_hdr_len |= tcp_hdr_len & DMA_CFG_DESC_TX_0_L4_LENGTH_MSK;
1336         /* EOP, TSO desc type, Segmentation enable,
1337          * Insert IPv4 and TCP / UDP Checksum
1338          */
1339         d->dma.cmd |= BIT(WIL_EDMA_DESC_TX_CFG_EOP_POS) |
1340                       tso_desc_type << WIL_EDMA_DESC_TX_CFG_TSO_DESC_TYPE_POS |
1341                       BIT(WIL_EDMA_DESC_TX_CFG_SEG_EN_POS) |
1342                       BIT(WIL_EDMA_DESC_TX_CFG_INSERT_IP_CHKSUM_POS) |
1343                       BIT(WIL_EDMA_DESC_TX_CFG_INSERT_TCP_CHKSUM_POS);
1344         /* Calculate pseudo-header */
1345         d->dma.w1 |= BIT(WIL_EDMA_DESC_TX_CFG_PSEUDO_HEADER_CALC_EN_POS) |
1346                      BIT(WIL_EDMA_DESC_TX_CFG_L4_TYPE_POS);
1347         /* IP Header Length */
1348         d->dma.ip_length |= skb_net_hdr_len;
1349         /* MAC header length and IP address family*/
1350         d->dma.b11 |= ETH_HLEN |
1351                       is_ipv4 << DMA_CFG_DESC_TX_OFFLOAD_CFG_L3T_IPV4_POS;
1352 }
1353
1354 static int wil_tx_tso_gen_desc(struct wil6210_priv *wil, void *buff_addr,
1355                                int len, uint i, int tso_desc_type,
1356                                skb_frag_t *frag, struct wil_ring *ring,
1357                                struct sk_buff *skb, bool is_ipv4,
1358                                int tcp_hdr_len, int skb_net_hdr_len,
1359                                int mss, int *descs_used)
1360 {
1361         struct device *dev = wil_to_dev(wil);
1362         struct wil_tx_enhanced_desc *_desc = (struct wil_tx_enhanced_desc *)
1363                 &ring->va[i].tx.enhanced;
1364         struct wil_tx_enhanced_desc desc_mem, *d = &desc_mem;
1365         int ring_index = ring - wil->ring_tx;
1366         dma_addr_t pa;
1367
1368         if (len == 0)
1369                 return 0;
1370
1371         if (!frag) {
1372                 pa = dma_map_single(dev, buff_addr, len, DMA_TO_DEVICE);
1373                 ring->ctx[i].mapped_as = wil_mapped_as_single;
1374         } else {
1375                 pa = skb_frag_dma_map(dev, frag, 0, len, DMA_TO_DEVICE);
1376                 ring->ctx[i].mapped_as = wil_mapped_as_page;
1377         }
1378         if (unlikely(dma_mapping_error(dev, pa))) {
1379                 wil_err(wil, "TSO: Skb DMA map error\n");
1380                 return -EINVAL;
1381         }
1382
1383         wil->txrx_ops.tx_desc_map((union wil_tx_desc *)d, pa,
1384                                    len, ring_index);
1385         wil_tx_desc_offload_setup_tso_edma(d, tso_desc_type, is_ipv4,
1386                                            tcp_hdr_len,
1387                                            skb_net_hdr_len, mss);
1388
1389         /* hold reference to skb
1390          * to prevent skb release before accounting
1391          * in case of immediate "tx done"
1392          */
1393         if (tso_desc_type == wil_tso_type_lst)
1394                 ring->ctx[i].skb = skb_get(skb);
1395
1396         wil_hex_dump_txrx("TxD ", DUMP_PREFIX_NONE, 32, 4,
1397                           (const void *)d, sizeof(*d), false);
1398
1399         *_desc = *d;
1400         (*descs_used)++;
1401
1402         return 0;
1403 }
1404
1405 static int __wil_tx_ring_tso_edma(struct wil6210_priv *wil,
1406                                   struct wil6210_vif *vif,
1407                                   struct wil_ring *ring,
1408                                   struct sk_buff *skb)
1409 {
1410         int ring_index = ring - wil->ring_tx;
1411         struct wil_ring_tx_data *txdata = &wil->ring_tx_data[ring_index];
1412         int nr_frags = skb_shinfo(skb)->nr_frags;
1413         int min_desc_required = nr_frags + 2; /* Headers, Head, Fragments */
1414         int used, avail = wil_ring_avail_tx(ring);
1415         int f, hdrlen, headlen;
1416         int gso_type;
1417         bool is_ipv4;
1418         u32 swhead = ring->swhead;
1419         int descs_used = 0; /* total number of used descriptors */
1420         int rc = -EINVAL;
1421         int tcp_hdr_len;
1422         int skb_net_hdr_len;
1423         int mss = skb_shinfo(skb)->gso_size;
1424
1425         wil_dbg_txrx(wil, "tx_ring_tso: %d bytes to ring %d\n", skb->len,
1426                      ring_index);
1427
1428         if (unlikely(!txdata->enabled))
1429                 return -EINVAL;
1430
1431         if (unlikely(avail < min_desc_required)) {
1432                 wil_err_ratelimited(wil,
1433                                     "TSO: Tx ring[%2d] full. No space for %d fragments\n",
1434                                     ring_index, min_desc_required);
1435                 return -ENOMEM;
1436         }
1437
1438         gso_type = skb_shinfo(skb)->gso_type & (SKB_GSO_TCPV6 | SKB_GSO_TCPV4);
1439         switch (gso_type) {
1440         case SKB_GSO_TCPV4:
1441                 is_ipv4 = true;
1442                 break;
1443         case SKB_GSO_TCPV6:
1444                 is_ipv4 = false;
1445                 break;
1446         default:
1447                 return -EINVAL;
1448         }
1449
1450         if (skb->ip_summed != CHECKSUM_PARTIAL)
1451                 return -EINVAL;
1452
1453         /* tcp header length and skb network header length are fixed for all
1454          * packet's descriptors - read them once here
1455          */
1456         tcp_hdr_len = tcp_hdrlen(skb);
1457         skb_net_hdr_len = skb_network_header_len(skb);
1458
1459         /* First descriptor must contain the header only
1460          * Header Length = MAC header len + IP header len + TCP header len
1461          */
1462         hdrlen = ETH_HLEN + tcp_hdr_len + skb_net_hdr_len;
1463         wil_dbg_txrx(wil, "TSO: process header descriptor, hdrlen %u\n",
1464                      hdrlen);
1465         rc = wil_tx_tso_gen_desc(wil, skb->data, hdrlen, swhead,
1466                                  wil_tso_type_hdr, NULL, ring, skb,
1467                                  is_ipv4, tcp_hdr_len, skb_net_hdr_len,
1468                                  mss, &descs_used);
1469         if (rc)
1470                 return -EINVAL;
1471
1472         /* Second descriptor contains the head */
1473         headlen = skb_headlen(skb) - hdrlen;
1474         wil_dbg_txrx(wil, "TSO: process skb head, headlen %u\n", headlen);
1475         rc = wil_tx_tso_gen_desc(wil, skb->data + hdrlen, headlen,
1476                                  (swhead + descs_used) % ring->size,
1477                                  (nr_frags != 0) ? wil_tso_type_first :
1478                                  wil_tso_type_lst, NULL, ring, skb,
1479                                  is_ipv4, tcp_hdr_len, skb_net_hdr_len,
1480                                  mss, &descs_used);
1481         if (rc)
1482                 goto mem_error;
1483
1484         /* Rest of the descriptors are from the SKB fragments */
1485         for (f = 0; f < nr_frags; f++) {
1486                 skb_frag_t *frag = &skb_shinfo(skb)->frags[f];
1487                 int len = skb_frag_size(frag);
1488
1489                 wil_dbg_txrx(wil, "TSO: frag[%d]: len %u, descs_used %d\n", f,
1490                              len, descs_used);
1491
1492                 rc = wil_tx_tso_gen_desc(wil, NULL, len,
1493                                          (swhead + descs_used) % ring->size,
1494                                          (f != nr_frags - 1) ?
1495                                          wil_tso_type_mid : wil_tso_type_lst,
1496                                          frag, ring, skb, is_ipv4,
1497                                          tcp_hdr_len, skb_net_hdr_len,
1498                                          mss, &descs_used);
1499                 if (rc)
1500                         goto mem_error;
1501         }
1502
1503         /* performance monitoring */
1504         used = wil_ring_used_tx(ring);
1505         if (wil_val_in_range(wil->ring_idle_trsh,
1506                              used, used + descs_used)) {
1507                 txdata->idle += get_cycles() - txdata->last_idle;
1508                 wil_dbg_txrx(wil,  "Ring[%2d] not idle %d -> %d\n",
1509                              ring_index, used, used + descs_used);
1510         }
1511
1512         /* advance swhead */
1513         wil_ring_advance_head(ring, descs_used);
1514         wil_dbg_txrx(wil, "TSO: Tx swhead %d -> %d\n", swhead, ring->swhead);
1515
1516         /* make sure all writes to descriptors (shared memory) are done before
1517          * committing them to HW
1518          */
1519         wmb();
1520
1521         if (wil->tx_latency)
1522                 *(ktime_t *)&skb->cb = ktime_get();
1523         else
1524                 memset(skb->cb, 0, sizeof(ktime_t));
1525
1526         wil_w(wil, ring->hwtail, ring->swhead);
1527
1528         return 0;
1529
1530 mem_error:
1531         while (descs_used > 0) {
1532                 struct device *dev = wil_to_dev(wil);
1533                 struct wil_ctx *ctx;
1534                 int i = (swhead + descs_used - 1) % ring->size;
1535                 struct wil_tx_enhanced_desc dd, *d = &dd;
1536                 struct wil_tx_enhanced_desc *_desc =
1537                         (struct wil_tx_enhanced_desc *)
1538                         &ring->va[i].tx.enhanced;
1539
1540                 *d = *_desc;
1541                 ctx = &ring->ctx[i];
1542                 wil_tx_desc_unmap_edma(dev, (union wil_tx_desc *)d, ctx);
1543                 memset(ctx, 0, sizeof(*ctx));
1544                 descs_used--;
1545         }
1546         return rc;
1547 }
1548
1549 static int wil_ring_init_bcast_edma(struct wil6210_vif *vif, int ring_id,
1550                                     int size)
1551 {
1552         struct wil6210_priv *wil = vif_to_wil(vif);
1553         struct wil_ring *ring = &wil->ring_tx[ring_id];
1554         int rc;
1555         struct wil_ring_tx_data *txdata = &wil->ring_tx_data[ring_id];
1556
1557         wil_dbg_misc(wil, "init bcast: ring_id=%d, sring_id=%d\n",
1558                      ring_id, wil->tx_sring_idx);
1559
1560         lockdep_assert_held(&wil->mutex);
1561
1562         wil_tx_data_init(txdata);
1563         ring->size = size;
1564         ring->is_rx = false;
1565         rc = wil_ring_alloc_desc_ring(wil, ring);
1566         if (rc)
1567                 goto out;
1568
1569         wil->ring2cid_tid[ring_id][0] = WIL6210_MAX_CID; /* CID */
1570         wil->ring2cid_tid[ring_id][1] = 0; /* TID */
1571         if (!vif->privacy)
1572                 txdata->dot1x_open = true;
1573
1574         rc = wil_wmi_bcast_desc_ring_add(vif, ring_id);
1575         if (rc)
1576                 goto out_free;
1577
1578         return 0;
1579
1580  out_free:
1581         spin_lock_bh(&txdata->lock);
1582         txdata->enabled = 0;
1583         txdata->dot1x_open = false;
1584         spin_unlock_bh(&txdata->lock);
1585         wil_ring_free_edma(wil, ring);
1586
1587 out:
1588         return rc;
1589 }
1590
1591 static void wil_tx_fini_edma(struct wil6210_priv *wil)
1592 {
1593         struct wil_status_ring *sring = &wil->srings[wil->tx_sring_idx];
1594
1595         wil_dbg_misc(wil, "free TX sring\n");
1596
1597         wil_sring_free(wil, sring);
1598 }
1599
1600 static void wil_rx_data_free(struct wil_status_ring *sring)
1601 {
1602         if (!sring)
1603                 return;
1604
1605         kfree_skb(sring->rx_data.skb);
1606         sring->rx_data.skb = NULL;
1607 }
1608
1609 static void wil_rx_fini_edma(struct wil6210_priv *wil)
1610 {
1611         struct wil_ring *ring = &wil->ring_rx;
1612         int i;
1613
1614         wil_dbg_misc(wil, "rx_fini_edma\n");
1615
1616         wil_ring_free_edma(wil, ring);
1617
1618         for (i = 0; i < wil->num_rx_status_rings; i++) {
1619                 wil_rx_data_free(&wil->srings[i]);
1620                 wil_sring_free(wil, &wil->srings[i]);
1621         }
1622
1623         wil_free_rx_buff_arr(wil);
1624 }
1625
1626 void wil_init_txrx_ops_edma(struct wil6210_priv *wil)
1627 {
1628         wil->txrx_ops.configure_interrupt_moderation =
1629                 wil_configure_interrupt_moderation_edma;
1630         /* TX ops */
1631         wil->txrx_ops.ring_init_tx = wil_ring_init_tx_edma;
1632         wil->txrx_ops.ring_fini_tx = wil_ring_free_edma;
1633         wil->txrx_ops.ring_init_bcast = wil_ring_init_bcast_edma;
1634         wil->txrx_ops.tx_init = wil_tx_init_edma;
1635         wil->txrx_ops.tx_fini = wil_tx_fini_edma;
1636         wil->txrx_ops.tx_desc_map = wil_tx_desc_map_edma;
1637         wil->txrx_ops.tx_desc_unmap = wil_tx_desc_unmap_edma;
1638         wil->txrx_ops.tx_ring_tso = __wil_tx_ring_tso_edma;
1639         wil->txrx_ops.tx_ring_modify = wil_tx_ring_modify_edma;
1640         /* RX ops */
1641         wil->txrx_ops.rx_init = wil_rx_init_edma;
1642         wil->txrx_ops.wmi_addba_rx_resp = wmi_addba_rx_resp_edma;
1643         wil->txrx_ops.get_reorder_params = wil_get_reorder_params_edma;
1644         wil->txrx_ops.get_netif_rx_params = wil_get_netif_rx_params_edma;
1645         wil->txrx_ops.rx_crypto_check = wil_rx_crypto_check_edma;
1646         wil->txrx_ops.rx_error_check = wil_rx_error_check_edma;
1647         wil->txrx_ops.is_rx_idle = wil_is_rx_idle_edma;
1648         wil->txrx_ops.rx_fini = wil_rx_fini_edma;
1649 }
1650