1// SPDX-License-Identifier: GPL-2.0-only
  2/*
  3 * Copyright (c) 2022, Microsoft Corporation. All rights reserved.
  4 */
  5
  6#include "mana_ib.h"
  7
  8int mana_ib_create_cq(struct ib_cq *ibcq, const struct ib_cq_init_attr *attr,
  9		      struct ib_udata *udata)
 10{
 11	struct mana_ib_cq *cq = container_of(ibcq, struct mana_ib_cq, ibcq);
 12	struct ib_device *ibdev = ibcq->device;
 13	struct mana_ib_create_cq ucmd = {};
 14	struct mana_ib_dev *mdev;
 15	struct gdma_context *gc;
 16	int err;
 17
 18	mdev = container_of(ibdev, struct mana_ib_dev, ib_dev);
 19	gc = mdev->gdma_dev->gdma_context;
 20
 21	if (udata->inlen < sizeof(ucmd))
 22		return -EINVAL;
 23
 24	if (attr->comp_vector > gc->max_num_queues)
 25		return -EINVAL;
 26
 27	cq->comp_vector = attr->comp_vector;
 28
 29	err = ib_copy_from_udata(&ucmd, udata, min(sizeof(ucmd), udata->inlen));
 30	if (err) {
 31		ibdev_dbg(ibdev,
 32			  "Failed to copy from udata for create cq, %d\n", err);
 33		return err;
 34	}
 35
 36	if (attr->cqe > mdev->adapter_caps.max_qp_wr) {
 37		ibdev_dbg(ibdev, "CQE %d exceeding limit\n", attr->cqe);
 38		return -EINVAL;
 39	}
 40
 41	cq->cqe = attr->cqe;
 42	cq->umem = ib_umem_get(ibdev, ucmd.buf_addr, cq->cqe * COMP_ENTRY_SIZE,
 43			       IB_ACCESS_LOCAL_WRITE);
 44	if (IS_ERR(cq->umem)) {
 45		err = PTR_ERR(cq->umem);
 46		ibdev_dbg(ibdev, "Failed to get umem for create cq, err %d\n",
 47			  err);
 48		return err;
 49	}
 50
 51	err = mana_ib_gd_create_dma_region(mdev, cq->umem, &cq->gdma_region);
 52	if (err) {
 53		ibdev_dbg(ibdev,
 54			  "Failed to create dma region for create cq, %d\n",
 55			  err);
 56		goto err_release_umem;
 57	}
 58
 59	ibdev_dbg(ibdev,
 60		  "mana_ib_gd_create_dma_region ret %d gdma_region 0x%llx\n",
 61		  err, cq->gdma_region);
 62
 63	/*
 64	 * The CQ ID is not known at this time. The ID is generated at create_qp
 65	 */
 66	cq->id = INVALID_QUEUE_ID;
 67
 68	return 0;
 69
 70err_release_umem:
 71	ib_umem_release(cq->umem);
 72	return err;
 73}
 74
 75int mana_ib_destroy_cq(struct ib_cq *ibcq, struct ib_udata *udata)
 76{
 77	struct mana_ib_cq *cq = container_of(ibcq, struct mana_ib_cq, ibcq);
 78	struct ib_device *ibdev = ibcq->device;
 79	struct mana_ib_dev *mdev;
 80	struct gdma_context *gc;
 81	int err;
 82
 83	mdev = container_of(ibdev, struct mana_ib_dev, ib_dev);
 84	gc = mdev->gdma_dev->gdma_context;
 85
 86	err = mana_ib_gd_destroy_dma_region(mdev, cq->gdma_region);
 87	if (err) {
 88		ibdev_dbg(ibdev,
 89			  "Failed to destroy dma region, %d\n", err);
 90		return err;
 91	}
 92
 93	if (cq->id != INVALID_QUEUE_ID) {
 94		kfree(gc->cq_table[cq->id]);
 95		gc->cq_table[cq->id] = NULL;
 96	}
 97
 
 98	ib_umem_release(cq->umem);
 99
100	return 0;
101}
102
103void mana_ib_cq_handler(void *ctx, struct gdma_queue *gdma_cq)
104{
105	struct mana_ib_cq *cq = ctx;
106
107	if (cq->ibcq.comp_handler)
108		cq->ibcq.comp_handler(&cq->ibcq, cq->ibcq.cq_context);
109}

 1// SPDX-License-Identifier: GPL-2.0-only
 2/*
 3 * Copyright (c) 2022, Microsoft Corporation. All rights reserved.
 4 */
 5
 6#include "mana_ib.h"
 7
 8int mana_ib_create_cq(struct ib_cq *ibcq, const struct ib_cq_init_attr *attr,
 9		      struct ib_udata *udata)
10{
11	struct mana_ib_cq *cq = container_of(ibcq, struct mana_ib_cq, ibcq);
12	struct ib_device *ibdev = ibcq->device;
13	struct mana_ib_create_cq ucmd = {};
14	struct mana_ib_dev *mdev;
 
15	int err;
16
17	mdev = container_of(ibdev, struct mana_ib_dev, ib_dev);
 
18
19	if (udata->inlen < sizeof(ucmd))
20		return -EINVAL;
21
 
 
 
 
 
22	err = ib_copy_from_udata(&ucmd, udata, min(sizeof(ucmd), udata->inlen));
23	if (err) {
24		ibdev_dbg(ibdev,
25			  "Failed to copy from udata for create cq, %d\n", err);
26		return err;
27	}
28
29	if (attr->cqe > MAX_SEND_BUFFERS_PER_QUEUE) {
30		ibdev_dbg(ibdev, "CQE %d exceeding limit\n", attr->cqe);
31		return -EINVAL;
32	}
33
34	cq->cqe = attr->cqe;
35	cq->umem = ib_umem_get(ibdev, ucmd.buf_addr, cq->cqe * COMP_ENTRY_SIZE,
36			       IB_ACCESS_LOCAL_WRITE);
37	if (IS_ERR(cq->umem)) {
38		err = PTR_ERR(cq->umem);
39		ibdev_dbg(ibdev, "Failed to get umem for create cq, err %d\n",
40			  err);
41		return err;
42	}
43
44	err = mana_ib_gd_create_dma_region(mdev, cq->umem, &cq->gdma_region);
45	if (err) {
46		ibdev_dbg(ibdev,
47			  "Failed to create dma region for create cq, %d\n",
48			  err);
49		goto err_release_umem;
50	}
51
52	ibdev_dbg(ibdev,
53		  "mana_ib_gd_create_dma_region ret %d gdma_region 0x%llx\n",
54		  err, cq->gdma_region);
55
56	/*
57	 * The CQ ID is not known at this time. The ID is generated at create_qp
58	 */
 
59
60	return 0;
61
62err_release_umem:
63	ib_umem_release(cq->umem);
64	return err;
65}
66
67int mana_ib_destroy_cq(struct ib_cq *ibcq, struct ib_udata *udata)
68{
69	struct mana_ib_cq *cq = container_of(ibcq, struct mana_ib_cq, ibcq);
70	struct ib_device *ibdev = ibcq->device;
71	struct mana_ib_dev *mdev;
 
 
72
73	mdev = container_of(ibdev, struct mana_ib_dev, ib_dev);
 
 
 
 
 
 
 
 
 
 
 
 
 
74
75	mana_ib_gd_destroy_dma_region(mdev, cq->gdma_region);
76	ib_umem_release(cq->umem);
77
78	return 0;
 
 
 
 
 
 
 
 
79}