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

Lines Matching refs:cq
104  * Takes the specified cq cmd and cq number and rings the cq doorbell
119 	((tavor_hw_uar_t *)ia_uar)->cq = HTOBE_64(doorbell);
127 	((tavor_hw_uar32_t *)ia_uar)->cq[0] =
129 	((tavor_hw_uar32_t *)ia_uar)->cq[1] =
134 	    &((tavor_hw_uar_t *)ia_uar)->cq);
552 dapli_arbel_cq_peek(ib_cq_handle_t cq, int *num_cqe)
563 	cons_indx = cq->cq_consindx;
569 	wrap_around_mask = (cq->cq_size - 1);
572 	cqe = &cq->cq_addr[cons_indx];
596 		cqe = &cq->cq_addr[cons_indx];
602 #define	dapli_arbel_cq_update_ci(cq, dbp) \
603 	(dbp)[0] = HTOBE_32(cq->cq_consindx)
611 dapli_arbel_cq_poll(ib_cq_handle_t cq, ibt_wc_t *wc_p, uint_t num_wc,
622 	cons_indx = cq->cq_consindx;
628 	wrap_around_mask = (cq->cq_size - 1);
631 	cqe = &cq->cq_addr[cons_indx];
645 		status = dapli_arbel_cq_cqe_consume(cq, cqe,
655 			cqe = &cq->cq_addr[cons_indx];
674 	if ((polled_cnt != 0) && (cq->cq_consindx != cons_indx)) {
679 		cq->cq_consindx = cons_indx;
680 		dapli_arbel_cq_update_ci(cq, cq->cq_poll_dbp);
686 		if (cq->cq_wrid_reap_head)	/* look before leaping */
687 			dapls_tavor_wrid_cq_reap(cq);
704 dapli_arbel_cq_poll_one(ib_cq_handle_t cq, ibt_wc_t *wc_p)
712 	cons_indx = cq->cq_consindx;
715 	cqe = &cq->cq_addr[cons_indx];
728 		status = dapli_arbel_cq_cqe_consume(cq, cqe, wc_p);
734 			cq->cq_consindx =
735 			    (cons_indx + 1) & (cq->cq_size - 1);
736 			dapli_arbel_cq_update_ci(cq, cq->cq_poll_dbp);
740 		if (cq->cq_wrid_reap_head)	/* look before leaping */
741 			dapls_tavor_wrid_cq_reap(cq);
971  * event for the cq is received.  This code extracts the cmd_sn field
982 dapli_arbel_cq_notify(ib_cq_handle_t cq, int flags, uint32_t param)
992 	dapli_arbel_cq_update_ci(cq, cq->cq_arm_dbp);
993 	cqnum = cq->cq_num;
994 	target = cq->cq_arm_dbp + 1;
1007 			dapli_arbel_cq_doorbell(cq->cq_iauar,
1009 			    cmd_sn, cq->cq_consindx);
1019 			dapli_arbel_cq_doorbell(cq->cq_iauar,
1021 			    cmd_sn, cq->cq_consindx);
1386 	ib_cq_handle_t		cq;
1398 	cq = qp->qp_rq_cqhdl;
1405 	cons_indx = cq->cq_consindx;
1411 	wrap_around_mask = (cq->cq_size - 1);
1414 	cqe = &cq->cq_addr[cons_indx];
1432 		/* update the pointer to the next cq entry */
1433 		cqe = &cq->cq_addr[tail_cons_indx];
1444 		cqe = &cq->cq_addr[check_indx];
1466 				next_cqe = &cq->cq_addr[new_indx];
1498 			cqe = &cq->cq_addr[indx];
1519 	if ((removed_cqes != 0) && (cq->cq_consindx != cons_indx)) {
1524 		cq->cq_consindx = cons_indx;
1525 		dapli_arbel_cq_update_ci(cq, cq->cq_poll_dbp);
1591 dapli_arbel_cq_init(ib_cq_handle_t cq)
1593 	(cq->cq_poll_dbp)[1] =
1594 	    HTOBE_32((cq->cq_num << 8) | ARBEL_DBR_CQ_SET_CI);
1595 	(cq->cq_arm_dbp)[1] =
1596 	    HTOBE_32((cq->cq_num << 8) | ARBEL_DBR_CQ_ARM | 0x8);