Lines Matching refs:chanp

557 		sol_ucma_chan_t	*chanp;
560 chanp = (sol_ucma_chan_t *)entry->data;
561 mutex_enter(&chanp->chan_mutex);
562 if (chanp->chan_rdma_id)
563 (chanp->chan_rdma_id)->context = NULL;
564 mutex_exit(&chanp->chan_mutex);
565 rdma_destroy_id(chanp->chan_rdma_id);
567 mutex_enter(&chanp->chan_mutex);
568 qphdl = chanp->chan_qp_hdl;
569 chanp->chan_qp_hdl = NULL;
570 mutex_exit(&chanp->chan_mutex);
574 ucma_free_chan(chanp, 1);
805 sol_ucma_chan_t *chanp;
820 chanp = ucma_alloc_chan(filep, ucma_id_inp);
821 if (chanp == NULL) {
827 ucma_id_resp.id = chanp->chan_id;
838 ucma_free_chan(chanp, 1);
844 chanp->chan_rdma_id = rdma_create_id(sol_ucma_evt_hdlr,
845 chanp, ucma_id_inp->ps);
846 if (chanp->chan_rdma_id == NULL) {
849 ucma_free_chan(chanp, 1);
853 mutex_enter(&chanp->chan_mutex);
854 (chanp->chan_rdma_id)->context = chanp;
855 mutex_exit(&chanp->chan_mutex);
856 rdma_map_id2clnthdl(chanp->chan_rdma_id, sol_ucma.ucma_ib_clnt_hdl,
868 sol_ucma_chan_t *chanp;
881 if (!get_file_chan(ucma_id, &filep, &chanp, "destroy_id", 0)) {
895 SOL_OFS_DPRINTF_L5(sol_ucma_dbg_str, "destroy_id: chanp %p", chanp);
915 if (chanp) {
916 mutex_enter(&chanp->chan_mutex);
917 id_resp.events_reported = chanp->chan_evt_cnt;
918 mutex_exit(&chanp->chan_mutex);
923 SOL_OFS_DPRINTF_L5(sol_ucma_dbg_str, "destroy_id : chanp %p, "
924 "evts %x", chanp, id_resp.events_reported);
940 if (chanp) {
941 mutex_enter(&chanp->chan_mutex);
942 if (chanp->chan_rdma_id)
943 (chanp->chan_rdma_id)->context = NULL;
944 mutex_exit(&chanp->chan_mutex);
945 rdma_destroy_id(chanp->chan_rdma_id);
946 ucma_free_chan(chanp, 1);
959 sol_ucma_chan_t *chanp;
968 if (get_file_chan(ucma_id, NULL, &chanp, "bind_addr", 1))
970 SOL_OFS_DPRINTF_L5(sol_ucma_dbg_str, "bind_addr - chanp %p", chanp);
972 ret = rdma_bind_addr(chanp->chan_rdma_id,
982 sol_ucma_chan_t *chanp;
992 if (get_file_chan(ucma_id, NULL, &chanp, "resolve_addr", 1)) {
997 ASSERT(chanp);
998 SOL_OFS_DPRINTF_L5(sol_ucma_dbg_str, "resolve_addr - chanp %p", chanp);
1000 ret = rdma_resolve_addr(chanp->chan_rdma_id,
1012 sol_ucma_chan_t *chanp;
1022 if (get_file_chan(ucma_id, NULL, &chanp, "resolve_route", 1))
1024 ASSERT(chanp);
1025 SOL_OFS_DPRINTF_L5(sol_ucma_dbg_str, "resolve_route - chanp %p",
1026 chanp);
1028 ret = rdma_resolve_route(chanp->chan_rdma_id,
1038 sol_ucma_chan_t *chanp;
1049 if (get_file_chan(ucma_id, NULL, &chanp, "query_route", 1))
1051 ASSERT(chanp);
1052 SOL_OFS_DPRINTF_L5(sol_ucma_dbg_str, "query_route - chanp %p", chanp);
1053 idp = chanp->chan_rdma_id;
1077 sol_ucma_chan_t *chanp;
1090 if (get_file_chan(ucma_id, NULL, &chanp, "connect", 1))
1092 ASSERT(chanp);
1093 SOL_OFS_DPRINTF_L5(sol_ucma_dbg_str, "connect - chanp %p", chanp);
1106 rdma_map_id2qphdl(chanp->chan_rdma_id, qphdl);
1107 idp = chanp->chan_rdma_id;
1111 chanp->chan_qp_num = conn_param.qp_num;
1112 ret = rdma_connect(chanp->chan_rdma_id, &conn_param);
1119 mutex_enter(&chanp->chan_mutex);
1120 chanp->chan_qp_hdl = qphdl;
1121 chanp->chan_flags |= SOL_UCMA_CHAN_CONNECT_FLAG;
1122 mutex_exit(&chanp->chan_mutex);
1135 sol_ucma_chan_t *chanp;
1145 if (get_file_chan(ucma_id, NULL, &chanp, "listen", 1))
1147 ASSERT(chanp);
1148 SOL_OFS_DPRINTF_L5(sol_ucma_dbg_str, "listen - chanp %p", chanp);
1153 chanp->chan_backlog = listenp->backlog;
1155 ret = rdma_listen(chanp->chan_rdma_id, listenp->backlog);
1166 sol_ucma_chan_t *chanp;
1176 if (get_file_chan(ucma_id, NULL, &chanp, "accept", 1))
1178 ASSERT(chanp);
1179 SOL_OFS_DPRINTF_L5(sol_ucma_dbg_str, "accept - chanp %p", chanp);
1184 chanp->chan_user_id = acpt->uid;
1195 rdma_map_id2qphdl(chanp->chan_rdma_id, qphdl);
1196 idp = chanp->chan_rdma_id;
1200 chanp->chan_qp_num = conn_param.qp_num;
1201 ret = rdma_accept(chanp->chan_rdma_id, &conn_param);
1203 ret = rdma_accept(chanp->chan_rdma_id, NULL);
1215 sol_ucma_chan_t *chanp;
1222 if (get_file_chan(ucma_id, NULL, &chanp, "reject", 1))
1224 ASSERT(chanp);
1225 SOL_OFS_DPRINTF_L5(sol_ucma_dbg_str, "reject - chanp %p", chanp);
1227 ret = rdma_reject(chanp->chan_rdma_id, rjct->private_data,
1241 sol_ucma_chan_t *chanp;
1251 if (get_file_chan(ucma_id, NULL, &chanp, "init_qp_attr", 1))
1253 ASSERT(chanp);
1254 SOL_OFS_DPRINTF_L5(sol_ucma_dbg_str, "init_qp_attr - chanp %p", chanp);
1257 if ((ret = rdma_init_qp_attr(chanp->chan_rdma_id, &qp_attr,
1473 sol_ucma_chan_t *chanp;
1482 if (get_file_chan(ucma_id, NULL, &chanp, "join_mcast", 1))
1488 mcastp->mcast_chan = chanp;
1498 rc = rdma_join_multicast(chanp->chan_rdma_id,
1520 rdma_leave_multicast(chanp->chan_rdma_id,
1540 sol_ucma_chan_t *chanp;
1554 chanp = mcastp->mcast_chan;
1556 rdma_leave_multicast(chanp->chan_rdma_id, &mcastp->mcast_addr);
1831 ucma_free_chan(sol_ucma_chan_t *chanp, int delete_list)
1835 ASSERT(chanp);
1837 filep = chanp->chan_file;
1840 delete_genlist(&filep->file_id_list, chanp->chan_list_ent);
1844 mutex_destroy(&chanp->chan_mutex);
1845 rw_enter(&(chanp->chan_uobj.uo_lock), RW_WRITER);
1846 (void) sol_ofs_uobj_remove(&ucma_ctx_uo_tbl, &(chanp->chan_uobj));
1847 rw_exit(&(chanp->chan_uobj.uo_lock));
1848 sol_ofs_uobj_free(&(chanp->chan_uobj));
1853 sol_ucma_chan_t **chanp, char *caller, int flag_err)
1859 if (chanp)
1860 *chanp = NULL;
1876 if (chanp)
1877 *chanp = chan;