Lines Matching refs:mqp
334 err = mlx5_core_qp_query(dev, &qp->trans_qp.base.mqp, outb, outlen,
1408 err = mlx5_core_create_sq_tracked(dev, in, inlen, &sq->base.mqp);
1428 mlx5_core_destroy_sq_tracked(dev, &sq->base.mqp);
1436 struct mlx5_ib_qp *mqp = rq->base.container_mibqp;
1477 if (mqp->flags & IB_QP_CREATE_SCATTER_FCS)
1495 err = mlx5_core_create_rq_tracked(dev, in, inlen, &rq->base.mqp);
1505 mlx5_core_destroy_rq_tracked(dev, &rq->base.mqp);
1538 MLX5_SET(tirc, tirc, inline_rqn, rq->base.mqp.qpn);
1600 resp->sqn = sq->base.mqp.qpn;
1605 sq->base.mqp.event = mlx5_ib_qp_event;
1626 resp->rqn = rq->base.mqp.qpn;
1648 qp->trans_qp.base.mqp.qpn = qp->sq.wqe_cnt ? sq->base.mqp.qpn :
1649 rq->base.mqp.qpn;
1912 qp->trans_qp.base.mqp.qpn = 0;
2050 err = mlx5_qpc_create_qp(dev, &base->mqp, in, inlen, out);
2056 base->mqp.event = mlx5_ib_qp_event;
2194 err = mlx5_qpc_create_qp(dev, &base->mqp, in, inlen, out);
2201 base->mqp.event = mlx5_ib_qp_event;
2397 err = mlx5_qpc_create_qp(dev, &base->mqp, in, inlen, out);
2404 base->mqp.event = mlx5_ib_qp_event;
2533 err = mlx5_qpc_create_qp(dev, &base->mqp, in, inlen, out);
2539 base->mqp.event = mlx5_ib_qp_event;
2680 NULL, &base->mqp, NULL);
2690 base->mqp.qpn);
2707 __mlx5_ib_cq_clean(recv_cq, base->mqp.qpn,
2710 __mlx5_ib_cq_clean(send_cq, base->mqp.qpn,
2720 err = mlx5_core_destroy_qp(dev, &base->mqp);
2723 base->mqp.qpn);
3133 qp->ibqp.qp_num = qp->trans_qp.base.mqp.qpn;
3137 qp->type, qp->ibqp.qp_num, qp->trans_qp.base.mqp.qpn,
3188 static int mlx5_ib_destroy_dct(struct mlx5_ib_qp *mqp)
3190 struct mlx5_ib_dev *dev = to_mdev(mqp->ibqp.device);
3192 if (mqp->state == IB_QPS_RTR) {
3195 err = mlx5_core_destroy_dct(dev, &mqp->dct.mdct);
3202 kfree(mqp->dct.in);
3339 struct mlx5_ib_qp *mqp = to_mqp(qp);
3341 if (mqp->type == IB_QPT_GSI)
3342 return mlx5_ib_destroy_gsi(mqp);
3344 if (mqp->type == MLX5_IB_QPT_DCT)
3345 return mlx5_ib_destroy_dct(mqp);
3347 destroy_qp_common(dev, mqp, udata);
3811 err = mlx5_core_modify_rq(dev->mdev, rq->base.mqp.qpn, in);
3874 err = mlx5_core_modify_sq(dev, sq->base.mqp.qpn, in);
4020 struct mlx5_ib_qp *mqp = to_mqp(qp);
4025 qp_supports_affinity(mqp)))
4028 if (mqp->flags & MLX5_IB_QP_CREATE_SQPN_QP1)
4029 tx_affinity = mqp->gsi_lag_port;
4038 qp_base = &mqp->trans_qp.base;
4041 tx_affinity, qp_base->mqp.qpn, ucontext);
4044 tx_affinity, qp_base->mqp.qpn);
4069 return mlx5_core_modify_rq(mdev, rq->base.mqp.qpn, in);
4077 struct mlx5_ib_qp *mqp = to_mqp(qp);
4085 set_id = mlx5_ib_get_counters_id(dev, mqp->port - 1);
4087 if (mqp->type == IB_QPT_RAW_PACKET)
4088 return __mlx5_ib_qp_set_raw_qp_counter(mqp, set_id, dev->mdev);
4090 base = &mqp->trans_qp.base;
4092 MLX5_SET(rts2rts_qp_in, in, qpn, base->mqp.qpn);
4093 MLX5_SET(rts2rts_qp_in, in, uid, base->mqp.uid);
4386 err = mlx5_core_qp_modify(dev, op, optpar, qpc, &base->mqp,
4410 mlx5_ib_cq_clean(recv_cq, base->mqp.qpn,
4413 mlx5_ib_cq_clean(send_cq, base->mqp.qpn, NULL);
4587 resp.dctn = qp->dct.mdct.mqp.qpn;
4825 err = mlx5_core_query_sq_state(dev->mdev, sq->base.mqp.qpn, sq_state);
4848 err = mlx5_core_query_rq(dev->mdev, rq->base.mqp.qpn, out);
4895 qp->raw_packet_qp.sq.base.mqp.qpn, sq_state,
4896 qp->raw_packet_qp.rq.base.mqp.qpn, rq_state);
4945 err = mlx5_core_qp_query(dev, &qp->trans_qp.base.mqp, outb, outlen,
4997 static int mlx5_ib_dct_query_qp(struct mlx5_ib_dev *dev, struct mlx5_ib_qp *mqp,
5001 struct mlx5_core_dct *dct = &mqp->dct.mdct;
5017 if (mqp->state != IB_QPS_RTR)
5809 struct mlx5_ib_qp *mqp = to_mqp(qp);
5812 mutex_lock(&mqp->mutex);
5813 if (mqp->state == IB_QPS_RESET) {
5823 if (mqp->state == IB_QPS_RTS) {
5831 mqp->counter_pending = 1;
5835 mutex_unlock(&mqp->mutex);