1/*
2 * Copyright (c) 2006 Chelsio, Inc. All rights reserved.
3 *
4 * This software is available to you under a choice of one of two
5 * licenses.  You may choose to be licensed under the terms of the GNU
6 * General Public License (GPL) Version 2, available from the file
7 * COPYING in the main directory of this source tree, or the
8 * OpenIB.org BSD license below:
9 *
10 *     Redistribution and use in source and binary forms, with or
11 *     without modification, are permitted provided that the following
12 *     conditions are met:
13 *
14 *      - Redistributions of source code must retain the above
15 *        copyright notice, this list of conditions and the following
16 *        disclaimer.
17 *
18 *      - Redistributions in binary form must reproduce the above
19 *        copyright notice, this list of conditions and the following
20 *        disclaimer in the documentation and/or other materials
21 *        provided with the distribution.
22 *
23 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
24 * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
25 * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
26 * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
27 * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
28 * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
29 * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
30 * SOFTWARE.
31 */
32#include "iwch_provider.h"
33#include "iwch.h"
34
35/*
36 * Get one cq entry from cxio and map it to openib.
37 *
38 * Returns:
39 *	0			EMPTY;
40 *	1			cqe returned
41 *	-EAGAIN		caller must try again
42 *	any other -errno	fatal error
43 */
44static int iwch_poll_cq_one(struct iwch_dev *rhp, struct iwch_cq *chp,
45			    struct ib_wc *wc)
46{
47	struct iwch_qp *qhp = NULL;
48	struct t3_cqe cqe, *rd_cqe;
49	struct t3_wq *wq;
50	u32 credit = 0;
51	u8 cqe_flushed;
52	u64 cookie;
53	int ret = 1;
54
55	rd_cqe = cxio_next_cqe(&chp->cq);
56
57	if (!rd_cqe)
58		return 0;
59
60	qhp = get_qhp(rhp, CQE_QPID(*rd_cqe));
61	if (!qhp)
62		wq = NULL;
63	else {
64		spin_lock(&qhp->lock);
65		wq = &(qhp->wq);
66	}
67	ret = cxio_poll_cq(wq, &(chp->cq), &cqe, &cqe_flushed, &cookie,
68				   &credit);
69	if (t3a_device(chp->rhp) && credit) {
70		PDBG("%s updating %d cq credits on id %d\n", __func__,
71		     credit, chp->cq.cqid);
72		cxio_hal_cq_op(&rhp->rdev, &chp->cq, CQ_CREDIT_UPDATE, credit);
73	}
74
75	if (ret) {
76		ret = -EAGAIN;
77		goto out;
78	}
79	ret = 1;
80
81	wc->wr_id = cookie;
82	wc->qp = &qhp->ibqp;
83	wc->vendor_err = CQE_STATUS(cqe);
84	wc->wc_flags = 0;
85
86	PDBG("%s qpid 0x%x type %d opcode %d status 0x%x wrid hi 0x%x "
87	     "lo 0x%x cookie 0x%llx\n", __func__,
88	     CQE_QPID(cqe), CQE_TYPE(cqe),
89	     CQE_OPCODE(cqe), CQE_STATUS(cqe), CQE_WRID_HI(cqe),
90	     CQE_WRID_LOW(cqe), (unsigned long long) cookie);
91
92	if (CQE_TYPE(cqe) == 0) {
93		if (!CQE_STATUS(cqe))
94			wc->byte_len = CQE_LEN(cqe);
95		else
96			wc->byte_len = 0;
97		wc->opcode = IB_WC_RECV;
98		if (CQE_OPCODE(cqe) == T3_SEND_WITH_INV ||
99		    CQE_OPCODE(cqe) == T3_SEND_WITH_SE_INV) {
100			wc->ex.invalidate_rkey = CQE_WRID_STAG(cqe);
101			wc->wc_flags |= IB_WC_WITH_INVALIDATE;
102		}
103	} else {
104		switch (CQE_OPCODE(cqe)) {
105		case T3_RDMA_WRITE:
106			wc->opcode = IB_WC_RDMA_WRITE;
107			break;
108		case T3_READ_REQ:
109			wc->opcode = IB_WC_RDMA_READ;
110			wc->byte_len = CQE_LEN(cqe);
111			break;
112		case T3_SEND:
113		case T3_SEND_WITH_SE:
114		case T3_SEND_WITH_INV:
115		case T3_SEND_WITH_SE_INV:
116			wc->opcode = IB_WC_SEND;
117			break;
118		case T3_BIND_MW:
119			wc->opcode = IB_WC_BIND_MW;
120			break;
121
122		case T3_LOCAL_INV:
123			wc->opcode = IB_WC_LOCAL_INV;
124			break;
125		case T3_FAST_REGISTER:
126			wc->opcode = IB_WC_REG_MR;
127			break;
128		default:
129			printk(KERN_ERR MOD "Unexpected opcode %d "
130			       "in the CQE received for QPID=0x%0x\n",
131			       CQE_OPCODE(cqe), CQE_QPID(cqe));
132			ret = -EINVAL;
133			goto out;
134		}
135	}
136
137	if (cqe_flushed)
138		wc->status = IB_WC_WR_FLUSH_ERR;
139	else {
140
141		switch (CQE_STATUS(cqe)) {
142		case TPT_ERR_SUCCESS:
143			wc->status = IB_WC_SUCCESS;
144			break;
145		case TPT_ERR_STAG:
146			wc->status = IB_WC_LOC_ACCESS_ERR;
147			break;
148		case TPT_ERR_PDID:
149			wc->status = IB_WC_LOC_PROT_ERR;
150			break;
151		case TPT_ERR_QPID:
152		case TPT_ERR_ACCESS:
153			wc->status = IB_WC_LOC_ACCESS_ERR;
154			break;
155		case TPT_ERR_WRAP:
156			wc->status = IB_WC_GENERAL_ERR;
157			break;
158		case TPT_ERR_BOUND:
159			wc->status = IB_WC_LOC_LEN_ERR;
160			break;
161		case TPT_ERR_INVALIDATE_SHARED_MR:
162		case TPT_ERR_INVALIDATE_MR_WITH_MW_BOUND:
163			wc->status = IB_WC_MW_BIND_ERR;
164			break;
165		case TPT_ERR_CRC:
166		case TPT_ERR_MARKER:
167		case TPT_ERR_PDU_LEN_ERR:
168		case TPT_ERR_OUT_OF_RQE:
169		case TPT_ERR_DDP_VERSION:
170		case TPT_ERR_RDMA_VERSION:
171		case TPT_ERR_DDP_QUEUE_NUM:
172		case TPT_ERR_MSN:
173		case TPT_ERR_TBIT:
174		case TPT_ERR_MO:
175		case TPT_ERR_MSN_RANGE:
176		case TPT_ERR_IRD_OVERFLOW:
177		case TPT_ERR_OPCODE:
178			wc->status = IB_WC_FATAL_ERR;
179			break;
180		case TPT_ERR_SWFLUSH:
181			wc->status = IB_WC_WR_FLUSH_ERR;
182			break;
183		default:
184			printk(KERN_ERR MOD "Unexpected cqe_status 0x%x for "
185			       "QPID=0x%0x\n", CQE_STATUS(cqe), CQE_QPID(cqe));
186			ret = -EINVAL;
187		}
188	}
189out:
190	if (wq)
191		spin_unlock(&qhp->lock);
192	return ret;
193}
194
195int iwch_poll_cq(struct ib_cq *ibcq, int num_entries, struct ib_wc *wc)
196{
197	struct iwch_dev *rhp;
198	struct iwch_cq *chp;
199	unsigned long flags;
200	int npolled;
201	int err = 0;
202
203	chp = to_iwch_cq(ibcq);
204	rhp = chp->rhp;
205
206	spin_lock_irqsave(&chp->lock, flags);
207	for (npolled = 0; npolled < num_entries; ++npolled) {
208#ifdef DEBUG
209		int i=0;
210#endif
211
212		/*
213		 * Because T3 can post CQEs that are _not_ associated
214		 * with a WR, we might have to poll again after removing
215		 * one of these.
216		 */
217		do {
218			err = iwch_poll_cq_one(rhp, chp, wc + npolled);
219#ifdef DEBUG
220			BUG_ON(++i > 1000);
221#endif
222		} while (err == -EAGAIN);
223		if (err <= 0)
224			break;
225	}
226	spin_unlock_irqrestore(&chp->lock, flags);
227
228	if (err < 0)
229		return err;
230	else {
231		return npolled;
232	}
233}
234