Home
last modified time | relevance | path

Searched refs:rmpp_ctx (Results 1 – 5 of 5) sorted by relevance

/illumos-gate/usr/src/uts/common/io/ib/mgt/ibmf/
H A Dibmf_rmpp.c91 ibmf_rmpp_ctx_t *rmpp_ctx = &msgimplp->im_rmpp_ctx; in ibmf_i_rmpp_sender_active_flow() local
173 rmpp_ctx->rmpp_state = IBMF_RMPP_STATE_ABORT; in ibmf_i_rmpp_sender_active_flow()
192 b2h32(rmpp_hdr->rmpp_segnum), tnf_uint, wl, rmpp_ctx->rmpp_wl, in ibmf_i_rmpp_sender_active_flow()
193 tnf_uint, wf, rmpp_ctx->rmpp_wf); in ibmf_i_rmpp_sender_active_flow()
197 if (b2h32(rmpp_hdr->rmpp_segnum) > rmpp_ctx->rmpp_wl) { in ibmf_i_rmpp_sender_active_flow()
220 rmpp_ctx->rmpp_state = IBMF_RMPP_STATE_ABORT; in ibmf_i_rmpp_sender_active_flow()
232 if (b2h32(rmpp_hdr->rmpp_segnum) < rmpp_ctx->rmpp_wf) { in ibmf_i_rmpp_sender_active_flow()
252 if (b2h32(rmpp_hdr->rmpp_pyldlen_nwl) < rmpp_ctx->rmpp_wl) { in ibmf_i_rmpp_sender_active_flow()
275 rmpp_ctx->rmpp_state = IBMF_RMPP_STATE_ABORT; in ibmf_i_rmpp_sender_active_flow()
289 if (b2h32(rmpp_hdr->rmpp_segnum) == rmpp_ctx->rmpp_num_pkts) { in ibmf_i_rmpp_sender_active_flow()
[all …]
H A Dibmf_timers.c43 ibmf_rmpp_ctx_t *rmpp_ctx; in ibmf_i_set_timer() local
78 rmpp_ctx = &msgimplp->im_rmpp_ctx; in ibmf_i_set_timer()
81 if (rmpp_ctx->rmpp_flags & IBMF_CTX_RMPP_FLAGS_DYN_PYLD) { in ibmf_i_set_timer()
188 ibmf_rmpp_ctx_t *rmpp_ctx; in ibmf_i_recv_timeout() local
229 rmpp_ctx = &msgimplp->im_rmpp_ctx; in ibmf_i_recv_timeout()
232 if (rmpp_ctx->rmpp_state == IBMF_RMPP_STATE_RECEVR_ACTIVE) { in ibmf_i_recv_timeout()
254 rmpp_ctx->rmpp_state = IBMF_RMPP_STATE_ABORT; in ibmf_i_recv_timeout()
264 } else if (rmpp_ctx->rmpp_state == IBMF_RMPP_STATE_RECEVR_TERMINATE) { in ibmf_i_recv_timeout()
271 rmpp_ctx->rmpp_state = IBMF_RMPP_STATE_DONE; in ibmf_i_recv_timeout()
373 ibmf_rmpp_ctx_t *rmpp_ctx; in ibmf_i_send_timeout() local
[all …]
H A Dibmf_wqe.c852 ibmf_rmpp_ctx_t *rmpp_ctx = &msgimplp->im_rmpp_ctx; in ibmf_i_init_send_wqe() local
886 (rmpp_ctx->rmpp_ns - 1) * rmpp_ctx->rmpp_pkt_data_sz; in ibmf_i_init_send_wqe()
887 data_sz = (rmpp_ctx->rmpp_ns == rmpp_ctx->rmpp_num_pkts) ? in ibmf_i_init_send_wqe()
888 rmpp_ctx->rmpp_last_pkt_sz : rmpp_ctx->rmpp_pkt_data_sz; in ibmf_i_init_send_wqe()
944 tnf_opaque, rmpp_type, rmpp_ctx->rmpp_type, in ibmf_i_init_send_wqe()
945 tnf_opaque, next_seg, rmpp_ctx->rmpp_ns, in ibmf_i_init_send_wqe()
946 tnf_opaque, num_pkts, rmpp_ctx->rmpp_num_pkts); in ibmf_i_init_send_wqe()
951 rmpp_ctx->rmpp_flags = IBMF_RMPP_FLAGS_ACTIVE; in ibmf_i_init_send_wqe()
954 if (rmpp_ctx->rmpp_type == IBMF_RMPP_TYPE_DATA) { in ibmf_i_init_send_wqe()
956 if (rmpp_ctx->rmpp_ns == 1) in ibmf_i_init_send_wqe()
[all …]
H A Dibmf_msg.c295 ibmf_rmpp_ctx_t *rmpp_ctx; in ibmf_i_find_msg() local
299 rmpp_ctx = &msgimplp->im_rmpp_ctx; in ibmf_i_find_msg()
302 ((rmpp_ctx->rmpp_state == in ibmf_i_find_msg()
304 (rmpp_ctx->rmpp_state == in ibmf_i_find_msg()
373 ibmf_rmpp_ctx_t *rmpp_ctx = &msgimplp->im_rmpp_ctx; in ibmf_i_find_msg() local
376 _NOTE(NOW_INVISIBLE_TO_OTHER_THREADS(*rmpp_ctx)) in ibmf_i_find_msg()
398 if ((rmpp_ctx->rmpp_state == in ibmf_i_find_msg()
400 (rmpp_ctx->rmpp_state == in ibmf_i_find_msg()
425 if ((rmpp_ctx->rmpp_state == in ibmf_i_find_msg()
427 (rmpp_ctx->rmpp_state == in ibmf_i_find_msg()
H A Dibmf_recv.c1085 ibmf_rmpp_ctx_t *rmpp_ctx = &msgimplp->im_rmpp_ctx; in ibmf_i_handle_non_rmpp() local
1153 rmpp_ctx->rmpp_state = IBMF_RMPP_STATE_DONE; in ibmf_i_handle_non_rmpp()