Lines Matching refs:mqp
1270 struct mlx4_ib_qp *mqp = to_mqp(ibqp); in add_gid_entry() local
1279 if (mlx4_ib_add_mc(mdev, mqp, gid)) { in add_gid_entry()
1280 ge->port = mqp->port; in add_gid_entry()
1284 mutex_lock(&mqp->mutex); in add_gid_entry()
1285 list_add_tail(&ge->list, &mqp->gid_list); in add_gid_entry()
1286 mutex_unlock(&mqp->mutex); in add_gid_entry()
1307 int mlx4_ib_add_mc(struct mlx4_ib_dev *mdev, struct mlx4_ib_qp *mqp, in mlx4_ib_add_mc() argument
1313 if (!mqp->port) in mlx4_ib_add_mc()
1317 ndev = mdev->iboe.netdevs[mqp->port - 1]; in mlx4_ib_add_mc()
1845 struct mlx4_ib_qp *mqp = to_mqp(ibqp); in mlx4_ib_mcg_attach() local
1857 err = mlx4_multicast_attach(mdev->dev, &mqp->mqp, gid->raw, mqp->port, in mlx4_ib_mcg_attach()
1858 !!(mqp->flags & in mlx4_ib_mcg_attach()
1868 err = mlx4_multicast_attach(mdev->dev, &mqp->mqp, gid->raw, in mlx4_ib_mcg_attach()
1869 (mqp->port == 1) ? 2 : 1, in mlx4_ib_mcg_attach()
1870 !!(mqp->flags & in mlx4_ib_mcg_attach()
1884 mutex_lock(&mqp->mutex); in mlx4_ib_mcg_attach()
1885 list_add(&ib_steering->list, &mqp->steering_rules); in mlx4_ib_mcg_attach()
1886 mutex_unlock(&mqp->mutex); in mlx4_ib_mcg_attach()
1891 mlx4_multicast_detach(mdev->dev, &mqp->mqp, gid->raw, in mlx4_ib_mcg_attach()
1894 mlx4_multicast_detach(mdev->dev, &mqp->mqp, gid->raw, in mlx4_ib_mcg_attach()
1923 struct mlx4_ib_qp *mqp = to_mqp(ibqp); in mlx4_ib_mcg_detach() local
1933 mutex_lock(&mqp->mutex); in mlx4_ib_mcg_detach()
1934 list_for_each_entry(ib_steering, &mqp->steering_rules, list) { in mlx4_ib_mcg_detach()
1940 mutex_unlock(&mqp->mutex); in mlx4_ib_mcg_detach()
1941 if (&ib_steering->list == &mqp->steering_rules) { in mlx4_ib_mcg_detach()
1949 err = mlx4_multicast_detach(mdev->dev, &mqp->mqp, gid->raw, in mlx4_ib_mcg_detach()
1955 err = mlx4_multicast_detach(mdev->dev, &mqp->mqp, gid->raw, in mlx4_ib_mcg_detach()
1961 mutex_lock(&mqp->mutex); in mlx4_ib_mcg_detach()
1962 ge = find_gid_entry(mqp, gid->raw); in mlx4_ib_mcg_detach()
1976 mutex_unlock(&mqp->mutex); in mlx4_ib_mcg_detach()
2313 if (mlx4_update_qp(ibdev->dev, qp->mqp.qpn, MLX4_UPDATE_QP_SMAC, in mlx4_ib_update_qps()
2935 int mlx4_ib_steer_qp_reg(struct mlx4_ib_dev *mdev, struct mlx4_ib_qp *mqp, in mlx4_ib_steer_qp_reg() argument
2949 flow->port = mqp->port; in mlx4_ib_steer_qp_reg()
2958 err = __mlx4_ib_create_flow(&mqp->ibqp, flow, MLX4_DOMAIN_NIC, in mlx4_ib_steer_qp_reg()
2959 MLX4_FS_REGULAR, &mqp->reg_id); in mlx4_ib_steer_qp_reg()
2961 err = __mlx4_ib_destroy_flow(mdev->dev, mqp->reg_id); in mlx4_ib_steer_qp_reg()
3059 struct mlx4_ib_qp *mqp; in mlx4_ib_handle_catas_error() local
3073 list_for_each_entry(mqp, &ibdev->qp_list, qps_list) { in mlx4_ib_handle_catas_error()
3074 spin_lock_irqsave(&mqp->sq.lock, flags_qp); in mlx4_ib_handle_catas_error()
3075 if (mqp->sq.tail != mqp->sq.head) { in mlx4_ib_handle_catas_error()
3076 send_mcq = to_mcq(mqp->ibqp.send_cq); in mlx4_ib_handle_catas_error()
3079 mqp->ibqp.send_cq->comp_handler) { in mlx4_ib_handle_catas_error()
3088 spin_unlock_irqrestore(&mqp->sq.lock, flags_qp); in mlx4_ib_handle_catas_error()
3090 spin_lock_irqsave(&mqp->rq.lock, flags_qp); in mlx4_ib_handle_catas_error()
3092 if (!mqp->ibqp.srq) { in mlx4_ib_handle_catas_error()
3093 if (mqp->rq.tail != mqp->rq.head) { in mlx4_ib_handle_catas_error()
3094 recv_mcq = to_mcq(mqp->ibqp.recv_cq); in mlx4_ib_handle_catas_error()
3097 mqp->ibqp.recv_cq->comp_handler) { in mlx4_ib_handle_catas_error()
3108 spin_unlock_irqrestore(&mqp->rq.lock, flags_qp); in mlx4_ib_handle_catas_error()