drivers/net/sfc/sfc_ef100_tx.c

   1 /* SPDX-License-Identifier: BSD-3-Clause
   2  *
   3  * Copyright(c) 2019-2020 Xilinx, Inc.
   4  * Copyright(c) 2018-2019 Solarflare Communications Inc.
   5  *
   6  * This software was jointly developed between OKTET Labs (under contract
   7  * for Solarflare) and Solarflare Communications, Inc.
   8  */
   9
  10 #include <stdbool.h>
  11
  12 #include <rte_mbuf.h>
  13 #include <rte_io.h>
  14
  15 #include "efx.h"
  16 #include "efx_types.h"
  17 #include "efx_regs.h"
  18 #include "efx_regs_ef100.h"
  19
  20 #include "sfc_debug.h"
  21 #include "sfc_dp_tx.h"
  22 #include "sfc_tweak.h"
  23 #include "sfc_kvargs.h"
  24 #include "sfc_ef100.h"
  25
  26
  27 #define sfc_ef100_tx_err(_txq, ...) \
  28         SFC_DP_LOG(SFC_KVARG_DATAPATH_EF100, ERR, &(_txq)->dp.dpq, __VA_ARGS__)
  29
  30 #define sfc_ef100_tx_debug(_txq, ...) \
  31         SFC_DP_LOG(SFC_KVARG_DATAPATH_EF100, DEBUG, &(_txq)->dp.dpq, \
  32                    __VA_ARGS__)
  33
  34
  35 /** Maximum length of the send descriptor data */
  36 #define SFC_EF100_TX_SEND_DESC_LEN_MAX \
  37         ((1u << ESF_GZ_TX_SEND_LEN_WIDTH) - 1)
  38
  39 /** Maximum length of the segment descriptor data */
  40 #define SFC_EF100_TX_SEG_DESC_LEN_MAX \
  41         ((1u << ESF_GZ_TX_SEG_LEN_WIDTH) - 1)
  42
  43 /**
  44  * Maximum number of descriptors/buffers in the Tx ring.
  45  * It should guarantee that corresponding event queue never overfill.
  46  * EF100 native datapath uses event queue of the same size as Tx queue.
  47  * Maximum number of events on datapath can be estimated as number of
  48  * Tx queue entries (one event per Tx buffer in the worst case) plus
  49  * Tx error and flush events.
  50  */
  51 #define SFC_EF100_TXQ_LIMIT(_ndesc) \
  52         ((_ndesc) - 1 /* head must not step on tail */ - \
  53          1 /* Rx error */ - 1 /* flush */)
  54
  55 struct sfc_ef100_tx_sw_desc {
  56         struct rte_mbuf                 *mbuf;
  57 };
  58
  59 struct sfc_ef100_txq {
  60         unsigned int                    flags;
  61 #define SFC_EF100_TXQ_STARTED           0x1
  62 #define SFC_EF100_TXQ_NOT_RUNNING       0x2
  63 #define SFC_EF100_TXQ_EXCEPTION         0x4
  64
  65         unsigned int                    ptr_mask;
  66         unsigned int                    added;
  67         unsigned int                    completed;
  68         unsigned int                    max_fill_level;
  69         unsigned int                    free_thresh;
  70         struct sfc_ef100_tx_sw_desc     *sw_ring;
  71         efx_oword_t                     *txq_hw_ring;
  72         volatile void                   *doorbell;
  73
  74         /* Completion/reap */
  75         unsigned int                    evq_read_ptr;
  76         unsigned int                    evq_phase_bit_shift;
  77         volatile efx_qword_t            *evq_hw_ring;
  78
  79         /* Datapath transmit queue anchor */
  80         struct sfc_dp_txq               dp;
  81 };
  82
  83 static inline struct sfc_ef100_txq *
  84 sfc_ef100_txq_by_dp_txq(struct sfc_dp_txq *dp_txq)
  85 {
  86         return container_of(dp_txq, struct sfc_ef100_txq, dp);
  87 }
  88
  89 static uint16_t
  90 sfc_ef100_tx_prepare_pkts(void *tx_queue, struct rte_mbuf **tx_pkts,
  91                           uint16_t nb_pkts)
  92 {
  93         struct sfc_ef100_txq * const txq = sfc_ef100_txq_by_dp_txq(tx_queue);
  94         uint16_t i;
  95
  96         for (i = 0; i < nb_pkts; i++) {
  97                 struct rte_mbuf *m = tx_pkts[i];
  98                 int ret;
  99
 100                 ret = sfc_dp_tx_prepare_pkt(m, 0, txq->max_fill_level, 0, 0);
 101                 if (unlikely(ret != 0)) {
 102                         rte_errno = ret;
 103                         break;
 104                 }
 105
 106                 if (m->nb_segs > EFX_MASK32(ESF_GZ_TX_SEND_NUM_SEGS)) {
 107                         rte_errno = EINVAL;
 108                         break;
 109                 }
 110         }
 111
 112         return i;
 113 }
 114
 115 static bool
 116 sfc_ef100_tx_get_event(struct sfc_ef100_txq *txq, efx_qword_t *ev)
 117 {
 118         volatile efx_qword_t *evq_hw_ring = txq->evq_hw_ring;
 119
 120         /*
 121          * Exception flag is set when reap is done.
 122          * It is never done twice per packet burst get, and absence of
 123          * the flag is checked on burst get entry.
 124          */
 125         SFC_ASSERT((txq->flags & SFC_EF100_TXQ_EXCEPTION) == 0);
 126
 127         *ev = evq_hw_ring[txq->evq_read_ptr & txq->ptr_mask];
 128
 129         if (!sfc_ef100_ev_present(ev,
 130                         (txq->evq_read_ptr >> txq->evq_phase_bit_shift) & 1))
 131                 return false;
 132
 133         if (unlikely(!sfc_ef100_ev_type_is(ev,
 134                                            ESE_GZ_EF100_EV_TX_COMPLETION))) {
 135                 /*
 136                  * Do not move read_ptr to keep the event for exception
 137                  * handling by the control path.
 138                  */
 139                 txq->flags |= SFC_EF100_TXQ_EXCEPTION;
 140                 sfc_ef100_tx_err(txq,
 141                         "TxQ exception at EvQ ptr %u(%#x), event %08x:%08x",
 142                         txq->evq_read_ptr, txq->evq_read_ptr & txq->ptr_mask,
 143                         EFX_QWORD_FIELD(*ev, EFX_DWORD_1),
 144                         EFX_QWORD_FIELD(*ev, EFX_DWORD_0));
 145                 return false;
 146         }
 147
 148         sfc_ef100_tx_debug(txq, "TxQ got event %08x:%08x at %u (%#x)",
 149                            EFX_QWORD_FIELD(*ev, EFX_DWORD_1),
 150                            EFX_QWORD_FIELD(*ev, EFX_DWORD_0),
 151                            txq->evq_read_ptr,
 152                            txq->evq_read_ptr & txq->ptr_mask);
 153
 154         txq->evq_read_ptr++;
 155         return true;
 156 }
 157
 158 static unsigned int
 159 sfc_ef100_tx_process_events(struct sfc_ef100_txq *txq)
 160 {
 161         unsigned int num_descs = 0;
 162         efx_qword_t tx_ev;
 163
 164         while (sfc_ef100_tx_get_event(txq, &tx_ev))
 165                 num_descs += EFX_QWORD_FIELD(tx_ev, ESF_GZ_EV_TXCMPL_NUM_DESC);
 166
 167         return num_descs;
 168 }
 169
 170 static void
 171 sfc_ef100_tx_reap_num_descs(struct sfc_ef100_txq *txq, unsigned int num_descs)
 172 {
 173         if (num_descs > 0) {
 174                 unsigned int completed = txq->completed;
 175                 unsigned int pending = completed + num_descs;
 176                 struct rte_mbuf *bulk[SFC_TX_REAP_BULK_SIZE];
 177                 unsigned int nb = 0;
 178
 179                 do {
 180                         struct sfc_ef100_tx_sw_desc *txd;
 181                         struct rte_mbuf *m;
 182
 183                         txd = &txq->sw_ring[completed & txq->ptr_mask];
 184                         if (txd->mbuf == NULL)
 185                                 continue;
 186
 187                         m = rte_pktmbuf_prefree_seg(txd->mbuf);
 188                         if (m == NULL)
 189                                 continue;
 190
 191                         txd->mbuf = NULL;
 192
 193                         if (nb == RTE_DIM(bulk) ||
 194                             (nb != 0 && m->pool != bulk[0]->pool)) {
 195                                 rte_mempool_put_bulk(bulk[0]->pool,
 196                                                      (void *)bulk, nb);
 197                                 nb = 0;
 198                         }
 199
 200                         bulk[nb++] = m;
 201                 } while (++completed != pending);
 202
 203                 if (nb != 0)
 204                         rte_mempool_put_bulk(bulk[0]->pool, (void *)bulk, nb);
 205
 206                 txq->completed = completed;
 207         }
 208 }
 209
 210 static void
 211 sfc_ef100_tx_reap(struct sfc_ef100_txq *txq)
 212 {
 213         sfc_ef100_tx_reap_num_descs(txq, sfc_ef100_tx_process_events(txq));
 214 }
 215
 216 static void
 217 sfc_ef100_tx_qdesc_send_create(const struct rte_mbuf *m, efx_oword_t *tx_desc)
 218 {
 219         bool outer_l4;
 220
 221         outer_l4 = (m->ol_flags & PKT_TX_L4_MASK);
 222
 223         EFX_POPULATE_OWORD_5(*tx_desc,
 224                         ESF_GZ_TX_SEND_ADDR, rte_mbuf_data_iova(m),
 225                         ESF_GZ_TX_SEND_LEN, rte_pktmbuf_data_len(m),
 226                         ESF_GZ_TX_SEND_NUM_SEGS, m->nb_segs,
 227                         ESF_GZ_TX_SEND_CSO_OUTER_L4, outer_l4,
 228                         ESF_GZ_TX_DESC_TYPE, ESE_GZ_TX_DESC_TYPE_SEND);
 229 }
 230
 231 static void
 232 sfc_ef100_tx_qdesc_seg_create(rte_iova_t addr, uint16_t len,
 233                               efx_oword_t *tx_desc)
 234 {
 235         EFX_POPULATE_OWORD_3(*tx_desc,
 236                         ESF_GZ_TX_SEG_ADDR, addr,
 237                         ESF_GZ_TX_SEG_LEN, len,
 238                         ESF_GZ_TX_DESC_TYPE, ESE_GZ_TX_DESC_TYPE_SEG);
 239 }
 240
 241 static inline void
 242 sfc_ef100_tx_qpush(struct sfc_ef100_txq *txq, unsigned int added)
 243 {
 244         efx_dword_t dword;
 245
 246         EFX_POPULATE_DWORD_1(dword, ERF_GZ_TX_RING_PIDX, added & txq->ptr_mask);
 247
 248         /* DMA sync to device is not required */
 249
 250         /*
 251          * rte_write32() has rte_io_wmb() which guarantees that the STORE
 252          * operations (i.e. Rx and event descriptor updates) that precede
 253          * the rte_io_wmb() call are visible to NIC before the STORE
 254          * operations that follow it (i.e. doorbell write).
 255          */
 256         rte_write32(dword.ed_u32[0], txq->doorbell);
 257
 258         sfc_ef100_tx_debug(txq, "TxQ pushed doorbell at pidx %u (added=%u)",
 259                            EFX_DWORD_FIELD(dword, ERF_GZ_TX_RING_PIDX),
 260                            added);
 261 }
 262
 263 static unsigned int
 264 sfc_ef100_tx_pkt_descs_max(const struct rte_mbuf *m)
 265 {
 266 /** Maximum length of an mbuf segment data */
 267 #define SFC_MBUF_SEG_LEN_MAX            UINT16_MAX
 268         RTE_BUILD_BUG_ON(sizeof(m->data_len) != 2);
 269
 270         /*
 271          * mbuf segment cannot be bigger than maximum segment length and
 272          * maximum packet length since TSO is not supported yet.
 273          * Make sure that the first segment does not need fragmentation
 274          * (split into many Tx descriptors).
 275          */
 276         RTE_BUILD_BUG_ON(SFC_EF100_TX_SEND_DESC_LEN_MAX <
 277                 RTE_MIN((unsigned int)EFX_MAC_PDU_MAX, SFC_MBUF_SEG_LEN_MAX));
 278
 279         /*
 280          * Any segment of scattered packet cannot be bigger than maximum
 281          * segment length and maximum packet length since TSO is not
 282          * supported yet.
 283          * Make sure that subsequent segments do not need fragmentation (split
 284          * into many Tx descriptors).
 285          */
 286         RTE_BUILD_BUG_ON(SFC_EF100_TX_SEG_DESC_LEN_MAX <
 287                 RTE_MIN((unsigned int)EFX_MAC_PDU_MAX, SFC_MBUF_SEG_LEN_MAX));
 288
 289         return m->nb_segs;
 290 }
 291
 292 static uint16_t
 293 sfc_ef100_xmit_pkts(void *tx_queue, struct rte_mbuf **tx_pkts, uint16_t nb_pkts)
 294 {
 295         struct sfc_ef100_txq * const txq = sfc_ef100_txq_by_dp_txq(tx_queue);
 296         unsigned int added;
 297         unsigned int dma_desc_space;
 298         bool reap_done;
 299         struct rte_mbuf **pktp;
 300         struct rte_mbuf **pktp_end;
 301
 302         if (unlikely(txq->flags &
 303                      (SFC_EF100_TXQ_NOT_RUNNING | SFC_EF100_TXQ_EXCEPTION)))
 304                 return 0;
 305
 306         added = txq->added;
 307         dma_desc_space = txq->max_fill_level - (added - txq->completed);
 308
 309         reap_done = (dma_desc_space < txq->free_thresh);
 310         if (reap_done) {
 311                 sfc_ef100_tx_reap(txq);
 312                 dma_desc_space = txq->max_fill_level - (added - txq->completed);
 313         }
 314
 315         for (pktp = &tx_pkts[0], pktp_end = &tx_pkts[nb_pkts];
 316              pktp != pktp_end;
 317              ++pktp) {
 318                 struct rte_mbuf *m_seg = *pktp;
 319                 unsigned int pkt_start = added;
 320                 unsigned int id;
 321
 322                 if (likely(pktp + 1 != pktp_end))
 323                         rte_mbuf_prefetch_part1(pktp[1]);
 324
 325                 if (sfc_ef100_tx_pkt_descs_max(m_seg) > dma_desc_space) {
 326                         if (reap_done)
 327                                 break;
 328
 329                         /* Push already prepared descriptors before polling */
 330                         if (added != txq->added) {
 331                                 sfc_ef100_tx_qpush(txq, added);
 332                                 txq->added = added;
 333                         }
 334
 335                         sfc_ef100_tx_reap(txq);
 336                         reap_done = true;
 337                         dma_desc_space = txq->max_fill_level -
 338                                 (added - txq->completed);
 339                         if (sfc_ef100_tx_pkt_descs_max(m_seg) > dma_desc_space)
 340                                 break;
 341                 }
 342
 343                 id = added++ & txq->ptr_mask;
 344                 sfc_ef100_tx_qdesc_send_create(m_seg, &txq->txq_hw_ring[id]);
 345
 346                 /*
 347                  * rte_pktmbuf_free() is commonly used in DPDK for
 348                  * recycling packets - the function checks every
 349                  * segment's reference counter and returns the
 350                  * buffer to its pool whenever possible;
 351                  * nevertheless, freeing mbuf segments one by one
 352                  * may entail some performance decline;
 353                  * from this point, sfc_efx_tx_reap() does the same job
 354                  * on its own and frees buffers in bulks (all mbufs
 355                  * within a bulk belong to the same pool);
 356                  * from this perspective, individual segment pointers
 357                  * must be associated with the corresponding SW
 358                  * descriptors independently so that only one loop
 359                  * is sufficient on reap to inspect all the buffers
 360                  */
 361                 txq->sw_ring[id].mbuf = m_seg;
 362
 363                 while ((m_seg = m_seg->next) != NULL) {
 364                         RTE_BUILD_BUG_ON(SFC_MBUF_SEG_LEN_MAX >
 365                                          SFC_EF100_TX_SEG_DESC_LEN_MAX);
 366
 367                         id = added++ & txq->ptr_mask;
 368                         sfc_ef100_tx_qdesc_seg_create(rte_mbuf_data_iova(m_seg),
 369                                         rte_pktmbuf_data_len(m_seg),
 370                                         &txq->txq_hw_ring[id]);
 371                         txq->sw_ring[id].mbuf = m_seg;
 372                 }
 373
 374                 dma_desc_space -= (added - pkt_start);
 375         }
 376
 377         if (likely(added != txq->added)) {
 378                 sfc_ef100_tx_qpush(txq, added);
 379                 txq->added = added;
 380         }
 381
 382 #if SFC_TX_XMIT_PKTS_REAP_AT_LEAST_ONCE
 383         if (!reap_done)
 384                 sfc_ef100_tx_reap(txq);
 385 #endif
 386
 387         return pktp - &tx_pkts[0];
 388 }
 389
 390 static sfc_dp_tx_get_dev_info_t sfc_ef100_get_dev_info;
 391 static void
 392 sfc_ef100_get_dev_info(struct rte_eth_dev_info *dev_info)
 393 {
 394         /*
 395          * Number of descriptors just defines maximum number of pushed
 396          * descriptors (fill level).
 397          */
 398         dev_info->tx_desc_lim.nb_min = 1;
 399         dev_info->tx_desc_lim.nb_align = 1;
 400 }
 401
 402 static sfc_dp_tx_qsize_up_rings_t sfc_ef100_tx_qsize_up_rings;
 403 static int
 404 sfc_ef100_tx_qsize_up_rings(uint16_t nb_tx_desc,
 405                            struct sfc_dp_tx_hw_limits *limits,
 406                            unsigned int *txq_entries,
 407                            unsigned int *evq_entries,
 408                            unsigned int *txq_max_fill_level)
 409 {
 410         /*
 411          * rte_ethdev API guarantees that the number meets min, max and
 412          * alignment requirements.
 413          */
 414         if (nb_tx_desc <= limits->txq_min_entries)
 415                 *txq_entries = limits->txq_min_entries;
 416         else
 417                 *txq_entries = rte_align32pow2(nb_tx_desc);
 418
 419         *evq_entries = *txq_entries;
 420
 421         *txq_max_fill_level = RTE_MIN(nb_tx_desc,
 422                                       SFC_EF100_TXQ_LIMIT(*evq_entries));
 423         return 0;
 424 }
 425
 426 static sfc_dp_tx_qcreate_t sfc_ef100_tx_qcreate;
 427 static int
 428 sfc_ef100_tx_qcreate(uint16_t port_id, uint16_t queue_id,
 429                     const struct rte_pci_addr *pci_addr, int socket_id,
 430                     const struct sfc_dp_tx_qcreate_info *info,
 431                     struct sfc_dp_txq **dp_txqp)
 432 {
 433         struct sfc_ef100_txq *txq;
 434         int rc;
 435
 436         rc = EINVAL;
 437         if (info->txq_entries != info->evq_entries)
 438                 goto fail_bad_args;
 439
 440         rc = ENOMEM;
 441         txq = rte_zmalloc_socket("sfc-ef100-txq", sizeof(*txq),
 442                                  RTE_CACHE_LINE_SIZE, socket_id);
 443         if (txq == NULL)
 444                 goto fail_txq_alloc;
 445
 446         sfc_dp_queue_init(&txq->dp.dpq, port_id, queue_id, pci_addr);
 447
 448         rc = ENOMEM;
 449         txq->sw_ring = rte_calloc_socket("sfc-ef100-txq-sw_ring",
 450                                          info->txq_entries,
 451                                          sizeof(*txq->sw_ring),
 452                                          RTE_CACHE_LINE_SIZE, socket_id);
 453         if (txq->sw_ring == NULL)
 454                 goto fail_sw_ring_alloc;
 455
 456         txq->flags = SFC_EF100_TXQ_NOT_RUNNING;
 457         txq->ptr_mask = info->txq_entries - 1;
 458         txq->max_fill_level = info->max_fill_level;
 459         txq->free_thresh = info->free_thresh;
 460         txq->evq_phase_bit_shift = rte_bsf32(info->evq_entries);
 461         txq->txq_hw_ring = info->txq_hw_ring;
 462         txq->doorbell = (volatile uint8_t *)info->mem_bar +
 463                         ER_GZ_TX_RING_DOORBELL_OFST +
 464                         (info->hw_index << info->vi_window_shift);
 465         txq->evq_hw_ring = info->evq_hw_ring;
 466
 467         sfc_ef100_tx_debug(txq, "TxQ doorbell is %p", txq->doorbell);
 468
 469         *dp_txqp = &txq->dp;
 470         return 0;
 471
 472 fail_sw_ring_alloc:
 473         rte_free(txq);
 474
 475 fail_txq_alloc:
 476 fail_bad_args:
 477         return rc;
 478 }
 479
 480 static sfc_dp_tx_qdestroy_t sfc_ef100_tx_qdestroy;
 481 static void
 482 sfc_ef100_tx_qdestroy(struct sfc_dp_txq *dp_txq)
 483 {
 484         struct sfc_ef100_txq *txq = sfc_ef100_txq_by_dp_txq(dp_txq);
 485
 486         rte_free(txq->sw_ring);
 487         rte_free(txq);
 488 }
 489
 490 static sfc_dp_tx_qstart_t sfc_ef100_tx_qstart;
 491 static int
 492 sfc_ef100_tx_qstart(struct sfc_dp_txq *dp_txq, unsigned int evq_read_ptr,
 493                    unsigned int txq_desc_index)
 494 {
 495         struct sfc_ef100_txq *txq = sfc_ef100_txq_by_dp_txq(dp_txq);
 496
 497         txq->evq_read_ptr = evq_read_ptr;
 498         txq->added = txq->completed = txq_desc_index;
 499
 500         txq->flags |= SFC_EF100_TXQ_STARTED;
 501         txq->flags &= ~(SFC_EF100_TXQ_NOT_RUNNING | SFC_EF100_TXQ_EXCEPTION);
 502
 503         return 0;
 504 }
 505
 506 static sfc_dp_tx_qstop_t sfc_ef100_tx_qstop;
 507 static void
 508 sfc_ef100_tx_qstop(struct sfc_dp_txq *dp_txq, unsigned int *evq_read_ptr)
 509 {
 510         struct sfc_ef100_txq *txq = sfc_ef100_txq_by_dp_txq(dp_txq);
 511
 512         txq->flags |= SFC_EF100_TXQ_NOT_RUNNING;
 513
 514         *evq_read_ptr = txq->evq_read_ptr;
 515 }
 516
 517 static sfc_dp_tx_qtx_ev_t sfc_ef100_tx_qtx_ev;
 518 static bool
 519 sfc_ef100_tx_qtx_ev(struct sfc_dp_txq *dp_txq, unsigned int num_descs)
 520 {
 521         struct sfc_ef100_txq *txq = sfc_ef100_txq_by_dp_txq(dp_txq);
 522
 523         SFC_ASSERT(txq->flags & SFC_EF100_TXQ_NOT_RUNNING);
 524
 525         sfc_ef100_tx_reap_num_descs(txq, num_descs);
 526
 527         return false;
 528 }
 529
 530 static sfc_dp_tx_qreap_t sfc_ef100_tx_qreap;
 531 static void
 532 sfc_ef100_tx_qreap(struct sfc_dp_txq *dp_txq)
 533 {
 534         struct sfc_ef100_txq *txq = sfc_ef100_txq_by_dp_txq(dp_txq);
 535         unsigned int completed;
 536
 537         for (completed = txq->completed; completed != txq->added; ++completed) {
 538                 struct sfc_ef100_tx_sw_desc *txd;
 539
 540                 txd = &txq->sw_ring[completed & txq->ptr_mask];
 541                 if (txd->mbuf != NULL) {
 542                         rte_pktmbuf_free_seg(txd->mbuf);
 543                         txd->mbuf = NULL;
 544                 }
 545         }
 546
 547         txq->flags &= ~SFC_EF100_TXQ_STARTED;
 548 }
 549
 550 static unsigned int
 551 sfc_ef100_tx_qdesc_npending(struct sfc_ef100_txq *txq)
 552 {
 553         const unsigned int evq_old_read_ptr = txq->evq_read_ptr;
 554         unsigned int npending = 0;
 555         efx_qword_t tx_ev;
 556
 557         if (unlikely(txq->flags &
 558                      (SFC_EF100_TXQ_NOT_RUNNING | SFC_EF100_TXQ_EXCEPTION)))
 559                 return 0;
 560
 561         while (sfc_ef100_tx_get_event(txq, &tx_ev))
 562                 npending += EFX_QWORD_FIELD(tx_ev, ESF_GZ_EV_TXCMPL_NUM_DESC);
 563
 564         /*
 565          * The function does not process events, so return event queue read
 566          * pointer to the original position to allow the events that were
 567          * read to be processed later
 568          */
 569         txq->evq_read_ptr = evq_old_read_ptr;
 570
 571         return npending;
 572 }
 573
 574 static sfc_dp_tx_qdesc_status_t sfc_ef100_tx_qdesc_status;
 575 static int
 576 sfc_ef100_tx_qdesc_status(struct sfc_dp_txq *dp_txq, uint16_t offset)
 577 {
 578         struct sfc_ef100_txq *txq = sfc_ef100_txq_by_dp_txq(dp_txq);
 579         unsigned int pushed = txq->added - txq->completed;
 580
 581         if (unlikely(offset > txq->ptr_mask))
 582                 return -EINVAL;
 583
 584         if (unlikely(offset >= txq->max_fill_level))
 585                 return RTE_ETH_TX_DESC_UNAVAIL;
 586
 587         return (offset >= pushed ||
 588                 offset < sfc_ef100_tx_qdesc_npending(txq)) ?
 589                 RTE_ETH_TX_DESC_DONE : RTE_ETH_TX_DESC_FULL;
 590 }
 591
 592 struct sfc_dp_tx sfc_ef100_tx = {
 593         .dp = {
 594                 .name           = SFC_KVARG_DATAPATH_EF100,
 595                 .type           = SFC_DP_TX,
 596                 .hw_fw_caps     = SFC_DP_HW_FW_CAP_EF100,
 597         },
 598         .features               = SFC_DP_TX_FEAT_MULTI_PROCESS,
 599         .dev_offload_capa       = 0,
 600         .queue_offload_capa     = DEV_TX_OFFLOAD_UDP_CKSUM |
 601                                   DEV_TX_OFFLOAD_TCP_CKSUM |
 602                                   DEV_TX_OFFLOAD_MULTI_SEGS,
 603         .get_dev_info           = sfc_ef100_get_dev_info,
 604         .qsize_up_rings         = sfc_ef100_tx_qsize_up_rings,
 605         .qcreate                = sfc_ef100_tx_qcreate,
 606         .qdestroy               = sfc_ef100_tx_qdestroy,
 607         .qstart                 = sfc_ef100_tx_qstart,
 608         .qtx_ev                 = sfc_ef100_tx_qtx_ev,
 609         .qstop                  = sfc_ef100_tx_qstop,
 610         .qreap                  = sfc_ef100_tx_qreap,
 611         .qdesc_status           = sfc_ef100_tx_qdesc_status,
 612         .pkt_prepare            = sfc_ef100_tx_prepare_pkts,
 613         .pkt_burst              = sfc_ef100_xmit_pkts,
 614 };