mgt/ibmf/ibmf_recv.c

72 static void ibmf_i_handle_non_rmpp(ibmf_client_t *clientp,
100 	ibmf_client_t		*clientp;
294 	    class, &clientp);
297 		recv_wqep->recv_client = clientp;
304 		mutex_enter(&clientp->ic_kstat_mutex);
305 		IBMF_ADD32_KSTATS(clientp, recv_cb_active, 1);
306 		mutex_exit(&clientp->ic_kstat_mutex);
308 		if ((clientp->ic_reg_flags & IBMF_REG_FLAG_NO_OFFLOAD) == 0) {
310 			ret = taskq_dispatch(clientp->ic_recv_taskq,
313 				mutex_enter(&clientp->ic_kstat_mutex);
314 				IBMF_SUB32_KSTATS(clientp, recv_cb_active, 1);
315 				mutex_exit(&clientp->ic_kstat_mutex);
337 		mutex_enter(&clientp->ic_kstat_mutex);
338 		IBMF_SUB32_KSTATS(clientp, recv_cb_active, 1);
339 		mutex_exit(&clientp->ic_kstat_mutex);
432 	ibmf_client_t		*clientp;
464 	clientp = recv_wqep->recv_client;
507 	msgimplp = ibmf_i_find_msg(clientp, b2h64(mad_hdr->TransactionID),
516 		msgimplp = ibmf_i_find_msg(clientp,
525 		if (clientp->ic_client_info.client_class == SUBN_ADM_MANAGER) {
533 			saa_portp = clientp->ic_async_cb_arg;
557 		if (ibmf_i_is_rmpp(clientp, ibmf_qp_handle) &&
561 			(void) ibmf_i_repost_recv_buffer(clientp->ic_myci,
588 			(void) ibmf_i_repost_recv_buffer(clientp->ic_myci,
610 				ibmf_i_notify_sequence(clientp, msgimplp,
632 		if (ibmf_i_is_rmpp(clientp, ibmf_qp_handle) &&
639 				    clientp->ic_myci, recv_wqep);
662 			mutex_enter(&clientp->ic_mutex);
663 			if (clientp->ic_recv_cb == NULL) {
664 				mutex_exit(&clientp->ic_mutex);
666 				    clientp->ic_myci, recv_wqep);
673 				    clientp->ic_client_info.client_class);
679 			IBMF_RECV_CB_SETUP(clientp);
680 			mutex_exit(&clientp->ic_mutex);
688 				    clientp->ic_myci, recv_wqep);
695 				    clientp->ic_client_info.client_class);
716 				mutex_enter(&clientp->ic_mutex);
717 				IBMF_RECV_CB_CLEANUP(clientp);
718 				mutex_exit(&clientp->ic_mutex);
725 			(void) ibmf_i_repost_recv_buffer(clientp->ic_myci,
738 		if ((clientp->ic_base_lid == 0) &&
739 		    (clientp->ic_qp->iq_qp_num != 0)) {
741 			    clientp->ic_client_info.ci_guid,
742 			    clientp->ic_client_info.port_num, NULL,
743 			    &clientp->ic_base_lid);
744 			if (clientp->ic_base_lid == 0) {
753 		addrinfo.ia_local_lid = clientp->ic_base_lid +
768 				    clientp->ic_myci, recv_wqep->recv_port_num,
779 					mutex_enter(&clientp->ic_mutex);
780 					IBMF_RECV_CB_CLEANUP(clientp);
781 					mutex_exit(&clientp->ic_mutex);
783 					    clientp->ic_myci, recv_wqep);
812 		msgimplp->im_client = clientp;
832 		status = ibmf_i_alloc_ud_dest(clientp, msgimplp,
836 				mutex_enter(&clientp->ic_mutex);
837 				IBMF_RECV_CB_CLEANUP(clientp);
838 				mutex_exit(&clientp->ic_mutex);
845 			(void) ibmf_i_repost_recv_buffer(clientp->ic_myci,
864 		ibmf_i_client_add_msg(clientp, msgimplp);
904 	if (ibmf_i_is_rmpp(clientp, ibmf_qp_handle) &&
962 		ibmf_i_handle_rmpp(clientp, ibmf_qp_handle, msgimplp,
970 		ibmf_i_handle_non_rmpp(clientp, msgimplp,
1033 	mutex_enter(&clientp->ic_kstat_mutex);
1034 	IBMF_ADD32_KSTATS(clientp, msgs_received, 1);
1035 	mutex_exit(&clientp->ic_kstat_mutex);
1041 	(void) ibmf_i_repost_recv_buffer(clientp->ic_myci, recv_wqep);
1055 		ibmf_i_client_rem_msg(clientp, msgimplp, &ref_cnt);
1066 			ibmf_i_notify_sequence(clientp, msgimplp, msg_flags);
1082 ibmf_i_handle_non_rmpp(ibmf_client_t *clientp, ibmf_msg_impl_t *msgimplp,
1093 	    "ibmf_i_handle_non_rmpp(): clientp = 0x%p, "
1094 	    "msgp = 0x%p, madp = 0x%p\n", tnf_opaque, clientp, clientp,
1123 		mutex_enter(&clientp->ic_kstat_mutex);
1124 		IBMF_ADD32_KSTATS(clientp, recv_bufs_alloced, 1);
1125 		mutex_exit(&clientp->ic_kstat_mutex);
1154 	ibmf_i_terminate_transaction(clientp, msgimplp, IBMF_SUCCESS);