Lines Matching defs:chanp
101 sol_cma_chan_t *chanp = (sol_cma_chan_t *)idp;
106 ASSERT(chanp);
107 ibchanp = &(chanp->chan_ib);
147 sol_cma_chan_t *chanp = (sol_cma_chan_t *)idp;
154 ASSERT(chanp);
155 ibchanp = &(chanp->chan_ib);
170 ret = ibcma_query_local_ip(idp, chanp, ibchanp);
178 chanp->chan_xport_type = SOL_CMA_XPORT_IB;
190 sol_cma_chan_t *chanp = (sol_cma_chan_t *)idp;
198 ASSERT(chanp);
199 ibchanp = &(chanp->chan_ib);
253 cma_resolve_addr_callback(chanp, 0);
257 if ((ret = ibcma_get_paths(idp, chanp, ibchanp)) == 0)
258 chanp->chan_xport_type = SOL_CMA_XPORT_IB;
291 sol_cma_chan_t *chanp;
297 chanp = (sol_cma_chan_t *)idp;
298 ibchanp = &chanp->chan_ib;
360 sol_cma_chan_t *chanp;
365 chanp = (sol_cma_chan_t *)idp;
366 ibchanp = &chanp->chan_ib;
370 ASSERT(chanp->chan_xport_type == SOL_CMA_XPORT_IB);
621 sol_cma_chan_t *chanp;
628 chanp = (sol_cma_chan_t *)idp;
629 ibchanp = &chanp->chan_ib;
633 if (chanp->chan_session_id == NULL) {
650 (ibt_channel_hdl_t)chanp->chan_qp_hdl;
670 chanp->chan_session_id, IBT_CM_ACCEPT, &cm_reply,
681 chanp->chan_session_id = NULL;
683 ibt_qp_hdl_t qphdl = chanp->chan_qp_hdl;
697 status = ibt_cm_ud_proceed(chanp->chan_session_id, qphdl,
717 sol_cma_chan_t *chanp;
722 chanp = (sol_cma_chan_t *)idp;
727 if (chanp->chan_session_id == NULL) {
750 chanp->chan_session_id, IBT_CM_REJECT, &cm_reply,
762 status = ibt_cm_ud_proceed(chanp->chan_session_id, NULL,
781 sol_cma_chan_t *root_chanp, *chanp;
787 chanp = (sol_cma_chan_t *)idp;
789 root_idp = CHAN_LISTEN_ROOT(chanp);
794 mutex_enter(&chanp->chan_mutex);
795 if (chanp->chan_req_state == REQ_CMID_NOTIFIED ||
796 chanp->chan_req_state == REQ_CMID_CREATED) {
797 CHAN_LISTEN_ROOT(chanp) = NULL;
798 mutex_exit(&chanp->chan_mutex);
801 status = ibt_cm_ud_proceed(chanp->chan_session_id,
814 chanp->chan_session_id, IBT_CM_REJECT, &cm_reply,
824 mutex_enter(&chanp->chan_mutex);
825 if (REQ_CMID_IN_REQ_AVL_TREE(chanp)) {
827 chanp->chan_session_id));
829 chanp->chan_req_state = REQ_CMID_SERVER_NONE;
831 mutex_exit(&chanp->chan_mutex);
834 mutex_exit(&chanp->chan_mutex);
841 mutex_enter(&chanp->chan_mutex);
842 if (idp->ps == RDMA_PS_TCP && chanp->chan_qp_hdl &&
843 SOL_CMID_CLOSE_REQUIRED(chanp)) {
845 void *qp_hdl = chanp->chan_qp_hdl;
852 mode = (chanp->chan_cmid_destroy_state &
855 mutex_exit(&chanp->chan_mutex);
865 mutex_exit(&chanp->chan_mutex);
874 sol_cma_chan_t *chanp = (sol_cma_chan_t *)idp;
884 ibchanp = &chanp->chan_ib;
957 sol_cma_chan_t *chanp = (sol_cma_chan_t *)idp;
964 ibchanp = &chanp->chan_ib;
996 sol_cma_chan_t *chanp = (sol_cma_chan_t *)idp;
1059 chanp->chan_qp_hdl, cep_flags);
1060 status = ibt_modify_rdma(chanp->chan_qp_hdl,
1072 chanp->chan_connect_flag = SOL_CMA_CONNECT_INITIATED;
1073 status = ibt_open_rc_channel(chanp->chan_qp_hdl, flags,
1080 chanp->chan_connect_flag = SOL_CMA_CONNECT_CLIENT_NONE;
1098 sol_cma_chan_t *chanp = (sol_cma_chan_t *)idp;
1138 chanp->chan_connect_flag = SOL_CMA_CONNECT_INITIATED;
1145 chanp->chan_connect_flag = SOL_CMA_CONNECT_CLIENT_NONE;
1198 ibcma_query_local_ip(struct rdma_cm_id *idp, sol_cma_chan_t *chanp,
1217 if ((status = ibt_get_ip_paths(chanp->chan_ib_client_hdl,
1247 sol_cma_chan_t *chanp = (sol_cma_chan_t *)arg;
1248 ibcma_chan_t *ibchanp = &(chanp->chan_ib);
1254 cma_resolve_addr_callback(chanp, 1);
1270 if (ibcma_init_devinfo((struct rdma_cm_id *)chanp,
1274 cma_resolve_addr_callback(chanp, 1);
1281 cma_resolve_addr_callback(chanp, 1);
1296 cma_resolve_addr_callback(chanp, 0);
1301 ibcma_get_paths(struct rdma_cm_id *idp, sol_cma_chan_t *chanp,
1324 status = ibt_aget_ip_paths(chanp->chan_ib_client_hdl, IBT_PATH_NO_FLAGS,
1349 sol_cma_chan_t *root_chanp, *chanp, *event_chanp;
1361 chanp = (sol_cma_chan_t *)idp;
1362 ibchanp = &chanp->chan_ib;
1363 root_idp = CHAN_LISTEN_ROOT(chanp);
1474 ASSERT(chanp->chan_connect_flag == SOL_CMA_CONNECT_INITIATED);
1475 mutex_enter(&chanp->chan_mutex);
1476 chanp->chan_connect_flag = SOL_CMA_CONNECT_CLIENT_NONE;
1477 chanp->chan_cmid_destroy_state |= SOL_CMA_CALLER_EVENT_PROGRESS;
1478 mutex_exit(&chanp->chan_mutex);
1526 sol_cma_chan_t *root_chanp, *event_chanp, *chanp;
1542 chanp = (sol_cma_chan_t *)idp;
1543 ibchanp = &chanp->chan_ib;
1544 root_idp = CHAN_LISTEN_ROOT(chanp);
1546 ASSERT(chanp->chan_listenp);
1716 sol_cma_chan_t *chanp;
1720 chanp = (sol_cma_chan_t *)idp;
1722 paramp = &chanp->chan_param;
1723 bzero(paramp, sizeof (chanp->chan_param));
1749 sol_cma_chan_t *event_chanp, *chanp, *root_chanp;
1753 chanp = (sol_cma_chan_t *)idp;
1754 if (chanp->chan_listenp == NULL) {
1755 ASSERT(chanp->chan_connect_flag == SOL_CMA_CONNECT_INITIATED);
1756 chanp->chan_connect_flag = SOL_CMA_CONNECT_ESTABLISHED;
1758 bcopy(&chanp->chan_param, paramp,
1763 bcopy((void *)((chanp->chan_param).private_data),
1766 kmem_free((void *)((chanp->chan_param).private_data),
1769 event_chanp = chanp;
1770 mutex_enter(&chanp->chan_mutex);
1771 chanp->chan_cmid_destroy_state |= SOL_CMA_CALLER_EVENT_PROGRESS;
1772 mutex_exit(&chanp->chan_mutex);
1776 root_idp = CHAN_LISTEN_ROOT((chanp));
1818 sol_cma_chan_t *chanp, *root_chanp, *event_chanp;
1822 chanp = (sol_cma_chan_t *)idp;
1823 mutex_enter(&chanp->chan_mutex);
1824 root_idp = CHAN_LISTEN_ROOT((chanp));
1826 chanp->chan_qp_hdl = NULL;
1828 chanp->chan_cmid_destroy_state |=
1830 chanp->chan_qp_hdl = NULL;
1831 chanp->chan_connect_flag = SOL_CMA_CONNECT_CLIENT_NONE;
1832 mutex_exit(&chanp->chan_mutex);
1836 mutex_exit(&chanp->chan_mutex);
1868 sol_cma_chan_t *event_chanp, *chanp, *root_chanp;
1876 chanp = (sol_cma_chan_t *)idp;
1877 root_idp = CHAN_LISTEN_ROOT((chanp));
1934 mutex_enter(&chanp->chan_mutex);
1935 chanp->chan_cmid_destroy_state |=
1937 chanp->chan_qp_hdl = NULL;
1938 chanp->chan_connect_flag =
1940 mutex_exit(&chanp->chan_mutex);
1987 mutex_enter(&chanp->chan_mutex);
1988 chanp->chan_cmid_destroy_state |=
1990 chanp->chan_qp_hdl = NULL;
1991 chanp->chan_connect_flag =
1993 mutex_exit(&chanp->chan_mutex);
2012 sol_cma_chan_t *chanp;
2022 chanp = (sol_cma_chan_t *)idp;
2023 chanp->chan_session_id = NULL;
2160 sol_cma_chan_t *chanp = (sol_cma_chan_t *)idp;
2169 ibchanp = &(chanp->chan_ib);
2173 ibcma_get_devlist(chanp, hca_guidp, num_hcas, &devlist, B_TRUE);
2180 chanp->chan_xport_type = SOL_CMA_XPORT_IB;
2419 sol_cma_chan_t *chanp, *new_chanp;
2427 chanp = (sol_cma_chan_t *)idp;
2428 ibchanp = &chanp->chan_ib;