Signed-off-by: Lee Daly <lee.d...@intel.com>
---
drivers/compress/isal/isal_compress_pmd.c | 56 ++++++++++++++++++++++-----
drivers/compress/isal/isal_compress_pmd_ops.c | 2 +
2 files changed, 49 insertions(+), 9 deletions(-)
diff --git a/drivers/compress/isal/isal_compress_pmd.c
b/drivers/compress/isal/isal_compress_pmd.c
index 8db6380..2e19b42 100644
--- a/drivers/compress/isal/isal_compress_pmd.c
+++ b/drivers/compress/isal/isal_compress_pmd.c
@@ -198,24 +198,62 @@ isal_comp_set_priv_xform_parameters(struct
isal_priv_xform *priv_xform,
return 0;
}
+/* Process compression operation */
+static int
+process_op(struct isal_comp_qp *qp __rte_unused,
+ struct rte_comp_op *op __rte_unused,
+ struct isal_priv_xform *priv_xform)
+{
+ switch (priv_xform->type) {
+ case RTE_COMP_COMPRESS:
+ break;
+ case RTE_COMP_DECOMPRESS:
+ break;
+ default:
+ ISAL_PMD_LOG(ERR, "Operation Not Supported\n");
+ return -ENOTSUP;
+ }
+ return 0;
+}
+
/* Enqueue burst */
static uint16_t
-isal_comp_pmd_enqueue_burst(void *queue_pair __rte_unused,
- struct rte_comp_op **ops __rte_unused,
- uint16_t nb_ops __rte_unused)
+isal_comp_pmd_enqueue_burst(void *queue_pair, struct rte_comp_op **ops,
+ uint16_t nb_ops)
{
- uint16_t num_enq = 0;
+ struct isal_comp_qp *qp = queue_pair;
+ uint16_t i;
+ int retval;
+ int16_t num_enq = RTE_MIN(qp->num_free_elements, nb_ops);
+
+ for (i = 0; i < num_enq; i++) {
+ retval = process_op(qp, ops[i], ops[i]->private_xform);
+ if (unlikely(retval < 0) ||
+ ops[i]->status != RTE_COMP_OP_STATUS_SUCCESS) {
+ qp->qp_stats.enqueue_err_count++;
+ }
+ }
+
+ retval = rte_ring_enqueue_burst(qp->processed_pkts, (void *)ops,
+ num_enq, NULL);
+ qp->num_free_elements -= retval;
+ qp->qp_stats.enqueued_count += retval;
- return num_enq;
+ return retval;
}
/* Dequeue burst */
static uint16_t
-isal_comp_pmd_dequeue_burst(void *queue_pair __rte_unused,
- struct rte_comp_op **ops __rte_unused,
- uint16_t nb_ops __rte_unused)
+isal_comp_pmd_dequeue_burst(void *queue_pair, struct rte_comp_op **ops,
+ uint16_t nb_ops)
{
- uint16_t nb_dequeued = 0;
+ struct isal_comp_qp *qp = queue_pair;
+ uint16_t nb_dequeued;
+
+ nb_dequeued = rte_ring_dequeue_burst(qp->processed_pkts, (void **)ops,
+ nb_ops, NULL);
+ qp->num_free_elements += nb_dequeued;
+ qp->qp_stats.dequeued_count += nb_dequeued;
return nb_dequeued;
}
diff --git a/drivers/compress/isal/isal_compress_pmd_ops.c
b/drivers/compress/isal/isal_compress_pmd_ops.c
index 73e4c84..1690c34 100644
--- a/drivers/compress/isal/isal_compress_pmd_ops.c
+++ b/drivers/compress/isal/isal_compress_pmd_ops.c
@@ -198,6 +198,8 @@ isal_comp_pmd_qp_setup(struct rte_compressdev *dev,
uint16_t qp_id,
goto qp_setup_cleanup;
}
+ qp->num_free_elements = rte_ring_free_count(qp->processed_pkts);
+
memset(&qp->qp_stats, 0, sizeof(qp->qp_stats));
return 0;
--
2.7.4
