[linux-2.6-block.git] / drivers / infiniband / hw / mlx4 / srq.c

/*
 * Copyright (c) 2007 Cisco Systems, Inc. All rights reserved.
 * Copyright (c) 2007, 2008 Mellanox Technologies. All rights reserved.
 *
 * This software is available to you under a choice of one of two
 * licenses.  You may choose to be licensed under the terms of the GNU
 * General Public License (GPL) Version 2, available from the file
 * COPYING in the main directory of this source tree, or the
 * OpenIB.org BSD license below:
 *
 *     Redistribution and use in source and binary forms, with or
 *     without modification, are permitted provided that the following
 *     conditions are met:
 *
 *      - Redistributions of source code must retain the above
 *        copyright notice, this list of conditions and the following
 *        disclaimer.
 *
 *      - Redistributions in binary form must reproduce the above
 *        copyright notice, this list of conditions and the following
 *        disclaimer in the documentation and/or other materials
 *        provided with the distribution.
 *
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
 * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
 * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
 * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
 * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
 * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
 * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 * SOFTWARE.
 */

#include <linux/mlx4/qp.h>
#include <linux/mlx4/srq.h>
#include <linux/slab.h>

#include "mlx4_ib.h"
#include <rdma/mlx4-abi.h>
#include <rdma/uverbs_ioctl.h>

static void *get_wqe(struct mlx4_ib_srq *srq, int n)
{
	return mlx4_buf_offset(&srq->buf, n << srq->msrq.wqe_shift);
}

static void mlx4_ib_srq_event(struct mlx4_srq *srq, enum mlx4_event type)
{
	struct ib_event event;
	struct ib_srq *ibsrq = &to_mibsrq(srq)->ibsrq;

	if (ibsrq->event_handler) {
		event.device      = ibsrq->device;
		event.element.srq = ibsrq;
		switch (type) {
		case MLX4_EVENT_TYPE_SRQ_LIMIT:
			event.event = IB_EVENT_SRQ_LIMIT_REACHED;
			break;
		case MLX4_EVENT_TYPE_SRQ_CATAS_ERROR:
			event.event = IB_EVENT_SRQ_ERR;
			break;
		default:
			pr_warn("Unexpected event type %d "
			       "on SRQ %06x\n", type, srq->srqn);
			return;
		}

		ibsrq->event_handler(&event, ibsrq->srq_context);
	}
}

struct ib_srq *mlx4_ib_create_srq(struct ib_pd *pd,
				  struct ib_srq_init_attr *init_attr,
				  struct ib_udata *udata)
{
	struct mlx4_ib_dev *dev = to_mdev(pd->device);
	struct mlx4_ib_ucontext *ucontext = rdma_udata_to_drv_context(
		udata, struct mlx4_ib_ucontext, ibucontext);
	struct mlx4_ib_srq *srq;
	struct mlx4_wqe_srq_next_seg *next;
	struct mlx4_wqe_data_seg *scatter;
	u32 cqn;
	u16 xrcdn;
	int desc_size;
	int buf_size;
	int err;
	int i;

	/* Sanity check SRQ size before proceeding */
	if (init_attr->attr.max_wr  >= dev->dev->caps.max_srq_wqes ||
	    init_attr->attr.max_sge >  dev->dev->caps.max_srq_sge)
		return ERR_PTR(-EINVAL);

	srq = kmalloc(sizeof *srq, GFP_KERNEL);
	if (!srq)
		return ERR_PTR(-ENOMEM);

	mutex_init(&srq->mutex);
	spin_lock_init(&srq->lock);
	srq->msrq.max    = roundup_pow_of_two(init_attr->attr.max_wr + 1);
	srq->msrq.max_gs = init_attr->attr.max_sge;

	desc_size = max(32UL,
			roundup_pow_of_two(sizeof (struct mlx4_wqe_srq_next_seg) +
					   srq->msrq.max_gs *
					   sizeof (struct mlx4_wqe_data_seg)));
	srq->msrq.wqe_shift = ilog2(desc_size);

	buf_size = srq->msrq.max * desc_size;

	if (udata) {
		struct mlx4_ib_create_srq ucmd;

		if (ib_copy_from_udata(&ucmd, udata, sizeof ucmd)) {
			err = -EFAULT;
			goto err_srq;
		}

		srq->umem = ib_umem_get(udata, ucmd.buf_addr, buf_size, 0, 0);
		if (IS_ERR(srq->umem)) {
			err = PTR_ERR(srq->umem);
			goto err_srq;
		}

		err = mlx4_mtt_init(dev->dev, ib_umem_page_count(srq->umem),
				    srq->umem->page_shift, &srq->mtt);
		if (err)
			goto err_buf;

		err = mlx4_ib_umem_write_mtt(dev, &srq->mtt, srq->umem);
		if (err)
			goto err_mtt;

		err = mlx4_ib_db_map_user(ucontext, udata, ucmd.db_addr,
					  &srq->db);
		if (err)
			goto err_mtt;
	} else {
		err = mlx4_db_alloc(dev->dev, &srq->db, 0);
		if (err)
			goto err_srq;

		*srq->db.db = 0;

		if (mlx4_buf_alloc(dev->dev, buf_size, PAGE_SIZE * 2,
				   &srq->buf)) {
			err = -ENOMEM;
			goto err_db;
		}

		srq->head    = 0;
		srq->tail    = srq->msrq.max - 1;
		srq->wqe_ctr = 0;

		for (i = 0; i < srq->msrq.max; ++i) {
			next = get_wqe(srq, i);
			next->next_wqe_index =
				cpu_to_be16((i + 1) & (srq->msrq.max - 1));

			for (scatter = (void *) (next + 1);
			     (void *) scatter < (void *) next + desc_size;
			     ++scatter)
				scatter->lkey = cpu_to_be32(MLX4_INVALID_LKEY);
		}

		err = mlx4_mtt_init(dev->dev, srq->buf.npages, srq->buf.page_shift,
				    &srq->mtt);
		if (err)
			goto err_buf;

		err = mlx4_buf_write_mtt(dev->dev, &srq->mtt, &srq->buf);
		if (err)
			goto err_mtt;

		srq->wrid = kvmalloc_array(srq->msrq.max,
					   sizeof(u64), GFP_KERNEL);
		if (!srq->wrid) {
			err = -ENOMEM;
			goto err_mtt;
		}
	}

	cqn = ib_srq_has_cq(init_attr->srq_type) ?
		to_mcq(init_attr->ext.cq)->mcq.cqn : 0;
	xrcdn = (init_attr->srq_type == IB_SRQT_XRC) ?
		to_mxrcd(init_attr->ext.xrc.xrcd)->xrcdn :
		(u16) dev->dev->caps.reserved_xrcds;
	err = mlx4_srq_alloc(dev->dev, to_mpd(pd)->pdn, cqn, xrcdn, &srq->mtt,
			     srq->db.dma, &srq->msrq);
	if (err)
		goto err_wrid;

	srq->msrq.event = mlx4_ib_srq_event;
	srq->ibsrq.ext.xrc.srq_num = srq->msrq.srqn;

	if (udata)
		if (ib_copy_to_udata(udata, &srq->msrq.srqn, sizeof (__u32))) {
			err = -EFAULT;
			goto err_wrid;
		}

	init_attr->attr.max_wr = srq->msrq.max - 1;

	return &srq->ibsrq;

err_wrid:
	if (udata)
		mlx4_ib_db_unmap_user(ucontext, &srq->db);
	else
		kvfree(srq->wrid);

err_mtt:
	mlx4_mtt_cleanup(dev->dev, &srq->mtt);

err_buf:
	if (srq->umem)
		ib_umem_release(srq->umem);
	else
		mlx4_buf_free(dev->dev, buf_size, &srq->buf);

err_db:
	if (!udata)
		mlx4_db_free(dev->dev, &srq->db);

err_srq:
	kfree(srq);

	return ERR_PTR(err);
}

int mlx4_ib_modify_srq(struct ib_srq *ibsrq, struct ib_srq_attr *attr,
		       enum ib_srq_attr_mask attr_mask, struct ib_udata *udata)
{
	struct mlx4_ib_dev *dev = to_mdev(ibsrq->device);
	struct mlx4_ib_srq *srq = to_msrq(ibsrq);
	int ret;

	/* We don't support resizing SRQs (yet?) */
	if (attr_mask & IB_SRQ_MAX_WR)
		return -EINVAL;

	if (attr_mask & IB_SRQ_LIMIT) {
		if (attr->srq_limit >= srq->msrq.max)
			return -EINVAL;

		mutex_lock(&srq->mutex);
		ret = mlx4_srq_arm(dev->dev, &srq->msrq, attr->srq_limit);
		mutex_unlock(&srq->mutex);

		if (ret)
			return ret;
	}

	return 0;
}

int mlx4_ib_query_srq(struct ib_srq *ibsrq, struct ib_srq_attr *srq_attr)
{
	struct mlx4_ib_dev *dev = to_mdev(ibsrq->device);
	struct mlx4_ib_srq *srq = to_msrq(ibsrq);
	int ret;
	int limit_watermark;

	ret = mlx4_srq_query(dev->dev, &srq->msrq, &limit_watermark);
	if (ret)
		return ret;

	srq_attr->srq_limit = limit_watermark;
	srq_attr->max_wr    = srq->msrq.max - 1;
	srq_attr->max_sge   = srq->msrq.max_gs;

	return 0;
}

int mlx4_ib_destroy_srq(struct ib_srq *srq)
{
	struct mlx4_ib_dev *dev = to_mdev(srq->device);
	struct mlx4_ib_srq *msrq = to_msrq(srq);

	mlx4_srq_free(dev->dev, &msrq->msrq);
	mlx4_mtt_cleanup(dev->dev, &msrq->mtt);

	if (srq->uobject) {
		mlx4_ib_db_unmap_user(to_mucontext(srq->uobject->context), &msrq->db);
		ib_umem_release(msrq->umem);
	} else {
		kvfree(msrq->wrid);
		mlx4_buf_free(dev->dev, msrq->msrq.max << msrq->msrq.wqe_shift,
			      &msrq->buf);
		mlx4_db_free(dev->dev, &msrq->db);
	}

	kfree(msrq);

	return 0;
}

void mlx4_ib_free_srq_wqe(struct mlx4_ib_srq *srq, int wqe_index)
{
	struct mlx4_wqe_srq_next_seg *next;

	/* always called with interrupts disabled. */
	spin_lock(&srq->lock);

	next = get_wqe(srq, srq->tail);
	next->next_wqe_index = cpu_to_be16(wqe_index);
	srq->tail = wqe_index;

	spin_unlock(&srq->lock);
}

int mlx4_ib_post_srq_recv(struct ib_srq *ibsrq, const struct ib_recv_wr *wr,
			  const struct ib_recv_wr **bad_wr)
{
	struct mlx4_ib_srq *srq = to_msrq(ibsrq);
	struct mlx4_wqe_srq_next_seg *next;
	struct mlx4_wqe_data_seg *scat;
	unsigned long flags;
	int err = 0;
	int nreq;
	int i;
	struct mlx4_ib_dev *mdev = to_mdev(ibsrq->device);

	spin_lock_irqsave(&srq->lock, flags);
	if (mdev->dev->persist->state & MLX4_DEVICE_STATE_INTERNAL_ERROR) {
		err = -EIO;
		*bad_wr = wr;
		nreq = 0;
		goto out;
	}

	for (nreq = 0; wr; ++nreq, wr = wr->next) {
		if (unlikely(wr->num_sge > srq->msrq.max_gs)) {
			err = -EINVAL;
			*bad_wr = wr;
			break;
		}

		if (unlikely(srq->head == srq->tail)) {
			err = -ENOMEM;
			*bad_wr = wr;
			break;
		}

		srq->wrid[srq->head] = wr->wr_id;

		next      = get_wqe(srq, srq->head);
		srq->head = be16_to_cpu(next->next_wqe_index);
		scat      = (struct mlx4_wqe_data_seg *) (next + 1);

		for (i = 0; i < wr->num_sge; ++i) {
			scat[i].byte_count = cpu_to_be32(wr->sg_list[i].length);
			scat[i].lkey       = cpu_to_be32(wr->sg_list[i].lkey);
			scat[i].addr       = cpu_to_be64(wr->sg_list[i].addr);
		}

		if (i < srq->msrq.max_gs) {
			scat[i].byte_count = 0;
			scat[i].lkey       = cpu_to_be32(MLX4_INVALID_LKEY);
			scat[i].addr       = 0;
		}
	}

	if (likely(nreq)) {
		srq->wqe_ctr += nreq;

		/*
		 * Make sure that descriptors are written before
		 * doorbell record.
		 */
		wmb();

		*srq->db.db = cpu_to_be32(srq->wqe_ctr);
	}
out:

	spin_unlock_irqrestore(&srq->lock, flags);

	return err;
}
Commit	Line	Data
225c7b1f RD	1	/*
225c7b1f RD	2	* Copyright (c) 2007 Cisco Systems, Inc. All rights reserved.
51a379d0	3	* Copyright (c) 2007, 2008 Mellanox Technologies. All rights reserved.
225c7b1f RD	4	*
	5	* This software is available to you under a choice of one of two
	6	* licenses. You may choose to be licensed under the terms of the GNU
	7	* General Public License (GPL) Version 2, available from the file
	8	* COPYING in the main directory of this source tree, or the
	9	* OpenIB.org BSD license below:
	10	*
	11	* Redistribution and use in source and binary forms, with or
	12	* without modification, are permitted provided that the following
	13	* conditions are met:
	14	*
	15	* - Redistributions of source code must retain the above
	16	* copyright notice, this list of conditions and the following
	17	* disclaimer.
	18	*
	19	* - Redistributions in binary form must reproduce the above
	20	* copyright notice, this list of conditions and the following
	21	* disclaimer in the documentation and/or other materials
	22	* provided with the distribution.
	23	*
	24	* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
	25	* EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
	26	* MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
	27	* NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
	28	* BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
	29	* ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
	30	* CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
	31	* SOFTWARE.
	32	*/
	33
	34	#include <linux/mlx4/qp.h>
	35	#include <linux/mlx4/srq.h>
5a0e3ad6	36	#include <linux/slab.h>
225c7b1f RD	37
225c7b1f RD	38	#include "mlx4_ib.h"
9ce28a20	39	#include <rdma/mlx4-abi.h>
89944450	40	#include <rdma/uverbs_ioctl.h>
225c7b1f RD	41
	42	static void get_wqe(struct mlx4_ib_srq srq, int n)
	43	{
1c69fc2a	44	return mlx4_buf_offset(&srq->buf, n << srq->msrq.wqe_shift);
225c7b1f RD	45	}
	46
	47	static void mlx4_ib_srq_event(struct mlx4_srq *srq, enum mlx4_event type)
	48	{
	49	struct ib_event event;
	50	struct ib_srq *ibsrq = &to_mibsrq(srq)->ibsrq;
	51
	52	if (ibsrq->event_handler) {
	53	event.device = ibsrq->device;
	54	event.element.srq = ibsrq;
	55	switch (type) {
	56	case MLX4_EVENT_TYPE_SRQ_LIMIT:
	57	event.event = IB_EVENT_SRQ_LIMIT_REACHED;
	58	break;
	59	case MLX4_EVENT_TYPE_SRQ_CATAS_ERROR:
	60	event.event = IB_EVENT_SRQ_ERR;
	61	break;
	62	default:
987c8f8f	63	pr_warn("Unexpected event type %d "
225c7b1f RD	64	"on SRQ %06x\n", type, srq->srqn);
	65	return;
	66	}
	67
	68	ibsrq->event_handler(&event, ibsrq->srq_context);
	69	}
	70	}
	71
	72	struct ib_srq mlx4_ib_create_srq(struct ib_pd pd,
	73	struct ib_srq_init_attr *init_attr,
	74	struct ib_udata *udata)
	75	{
	76	struct mlx4_ib_dev *dev = to_mdev(pd->device);
89944450 SR	77	struct mlx4_ib_ucontext *ucontext = rdma_udata_to_drv_context(
89944450 SR	78	udata, struct mlx4_ib_ucontext, ibucontext);
225c7b1f RD	79	struct mlx4_ib_srq *srq;
225c7b1f RD	80	struct mlx4_wqe_srq_next_seg *next;
4c425588	81	struct mlx4_wqe_data_seg *scatter;
18abd5ea SH	82	u32 cqn;
18abd5ea SH	83	u16 xrcdn;
225c7b1f RD	84	int desc_size;
	85	int buf_size;
	86	int err;
	87	int i;
	88
	89	/* Sanity check SRQ size before proceeding */
	90	if (init_attr->attr.max_wr >= dev->dev->caps.max_srq_wqes \|\|
	91	init_attr->attr.max_sge > dev->dev->caps.max_srq_sge)
	92	return ERR_PTR(-EINVAL);
	93
	94	srq = kmalloc(sizeof *srq, GFP_KERNEL);
	95	if (!srq)
	96	return ERR_PTR(-ENOMEM);
	97
	98	mutex_init(&srq->mutex);
	99	spin_lock_init(&srq->lock);
	100	srq->msrq.max = roundup_pow_of_two(init_attr->attr.max_wr + 1);
	101	srq->msrq.max_gs = init_attr->attr.max_sge;
	102
	103	desc_size = max(32UL,
	104	roundup_pow_of_two(sizeof (struct mlx4_wqe_srq_next_seg) +
	105	srq->msrq.max_gs *
	106	sizeof (struct mlx4_wqe_data_seg)));
	107	srq->msrq.wqe_shift = ilog2(desc_size);
	108
	109	buf_size = srq->msrq.max * desc_size;
	110
e00b64f7	111	if (udata) {
225c7b1f RD	112	struct mlx4_ib_create_srq ucmd;
	113
	114	if (ib_copy_from_udata(&ucmd, udata, sizeof ucmd)) {
	115	err = -EFAULT;
	116	goto err_srq;
	117	}
	118
b0ea0fa5	119	srq->umem = ib_umem_get(udata, ucmd.buf_addr, buf_size, 0, 0);
225c7b1f RD	120	if (IS_ERR(srq->umem)) {
	121	err = PTR_ERR(srq->umem);
	122	goto err_srq;
	123	}
	124
	125	err = mlx4_mtt_init(dev->dev, ib_umem_page_count(srq->umem),
3e7e1193	126	srq->umem->page_shift, &srq->mtt);
225c7b1f RD	127	if (err)
	128	goto err_buf;
	129
	130	err = mlx4_ib_umem_write_mtt(dev, &srq->mtt, srq->umem);
	131	if (err)
	132	goto err_mtt;
	133
89944450 SR	134	err = mlx4_ib_db_map_user(ucontext, udata, ucmd.db_addr,
89944450 SR	135	&srq->db);
225c7b1f RD	136	if (err)
	137	goto err_mtt;
	138	} else {
8900b894	139	err = mlx4_db_alloc(dev->dev, &srq->db, 0);
225c7b1f RD	140	if (err)
	141	goto err_srq;
	142
	143	*srq->db.db = 0;
	144
8900b894 LR	145	if (mlx4_buf_alloc(dev->dev, buf_size, PAGE_SIZE * 2,
8900b894 LR	146	&srq->buf)) {
225c7b1f RD	147	err = -ENOMEM;
	148	goto err_db;
	149	}
	150
	151	srq->head = 0;
	152	srq->tail = srq->msrq.max - 1;
	153	srq->wqe_ctr = 0;
	154
	155	for (i = 0; i < srq->msrq.max; ++i) {
	156	next = get_wqe(srq, i);
	157	next->next_wqe_index =
	158	cpu_to_be16((i + 1) & (srq->msrq.max - 1));
4c425588 JM	159
	160	for (scatter = (void *) (next + 1);
	161	(void ) scatter < (void ) next + desc_size;
	162	++scatter)
	163	scatter->lkey = cpu_to_be32(MLX4_INVALID_LKEY);
225c7b1f RD	164	}
	165
	166	err = mlx4_mtt_init(dev->dev, srq->buf.npages, srq->buf.page_shift,
	167	&srq->mtt);
	168	if (err)
	169	goto err_buf;
	170
8900b894	171	err = mlx4_buf_write_mtt(dev->dev, &srq->mtt, &srq->buf);
225c7b1f RD	172	if (err)
	173	goto err_mtt;
	174
e9105cde LD	175	srq->wrid = kvmalloc_array(srq->msrq.max,
e9105cde LD	176	sizeof(u64), GFP_KERNEL);
225c7b1f	177	if (!srq->wrid) {
e9105cde LD	178	err = -ENOMEM;
e9105cde LD	179	goto err_mtt;
225c7b1f RD	180	}
	181	}
	182
1a56ff6d AK	183	cqn = ib_srq_has_cq(init_attr->srq_type) ?
1a56ff6d AK	184	to_mcq(init_attr->ext.cq)->mcq.cqn : 0;
18abd5ea SH	185	xrcdn = (init_attr->srq_type == IB_SRQT_XRC) ?
	186	to_mxrcd(init_attr->ext.xrc.xrcd)->xrcdn :
	187	(u16) dev->dev->caps.reserved_xrcds;
	188	err = mlx4_srq_alloc(dev->dev, to_mpd(pd)->pdn, cqn, xrcdn, &srq->mtt,
225c7b1f RD	189	srq->db.dma, &srq->msrq);
	190	if (err)
	191	goto err_wrid;
	192
	193	srq->msrq.event = mlx4_ib_srq_event;
18abd5ea	194	srq->ibsrq.ext.xrc.srq_num = srq->msrq.srqn;
225c7b1f	195
e00b64f7	196	if (udata)
225c7b1f RD	197	if (ib_copy_to_udata(udata, &srq->msrq.srqn, sizeof (__u32))) {
	198	err = -EFAULT;
	199	goto err_wrid;
	200	}
	201
	202	init_attr->attr.max_wr = srq->msrq.max - 1;
	203
	204	return &srq->ibsrq;
	205
	206	err_wrid:
e00b64f7	207	if (udata)
89944450	208	mlx4_ib_db_unmap_user(ucontext, &srq->db);
225c7b1f	209	else
0ef2f05c	210	kvfree(srq->wrid);
225c7b1f RD	211
	212	err_mtt:
	213	mlx4_mtt_cleanup(dev->dev, &srq->mtt);
	214
	215	err_buf:
e00b64f7	216	if (srq->umem)
225c7b1f RD	217	ib_umem_release(srq->umem);
	218	else
	219	mlx4_buf_free(dev->dev, buf_size, &srq->buf);
	220
	221	err_db:
e00b64f7	222	if (!udata)
6296883c	223	mlx4_db_free(dev->dev, &srq->db);
225c7b1f RD	224
	225	err_srq:
	226	kfree(srq);
	227
	228	return ERR_PTR(err);
	229	}
	230
	231	int mlx4_ib_modify_srq(struct ib_srq ibsrq, struct ib_srq_attr attr,
	232	enum ib_srq_attr_mask attr_mask, struct ib_udata *udata)
	233	{
	234	struct mlx4_ib_dev *dev = to_mdev(ibsrq->device);
	235	struct mlx4_ib_srq *srq = to_msrq(ibsrq);
	236	int ret;
	237
	238	/* We don't support resizing SRQs (yet?) */
	239	if (attr_mask & IB_SRQ_MAX_WR)
	240	return -EINVAL;
	241
	242	if (attr_mask & IB_SRQ_LIMIT) {
	243	if (attr->srq_limit >= srq->msrq.max)
	244	return -EINVAL;
	245
	246	mutex_lock(&srq->mutex);
	247	ret = mlx4_srq_arm(dev->dev, &srq->msrq, attr->srq_limit);
	248	mutex_unlock(&srq->mutex);
	249
	250	if (ret)
	251	return ret;
	252	}
	253
	254	return 0;
	255	}
	256
65541cb7 JM	257	int mlx4_ib_query_srq(struct ib_srq ibsrq, struct ib_srq_attr srq_attr)
	258	{
	259	struct mlx4_ib_dev *dev = to_mdev(ibsrq->device);
	260	struct mlx4_ib_srq *srq = to_msrq(ibsrq);
	261	int ret;
	262	int limit_watermark;
	263
	264	ret = mlx4_srq_query(dev->dev, &srq->msrq, &limit_watermark);
	265	if (ret)
	266	return ret;
	267
d7dc3ccb	268	srq_attr->srq_limit = limit_watermark;
65541cb7 JM	269	srq_attr->max_wr = srq->msrq.max - 1;
	270	srq_attr->max_sge = srq->msrq.max_gs;
	271
	272	return 0;
	273	}
	274
225c7b1f RD	275	int mlx4_ib_destroy_srq(struct ib_srq *srq)
	276	{
	277	struct mlx4_ib_dev *dev = to_mdev(srq->device);
	278	struct mlx4_ib_srq *msrq = to_msrq(srq);
	279
	280	mlx4_srq_free(dev->dev, &msrq->msrq);
	281	mlx4_mtt_cleanup(dev->dev, &msrq->mtt);
	282
	283	if (srq->uobject) {
	284	mlx4_ib_db_unmap_user(to_mucontext(srq->uobject->context), &msrq->db);
	285	ib_umem_release(msrq->umem);
	286	} else {
df417667	287	kvfree(msrq->wrid);
225c7b1f RD	288	mlx4_buf_free(dev->dev, msrq->msrq.max << msrq->msrq.wqe_shift,
225c7b1f RD	289	&msrq->buf);
6296883c	290	mlx4_db_free(dev->dev, &msrq->db);
225c7b1f RD	291	}
	292
	293	kfree(msrq);
	294
	295	return 0;
	296	}
	297
	298	void mlx4_ib_free_srq_wqe(struct mlx4_ib_srq *srq, int wqe_index)
	299	{
	300	struct mlx4_wqe_srq_next_seg *next;
	301
	302	/* always called with interrupts disabled. */
	303	spin_lock(&srq->lock);
	304
	305	next = get_wqe(srq, srq->tail);
	306	next->next_wqe_index = cpu_to_be16(wqe_index);
	307	srq->tail = wqe_index;
	308
	309	spin_unlock(&srq->lock);
	310	}
	311
d34ac5cd BVA	312	int mlx4_ib_post_srq_recv(struct ib_srq ibsrq, const struct ib_recv_wr wr,
d34ac5cd BVA	313	const struct ib_recv_wr **bad_wr)
225c7b1f RD	314	{
	315	struct mlx4_ib_srq *srq = to_msrq(ibsrq);
	316	struct mlx4_wqe_srq_next_seg *next;
	317	struct mlx4_wqe_data_seg *scat;
	318	unsigned long flags;
	319	int err = 0;
	320	int nreq;
	321	int i;
35f05dab	322	struct mlx4_ib_dev *mdev = to_mdev(ibsrq->device);
225c7b1f RD	323
225c7b1f RD	324	spin_lock_irqsave(&srq->lock, flags);
35f05dab YH	325	if (mdev->dev->persist->state & MLX4_DEVICE_STATE_INTERNAL_ERROR) {
	326	err = -EIO;
	327	*bad_wr = wr;
	328	nreq = 0;
	329	goto out;
	330	}
225c7b1f RD	331
	332	for (nreq = 0; wr; ++nreq, wr = wr->next) {
	333	if (unlikely(wr->num_sge > srq->msrq.max_gs)) {
	334	err = -EINVAL;
	335	*bad_wr = wr;
	336	break;
	337	}
	338
56a8c8b6 RD	339	if (unlikely(srq->head == srq->tail)) {
	340	err = -ENOMEM;
	341	*bad_wr = wr;
	342	break;
	343	}
	344
225c7b1f RD	345	srq->wrid[srq->head] = wr->wr_id;
	346
	347	next = get_wqe(srq, srq->head);
	348	srq->head = be16_to_cpu(next->next_wqe_index);
	349	scat = (struct mlx4_wqe_data_seg *) (next + 1);
	350
	351	for (i = 0; i < wr->num_sge; ++i) {
	352	scat[i].byte_count = cpu_to_be32(wr->sg_list[i].length);
	353	scat[i].lkey = cpu_to_be32(wr->sg_list[i].lkey);
	354	scat[i].addr = cpu_to_be64(wr->sg_list[i].addr);
	355	}
	356
	357	if (i < srq->msrq.max_gs) {
	358	scat[i].byte_count = 0;
	359	scat[i].lkey = cpu_to_be32(MLX4_INVALID_LKEY);
	360	scat[i].addr = 0;
	361	}
	362	}
	363
	364	if (likely(nreq)) {
	365	srq->wqe_ctr += nreq;
	366
	367	/*
	368	* Make sure that descriptors are written before
	369	* doorbell record.
	370	*/
	371	wmb();
	372
	373	*srq->db.db = cpu_to_be32(srq->wqe_ctr);
	374	}
35f05dab	375	out:
225c7b1f RD	376
	377	spin_unlock_irqrestore(&srq->lock, flags);
	378
	379	return err;
	380	}