Lines Matching refs:send_cq
52 static void mlx4_ib_lock_cqs(struct mlx4_ib_cq *send_cq,
54 static void mlx4_ib_unlock_cqs(struct mlx4_ib_cq *send_cq,
758 if (init_attr->send_cq || init_attr->cap.max_send_wr) { in _mlx4_ib_create_qp_rss()
956 mlx4_ib_lock_cqs(to_mcq(init_attr->send_cq), in create_rq()
965 mcq = to_mcq(init_attr->send_cq); in create_rq()
969 mlx4_ib_unlock_cqs(to_mcq(init_attr->send_cq), in create_rq()
1230 mlx4_ib_lock_cqs(to_mcq(init_attr->send_cq), in create_qp_common()
1239 mcq = to_mcq(init_attr->send_cq); in create_qp_common()
1243 mlx4_ib_unlock_cqs(to_mcq(init_attr->send_cq), in create_qp_common()
1298 static void mlx4_ib_lock_cqs(struct mlx4_ib_cq *send_cq, struct mlx4_ib_cq *recv_cq) in mlx4_ib_lock_cqs() argument
1299 __acquires(&send_cq->lock) __acquires(&recv_cq->lock) in mlx4_ib_lock_cqs()
1301 if (send_cq == recv_cq) { in mlx4_ib_lock_cqs()
1302 spin_lock(&send_cq->lock); in mlx4_ib_lock_cqs()
1304 } else if (send_cq->mcq.cqn < recv_cq->mcq.cqn) { in mlx4_ib_lock_cqs()
1305 spin_lock(&send_cq->lock); in mlx4_ib_lock_cqs()
1309 spin_lock_nested(&send_cq->lock, SINGLE_DEPTH_NESTING); in mlx4_ib_lock_cqs()
1313 static void mlx4_ib_unlock_cqs(struct mlx4_ib_cq *send_cq, struct mlx4_ib_cq *recv_cq) in mlx4_ib_unlock_cqs() argument
1314 __releases(&send_cq->lock) __releases(&recv_cq->lock) in mlx4_ib_unlock_cqs()
1316 if (send_cq == recv_cq) { in mlx4_ib_unlock_cqs()
1318 spin_unlock(&send_cq->lock); in mlx4_ib_unlock_cqs()
1319 } else if (send_cq->mcq.cqn < recv_cq->mcq.cqn) { in mlx4_ib_unlock_cqs()
1321 spin_unlock(&send_cq->lock); in mlx4_ib_unlock_cqs()
1323 spin_unlock(&send_cq->lock); in mlx4_ib_unlock_cqs()
1347 struct mlx4_ib_cq **send_cq, struct mlx4_ib_cq **recv_cq) in get_cqs() argument
1351 *send_cq = to_mcq(to_mxrcd(qp->ibqp.xrcd)->cq); in get_cqs()
1352 *recv_cq = *send_cq; in get_cqs()
1355 *send_cq = to_mcq(qp->ibqp.send_cq); in get_cqs()
1356 *recv_cq = *send_cq; in get_cqs()
1361 *send_cq = (src == MLX4_IB_QP_SRC) ? to_mcq(qp->ibqp.send_cq) : in get_cqs()
1400 struct mlx4_ib_cq *send_cq, *recv_cq; in destroy_qp_common() local
1431 get_cqs(qp, src, &send_cq, &recv_cq); in destroy_qp_common()
1434 mlx4_ib_lock_cqs(send_cq, recv_cq); in destroy_qp_common()
1443 if (send_cq != recv_cq) in destroy_qp_common()
1444 __mlx4_ib_cq_clean(send_cq, qp->mqp.qpn, NULL); in destroy_qp_common()
1449 mlx4_ib_unlock_cqs(send_cq, recv_cq); in destroy_qp_common()
1559 init_attr->send_cq = to_mxrcd(init_attr->xrcd)->cq; in _mlx4_ib_create_qp()
1564 init_attr->recv_cq = init_attr->send_cq; in _mlx4_ib_create_qp()
2117 struct mlx4_ib_cq *send_cq, *recv_cq; in __mlx4_ib_modify_qp() local
2352 get_cqs(qp, src_type, &send_cq, &recv_cq); in __mlx4_ib_modify_qp()
2354 send_cq = to_mcq(rwq_ind_tbl->ind_tbl[0]->cq); in __mlx4_ib_modify_qp()
2355 recv_cq = send_cq; in __mlx4_ib_modify_qp()
2357 context->cqn_send = cpu_to_be32(send_cq->mcq.cqn); in __mlx4_ib_modify_qp()
2576 if (send_cq != recv_cq) in __mlx4_ib_modify_qp()
2577 mlx4_ib_cq_clean(send_cq, qp->mqp.qpn, NULL); in __mlx4_ib_modify_qp()
3572 if (mlx4_wq_overflow(&qp->sq, nreq, qp->ibqp.send_cq)) { in _mlx4_ib_post_send()
4170 ib_qp_init_attr.send_cq = ib_qp_init_attr.recv_cq; /* Dummy CQ */ in mlx4_ib_create_wq()
4444 struct ib_cq *cq = qp->send_cq; in mlx4_ib_drain_sq()