11 int rxe_cq_chk_attr(struct rxe_dev *rxe, struct rxe_cq *cq,  in rxe_cq_chk_attr()  argument
27 	if (cq) {  in rxe_cq_chk_attr()
28 		count = queue_count(cq->queue);  in rxe_cq_chk_attr()
44 	struct rxe_cq *cq = from_tasklet(cq, t, comp_task);  in rxe_send_complete()  local
47 	spin_lock_irqsave(&cq->cq_lock, flags);  in rxe_send_complete()
48 	if (cq->is_dying) {  in rxe_send_complete()
49 		spin_unlock_irqrestore(&cq->cq_lock, flags);  in rxe_send_complete()
52 	spin_unlock_irqrestore(&cq->cq_lock, flags);  in rxe_send_complete()
54 	cq->ibcq.comp_handler(&cq->ibcq, cq->ibcq.cq_context);  in rxe_send_complete()
57 int rxe_cq_from_init(struct rxe_dev *rxe, struct rxe_cq *cq, int cqe,  in rxe_cq_from_init()  argument
63 	cq->queue = rxe_queue_init(rxe, &cqe,  in rxe_cq_from_init()
65 	if (!cq->queue) {  in rxe_cq_from_init()
71 			   cq->queue->buf, cq->queue->buf_size, &cq->queue->ip);  in rxe_cq_from_init()
73 		vfree(cq->queue->buf);  in rxe_cq_from_init()
74 		kfree(cq->queue);  in rxe_cq_from_init()
79 		cq->is_user = 1;  in rxe_cq_from_init()
81 	cq->is_dying = false;  in rxe_cq_from_init()
83 	tasklet_setup(&cq->comp_task, rxe_send_complete);  in rxe_cq_from_init()
85 	spin_lock_init(&cq->cq_lock);  in rxe_cq_from_init()
86 	cq->ibcq.cqe = cqe;  in rxe_cq_from_init()
90 int rxe_cq_resize_queue(struct rxe_cq *cq, int cqe,  in rxe_cq_resize_queue()  argument
96 	err = rxe_queue_resize(cq->queue, (unsigned int *)&cqe,  in rxe_cq_resize_queue()
98 			       uresp ? &uresp->mi : NULL, NULL, &cq->cq_lock);  in rxe_cq_resize_queue()
100 		cq->ibcq.cqe = cqe;  in rxe_cq_resize_queue()
105 int rxe_cq_post(struct rxe_cq *cq, struct rxe_cqe *cqe, int solicited)  in rxe_cq_post()  argument
110 	spin_lock_irqsave(&cq->cq_lock, flags);  in rxe_cq_post()
112 	if (unlikely(queue_full(cq->queue))) {  in rxe_cq_post()
113 		spin_unlock_irqrestore(&cq->cq_lock, flags);  in rxe_cq_post()
114 		if (cq->ibcq.event_handler) {  in rxe_cq_post()
115 			ev.device = cq->ibcq.device;  in rxe_cq_post()
116 			ev.element.cq = &cq->ibcq;  in rxe_cq_post()
118 			cq->ibcq.event_handler(&ev, cq->ibcq.cq_context);  in rxe_cq_post()
124 	memcpy(producer_addr(cq->queue), cqe, sizeof(*cqe));  in rxe_cq_post()
131 	advance_producer(cq->queue);  in rxe_cq_post()
132 	spin_unlock_irqrestore(&cq->cq_lock, flags);  in rxe_cq_post()
134 	if ((cq->notify == IB_CQ_NEXT_COMP) ||  in rxe_cq_post()
135 	    (cq->notify == IB_CQ_SOLICITED && solicited)) {  in rxe_cq_post()
136 		cq->notify = 0;  in rxe_cq_post()
137 		tasklet_schedule(&cq->comp_task);  in rxe_cq_post()
143 void rxe_cq_disable(struct rxe_cq *cq)  in rxe_cq_disable()  argument
147 	spin_lock_irqsave(&cq->cq_lock, flags);  in rxe_cq_disable()
148 	cq->is_dying = true;  in rxe_cq_disable()
149 	spin_unlock_irqrestore(&cq->cq_lock, flags);  in rxe_cq_disable()
154 	struct rxe_cq *cq = container_of(arg, typeof(*cq), pelem);  in rxe_cq_cleanup()  local
156 	if (cq->queue)  in rxe_cq_cleanup()
157 		rxe_queue_cleanup(cq->queue);  in rxe_cq_cleanup()