/illumos-gate/usr/src/uts/common/io/ib/mgt/ibmf/ |
H A D | ibmf_trans.c | 40 ibmf_i_terminate_transaction(ibmf_client_t *clientp, ibmf_msg_impl_t *msgimplp, argument 48 tnf_opaque, msg, msgimplp, tnf_uint, status, status); 50 ASSERT(MUTEX_HELD(&msgimplp->im_mutex)); 52 msgimplp->im_msg_status = status; 59 ibmf_i_unset_timer(msgimplp, IBMF_TRANS_TIMER); 67 if (msgimplp->im_unsolicited == B_TRUE) { 69 msgimplp->im_trans_state_flags |= IBMF_TRANS_STATE_FLAG_DONE; 79 msgimplp->im_trans_state_flags, 80 tnf_opaque, flags, msgimplp->im_flags); 83 msgimplp 108 ibmf_i_notify_client(ibmf_msg_impl_t *msgimplp) argument 357 ibmf_i_notify_sequence(ibmf_client_t *clientp, ibmf_msg_impl_t *msgimplp, int msg_flags) argument [all...] |
H A D | ibmf_msg.c | 42 ibmf_i_client_add_msg(ibmf_client_t *clientp, ibmf_msg_impl_t *msgimplp) argument 47 tnf_opaque, clientp, clientp, tnf_opaque, msg, msgimplp); 49 ASSERT(MUTEX_NOT_HELD(&msgimplp->im_mutex)); 58 mutex_enter(&msgimplp->im_mutex); 59 if (msgimplp->im_flags & IBMF_MSG_FLAGS_TERMINATION) { 61 mutex_exit(&msgimplp->im_mutex); 65 msgimplp; 67 msgimplp->im_msg_prev = clientp->ic_term_msg_last; 68 clientp->ic_term_msg_last->im_msg_next = msgimplp; 69 clientp->ic_term_msg_last = msgimplp; 117 ibmf_i_client_rem_msg(ibmf_client_t *clientp, ibmf_msg_impl_t *msgimplp, uint_t *refcnt) argument 219 ibmf_msg_impl_t *msgimplp; local 512 ibmf_i_find_msg_client(ibmf_client_t *clp, ibmf_msg_impl_t *msgimplp, boolean_t inc_refcnt) argument 606 ibmf_setup_recvbuf_on_error(ibmf_msg_impl_t *msgimplp, uchar_t *mad) argument [all...] |
H A D | ibmf_timers.c | 39 ibmf_i_set_timer(void (*func)(void *), ibmf_msg_impl_t *msgimplp, argument 45 ASSERT(MUTEX_HELD(&msgimplp->im_mutex)); 50 tnf_opaque, msgimplp, msgimplp, tnf_opaque, timer_type, type, 63 ASSERT(msgimplp->im_rp_timeout_id == 0); 64 interval = msgimplp->im_retrans.retrans_rtv + 65 msgimplp->im_retrans.retrans_rttv; 72 tnf_uint, resp_time, msgimplp->im_retrans.retrans_rtv, 73 tnf_uint, interval, msgimplp->im_retrans.retrans_rttv); 75 msgimplp 151 ibmf_i_unset_timer(ibmf_msg_impl_t *msgimplp, ibmf_timer_t type) argument 186 ibmf_msg_impl_t *msgimplp = (ibmf_msg_impl_t *)argp; local 371 ibmf_msg_impl_t *msgimplp = (ibmf_msg_impl_t *)argp; local 669 ibmf_msg_impl_t *msgimplp = (ibmf_msg_impl_t *)argp; local [all...] |
H A D | ibmf_rmpp.c | 41 ibmf_qp_handle_t qp_hdl, ibmf_msg_impl_t *msgimplp, uchar_t *mad); 43 ibmf_qp_handle_t qp_hdl, ibmf_msg_impl_t *msgimplp, uchar_t *mad); 45 ibmf_qp_handle_t qp_hdl, ibmf_msg_impl_t *msgimplp, uchar_t *mad); 47 ibmf_qp_handle_t qp_hdl, ibmf_msg_impl_t *msgimplp, uchar_t *mad); 49 ibmf_qp_handle_t qp_hdl, ibmf_msg_impl_t *msgimplp, uchar_t *mad); 91 ibmf_msg_impl_t *msgimplp, uchar_t *mad) 93 ibmf_rmpp_ctx_t *rmpp_ctx = &msgimplp->im_rmpp_ctx; 102 tnf_opaque, qp_hdl, qp_hdl, tnf_opaque, msg, msgimplp, 125 ibmf_i_send_rmpp_window(msgimplp, IBMF_NO_BLOCK); 146 status = ibmf_i_send_rmpp(msgimplp, 90 ibmf_i_rmpp_sender_active_flow(ibmf_client_t *clientp, ibmf_qp_handle_t qp_hdl, ibmf_msg_impl_t *msgimplp, uchar_t *mad) argument 370 ibmf_i_rmpp_sender_switch_flow(ibmf_client_t *clientp, ibmf_qp_handle_t qp_hdl, ibmf_msg_impl_t *msgimplp, uchar_t *mad) argument 451 ibmf_i_rmpp_recvr_flow_main(ibmf_client_t *clientp, ibmf_qp_handle_t qp_hdl, ibmf_msg_impl_t *msgimplp, uchar_t *mad) argument 1091 ibmf_i_rmpp_recvr_active_flow(ibmf_client_t *clientp, ibmf_qp_handle_t qp_hdl, ibmf_msg_impl_t *msgimplp, uchar_t *mad) argument 1204 ibmf_i_rmpp_recvr_term_flow(ibmf_client_t *clientp, ibmf_qp_handle_t qp_hdl, ibmf_msg_impl_t *msgimplp, uchar_t *mad) argument 1376 ibmf_i_handle_rmpp(ibmf_client_t *clientp, ibmf_qp_handle_t qp_hdl, ibmf_msg_impl_t *msgimplp, uchar_t *madp) argument 1648 ibmf_i_send_rmpp(ibmf_msg_impl_t *msgimplp, uint8_t rmpp_type, uint8_t rmpp_status, uint32_t segno, uint32_t nwl, int block) argument 1704 ibmf_i_send_rmpp_window(ibmf_msg_impl_t *msgimplp, int block) argument 1778 ibmf_i_send_rmpp_pkts(ibmf_client_t *clientp, ibmf_qp_handle_t ibmf_qp_handle, ibmf_msg_impl_t *msgimplp, boolean_t isDS, int block) argument [all...] |
H A D | 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, argument 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 140 ibmf_i_send_pkt(ibmf_client_t *clientp, ibmf_qp_handle_t ibmf_qp_handle, ibmf_msg_impl_t *msgimplp, int block) argument 218 ibmf_i_send_single_pkt(ibmf_client_t *clientp, ibmf_qp_handle_t ibmf_qp_handle, ibmf_msg_impl_t *msgimplp, int block) argument 285 ibmf_msg_impl_t *msgimplp; local 397 ibmf_msg_impl_t *msgimplp; local 684 ibmf_i_do_send_compl(ibmf_handle_t ibmf_handle, ibmf_msg_impl_t *msgimplp, ibmf_send_wqe_t *send_wqep) argument [all...] |
H A D | 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, argument 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, argument 210 ibmf_i_dr_loopback_filter(ibmf_client_t *clientp, ibmf_msg_impl_t *msgimplp, int blocking) argument [all...] |
H A D | ibmf_recv.c | 73 ibmf_msg_impl_t *msgimplp, uchar_t *mad); 431 ibmf_msg_impl_t *msgimplp; local 507 msgimplp = ibmf_i_find_msg(clientp, b2h64(mad_hdr->TransactionID), 515 if (msgimplp == NULL) { 516 msgimplp = ibmf_i_find_msg(clientp, 522 if (msgimplp != NULL) { 543 mutex_enter(&msgimplp->im_mutex); 548 if (msgimplp->im_rp_timeout_id != 0) { 549 ibmf_i_unset_timer(msgimplp, IBMF_RESP_TIMER); 558 (msgimplp 1082 ibmf_i_handle_non_rmpp(ibmf_client_t *clientp, ibmf_msg_impl_t *msgimplp, uchar_t *mad) argument 1459 ibmf_msg_impl_t *msgimplp; local [all...] |
H A D | ibmf_ud_dest.c | 327 ibmf_i_alloc_ud_dest(ibmf_client_t *clientp, ibmf_msg_impl_t *msgimplp, argument 340 tnf_opaque, clientp, clientp, tnf_opaque, msg, msgimplp, 346 addrp = &msgimplp->im_local_addr; 366 if (msgimplp->im_msg_flags & IBMF_MSG_FLAGS_GLOBAL_ADDRESS) { 368 adds_vec.av_flow = msgimplp->im_global_addr.ig_flow_label; 370 adds_vec.av_tclass = msgimplp->im_global_addr.ig_tclass; 371 adds_vec.av_hop = msgimplp->im_global_addr.ig_hop_limit; 372 if (msgimplp->im_unsolicited == B_TRUE) { 374 msgimplp->im_global_addr.ig_recver_gid; 376 msgimplp 467 ibmf_i_free_ud_dest(ibmf_client_t *clientp, ibmf_msg_impl_t *msgimplp) argument [all...] |
H A D | ibmf_impl.c | 1939 ibmf_msg_impl_t *msgimplp; local 1948 msgimplp = (ibmf_msg_impl_t *)kmem_zalloc(sizeof (ibmf_msg_impl_t), 1950 if (msgimplp != NULL) { 1964 *msgp = msgimplp; 1976 ibmf_i_free_msg(ibmf_msg_impl_t *msgimplp) argument 1978 ibmf_msg_bufs_t *msgbufp = &msgimplp->im_msgbufs_recv; 1979 ibmf_client_t *clientp = (ibmf_client_t *)msgimplp->im_client; 1984 "ibmf_i_free_msg() enter, msg = %p\n", tnf_opaque, msg, msgimplp); 1987 if (msgimplp->im_ibmf_ud_dest != NULL) { 1988 ibmf_i_free_ud_dest(clientp, msgimplp); 2021 ibmf_i_msg_transport(ibmf_client_t *clientp, ibmf_qp_handle_t ibmf_qp_handle, ibmf_msg_impl_t *msgimplp, int blocking) argument 2351 ibmf_i_init_msg(ibmf_msg_impl_t *msgimplp, ibmf_msg_cb_t trans_cb, void *trans_cb_arg, ibmf_retrans_t *retrans, boolean_t block) argument 3441 ibmf_msg_impl_t *msgimplp; local [all...] |
H A D | ibmf_wqe.c | 845 ibmf_i_init_send_wqe(ibmf_client_t *clientp, ibmf_msg_impl_t *msgimplp, argument 849 ibmf_msg_bufs_t *ipbufs = &msgimplp->im_msgbufs_send; 852 ibmf_rmpp_ctx_t *rmpp_ctx = &msgimplp->im_rmpp_ctx; 862 tnf_opaque, clientp, clientp, tnf_opaque, msg, msgimplp, 878 wqep->send_msg = msgimplp; 884 if (msgimplp->im_flags & IBMF_MSG_FLAGS_SEND_RMPP) { 902 if ((msgimplp->im_flags & IBMF_MSG_FLAGS_SEQUENCED) && 903 ((msgimplp->im_flags & IBMF_MSG_FLAGS_TERMINATION) == 0)) { 904 hdr_ipbufs = &msgimplp->im_msgbufs_send; 905 } else if (msgimplp 1251 ibmf_i_alloc_send_resources(ibmf_ci_t *cip, ibmf_msg_impl_t *msgimplp, boolean_t block, ibmf_send_wqe_t **swqepp) argument 1348 ibmf_i_free_send_resources(ibmf_ci_t *cip, ibmf_msg_impl_t *msgimplp, ibmf_send_wqe_t *swqep) argument [all...] |
H A D | ibmf.c | 844 ibmf_msg_impl_t *msgimplp; local 858 _NOTE(NOW_INVISIBLE_TO_OTHER_THREADS(*msgp,*msgimplp)) 950 msgimplp = (ibmf_msg_impl_t *)msgp; 952 ASSERT(msgimplp->im_client != NULL); 953 ASSERT(msgimplp->im_client == clientp); 955 msgimplp->im_transp_op_flags = flags; 957 mutex_enter(&msgimplp->im_mutex); 960 if (msgimplp->im_msgbufs_send.im_bufs_mad_hdr == NULL) { 961 mutex_exit(&msgimplp->im_mutex); 974 (msgimplp [all...] |
/illumos-gate/usr/src/uts/common/sys/ib/mgt/ibmf/ |
H A D | ibmf_impl.h | 641 ibmf_msg_impl_t *msgimplp, ibt_ud_dest_hdl_t *ud_dest_p, boolean_t block); 643 ibmf_msg_impl_t *msgimplp); 652 void ibmf_i_free_send_resources(ibmf_ci_t *cip, ibmf_msg_impl_t *msgimplp, 659 int ibmf_i_check_for_loopback(ibmf_msg_impl_t *msgimplp, ibmf_msg_cb_t msgp, 664 ibmf_msg_impl_t *msgimplp, int block); 666 ibmf_qp_handle_t ibmf_qp_handle, ibmf_msg_impl_t *msgimplp, int block); 672 ibmf_msg_impl_t *msgimplp, ibt_wr_ds_t *sglp, ibmf_send_wqe_t *wqep, 687 void ibmf_i_init_msg(ibmf_msg_impl_t *msgimplp, ibmf_msg_cb_t trans_cb, 689 void ibmf_i_client_add_msg(ibmf_client_t *clientp, ibmf_msg_impl_t *msgimplp); 690 void ibmf_i_client_rem_msg(ibmf_client_t *clientp, ibmf_msg_impl_t *msgimplp, [all...] |