Home
last modified time | relevance | path

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

/titanic_44/usr/src/uts/common/io/ib/mgt/ibmf/
H A Dibmf_rmpp.c93 ibmf_rmpp_ctx_t *rmpp_ctx = &msgimplp->im_rmpp_ctx; in ibmf_i_rmpp_sender_active_flow() local
175 rmpp_ctx->rmpp_state = IBMF_RMPP_STATE_ABORT; in ibmf_i_rmpp_sender_active_flow()
194 b2h32(rmpp_hdr->rmpp_segnum), tnf_uint, wl, rmpp_ctx->rmpp_wl, in ibmf_i_rmpp_sender_active_flow()
195 tnf_uint, wf, rmpp_ctx->rmpp_wf); in ibmf_i_rmpp_sender_active_flow()
199 if (b2h32(rmpp_hdr->rmpp_segnum) > rmpp_ctx->rmpp_wl) { in ibmf_i_rmpp_sender_active_flow()
222 rmpp_ctx->rmpp_state = IBMF_RMPP_STATE_ABORT; in ibmf_i_rmpp_sender_active_flow()
234 if (b2h32(rmpp_hdr->rmpp_segnum) < rmpp_ctx->rmpp_wf) { in ibmf_i_rmpp_sender_active_flow()
254 if (b2h32(rmpp_hdr->rmpp_pyldlen_nwl) < rmpp_ctx->rmpp_wl) { in ibmf_i_rmpp_sender_active_flow()
277 rmpp_ctx->rmpp_state = IBMF_RMPP_STATE_ABORT; in ibmf_i_rmpp_sender_active_flow()
291 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_msg.c297 ibmf_rmpp_ctx_t *rmpp_ctx; in ibmf_i_find_msg() local
301 rmpp_ctx = &msgimplp->im_rmpp_ctx; in ibmf_i_find_msg()
304 ((rmpp_ctx->rmpp_state == in ibmf_i_find_msg()
306 (rmpp_ctx->rmpp_state == in ibmf_i_find_msg()
375 ibmf_rmpp_ctx_t *rmpp_ctx = &msgimplp->im_rmpp_ctx; in ibmf_i_find_msg() local
378 _NOTE(NOW_INVISIBLE_TO_OTHER_THREADS(*rmpp_ctx)) in ibmf_i_find_msg()
400 if ((rmpp_ctx->rmpp_state == in ibmf_i_find_msg()
402 (rmpp_ctx->rmpp_state == in ibmf_i_find_msg()
427 if ((rmpp_ctx->rmpp_state == in ibmf_i_find_msg()
429 (rmpp_ctx->rmpp_state == in ibmf_i_find_msg()
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_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()