hw/ehca/ehca_cq.c

122 	struct ehca_cq *my_cq;
145 	my_cq = kmem_cache_zalloc(cq_cache, GFP_KERNEL);
146 	if (!my_cq) {
155 	spin_lock_init(&my_cq->spinlock);
156 	spin_lock_init(&my_cq->cb_lock);
157 	spin_lock_init(&my_cq->task_lock);
158 	atomic_set(&my_cq->nr_events, 0);
159 	init_waitqueue_head(&my_cq->wait_completion);
161 	cq = &my_cq->ib_cq;
175 		ret = idr_get_new(&ehca_cq_idr, my_cq, &my_cq->token);
186 	if (my_cq->token > 0x1FFFFFF) {
197 	h_ret = hipz_h_alloc_resource_cq(adapter_handle, my_cq, &param);
206 	ipz_rc = ipz_queue_ctor(NULL, &my_cq->ipz_queue, param.act_pages,
216 		vpage = ipz_qpageit_get_inc(&my_cq->ipz_queue);
226 						 my_cq->ipz_cq_handle,
227 						 &my_cq->pf,
232 						 my_cq->galpas.
238 				 "act_pages=%i", my_cq, my_cq->cq_number,
245 			vpage = ipz_qpageit_get_inc(&my_cq->ipz_queue);
249 					 "h_ret=%lli", my_cq, my_cq->cq_number,
259 					 my_cq, my_cq->cq_number,
267 	ipz_qeit_reset(&my_cq->ipz_queue);
269 	gal = my_cq->galpas.kernel;
272 		 my_cq, my_cq->cq_number, cqx_fec);
274 	my_cq->ib_cq.cqe = my_cq->nr_of_entries =
276 	my_cq->cq_number = (my_cq->ipz_cq_handle.handle) & 0xffff;
279 		INIT_HLIST_HEAD(&my_cq->qp_hashtab[i]);
281 	INIT_LIST_HEAD(&my_cq->sqp_err_list);
282 	INIT_LIST_HEAD(&my_cq->rqp_err_list);
285 		struct ipz_queue *ipz_queue = &my_cq->ipz_queue;
288 		resp.cq_number = my_cq->cq_number;
289 		resp.token = my_cq->token;
296 			(my_cq->galpas.user.fw_handle & (PAGE_SIZE - 1));
306 	ipz_queue_dtor(NULL, &my_cq->ipz_queue);
309 	h_ret = hipz_h_destroy_cq(adapter_handle, my_cq, 1);
312 			 "cq_num=%x h_ret=%lli", my_cq, my_cq->cq_number, h_ret);
316 	idr_remove(&ehca_cq_idr, my_cq->token);
320 	kmem_cache_free(cq_cache, my_cq);
329 	struct ehca_cq *my_cq = container_of(cq, struct ehca_cq, ib_cq);
330 	int cq_num = my_cq->cq_number;
338 		if (my_cq->mm_count_galpa || my_cq->mm_count_queue) {
340 				 "user space cq_num=%x", my_cq->cq_number);
350 	idr_remove(&ehca_cq_idr, my_cq->token);
354 	wait_event(my_cq->wait_completion, !atomic_read(&my_cq->nr_events));
357 	h_ret = hipz_h_destroy_cq(adapter_handle, my_cq, 0);
362 			 my_cq, cq_num, my_cq->ipz_cq_handle.handle);
363 		ehca_error_data(shca, my_cq, my_cq->ipz_cq_handle.handle);
364 		h_ret = hipz_h_destroy_cq(adapter_handle, my_cq, 1);
371 			 "ehca_cq=%p cq_num=%x", h_ret, my_cq, cq_num);
374 	ipz_queue_dtor(NULL, &my_cq->ipz_queue);
375 	kmem_cache_free(cq_cache, my_cq);