Lines Matching refs:recv_cq
55 struct mlx4_ib_cq *recv_cq);
57 struct mlx4_ib_cq *recv_cq);
888 to_mcq(init_attr->recv_cq));
898 mcq = to_mcq(init_attr->recv_cq);
901 to_mcq(init_attr->recv_cq));
957 static void mlx4_ib_lock_cqs(struct mlx4_ib_cq *send_cq, struct mlx4_ib_cq *recv_cq)
958 __acquires(&send_cq->lock) __acquires(&recv_cq->lock)
960 if (send_cq == recv_cq) {
962 __acquire(&recv_cq->lock);
963 } else if (send_cq->mcq.cqn < recv_cq->mcq.cqn) {
965 spin_lock_nested(&recv_cq->lock, SINGLE_DEPTH_NESTING);
967 spin_lock(&recv_cq->lock);
972 static void mlx4_ib_unlock_cqs(struct mlx4_ib_cq *send_cq, struct mlx4_ib_cq *recv_cq)
973 __releases(&send_cq->lock) __releases(&recv_cq->lock)
975 if (send_cq == recv_cq) {
976 __release(&recv_cq->lock);
978 } else if (send_cq->mcq.cqn < recv_cq->mcq.cqn) {
979 spin_unlock(&recv_cq->lock);
983 spin_unlock(&recv_cq->lock);
1006 struct mlx4_ib_cq **send_cq, struct mlx4_ib_cq **recv_cq)
1011 *recv_cq = *send_cq;
1015 *recv_cq = *send_cq;
1019 *recv_cq = to_mcq(qp->ibqp.recv_cq);
1027 struct mlx4_ib_cq *send_cq, *recv_cq;
1058 get_cqs(qp, &send_cq, &recv_cq);
1061 mlx4_ib_lock_cqs(send_cq, recv_cq);
1068 __mlx4_ib_cq_clean(recv_cq, qp->mqp.qpn,
1070 if (send_cq != recv_cq)
1076 mlx4_ib_unlock_cqs(send_cq, recv_cq);
1181 init_attr->recv_cq = init_attr->send_cq;
1626 struct mlx4_ib_cq *send_cq, *recv_cq;
1837 get_cqs(qp, &send_cq, &recv_cq);
1840 context->cqn_recv = cpu_to_be32(recv_cq->mcq.cqn);
2047 mlx4_ib_cq_clean(recv_cq, qp->mqp.qpn,
2049 if (send_cq != recv_cq)
3292 if (mlx4_wq_overflow(&qp->rq, nreq, qp->ibqp.recv_cq)) {