| /freebsd/sys/ofed/drivers/infiniband/core/ |
| H A D | ib_iwcm.c | 88 struct iwcm_id_private *cm_id; member
134 list_add(&work->free_list, &work->cm_id->work_free_list); in put_work()
156 work->cm_id = cm_id_priv; in alloc_work_entries()
201 static void add_ref(struct iw_cm_id *cm_id) in add_ref() argument
204 cm_id_priv = container_of(cm_id, struct iwcm_id_private, id); in add_ref()
208 static void rem_ref(struct iw_cm_id *cm_id) in rem_ref() argument
212 cm_id_priv = container_of(cm_id, struct iwcm_id_private, id); in rem_ref()
217 static int cm_event_handler(struct iw_cm_id *cm_id, struct iw_cm_event *event);
284 int iw_cm_disconnect(struct iw_cm_id *cm_id, int abrupt) in iw_cm_disconnect() argument
291 cm_id_priv = container_of(cm_id, struct iwcm_id_private, id); in iw_cm_disconnect()
[all …]
|
| H A D | ib_ucma.c | 80 struct rdma_cm_id *cm_id; member
109 struct rdma_cm_id *cm_id; member
126 else if (ctx->file != file || !ctx->cm_id) in _ucma_find_context()
163 if (!ctx->cm_id->device) { in ucma_get_ctx_dev()
174 rdma_destroy_id(uevent_close->cm_id); in ucma_close_event_id()
189 rdma_destroy_id(ctx->cm_id); in ucma_close_id()
292 static void ucma_removal_event_handler(struct rdma_cm_id *cm_id) in ucma_removal_event_handler() argument
294 struct ucma_context *ctx = cm_id->context; in ucma_removal_event_handler()
307 if (ctx->cm_id == cm_id) { in ucma_removal_event_handler()
316 if (con_req_eve->cm_id == cm_id && in ucma_removal_event_handler()
[all …]
|
| H A D | ib_cm.c | 965 static void cm_destroy_id(struct ib_cm_id *cm_id, int err) in cm_destroy_id() argument
970 cm_id_priv = container_of(cm_id, struct cm_id_private, id); in cm_destroy_id()
973 switch (cm_id->state) { in cm_destroy_id()
988 cm_id->state = IB_CM_IDLE; in cm_destroy_id()
1005 ib_send_cm_rej(cm_id, IB_CM_REJ_TIMEOUT, in cm_destroy_id()
1017 ib_send_cm_rej(cm_id, IB_CM_REJ_CONSUMER_DEFINED, in cm_destroy_id()
1029 ib_send_cm_rej(cm_id, IB_CM_REJ_CONSUMER_DEFINED, in cm_destroy_id()
1036 ib_send_cm_dreq(cm_id, NULL, 0); in cm_destroy_id()
1045 ib_send_cm_drep(cm_id, NULL, 0); in cm_destroy_id()
1061 cm_free_id(cm_id->local_id); in cm_destroy_id()
[all …]
|
| H A D | ib_ucm.c | 85 struct ib_cm_id *cm_id; member
97 struct ib_cm_id *cm_id; member
170 ib_destroy_cm_id(uevent->cm_id); in ib_ucm_cleanup_events()
349 static int ib_ucm_event_handler(struct ib_cm_id *cm_id, in ib_ucm_event_handler() argument
356 ctx = cm_id->context; in ib_ucm_event_handler()
363 uevent->cm_id = cm_id; in ib_ucm_event_handler()
424 ctx->cm_id = uevent->cm_id; in ib_ucm_event()
425 ctx->cm_id->context = ctx; in ib_ucm_event()
493 ctx->cm_id = ib_create_cm_id(file->device->ib_dev, in ib_ucm_create_id()
495 if (IS_ERR(ctx->cm_id)) { in ib_ucm_create_id()
[all …]
|
| H A D | ib_cma.c | 331 } cm_id; member
1009 if (!id_priv->cm_id.ib || (id_priv->id.qp_type == IB_QPT_UD)) in rdma_init_qp_attr()
1012 ret = ib_cm_init_qp_attr(id_priv->cm_id.ib, qp_attr, in rdma_init_qp_attr()
1018 if (!id_priv->cm_id.iw) { in rdma_init_qp_attr()
1022 ret = iw_cm_init_qp_attr(id_priv->cm_id.iw, qp_attr, in rdma_init_qp_attr()
1701 const struct ib_cm_id *cm_id, in cma_find_listener() argument
1713 if (id_priv->id.device == cm_id->device && in cma_find_listener()
1719 if (id_priv_dev->id.device == cm_id->device && in cma_find_listener()
1729 static struct rdma_id_private *cma_id_from_event(struct ib_cm_id *cm_id, in cma_id_from_event() argument
1742 if (rdma_ps_from_service_id(cm_id->service_id) == RDMA_PS_SDP) { in cma_id_from_event()
[all …]
|
| /freebsd/sys/ofed/include/rdma/ |
| H A D | iw_cm.h | 71 typedef int (*iw_cm_handler)(struct iw_cm_id *cm_id,
82 typedef int (*iw_event_handler)(struct iw_cm_id *cm_id,
118 int (*connect)(struct iw_cm_id *cm_id,
121 int (*accept)(struct iw_cm_id *cm_id,
124 int (*reject)(struct iw_cm_id *cm_id,
127 int (*create_listen)(struct iw_cm_id *cm_id,
130 int (*destroy_listen)(struct iw_cm_id *cm_id);
153 void iw_destroy_cm_id(struct iw_cm_id *cm_id);
166 void iw_cm_unbind_qp(struct iw_cm_id *cm_id, struct ib_qp *qp);
187 int iw_cm_listen(struct iw_cm_id *cm_id, int backlog);
[all …]
|
| H A D | ib_cm.h | 316 typedef int (*ib_cm_handler)(struct ib_cm_id *cm_id,
353 void ib_destroy_cm_id(struct ib_cm_id *cm_id);
375 int ib_cm_listen(struct ib_cm_id *cm_id, __be64 service_id,
410 int ib_send_cm_req(struct ib_cm_id *cm_id,
434 int ib_send_cm_rep(struct ib_cm_id *cm_id,
445 int ib_send_cm_rtu(struct ib_cm_id *cm_id,
458 int ib_send_cm_dreq(struct ib_cm_id *cm_id,
473 int ib_send_cm_drep(struct ib_cm_id *cm_id,
491 int ib_cm_notify(struct ib_cm_id *cm_id, enum ib_event_type event);
505 int ib_send_cm_rej(struct ib_cm_id *cm_id,
[all …]
|
| /freebsd/contrib/ofed/libibcm/ |
| H A D | cm.c | 247 struct ib_cm_id **cm_id, void *context) in ib_cm_create_id() argument
270 *cm_id = &cm_id_priv->id; in ib_cm_create_id()
277 int ib_cm_destroy_id(struct ib_cm_id *cm_id) in ib_cm_destroy_id() argument
287 cmd->id = cm_id->handle; in ib_cm_destroy_id()
289 result = write(cm_id->device->fd, msg, size); in ib_cm_destroy_id()
295 cm_id_priv = container_of(cm_id, struct cm_id_private, id); in ib_cm_destroy_id()
306 int ib_cm_attr_id(struct ib_cm_id *cm_id, struct ib_cm_attr_param *param) in ib_cm_attr_id() argument
318 cmd->id = cm_id->handle; in ib_cm_attr_id()
320 result = write(cm_id->device->fd, msg, size); in ib_cm_attr_id()
333 int ib_cm_init_qp_attr(struct ib_cm_id *cm_id, in ib_cm_init_qp_attr() argument
[all …]
|
| H A D | cm.h | 236 struct ib_cm_id *cm_id; member
309 struct ib_cm_id **cm_id, void *context);
315 int ib_cm_destroy_id(struct ib_cm_id *cm_id);
331 int ib_cm_attr_id(struct ib_cm_id *cm_id,
348 int ib_cm_listen(struct ib_cm_id *cm_id,
380 int ib_cm_send_req(struct ib_cm_id *cm_id,
405 int ib_cm_send_rep(struct ib_cm_id *cm_id,
416 int ib_cm_send_rtu(struct ib_cm_id *cm_id,
429 int ib_cm_send_dreq(struct ib_cm_id *cm_id,
441 int ib_cm_send_drep(struct ib_cm_id *cm_id,
[all …]
|
| /freebsd/sys/dev/irdma/ |
| H A D | irdma_cm.c | 171 * @cm_id: upper layers cm struct for the event
176 struct iw_cm_id *cm_id, in irdma_get_cmevent_info() argument
179 memcpy(&event->local_addr, &cm_id->m_local_addr, in irdma_get_cmevent_info()
181 memcpy(&event->remote_addr, &cm_id->m_remote_addr, in irdma_get_cmevent_info()
194 * @cm_id: upper layer's cm info struct
200 struct iw_cm_id *cm_id, in irdma_send_cm_event() argument
209 "cm_node %p cm_id=%p state=%d accel=%d event_type=%d status=%d\n", in irdma_send_cm_event()
210 cm_node, cm_id, cm_node->accelerated, cm_node->state, type, in irdma_send_cm_event()
225 irdma_get_cmevent_info(cm_node, cm_id, &event); in irdma_send_cm_event()
241 return cm_id in irdma_send_cm_event()
705 struct iw_cm_id *cm_id; irdma_event_connect_error() local
1629 irdma_get_vlan_mac_ipv6(struct iw_cm_id * cm_id,u32 * addr,u16 * vlan_id,u8 * mac) irdma_get_vlan_mac_ipv6() argument
1665 irdma_get_vlan_ipv4(struct iw_cm_id * cm_id,u32 * addr) irdma_get_vlan_ipv4() argument
3351 struct iw_cm_id *cm_id; irdma_cm_disconn_true() local
3503 irdma_accept(struct iw_cm_id * cm_id,struct iw_cm_conn_param * conn_param) irdma_accept() argument
3657 irdma_reject(struct iw_cm_id * cm_id,const void * pdata,u8 pdata_len) irdma_reject() argument
3683 irdma_connect(struct iw_cm_id * cm_id,struct iw_cm_conn_param * conn_param) irdma_connect() argument
3830 irdma_create_listen(struct iw_cm_id * cm_id,int backlog) irdma_create_listen() argument
3949 irdma_destroy_listen(struct iw_cm_id * cm_id) irdma_destroy_listen() argument
4075 struct iw_cm_id *cm_id; irdma_cm_event_connected() local
4134 struct iw_cm_id *cm_id = cm_node->cm_id; irdma_cm_event_reset() local
[all...] |
| H A D | irdma_cm.h | 277 struct iw_cm_id *cm_id; member
324 struct iw_cm_id *cm_id; member
359 struct iw_cm_id *cm_id; member
431 int irdma_accept(struct iw_cm_id *cm_id, struct iw_cm_conn_param *conn_param);
432 int irdma_reject(struct iw_cm_id *cm_id, const void *pdata, u8 pdata_len);
433 int irdma_connect(struct iw_cm_id *cm_id, struct iw_cm_conn_param *conn_param);
434 int irdma_create_listen(struct iw_cm_id *cm_id, int backlog);
435 int irdma_destroy_listen(struct iw_cm_id *cm_id);
|
| H A D | fbsd_kcompat.h | 116 irdma_cmid_to_vnet(struct iw_cm_id *cm_id) in irdma_cmid_to_vnet() argument
120 if (!cm_id) in irdma_cmid_to_vnet()
123 rdma_id = (struct rdma_cm_id *)cm_id->context; in irdma_cmid_to_vnet()
|
| H A D | irdma_main.h | 584 u16 irdma_get_vlan_ipv4(struct iw_cm_id *cm_id, u32 *addr);
585 void irdma_get_vlan_mac_ipv6(struct iw_cm_id *cm_id, u32 *addr, u16 *vlan_id,
|
| /freebsd/contrib/ofed/librdmacm/ |
| H A D | rsocket.c | 285 struct rdma_cm_id *cm_id; member
308 struct rdma_cm_id *cm_id; member
642 if (rs->cm_id->recv_cq_channel) in rs_set_nonblocking()
643 ret = fcntl(rs->cm_id->recv_cq_channel->fd, F_SETFL, arg); in rs_set_nonblocking()
646 ret = fcntl(rs->cm_id->channel->fd, F_SETFL, arg); in rs_set_nonblocking()
652 ret = fcntl(qp->cm_id->recv_cq_channel->fd, in rs_set_nonblocking()
666 max_size = min(ucma_max_qpsize(rs->cm_id), RS_QP_MAX_SIZE); in rs_set_qp_size()
717 rs->smr = rdma_reg_msgs(rs->cm_id, rs->sbuf, total_sbuf_size); in rs_init_bufs()
727 rs->target_mr = rdma_reg_write(rs->cm_id, rs->target_buffer_list, len); in rs_init_bufs()
743 rs->rmr = rdma_reg_write(rs->cm_id, rs->rbuf, total_rbuf_size); in rs_init_bufs()
[all …]
|
| H A D | cma.c | 2342 struct rdma_cm_id *cm_id; in rdma_create_ep() local
2346 ret = rdma_create_id2(NULL, &cm_id, NULL, res->ai_port_space, res->ai_qp_type); in rdma_create_ep()
2351 ret = ucma_passive_ep(cm_id, res, pd, qp_init_attr); in rdma_create_ep()
2358 ret = rdma_resolve_addr2(cm_id, res->ai_src_addr, res->ai_src_len, in rdma_create_ep()
2361 ret = rdma_resolve_addr(cm_id, res->ai_src_addr, res->ai_dst_addr, 2000); in rdma_create_ep()
2366 ret = rdma_set_option(cm_id, RDMA_OPTION_IB, RDMA_OPTION_IB_PATH, in rdma_create_ep()
2369 ret = ucma_complete(cm_id); in rdma_create_ep()
2371 ret = rdma_resolve_route(cm_id, 2000); in rdma_create_ep()
2378 ret = rdma_create_qp(cm_id, pd, qp_init_attr); in rdma_create_ep()
2384 id_priv = container_of(cm_id, struct cma_id_private, id); in rdma_create_ep()
[all …]
|
| /freebsd/sys/dev/cxgbe/iw_cxgbe/ |
| H A D | cm.c | 186 epc->cm_id->rem_ref(epc->cm_id); in deref_cm_id()
187 epc->cm_id = NULL; in deref_cm_id()
194 epc->cm_id->add_ref(epc->cm_id); in ref_cm_id()
406 if (ep->com.cm_id && ep->com.qp) { in process_timeout()
640 if (ep->com.cm_id && ep->com.qp) { in process_peer_close()
717 if (ep->com.cm_id && ep->com.qp) { in process_conn_error()
778 if ((ep->com.cm_id) && (ep->com.qp)) { in process_close_complete()
1005 new_ep->com.cm_id = NULL; in process_newconn()
1622 if (ep->com.cm_id) { in close_complete_upcall()
1625 ep->com.cm_id->event_handler(ep->com.cm_id, &event); in close_complete_upcall()
[all …]
|
| H A D | iw_cxgbe.h | 823 struct iw_cm_id *cm_id; member
876 static inline struct c4iw_ep *to_ep(struct iw_cm_id *cm_id) in to_ep() argument
878 return cm_id->provider_data; in to_ep()
881 static inline struct c4iw_listen_ep *to_listen_ep(struct iw_cm_id *cm_id) in to_listen_ep() argument
883 return cm_id->provider_data; in to_listen_ep()
928 int c4iw_connect(struct iw_cm_id *cm_id, struct iw_cm_conn_param *conn_param);
929 int c4iw_create_listen(struct iw_cm_id *cm_id, int backlog);
930 int c4iw_destroy_listen(struct iw_cm_id *cm_id);
931 int c4iw_accept_cr(struct iw_cm_id *cm_id, struct iw_cm_conn_param *conn_param);
932 int c4iw_reject_cr(struct iw_cm_id *cm_id, const void *pdata, u8 pdata_len);
|
| /freebsd/sys/ofed/drivers/infiniband/ulp/ipoib/ |
| H A D | ipoib_cm.c | 81 static int ipoib_cm_tx_handler(struct ib_cm_id *cm_id,
233 struct ib_cm_id *cm_id, struct ib_qp *qp, in ipoib_cm_modify_rx_qp() argument
240 ret = ib_cm_init_qp_attr(cm_id, &qp_attr, &qp_attr_mask); in ipoib_cm_modify_rx_qp()
251 ret = ib_cm_init_qp_attr(cm_id, &qp_attr, &qp_attr_mask); in ipoib_cm_modify_rx_qp()
272 ret = ib_cm_init_qp_attr(cm_id, &qp_attr, &qp_attr_mask); in ipoib_cm_modify_rx_qp()
301 struct ib_cm_id *cm_id, struct ipoib_cm_rx *rx) in ipoib_cm_nonsrq_init_rx() argument
331 ib_send_cm_rej(cm_id, IB_CM_REJ_NO_QP, NULL, 0, NULL, 0); in ipoib_cm_nonsrq_init_rx()
372 static int ipoib_cm_send_rep(struct ipoib_dev_priv *priv, struct ib_cm_id *cm_id, in ipoib_cm_send_rep() argument
389 return ib_send_cm_rep(cm_id, &rep); in ipoib_cm_send_rep()
392 static int ipoib_cm_req_handler(struct ib_cm_id *cm_id, struct ib_cm_event *event) in ipoib_cm_req_handler() argument
[all …]
|
| /freebsd/sys/dev/qlnx/qlnxr/ |
| H A D | qlnxr_verbs.h | 176 extern int qlnxr_iw_connect(struct iw_cm_id *cm_id,
179 extern int qlnxr_iw_create_listen(struct iw_cm_id *cm_id, int backlog);
181 void qlnxr_iw_destroy_listen(struct iw_cm_id *cm_id);
183 extern int qlnxr_iw_accept(struct iw_cm_id *cm_id,
186 extern int qlnxr_iw_reject(struct iw_cm_id *cm_id, const void *pdata, u8 pdata_len);
|
| H A D | qlnxr_verbs.c | 5695 listener->cm_id->event_handler(listener->cm_id, &event); in qlnxr_iw_mpa_request()
5737 if (ep->cm_id) in qlnxr_iw_issue_event()
5738 ep->cm_id->event_handler(ep->cm_id, &event); in qlnxr_iw_issue_event()
5762 if (ep->cm_id) { in qlnxr_iw_close_event()
5767 ep->cm_id->rem_ref(ep->cm_id); in qlnxr_iw_close_event()
5768 ep->cm_id = NULL; in qlnxr_iw_close_event()
5849 if (ep->cm_id) in qlnxr_iw_disconnect_worker()
5850 ep->cm_id->event_handler(ep->cm_id, &event); in qlnxr_iw_disconnect_worker()
5979 ep->cm_id->rem_ref(ep->cm_id); in qlnxr_iw_event_handler()
5980 ep->cm_id = NULL; in qlnxr_iw_event_handler()
[all …]
|
| H A D | qlnxr_def.h | 722 struct iw_cm_id *cm_id; member
729 struct iw_cm_id *cm_id; member
|
| /freebsd/contrib/ofed/librdmacm/examples/ |
| H A D | rping.c | 155 struct rdma_cm_id *cm_id; /* connection on client side,*/ member
168 (cma_id == cb->cm_id) ? "parent" : "child"); in rping_cma_event_handler()
499 ret = rdma_create_qp(cb->cm_id, cb->pd, &init_attr); in rping_create_qp()
501 cb->qp = cb->cm_id->qp; in rping_create_qp()
515 static int rping_setup_qp(struct rping_cb *cb, struct rdma_cm_id *cm_id) in rping_setup_qp() argument
519 cb->pd = ibv_alloc_pd(cm_id->verbs); in rping_setup_qp()
526 cb->channel = ibv_create_comp_channel(cm_id->verbs); in rping_setup_qp()
534 cb->cq = ibv_create_cq(cm_id->verbs, RPING_SQ_DEPTH * 2, cb, in rping_setup_qp()
740 ret = rdma_bind_addr(cb->cm_id, (struct sockaddr *) &cb->sin); in rping_bind_server()
748 ret = rdma_listen(cb->cm_id, 3); in rping_bind_server()
[all …]
|
| /freebsd/sys/dev/mlx4/mlx4_ib/ |
| H A D | mlx4_ib_cm.c | 75 static void set_local_comm_id(struct ib_mad *mad, u32 cm_id) in set_local_comm_id() argument
80 msg->request_id = cpu_to_be32(cm_id); in set_local_comm_id()
86 msg->local_comm_id = cpu_to_be32(cm_id); in set_local_comm_id()
105 static void set_remote_comm_id(struct ib_mad *mad, u32 cm_id) in set_remote_comm_id() argument
110 msg->request_id = cpu_to_be32(cm_id); in set_remote_comm_id()
116 msg->remote_comm_id = cpu_to_be32(cm_id); in set_remote_comm_id()
|
| /freebsd/sys/contrib/rdma/krping/ |
| H A D | krping.c | 239 struct rdma_cm_id *cm_id; /* connection on client side,*/ member
252 (cma_id == cb->cm_id) ? "parent" : "child"); in krping_cma_event_handler()
636 ret = rdma_create_qp(cb->cm_id, cb->pd, &init_attr); in krping_create_qp()
638 cb->qp = cb->cm_id->qp; in krping_create_qp()
651 static int krping_setup_qp(struct krping_cb *cb, struct rdma_cm_id *cm_id) in krping_setup_qp() argument
656 cb->pd = ib_alloc_pd(cm_id->device, 0); in krping_setup_qp()
667 cb->cq = ib_create_cq(cm_id->device, krping_cq_event_handler, NULL, in krping_setup_qp()
1406 ret = rdma_bind_addr(cb->cm_id, (struct sockaddr *)&sin); in krping_bind_server()
1414 ret = rdma_listen(cb->cm_id, 3); in krping_bind_server()
1739 rdma_disconnect(cb->cm_id); in flush_qp()
[all …]
|
| /freebsd/sys/dev/xen/blkfront/ |
| H A D | block.h | 115 uint64_t cm_id; member
|