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

Lines Matching refs:wqhdr
608 	dapls_tavor_workq_hdr_t	*wqhdr, *consume_wqhdr = NULL;
612 	wqhdr = wridlist->wl_wqhdr;
613 	dapl_os_lock(&wqhdr->wq_wrid_lock->wrl_lock);
630 	if ((wqhdr->wq_wrid_poll == wridlist) &&
631 	    (wqhdr->wq_wrid_post == wridlist)) {
632 		consume_wqhdr = wqhdr;
636 	if (wqhdr->wq_wrid_poll == wridlist) {
637 		wqhdr->wq_wrid_poll = next;
639 	if (wqhdr->wq_wrid_post == wridlist) {
640 		wqhdr->wq_wrid_post = NULL;
656 	dapl_os_unlock(&wqhdr->wq_wrid_lock->wrl_lock);
832 		/* store the wl_lock in the wqhdr */
859 	/* For SRQ based QPs r_wridlist does not point to recv wqhdr */
895 	 * wridlist and wqhdr.
945 		/* for non-srq wqhdr the lock is allocated with the wqhdr */
956 		/* wrl allocated with wqhdr don't have srq enabled */
983 dapli_tavor_wrid_wqhdr_add(dapls_tavor_workq_hdr_t *wqhdr,
986 	/* dapl_os_assert(MUTEX_HELD(&wqhdr->wq_wrid_lock)); */
989 	if ((wqhdr->wq_wrid_post == NULL) &&
990 	    (wqhdr->wq_wrid_poll == NULL)) {
991 		wqhdr->wq_wrid_poll = wridlist;
992 		wqhdr->wq_wrid_post = wridlist;
994 		wqhdr->wq_wrid_post->wl_next = wridlist;
995 		wridlist->wl_prev = wqhdr->wq_wrid_post;
996 		wqhdr->wq_wrid_post = wridlist;
1007 dapli_tavor_wrid_wqhdr_remove(dapls_tavor_workq_hdr_t *wqhdr,
1012 	/* dapl_os_assert(MUTEX_HELD(&wqhdr->wq_wrid_lock)); */
1028 	if (wqhdr->wq_wrid_post == wridlist) {
1029 		wqhdr->wq_wrid_post = prev;
1031 	if (wqhdr->wq_wrid_poll == wridlist) {
1032 		wqhdr->wq_wrid_poll = NULL;
1091 dapli_tavor_cq_wqhdr_add(ib_cq_handle_t cq, dapls_tavor_workq_hdr_t *wqhdr)
1101 	key = (DAPL_HASH_KEY)(((uint64_t)wqhdr->wq_send_or_recv << 32) |
1102 	    wqhdr->wq_qpn);
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)
1120 	/* Remove "wqhdr" from the work queue header list on "cq" */
1122 	key = (DAPL_HASH_KEY)(((uint64_t)wqhdr->wq_send_or_recv << 32) |
1123 	    wqhdr->wq_qpn);
1128 	if (wqhdr->wq_wrid_lock && (!wqhdr->wq_wrid_lock->wrl_on_srq)) {
1129 		dapl_os_lock_destroy(&wqhdr->wq_wrid_lock->wrl_lock);
1133 	/* Free the memory associated with "wqhdr" */
1134 	dapl_os_free(wqhdr, size);