mgt/ibmf/ibmf_send.c

42     ibmf_msg_impl_t *msgimplp, ibmf_send_wqe_t *send_wqep);
49 ibmf_i_issue_pkt(ibmf_client_t *clientp, ibmf_msg_impl_t *msgimplp,
64 	    tnf_opaque, msg, msgimplp, tnf_opaque, ibmf_qp_handle,
67 	ASSERT(MUTEX_HELD(&msgimplp->im_mutex));
84 	ibmf_i_init_send_wqe(clientp, msgimplp, sgl, send_wqep,
85 	    msgimplp->im_ud_dest, ibt_qp_handle, ibmf_qp_handle);
141     ibmf_msg_impl_t *msgimplp, int block)
150 	    tnf_opaque, qp_hdl, ibmf_qp_handle, tnf_opaque, msg, msgimplp,
153 	ASSERT(MUTEX_HELD(&msgimplp->im_mutex));
161 	msgimplp->im_trans_state_flags &= ~IBMF_TRANS_STATE_FLAG_SEND_DONE;
168 	    msgimplp, block, &send_wqep);
180 	if (msgimplp->im_flags & IBMF_MSG_FLAGS_SEND_RMPP)
181 		send_wqep->send_rmpp_segment = msgimplp->im_rmpp_ctx.rmpp_ns;
190 	msgimplp->im_pending_send_compls += 1;
193 	status = ibmf_i_issue_pkt(clientp, msgimplp, ibmf_qp_handle, send_wqep);
195 		ibmf_i_free_send_resources(clientp->ic_myci, msgimplp,
219     ibmf_msg_impl_t *msgimplp, int block)
227 	    tnf_opaque, qp_hdl, ibmf_qp_handle, tnf_opaque, msg, msgimplp,
230 	ASSERT(MUTEX_HELD(&msgimplp->im_mutex));
232 	status = ibmf_i_send_pkt(clientp, ibmf_qp_handle, msgimplp, block);
285 		ibmf_msg_impl_t		*msgimplp;
291 		msgimplp = send_wqep->send_msg;
303 		ibmf_i_put_ud_dest(cip, msgimplp->im_ibmf_ud_dest);
305 		kmem_free(msgimplp, sizeof (ibmf_msg_impl_t));
397 	ibmf_msg_impl_t		*msgimplp;
419 	msgimplp = send_wqep->send_msg;
434 	found = ibmf_i_find_msg_client(clientp, msgimplp, inc_refcnt);
466 	mutex_enter(&msgimplp->im_mutex);
472 	msgimplp->im_pending_send_compls -= 1;
490 	if (msgimplp->im_pending_send_compls != 0) {
491 		IBMF_MSG_DECR_REFCNT(msgimplp);
492 		mutex_exit(&msgimplp->im_mutex);
522 	if ((msgimplp->im_trans_state_flags & IBMF_TRANS_STATE_FLAG_UNINIT) ||
523 	    (msgimplp->im_trans_state_flags & IBMF_TRANS_STATE_FLAG_DONE)) {
524 		IBMF_MSG_DECR_REFCNT(msgimplp);
525 		msg_trans_state_flags = msgimplp->im_trans_state_flags;
526 		msg_flags = msgimplp->im_flags;
527 		ref_cnt = msgimplp->im_ref_count;
528 		mutex_exit(&msgimplp->im_mutex);
548 			ibmf_i_notify_sequence(clientp, msgimplp, msg_flags);
572 		    "send cb", tnf_opaque, msgimplp, msgimplp);
577 	ibmf_i_do_send_compl((ibmf_handle_t)clientp, msgimplp, send_wqep);
582 	msg_trans_state_flags = msgimplp->im_trans_state_flags;
583 	msg_flags = msgimplp->im_flags;
584 	msg_rp_unset_id = msgimplp->im_rp_unset_timeout_id;
585 	msg_tr_unset_id = msgimplp->im_tr_unset_timeout_id;
586 	msgimplp->im_rp_unset_timeout_id = 0;
587 	msgimplp->im_tr_unset_timeout_id = 0;
594 	IBMF_MSG_DECR_REFCNT(msgimplp);
597 		if (msgimplp->im_rp_timeout_id != 0) {
598 			msg_rp_set_id = msgimplp->im_rp_timeout_id;
599 			msgimplp->im_rp_timeout_id = 0;
601 		if (msgimplp->im_tr_timeout_id != 0) {
602 			msg_tr_set_id = msgimplp->im_tr_timeout_id;
603 			msgimplp->im_tr_timeout_id = 0;
607 	mutex_exit(&msgimplp->im_mutex);
629 	    tnf_opaque, msgimplp, msgimplp);
639 		ibmf_i_client_rem_msg(clientp, msgimplp, &ref_cnt);
650 			ibmf_i_notify_sequence(clientp, msgimplp, msg_flags);
684 ibmf_i_do_send_compl(ibmf_handle_t ibmf_handle, ibmf_msg_impl_t *msgimplp,
690 	    tnf_opaque, ibmf_hdl, ibmf_handle, tnf_opaque, msgimplp, msgimplp,
692 	    tnf_opaque, msg_flags, msgimplp->im_flags);
694 	ASSERT(MUTEX_HELD(&msgimplp->im_mutex));
706 	if ((msgimplp->im_flags & IBMF_MSG_FLAGS_RECV_RMPP) ||
707 	    (msgimplp->im_flags & IBMF_MSG_FLAGS_SEND_RMPP)) {
713 		    tnf_opaque, msg, msgimplp,
714 		    tnf_opaque, rmpp_state, msgimplp->im_rmpp_ctx.rmpp_state);
727 		if (msgimplp->im_rmpp_ctx.rmpp_state == IBMF_RMPP_STATE_ABORT) {
728 			msgimplp->im_trans_state_flags |=
730 			if (msgimplp->im_trans_state_flags &
732 				msgimplp->im_trans_state_flags |=
737 		if ((msgimplp->im_rmpp_ctx.rmpp_state ==
739 		    (msgimplp->im_rmpp_ctx.rmpp_state ==
741 			msgimplp->im_trans_state_flags |=
743 			if (msgimplp->im_trans_state_flags  &
745 				msgimplp->im_trans_state_flags |=
762 		if ((msgimplp->im_flags & IBMF_MSG_FLAGS_SEQUENCED) == 0) {
763 			if (msgimplp->im_pending_send_compls == 0) {
764 				msgimplp->im_trans_state_flags |=
766 				if (msgimplp->im_trans_state_flags  &
768 					msgimplp->im_trans_state_flags |=
788 	if (msgimplp->im_flags & IBMF_MSG_FLAGS_SEQUENCED) {
794 		    tnf_opaque, msg, msgimplp);
802 		if (msgimplp->im_trans_state_flags  &
812 		msgimplp->im_trans_state_flags |=
815 		if (msgimplp->im_trans_state_flags  &
817 			msgimplp->im_trans_state_flags |=
829 		if (((msgimplp->im_trans_state_flags &
831 		    ((msgimplp->im_trans_state_flags &
834 			ibmf_i_set_timer(ibmf_i_send_timeout, msgimplp,
838 		msgimplp->im_msg_status = IBMF_SUCCESS;
839 		msgimplp->im_trans_state_flags |=
841 		msgimplp->im_trans_state_flags |= IBMF_TRANS_STATE_FLAG_DONE;