/freebsd-13-stable/sys/ofed/include/rdma/ |
H A D | iw_cm.h | 70 * @cm_id: The IW CM identifier associated with the event. 73 typedef int (*iw_cm_handler)(struct iw_cm_id *cm_id, 81 * @cm_id: The IW CM identifier associated with the event. 84 typedef int (*iw_event_handler)(struct iw_cm_id *cm_id, 98 /* Used by provider to add and remove refs on IW cm_id */ 120 int (*connect)(struct iw_cm_id *cm_id, 123 int (*accept)(struct iw_cm_id *cm_id, 126 int (*reject)(struct iw_cm_id *cm_id, 129 int (*create_listen)(struct iw_cm_id *cm_id, 132 int (*destroy_listen)(struct iw_cm_id *cm_id); [all...] |
H A D | ib_cm.h | 304 * @cm_id: Communication identifier associated with the reported event. 309 * new @cm_id. The new @cm_id is returned to the user through this callback. 310 * Clients are responsible for destroying the new @cm_id. For peer-to-peer 311 * IB_CM_REQ_RECEIVED and all other events, the returned @cm_id corresponds 316 * destroy the @cm_id after the callback completes. 318 typedef int (*ib_cm_handler)(struct ib_cm_id *cm_id, 336 * @device: Device associated with the cm_id. All related communication will 351 * @cm_id: Connection identifier to destroy. 355 void ib_destroy_cm_id(struct ib_cm_id *cm_id); [all...] |
/freebsd-13-stable/sys/ofed/drivers/infiniband/core/ |
H A D | ib_iwcm.c | 69 struct iwcm_id_private *cm_id; member in struct:iwcm_work 79 * elements. The design pre-allocates them based on the cm_id type: 89 * One exception is when creating the cm_id for incoming connection requests. 91 * 1) in the event upcall, cm_event_handler(), for a listening cm_id. If 96 * If work elements cannot be allocated for the new connect request cm_id, 115 list_add(&work->free_list, &work->cm_id->work_free_list); 137 work->cm_id = cm_id_priv; 167 * Release a reference on cm_id. If the last reference is being 168 * released, free the cm_id and return 1. 182 static void add_ref(struct iw_cm_id *cm_id) argument 189 rem_ref(struct iw_cm_id *cm_id) argument 265 iw_cm_disconnect(struct iw_cm_id *cm_id, int abrupt) argument 332 destroy_cm_id(struct iw_cm_id *cm_id) argument 404 iw_destroy_cm_id(struct iw_cm_id *cm_id) argument 424 iw_cm_map(struct iw_cm_id *cm_id, bool active) argument 438 iw_cm_listen(struct iw_cm_id *cm_id, int backlog) argument 479 iw_cm_reject(struct iw_cm_id *cm_id, const void *private_data, u8 private_data_len) argument 517 iw_cm_accept(struct iw_cm_id *cm_id, struct iw_cm_conn_param *iw_param) argument 573 iw_cm_connect(struct iw_cm_id *cm_id, struct iw_cm_conn_param *iw_param) argument 644 struct iw_cm_id *cm_id; local 923 cm_event_handler(struct iw_cm_id *cm_id, struct iw_cm_event *iw_event) argument 1015 iw_cm_init_qp_attr(struct iw_cm_id *cm_id, struct ib_qp_attr *qp_attr, int *qp_attr_mask) argument [all...] |
H A D | ib_ucma.c | 82 struct rdma_cm_id *cm_id; member in struct:ucma_context 111 struct rdma_cm_id *cm_id; member in struct:ucma_event 128 else if (ctx->file != file || !ctx->cm_id) 156 * Same as ucm_get_ctx but requires that ->cm_id->device is valid, eg that the 165 if (!ctx->cm_id->device) { 176 rdma_destroy_id(uevent_close->cm_id); 191 rdma_destroy_id(ctx->cm_id); 294 static void ucma_removal_event_handler(struct rdma_cm_id *cm_id) argument 296 struct ucma_context *ctx = cm_id->context; 303 /* only if context is pointing to cm_id tha 331 ucma_event_handler(struct rdma_cm_id *cm_id, struct rdma_cm_event *event) argument 467 struct rdma_cm_id *cm_id; local 861 ucma_query_device_addr(struct rdma_cm_id *cm_id, struct rdma_ucm_query_addr_resp *resp) argument [all...] |
H A D | ib_ucm.c | 87 struct ib_cm_id *cm_id; member in struct:ib_ucm_context 99 struct ib_cm_id *cm_id; member in struct:ib_ucm_event 172 ib_destroy_cm_id(uevent->cm_id); 351 static int ib_ucm_event_handler(struct ib_cm_id *cm_id, argument 358 ctx = cm_id->context; 365 uevent->cm_id = cm_id; 384 /* Destroy new cm_id's */ 426 ctx->cm_id = uevent->cm_id; 832 ib_ucm_send_private_data(struct ib_ucm_file *file, const char __user *inbuf, int in_len, int (*func)(struct ib_cm_id *cm_id, const void *private_data, u8 private_data_len)) argument 882 ib_ucm_send_info(struct ib_ucm_file *file, const char __user *inbuf, int in_len, int (*func)(struct ib_cm_id *cm_id, int status, const void *info, u8 info_len, const void *data, u8 data_len)) argument [all...] |
H A D | ib_cm.c | 861 * The cm_id could be destroyed by the user before we exit timewait. 862 * To protect against this, we search for the cm_id after exiting 892 static void cm_destroy_id(struct ib_cm_id *cm_id, int err) argument 897 cm_id_priv = container_of(cm_id, struct cm_id_private, id); 900 switch (cm_id->state) { 915 cm_id->state = IB_CM_IDLE; 932 ib_send_cm_rej(cm_id, IB_CM_REJ_TIMEOUT, 944 ib_send_cm_rej(cm_id, IB_CM_REJ_CONSUMER_DEFINED, 956 ib_send_cm_rej(cm_id, IB_CM_REJ_CONSUMER_DEFINED, 963 ib_send_cm_dreq(cm_id, NUL 997 ib_destroy_cm_id(struct ib_cm_id *cm_id) argument 1016 __ib_cm_listen(struct ib_cm_id *cm_id, __be64 service_id, __be64 service_mask) argument 1052 ib_cm_listen(struct ib_cm_id *cm_id, __be64 service_id, __be64 service_mask) argument 1086 struct ib_cm_id *cm_id; local 1259 ib_send_cm_req(struct ib_cm_id *cm_id, struct ib_cm_req_param *param) argument 1687 struct ib_cm_id *cm_id; local 1831 ib_send_cm_rep(struct ib_cm_id *cm_id, struct ib_cm_rep_param *param) argument 1893 ib_send_cm_rtu(struct ib_cm_id *cm_id, const void *private_data, u8 private_data_len) argument 2182 ib_send_cm_dreq(struct ib_cm_id *cm_id, const void *private_data, u8 private_data_len) argument 2244 ib_send_cm_drep(struct ib_cm_id *cm_id, const void *private_data, u8 private_data_len) argument 2431 ib_send_cm_rej(struct ib_cm_id *cm_id, enum ib_cm_rej_reason reason, void *ari, u8 ari_length, const void *private_data, u8 private_data_len) argument 2605 ib_send_cm_mra(struct ib_cm_id *cm_id, u8 service_timeout, const void *private_data, u8 private_data_len) argument 2801 ib_send_cm_lap(struct ib_cm_id *cm_id, struct ib_sa_path_rec *alternate_path, const void *private_data, u8 private_data_len) argument 2982 ib_send_cm_apr(struct ib_cm_id *cm_id, enum ib_cm_apr_status status, void *info, u8 info_length, const void *private_data, u8 private_data_len) argument 3122 ib_send_cm_sidr_req(struct ib_cm_id *cm_id, struct ib_cm_sidr_req_param *param) argument 3192 struct ib_cm_id *cm_id; local 3272 ib_send_cm_sidr_rep(struct ib_cm_id *cm_id, struct ib_cm_sidr_rep_param *param) argument 3510 cm_establish(struct ib_cm_id *cm_id) argument 3574 cm_migrate(struct ib_cm_id *cm_id) argument 3603 ib_cm_notify(struct ib_cm_id *cm_id, enum ib_event_type event) argument 3846 ib_cm_init_qp_attr(struct ib_cm_id *cm_id, struct ib_qp_attr *qp_attr, int *qp_attr_mask) argument [all...] |
H A D | ib_cma.c | 319 } cm_id; member in struct:rdma_id_private 993 if (!id_priv->cm_id.ib || (id_priv->id.qp_type == IB_QPT_UD)) 996 ret = ib_cm_init_qp_attr(id_priv->cm_id.ib, qp_attr, 1002 if (!id_priv->cm_id.iw) { 1006 ret = iw_cm_init_qp_attr(id_priv->cm_id.iw, qp_attr, 1654 const struct ib_cm_id *cm_id, 1666 if (id_priv->id.device == cm_id->device && 1672 if (id_priv_dev->id.device == cm_id->device && 1682 static struct rdma_id_private *cma_id_from_event(struct ib_cm_id *cm_id, argument 1695 if (rdma_ps_from_service_id(cm_id 1652 cma_find_listener( const struct rdma_bind_list *bind_list, const struct ib_cm_id *cm_id, const struct ib_cm_event *ib_event, const struct cma_req_info *req, const struct net_device *net_dev) argument 1919 cma_ib_handler(struct ib_cm_id *cm_id, struct ib_cm_event *ib_event) argument 2131 cma_req_handler(struct ib_cm_id *cm_id, struct ib_cm_event *ib_event) argument 2299 iw_conn_req_handler(struct iw_cm_id *cm_id, struct iw_cm_event *iw_event) argument 3509 cma_sidr_rep_handler(struct ib_cm_id *cm_id, struct ib_cm_event *ib_event) argument 3705 struct iw_cm_id *cm_id; local [all...] |
/freebsd-13-stable/contrib/ofed/libibcm/ |
H A D | cm.h | 236 struct ib_cm_id *cm_id; member in struct:ib_cm_event 264 * new @cm_id. 265 * Clients are responsible for destroying the new @cm_id. For peer-to-peer 266 * IB_CM_REQ_RECEIVED and all other events, the returned @cm_id corresponds 309 struct ib_cm_id **cm_id, void *context); 313 * @cm_id: Connection identifier to destroy. 315 int ib_cm_destroy_id(struct ib_cm_id *cm_id); 326 * @cm_id: Connection identifier to retrieve attributes. 331 int ib_cm_attr_id(struct ib_cm_id *cm_id, 340 * @cm_id [all...] |
H A D | cm.c | 246 struct ib_cm_id **cm_id, void *context) 269 *cm_id = &cm_id_priv->id; 276 int ib_cm_destroy_id(struct ib_cm_id *cm_id) argument 286 cmd->id = cm_id->handle; 288 result = write(cm_id->device->fd, msg, size); 294 cm_id_priv = container_of(cm_id, struct cm_id_private, id); 305 int ib_cm_attr_id(struct ib_cm_id *cm_id, struct ib_cm_attr_param *param) argument 317 cmd->id = cm_id->handle; 319 result = write(cm_id->device->fd, msg, size); 332 int ib_cm_init_qp_attr(struct ib_cm_id *cm_id, argument 245 ib_cm_create_id(struct ib_cm_device *device, struct ib_cm_id **cm_id, void *context) argument 361 ib_cm_listen(struct ib_cm_id *cm_id, __be64 service_id, __be64 service_mask) argument 382 ib_cm_send_req(struct ib_cm_id *cm_id, struct ib_cm_req_param *param) argument 435 ib_cm_send_rep(struct ib_cm_id *cm_id, struct ib_cm_rep_param *param) argument 470 cm_send_private_data(struct ib_cm_id *cm_id, uint32_t type, void *private_data, uint8_t private_data_len) argument 495 ib_cm_send_rtu(struct ib_cm_id *cm_id, void *private_data, uint8_t private_data_len) argument 503 ib_cm_send_dreq(struct ib_cm_id *cm_id, void *private_data, uint8_t private_data_len) argument 511 ib_cm_send_drep(struct ib_cm_id *cm_id, void *private_data, uint8_t private_data_len) argument 519 cm_establish(struct ib_cm_id *cm_id) argument 544 ib_cm_notify(struct ib_cm_id *cm_id, enum ibv_event_type event) argument 569 cm_send_status(struct ib_cm_id *cm_id, uint32_t type, int status, void *info, uint8_t info_length, void *private_data, uint8_t private_data_len) argument 603 ib_cm_send_rej(struct ib_cm_id *cm_id, enum ib_cm_rej_reason reason, void *ari, uint8_t ari_length, void *private_data, uint8_t private_data_len) argument 615 ib_cm_send_apr(struct ib_cm_id *cm_id, enum ib_cm_apr_status status, void *info, uint8_t info_length, void *private_data, uint8_t private_data_len) argument 627 ib_cm_send_mra(struct ib_cm_id *cm_id, uint8_t service_timeout, void *private_data, uint8_t private_data_len) argument 653 ib_cm_send_lap(struct ib_cm_id *cm_id, struct ibv_sa_path_rec *alternate_path, void *private_data, uint8_t private_data_len) argument 682 ib_cm_send_sidr_req(struct ib_cm_id *cm_id, struct ib_cm_sidr_req_param *param) argument 715 ib_cm_send_sidr_rep(struct ib_cm_id *cm_id, struct ib_cm_sidr_rep_param *param) argument [all...] |
/freebsd-13-stable/contrib/ofed/librdmacm/ |
H A D | rsocket.c | 285 struct rdma_cm_id *cm_id; member in struct:ds_qp 308 struct rdma_cm_id *cm_id; member in struct:rsocket::__anon5734::__anon5735 642 if (rs->cm_id->recv_cq_channel) 643 ret = fcntl(rs->cm_id->recv_cq_channel->fd, F_SETFL, arg); 646 ret = fcntl(rs->cm_id->channel->fd, F_SETFL, arg); 652 ret = fcntl(qp->cm_id->recv_cq_channel->fd, 666 max_size = min(ucma_max_qpsize(rs->cm_id), RS_QP_MAX_SIZE); 717 rs->smr = rdma_reg_msgs(rs->cm_id, rs->sbuf, total_sbuf_size); 727 rs->target_mr = rdma_reg_write(rs->cm_id, rs->target_buffer_list, len); 743 rs->rmr = rdma_reg_write(rs->cm_id, r 781 rs_create_cq(struct rsocket *rs, struct rdma_cm_id *cm_id) argument [all...] |
H A D | cma.c | 2341 struct rdma_cm_id *cm_id; local 2345 ret = rdma_create_id2(NULL, &cm_id, NULL, res->ai_port_space, res->ai_qp_type); 2350 ret = ucma_passive_ep(cm_id, res, pd, qp_init_attr); 2357 ret = rdma_resolve_addr2(cm_id, res->ai_src_addr, res->ai_src_len, 2360 ret = rdma_resolve_addr(cm_id, res->ai_src_addr, res->ai_dst_addr, 2000); 2365 ret = rdma_set_option(cm_id, RDMA_OPTION_IB, RDMA_OPTION_IB_PATH, 2368 ret = ucma_complete(cm_id); 2370 ret = rdma_resolve_route(cm_id, 2000); 2377 ret = rdma_create_qp(cm_id, pd, qp_init_attr); 2383 id_priv = container_of(cm_id, struc [all...] |
/freebsd-13-stable/sys/dev/qlnx/qlnxr/ |
H A D | qlnxr_verbs.h | 243 extern int qlnxr_iw_connect(struct iw_cm_id *cm_id, 246 extern int qlnxr_iw_create_listen(struct iw_cm_id *cm_id, int backlog); 248 void qlnxr_iw_destroy_listen(struct iw_cm_id *cm_id); 250 extern int qlnxr_iw_accept(struct iw_cm_id *cm_id, 253 extern int qlnxr_iw_reject(struct iw_cm_id *cm_id, const void *pdata, u8 pdata_len);
|
H A D | qlnxr_verbs.c | 6499 listener->cm_id->event_handler(listener->cm_id, &event); 6543 if (ep->cm_id) 6544 ep->cm_id->event_handler(ep->cm_id, &event); 6546 QL_DPRINT11(ha, "ep->cm_id == NULL \n"); 6568 if (ep->cm_id) { 6573 ep->cm_id->rem_ref(ep->cm_id); 6574 ep->cm_id 6908 qlnxr_iw_connect(struct iw_cm_id *cm_id, struct iw_cm_conn_param *conn_param) argument 7014 qlnxr_iw_create_listen(struct iw_cm_id *cm_id, int backlog) argument 7085 qlnxr_iw_destroy_listen(struct iw_cm_id *cm_id) argument 7107 qlnxr_iw_accept(struct iw_cm_id *cm_id, struct iw_cm_conn_param *conn_param) argument 7158 qlnxr_iw_reject(struct iw_cm_id *cm_id, const void *pdata, u8 pdata_len) argument [all...] |
H A D | qlnxr_def.h | 748 struct iw_cm_id *cm_id; member in struct:qlnxr_iw_listener 755 struct iw_cm_id *cm_id; member in struct:qlnxr_iw_ep
|
H A D | qlnxr_os.c | 141 __qlnxr_iw_destroy_listen(struct iw_cm_id *cm_id) argument 143 qlnxr_iw_destroy_listen(cm_id);
|
/freebsd-13-stable/contrib/ofed/librdmacm/examples/ |
H A D | rping.c | 155 struct rdma_cm_id *cm_id; /* connection on client side,*/ member in struct:rping_cb 168 (cma_id == cb->cm_id) ? "parent" : "child"); 499 ret = rdma_create_qp(cb->cm_id, cb->pd, &init_attr); 501 cb->qp = cb->cm_id->qp; 515 static int rping_setup_qp(struct rping_cb *cb, struct rdma_cm_id *cm_id) argument 519 cb->pd = ibv_alloc_pd(cm_id->verbs); 526 cb->channel = ibv_create_comp_channel(cm_id->verbs); 534 cb->cq = ibv_create_cq(cm_id->verbs, RPING_SQ_DEPTH * 2, cb, 740 ret = rdma_bind_addr(cb->cm_id, (struct sockaddr *) &cb->sin); 748 ret = rdma_listen(cb->cm_id, [all...] |
/freebsd-13-stable/sys/ofed/drivers/infiniband/ulp/ipoib/ |
H A D | ipoib_cm.c | 83 static int ipoib_cm_tx_handler(struct ib_cm_id *cm_id, 235 struct ib_cm_id *cm_id, struct ib_qp *qp, 242 ret = ib_cm_init_qp_attr(cm_id, &qp_attr, &qp_attr_mask); 253 ret = ib_cm_init_qp_attr(cm_id, &qp_attr, &qp_attr_mask); 274 ret = ib_cm_init_qp_attr(cm_id, &qp_attr, &qp_attr_mask); 303 struct ib_cm_id *cm_id, struct ipoib_cm_rx *rx) 333 ib_send_cm_rej(cm_id, IB_CM_REJ_NO_QP, NULL, 0, NULL, 0); 374 static int ipoib_cm_send_rep(struct ipoib_dev_priv *priv, struct ib_cm_id *cm_id, argument 391 return ib_send_cm_rep(cm_id, &rep); 394 static int ipoib_cm_req_handler(struct ib_cm_id *cm_id, struc argument 234 ipoib_cm_modify_rx_qp(struct ipoib_dev_priv *priv, struct ib_cm_id *cm_id, struct ib_qp *qp, unsigned psn) argument 302 ipoib_cm_nonsrq_init_rx(struct ipoib_dev_priv *priv, struct ib_cm_id *cm_id, struct ipoib_cm_rx *rx) argument 454 ipoib_cm_rx_handler(struct ib_cm_id *cm_id, struct ib_cm_event *event) argument 847 ipoib_cm_rep_handler(struct ib_cm_id *cm_id, struct ib_cm_event *event) argument 982 ipoib_cm_modify_tx_init(struct ipoib_dev_priv *priv, struct ib_cm_id *cm_id, struct ib_qp *qp) argument 1114 ipoib_cm_tx_handler(struct ib_cm_id *cm_id, struct ib_cm_event *event) argument [all...] |
/freebsd-13-stable/sys/dev/cxgbe/iw_cxgbe/ |
H A D | cm.c | 196 epc->cm_id->rem_ref(epc->cm_id); 197 epc->cm_id = NULL; 204 epc->cm_id->add_ref(epc->cm_id); 416 if (ep->com.cm_id && ep->com.qp) { 650 if (ep->com.cm_id && ep->com.qp) { 727 if (ep->com.cm_id && ep->com.qp) { 772 /* The cm_id may be null if we failed to connect */ 788 if ((ep->com.cm_id) 2355 c4iw_reject_cr(struct iw_cm_id *cm_id, const void *pdata, u8 pdata_len) argument 2392 c4iw_accept_cr(struct iw_cm_id *cm_id, struct iw_cm_conn_param *conn_param) argument 2584 c4iw_connect(struct iw_cm_id *cm_id, struct iw_cm_conn_param *conn_param) argument 2695 c4iw_create_listen(struct iw_cm_id *cm_id, int backlog) argument 2775 c4iw_destroy_listen(struct iw_cm_id *cm_id) argument [all...] |
H A D | iw_cxgbe.h | 823 struct iw_cm_id *cm_id; member in struct:c4iw_ep_common 876 static inline struct c4iw_ep *to_ep(struct iw_cm_id *cm_id) argument 878 return cm_id->provider_data; 881 static inline struct c4iw_listen_ep *to_listen_ep(struct iw_cm_id *cm_id) argument 883 return cm_id->provider_data; 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, cons [all...] |
/freebsd-13-stable/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) argument 80 msg->request_id = cpu_to_be32(cm_id); 86 msg->local_comm_id = cpu_to_be32(cm_id); 105 static void set_remote_comm_id(struct ib_mad *mad, u32 cm_id) argument 110 msg->request_id = cpu_to_be32(cm_id); 116 msg->remote_comm_id = cpu_to_be32(cm_id); 220 pr_debug("overriding existing sl_id_map entry (cm_id = %x)\n",
|
/freebsd-13-stable/sys/contrib/rdma/krping/ |
H A D | krping.c | 241 struct rdma_cm_id *cm_id; /* connection on client side,*/ member in struct:krping_cb 254 (cma_id == cb->cm_id) ? "parent" : "child"); 638 ret = rdma_create_qp(cb->cm_id, cb->pd, &init_attr); 640 cb->qp = cb->cm_id->qp; 653 static int krping_setup_qp(struct krping_cb *cb, struct rdma_cm_id *cm_id) argument 658 cb->pd = ib_alloc_pd(cm_id->device, 0); 669 cb->cq = ib_create_cq(cm_id->device, krping_cq_event_handler, NULL, 1408 ret = rdma_bind_addr(cb->cm_id, (struct sockaddr *)&sin); 1416 ret = rdma_listen(cb->cm_id, 3); 1739 rdma_disconnect(cb->cm_id); [all...] |
/freebsd-13-stable/sys/dev/xen/blkfront/ |
H A D | block.h | 117 uint64_t cm_id; member in struct:xbd_command
|
H A D | blkfront.c | 239 ring_req->id = cm->cm_id; 256 ring_req->id = cm->cm_id; 1358 cm->cm_id = i;
|