net/iavf/base: adjust indentation

[dpdk.git] / drivers / bus / fslmc / portal / dpaa2_hw_dpio.c

diff --git a/drivers/bus/fslmc/portal/dpaa2_hw_dpio.c b/drivers/bus/fslmc/portal/dpaa2_hw_dpio.c
index f377f24..3ca3ae4 100644 (file)
--- a/drivers/bus/fslmc/portal/dpaa2_hw_dpio.c
+++ b/drivers/bus/fslmc/portal/dpaa2_hw_dpio.c
@@ -1,7 +1,7 @@
 /* SPDX-License-Identifier: BSD-3-Clause
  *
  *   Copyright (c) 2016 Freescale Semiconductor, Inc. All rights reserved.
- *   Copyright 2016-2018 NXP
+ *   Copyright 2016-2019 NXP
  *
  */
 #include <unistd.h>
@@ -366,7 +366,9 @@ dpaa2_check_lcore_cpuset(void)
 
        for (lcore_id = 0; lcore_id < RTE_MAX_LCORE; lcore_id++) {
                for (i = 0; i < RTE_MAX_LCORE; i++) {
-                       if (CPU_ISSET(i, &lcore_config[lcore_id].cpuset)) {
+                       rte_cpuset_t cpuset = rte_lcore_cpuset(lcore_id);
+
+                       if (CPU_ISSET(i, &cpuset)) {
                                RTE_LOG(DEBUG, EAL, "lcore id = %u cpu=%u\n",
                                        lcore_id, i);
                                if (dpaa2_cpu[lcore_id] != 0xffffffff) {
@@ -526,6 +528,18 @@ dpaa2_create_dpio_device(int vdev_fd,
                goto err;
        }
 
+       dpio_dev->eqresp = rte_zmalloc(NULL, MAX_EQ_RESP_ENTRIES *
+                                    (sizeof(struct qbman_result) +
+                                    sizeof(struct eqresp_metadata)),
+                                    RTE_CACHE_LINE_SIZE);
+       if (!dpio_dev->eqresp) {
+               DPAA2_BUS_ERR("Memory allocation failed for eqresp");
+               goto err;
+       }
+       dpio_dev->eqresp_meta = (struct eqresp_metadata *)(dpio_dev->eqresp +
+                               MAX_EQ_RESP_ENTRIES);
+
+
        TAILQ_INSERT_TAIL(&dpio_dev_list, dpio_dev, next);
 
        return 0;
@@ -588,6 +602,41 @@ fail:
        return -1;
 }
 
+uint32_t
+dpaa2_free_eq_descriptors(void)
+{
+       struct dpaa2_dpio_dev *dpio_dev = DPAA2_PER_LCORE_DPIO;
+       struct qbman_result *eqresp;
+       struct eqresp_metadata *eqresp_meta;
+       struct dpaa2_queue *txq;
+
+       while (dpio_dev->eqresp_ci != dpio_dev->eqresp_pi) {
+               eqresp = &dpio_dev->eqresp[dpio_dev->eqresp_ci];
+               eqresp_meta = &dpio_dev->eqresp_meta[dpio_dev->eqresp_ci];
+
+               if (!qbman_result_eqresp_rspid(eqresp))
+                       break;
+
+               if (qbman_result_eqresp_rc(eqresp)) {
+                       txq = eqresp_meta->dpaa2_q;
+                       txq->cb_eqresp_free(dpio_dev->eqresp_ci);
+               }
+               qbman_result_eqresp_set_rspid(eqresp, 0);
+
+               dpio_dev->eqresp_ci + 1 < MAX_EQ_RESP_ENTRIES ?
+                       dpio_dev->eqresp_ci++ : (dpio_dev->eqresp_ci = 0);
+       }
+
+       /* Return 1 less entry so that PI and CI are never same in a
+        * case there all the EQ responses are in use.
+        */
+       if (dpio_dev->eqresp_ci > dpio_dev->eqresp_pi)
+               return dpio_dev->eqresp_ci - dpio_dev->eqresp_pi - 1;
+       else
+               return dpio_dev->eqresp_ci - dpio_dev->eqresp_pi +
+                       MAX_EQ_RESP_ENTRIES - 1;
+}
+
 static struct rte_dpaa2_object rte_dpaa2_dpio_obj = {
        .dev_type = DPAA2_IO,
        .create = dpaa2_create_dpio_device,