Lines Matching defs:cq

77 	((tavor_hw_uar_t *)ia_uar)->cq = HTOBE_64( \
84 * Takes the specified cq cmd and cq number and rings the cq doorbell
98 ((tavor_hw_uar_t *)ia_uar)->cq = HTOBE_64(doorbell);
106 ((tavor_hw_uar32_t *)ia_uar)->cq[0] =
108 ((tavor_hw_uar32_t *)ia_uar)->cq[1] =
113 &((tavor_hw_uar_t *)ia_uar)->cq);
784 dapli_tavor_cq_peek(ib_cq_handle_t cq, int *num_cqe)
795 cons_indx = cq->cq_consindx;
801 wrap_around_mask = (cq->cq_size - 1);
804 cqe = &cq->cq_addr[cons_indx];
828 cqe = &cq->cq_addr[cons_indx];
840 dapli_tavor_cq_poll(ib_cq_handle_t cq, ibt_wc_t *wc_p, uint_t num_wc,
852 cons_indx = cq->cq_consindx;
858 wrap_around_mask = (cq->cq_size - 1);
861 cqe = &cq->cq_addr[cons_indx];
875 status = dapli_tavor_cq_cqe_consume(cq, cqe,
885 cqe = &cq->cq_addr[cons_indx];
904 if ((polled_cnt != 0) && (cq->cq_consindx != cons_indx)) {
909 if (cons_indx > cq->cq_consindx) {
910 num_to_increment = (cons_indx - cq->cq_consindx) - 1;
912 num_to_increment = ((cons_indx + cq->cq_size) -
913 cq->cq_consindx) - 1;
915 cq->cq_consindx = cons_indx;
916 dapli_tavor_cq_doorbell(cq->cq_iauar, TAVOR_CQDB_INCR_CONSINDX,
917 cq->cq_num, num_to_increment);
923 if (cq->cq_wrid_reap_head) /* look before leaping */
924 dapls_tavor_wrid_cq_reap(cq);
941 dapli_tavor_cq_poll_one(ib_cq_handle_t cq, ibt_wc_t *wc_p)
949 cons_indx = cq->cq_consindx;
952 cqe = &cq->cq_addr[cons_indx];
965 status = dapli_tavor_cq_cqe_consume(cq, cqe, wc_p);
971 cq->cq_consindx =
972 (cons_indx + 1) & (cq->cq_size - 1);
973 dapli_tavor_cq_doorbell(cq->cq_iauar,
975 cq->cq_num, 0);
979 if (cq->cq_wrid_reap_head) /* look before leaping */
980 dapls_tavor_wrid_cq_reap(cq);
1263 dapli_tavor_cq_notify(ib_cq_handle_t cq, int flags, uint32_t param)
1271 cqnum = cq->cq_num;
1273 dapli_tavor_cq_doorbell(cq->cq_iauar, TAVOR_CQDB_NOTIFY_CQ,
1277 dapli_tavor_cq_doorbell(cq->cq_iauar,
1282 dapli_tavor_cq_doorbell(cq->cq_iauar, TAVOR_CQDB_NOTIFY_NCQ,
1719 ib_cq_handle_t cq;
1732 cq = qp->qp_rq_cqhdl;
1739 cons_indx = cq->cq_consindx;
1745 wrap_around_mask = (cq->cq_size - 1);
1748 cqe = &cq->cq_addr[cons_indx];
1766 /* update the pointer to the next cq entry */
1767 cqe = &cq->cq_addr[tail_cons_indx];
1778 cqe = &cq->cq_addr[check_indx];
1800 next_cqe = &cq->cq_addr[new_indx];
1832 cqe = &cq->cq_addr[indx];
1853 if ((removed_cqes != 0) && (cq->cq_consindx != cons_indx)) {
1858 if (cons_indx > cq->cq_consindx) {
1859 num_to_increment = (cons_indx - cq->cq_consindx) - 1;
1861 num_to_increment = ((cons_indx + cq->cq_size) -
1862 cq->cq_consindx) - 1;
1864 cq->cq_consindx = cons_indx;
1866 dapli_tavor_cq_doorbell(cq->cq_iauar, TAVOR_CQDB_INCR_CONSINDX,
1867 cq->cq_num, num_to_increment);
1879 dapli_tavor_cq_init(ib_cq_handle_t cq)