Lines Matching refs:queue
201 qp->sq.queue = rxe_queue_init(rxe, &qp->sq.max_wr, wqe_size,
203 if (!qp->sq.queue) {
204 rxe_err_qp(qp, "Unable to allocate send queue\n");
209 /* prepare info for caller to mmap send queue if user space qp */
211 qp->sq.queue->buf, qp->sq.queue->buf_size,
212 &qp->sq.queue->ip);
228 vfree(qp->sq.queue->buf);
229 kfree(qp->sq.queue);
230 qp->sq.queue = NULL;
241 /* if we don't finish qp create make sure queue is valid */
262 qp->req.wqe_index = queue_get_producer(qp->sq.queue,
292 qp->rq.queue = rxe_queue_init(rxe, &qp->rq.max_wr, wqe_size,
294 if (!qp->rq.queue) {
295 rxe_err_qp(qp, "Unable to allocate recv queue\n");
300 /* prepare info for caller to mmap recv queue if user space qp */
302 qp->rq.queue->buf, qp->rq.queue->buf_size,
303 &qp->rq.queue->ip);
317 vfree(qp->rq.queue->buf);
318 kfree(qp->rq.queue);
319 qp->rq.queue = NULL;
331 /* if we don't finish qp create make sure queue is valid */
393 rxe_queue_cleanup(qp->sq.queue);
394 qp->sq.queue = NULL;
526 if (qp->rq.queue)
527 rxe_queue_reset(qp->rq.queue);
528 if (qp->sq.queue)
529 rxe_queue_reset(qp->sq.queue);
838 if (qp->sq.queue)
839 rxe_queue_cleanup(qp->sq.queue);
844 if (qp->rq.queue)
845 rxe_queue_cleanup(qp->rq.queue);