dmadev: add burst capacity API

Add a burst capacity check API to the dmadev library. This API is useful to
applications which need to how many descriptors can be enqueued in the
current batch. For example, it could be used to determine whether all
segments of a multi-segment packet can be enqueued in the same batch or not
(to avoid half-offload of the packet).

Signed-off-by: Kevin Laatz <kevin.laatz@intel.com>
Reviewed-by: Conor Walsh <conor.walsh@intel.com>

diff --git a/drivers/dma/skeleton/skeleton_dmadev.c b/drivers/dma/skeleton/skeleton_dmadev.c
index dd2f1c9b57d69d3f41c33fb707678242f66c515d..29524171268b36de3b9cf1b9b49078805f731555 100644 (file)
--- a/drivers/dma/skeleton/skeleton_dmadev.c
+++ b/drivers/dma/skeleton/skeleton_dmadev.c
@@ -431,6 +431,15 @@ skeldma_completed_status(void *dev_private,
        return count;
 }
 
+static uint16_t
+skeldma_burst_capacity(const void *dev_private, uint16_t vchan)
+{
+       const struct skeldma_hw *hw = dev_private;
+
+       RTE_SET_USED(vchan);
+       return rte_ring_count(hw->desc_empty);
+}
+
 static const struct rte_dma_dev_ops skeldma_ops = {
        .dev_info_get     = skeldma_info_get,
        .dev_configure    = skeldma_configure,
@@ -469,6 +478,7 @@ skeldma_create(const char *name, struct rte_vdev_device *vdev, int lcore_id)
        dev->fp_obj->submit = skeldma_submit;
        dev->fp_obj->completed = skeldma_completed;
        dev->fp_obj->completed_status = skeldma_completed_status;
+       dev->fp_obj->burst_capacity = skeldma_burst_capacity;
 
        hw = dev->data->dev_private;
        hw->lcore_id = lcore_id;

diff --git a/lib/dmadev/rte_dmadev.c b/lib/dmadev/rte_dmadev.c
index 3f9154e61902a223d33edf17fa3700fdfc7505d1..c737cc6cdc0d799081a3caa13a29d3237fce1e19 100644 (file)
--- a/lib/dmadev/rte_dmadev.c
+++ b/lib/dmadev/rte_dmadev.c
@@ -830,6 +830,14 @@ dummy_completed_status(__rte_unused void *dev_private,
        return 0;
 }
 
+static uint16_t
+dummy_burst_capacity(__rte_unused const void *dev_private,
+                    __rte_unused uint16_t vchan)
+{
+       RTE_DMA_LOG(ERR, "burst_capacity is not configured or not supported.");
+       return 0;
+}
+
 static void
 dma_fp_object_dummy(struct rte_dma_fp_object *obj)
 {
@@ -840,4 +848,5 @@ dma_fp_object_dummy(struct rte_dma_fp_object *obj)
        obj->submit           = dummy_submit;
        obj->completed        = dummy_completed;
        obj->completed_status = dummy_completed_status;
+       obj->burst_capacity   = dummy_burst_capacity;
 }

diff --git a/lib/dmadev/rte_dmadev.h b/lib/dmadev/rte_dmadev.h
index e35aca7d1c7c9d2d2cf436cfca85e4342f4c8b83..a0824be20d0a7d2a442aeed831229f9138935482 100644 (file)
--- a/lib/dmadev/rte_dmadev.h
+++ b/lib/dmadev/rte_dmadev.h
@@ -1076,6 +1076,35 @@ rte_dma_completed_status(int16_t dev_id, uint16_t vchan,
                                        last_idx, status);
 }
 
+/**
+ * @warning
+ * @b EXPERIMENTAL: this API may change without prior notice.
+ *
+ * Check remaining capacity in descriptor ring for the current burst.
+ *
+ * @param dev_id
+ *   The identifier of the device.
+ * @param vchan
+ *   The identifier of virtual DMA channel.
+ *
+ * @return
+ *   - Remaining space in the descriptor ring for the current burst.
+ *   - 0 on error
+ */
+__rte_experimental
+static inline uint16_t
+rte_dma_burst_capacity(int16_t dev_id, uint16_t vchan)
+{
+       struct rte_dma_fp_object *obj = &rte_dma_fp_objs[dev_id];
+
+#ifdef RTE_DMADEV_DEBUG
+       if (!rte_dma_is_valid(dev_id))
+               return 0;
+       RTE_FUNC_PTR_OR_ERR_RET(*obbj->burst_capacity, 0);
+#endif
+       return (*obj->burst_capacity)(obj->dev_private, vchan);
+}
+
 #ifdef __cplusplus
 }
 #endif

diff --git a/lib/dmadev/rte_dmadev_core.h b/lib/dmadev/rte_dmadev_core.h
index 236d9d38e5fbe3f10750f63757f611513fc92529..e42d8739ab633a1c546835d4ff9cb72d50e9460f 100644 (file)
--- a/lib/dmadev/rte_dmadev_core.h
+++ b/lib/dmadev/rte_dmadev_core.h
@@ -47,6 +47,9 @@ typedef uint16_t (*rte_dma_completed_status_t)(void *dev_private,
                        uint16_t vchan, const uint16_t nb_cpls,
                        uint16_t *last_idx, enum rte_dma_status_code *status);
 
+/** @internal Used to check the remaining space in descriptor ring. */
+typedef uint16_t (*rte_dma_burst_capacity_t)(const void *dev_private, uint16_t vchan);
+
 /**
  * @internal
  * Fast-path dmadev functions and related data are hold in a flat array.
@@ -69,6 +72,7 @@ struct rte_dma_fp_object {
        rte_dma_submit_t           submit;
        rte_dma_completed_t        completed;
        rte_dma_completed_status_t completed_status;
+       rte_dma_burst_capacity_t   burst_capacity;
 } __rte_aligned(128);
 
 extern struct rte_dma_fp_object *rte_dma_fp_objs;

diff --git a/lib/dmadev/version.map b/lib/dmadev/version.map
index 8785e146481848a92b0e35e7eb379debc7287365..4bbfdd52f63e48b0230c128f05d85750d786b40f 100644 (file)
--- a/lib/dmadev/version.map
+++ b/lib/dmadev/version.map
@@ -1,6 +1,7 @@
 EXPERIMENTAL {
        global:
 
+       rte_dma_burst_capacity;
        rte_dma_close;
        rte_dma_completed;
        rte_dma_completed_status;