Lines Matching refs:chp
134 struct iwch_cq *chp;
137 chp = to_iwch_cq(ib_cq);
139 remove_handle(chp->rhp, &chp->rhp->cqidr, chp->cq.cqid);
140 atomic_dec(&chp->refcnt);
141 wait_event(chp->wait, !atomic_read(&chp->refcnt));
143 cxio_destroy_cq(&chp->rhp->rdev, &chp->cq);
144 kfree(chp);
153 struct iwch_cq *chp;
160 chp = kzalloc(sizeof(*chp), GFP_KERNEL);
161 if (!chp)
168 kfree(chp);
171 chp->user_rptr_addr = (u32 __user *)(unsigned long)ureq.user_rptr_addr;
189 chp->cq.size_log2 = ilog2(entries);
191 if (cxio_create_cq(&rhp->rdev, &chp->cq, !ucontext)) {
192 kfree(chp);
195 chp->rhp = rhp;
196 chp->ibcq.cqe = 1 << chp->cq.size_log2;
197 spin_lock_init(&chp->lock);
198 atomic_set(&chp->refcnt, 1);
199 init_waitqueue_head(&chp->wait);
200 if (insert_handle(rhp, &rhp->cqidr, chp, chp->cq.cqid)) {
201 cxio_destroy_cq(&chp->rhp->rdev, &chp->cq);
202 kfree(chp);
211 iwch_destroy_cq(&chp->ibcq);
214 uresp.cqid = chp->cq.cqid;
215 uresp.size_log2 = chp->cq.size_log2;
222 iwch_destroy_cq(&chp->ibcq);
226 mm->addr = virt_to_phys(chp->cq.queue);
231 PDBG("created cqid 0x%0x chp %p size 0x%0x, dma_addr 0x%0llx\n",
232 chp->cq.cqid, chp, (1 << chp->cq.size_log2),
233 (unsigned long long) chp->cq.dma_addr);
234 return &chp->ibcq;
240 struct iwch_cq *chp = to_iwch_cq(cq);
255 if (cqe < Q_COUNT(chp->cq.rptr, chp->cq.wptr)) {
260 ret = iwch_quiesce_qps(chp);
265 ret = cxio_create_cq(&chp->rhp->rdev, &newcq);
271 memcpy(newcq.queue, chp->cq.queue, (1 << chp->cq.size_log2) *
275 oldcq = chp->cq;
276 chp->cq = newcq;
277 chp->cq.cqid = oldcq.cqid;
280 ret = cxio_resize_cq(&chp->rhp->rdev, &chp->cq);
282 chp->cq = oldcq;
285 chp->ibcq.cqe = (1<<chp->cq.size_log2) - 1;
289 ret = cxio_destroy_cq(&chp->rhp->rdev, &oldcq);
298 ret = iwch_resume_qps(chp);
308 struct iwch_cq *chp;
314 chp = to_iwch_cq(ibcq);
315 rhp = chp->rhp;
320 if (chp->user_rptr_addr) {
321 if (get_user(rptr, chp->user_rptr_addr))
323 spin_lock_irqsave(&chp->lock, flag);
324 chp->cq.rptr = rptr;
326 spin_lock_irqsave(&chp->lock, flag);
327 PDBG("%s rptr 0x%x\n", __func__, chp->cq.rptr);
328 err = cxio_hal_cq_op(&rhp->rdev, &chp->cq, cq_op, 0);
329 spin_unlock_irqrestore(&chp->lock, flag);
332 chp->cq.cqid);