mgt/ibmf/ibmf_rmpp.c

40 static void ibmf_i_rmpp_sender_active_flow(ibmf_client_t *clientp,
42 static void ibmf_i_rmpp_sender_switch_flow(ibmf_client_t *clientp,
44 static void ibmf_i_rmpp_recvr_flow_main(ibmf_client_t *clientp,
46 static void ibmf_i_rmpp_recvr_active_flow(ibmf_client_t *clientp,
48 static void ibmf_i_rmpp_recvr_term_flow(ibmf_client_t *clientp,
57 ibmf_i_is_rmpp(ibmf_client_t *clientp, ibmf_qp_handle_t ibmf_qp_handle)
63 	    IBMF_TNF_TRACE, "", "ibmf_i_is_rmpp(): clientp = %p, "
64 	    "ibmf_qp_handle = 0x%p\n", tnf_opaque, clientp, clientp,
67 	if ((clientp->ic_reg_flags & IBMF_REG_FLAG_RMPP) == 0) {
90 ibmf_i_rmpp_sender_active_flow(ibmf_client_t *clientp, ibmf_qp_handle_t qp_hdl,
100 	    "ibmf_i_rmpp_sender_active_flow(): clientp = 0x%p, qp_hdl = 0x%p, "
101 	    "msgp = 0x%p, madp = 0x%p\n", tnf_opaque, clientp, clientp,
159 			mutex_enter(&clientp->ic_kstat_mutex);
160 			IBMF_ADD32_KSTATS(clientp, rmpp_errors, 1);
161 			mutex_exit(&clientp->ic_kstat_mutex);
213 		mutex_enter(&clientp->ic_kstat_mutex);
214 		IBMF_ADD32_KSTATS(clientp, rmpp_errors, 1);
215 		mutex_exit(&clientp->ic_kstat_mutex);
273 		mutex_enter(&clientp->ic_kstat_mutex);
274 		IBMF_ADD32_KSTATS(clientp, rmpp_errors, 1);
275 		mutex_exit(&clientp->ic_kstat_mutex);
332 		ibmf_i_terminate_transaction(clientp, msgimplp, IBMF_SUCCESS);
370 ibmf_i_rmpp_sender_switch_flow(ibmf_client_t *clientp, ibmf_qp_handle_t qp_hdl,
379 	    "ibmf_i_rmpp_sender_switch_flow(): clientp = 0x%p, qp_hdl = 0x%p, "
380 	    "msgp = 0x%p, madp = 0x%p\n", tnf_opaque, clientp, clientp,
408 		ibmf_i_rmpp_recvr_flow_main(clientp, qp_hdl, msgimplp, mad);
429 		mutex_enter(&clientp->ic_kstat_mutex);
430 		IBMF_ADD32_KSTATS(clientp, rmpp_errors, 1);
431 		mutex_exit(&clientp->ic_kstat_mutex);
451 ibmf_i_rmpp_recvr_flow_main(ibmf_client_t *clientp, ibmf_qp_handle_t qp_hdl,
466 	    "ibmf_i_rmpp_recvr_flow_main(): clientp = 0x%p, qp_hdl = 0x%p, "
467 	    "msgp = 0x%p, madp = 0x%p\n", tnf_opaque, clientp, clientp,
584 			mutex_enter(&clientp->ic_kstat_mutex);
585 			IBMF_ADD32_KSTATS(clientp, rmpp_errors, 1);
586 			mutex_exit(&clientp->ic_kstat_mutex);
688 		mutex_enter(&clientp->ic_kstat_mutex);
689 		IBMF_ADD32_KSTATS(clientp, recv_bufs_alloced, 1);
690 		mutex_exit(&clientp->ic_kstat_mutex);
798 			mutex_enter(&clientp->ic_kstat_mutex);
799 			IBMF_ADD32_KSTATS(clientp, rmpp_errors, 1);
800 			mutex_exit(&clientp->ic_kstat_mutex);
868 		mutex_enter(&clientp->ic_kstat_mutex);
869 		IBMF_ADD32_KSTATS(clientp, recv_bufs_alloced, 1);
870 		mutex_exit(&clientp->ic_kstat_mutex);
942 			mutex_enter(&clientp->ic_kstat_mutex);
943 			IBMF_ADD32_KSTATS(clientp, recv_bufs_alloced, 1);
944 			mutex_exit(&clientp->ic_kstat_mutex);
1044 		ibmf_i_terminate_transaction(clientp, msgimplp, IBMF_SUCCESS);
1091 ibmf_i_rmpp_recvr_active_flow(ibmf_client_t *clientp, ibmf_qp_handle_t qp_hdl,
1101 	    "ibmf_i_rmpp_recvr_active_flow(): clientp = 0x%p, qp_hdl = 0x%p, "
1102 	    "msgp = 0x%p, madp = 0x%p\n", tnf_opaque, clientp, clientp,
1137 		ibmf_i_rmpp_recvr_flow_main(clientp, qp_hdl, msgimplp, mad);
1182 		mutex_enter(&clientp->ic_kstat_mutex);
1183 		IBMF_ADD32_KSTATS(clientp, rmpp_errors, 1);
1184 		mutex_exit(&clientp->ic_kstat_mutex);
1204 ibmf_i_rmpp_recvr_term_flow(ibmf_client_t *clientp, ibmf_qp_handle_t qp_hdl,
1213 	    "ibmf_i_rmpp_recvr_term_flow(): clientp = 0x%p, qp_hdl = 0x%p, "
1214 	    "msgp = 0x%p, madp = 0x%p\n", tnf_opaque, clientp, clientp,
1267 			ibmf_i_terminate_transaction(clientp, msgimplp,
1312 		mutex_enter(&clientp->ic_kstat_mutex);
1313 		IBMF_ADD32_KSTATS(clientp, rmpp_errors, 1);
1314 		mutex_exit(&clientp->ic_kstat_mutex);
1376 ibmf_i_handle_rmpp(ibmf_client_t *clientp, ibmf_qp_handle_t qp_hdl,
1385 	    "ibmf_i_handle_rmpp(): clientp = 0x%p, qp_hdl = 0x%p, "
1386 	    "msgp = 0x%p, madp = 0x%p\n", tnf_opaque, clientp, clientp,
1458 		mutex_enter(&clientp->ic_kstat_mutex);
1459 		IBMF_ADD32_KSTATS(clientp, rmpp_errors, 1);
1460 		mutex_exit(&clientp->ic_kstat_mutex);
1545 		mutex_enter(&clientp->ic_kstat_mutex);
1546 		IBMF_ADD32_KSTATS(clientp, rmpp_errors, 1);
1547 		mutex_exit(&clientp->ic_kstat_mutex);
1582 		ibmf_i_rmpp_sender_active_flow(clientp, qp_hdl, msgimplp, madp);
1585 		ibmf_i_rmpp_sender_switch_flow(clientp, qp_hdl, msgimplp, madp);
1588 		ibmf_i_rmpp_recvr_active_flow(clientp, qp_hdl, msgimplp, madp);
1591 		ibmf_i_rmpp_recvr_term_flow(clientp, qp_hdl, msgimplp, madp);
1778 ibmf_i_send_rmpp_pkts(ibmf_client_t *clientp, ibmf_qp_handle_t ibmf_qp_handle,
1787 	    IBMF_TNF_TRACE, "", "ibmf_i_send_rmpp_pkts(): clientp = 0x%p, "
1789 	    tnf_opaque, clientp, clientp, tnf_opaque, qphdl, ibmf_qp_handle,