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

/illumos-gate/usr/src/uts/common/io/ib/mgt/ibmf/
H A Dibmf_trans.c40 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 Dibmf_msg.c42 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 Dibmf_timers.c39 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 Dibmf_rmpp.c41 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 Dibmf_send.c42 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 Dibmf_dr.c38 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 Dibmf_recv.c73 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 Dibmf_ud_dest.c327 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 Dibmf_impl.c1939 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 Dibmf_wqe.c845 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 Dibmf.c844 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 Dibmf_impl.h641 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...]

Completed in 683 milliseconds