| /freebsd/sys/dev/mlx4/mlx4_core/ |
| H A D | mlx4_qp.c | 50 void mlx4_qp_event(struct mlx4_dev *dev, u32 qpn, int event_type) in mlx4_qp_event() argument
57 qp = __mlx4_qp_lookup(dev, qpn); in mlx4_qp_event()
64 mlx4_dbg(dev, "Async event for none existent QP %08x\n", qpn); in mlx4_qp_event()
80 *proxy_qp0 = qp->qpn >= pf_proxy_offset && qp->qpn <= pf_proxy_offset + 1; in is_master_qp0()
82 *real_qp0 = qp->qpn >= dev->phys_caps.base_sqpn && in is_master_qp0()
83 qp->qpn <= dev->phys_caps.base_sqpn + 1; in is_master_qp0()
146 ret = mlx4_cmd(dev, 0, qp->qpn, 2, in __mlx4_qp_modify()
151 port = (qp->qpn & 1) + 1; in __mlx4_qp_modify()
175 cpu_to_be16(mlx4_qp_roce_entropy(dev, qp->qpn)); in __mlx4_qp_modify()
181 cpu_to_be32(qp->qpn); in __mlx4_qp_modify()
[all …]
|
| H A D | mlx4_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 …]
|
| H A D | mlx4_resource_tracker.c | 223 int qpn; member
738 u8 slave, u32 qpn) in update_vport_qp_param() argument
759 if (mlx4_is_qp_reserved(dev, qpn)) in update_vport_qp_param()
773 err = mlx4_update_qp(dev, qpn, MLX4_UPDATE_QP_VSD, ¶ms); in update_vport_qp_param()
1119 static struct res_common *alloc_fs_rule_tr(u64 id, int qpn) in alloc_fs_rule_tr() argument
1129 ret->qpn = qpn; in alloc_fs_rule_tr()
1451 static int qp_res_start_move_to(struct mlx4_dev *dev, int slave, int qpn, in qp_res_start_move_to() argument
1461 r = res_tracker_lookup(&tracker->res_tree[RES_QP], qpn); in qp_res_start_move_to()
1722 static int valid_reserved(struct mlx4_dev *dev, int slave, int qpn) in valid_reserved() argument
1724 return mlx4_is_qp_reserved(dev, qpn) && in valid_reserved()
[all …]
|
| /freebsd/sys/dev/mlx5/mlx5_core/ |
| H A D | mlx5_qp.c | 93 err = radix_tree_insert(&table->tree, qp->qpn | (rsc_type << 24), qp); in create_qprqsq_common()
112 radix_tree_delete(&table->tree, qp->qpn | (rsc_type << 24)); in destroy_qprqsq_common()
135 qp->qpn = MLX5_GET(create_qp_out, out, qpn); in mlx5_core_create_qp()
136 mlx5_core_dbg(dev, "qpn = 0x%x\n", qp->qpn); in mlx5_core_create_qp()
148 MLX5_SET(destroy_qp_in, din, qpn, qp->qpn); in mlx5_core_create_qp()
166 MLX5_SET(destroy_qp_in, in, qpn, qp->qpn); in mlx5_core_destroy_qp()
205 static int modify_qp_mbox_alloc(struct mlx5_core_dev *dev, u16 opcode, int qpn, in modify_qp_mbox_alloc() argument
218 MLX5_SET(typ##_in, in, qpn, _qpn); \ in modify_qp_mbox_alloc()
235 MOD_QP_IN_SET(qp_2rst, mbox->in, opcode, qpn, uid); in modify_qp_mbox_alloc()
240 MOD_QP_IN_SET(qp_2err, mbox->in, opcode, qpn, uid); in modify_qp_mbox_alloc()
[all …]
|
| H A D | mlx5_mcg.c | 35 int mlx5_core_attach_mcg(struct mlx5_core_dev *dev, union ib_gid *mgid, u32 qpn) in mlx5_core_attach_mcg() argument
41 MLX5_SET(attach_to_mcg_in, in, qpn, qpn); in mlx5_core_attach_mcg()
49 int mlx5_core_detach_mcg(struct mlx5_core_dev *dev, union ib_gid *mgid, u32 qpn) in mlx5_core_detach_mcg() argument
55 MLX5_SET(detach_from_mcg_in, in, qpn, qpn); in mlx5_core_detach_mcg()
|
| /freebsd/sys/ofed/include/uapi/rdma/ |
| H A D | ib_user_mad.h | 79 __be32 qpn; member
123 __be32 qpn; member
188 __u8 qpn; member
223 __u32 qpn; member
|
| H A D | ib_user_cm.h | 139 __u32 qpn; member
164 __u32 qpn; member
217 __u32 qpn; member
301 __u32 qpn; member
|
| /freebsd/contrib/ofed/opensm/libvendor/ |
| H A D | 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()
|
| H A D | 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()
|
| /freebsd/sys/dev/mthca/ |
| H A D | mthca_qp.c | 198 return qp->qpn >= dev->qp_table.sqp_start && in is_sqp()
199 qp->qpn <= dev->qp_table.sqp_start + 3; in is_sqp()
204 return qp->qpn >= dev->qp_table.sqp_start && in is_qp0()
205 qp->qpn <= dev->qp_table.sqp_start + 1; in is_qp0()
238 void mthca_qp_event(struct mthca_dev *dev, u32 qpn, in mthca_qp_event() argument
245 qp = mthca_array_get(&dev->qp_table.qp, qpn & (dev->limits.num_qps - 1)); in mthca_qp_event()
252 event_type, qpn); in mthca_qp_event()
449 err = mthca_QUERY_QP(dev, qp->qpn, 0, mailbox); in mthca_query_qp()
618 qp_context->local_qpn = cpu_to_be32(qp->qpn); in __mthca_modify_qp()
759 ((qp->qpn & (dev->limits.num_qps - 1)) * MTHCA_RDB_ENTRY_SIZE << in __mthca_modify_qp()
[all …]
|
| /freebsd/contrib/ofed/libibverbs/examples/ |
| H A D | ud_pingpong.c | 75 int qpn; member
170 sprintf(msg, "%04x:%06x:%06x:%s", my_dest->lid, my_dest->qpn, in pp_client_exch_dest()
188 sscanf(msg, "%x:%x:%x:%s", &rem_dest->lid, &rem_dest->qpn, in pp_client_exch_dest()
271 sscanf(msg, "%x:%x:%x:%s", &rem_dest->lid, &rem_dest->qpn, in pp_server_exch_dest()
284 sprintf(msg, "%04x:%06x:%06x:%s", my_dest->lid, my_dest->qpn, in pp_server_exch_dest()
512 static int pp_post_send(struct pingpong_context *ctx, uint32_t qpn) in pp_post_send() argument
528 .remote_qpn = qpn, in pp_post_send()
708 my_dest.qpn = ctx->qp->qp_num; in main()
722 my_dest.lid, my_dest.qpn, my_dest.psn, gid); in main()
735 rem_dest->lid, rem_dest->qpn, rem_dest->psn, gid); in main()
[all …]
|
| H A D | srq_pingpong.c | 78 int qpn; member
93 .dest_qp_num = dest[i].qpn, in pp_connect_ctx()
194 my_dest[i].qpn, my_dest[i].psn, gid); in pp_client_exch_dest()
218 sscanf(msg, "%x:%x:%x:%s", &rem_dest[i].lid, &rem_dest[i].qpn, in pp_client_exch_dest()
315 sscanf(msg, "%x:%x:%x:%s", &rem_dest[i].lid, &rem_dest[i].qpn, in pp_server_exch_dest()
331 my_dest[i].qpn, my_dest[i].psn, gid); in pp_server_exch_dest()
594 static int find_qp(int qpn, struct pingpong_context *ctx, int num_qp) in find_qp() argument
599 if (ctx->qp[i]->qp_num == qpn) in find_qp()
810 my_dest[i].qpn = ctx->qp[i]->qp_num; in main()
831 "GID %s\n", my_dest[i].lid, my_dest[i].qpn, in main()
[all …]
|
| H A D | uc_pingpong.c | 74 int qpn; member
86 .dest_qp_num = dest->qpn, in pp_connect_ctx()
170 sprintf(msg, "%04x:%06x:%06x:%s", my_dest->lid, my_dest->qpn, in pp_client_exch_dest()
189 sscanf(msg, "%x:%x:%x:%s", &rem_dest->lid, &rem_dest->qpn, in pp_client_exch_dest()
273 sscanf(msg, "%x:%x:%x:%s", &rem_dest->lid, &rem_dest->qpn, in pp_server_exch_dest()
287 sprintf(msg, "%04x:%06x:%06x:%s", my_dest->lid, my_dest->qpn, in pp_server_exch_dest()
710 my_dest.qpn = ctx->qp->qp_num; in main()
714 my_dest.lid, my_dest.qpn, my_dest.psn, gid); in main()
728 rem_dest->lid, rem_dest->qpn, rem_dest->psn, gid); in main()
|
| H A D | rc_pingpong.c | 89 int qpn; member
101 .dest_qp_num = dest->qpn, in pp_connect_ctx()
197 sprintf(msg, "%04x:%06x:%06x:%s", my_dest->lid, my_dest->qpn, in pp_client_exch_dest()
215 sscanf(msg, "%x:%x:%x:%s", &rem_dest->lid, &rem_dest->qpn, in pp_client_exch_dest()
299 sscanf(msg, "%x:%x:%x:%s", &rem_dest->lid, &rem_dest->qpn, in pp_server_exch_dest()
313 sprintf(msg, "%04x:%06x:%06x:%s", my_dest->lid, my_dest->qpn, in pp_server_exch_dest()
885 my_dest.qpn = ctx->qp->qp_num; in main()
889 my_dest.lid, my_dest.qpn, my_dest.psn, gid); in main()
903 rem_dest->lid, rem_dest->qpn, rem_dest->psn, gid); in main()
|
| /freebsd/contrib/ofed/libmlx5/ |
| H A D | qp.c | 423 uint32_t qpn, void **seg, int *size) in set_umr_data_seg() argument
443 uint32_t qpn, void **seg, int *size) in set_umr_mkey_seg() argument
449 0xFFFFFF00 : qpn << 8)); in set_umr_mkey_seg()
481 uint32_t qpn, void **seg, int *size) in set_umr_control_seg() argument
518 uint32_t qpn, void **seg, int *size) in set_bind_wr() argument
544 set_umr_control_seg(qp, type, rkey, bind_info, qpn, seg, size); in set_bind_wr()
548 set_umr_mkey_seg(qp, type, rkey, bind_info, qpn, seg, size); in set_bind_wr()
555 set_umr_data_seg(qp, type, rkey, bind_info, qpn, seg, size); in set_bind_wr()
1041 uint32_t qpn = qp->ibv_qp->qp_num; in set_sig_seg() local
1044 sign ^= calc_sig(&qpn, 4); in set_sig_seg()
[all …]
|
| /freebsd/sys/dev/mlx4/ |
| H A D | device.h | 755 int qpn; member
910 __be32 qpn; member
1039 static inline int mlx4_is_qp_reserved(struct mlx4_dev *dev, u32 qpn) in mlx4_is_qp_reserved() argument
1041 return (qpn < dev->phys_caps.base_sqpn + 8 + in mlx4_is_qp_reserved()
1043 qpn >= dev->phys_caps.base_sqpn) || in mlx4_is_qp_reserved()
1044 (qpn < dev->caps.reserved_qps_cnt[MLX4_QP_REGION_FW]); in mlx4_is_qp_reserved()
1047 static inline int mlx4_is_guest_proxy(struct mlx4_dev *dev, int slave, u32 qpn) in mlx4_is_guest_proxy() argument
1051 if (qpn >= guest_proxy_base && qpn < guest_proxy_base + 8) in mlx4_is_guest_proxy()
1129 int mlx4_qp_alloc(struct mlx4_dev *dev, int qpn, struct mlx4_qp *qp,
1259 u32 qpn; member
[all …]
|
| H A D | qp.h | 477 int mlx4_update_qp(struct mlx4_dev *dev, u32 qpn,
492 static inline struct mlx4_qp *__mlx4_qp_lookup(struct mlx4_dev *dev, u32 qpn) in __mlx4_qp_lookup() argument
494 return radix_tree_lookup(&dev->qp_table_tree, qpn & (dev->caps.num_qps - 1)); in __mlx4_qp_lookup()
507 u16 mlx4_qp_roce_entropy(struct mlx4_dev *dev, u32 qpn);
|
| /freebsd/contrib/ofed/libibumad/ |
| H A D | umad.c | 60 uint8_t qpn; member
72 uint32_t qpn; member
780 mad->addr.qpn = htobe32(dqp); in umad_set_addr()
794 mad->addr.qpn = dqp; in umad_set_addr_net()
920 req.qpn = 1; in umad_register_oui()
936 fd, req.id, req.qpn, req.mgmt_class, oui); in umad_register_oui()
941 fd, req.qpn, req.mgmt_class, req.mgmt_class_version, oui); in umad_register_oui()
956 req.qpn = qp = (mgmt_class == 0x1 || mgmt_class == 0x81) ? 0 : 1; in umad_register()
1006 req.qpn = (attr->mgmt_class == 0x1 || attr->mgmt_class == 0x81) ? 0 : 1; in umad_register2()
1016 port_fd, req.id, req.qpn, req.mgmt_class, attr->oui); in umad_register2()
[all …]
|
| /freebsd/sys/ofed/drivers/infiniband/core/ |
| H A D | cm_msgs.h | 111 static inline void cm_req_set_local_qpn(struct cm_req_msg *req_msg, __be32 qpn) in cm_req_set_local_qpn() argument
113 req_msg->offset32 = cpu_to_be32((be32_to_cpu(qpn) << 8) | in cm_req_set_local_qpn()
519 static inline void cm_rep_set_local_qpn(struct cm_rep_msg *rep_msg, __be32 qpn) in cm_rep_set_local_qpn() argument
521 rep_msg->offset12 = cpu_to_be32((be32_to_cpu(qpn) << 8) | in cm_rep_set_local_qpn()
639 static inline void cm_dreq_set_remote_qpn(struct cm_dreq_msg *dreq_msg, __be32 qpn) in cm_dreq_set_remote_qpn() argument
641 dreq_msg->offset8 = cpu_to_be32((be32_to_cpu(qpn) << 8) | in cm_dreq_set_remote_qpn()
688 static inline void cm_lap_set_remote_qpn(struct cm_lap_msg *lap_msg, __be32 qpn) in cm_lap_set_remote_qpn() argument
690 lap_msg->offset12 = cpu_to_be32((be32_to_cpu(qpn) << 8) | in cm_lap_set_remote_qpn()
825 __be32 qpn) in cm_sidr_rep_set_qpn() argument
827 sidr_rep_msg->offset8 = cpu_to_be32((be32_to_cpu(qpn) << 8) | in cm_sidr_rep_set_qpn()
|
| /freebsd/sys/ofed/include/rdma/ |
| H A D | iw_cm.h | 107 u32 qpn; member
116 int qpn);
174 struct ib_qp *iw_cm_get_qp(struct ib_device *device, int qpn);
|
| H A D | rdma_vt.h | 468 u32 qpn) __must_hold(RCU) in rvt_lookup_qpn() argument
472 if (unlikely(qpn <= 1)) { in rvt_lookup_qpn()
473 qp = rcu_dereference(rvp->qp[qpn]); in rvt_lookup_qpn()
475 u32 n = hash_32(qpn, rdi->qp_dev->qp_table_bits); in rvt_lookup_qpn()
479 if (qp->ibqp.qp_num == qpn) in rvt_lookup_qpn()
|
| /freebsd/contrib/ofed/libmlx4/ |
| H A D | cq.c | 242 uint32_t qpn; in mlx4_parse_cqe() local
253 qpn = be32toh(cqe->vlan_my_qpn) & MLX4_CQE_QPN_MASK; in mlx4_parse_cqe()
258 wc->qp_num = qpn; in mlx4_parse_cqe()
264 if ((qpn & MLX4_XRC_QPN_BIT) && !is_send) { in mlx4_parse_cqe()
275 if (!*cur_qp || (qpn != (*cur_qp)->verbs_qp.qp.qp_num)) { in mlx4_parse_cqe()
281 *cur_qp = mlx4_find_qp(mctx, qpn); in mlx4_parse_cqe()
714 void __mlx4_cq_clean(struct mlx4_cq *cq, uint32_t qpn, struct mlx4_srq *srq) in __mlx4_cq_clean() argument
745 } else if ((be32toh(cqe->vlan_my_qpn) & MLX4_CQE_QPN_MASK) == qpn) { in __mlx4_cq_clean()
770 void mlx4_cq_clean(struct mlx4_cq *cq, uint32_t qpn, struct mlx4_srq *srq) in mlx4_cq_clean() argument
773 __mlx4_cq_clean(cq, qpn, srq); in mlx4_cq_clean()
|
| H A D | qp.c | 742 struct mlx4_qp *mlx4_find_qp(struct mlx4_context *ctx, uint32_t qpn) in mlx4_find_qp() argument
744 int tind = (qpn & (ctx->num_qps - 1)) >> ctx->qp_table_shift; in mlx4_find_qp()
747 return ctx->qp_table[tind].table[qpn & ctx->qp_table_mask]; in mlx4_find_qp()
752 int mlx4_store_qp(struct mlx4_context *ctx, uint32_t qpn, struct mlx4_qp *qp) in mlx4_store_qp() argument
754 int tind = (qpn & (ctx->num_qps - 1)) >> ctx->qp_table_shift; in mlx4_store_qp()
764 ctx->qp_table[tind].table[qpn & ctx->qp_table_mask] = qp; in mlx4_store_qp()
768 void mlx4_clear_qp(struct mlx4_context *ctx, uint32_t qpn) in mlx4_clear_qp() argument
770 int tind = (qpn & (ctx->num_qps - 1)) >> ctx->qp_table_shift; in mlx4_clear_qp()
775 ctx->qp_table[tind].table[qpn & ctx->qp_table_mask] = NULL; in mlx4_clear_qp()
|
| H A D | mlx4.h | 397 void __mlx4_cq_clean(struct mlx4_cq *cq, uint32_t qpn, struct mlx4_srq *srq);
398 void mlx4_cq_clean(struct mlx4_cq *cq, uint32_t qpn, struct mlx4_srq *srq);
450 struct mlx4_qp *mlx4_find_qp(struct mlx4_context *ctx, uint32_t qpn);
451 int mlx4_store_qp(struct mlx4_context *ctx, uint32_t qpn, struct mlx4_qp *qp);
452 void mlx4_clear_qp(struct mlx4_context *ctx, uint32_t qpn);
|
| /freebsd/sys/dev/mlx4/mlx4_en/ |
| H A D | mlx4_en_rx.c | 921 static int mlx4_en_config_rss_qp(struct mlx4_en_priv *priv, int qpn, in mlx4_en_config_rss_qp() argument
936 err = mlx4_qp_alloc(mdev->dev, qpn, qp, GFP_KERNEL); in mlx4_en_config_rss_qp()
938 en_err(priv, "Failed to allocate qp #%x\n", qpn); in mlx4_en_config_rss_qp()
945 qpn, ring->cqn, -1, context); in mlx4_en_config_rss_qp()
969 u32 qpn; in mlx4_en_create_drop_qp() local
971 err = mlx4_qp_reserve_range(priv->mdev->dev, 1, 1, &qpn, 0); in mlx4_en_create_drop_qp()
976 err = mlx4_qp_alloc(priv->mdev->dev, qpn, &priv->drop_qp, GFP_KERNEL); in mlx4_en_create_drop_qp()
979 mlx4_qp_release_range(priv->mdev->dev, qpn, 1); in mlx4_en_create_drop_qp()
988 u32 qpn; in mlx4_en_destroy_drop_qp() local
990 qpn = priv->drop_qp.qpn; in mlx4_en_destroy_drop_qp()
[all …]
|