/illumos-gate/usr/src/uts/common/io/ib/mgt/ibmf/ |
H A D | ibmf_timers.c | 155 tnf_opaque, msgimplp, msgimplp); in ibmf_i_unset_timer() 218 tnf_opaque, msgimplp, msgimplp); in ibmf_i_recv_timeout() 403 tnf_opaque, msgimplp, msgimplp); in ibmf_i_send_timeout() 427 tnf_opaque, msgimplp, msgimplp); in ibmf_i_send_timeout() 455 tnf_opaque, msgimplp, msgimplp, in ibmf_i_send_timeout() 463 msgimplp->im_qp_hdl, msgimplp, IBMF_NO_BLOCK); in ibmf_i_send_timeout() 472 tnf_opaque, msgimplp, msgimplp); in ibmf_i_send_timeout() 482 tnf_opaque, msgimplp, msgimplp, in ibmf_i_send_timeout() 527 tnf_opaque, msgimplp, msgimplp); in ibmf_i_send_timeout() 552 tnf_opaque, msgimplp, msgimplp, in ibmf_i_send_timeout() [all …]
|
H A D | ibmf_msg.c | 257 msgimplp = msgimplp->im_msg_next; in ibmf_i_find_msg() 275 msgimplp = msgimplp->im_msg_next; in ibmf_i_find_msg() 284 msgimplp = msgimplp->im_msg_next; in ibmf_i_find_msg() 309 msgimplp = msgimplp->im_msg_next; in ibmf_i_find_msg() 337 msgimplp = msgimplp->im_msg_next; in ibmf_i_find_msg() 418 msgimplp = msgimplp-> in ibmf_i_find_msg() 441 msgimplp = msgimplp-> in ibmf_i_find_msg() 470 msgimplp = msgimplp-> im_msg_next; in ibmf_i_find_msg() 490 tnf_opaque, msgimplp, msgimplp, in ibmf_i_find_msg() 539 tnf_opaque, msgimplp, msgimplp, in ibmf_i_find_msg_client() [all …]
|
H A D | ibmf_trans.c | 116 tnf_opaque, msgimplp, msgimplp); in ibmf_i_notify_client() 118 clientp = msgimplp->im_client; in ibmf_i_notify_client() 191 ibmf_i_free_msg(msgimplp); in ibmf_i_notify_client() 308 tnf_opaque, msgimplp, msgimplp); in ibmf_i_notify_client() 316 tnf_opaque, msgimplp, msgimplp); in ibmf_i_notify_client() 336 tnf_opaque, msgimplp, msgimplp); in ibmf_i_notify_client() 339 msgimplp->im_trans_cb( in ibmf_i_notify_client() 365 tnf_opaque, clientp, clientp, tnf_opaque, msgimplp, msgimplp); in ibmf_i_notify_sequence() 372 tnf_opaque, msgimplp, msgimplp); in ibmf_i_notify_sequence() 401 tnf_opaque, msgimplp, msgimplp); in ibmf_i_notify_sequence() [all …]
|
H A D | ibmf_rmpp.c | 295 tnf_opaque, msgimplp, msgimplp, in ibmf_i_rmpp_sender_active_flow() 305 tnf_opaque, msgimplp, msgimplp); in ibmf_i_rmpp_sender_active_flow() 678 msgimplp->im_client, msgimplp, in ibmf_i_rmpp_recvr_flow_main() 858 msgimplp->im_client, msgimplp, in ibmf_i_rmpp_recvr_flow_main() 932 msgimplp->im_client, msgimplp, in ibmf_i_rmpp_recvr_flow_main() 1233 tnf_opaque, msgimplp, msgimplp, tnf_opaque, in ibmf_i_rmpp_recvr_term_flow() 1246 tnf_opaque, msgimplp, msgimplp); in ibmf_i_rmpp_recvr_term_flow() 1259 tnf_opaque, msgimplp, msgimplp); in ibmf_i_rmpp_recvr_term_flow() 1275 tnf_opaque, msgimplp, msgimplp); in ibmf_i_rmpp_recvr_term_flow() 1679 status = ibmf_i_send_pkt(msgimplp->im_client, msgimplp->im_qp_hdl, in ibmf_i_send_rmpp() [all …]
|
H A D | ibmf_send.c | 166 msgimplp, block, &send_wqep); in ibmf_i_send_pkt() 283 ibmf_msg_impl_t *msgimplp; in ibmf_i_handle_send_completion() local 289 msgimplp = send_wqep->send_msg; in ibmf_i_handle_send_completion() 395 ibmf_msg_impl_t *msgimplp; in ibmf_i_do_send_cb() local 417 msgimplp = send_wqep->send_msg; in ibmf_i_do_send_cb() 570 "send cb", tnf_opaque, msgimplp, msgimplp); in ibmf_i_do_send_cb() 581 msg_flags = msgimplp->im_flags; in ibmf_i_do_send_cb() 592 IBMF_MSG_DECR_REFCNT(msgimplp); in ibmf_i_do_send_cb() 627 tnf_opaque, msgimplp, msgimplp); in ibmf_i_do_send_cb() 688 tnf_opaque, ibmf_hdl, ibmf_handle, tnf_opaque, msgimplp, msgimplp, in ibmf_i_do_send_compl() [all …]
|
H A D | ibmf_dr.c | 58 tnf_opaque, msg, msgimplp); in ibmf_i_check_for_loopback() 86 msgimplp, blocking); in ibmf_i_check_for_loopback() 124 mutex_enter(&msgimplp->im_mutex); in ibmf_i_dr_loopback_term() 145 cv_wait(&msgimplp->im_trans_cv, &msgimplp->im_mutex); in ibmf_i_dr_loopback_term() 152 mutex_exit(&msgimplp->im_mutex); in ibmf_i_dr_loopback_term() 154 } else if ((msgimplp->im_flags & in ibmf_i_dr_loopback_term() 178 mutex_exit(&msgimplp->im_mutex); in ibmf_i_dr_loopback_term() 182 if (msgimplp->im_trans_cb) { in ibmf_i_dr_loopback_term() 184 (ibmf_msg_t *)msgimplp, msgimplp->im_trans_cb_arg); in ibmf_i_dr_loopback_term() 189 mutex_exit(&msgimplp->im_mutex); in ibmf_i_dr_loopback_term() [all …]
|
H A D | ibmf_recv.c | 431 ibmf_msg_impl_t *msgimplp; in ibmf_i_do_recv_cb() local 515 if (msgimplp == NULL) { in ibmf_i_do_recv_cb() 522 if (msgimplp != NULL) { in ibmf_i_do_recv_cb() 568 "dropping MAD", tnf_opaque, msgimplp, msgimplp); in ibmf_i_do_recv_cb() 619 tnf_opaque, msgimplp, msgimplp); in ibmf_i_do_recv_cb() 714 if (msgimplp == NULL) { in ibmf_i_do_recv_cb() 786 kmem_free(msgimplp, in ibmf_i_do_recv_cb() 814 msgimplp->im_flags = 0; in ibmf_i_do_recv_cb() 935 tnf_opaque, msgimplp, msgimplp); in ibmf_i_do_recv_cb() 1052 tnf_opaque, msgimplp, msgimplp); in ibmf_i_do_recv_cb() [all …]
|
H A D | ibmf_impl.c | 1950 if (msgimplp != NULL) { in ibmf_i_alloc_msg() 1964 *msgp = msgimplp; in ibmf_i_alloc_msg() 2094 msgimplp, tnf_opaque, class, msgimplp->im_mgt_class, tnf_opaque, in ibmf_i_msg_transport() 2101 tnf_opaque, msgimplp, msgimplp, tnf_opaque, tid, msgimplp->im_tid, in ibmf_i_msg_transport() 2137 tnf_opaque, msgimplp, msgimplp, in ibmf_i_msg_transport() 2190 "unsetting timer %p %d\n", tnf_opaque, msgimplp, msgimplp, in ibmf_i_msg_transport() 2272 tnf_opaque, msgimplp, msgimplp); in ibmf_i_msg_transport() 2275 cv_wait(&msgimplp->im_trans_cv, &msgimplp->im_mutex); in ibmf_i_msg_transport() 2281 tnf_opaque, msgimplp, msgimplp); in ibmf_i_msg_transport() 2336 tnf_string, msg, errmsg, tnf_opaque, msgimplp, msgimplp); in ibmf_i_msg_transport() [all …]
|
H A D | ibmf_ud_dest.c | 344 addrp = &msgimplp->im_local_addr; in ibmf_i_alloc_ud_dest() 370 if (msgimplp->im_unsolicited == B_TRUE) { in ibmf_i_alloc_ud_dest() 372 msgimplp->im_global_addr.ig_recver_gid; in ibmf_i_alloc_ud_dest() 374 msgimplp->im_global_addr.ig_sender_gid; in ibmf_i_alloc_ud_dest() 377 msgimplp->im_global_addr.ig_sender_gid; in ibmf_i_alloc_ud_dest() 379 msgimplp->im_global_addr.ig_recver_gid; in ibmf_i_alloc_ud_dest() 429 msgimplp->im_ibmf_ud_dest = ibmf_ud_dest; in ibmf_i_alloc_ud_dest() 473 mutex_enter(&msgimplp->im_mutex); in ibmf_i_free_ud_dest() 474 msgimplp->im_ibmf_ud_dest = NULL; in ibmf_i_free_ud_dest() 475 msgimplp->im_ud_dest = NULL; in ibmf_i_free_ud_dest() [all …]
|
H A D | ibmf.c | 844 ibmf_msg_impl_t *msgimplp; in ibmf_msg_transport() local 957 mutex_enter(&msgimplp->im_mutex); in ibmf_msg_transport() 961 mutex_exit(&msgimplp->im_mutex); in ibmf_msg_transport() 976 mutex_exit(&msgimplp->im_mutex); in ibmf_msg_transport() 988 mutex_exit(&msgimplp->im_mutex); in ibmf_msg_transport() 1000 mutex_exit(&msgimplp->im_mutex); in ibmf_msg_transport() 1010 mutex_exit(&msgimplp->im_mutex); in ibmf_msg_transport() 1026 mutex_enter(&msgimplp->im_mutex); in ibmf_msg_transport() 1028 mutex_exit(&msgimplp->im_mutex); in ibmf_msg_transport() 1055 mutex_enter(&msgimplp->im_mutex); in ibmf_msg_transport() [all …]
|
H A D | ibmf_wqe.c | 878 wqep->send_msg = msgimplp; in ibmf_i_init_send_wqe() 904 hdr_ipbufs = &msgimplp->im_msgbufs_send; in ibmf_i_init_send_wqe() 906 hdr_ipbufs = &msgimplp->im_msgbufs_recv; in ibmf_i_init_send_wqe() 908 hdr_ipbufs = &msgimplp->im_msgbufs_send; in ibmf_i_init_send_wqe() 910 if (msgimplp->im_unsolicited == B_TRUE) { in ibmf_i_init_send_wqe() 925 if (msgimplp->im_unsolicited == B_TRUE) { in ibmf_i_init_send_wqe() 943 tnf_opaque, msgimplp, msgimplp, in ibmf_i_init_send_wqe() 980 tnf_opaque, msgimplp, msgimplp, in ibmf_i_init_send_wqe() 1263 msgimplp, tnf_uint, block, block); in ibmf_i_alloc_send_resources() 1332 send_wqep->send_msg = msgimplp; in ibmf_i_alloc_send_resources() [all …]
|
/illumos-gate/usr/src/uts/common/sys/ib/mgt/ibmf/ |
H A D | ibmf_impl.h | 643 ibmf_msg_impl_t *msgimplp); 664 ibmf_msg_impl_t *msgimplp, int block); 687 void ibmf_i_init_msg(ibmf_msg_impl_t *msgimplp, ibmf_msg_cb_t trans_cb, 694 void ibmf_i_free_msg(ibmf_msg_impl_t *msgimplp); 697 void ibmf_i_decrement_ref_count(ibmf_msg_impl_t *msgimplp); 704 ibmf_msg_impl_t *msgimplp, uint32_t status); 705 void ibmf_i_notify_client(ibmf_msg_impl_t *msgimplp); 710 void ibmf_i_set_timer(void (*func)(void *), ibmf_msg_impl_t *msgimplp, 712 void ibmf_i_unset_timer(ibmf_msg_impl_t *msgimplp, ibmf_timer_t type); 734 int ibmf_i_send_rmpp(ibmf_msg_impl_t *msgimplp, uint8_t rmpp_type, [all …]
|