mgt/ibmf/ibmf_impl.c

1357 ibmf_i_free_client(ibmf_client_t *clientp)
1360 	    IBMF_TNF_TRACE, "", "ibmf_i_free_client() enter, clientp = %p\n",
1361 	    tnf_opaque, clientp, clientp);
1364 	if (clientp->ic_kstatp != NULL) {
1365 		kstat_delete(clientp->ic_kstatp);
1366 		clientp->ic_kstatp = NULL;
1370 	if (clientp->ic_init_state_class & IBMF_CI_INIT_SEND_TASKQ_DONE) {
1371 		if ((clientp->ic_reg_flags & IBMF_REG_FLAG_NO_OFFLOAD) == 0) {
1372 			taskq_destroy(clientp->ic_send_taskq);
1374 		clientp->ic_init_state_class &= ~IBMF_CI_INIT_SEND_TASKQ_DONE;
1377 	if (clientp->ic_init_state_class & IBMF_CI_INIT_RECV_TASKQ_DONE) {
1378 		if ((clientp->ic_reg_flags & IBMF_REG_FLAG_NO_OFFLOAD) == 0) {
1379 			taskq_destroy(clientp->ic_recv_taskq);
1381 		clientp->ic_init_state_class &= ~IBMF_CI_INIT_RECV_TASKQ_DONE;
1384 	mutex_destroy(&clientp->ic_mutex);
1385 	mutex_destroy(&clientp->ic_msg_mutex);
1386 	mutex_destroy(&clientp->ic_kstat_mutex);
1387 	cv_destroy(&clientp->ic_recv_cb_teardown_cv);
1388 	kmem_free((void *)clientp, sizeof (ibmf_client_t));
1408 	    "clientp = %p\n", tnf_opaque, cip, ibmf_cip,
1458 	ibmf_client_t *clientp;
1471 	clientp = ibmf_cip->ci_clients;
1472 	while (clientp != NULL) {
1473 		ibmf_client_info_t *tmp = &clientp->ic_client_info;
1481 		clientp = clientp->ic_next;
1485 	if (clientp != NULL) {
1486 		*clientpp = clientp;
1489 		    "ibmf_i_lookup_client_by_info(): clientp = %p\n",
1490 		    tnf_opaque, clientp, clientp);
1509 	    "ibmf_i_add_client() enter, cip = %p, clientp = %p\n",
1539 	    "ibmf_i_delete_client() enter, cip = %p, clientp = %p\n",
1937 ibmf_i_alloc_msg(ibmf_client_t *clientp, ibmf_msg_impl_t **msgp, int km_flags)
1943 	    "ibmf_i_alloc_msg() enter, clientp = %p, msg = %p, "
1944 	    " kmflags = %d\n", tnf_opaque, clientp, clientp, tnf_opaque, msg,
1952 			ibmf_i_pop_ud_dest_thread(clientp->ic_myci);
1979 	ibmf_client_t *clientp = (ibmf_client_t *)msgimplp->im_client;
1988 		ibmf_i_free_ud_dest(clientp, msgimplp);
1989 		ibmf_i_clean_ud_dest_list(clientp->ic_myci, B_FALSE);
2000 		mutex_enter(&clientp->ic_kstat_mutex);
2001 		IBMF_SUB32_KSTATS(clientp, recv_bufs_alloced, 1);
2002 		mutex_exit(&clientp->ic_kstat_mutex);
2021 ibmf_i_msg_transport(ibmf_client_t *clientp, ibmf_qp_handle_t ibmf_qp_handle,
2035 	    IBMF_TNF_TRACE, "", "ibmf_i_msg_transport(): clientp = 0x%p, "
2037 	    tnf_opaque, clientp, clientp, tnf_opaque, qphdl, ibmf_qp_handle,
2158 	status = ibmf_i_alloc_ud_dest(clientp, msgimplp,
2169 	ibmf_i_client_add_msg(clientp, msgimplp);
2200 		status = ibmf_i_send_single_pkt(clientp, ibmf_qp_handle,
2205 			ibmf_i_client_rem_msg(clientp, msgimplp, &refcnt);
2216 		if ((clientp->ic_reg_flags & IBMF_REG_FLAG_RMPP) == 0) {
2219 			ibmf_i_client_rem_msg(clientp, msgimplp, &refcnt);
2232 			ibmf_i_client_rem_msg(clientp, msgimplp, &refcnt);
2243 		status = ibmf_i_send_rmpp_pkts(clientp, ibmf_qp_handle,
2248 			ibmf_i_client_rem_msg(clientp, msgimplp, &refcnt);
2327 	mutex_enter(&clientp->ic_kstat_mutex);
2328 	IBMF_ADD32_KSTATS(clientp, msgs_sent, 1);
2329 	mutex_exit(&clientp->ic_kstat_mutex);
2380 ibmf_i_alloc_qp(ibmf_client_t *clientp, ib_pkey_t p_key, ib_qkey_t q_key,
2383 	ibmf_ci_t		*ibmf_cip = clientp->ic_myci;
2397 	    "ibmf_i_alloc_qp() enter, clientp = %p, pkey = %x, qkey = %x \n",
2398 	    tnf_opaque, clientp, clientp, tnf_uint, p_key, p_key,
2404 	if (ibmf_i_get_pkeyix(clientp->ic_ci_handle, p_key,
2405 	    clientp->ic_client_info.port_num, &pkey_ix) != IBMF_SUCCESS) {
2436 	ibt_status = ibt_alloc_qp(clientp->ic_ci_handle, IBT_UD_RQP,
2454 	    clientp->ic_client_info.port_num;
2457 	qp_ctx->isq_client_hdl = clientp;
2485 	qp_ctx->isq_port_num = clientp->ic_client_info.port_num;
2518 		status = ibmf_i_post_recv_buffer(ibmf_cip, clientp->ic_qp,
2529 	mutex_enter(&clientp->ic_kstat_mutex);
2530 	IBMF_ADD32_KSTATS(clientp, alt_qps_alloced, 1);
2531 	mutex_exit(&clientp->ic_kstat_mutex);
2555 	ibmf_client_t		*clientp = qp_ctx->isq_client_hdl;
2630 	mutex_enter(&clientp->ic_kstat_mutex);
2631 	IBMF_SUB32_KSTATS(clientp, alt_qps_alloced, 1);
2632 	mutex_exit(&clientp->ic_kstat_mutex);
2714 	ibmf_client_t		*clientp = qp_ctx->isq_client_hdl;
2715 	ibmf_ci_t		*ibmf_cip = clientp->ic_myci;
2733 	if (ibmf_i_get_pkeyix(clientp->ic_ci_handle, p_key,
2734 	    clientp->ic_client_info.port_num, &pkey_ix) != IBMF_SUCCESS) {
3077 	ibmf_client_t 		*clientp;
3090 	clientp = ibmf_cip->ci_clients;
3093 	while (clientp != NULL) {
3094 		client_infop = &clientp->ic_client_info;
3100 		clientp = clientp->ic_next;
3105 	if (clientp != NULL) {
3106 		*clientpp = clientp;
3110 		    tnf_opaque, clientp, clientp);
3315 	ibmf_client_t	*clp, *clientp = (ibmf_client_t *)ibmf_handle;
3334 			if (clp == clientp)
3341 		if (clp == clientp) {
3373 	ibmf_client_t	*clientp = (ibmf_client_t *)ibmf_handle;
3375 	ibmf_ci_t	*cip = clientp->ic_myci;
3439 ibmf_setup_term_ctx(ibmf_client_t *clientp, ibmf_msg_impl_t *regmsgimplp)
3549 	status = ibmf_i_alloc_ud_dest(clientp, msgimplp, &msgimplp->im_ud_dest,
3568 	ibmf_i_client_add_msg(clientp, msgimplp);
3577 	mutex_enter(&clientp->ic_mutex);
3578 	clientp->ic_msgs_alloced++;
3579 	mutex_exit(&clientp->ic_mutex);