of/sol_ofs/sol_cma.c

278 			sol_cma_chan_t	*root_chanp;
282 			root_chanp = (sol_cma_chan_t *)ep_chanp->listen_root;
283 			root_chanp->chan_listenp->listen_eps--;
284 			delete_genlist(&root_chanp->chan_listenp->listen_list,
448 	sol_cma_chan_t		*chanp, *root_chanp;
460 	root_chanp = (sol_cma_chan_t *)chanp->listen_root;
462 	    rdma_idp, root_chanp);
483 	if (root_chanp == NULL && is_root_cmid == 0)
563 	if (root_chanp)
564 		mutex_enter(&root_chanp->chan_mutex);
568 	    "root_idp %p, cnt %x, state %x", root_chanp,
569 	    root_chanp ? root_chanp->chan_req_total_cnt : 0,
570 	    root_chanp ? cma_get_chan_state(root_chanp) : 0);
573 	if (root_chanp && root_chanp->chan_req_total_cnt == 1 &&
574 	    cma_get_chan_state(root_chanp) == SOL_CMA_CHAN_DESTROY_PENDING)
576 	if (root_chanp)
577 		mutex_exit(&root_chanp->chan_mutex);
596 		if (root_chanp && chanp->listen_root == NULL)
597 			chanp->listen_root = (struct rdma_cm_id *)root_chanp;
1027 	sol_cma_chan_t		*root_chanp, *chanp;
1047 	root_chanp = (sol_cma_chan_t *)root_idp;
1057 		    "REQ AVL remove %p", root_chanp, idp);
1058 		mutex_enter(&root_chanp->chan_mutex);
1067 			mutex_exit(&root_chanp->chan_mutex);
1070 			    "AVL tree",  root_chanp, chanp);
1074 		avl_remove(&root_chanp->chan_req_avl_tree, idp);
1080 		find_ret = avl_find(&root_chanp->chan_acpt_avl_tree,
1085 			mutex_exit(&root_chanp->chan_mutex);
1092 		avl_insert(&root_chanp->chan_acpt_avl_tree,
1096 		mutex_exit(&root_chanp->chan_mutex);
1131 		mutex_enter(&root_chanp->chan_mutex);
1136 			avl_remove(&root_chanp->chan_acpt_avl_tree,
1138 			find_ret = avl_find(&root_chanp->chan_req_avl_tree,
1143 				mutex_exit(&root_chanp->chan_mutex);
1150 			avl_insert(&root_chanp->chan_req_avl_tree, idp, where);
1154 		mutex_exit(&root_chanp->chan_mutex);
1189 	sol_cma_chan_t		*root_chanp, *chanp;
1195 	root_chanp = (sol_cma_chan_t *)root_idp;
1211 		    "REQ AVL remove %p", root_chanp, idp);
1217 		mutex_enter(&root_chanp->chan_mutex);
1222 			mutex_exit(&root_chanp->chan_mutex);
1225 			    "AVL tree",  root_chanp, chanp);
1229 		avl_remove(&root_chanp->chan_req_avl_tree, idp);
1232 		mutex_exit(&root_chanp->chan_mutex);
1264 		mutex_enter(&root_chanp->chan_mutex);
1267 			if (avl_find(&root_chanp->chan_req_avl_tree,
1270 				mutex_exit(&root_chanp->chan_mutex);
1277 			avl_insert(&root_chanp->chan_req_avl_tree,
1282 		mutex_exit(&root_chanp->chan_mutex);
1710 	sol_cma_chan_t		*root_chanp;
1740 	root_chanp = (sol_cma_chan_t *)root_idp;
1750 		mutex_enter(&root_chanp->chan_mutex);
1751 		root_chanp->chan_req_cnt--;
1755 		    root_idp, idp, root_chanp->chan_req_cnt);
1757 		mutex_exit(&root_chanp->chan_mutex);
2077 		sol_cma_chan_t		*root_chanp;
2080 		root_chanp = (sol_cma_chan_t *)root_idp;
2081 		mutex_enter(&root_chanp->chan_mutex);
2082 		state = cma_get_chan_state(root_chanp);
2083 		acpt_nodes = avl_numnodes(&root_chanp->chan_acpt_avl_tree);
2084 		req_nodes = avl_numnodes(&root_chanp->chan_req_avl_tree);
2085 		mutex_exit(&root_chanp->chan_mutex);
2092 			mutex_enter(&root_chanp->chan_mutex);
2093 			root_chanp->chan_req_state = REQ_CMID_SERVER_NONE;
2094 			mutex_exit(&root_chanp->chan_mutex);
2098 			mutex_enter(&root_chanp->chan_mutex);
2099 			cma_set_chan_state(root_chanp,
2101 			root_chanp->chan_req_state = REQ_CMID_SERVER_NONE;
2102 			cv_broadcast(&root_chanp->chan_destroy_cv);
2103 			mutex_exit(&root_chanp->chan_mutex);
2124 	sol_cma_chan_t		*root_chanp;
2130 	root_chanp = (sol_cma_chan_t *)root_idp;
2131 	if (!root_chanp)
2134 	mutex_enter(&root_chanp->chan_mutex);
2137 	root_chanp->chan_req_total_cnt--;
2147 		avl_remove(&root_chanp->chan_acpt_avl_tree, idp);
2154 		avl_remove(&root_chanp->chan_req_avl_tree, idp);
2158 	state = cma_get_chan_state(root_chanp);
2159 	req_nodes = avl_numnodes(&root_chanp->chan_req_avl_tree);
2160 	acpt_nodes = avl_numnodes(&root_chanp->chan_acpt_avl_tree);
2162 	mutex_exit(&root_chanp->chan_mutex);