Lines Matching refs:mqp
1257 err = mlx5_core_create_sq_tracked(dev, in, inlen, &sq->base.mqp);
1277 mlx5_core_destroy_sq_tracked(dev, &sq->base.mqp);
1300 struct mlx5_ib_qp *mqp = rq->base.container_mibqp;
1329 if (mqp->flags & IB_QP_CREATE_SCATTER_FCS)
1347 err = mlx5_core_create_rq_tracked(dev, in, inlen, &rq->base.mqp);
1357 mlx5_core_destroy_rq_tracked(dev, &rq->base.mqp);
1390 MLX5_SET(tirc, tirc, inline_rqn, rq->base.mqp.qpn);
1451 resp->sqn = sq->base.mqp.qpn;
1456 sq->base.mqp.event = mlx5_ib_qp_event;
1476 resp->rqn = rq->base.mqp.qpn;
1498 qp->trans_qp.base.mqp.qpn = qp->sq.wqe_cnt ? sq->base.mqp.qpn :
1499 rq->base.mqp.qpn;
1762 qp->trans_qp.base.mqp.qpn = 0;
1899 err = mlx5_qpc_create_qp(dev, &base->mqp, in, inlen, out);
1905 base->mqp.event = mlx5_ib_qp_event;
2074 err = mlx5_qpc_create_qp(dev, &base->mqp, in, inlen, out);
2081 base->mqp.event = mlx5_ib_qp_event;
2206 err = mlx5_qpc_create_qp(dev, &base->mqp, in, inlen, out);
2212 base->mqp.event = mlx5_ib_qp_event;
2353 NULL, &base->mqp, NULL);
2363 base->mqp.qpn);
2380 __mlx5_ib_cq_clean(recv_cq, base->mqp.qpn,
2383 __mlx5_ib_cq_clean(send_cq, base->mqp.qpn,
2393 err = mlx5_core_destroy_qp(dev, &base->mqp);
2396 base->mqp.qpn);
2795 qp->ibqp.qp_num = qp->trans_qp.base.mqp.qpn;
2799 qp->type, qp->ibqp.qp_num, qp->trans_qp.base.mqp.qpn,
2850 static int mlx5_ib_destroy_dct(struct mlx5_ib_qp *mqp)
2852 struct mlx5_ib_dev *dev = to_mdev(mqp->ibqp.device);
2854 if (mqp->state == IB_QPS_RTR) {
2857 err = mlx5_core_destroy_dct(dev, &mqp->dct.mdct);
2864 kfree(mqp->dct.in);
2865 kfree(mqp);
3020 struct mlx5_ib_qp *mqp = to_mqp(qp);
3023 return mlx5_ib_destroy_gsi(mqp);
3025 if (mqp->type == MLX5_IB_QPT_DCT)
3026 return mlx5_ib_destroy_dct(mqp);
3028 destroy_qp_common(dev, mqp, udata);
3030 kfree(mqp);
3480 err = mlx5_core_modify_rq(dev->mdev, rq->base.mqp.qpn, in);
3543 err = mlx5_core_modify_sq(dev, sq->base.mqp.qpn, in);
3689 struct mlx5_ib_qp *mqp = to_mqp(qp);
3694 qp_supports_affinity(mqp)))
3697 if (mqp->flags & MLX5_IB_QP_CREATE_SQPN_QP1)
3698 tx_affinity = mqp->gsi_lag_port;
3707 qp_base = &mqp->trans_qp.base;
3710 tx_affinity, qp_base->mqp.qpn, ucontext);
3713 tx_affinity, qp_base->mqp.qpn);
3738 return mlx5_core_modify_rq(mdev, rq->base.mqp.qpn, in);
3746 struct mlx5_ib_qp *mqp = to_mqp(qp);
3754 set_id = mlx5_ib_get_counters_id(dev, mqp->port - 1);
3756 if (mqp->type == IB_QPT_RAW_PACKET)
3757 return __mlx5_ib_qp_set_raw_qp_counter(mqp, set_id, dev->mdev);
3759 base = &mqp->trans_qp.base;
3761 MLX5_SET(rts2rts_qp_in, in, qpn, base->mqp.qpn);
3762 MLX5_SET(rts2rts_qp_in, in, uid, base->mqp.uid);
4054 err = mlx5_core_qp_modify(dev, op, optpar, qpc, &base->mqp,
4078 mlx5_ib_cq_clean(recv_cq, base->mqp.qpn,
4081 mlx5_ib_cq_clean(send_cq, base->mqp.qpn, NULL);
4254 resp.dctn = qp->dct.mdct.mqp.qpn;
4500 err = mlx5_core_query_sq_state(dev->mdev, sq->base.mqp.qpn, sq_state);
4523 err = mlx5_core_query_rq(dev->mdev, rq->base.mqp.qpn, out);
4570 qp->raw_packet_qp.sq.base.mqp.qpn, sq_state,
4571 qp->raw_packet_qp.rq.base.mqp.qpn, rq_state);
4620 err = mlx5_core_qp_query(dev, &qp->trans_qp.base.mqp, outb, outlen);
4670 static int mlx5_ib_dct_query_qp(struct mlx5_ib_dev *dev, struct mlx5_ib_qp *mqp,
4674 struct mlx5_core_dct *dct = &mqp->dct.mdct;
4690 if (mqp->state != IB_QPS_RTR)
5477 struct mlx5_ib_qp *mqp = to_mqp(qp);
5480 mutex_lock(&mqp->mutex);
5481 if (mqp->state == IB_QPS_RESET) {
5491 if (mqp->state == IB_QPS_RTS) {
5499 mqp->counter_pending = 1;
5503 mutex_unlock(&mqp->mutex);