mgt/ibmf/ibmf_dr.c

38     ibmf_msg_impl_t *msgimplp, int blocking);
40     ibmf_msg_impl_t *msgimplp, int blocking);
47 ibmf_i_check_for_loopback(ibmf_msg_impl_t *msgimplp, ibmf_msg_cb_t msg_cb,
53 	ibmf_ci_t	*cip = ((ibmf_client_t *)msgimplp->im_client)->ic_myci;
58 	    tnf_opaque, msg, msgimplp);
61 	dr_hdr = (sm_dr_mad_hdr_t *)msgimplp->im_msgbufs_send.im_bufs_mad_hdr;
82 		ibmf_i_init_msg(msgimplp, msg_cb, msg_cb_args, retrans,
85 		status = ibmf_i_dr_loopback_filter(msgimplp->im_client,
86 		    msgimplp, blocking);
114 ibmf_i_dr_loopback_term(ibmf_client_t *clientp, ibmf_msg_impl_t *msgimplp,
122 	    tnf_opaque, clientp, clientp, tnf_opaque, msg, msgimplp);
124 	mutex_enter(&msgimplp->im_mutex);
133 		if ((msgimplp->im_flags & IBMF_MSG_FLAGS_SEQUENCED) &&
134 		    ((msgimplp->im_trans_state_flags &
137 			msgimplp->im_trans_state_flags |=
145 			cv_wait(&msgimplp->im_trans_cv, &msgimplp->im_mutex);
147 			msgimplp->im_trans_state_flags &=
150 			msgimplp->im_flags &= ~IBMF_MSG_FLAGS_BUSY;
152 			mutex_exit(&msgimplp->im_mutex);
154 		} else if ((msgimplp->im_flags &
157 			msgimplp->im_trans_state_flags |=
159 			msgimplp->im_flags &= ~IBMF_MSG_FLAGS_BUSY;
161 			mutex_exit(&msgimplp->im_mutex);
163 			ibmf_i_client_rem_msg(clientp, msgimplp, &refcnt);
166 			msgimplp->im_flags &= ~IBMF_MSG_FLAGS_BUSY;
167 			mutex_exit(&msgimplp->im_mutex);
170 	} else if ((msgimplp->im_flags & IBMF_MSG_FLAGS_SEQUENCED) == 0) {
176 		msgimplp->im_trans_state_flags |= IBMF_TRANS_STATE_FLAG_DONE;
177 		msgimplp->im_flags &= ~IBMF_MSG_FLAGS_BUSY;
178 		mutex_exit(&msgimplp->im_mutex);
180 		ibmf_i_client_rem_msg(clientp, msgimplp, &refcnt);
182 		if (msgimplp->im_trans_cb) {
183 			msgimplp->im_trans_cb((ibmf_handle_t)clientp,
184 			    (ibmf_msg_t *)msgimplp, msgimplp->im_trans_cb_arg);
188 		msgimplp->im_flags &= ~IBMF_MSG_FLAGS_BUSY;
189 		mutex_exit(&msgimplp->im_mutex);
210 ibmf_i_dr_loopback_filter(ibmf_client_t *clientp, ibmf_msg_impl_t *msgimplp,
224 	    tnf_opaque, clientp, clientp, tnf_opaque, msg, msgimplp);
226 	dr_hdr = (sm_dr_mad_hdr_t *)msgimplp->im_msgbufs_send.im_bufs_mad_hdr;
229 	if (msgimplp->im_transp_op_flags & IBMF_MSG_TRANS_FLAG_SEQ)
230 		msgimplp->im_flags |= IBMF_MSG_FLAGS_SEQUENCED;
293 	msgimplp->im_tid	= b2h64(dr_hdr->TransactionID);
294 	msgimplp->im_mgt_class 	= dr_hdr->MgmtClass;
300 	rmsgimplp = ibmf_i_find_msg(rclientp, msgimplp->im_tid,
302 	    msgimplp->im_local_addr.ia_remote_lid, NULL, B_FALSE, NULL,
348 			    tnf_opaque, msgimplp, msgimplp);
376 		rmsgimplp->im_qp_hdl	= msgimplp->im_qp_hdl;
437 	bcopy((void *)msgimplp->im_msgbufs_send.im_bufs_mad_hdr,
450 	    msgimplp->im_msgbufs_send.im_bufs_cl_hdr_len;
451 	bcopy((void *)msgimplp->im_msgbufs_send.im_bufs_cl_hdr,
453 	    msgimplp->im_msgbufs_send.im_bufs_cl_hdr_len);
461 	    msgimplp->im_msgbufs_send.im_bufs_cl_data_len;
462 	bcopy((void *)msgimplp->im_msgbufs_send.im_bufs_cl_data,
464 	    msgimplp->im_msgbufs_send.im_bufs_cl_data_len);
467 	bcopy((void *)&msgimplp->im_global_addr,
472 	bcopy((void *)&msgimplp->im_local_addr,
499 	ibmf_i_client_add_msg(clientp, msgimplp);
515 	ibmf_i_dr_loopback_term(clientp, msgimplp, blocking);