mgt/ibmf/ibmf_trans.c

40 ibmf_i_terminate_transaction(ibmf_client_t *clientp, ibmf_msg_impl_t *msgimplp,
46 	    "ibmf_i_terminate_transaction(): clientp = 0x%p, msgp = 0x%p, "
47 	    "status = 0x%x\n", tnf_opaque, clientp, clientp,
110 	ibmf_client_t	*clientp;
118 	clientp = msgimplp->im_client;
160 		ibmf_i_free_ud_dest(clientp, msgimplp);
161 		ibmf_i_clean_ud_dest_list(clientp->ic_myci, B_FALSE);
174 				mutex_enter(&clientp->ic_mutex);
175 				IBMF_RECV_CB_CLEANUP(clientp);
176 				mutex_exit(&clientp->ic_mutex);
210 			mutex_enter(&clientp->ic_mutex);
212 			if ((clientp->ic_recv_cb == NULL) ||
213 			    (clientp->ic_flags & IBMF_CLIENT_TEAR_DOWN_CB)) {
214 				IBMF_RECV_CB_CLEANUP(clientp);
215 				mutex_exit(&clientp->ic_mutex);
229 			clientp->ic_msgs_alloced++;
230 			mutex_enter(&clientp->ic_kstat_mutex);
231 			IBMF_ADD32_KSTATS(clientp, msgs_alloced, 1);
232 			mutex_exit(&clientp->ic_kstat_mutex);
234 			async_cb = clientp->ic_recv_cb;
235 			async_cb_arg = clientp->ic_recv_cb_arg;
237 			mutex_exit(&clientp->ic_mutex);
239 			async_cb((ibmf_handle_t)clientp, (ibmf_msg_t *)msgimplp,
242 			mutex_enter(&clientp->ic_mutex);
243 			IBMF_RECV_CB_CLEANUP(clientp);
244 			mutex_exit(&clientp->ic_mutex);
274 			mutex_enter(&clientp->ic_mutex);
276 			clientp->ic_msgs_alloced++;
278 			mutex_exit(&clientp->ic_mutex);
280 			mutex_enter(&clientp->ic_kstat_mutex);
281 			IBMF_ADD32_KSTATS(clientp, msgs_alloced, 1);
282 			mutex_exit(&clientp->ic_kstat_mutex);
284 			async_cb((ibmf_handle_t)clientp, (ibmf_msg_t *)msgimplp,
340 				    (ibmf_handle_t)clientp,
357 ibmf_i_notify_sequence(ibmf_client_t *clientp, ibmf_msg_impl_t *msgimplp,
364 	    "ibmf_i_notify_sequence() enter, clientp = %p, msgimplp = %p\n",
365 	    tnf_opaque, clientp, clientp, tnf_opaque, msgimplp, msgimplp);
392 		status = ibmf_setup_term_ctx(clientp, msgimplp);
420 			ibmf_i_client_add_msg(clientp, msgimplp);