Cross Reference: /osnet-11/usr/src/lib/udapl/udapl_tavor/tavor/dapl_tavor

Lines Matching defs:cq
59 dapls_tavor_wrid_get_entry(ib_cq_handle_t cq, tavor_hw_cqe_t *cqe,
68 	dapl_os_lock(&cq->cq_wrid_wqhdr_lock);
72 	wq = dapli_tavor_wrid_wqhdr_find(cq, qpnum, send_or_recv);
114 	dapl_os_unlock(&cq->cq_wrid_wqhdr_lock);
303 dapls_tavor_wrid_cq_reap(ib_cq_handle_t cq)
309 	/* dapl_os_assert(MUTEX_HELD(&cq->cq_lock)); */
312 	dapl_os_lock(&cq->cq_wrid_wqhdr_lock);
315 	container = cq->cq_wrid_reap_head;
326 			dapli_tavor_cq_wqhdr_remove(cq, consume_wqhdr);
331 	cq->cq_wrid_reap_head = cq->cq_wrid_reap_tail = NULL;
333 	dapl_os_unlock(&cq->cq_wrid_wqhdr_lock);
341 dapls_tavor_wrid_cq_force_reap(ib_cq_handle_t cq)
348 	/* dapl_os_assert(MUTEX_HELD(&cq->cq_lock)); */
356 	dapls_tavor_wrid_cq_reap(cq);
359 	dapl_os_lock(&cq->cq_wrid_wqhdr_lock);
370 	retval = dapls_hash_iterate(cq->cq_wrid_wqhdr_list,
377 		retval = dapls_hash_iterate(cq->cq_wrid_wqhdr_list,
393 				dapli_tavor_cq_wqhdr_remove(cq, to_free_wqhdr);
398 	dapl_os_lock(&cq->cq_wrid_wqhdr_lock);
509 dapli_tavor_wrid_reaplist_add(ib_cq_handle_t cq, dapls_tavor_workq_hdr_t *wq)
511 	/* dapl_os_assert(MUTEX_HELD(&cq->cq_wrid_wqhdr_lock)); */
519 	if ((cq->cq_wrid_reap_head == NULL) &&
520 	    (cq->cq_wrid_reap_tail == NULL)) {
521 		cq->cq_wrid_reap_head = wq->wq_wrid_post;
522 		cq->cq_wrid_reap_tail = wq->wq_wrid_post;
524 		cq->cq_wrid_reap_tail->wl_reap_next = wq->wq_wrid_post;
525 		cq->cq_wrid_reap_tail = wq->wq_wrid_post;
536 dapli_tavor_wrid_wqhdr_find(ib_cq_handle_t cq, uint_t qpn, uint_t send_or_recv)
542 	/* dapl_os_assert(MUTEX_HELD(&cq->cq_wrid_wqhdr_lock)); */
552 	status = dapls_hash_search(cq->cq_wrid_wqhdr_list, key, &curr);
894 	 * However for qps with SRQ we flush the cq entries, remove the
926 dapli_tavor_wrid_wqhdr_create(ib_cq_handle_t cq, uint_t qpn,
932 	/* dapl_os_assert(MUTEX_HELD(&cq->cq_wrid_wqhdr_lock)); */
967 	if (dapli_tavor_cq_wqhdr_add(cq, wqhdr_tmp) != DAT_SUCCESS) {
1091 dapli_tavor_cq_wqhdr_add(ib_cq_handle_t cq, dapls_tavor_workq_hdr_t *wqhdr)
1095 	/* dapl_os_assert(MUTEX_HELD(&cq->cq_wrid_wqhdr_lock)); */
1104 	return (dapls_hash_insert(cq->cq_wrid_wqhdr_list, key, wqhdr));
1112 dapli_tavor_cq_wqhdr_remove(ib_cq_handle_t cq, dapls_tavor_workq_hdr_t *wqhdr)
1118 	/* dapl_os_assert(MUTEX_HELD(&cq->cq_wrid_wqhdr_lock)); */
1120 	/* Remove "wqhdr" from the work queue header list on "cq" */
1125 	(void) dapls_hash_remove(cq->cq_wrid_wqhdr_list, key,  &curr);