| /NextBSD/sys/ofed/drivers/net/mlx4/ |
| HD | qp.c | 52 void mlx4_qp_event(struct mlx4_dev *dev, u32 qpn, int event_type) in mlx4_qp_event() argument
59 qp = __mlx4_qp_lookup(dev, qpn); in mlx4_qp_event()
66 mlx4_dbg(dev, "Async event for none existent QP %08x\n", qpn); in mlx4_qp_event()
82 *proxy_qp0 = qp->qpn >= pf_proxy_offset && qp->qpn <= pf_proxy_offset + 1; in is_master_qp0()
84 *real_qp0 = qp->qpn >= dev->phys_caps.base_sqpn && in is_master_qp0()
85 qp->qpn <= dev->phys_caps.base_sqpn + 1; in is_master_qp0()
148 ret = mlx4_cmd(dev, 0, qp->qpn, 2, in __mlx4_qp_modify()
153 port = (qp->qpn & 1) + 1; in __mlx4_qp_modify()
177 cpu_to_be32(qp->qpn); in __mlx4_qp_modify()
180 qp->qpn | (!!sqd_event << 31), in __mlx4_qp_modify()
[all …]
|
| HD | mcg.c | 125 u32 qpn) in get_promisc_qp() argument
136 if (pqp->qpn == qpn) in get_promisc_qp()
149 unsigned int index, u32 qpn) in new_steering_entry() argument
176 pqp = get_promisc_qp(dev, port, steer, qpn); in new_steering_entry()
183 dqp->qpn = qpn; in new_steering_entry()
209 if (pqp->qpn == qpn) in new_steering_entry()
218 mgm->qp[members_count++] = cpu_to_be32(pqp->qpn & MGM_QPN_MASK); in new_steering_entry()
241 unsigned int index, u32 qpn) in existing_steering_entry() argument
253 pqp = get_promisc_qp(dev, port, steer, qpn); in existing_steering_entry()
272 if (qpn == dqp->qpn) in existing_steering_entry()
[all …]
|
| HD | resource_tracker.c | 221 int qpn; member
663 u8 slave, u32 qpn) in update_vport_qp_param() argument
688 !mlx4_is_qp_reserved(dev, qpn) && in update_vport_qp_param()
701 if (mlx4_is_qp_reserved(dev, qpn)) in update_vport_qp_param()
940 static struct res_common *alloc_fs_rule_tr(u64 id, int qpn) in alloc_fs_rule_tr() argument
950 ret->qpn = qpn; in alloc_fs_rule_tr()
1225 static int qp_res_start_move_to(struct mlx4_dev *dev, int slave, int qpn, in qp_res_start_move_to() argument
1235 r = res_tracker_lookup(&tracker->res_tree[RES_QP], qpn); in qp_res_start_move_to()
1523 static int valid_reserved(struct mlx4_dev *dev, int slave, int qpn) in valid_reserved() argument
1525 return mlx4_is_qp_reserved(dev, qpn) && in valid_reserved()
[all …]
|
| HD | en_rx.c | 737 static int mlx4_en_config_rss_qp(struct mlx4_en_priv *priv, int qpn, in mlx4_en_config_rss_qp() argument
752 err = mlx4_qp_alloc(mdev->dev, qpn, qp); in mlx4_en_config_rss_qp()
754 en_err(priv, "Failed to allocate qp #%x\n", qpn); in mlx4_en_config_rss_qp()
761 qpn, ring->cqn, -1, context); in mlx4_en_config_rss_qp()
785 u32 qpn; in mlx4_en_create_drop_qp() local
787 err = mlx4_qp_reserve_range(priv->mdev->dev, 1, 1, &qpn, 0); in mlx4_en_create_drop_qp()
792 err = mlx4_qp_alloc(priv->mdev->dev, qpn, &priv->drop_qp); in mlx4_en_create_drop_qp()
795 mlx4_qp_release_range(priv->mdev->dev, qpn, 1); in mlx4_en_create_drop_qp()
804 u32 qpn; in mlx4_en_destroy_drop_qp() local
806 qpn = priv->drop_qp.qpn; in mlx4_en_destroy_drop_qp()
[all …]
|
| /NextBSD/sys/dev/ifmlx4/ |
| HD | qp.c | 52 void mlx4_qp_event(struct mlx4_dev *dev, u32 qpn, int event_type) in mlx4_qp_event() argument
59 qp = __mlx4_qp_lookup(dev, qpn); in mlx4_qp_event()
66 mlx4_dbg(dev, "Async event for none existent QP %08x\n", qpn); in mlx4_qp_event()
82 *proxy_qp0 = qp->qpn >= pf_proxy_offset && qp->qpn <= pf_proxy_offset + 1; in is_master_qp0()
84 *real_qp0 = qp->qpn >= dev->phys_caps.base_sqpn && in is_master_qp0()
85 qp->qpn <= dev->phys_caps.base_sqpn + 1; in is_master_qp0()
148 ret = mlx4_cmd(dev, 0, qp->qpn, 2, in __mlx4_qp_modify()
153 port = (qp->qpn & 1) + 1; in __mlx4_qp_modify()
177 cpu_to_be32(qp->qpn); in __mlx4_qp_modify()
180 qp->qpn | (!!sqd_event << 31), in __mlx4_qp_modify()
[all …]
|
| HD | mcg.c | 125 u32 qpn) in get_promisc_qp() argument
136 if (pqp->qpn == qpn) in get_promisc_qp()
149 unsigned int index, u32 qpn) in new_steering_entry() argument
176 pqp = get_promisc_qp(dev, port, steer, qpn); in new_steering_entry()
183 dqp->qpn = qpn; in new_steering_entry()
209 if (pqp->qpn == qpn) in new_steering_entry()
218 mgm->qp[members_count++] = cpu_to_be32(pqp->qpn & MGM_QPN_MASK); in new_steering_entry()
241 unsigned int index, u32 qpn) in existing_steering_entry() argument
253 pqp = get_promisc_qp(dev, port, steer, qpn); in existing_steering_entry()
272 if (qpn == dqp->qpn) in existing_steering_entry()
[all …]
|
| HD | resource_tracker.c | 221 int qpn; member
663 u8 slave, u32 qpn) in update_vport_qp_param() argument
688 !mlx4_is_qp_reserved(dev, qpn) && in update_vport_qp_param()
701 if (mlx4_is_qp_reserved(dev, qpn)) in update_vport_qp_param()
940 static struct res_common *alloc_fs_rule_tr(u64 id, int qpn) in alloc_fs_rule_tr() argument
950 ret->qpn = qpn; in alloc_fs_rule_tr()
1225 static int qp_res_start_move_to(struct mlx4_dev *dev, int slave, int qpn, in qp_res_start_move_to() argument
1235 r = res_tracker_lookup(&tracker->res_tree[RES_QP], qpn); in qp_res_start_move_to()
1523 static int valid_reserved(struct mlx4_dev *dev, int slave, int qpn) in valid_reserved() argument
1525 return mlx4_is_qp_reserved(dev, qpn) && in valid_reserved()
[all …]
|
| HD | en_rx.c | 715 static int mlx4_en_config_rss_qp(struct mlx4_en_priv *priv, int qpn, in mlx4_en_config_rss_qp() argument
730 err = mlx4_qp_alloc(mdev->dev, qpn, qp); in mlx4_en_config_rss_qp()
732 en_err(priv, "Failed to allocate qp #%x\n", qpn); in mlx4_en_config_rss_qp()
739 qpn, ring->cqn, -1, context); in mlx4_en_config_rss_qp()
763 u32 qpn; in mlx4_en_create_drop_qp() local
765 err = mlx4_qp_reserve_range(priv->mdev->dev, 1, 1, &qpn, 0); in mlx4_en_create_drop_qp()
770 err = mlx4_qp_alloc(priv->mdev->dev, qpn, &priv->drop_qp); in mlx4_en_create_drop_qp()
773 mlx4_qp_release_range(priv->mdev->dev, qpn, 1); in mlx4_en_create_drop_qp()
782 u32 qpn; in mlx4_en_destroy_drop_qp() local
784 qpn = priv->drop_qp.qpn; in mlx4_en_destroy_drop_qp()
[all …]
|
| /NextBSD/sys/dev/mlx5/mlx5_core/ |
| HD | mlx5_qp.c | 116 qp->qpn = be32_to_cpu(out.qpn) & 0xffffff; in mlx5_core_create_qp()
117 mlx5_core_dbg(dev, "qpn = 0x%x\n", qp->qpn); in mlx5_core_create_qp()
121 err = radix_tree_insert(&table->tree, qp->qpn, qp); in mlx5_core_create_qp()
139 din.qpn = cpu_to_be32(qp->qpn); in mlx5_core_create_qp()
157 radix_tree_delete(&table->tree, qp->qpn); in mlx5_core_destroy_qp()
166 in.qpn = cpu_to_be32(qp->qpn); in mlx5_core_destroy_qp()
232 in->qpn = cpu_to_be32(qp->qpn); in mlx5_core_qp_modify()
262 in.qpn = cpu_to_be32(qp->qpn); in mlx5_core_qp_query()
|
| HD | mlx5_mcg.c | 34 int mlx5_core_attach_mcg(struct mlx5_core_dev *dev, union ib_gid *mgid, u32 qpn) in mlx5_core_attach_mcg() argument
42 MLX5_SET(attach_to_mcg_in, in, qpn, qpn); in mlx5_core_attach_mcg()
52 int mlx5_core_detach_mcg(struct mlx5_core_dev *dev, union ib_gid *mgid, u32 qpn) in mlx5_core_detach_mcg() argument
60 MLX5_SET(detach_from_mcg_in, in, qpn, qpn); in mlx5_core_detach_mcg()
|
| /NextBSD/contrib/ofed/libibverbs/fixes/ |
| HD | rocee_examples.patch | 123 int qpn;
166 - sprintf(msg, "%04x:%06x:%06x", my_dest->lid, my_dest->qpn, my_dest->psn);
168 + sprintf(msg, "%04x:%06x:%06x:%s", my_dest->lid, my_dest->qpn, my_dest->psn, gid);
176 - sscanf(msg, "%x:%x:%x", &rem_dest->lid, &rem_dest->qpn, &rem_dest->psn);
177 + sscanf(msg, "%x:%x:%x:%s", &rem_dest->lid, &rem_dest->qpn, &rem_dest->psn, gid);
209 - sscanf(msg, "%x:%x:%x", &rem_dest->lid, &rem_dest->qpn, &rem_dest->psn);
210 + sscanf(msg, "%x:%x:%x:%s", &rem_dest->lid, &rem_dest->qpn, &rem_dest->psn, gid);
221 - sprintf(msg, "%04x:%06x:%06x", my_dest->lid, my_dest->qpn, my_dest->psn);
224 + sprintf(msg, "%04x:%06x:%06x:%s", my_dest->lid, my_dest->qpn, my_dest->psn, gid);
306 - my_dest.qpn = ctx->qp->qp_num;
[all …]
|
| /NextBSD/contrib/ofed/management/opensm/libvendor/ |
| HD | osm_vendor_mlx_ts.c | 187 int qpn; in osmv_transport_init() local
219 qpn = 0; in osmv_transport_init()
220 p_mgr->filter.qpn = qpn; in osmv_transport_init()
239 qpn = 1; in osmv_transport_init()
240 p_mgr->filter.qpn = qpn; in osmv_transport_init()
376 ts_mad.sqpn = p_mgr->filter.qpn; in __osm_transport_gen_dummy_mad()
377 ts_mad.dqpn = p_mgr->filter.qpn; in __osm_transport_gen_dummy_mad()
|
| HD | osm_vendor_mlx_sim.c | 155 int qpn; in osmv_transport_init() local
194 qpn = 0; in osmv_transport_init()
195 p_mgr->filter.qpn = qpn; in osmv_transport_init()
212 qpn = 1; in osmv_transport_init()
213 p_mgr->filter.qpn = qpn; in osmv_transport_init()
|
| /NextBSD/sys/ofed/drivers/infiniband/hw/mthca/ |
| HD | mthca_qp.c | 197 return qp->qpn >= dev->qp_table.sqp_start && in is_sqp()
198 qp->qpn <= dev->qp_table.sqp_start + 3; in is_sqp()
203 return qp->qpn >= dev->qp_table.sqp_start && in is_qp0()
204 qp->qpn <= dev->qp_table.sqp_start + 1; in is_qp0()
237 void mthca_qp_event(struct mthca_dev *dev, u32 qpn, in mthca_qp_event() argument
244 qp = mthca_array_get(&dev->qp_table.qp, qpn & (dev->limits.num_qps - 1)); in mthca_qp_event()
251 (int) event_type, qpn); in mthca_qp_event()
452 err = mthca_QUERY_QP(dev, qp->qpn, 0, mailbox, &status); in mthca_query_qp()
621 qp_context->local_qpn = cpu_to_be32(qp->qpn); in __mthca_modify_qp()
762 ((qp->qpn & (dev->limits.num_qps - 1)) * MTHCA_RDB_ENTRY_SIZE << in __mthca_modify_qp()
[all …]
|
| /NextBSD/contrib/ofed/libmlx4/src/ |
| HD | cq.c | 199 uint32_t qpn; in mlx4_poll_one() local
220 qpn = ntohl(cqe->my_qpn); in mlx4_poll_one()
226 if (qpn & MLX4_XRC_QPN_BIT && !is_send) { in mlx4_poll_one()
236 } else if (!*cur_qp || (qpn & 0xffffff) != (*cur_qp)->ibv_qp.qp_num) { in mlx4_poll_one()
243 qpn & 0xffffff); in mlx4_poll_one()
248 wc->qp_num = qpn & 0xffffff; in mlx4_poll_one()
399 void __mlx4_cq_clean(struct mlx4_cq *cq, uint32_t qpn, struct mlx4_srq *srq) in __mlx4_cq_clean() argument
434 } else if ((ntohl(cqe->my_qpn) & 0xffffff) == qpn) { in __mlx4_cq_clean()
459 void mlx4_cq_clean(struct mlx4_cq *cq, uint32_t qpn, struct mlx4_srq *srq) in mlx4_cq_clean() argument
462 __mlx4_cq_clean(cq, qpn, srq); in mlx4_cq_clean()
|
| /NextBSD/contrib/ofed/libibverbs/examples/ |
| HD | ud_pingpong.c | 75 int qpn; member
170 sprintf(msg, "%04x:%06x:%06x:%s", my_dest->lid, my_dest->qpn, my_dest->psn, gid); in pp_client_exch_dest()
188 sscanf(msg, "%x:%x:%x:%s", &rem_dest->lid, &rem_dest->qpn, &rem_dest->psn, gid); in pp_client_exch_dest()
266 sscanf(msg, "%x:%x:%x:%s", &rem_dest->lid, &rem_dest->qpn, &rem_dest->psn, gid); in pp_server_exch_dest()
277 sprintf(msg, "%04x:%06x:%06x:%s", my_dest->lid, my_dest->qpn, my_dest->psn, gid); in pp_server_exch_dest()
456 static int pp_post_send(struct pingpong_context *ctx, uint32_t qpn) in pp_post_send() argument
472 .remote_qpn = qpn, in pp_post_send()
650 my_dest.qpn = ctx->qp->qp_num; in main()
663 my_dest.lid, my_dest.qpn, my_dest.psn, gid); in main()
675 rem_dest->lid, rem_dest->qpn, rem_dest->psn, gid); in main()
[all …]
|
| HD | srq_pingpong.c | 78 int qpn; member
93 .dest_qp_num = dest[i].qpn, in pp_connect_ctx()
193 sprintf(msg, "%04x:%06x:%06x:%s", my_dest[i].lid, my_dest[i].qpn, my_dest[i].psn, gid); in pp_client_exch_dest()
218 &rem_dest[i].lid, &rem_dest[i].qpn, &rem_dest[i].psn, gid); in pp_client_exch_dest()
309 &rem_dest[i].lid, &rem_dest[i].qpn, &rem_dest[i].psn, gid); in pp_server_exch_dest()
322 sprintf(msg, "%04x:%06x:%06x:%s", my_dest[i].lid, my_dest[i].qpn, my_dest[i].psn, gid); in pp_server_exch_dest()
541 static int find_qp(int qpn, struct pingpong_context *ctx, int num_qp) in find_qp() argument
546 if (ctx->qp[i]->qp_num == qpn) in find_qp()
753 my_dest[i].qpn = ctx->qp[i]->qp_num; in main()
771 my_dest[i].lid, my_dest[i].qpn, my_dest[i].psn, gid); in main()
[all …]
|
| HD | uc_pingpong.c | 74 int qpn; member
86 .dest_qp_num = dest->qpn, in pp_connect_ctx()
171 sprintf(msg, "%04x:%06x:%06x:%s", my_dest->lid, my_dest->qpn, my_dest->psn, gid); in pp_client_exch_dest()
189 sscanf(msg, "%x:%x:%x:%s", &rem_dest->lid, &rem_dest->qpn, &rem_dest->psn, gid); in pp_client_exch_dest()
268 sscanf(msg, "%x:%x:%x:%s", &rem_dest->lid, &rem_dest->qpn, &rem_dest->psn, gid); in pp_server_exch_dest()
279 sprintf(msg, "%04x:%06x:%06x:%s", my_dest->lid, my_dest->qpn, my_dest->psn, gid); in pp_server_exch_dest()
665 my_dest.qpn = ctx->qp->qp_num; in main()
669 my_dest.lid, my_dest.qpn, my_dest.psn, gid); in main()
681 rem_dest->lid, rem_dest->qpn, rem_dest->psn, gid); in main()
|
| HD | rc_pingpong.c | 75 int qpn; member
87 .dest_qp_num = dest->qpn, in pp_connect_ctx()
183 sprintf(msg, "%04x:%06x:%06x:%s", my_dest->lid, my_dest->qpn, my_dest->psn, gid); in pp_client_exch_dest()
201 sscanf(msg, "%x:%x:%x:%s", &rem_dest->lid, &rem_dest->qpn, &rem_dest->psn, gid); in pp_client_exch_dest()
280 sscanf(msg, "%x:%x:%x:%s", &rem_dest->lid, &rem_dest->qpn, &rem_dest->psn, gid); in pp_server_exch_dest()
292 sprintf(msg, "%04x:%06x:%06x:%s", my_dest->lid, my_dest->qpn, my_dest->psn, gid); in pp_server_exch_dest()
681 my_dest.qpn = ctx->qp->qp_num; in main()
685 my_dest.lid, my_dest.qpn, my_dest.psn, gid); in main()
698 rem_dest->lid, rem_dest->qpn, rem_dest->psn, gid); in main()
|
| /NextBSD/sys/dev/mlx5/ |
| HD | qp.h | 385 int qpn; member
467 __be32 qpn; member
473 __be32 qpn; member
484 __be32 qpn; member
498 __be32 qpn; member
514 __be32 qpn; member
524 static inline struct mlx5_core_qp *__mlx5_qp_lookup(struct mlx5_core_dev *dev, u32 qpn) in __mlx5_qp_lookup() argument
526 return radix_tree_lookup(&dev->priv.qp_table.tree, qpn); in __mlx5_qp_lookup()
|
| /NextBSD/sys/ofed/include/rdma/ |
| HD | ib_user_mad.h | 78 __be32 qpn; member
122 __be32 qpn; member
187 __u8 qpn; member
|
| HD | iw_cm.h | 103 u32 qpn; member
112 int qpn);
169 struct ib_qp *iw_cm_get_qp(struct ib_device *device, int qpn);
|
| /NextBSD/sys/ofed/include/linux/mlx4/ |
| HD | device.h | 660 int qpn; member
827 __be32 qpn; member
957 static inline int mlx4_is_qp_reserved(struct mlx4_dev *dev, u32 qpn) in mlx4_is_qp_reserved() argument
959 return (qpn < dev->phys_caps.base_sqpn + 8 + in mlx4_is_qp_reserved()
963 static inline int mlx4_is_guest_proxy(struct mlx4_dev *dev, int slave, u32 qpn) in mlx4_is_guest_proxy() argument
967 if (qpn >= guest_proxy_base && qpn < guest_proxy_base + 8) in mlx4_is_guest_proxy()
1040 int mlx4_qp_alloc(struct mlx4_dev *dev, int qpn, struct mlx4_qp *qp);
1159 u32 qpn; member
1170 __be32 qpn; member
1243 int mlx4_flow_steer_promisc_add(struct mlx4_dev *dev, u8 port, u32 qpn,
[all …]
|
| /NextBSD/sys/ofed/drivers/infiniband/core/ |
| HD | cm_msgs.h | 115 static inline void cm_req_set_local_qpn(struct cm_req_msg *req_msg, __be32 qpn) in cm_req_set_local_qpn() argument
117 req_msg->offset32 = cpu_to_be32((be32_to_cpu(qpn) << 8) | in cm_req_set_local_qpn()
523 static inline void cm_rep_set_local_qpn(struct cm_rep_msg *rep_msg, __be32 qpn) in cm_rep_set_local_qpn() argument
525 rep_msg->offset12 = cpu_to_be32((be32_to_cpu(qpn) << 8) | in cm_rep_set_local_qpn()
643 static inline void cm_dreq_set_remote_qpn(struct cm_dreq_msg *dreq_msg, __be32 qpn) in cm_dreq_set_remote_qpn() argument
645 dreq_msg->offset8 = cpu_to_be32((be32_to_cpu(qpn) << 8) | in cm_dreq_set_remote_qpn()
692 static inline void cm_lap_set_remote_qpn(struct cm_lap_msg *lap_msg, __be32 qpn) in cm_lap_set_remote_qpn() argument
694 lap_msg->offset12 = cpu_to_be32((be32_to_cpu(qpn) << 8) | in cm_lap_set_remote_qpn()
829 __be32 qpn) in cm_sidr_rep_set_qpn() argument
831 sidr_rep_msg->offset8 = cpu_to_be32((be32_to_cpu(qpn) << 8) | in cm_sidr_rep_set_qpn()
|
| /NextBSD/sys/ofed/drivers/infiniband/hw/mlx4/ |
| HD | qp.c | 138 return qp->mqp.qpn >= dev->dev->phys_caps.base_tunnel_sqpn && in is_tunnel_qp()
139 qp->mqp.qpn < dev->dev->phys_caps.base_tunnel_sqpn + in is_tunnel_qp()
150 qp->mqp.qpn >= dev->dev->phys_caps.base_sqpn && in is_sqp()
151 qp->mqp.qpn <= dev->dev->phys_caps.base_sqpn + 3); in is_sqp()
157 if (qp->mqp.qpn == dev->dev->caps.qp0_proxy[i] || in is_sqp()
158 qp->mqp.qpn == dev->dev->caps.qp1_proxy[i]) { in is_sqp()
175 qp->mqp.qpn >= dev->dev->phys_caps.base_sqpn && in is_qp0()
176 qp->mqp.qpn <= dev->dev->phys_caps.base_sqpn + 1); in is_qp0()
182 if (qp->mqp.qpn == dev->dev->caps.qp0_proxy[i]) { in is_qp0()
331 "on QP %06x\n", type, qp->qpn); in mlx4_ib_qp_event()
[all …]
|