net/mlx5: create clock queue for packet pacing

[dpdk.git] / drivers / net / mlx5 / mlx5.c

diff --git a/drivers/net/mlx5/mlx5.c b/drivers/net/mlx5/mlx5.c
index 0786945..10196ac 100644 (file)
--- a/drivers/net/mlx5/mlx5.c
+++ b/drivers/net/mlx5/mlx5.c
@@ -709,6 +709,12 @@ mlx5_alloc_shared_dev_ctx(const struct mlx5_dev_spawn_data *spawn,
                        err = ENOMEM;
                        goto error;
                }
+               sh->tx_uar = mlx5_glue->devx_alloc_uar(sh->ctx, 0);
+               if (!sh->tx_uar) {
+                       DRV_LOG(ERR, "Failed to allocate DevX UAR.");
+                       err = ENOMEM;
+                       goto error;
+               }
        }
        sh->flow_id_pool = mlx5_flow_id_pool_alloc
                                        ((1 << HAIRPIN_FLOW_ID_BITS) - 1);
@@ -761,12 +767,17 @@ exit:
        pthread_mutex_unlock(&mlx5_dev_ctx_list_mutex);
        return sh;
 error:
+       pthread_mutex_destroy(&sh->txpp.mutex);
        pthread_mutex_unlock(&mlx5_dev_ctx_list_mutex);
        MLX5_ASSERT(sh);
        if (sh->cnt_id_tbl) {
                mlx5_l3t_destroy(sh->cnt_id_tbl);
                sh->cnt_id_tbl = NULL;
        }
+       if (sh->tx_uar) {
+               mlx5_glue->devx_free_uar(sh->tx_uar);
+               sh->tx_uar = NULL;
+       }
        if (sh->tis)
                claim_zero(mlx5_devx_cmd_destroy(sh->tis));
        if (sh->td)
@@ -832,6 +843,10 @@ mlx5_free_shared_dev_ctx(struct mlx5_dev_ctx_shared *sh)
                mlx5_l3t_destroy(sh->cnt_id_tbl);
                sh->cnt_id_tbl = NULL;
        }
+       if (sh->tx_uar) {
+               mlx5_glue->devx_free_uar(sh->tx_uar);
+               sh->tx_uar = NULL;
+       }
        if (sh->pd)
                claim_zero(mlx5_glue->dealloc_pd(sh->pd));
        if (sh->tis)
@@ -842,6 +857,7 @@ mlx5_free_shared_dev_ctx(struct mlx5_dev_ctx_shared *sh)
                claim_zero(mlx5_glue->close_device(sh->ctx));
        if (sh->flow_id_pool)
                mlx5_flow_id_pool_release(sh->flow_id_pool);
+       pthread_mutex_destroy(&sh->txpp.mutex);
        rte_free(sh);
 exit:
        pthread_mutex_unlock(&mlx5_dev_ctx_list_mutex);