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         EFX_POPULATE_OWORD_4(*tx_desc,
 220                         ESF_GZ_TX_SEND_ADDR, rte_mbuf_data_iova(m),
 221                         ESF_GZ_TX_SEND_LEN, rte_pktmbuf_data_len(m),
 222                         ESF_GZ_TX_SEND_NUM_SEGS, m->nb_segs,
 223                         ESF_GZ_TX_DESC_TYPE, ESE_GZ_TX_DESC_TYPE_SEND);
 224 }
 225
 226 static void
 227 sfc_ef100_tx_qdesc_seg_create(rte_iova_t addr, uint16_t len,
 228                               efx_oword_t *tx_desc)
 229 {
 230         EFX_POPULATE_OWORD_3(*tx_desc,
 231                         ESF_GZ_TX_SEG_ADDR, addr,
 232                         ESF_GZ_TX_SEG_LEN, len,
 233                         ESF_GZ_TX_DESC_TYPE, ESE_GZ_TX_DESC_TYPE_SEG);
 234 }
 235
 236 static inline void
 237 sfc_ef100_tx_qpush(struct sfc_ef100_txq *txq, unsigned int added)
 238 {
 239         efx_dword_t dword;
 240
 241         EFX_POPULATE_DWORD_1(dword, ERF_GZ_TX_RING_PIDX, added & txq->ptr_mask);
 242
 243         /* DMA sync to device is not required */
 244
 245         /*
 246          * rte_write32() has rte_io_wmb() which guarantees that the STORE
 247          * operations (i.e. Rx and event descriptor updates) that precede
 248          * the rte_io_wmb() call are visible to NIC before the STORE
 249          * operations that follow it (i.e. doorbell write).
 250          */
 251         rte_write32(dword.ed_u32[0], txq->doorbell);
 252
 253         sfc_ef100_tx_debug(txq, "TxQ pushed doorbell at pidx %u (added=%u)",
 254                            EFX_DWORD_FIELD(dword, ERF_GZ_TX_RING_PIDX),
 255                            added);
 256 }
 257
 258 static unsigned int
 259 sfc_ef100_tx_pkt_descs_max(const struct rte_mbuf *m)
 260 {
 261 /** Maximum length of an mbuf segment data */
 262 #define SFC_MBUF_SEG_LEN_MAX            UINT16_MAX
 263         RTE_BUILD_BUG_ON(sizeof(m->data_len) != 2);
 264
 265         /*
 266          * mbuf segment cannot be bigger than maximum segment length and
 267          * maximum packet length since TSO is not supported yet.
 268          * Make sure that the first segment does not need fragmentation
 269          * (split into many Tx descriptors).
 270          */
 271         RTE_BUILD_BUG_ON(SFC_EF100_TX_SEND_DESC_LEN_MAX <
 272                 RTE_MIN((unsigned int)EFX_MAC_PDU_MAX, SFC_MBUF_SEG_LEN_MAX));
 273
 274         /*
 275          * Any segment of scattered packet cannot be bigger than maximum
 276          * segment length and maximum packet length since TSO is not
 277          * supported yet.
 278          * Make sure that subsequent segments do not need fragmentation (split
 279          * into many Tx descriptors).
 280          */
 281         RTE_BUILD_BUG_ON(SFC_EF100_TX_SEG_DESC_LEN_MAX <
 282                 RTE_MIN((unsigned int)EFX_MAC_PDU_MAX, SFC_MBUF_SEG_LEN_MAX));
 283
 284         return m->nb_segs;
 285 }
 286
 287 static uint16_t
 288 sfc_ef100_xmit_pkts(void *tx_queue, struct rte_mbuf **tx_pkts, uint16_t nb_pkts)
 289 {
 290         struct sfc_ef100_txq * const txq = sfc_ef100_txq_by_dp_txq(tx_queue);
 291         unsigned int added;
 292         unsigned int dma_desc_space;
 293         bool reap_done;
 294         struct rte_mbuf **pktp;
 295         struct rte_mbuf **pktp_end;
 296
 297         if (unlikely(txq->flags &
 298                      (SFC_EF100_TXQ_NOT_RUNNING | SFC_EF100_TXQ_EXCEPTION)))
 299                 return 0;
 300
 301         added = txq->added;
 302         dma_desc_space = txq->max_fill_level - (added - txq->completed);
 303
 304         reap_done = (dma_desc_space < txq->free_thresh);
 305         if (reap_done) {
 306                 sfc_ef100_tx_reap(txq);
 307                 dma_desc_space = txq->max_fill_level - (added - txq->completed);
 308         }
 309
 310         for (pktp = &tx_pkts[0], pktp_end = &tx_pkts[nb_pkts];
 311              pktp != pktp_end;
 312              ++pktp) {
 313                 struct rte_mbuf *m_seg = *pktp;
 314                 unsigned int pkt_start = added;
 315                 unsigned int id;
 316
 317                 if (likely(pktp + 1 != pktp_end))
 318                         rte_mbuf_prefetch_part1(pktp[1]);
 319
 320                 if (sfc_ef100_tx_pkt_descs_max(m_seg) > dma_desc_space) {
 321                         if (reap_done)
 322                                 break;
 323
 324                         /* Push already prepared descriptors before polling */
 325                         if (added != txq->added) {
 326                                 sfc_ef100_tx_qpush(txq, added);
 327                                 txq->added = added;
 328                         }
 329
 330                         sfc_ef100_tx_reap(txq);
 331                         reap_done = true;
 332                         dma_desc_space = txq->max_fill_level -
 333                                 (added - txq->completed);
 334                         if (sfc_ef100_tx_pkt_descs_max(m_seg) > dma_desc_space)
 335                                 break;
 336                 }
 337
 338                 id = added++ & txq->ptr_mask;
 339                 sfc_ef100_tx_qdesc_send_create(m_seg, &txq->txq_hw_ring[id]);
 340
 341                 /*
 342                  * rte_pktmbuf_free() is commonly used in DPDK for
 343                  * recycling packets - the function checks every
 344                  * segment's reference counter and returns the
 345                  * buffer to its pool whenever possible;
 346                  * nevertheless, freeing mbuf segments one by one
 347                  * may entail some performance decline;
 348                  * from this point, sfc_efx_tx_reap() does the same job
 349                  * on its own and frees buffers in bulks (all mbufs
 350                  * within a bulk belong to the same pool);
 351                  * from this perspective, individual segment pointers
 352                  * must be associated with the corresponding SW
 353                  * descriptors independently so that only one loop
 354                  * is sufficient on reap to inspect all the buffers
 355                  */
 356                 txq->sw_ring[id].mbuf = m_seg;
 357
 358                 while ((m_seg = m_seg->next) != NULL) {
 359                         RTE_BUILD_BUG_ON(SFC_MBUF_SEG_LEN_MAX >
 360                                          SFC_EF100_TX_SEG_DESC_LEN_MAX);
 361
 362                         id = added++ & txq->ptr_mask;
 363                         sfc_ef100_tx_qdesc_seg_create(rte_mbuf_data_iova(m_seg),
 364                                         rte_pktmbuf_data_len(m_seg),
 365                                         &txq->txq_hw_ring[id]);
 366                         txq->sw_ring[id].mbuf = m_seg;
 367                 }
 368
 369                 dma_desc_space -= (added - pkt_start);
 370         }
 371
 372         if (likely(added != txq->added)) {
 373                 sfc_ef100_tx_qpush(txq, added);
 374                 txq->added = added;
 375         }
 376
 377 #if SFC_TX_XMIT_PKTS_REAP_AT_LEAST_ONCE
 378         if (!reap_done)
 379                 sfc_ef100_tx_reap(txq);
 380 #endif
 381
 382         return pktp - &tx_pkts[0];
 383 }
 384
 385 static sfc_dp_tx_get_dev_info_t sfc_ef100_get_dev_info;
 386 static void
 387 sfc_ef100_get_dev_info(struct rte_eth_dev_info *dev_info)
 388 {
 389         /*
 390          * Number of descriptors just defines maximum number of pushed
 391          * descriptors (fill level).
 392          */
 393         dev_info->tx_desc_lim.nb_min = 1;
 394         dev_info->tx_desc_lim.nb_align = 1;
 395 }
 396
 397 static sfc_dp_tx_qsize_up_rings_t sfc_ef100_tx_qsize_up_rings;
 398 static int
 399 sfc_ef100_tx_qsize_up_rings(uint16_t nb_tx_desc,
 400                            struct sfc_dp_tx_hw_limits *limits,
 401                            unsigned int *txq_entries,
 402                            unsigned int *evq_entries,
 403                            unsigned int *txq_max_fill_level)
 404 {
 405         /*
 406          * rte_ethdev API guarantees that the number meets min, max and
 407          * alignment requirements.
 408          */
 409         if (nb_tx_desc <= limits->txq_min_entries)
 410                 *txq_entries = limits->txq_min_entries;
 411         else
 412                 *txq_entries = rte_align32pow2(nb_tx_desc);
 413
 414         *evq_entries = *txq_entries;
 415
 416         *txq_max_fill_level = RTE_MIN(nb_tx_desc,
 417                                       SFC_EF100_TXQ_LIMIT(*evq_entries));
 418         return 0;
 419 }
 420
 421 static sfc_dp_tx_qcreate_t sfc_ef100_tx_qcreate;
 422 static int
 423 sfc_ef100_tx_qcreate(uint16_t port_id, uint16_t queue_id,
 424                     const struct rte_pci_addr *pci_addr, int socket_id,
 425                     const struct sfc_dp_tx_qcreate_info *info,
 426                     struct sfc_dp_txq **dp_txqp)
 427 {
 428         struct sfc_ef100_txq *txq;
 429         int rc;
 430
 431         rc = EINVAL;
 432         if (info->txq_entries != info->evq_entries)
 433                 goto fail_bad_args;
 434
 435         rc = ENOMEM;
 436         txq = rte_zmalloc_socket("sfc-ef100-txq", sizeof(*txq),
 437                                  RTE_CACHE_LINE_SIZE, socket_id);
 438         if (txq == NULL)
 439                 goto fail_txq_alloc;
 440
 441         sfc_dp_queue_init(&txq->dp.dpq, port_id, queue_id, pci_addr);
 442
 443         rc = ENOMEM;
 444         txq->sw_ring = rte_calloc_socket("sfc-ef100-txq-sw_ring",
 445                                          info->txq_entries,
 446                                          sizeof(*txq->sw_ring),
 447                                          RTE_CACHE_LINE_SIZE, socket_id);
 448         if (txq->sw_ring == NULL)
 449                 goto fail_sw_ring_alloc;
 450
 451         txq->flags = SFC_EF100_TXQ_NOT_RUNNING;
 452         txq->ptr_mask = info->txq_entries - 1;
 453         txq->max_fill_level = info->max_fill_level;
 454         txq->free_thresh = info->free_thresh;
 455         txq->evq_phase_bit_shift = rte_bsf32(info->evq_entries);
 456         txq->txq_hw_ring = info->txq_hw_ring;
 457         txq->doorbell = (volatile uint8_t *)info->mem_bar +
 458                         ER_GZ_TX_RING_DOORBELL_OFST +
 459                         (info->hw_index << info->vi_window_shift);
 460         txq->evq_hw_ring = info->evq_hw_ring;
 461
 462         sfc_ef100_tx_debug(txq, "TxQ doorbell is %p", txq->doorbell);
 463
 464         *dp_txqp = &txq->dp;
 465         return 0;
 466
 467 fail_sw_ring_alloc:
 468         rte_free(txq);
 469
 470 fail_txq_alloc:
 471 fail_bad_args:
 472         return rc;
 473 }
 474
 475 static sfc_dp_tx_qdestroy_t sfc_ef100_tx_qdestroy;
 476 static void
 477 sfc_ef100_tx_qdestroy(struct sfc_dp_txq *dp_txq)
 478 {
 479         struct sfc_ef100_txq *txq = sfc_ef100_txq_by_dp_txq(dp_txq);
 480
 481         rte_free(txq->sw_ring);
 482         rte_free(txq);
 483 }
 484
 485 static sfc_dp_tx_qstart_t sfc_ef100_tx_qstart;
 486 static int
 487 sfc_ef100_tx_qstart(struct sfc_dp_txq *dp_txq, unsigned int evq_read_ptr,
 488                    unsigned int txq_desc_index)
 489 {
 490         struct sfc_ef100_txq *txq = sfc_ef100_txq_by_dp_txq(dp_txq);
 491
 492         txq->evq_read_ptr = evq_read_ptr;
 493         txq->added = txq->completed = txq_desc_index;
 494
 495         txq->flags |= SFC_EF100_TXQ_STARTED;
 496         txq->flags &= ~(SFC_EF100_TXQ_NOT_RUNNING | SFC_EF100_TXQ_EXCEPTION);
 497
 498         return 0;
 499 }
 500
 501 static sfc_dp_tx_qstop_t sfc_ef100_tx_qstop;
 502 static void
 503 sfc_ef100_tx_qstop(struct sfc_dp_txq *dp_txq, unsigned int *evq_read_ptr)
 504 {
 505         struct sfc_ef100_txq *txq = sfc_ef100_txq_by_dp_txq(dp_txq);
 506
 507         txq->flags |= SFC_EF100_TXQ_NOT_RUNNING;
 508
 509         *evq_read_ptr = txq->evq_read_ptr;
 510 }
 511
 512 static sfc_dp_tx_qtx_ev_t sfc_ef100_tx_qtx_ev;
 513 static bool
 514 sfc_ef100_tx_qtx_ev(struct sfc_dp_txq *dp_txq, unsigned int num_descs)
 515 {
 516         struct sfc_ef100_txq *txq = sfc_ef100_txq_by_dp_txq(dp_txq);
 517
 518         SFC_ASSERT(txq->flags & SFC_EF100_TXQ_NOT_RUNNING);
 519
 520         sfc_ef100_tx_reap_num_descs(txq, num_descs);
 521
 522         return false;
 523 }
 524
 525 static sfc_dp_tx_qreap_t sfc_ef100_tx_qreap;
 526 static void
 527 sfc_ef100_tx_qreap(struct sfc_dp_txq *dp_txq)
 528 {
 529         struct sfc_ef100_txq *txq = sfc_ef100_txq_by_dp_txq(dp_txq);
 530         unsigned int completed;
 531
 532         for (completed = txq->completed; completed != txq->added; ++completed) {
 533                 struct sfc_ef100_tx_sw_desc *txd;
 534
 535                 txd = &txq->sw_ring[completed & txq->ptr_mask];
 536                 if (txd->mbuf != NULL) {
 537                         rte_pktmbuf_free_seg(txd->mbuf);
 538                         txd->mbuf = NULL;
 539                 }
 540         }
 541
 542         txq->flags &= ~SFC_EF100_TXQ_STARTED;
 543 }
 544
 545 static unsigned int
 546 sfc_ef100_tx_qdesc_npending(struct sfc_ef100_txq *txq)
 547 {
 548         const unsigned int evq_old_read_ptr = txq->evq_read_ptr;
 549         unsigned int npending = 0;
 550         efx_qword_t tx_ev;
 551
 552         if (unlikely(txq->flags &
 553                      (SFC_EF100_TXQ_NOT_RUNNING | SFC_EF100_TXQ_EXCEPTION)))
 554                 return 0;
 555
 556         while (sfc_ef100_tx_get_event(txq, &tx_ev))
 557                 npending += EFX_QWORD_FIELD(tx_ev, ESF_GZ_EV_TXCMPL_NUM_DESC);
 558
 559         /*
 560          * The function does not process events, so return event queue read
 561          * pointer to the original position to allow the events that were
 562          * read to be processed later
 563          */
 564         txq->evq_read_ptr = evq_old_read_ptr;
 565
 566         return npending;
 567 }
 568
 569 static sfc_dp_tx_qdesc_status_t sfc_ef100_tx_qdesc_status;
 570 static int
 571 sfc_ef100_tx_qdesc_status(struct sfc_dp_txq *dp_txq, uint16_t offset)
 572 {
 573         struct sfc_ef100_txq *txq = sfc_ef100_txq_by_dp_txq(dp_txq);
 574         unsigned int pushed = txq->added - txq->completed;
 575
 576         if (unlikely(offset > txq->ptr_mask))
 577                 return -EINVAL;
 578
 579         if (unlikely(offset >= txq->max_fill_level))
 580                 return RTE_ETH_TX_DESC_UNAVAIL;
 581
 582         return (offset >= pushed ||
 583                 offset < sfc_ef100_tx_qdesc_npending(txq)) ?
 584                 RTE_ETH_TX_DESC_DONE : RTE_ETH_TX_DESC_FULL;
 585 }
 586
 587 struct sfc_dp_tx sfc_ef100_tx = {
 588         .dp = {
 589                 .name           = SFC_KVARG_DATAPATH_EF100,
 590                 .type           = SFC_DP_TX,
 591                 .hw_fw_caps     = SFC_DP_HW_FW_CAP_EF100,
 592         },
 593         .features               = SFC_DP_TX_FEAT_MULTI_PROCESS,
 594         .dev_offload_capa       = 0,
 595         .queue_offload_capa     = DEV_TX_OFFLOAD_MULTI_SEGS,
 596         .get_dev_info           = sfc_ef100_get_dev_info,
 597         .qsize_up_rings         = sfc_ef100_tx_qsize_up_rings,
 598         .qcreate                = sfc_ef100_tx_qcreate,
 599         .qdestroy               = sfc_ef100_tx_qdestroy,
 600         .qstart                 = sfc_ef100_tx_qstart,
 601         .qtx_ev                 = sfc_ef100_tx_qtx_ev,
 602         .qstop                  = sfc_ef100_tx_qstop,
 603         .qreap                  = sfc_ef100_tx_qreap,
 604         .qdesc_status           = sfc_ef100_tx_qdesc_status,
 605         .pkt_prepare            = sfc_ef100_tx_prepare_pkts,
 606         .pkt_burst              = sfc_ef100_xmit_pkts,
 607 };