Home
last modified time | relevance | path

Searched refs:msgimplp (Results 1 – 12 of 12) sorted by relevance

/illumos-gate/usr/src/uts/common/io/ib/mgt/ibmf/
H A Dibmf_timers.c155 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 Dibmf_msg.c257 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 Dibmf_trans.c116 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 Dibmf_rmpp.c295 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 Dibmf_send.c166 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 Dibmf_dr.c58 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 Dibmf_recv.c431 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 Dibmf_impl.c1950 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 Dibmf_ud_dest.c344 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 Dibmf.c844 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 Dibmf_wqe.c878 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 Dibmf_impl.h643 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 …]