Lines Matching refs:recv_cq
787 cm_id->recv_cq = ibv_create_cq(cm_id->verbs, rs->sq_size + rs->rq_size, in rs_create_cq()
789 if (!cm_id->recv_cq) in rs_create_cq()
797 ibv_req_notify_cq(cm_id->recv_cq, 0); in rs_create_cq()
799 cm_id->send_cq = cm_id->recv_cq; in rs_create_cq()
803 ibv_destroy_cq(cm_id->recv_cq); in rs_create_cq()
804 cm_id->recv_cq = NULL; in rs_create_cq()
872 qp_attr.recv_cq = rs->cm_id->recv_cq; in rs_create_ep()
1018 ibv_ack_cq_events(rs->cm_id->recv_cq, rs->unack_cqe); in rs_free()
1519 qp_attr.recv_cq = qp->cm_id->recv_cq; in ds_create_qp()
1906 while ((ret = ibv_poll_cq(rs->cm_id->recv_cq, 1, &wc)) > 0) { in rs_poll_cq()
2000 ibv_ack_cq_events(rs->cm_id->recv_cq, rs->unack_cqe); in rs_get_cq_event()
2041 ibv_req_notify_cq(rs->cm_id->recv_cq, 0); in rs_process_cq()
2113 ret = ibv_poll_cq(qp->cm_id->recv_cq, 1, &wc); in ds_poll_cqs()
2158 ibv_req_notify_cq(qp->cm_id->recv_cq, 0); in ds_req_notify_cqs()
2183 ibv_ack_cq_events(qp->cm_id->recv_cq, 1); in ds_get_cq_event()
3273 ibv_req_notify_cq(rs->cm_id->recv_cq, 0); in rshutdown()