Lines Matching refs:send_cq
84 struct mlx5_ib_cq **send_cq, struct mlx5_ib_cq **recv_cq);
823 static void mlx5_ib_lock_cqs(struct mlx5_ib_cq *send_cq,
825 static void mlx5_ib_unlock_cqs(struct mlx5_ib_cq *send_cq,
1292 static int get_sq_ts_format(struct mlx5_ib_dev *dev, struct mlx5_ib_cq *send_cq) in get_sq_ts_format() argument
1296 return get_ts_format(dev, send_cq, fr_supported(ts_cap), in get_sq_ts_format()
1300 static int get_qp_ts_format(struct mlx5_ib_dev *dev, struct mlx5_ib_cq *send_cq, in get_qp_ts_format() argument
1309 send_cq ? get_ts_format(dev, send_cq, fr_sup, rt_sup) : in get_qp_ts_format()
1586 to_mcq(init_attr->send_cq)); in create_raw_packet_qp()
1927 scqe_sz = mlx5_ib_get_cqe_size(init_attr->send_cq); in configure_requester_scat_cqe()
2073 struct mlx5_ib_cq *send_cq; in create_dci() local
2109 ts_format = get_qp_ts_format(dev, to_mcq(init_attr->send_cq), in create_dci()
2166 if (init_attr->send_cq) in create_dci()
2168 to_mcq(init_attr->send_cq)->mcq.cqn); in create_dci()
2198 get_cqs(qp->type, init_attr->send_cq, init_attr->recv_cq, in create_dci()
2199 &send_cq, &recv_cq); in create_dci()
2201 mlx5_ib_lock_cqs(send_cq, recv_cq); in create_dci()
2208 if (send_cq) in create_dci()
2209 list_add_tail(&qp->cq_send_list, &send_cq->list_send_qp); in create_dci()
2212 mlx5_ib_unlock_cqs(send_cq, recv_cq); in create_dci()
2234 struct mlx5_ib_cq *send_cq; in create_user_qp() local
2277 ts_format = get_qp_ts_format(dev, to_mcq(init_attr->send_cq), in create_user_qp()
2363 if (init_attr->send_cq) in create_user_qp()
2364 MLX5_SET(qpc, qpc, cqn_snd, to_mcq(init_attr->send_cq)->mcq.cqn); in create_user_qp()
2401 get_cqs(qp->type, init_attr->send_cq, init_attr->recv_cq, in create_user_qp()
2402 &send_cq, &recv_cq); in create_user_qp()
2404 mlx5_ib_lock_cqs(send_cq, recv_cq); in create_user_qp()
2411 if (send_cq) in create_user_qp()
2412 list_add_tail(&qp->cq_send_list, &send_cq->list_send_qp); in create_user_qp()
2415 mlx5_ib_unlock_cqs(send_cq, recv_cq); in create_user_qp()
2435 struct mlx5_ib_cq *send_cq; in create_kernel_qp() local
2506 if (attr->send_cq) in create_kernel_qp()
2507 MLX5_SET(qpc, qpc, cqn_snd, to_mcq(attr->send_cq)->mcq.cqn); in create_kernel_qp()
2530 get_cqs(qp->type, attr->send_cq, attr->recv_cq, in create_kernel_qp()
2531 &send_cq, &recv_cq); in create_kernel_qp()
2533 mlx5_ib_lock_cqs(send_cq, recv_cq); in create_kernel_qp()
2540 if (send_cq) in create_kernel_qp()
2541 list_add_tail(&qp->cq_send_list, &send_cq->list_send_qp); in create_kernel_qp()
2544 mlx5_ib_unlock_cqs(send_cq, recv_cq); in create_kernel_qp()
2554 static void mlx5_ib_lock_cqs(struct mlx5_ib_cq *send_cq, struct mlx5_ib_cq *recv_cq) in mlx5_ib_lock_cqs() argument
2555 __acquires(&send_cq->lock) __acquires(&recv_cq->lock) in mlx5_ib_lock_cqs()
2557 if (send_cq) { in mlx5_ib_lock_cqs()
2559 if (send_cq->mcq.cqn < recv_cq->mcq.cqn) { in mlx5_ib_lock_cqs()
2560 spin_lock(&send_cq->lock); in mlx5_ib_lock_cqs()
2563 } else if (send_cq->mcq.cqn == recv_cq->mcq.cqn) { in mlx5_ib_lock_cqs()
2564 spin_lock(&send_cq->lock); in mlx5_ib_lock_cqs()
2568 spin_lock_nested(&send_cq->lock, in mlx5_ib_lock_cqs()
2572 spin_lock(&send_cq->lock); in mlx5_ib_lock_cqs()
2577 __acquire(&send_cq->lock); in mlx5_ib_lock_cqs()
2579 __acquire(&send_cq->lock); in mlx5_ib_lock_cqs()
2584 static void mlx5_ib_unlock_cqs(struct mlx5_ib_cq *send_cq, struct mlx5_ib_cq *recv_cq) in mlx5_ib_unlock_cqs() argument
2585 __releases(&send_cq->lock) __releases(&recv_cq->lock) in mlx5_ib_unlock_cqs()
2587 if (send_cq) { in mlx5_ib_unlock_cqs()
2589 if (send_cq->mcq.cqn < recv_cq->mcq.cqn) { in mlx5_ib_unlock_cqs()
2591 spin_unlock(&send_cq->lock); in mlx5_ib_unlock_cqs()
2592 } else if (send_cq->mcq.cqn == recv_cq->mcq.cqn) { in mlx5_ib_unlock_cqs()
2594 spin_unlock(&send_cq->lock); in mlx5_ib_unlock_cqs()
2596 spin_unlock(&send_cq->lock); in mlx5_ib_unlock_cqs()
2601 spin_unlock(&send_cq->lock); in mlx5_ib_unlock_cqs()
2604 __release(&send_cq->lock); in mlx5_ib_unlock_cqs()
2608 __release(&send_cq->lock); in mlx5_ib_unlock_cqs()
2614 struct mlx5_ib_cq **send_cq, struct mlx5_ib_cq **recv_cq) in get_cqs() argument
2618 *send_cq = NULL; in get_cqs()
2623 *send_cq = ib_send_cq ? to_mcq(ib_send_cq) : NULL; in get_cqs()
2633 *send_cq = ib_send_cq ? to_mcq(ib_send_cq) : NULL; in get_cqs()
2637 *send_cq = NULL; in get_cqs()
2650 struct mlx5_ib_cq *send_cq, *recv_cq; in destroy_qp_common() local
2682 get_cqs(qp->type, qp->ibqp.send_cq, qp->ibqp.recv_cq, &send_cq, in destroy_qp_common()
2686 mlx5_ib_lock_cqs(send_cq, recv_cq); in destroy_qp_common()
2689 if (send_cq) in destroy_qp_common()
2698 if (send_cq != recv_cq) in destroy_qp_common()
2699 __mlx5_ib_cq_clean(send_cq, base->mqp.qpn, in destroy_qp_common()
2702 mlx5_ib_unlock_cqs(send_cq, recv_cq); in destroy_qp_common()
3129 params->attr->send_cq ? to_mcq(params->attr->send_cq)->mcq.cqn : in create_qp()
3151 ret = (attr->rwq_ind_tbl && attr->send_cq) ? -EINVAL : 0; in check_qp_attr()
4113 struct mlx5_ib_cq *send_cq, *recv_cq; in __mlx5_ib_modify_qp() local
4219 get_cqs(qp->type, qp->ibqp.send_cq, qp->ibqp.recv_cq, in __mlx5_ib_modify_qp()
4220 &send_cq, &recv_cq); in __mlx5_ib_modify_qp()
4223 if (send_cq) in __mlx5_ib_modify_qp()
4224 MLX5_SET(qpc, qpc, cqn_snd, send_cq->mcq.cqn); in __mlx5_ib_modify_qp()
4374 if (send_cq != recv_cq) in __mlx5_ib_modify_qp()
4375 mlx5_ib_cq_clean(send_cq, base->mqp.qpn, NULL); in __mlx5_ib_modify_qp()
5078 qp_init_attr->send_cq = ibqp->send_cq; in mlx5_ib_query_qp()
5702 struct ib_cq *cq = qp->send_cq; in mlx5_ib_drain_sq()