From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: Received: from mga06.intel.com (mga06.intel.com [134.134.136.31]) by dpdk.org (Postfix) with ESMTP id EE8C17CD2 for ; Sat, 28 Apr 2018 01:39:30 +0200 (CEST) X-Amp-Result: SKIPPED(no attachment in message) X-Amp-File-Uploaded: False Received: from fmsmga003.fm.intel.com ([10.253.24.29]) by orsmga104.jf.intel.com with ESMTP/TLS/DHE-RSA-AES256-GCM-SHA384; 27 Apr 2018 16:39:30 -0700 X-ExtLoop1: 1 X-IronPort-AV: E=Sophos;i="5.49,336,1520924400"; d="scan'208";a="45186658" Received: from silpixa00399501.ir.intel.com ([10.237.223.69]) by FMSMGA003.fm.intel.com with ESMTP; 27 Apr 2018 16:39:29 -0700 From: Lee Daly To: dev@dpdk.org Cc: pablo.de.lara.guarch@intel.com, greg.b.tucker@intel.com, deepak.k.jain@intel.com, fiona.trahe@intel.com, Lee Daly Date: Sat, 28 Apr 2018 00:38:29 +0100 Message-Id: <1524872313-196340-7-git-send-email-lee.daly@intel.com> X-Mailer: git-send-email 2.7.4 In-Reply-To: <1524872313-196340-1-git-send-email-lee.daly@intel.com> References: <1523972132-6894-12-git-send-email-lee.daly@intel.com> <1524872313-196340-1-git-send-email-lee.daly@intel.com> Subject: [dpdk-dev] [PATCH v4 06/10] compress/isal: support enqueue/dequeue api X-BeenThere: dev@dpdk.org X-Mailman-Version: 2.1.15 Precedence: list List-Id: DPDK patches and discussions List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , X-List-Received-Date: Fri, 27 Apr 2018 23:39:31 -0000 This patchs adds support for the compressdev enqueue_burst and dequeue_burst API operations. Signed-off-by: Lee Daly --- drivers/compress/isal/isal_compress_pmd.c | 64 +++++++++++++++++++++++++++ drivers/compress/isal/isal_compress_pmd_ops.c | 2 + 2 files changed, 66 insertions(+) diff --git a/drivers/compress/isal/isal_compress_pmd.c b/drivers/compress/isal/isal_compress_pmd.c index 325867b..b13822a 100644 --- a/drivers/compress/isal/isal_compress_pmd.c +++ b/drivers/compress/isal/isal_compress_pmd.c @@ -208,6 +208,66 @@ isal_comp_set_priv_xform_parameters(struct isal_priv_xform *priv_xform, return 0; } +/* Process compression/decompression 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, struct rte_comp_op **ops, + uint16_t nb_ops) +{ + 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 retval; +} + +/* Dequeue burst */ +static uint16_t +isal_comp_pmd_dequeue_burst(void *queue_pair, struct rte_comp_op **ops, + uint16_t nb_ops) +{ + 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; +} + /* Create ISA-L compression device */ static int compdev_isal_create(const char *name, struct rte_vdev_device *vdev, @@ -224,6 +284,10 @@ compdev_isal_create(const char *name, struct rte_vdev_device *vdev, dev->dev_ops = isal_compress_pmd_ops; + /* register rx/tx burst functions for data path */ + dev->dequeue_burst = isal_comp_pmd_dequeue_burst; + dev->enqueue_burst = isal_comp_pmd_enqueue_burst; + return 0; } diff --git a/drivers/compress/isal/isal_compress_pmd_ops.c b/drivers/compress/isal/isal_compress_pmd_ops.c index b0abf42..4033864 100644 --- a/drivers/compress/isal/isal_compress_pmd_ops.c +++ b/drivers/compress/isal/isal_compress_pmd_ops.c @@ -203,6 +203,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