Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit 0c43ab37 authored by Jason Gunthorpe's avatar Jason Gunthorpe
Browse files

RDMA/rxe: Use structs to describe the uABI instead of opencoding 



Open coding pointer math is not acceptable for describing the uABI in
RDMA. Provide structs for all the cases.

The udata is casted to the struct as close to the verbs entry point
as possible for maximum clarity. Function signatures and so forth
are revised to allow for this.

Tested-by: default avatarYuval Shaia <yuval.shaia@oracle.com>
Signed-off-by: default avatarJason Gunthorpe <jgg@mellanox.com>
parent b92ec0fe

drivers/infiniband/sw/rxe/rxe_cq.c

+7 −6
Original line number Diff line number Diff line
@@ -83,7 +83,7 @@ static void rxe_send_complete(unsigned long data) 


int rxe_cq_from_init(struct rxe_dev *rxe, struct rxe_cq *cq, int cqe,

		     int comp_vector, struct ib_ucontext *context,

		     struct ib_udata *udata)

		     struct rxe_create_cq_resp __user *uresp)

{

	int err;
@@ -94,15 +94,15 @@ int rxe_cq_from_init(struct rxe_dev *rxe, struct rxe_cq *cq, int cqe, 
		return -ENOMEM;

	}



	err = do_mmap_info(rxe, udata, false, context, cq->queue->buf,

			   cq->queue->buf_size, &cq->queue->ip);

	err = do_mmap_info(rxe, uresp ? &uresp->mi : NULL, context,

			   cq->queue->buf, cq->queue->buf_size, &cq->queue->ip);

	if (err) {

		kvfree(cq->queue->buf);

		kfree(cq->queue);

		return err;

	}



	if (udata)

	if (uresp)

		cq->is_user = 1;



	cq->is_dying = false;
@@ -114,14 +114,15 @@ int rxe_cq_from_init(struct rxe_dev *rxe, struct rxe_cq *cq, int cqe, 
	return 0;

}



int rxe_cq_resize_queue(struct rxe_cq *cq, int cqe, struct ib_udata *udata)

int rxe_cq_resize_queue(struct rxe_cq *cq, int cqe,

			struct rxe_resize_cq_resp __user *uresp)

{

	int err;



	err = rxe_queue_resize(cq->queue, (unsigned int *)&cqe,

			       sizeof(struct rxe_cqe),

			       cq->queue->ip ? cq->queue->ip->context : NULL,

			       udata, NULL, &cq->cq_lock);

			       uresp ? &uresp->mi : NULL, NULL, &cq->cq_lock);

	if (!err)

		cq->ibcq.cqe = cqe;

drivers/infiniband/sw/rxe/rxe_loc.h

+8 −5
Original line number Diff line number Diff line
@@ -56,9 +56,10 @@ int rxe_cq_chk_attr(struct rxe_dev *rxe, struct rxe_cq *cq, 


int rxe_cq_from_init(struct rxe_dev *rxe, struct rxe_cq *cq, int cqe,

		     int comp_vector, struct ib_ucontext *context,

		     struct ib_udata *udata);

		     struct rxe_create_cq_resp __user *uresp);



int rxe_cq_resize_queue(struct rxe_cq *cq, int new_cqe, struct ib_udata *udata);

int rxe_cq_resize_queue(struct rxe_cq *cq, int new_cqe,

			struct rxe_resize_cq_resp __user *uresp);



int rxe_cq_post(struct rxe_cq *cq, struct rxe_cqe *cqe, int solicited);
@@ -158,7 +159,8 @@ int rxe_mcast_delete(struct rxe_dev *rxe, union ib_gid *mgid); 
int rxe_qp_chk_init(struct rxe_dev *rxe, struct ib_qp_init_attr *init);



int rxe_qp_from_init(struct rxe_dev *rxe, struct rxe_qp *qp, struct rxe_pd *pd,

		     struct ib_qp_init_attr *init, struct ib_udata *udata,

		     struct ib_qp_init_attr *init,

		     struct rxe_create_qp_resp __user *uresp,

		     struct ib_pd *ibpd);



int rxe_qp_to_init(struct rxe_qp *qp, struct ib_qp_init_attr *init);
@@ -226,11 +228,12 @@ int rxe_srq_chk_attr(struct rxe_dev *rxe, struct rxe_srq *srq, 


int rxe_srq_from_init(struct rxe_dev *rxe, struct rxe_srq *srq,

		      struct ib_srq_init_attr *init,

		      struct ib_ucontext *context, struct ib_udata *udata);

		      struct ib_ucontext *context,

		      struct rxe_create_srq_resp __user *uresp);



int rxe_srq_from_attr(struct rxe_dev *rxe, struct rxe_srq *srq,

		      struct ib_srq_attr *attr, enum ib_srq_attr_mask mask,

		      struct ib_udata *udata);

		      struct rxe_modify_srq_cmd *ucmd);



void rxe_release(struct kref *kref);

drivers/infiniband/sw/rxe/rxe_qp.c

+14 −12
Original line number Diff line number Diff line
@@ -216,7 +216,8 @@ static void rxe_qp_init_misc(struct rxe_dev *rxe, struct rxe_qp *qp, 


static int rxe_qp_init_req(struct rxe_dev *rxe, struct rxe_qp *qp,

			   struct ib_qp_init_attr *init,

			   struct ib_ucontext *context, struct ib_udata *udata)

			   struct ib_ucontext *context,

			   struct rxe_create_qp_resp __user *uresp)

{

	int err;

	int wqe_size;
@@ -241,9 +242,9 @@ static int rxe_qp_init_req(struct rxe_dev *rxe, struct rxe_qp *qp, 
	if (!qp->sq.queue)

		return -ENOMEM;



	err = do_mmap_info(rxe, udata, true,

			   context, qp->sq.queue->buf,

			   qp->sq.queue->buf_size, &qp->sq.queue->ip);

	err = do_mmap_info(rxe, uresp ? &uresp->sq_mi : NULL, context,

			   qp->sq.queue->buf, qp->sq.queue->buf_size,

			   &qp->sq.queue->ip);



	if (err) {

		kvfree(qp->sq.queue->buf);
@@ -274,7 +275,8 @@ static int rxe_qp_init_req(struct rxe_dev *rxe, struct rxe_qp *qp, 


static int rxe_qp_init_resp(struct rxe_dev *rxe, struct rxe_qp *qp,

			    struct ib_qp_init_attr *init,

			    struct ib_ucontext *context, struct ib_udata *udata)

			    struct ib_ucontext *context,

			    struct rxe_create_qp_resp __user *uresp)

{

	int err;

	int wqe_size;
@@ -294,9 +296,8 @@ static int rxe_qp_init_resp(struct rxe_dev *rxe, struct rxe_qp *qp, 
		if (!qp->rq.queue)

			return -ENOMEM;



		err = do_mmap_info(rxe, udata, false, context,

				   qp->rq.queue->buf,

				   qp->rq.queue->buf_size,

		err = do_mmap_info(rxe, uresp ? &uresp->rq_mi : NULL, context,

				   qp->rq.queue->buf, qp->rq.queue->buf_size,

				   &qp->rq.queue->ip);

		if (err) {

			kvfree(qp->rq.queue->buf);
@@ -322,14 +323,15 @@ static int rxe_qp_init_resp(struct rxe_dev *rxe, struct rxe_qp *qp, 


/* called by the create qp verb */

int rxe_qp_from_init(struct rxe_dev *rxe, struct rxe_qp *qp, struct rxe_pd *pd,

		     struct ib_qp_init_attr *init, struct ib_udata *udata,

		     struct ib_qp_init_attr *init,

		     struct rxe_create_qp_resp __user *uresp,

		     struct ib_pd *ibpd)

{

	int err;

	struct rxe_cq *rcq = to_rcq(init->recv_cq);

	struct rxe_cq *scq = to_rcq(init->send_cq);

	struct rxe_srq *srq = init->srq ? to_rsrq(init->srq) : NULL;

	struct ib_ucontext *context = udata ? ibpd->uobject->context : NULL;

	struct ib_ucontext *context = ibpd->uobject ? ibpd->uobject->context : NULL;



	rxe_add_ref(pd);

	rxe_add_ref(rcq);
@@ -344,11 +346,11 @@ int rxe_qp_from_init(struct rxe_dev *rxe, struct rxe_qp *qp, struct rxe_pd *pd, 


	rxe_qp_init_misc(rxe, qp, init);



	err = rxe_qp_init_req(rxe, qp, init, context, udata);

	err = rxe_qp_init_req(rxe, qp, init, context, uresp);

	if (err)

		goto err1;



	err = rxe_qp_init_resp(rxe, qp, init, context, udata);

	err = rxe_qp_init_resp(rxe, qp, init, context, uresp);

	if (err)

		goto err2;

drivers/infiniband/sw/rxe/rxe_queue.c

+5 −19
Original line number Diff line number Diff line
@@ -37,35 +37,21 @@ 
#include "rxe_queue.h"



int do_mmap_info(struct rxe_dev *rxe,

		 struct ib_udata *udata,

		 bool is_req,

		 struct mminfo __user *outbuf,

		 struct ib_ucontext *context,

		 struct rxe_queue_buf *buf,

		 size_t buf_size,

		 struct rxe_mmap_info **ip_p)

{

	int err;

	u32 len, offset;

	struct rxe_mmap_info *ip = NULL;



	if (udata) {

		if (is_req) {

			len = udata->outlen - sizeof(struct mminfo);

			offset = sizeof(struct mminfo);

		} else {

			len = udata->outlen;

			offset = 0;

		}



		if (len < sizeof(ip->info))

			goto err1;



	if (outbuf) {

		ip = rxe_create_mmap_info(rxe, buf_size, context, buf);

		if (!ip)

			goto err1;



		err = copy_to_user(udata->outbuf + offset, &ip->info,

				   sizeof(ip->info));

		err = copy_to_user(outbuf, &ip->info, sizeof(ip->info));

		if (err)

			goto err2;
@@ -171,7 +157,7 @@ int rxe_queue_resize(struct rxe_queue *q, 
		     unsigned int *num_elem_p,

		     unsigned int elem_size,

		     struct ib_ucontext *context,

		     struct ib_udata *udata,

		     struct mminfo __user *outbuf,

		     spinlock_t *producer_lock,

		     spinlock_t *consumer_lock)

{
@@ -184,7 +170,7 @@ int rxe_queue_resize(struct rxe_queue *q, 
	if (!new_q)

		return -ENOMEM;



	err = do_mmap_info(new_q->rxe, udata, false, context, new_q->buf,

	err = do_mmap_info(new_q->rxe, outbuf, context, new_q->buf,

			   new_q->buf_size, &new_q->ip);

	if (err) {

		vfree(new_q->buf);

drivers/infiniband/sw/rxe/rxe_queue.h

+2 −3
Original line number Diff line number Diff line
@@ -77,8 +77,7 @@ struct rxe_queue { 
};



int do_mmap_info(struct rxe_dev *rxe,

		 struct ib_udata *udata,

		 bool is_req,

		 struct mminfo __user *outbuf,

		 struct ib_ucontext *context,

		 struct rxe_queue_buf *buf,

		 size_t buf_size,
@@ -94,7 +93,7 @@ int rxe_queue_resize(struct rxe_queue *q, 
		     unsigned int *num_elem_p,

		     unsigned int elem_size,

		     struct ib_ucontext *context,

		     struct ib_udata *udata,

		     struct mminfo __user *outbuf,

		     /* Protect producers while resizing queue */

		     spinlock_t *producer_lock,

		     /* Protect consumers while resizing queue */