[PATCH] libmlx5: Implement missing open_qp verb

[Sébastien Dugué <sebastien.dugue@xxxxxxxx>]

  Commit 0c7ac1083831 added XRC support for mlx5, however this is missing
the open_qp verb.

Signed-off-by: Sébastien Dugué <sebastien.dugue@xxxxxxxx>
---
 src/mlx5.c  |  1 +
 src/mlx5.h  |  2 ++
 src/verbs.c | 38 ++++++++++++++++++++++++++++++++++++++
 3 files changed, 41 insertions(+)

diff --git a/src/mlx5.c b/src/mlx5.c
index d02328881992..39f59975d3d2 100644
--- a/src/mlx5.c
+++ b/src/mlx5.c
@@ -579,6 +579,7 @@ static int mlx5_init_context(struct verbs_device *vdev,
 	context->ibv_ctx.ops = mlx5_ctx_ops;
 
 	verbs_set_ctx_op(v_ctx, create_qp_ex, mlx5_create_qp_ex);
+	verbs_set_ctx_op(v_ctx, open_qp, mlx5_open_qp);
 	verbs_set_ctx_op(v_ctx, open_xrcd, mlx5_open_xrcd);
 	verbs_set_ctx_op(v_ctx, close_xrcd, mlx5_close_xrcd);
 	verbs_set_ctx_op(v_ctx, create_srq_ex, mlx5_create_srq_ex);
diff --git a/src/mlx5.h b/src/mlx5.h
index 6ad79fe324d3..f548e51ee338 100644
--- a/src/mlx5.h
+++ b/src/mlx5.h
@@ -613,6 +613,8 @@ void *mlx5_get_send_wqe(struct mlx5_qp *qp, int n);
 int mlx5_copy_to_recv_wqe(struct mlx5_qp *qp, int idx, void *buf, int size);
 int mlx5_copy_to_send_wqe(struct mlx5_qp *qp, int idx, void *buf, int size);
 int mlx5_copy_to_recv_srq(struct mlx5_srq *srq, int idx, void *buf, int size);
+struct ibv_qp *mlx5_open_qp(struct ibv_context *context,
+			    struct ibv_qp_open_attr *attr);
 struct ibv_xrcd *mlx5_open_xrcd(struct ibv_context *context,
 				struct ibv_xrcd_init_attr *xrcd_init_attr);
 int mlx5_get_srq_num(struct ibv_srq *srq, uint32_t *srq_num);
diff --git a/src/verbs.c b/src/verbs.c
index 8ddf4e631c9f..dc899bce4e00 100644
--- a/src/verbs.c
+++ b/src/verbs.c
@@ -1122,6 +1122,44 @@ int mlx5_modify_qp(struct ibv_qp *qp, struct ibv_qp_attr *attr,
 	return ret;
 }
 
+struct ibv_qp *mlx5_open_qp(struct ibv_context *context,
+			    struct ibv_qp_open_attr *attr)
+{
+	struct ibv_open_qp cmd;
+	struct ibv_create_qp_resp resp;
+	struct mlx5_qp *qp;
+	int ret;
+	struct mlx5_context *ctx = to_mctx(context);
+
+	qp = calloc(1, sizeof(*qp));
+
+	if (!qp)
+		return NULL;
+
+	ret = ibv_cmd_open_qp(context, &qp->verbs_qp, sizeof(qp->verbs_qp),
+			      attr, &cmd, sizeof(cmd), &resp, sizeof(resp));
+	if (ret)
+		goto err;
+
+	pthread_mutex_lock(&ctx->qp_table_mutex);
+	ret = mlx5_store_qp(ctx, qp->verbs_qp.qp.qp_num, qp);
+
+	if (ret) {
+		pthread_mutex_unlock(&ctx->qp_table_mutex);
+		fprintf(stderr, "mlx5_store_qp failed ret=%d\n", ret);
+		goto destroy;
+	}
+	pthread_mutex_unlock(&ctx->qp_table_mutex);
+
+	return (struct ibv_qp *)&qp->verbs_qp;
+
+destroy:
+	ibv_cmd_destroy_qp(&qp->verbs_qp.qp);
+err:
+	free(qp);
+	return NULL;
+}
+
 struct ibv_ah *mlx5_create_ah(struct ibv_pd *pd, struct ibv_ah_attr *attr)
 {
 	struct mlx5_ah *ah;
-- 
1.9.1

--
To unsubscribe from this list: send the line "unsubscribe linux-rdma" in
the body of a message to majordomo@xxxxxxxxxxxxxxx
More majordomo info at  http://vger.kernel.org/majordomo-info.html