/freebsd-10.2-release/sys/ofed/include/rdma/ |
H A D | iw_cm.h | 73 * @cm_id: The IW CM identifier associated with the event. 76 typedef int (*iw_cm_handler)(struct iw_cm_id *cm_id, 84 * @cm_id: The IW CM identifier associated with the event. 87 typedef int (*iw_event_handler)(struct iw_cm_id *cm_id, 99 /* Used by provider to add and remove refs on IW cm_id */ 121 int (*connect)(struct iw_cm_id *cm_id, 124 int (*accept)(struct iw_cm_id *cm_id, 127 int (*reject)(struct iw_cm_id *cm_id, 130 int (*create_listen)(struct iw_cm_id *cm_id, 133 int (*destroy_listen)(struct iw_cm_id *cm_id); [all...] |
H A D | ib_cm.h | 279 * @cm_id: Communication identifier associated with the reported event. 284 * new @cm_id. The new @cm_id is returned to the user through this callback. 285 * Clients are responsible for destroying the new @cm_id. For peer-to-peer 286 * IB_CM_REQ_RECEIVED and all other events, the returned @cm_id corresponds 291 * destroy the @cm_id after the callback completes. 293 typedef int (*ib_cm_handler)(struct ib_cm_id *cm_id, 311 * @device: Device associated with the cm_id. All related communication will 326 * @cm_id: Connection identifier to destroy. 330 void ib_destroy_cm_id(struct ib_cm_id *cm_id); [all...] |
/freebsd-10.2-release/contrib/ofed/libibcm/include/infiniband/ |
H A D | cm.h | 230 struct ib_cm_id *cm_id; member in struct:ib_cm_event 258 * new @cm_id. 259 * Clients are responsible for destroying the new @cm_id. For peer-to-peer 260 * IB_CM_REQ_RECEIVED and all other events, the returned @cm_id corresponds 303 struct ib_cm_id **cm_id, void *context); 307 * @cm_id: Connection identifier to destroy. 309 int ib_cm_destroy_id(struct ib_cm_id *cm_id); 320 * @cm_id: Connection identifier to retrieve attributes. 325 int ib_cm_attr_id(struct ib_cm_id *cm_id, 334 * @cm_id [all...] |
/freebsd-10.2-release/contrib/ofed/libibcm/src/ |
H A D | cm.c | 259 struct ib_cm_id **cm_id, void *context) 282 *cm_id = &cm_id_priv->id; 289 int ib_cm_destroy_id(struct ib_cm_id *cm_id) argument 299 cmd->id = cm_id->handle; 301 result = write(cm_id->device->fd, msg, size); 307 cm_id_priv = container_of(cm_id, struct cm_id_private, id); 318 int ib_cm_attr_id(struct ib_cm_id *cm_id, struct ib_cm_attr_param *param) argument 330 cmd->id = cm_id->handle; 332 result = write(cm_id->device->fd, msg, size); 345 int ib_cm_init_qp_attr(struct ib_cm_id *cm_id, argument 258 ib_cm_create_id(struct ib_cm_device *device, struct ib_cm_id **cm_id, void *context) argument 374 ib_cm_listen(struct ib_cm_id *cm_id, uint64_t service_id, uint64_t service_mask) argument 395 ib_cm_send_req(struct ib_cm_id *cm_id, struct ib_cm_req_param *param) argument 454 ib_cm_send_rep(struct ib_cm_id *cm_id, struct ib_cm_rep_param *param) argument 489 cm_send_private_data(struct ib_cm_id *cm_id, uint32_t type, void *private_data, uint8_t private_data_len) argument 514 ib_cm_send_rtu(struct ib_cm_id *cm_id, void *private_data, uint8_t private_data_len) argument 522 ib_cm_send_dreq(struct ib_cm_id *cm_id, void *private_data, uint8_t private_data_len) argument 530 ib_cm_send_drep(struct ib_cm_id *cm_id, void *private_data, uint8_t private_data_len) argument 538 cm_establish(struct ib_cm_id *cm_id) argument 555 ib_cm_notify(struct ib_cm_id *cm_id, enum ibv_event_type event) argument 580 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 614 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 626 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 638 ib_cm_send_mra(struct ib_cm_id *cm_id, uint8_t service_timeout, void *private_data, uint8_t private_data_len) argument 664 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 699 ib_cm_send_sidr_req(struct ib_cm_id *cm_id, struct ib_cm_sidr_req_param *param) argument 739 ib_cm_send_sidr_rep(struct ib_cm_id *cm_id, struct ib_cm_sidr_rep_param *param) argument [all...] |
/freebsd-10.2-release/sys/ofed/drivers/infiniband/core/ |
H A D | iwcm.c | 60 struct iwcm_id_private *cm_id; member in struct:iwcm_work 68 * elements. The design pre-allocates them based on the cm_id type: 78 * One exception is when creating the cm_id for incoming connection requests. 80 * 1) in the event upcall, cm_event_handler(), for a listening cm_id. If 85 * If work elements cannot be allocated for the new connect request cm_id, 104 list_add(&work->free_list, &work->cm_id->work_free_list); 126 work->cm_id = cm_id_priv; 156 * Release a reference on cm_id. If the last reference is being 172 static void add_ref(struct iw_cm_id *cm_id) argument 175 cm_id_priv = container_of(cm_id, struc 179 rem_ref(struct iw_cm_id *cm_id) argument 259 iw_cm_disconnect(struct iw_cm_id *cm_id, int abrupt) argument 326 destroy_cm_id(struct iw_cm_id *cm_id) argument 393 iw_destroy_cm_id(struct iw_cm_id *cm_id) argument 414 iw_cm_listen(struct iw_cm_id *cm_id, int backlog) argument 450 iw_cm_reject(struct iw_cm_id *cm_id, const void *private_data, u8 private_data_len) argument 488 iw_cm_accept(struct iw_cm_id *cm_id, struct iw_cm_conn_param *iw_param) argument 542 iw_cm_connect(struct iw_cm_id *cm_id, struct iw_cm_conn_param *iw_param) argument 613 struct iw_cm_id *cm_id; local 896 cm_event_handler(struct iw_cm_id *cm_id, struct iw_cm_event *iw_event) argument 988 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 | ucma.c | 71 struct rdma_cm_id *cm_id; member in struct:ucma_context 92 struct rdma_cm_id *cm_id; member in struct:ucma_event 245 static int ucma_event_handler(struct rdma_cm_id *cm_id, argument 249 struct ucma_context *ctx = cm_id->context; 256 uevent->cm_id = cm_id; 260 if (cm_id->ps == RDMA_PS_UDP || cm_id->ps == RDMA_PS_IPOIB) 332 ctx->cm_id = uevent->cm_id; [all...] |
H A D | cm.c | 822 * The cm_id could be destroyed by the user before we exit timewait. 823 * To protect against this, we search for the cm_id after exiting 847 static void cm_destroy_id(struct ib_cm_id *cm_id, int err) argument 852 cm_id_priv = container_of(cm_id, struct cm_id_private, id); 855 switch (cm_id->state) { 857 cm_id->state = IB_CM_IDLE; 864 cm_id->state = IB_CM_IDLE; 875 ib_send_cm_rej(cm_id, IB_CM_REJ_TIMEOUT, 887 ib_send_cm_rej(cm_id, IB_CM_REJ_CONSUMER_DEFINED, 900 ib_send_cm_rej(cm_id, IB_CM_REJ_CONSUMER_DEFINE 931 ib_destroy_cm_id(struct ib_cm_id *cm_id) argument 937 ib_cm_listen(struct ib_cm_id *cm_id, __be64 service_id, __be64 service_mask, struct ib_cm_compare_data *compare_data) argument 1123 ib_send_cm_req(struct ib_cm_id *cm_id, struct ib_cm_req_param *param) argument 1542 struct ib_cm_id *cm_id; local 1658 ib_send_cm_rep(struct ib_cm_id *cm_id, struct ib_cm_rep_param *param) argument 1720 ib_send_cm_rtu(struct ib_cm_id *cm_id, const void *private_data, u8 private_data_len) argument 2009 ib_send_cm_dreq(struct ib_cm_id *cm_id, const void *private_data, u8 private_data_len) argument 2067 ib_send_cm_drep(struct ib_cm_id *cm_id, const void *private_data, u8 private_data_len) argument 2248 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 2413 ib_send_cm_mra(struct ib_cm_id *cm_id, u8 service_timeout, const void *private_data, u8 private_data_len) argument 2615 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 2788 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 2928 ib_send_cm_sidr_req(struct ib_cm_id *cm_id, struct ib_cm_sidr_req_param *param) argument 3000 struct ib_cm_id *cm_id; local 3077 ib_send_cm_sidr_rep(struct ib_cm_id *cm_id, struct ib_cm_sidr_rep_param *param) argument 3312 cm_establish(struct ib_cm_id *cm_id) argument 3361 cm_migrate(struct ib_cm_id *cm_id) argument 3381 ib_cm_notify(struct ib_cm_id *cm_id, enum ib_event_type event) argument 3603 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 | ucm.c | 80 struct ib_cm_id *cm_id; member in struct:ib_ucm_context 92 struct ib_cm_id *cm_id; member in struct:ib_ucm_event 165 ib_destroy_cm_id(uevent->cm_id); 352 static int ib_ucm_event_handler(struct ib_cm_id *cm_id, argument 359 ctx = cm_id->context; 366 uevent->cm_id = cm_id; 387 /* Destroy new cm_id's */ 430 ctx->cm_id = uevent->cm_id; 842 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 892 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 | cma.c | 164 } cm_id; member in struct:rdma_id_private 416 return (id_priv->id.device && id_priv->cm_id.ib); 650 if (!id_priv->cm_id.ib || cma_is_ud_ps(id_priv->id.ps)) 653 ret = ib_cm_init_qp_attr(id_priv->cm_id.ib, qp_attr, 659 if (!id_priv->cm_id.iw) { 663 ret = iw_cm_init_qp_attr(id_priv->cm_id.iw, qp_attr, 907 if (id_priv->cm_id.ib && !IS_ERR(id_priv->cm_id.ib)) 908 ib_destroy_cm_id(id_priv->cm_id.ib); 911 if (id_priv->cm_id 983 cma_ib_handler(struct ib_cm_id *cm_id, struct ib_cm_event *ib_event) argument 1169 cma_req_handler(struct ib_cm_id *cm_id, struct ib_cm_event *ib_event) argument 1355 iw_conn_req_handler(struct iw_cm_id *cm_id, struct iw_cm_event *iw_event) argument [all...] |
/freebsd-10.2-release/sys/dev/cxgb/ulp/iw_cxgb/ |
H A D | iw_cxgb_cm.c | 448 if (ep->com.cm_id) { 449 CTR3(KTR_IW_CXGB, "close complete delivered ep %p cm_id %p tid %d", 450 ep, ep->com.cm_id, ep->hwtid); 451 ep->com.cm_id->event_handler(ep->com.cm_id, &event); 452 ep->com.cm_id->rem_ref(ep->com.cm_id); 453 ep->com.cm_id = NULL; 478 if (ep->com.cm_id) { 479 CTR3(KTR_IW_CXGB, "peer close delivered ep %p cm_id 1168 iwch_reject_cr(struct iw_cm_id *cm_id, const void *pdata, u8 pdata_len) argument 1190 iwch_accept_cr(struct iw_cm_id *cm_id, struct iw_cm_conn_param *conn_param) argument 1286 is_loopback_dst(struct iw_cm_id *cm_id) argument 1299 iwch_connect(struct iw_cm_id *cm_id, struct iw_cm_conn_param *conn_param) argument 1377 iwch_create_listen(struct iw_cm_id *cm_id, int backlog) argument 1415 iwch_destroy_listen(struct iw_cm_id *cm_id) argument [all...] |
H A D | iw_cxgb_cm.h | 149 struct iw_cm_id *cm_id; member in struct:iwch_ep_common 191 static inline struct iwch_ep *to_ep(struct iw_cm_id *cm_id) argument 193 return cm_id->provider_data; 196 static inline struct iwch_listen_ep *to_listen_ep(struct iw_cm_id *cm_id) argument 198 return cm_id->provider_data; 233 int iwch_connect(struct iw_cm_id *cm_id, struct iw_cm_conn_param *conn_param); 234 int iwch_create_listen(struct iw_cm_id *cm_id, int backlog); 235 int iwch_destroy_listen(struct iw_cm_id *cm_id); 236 int iwch_reject_cr(struct iw_cm_id *cm_id, const void *pdata, u8 pdata_len); 237 int iwch_accept_cr(struct iw_cm_id *cm_id, struc [all...] |
/freebsd-10.2-release/sys/dev/cxgbe/iw_cxgbe/ |
H A D | cm.c | 310 ep->com.cm_id->rem_ref(ep->com.cm_id); 311 ep->com.cm_id = NULL; 363 if (ep->com.cm_id && ep->com.qp) { 447 if (ep->com.cm_id && ep->com.qp) { 494 /* The cm_id may be null if we failed to connect */ 510 if ((ep->com.cm_id) && (ep->com.qp)) { 688 child_ep->com.cm_id = NULL; 1218 if (ep->com.cm_id) { 1221 ep->com.cm_id 1866 c4iw_reject_cr(struct iw_cm_id *cm_id, const void *pdata, u8 pdata_len) argument 1897 c4iw_accept_cr(struct iw_cm_id *cm_id, struct iw_cm_conn_param *conn_param) argument 2030 c4iw_connect(struct iw_cm_id *cm_id, struct iw_cm_conn_param *conn_param) argument 2153 c4iw_create_listen(struct iw_cm_id *cm_id, int backlog) argument 2199 c4iw_destroy_listen(struct iw_cm_id *cm_id) argument [all...] |
H A D | iw_cxgbe.h | 747 struct iw_cm_id *cm_id; member in struct:c4iw_ep_common 800 static inline struct c4iw_ep *to_ep(struct iw_cm_id *cm_id) argument 802 return cm_id->provider_data; 805 static inline struct c4iw_listen_ep *to_listen_ep(struct iw_cm_id *cm_id) argument 807 return cm_id->provider_data; 854 int c4iw_connect(struct iw_cm_id *cm_id, struct iw_cm_conn_param *conn_param); 855 int c4iw_create_listen(struct iw_cm_id *cm_id, int backlog); 856 int c4iw_destroy_listen(struct iw_cm_id *cm_id); 857 int c4iw_accept_cr(struct iw_cm_id *cm_id, struct iw_cm_conn_param *conn_param); 858 int c4iw_reject_cr(struct iw_cm_id *cm_id, cons [all...] |
/freebsd-10.2-release/contrib/ofed/librdmacm/examples/ |
H A D | rping.c | 156 struct rdma_cm_id *cm_id; /* connection on client side,*/ member in struct:rping_cb 169 (cma_id == cb->cm_id) ? "parent" : "child"); 496 ret = rdma_create_qp(cb->cm_id, cb->pd, &init_attr); 498 cb->qp = cb->cm_id->qp; 512 static int rping_setup_qp(struct rping_cb *cb, struct rdma_cm_id *cm_id) argument 516 cb->pd = ibv_alloc_pd(cm_id->verbs); 523 cb->channel = ibv_create_comp_channel(cm_id->verbs); 531 cb->cq = ibv_create_cq(cm_id->verbs, RPING_SQ_DEPTH * 2, cb, 737 ret = rdma_bind_addr(cb->cm_id, (struct sockaddr *) &cb->sin); 745 ret = rdma_listen(cb->cm_id, [all...] |
/freebsd-10.2-release/sys/ofed/drivers/infiniband/ulp/ipoib/ |
H A D | ipoib_cm.c | 78 static int ipoib_cm_tx_handler(struct ib_cm_id *cm_id, 230 struct ib_cm_id *cm_id, struct ib_qp *qp, 237 ret = ib_cm_init_qp_attr(cm_id, &qp_attr, &qp_attr_mask); 248 ret = ib_cm_init_qp_attr(cm_id, &qp_attr, &qp_attr_mask); 269 ret = ib_cm_init_qp_attr(cm_id, &qp_attr, &qp_attr_mask); 298 struct ib_cm_id *cm_id, struct ipoib_cm_rx *rx) 328 ib_send_cm_rej(cm_id, IB_CM_REJ_NO_QP, NULL, 0, NULL, 0); 369 static int ipoib_cm_send_rep(struct ipoib_dev_priv *priv, struct ib_cm_id *cm_id, argument 386 return ib_send_cm_rep(cm_id, &rep); 389 static int ipoib_cm_req_handler(struct ib_cm_id *cm_id, struc argument 229 ipoib_cm_modify_rx_qp(struct ipoib_dev_priv *priv, struct ib_cm_id *cm_id, struct ib_qp *qp, unsigned psn) argument 297 ipoib_cm_nonsrq_init_rx(struct ipoib_dev_priv *priv, struct ib_cm_id *cm_id, struct ipoib_cm_rx *rx) argument 449 ipoib_cm_rx_handler(struct ib_cm_id *cm_id, struct ib_cm_event *event) argument 832 ipoib_cm_rep_handler(struct ib_cm_id *cm_id, struct ib_cm_event *event) argument 964 ipoib_cm_modify_tx_init(struct ipoib_dev_priv *priv, struct ib_cm_id *cm_id, struct ib_qp *qp) argument 1096 ipoib_cm_tx_handler(struct ib_cm_id *cm_id, struct ib_cm_event *event) argument [all...] |
/freebsd-10.2-release/sys/ofed/drivers/infiniband/hw/mlx4/ |
H A D | cm.c | 69 static void set_local_comm_id(struct ib_mad *mad, u32 cm_id) argument 72 msg->local_comm_id = cpu_to_be32(cm_id); 82 static void set_remote_comm_id(struct ib_mad *mad, u32 cm_id) argument 85 msg->remote_comm_id = cpu_to_be32(cm_id); 180 pr_debug("overriding existing sl_id_map entry (cm_id = %x)\n",
|
/freebsd-10.2-release/sys/contrib/rdma/krping/ |
H A D | krping.c | 235 struct rdma_cm_id *cm_id; /* connection on client side,*/ member in struct:krping_cb 248 cma_id, (cma_id == cb->cm_id) ? "parent" : "child"); 778 ret = rdma_create_qp(cb->cm_id, cb->pd, &init_attr); 780 cb->qp = cb->cm_id->qp; 793 static int krping_setup_qp(struct krping_cb *cb, struct rdma_cm_id *cm_id) argument 796 cb->pd = ib_alloc_pd(cm_id->device); 805 cb->cq = ib_create_cq(cm_id->device, krping_cq_event_handler, NULL, 1573 ret = rdma_bind_addr(cb->cm_id, (struct sockaddr *) &sin); 1581 ret = rdma_listen(cb->cm_id, 3); 2017 ret = rdma_connect(cb->cm_id, [all...] |
/freebsd-10.2-release/sys/dev/xen/blkfront/ |
H A D | block.h | 113 uint64_t cm_id; member in struct:xbd_command
|
H A D | blkfront.c | 186 ring_req->id = cm->cm_id; 1147 cm->cm_id = i;
|