Home
last modified time | relevance | path

Searched refs:p_send_ctx (Results 1 – 6 of 6) sorted by relevance

/NextBSD/contrib/ofed/management/opensm/libvendor/
HDosm_vendor_mlx_rmpp_ctx.c92 uint32_t osmv_rmpp_send_ctx_get_num_segs(IN osmv_rmpp_send_ctx_t * p_send_ctx) in osmv_rmpp_send_ctx_get_num_segs() argument
96 CL_ASSERT(p_send_ctx); in osmv_rmpp_send_ctx_get_num_segs()
98 if (p_send_ctx->is_sa_mad) { in osmv_rmpp_send_ctx_get_num_segs()
99 data_len = p_send_ctx->mad_sz - IB_SA_MAD_HDR_SIZE; in osmv_rmpp_send_ctx_get_num_segs()
102 data_len = p_send_ctx->mad_sz - MAD_RMPP_HDR_SIZE; in osmv_rmpp_send_ctx_get_num_segs()
115 osmv_rmpp_send_ctx_get_seg(IN osmv_rmpp_send_ctx_t * p_send_ctx, in osmv_rmpp_send_ctx_get_seg() argument
123 OSM_LOG_ENTER(p_send_ctx->p_log); in osmv_rmpp_send_ctx_get_seg()
124 CL_ASSERT(p_send_ctx); in osmv_rmpp_send_ctx_get_seg()
126 st = osmv_rmpp_sar_get_mad_seg(&p_send_ctx->sar, seg_idx, p_buf); in osmv_rmpp_send_ctx_get_seg()
137 num_segs = osmv_rmpp_send_ctx_get_num_segs(p_send_ctx); in osmv_rmpp_send_ctx_get_seg()
[all …]
HDosm_vendor_mlx_sender.c144 osmv_rmpp_send_ctx_t *p_send_ctx = osmv_txn_get_rmpp_send_ctx(p_txn); in osmv_rmpp_send_madw() local
149 total_segs = osmv_rmpp_send_ctx_get_num_segs(p_send_ctx); in osmv_rmpp_send_madw()
156 if (p_send_ctx->window_first > total_segs) { in osmv_rmpp_send_madw()
163 for (i = p_send_ctx->window_first; i <= p_send_ctx->window_last; in osmv_rmpp_send_madw()
188 cl_event_wait_on(&p_send_ctx->event, in osmv_rmpp_send_madw()
211 if (IB_SUCCESS != p_send_ctx->status) { in osmv_rmpp_send_madw()
215 ib_get_err_str(p_send_ctx->status), p_madw); in osmv_rmpp_send_madw()
216 ret = p_send_ctx->status; in osmv_rmpp_send_madw()
311 osmv_rmpp_send_ctx_t *p_send_ctx; in __osmv_rmpp_send_segment() local
331 p_send_ctx = osmv_txn_get_rmpp_send_ctx(p_txn); in __osmv_rmpp_send_segment()
[all …]
HDosm_vendor_mlx_dispatcher.c392 osmv_rmpp_send_ctx_t *p_send_ctx = osmv_txn_get_rmpp_send_ctx(p_txn); in __osmv_dispatch_rmpp_snd() local
394 uint32_t old_wl = p_send_ctx->window_last; in __osmv_dispatch_rmpp_snd()
395 uint32_t total_segs = osmv_rmpp_send_ctx_get_num_segs(p_send_ctx); in __osmv_dispatch_rmpp_snd()
407 osmv_rmpp_snd_error(p_send_ctx, IB_REMOTE_ERROR); in __osmv_dispatch_rmpp_snd()
428 osmv_rmpp_snd_error(p_send_ctx, IB_REMOTE_ERROR); in __osmv_dispatch_rmpp_snd()
446 osmv_rmpp_snd_error(p_send_ctx, IB_REMOTE_ERROR); in __osmv_dispatch_rmpp_snd()
460 p_send_ctx->window_first, old_wl); in __osmv_dispatch_rmpp_snd()
462 p_send_ctx->window_first = seg_num + 1; in __osmv_dispatch_rmpp_snd()
463 p_send_ctx->window_last = in __osmv_dispatch_rmpp_snd()
470 cl_event_signal(&p_send_ctx->event); in __osmv_dispatch_rmpp_snd()
HDosm_vendor_mlx_txn.c280 osmv_rmpp_send_ctx_t *p_send_ctx; in osmv_txn_abort_rmpp_txns() local
290 p_send_ctx = osmv_txn_get_rmpp_send_ctx(p_txn); in osmv_txn_abort_rmpp_txns()
292 if (NULL != p_send_ctx) { in osmv_txn_abort_rmpp_txns()
294 p_send_ctx->status = IB_INTERRUPTED; in osmv_txn_abort_rmpp_txns()
297 cl_event_signal(&p_send_ctx->event); in osmv_txn_abort_rmpp_txns()
532 osmv_rmpp_send_ctx_t *p_send_ctx; in __osmv_txn_timeout_cb() local
620 p_send_ctx = osmv_txn_get_rmpp_send_ctx(p_txn); in __osmv_txn_timeout_cb()
629 p_send_ctx->status = IB_TIMEOUT; in __osmv_txn_timeout_cb()
641 cl_event_signal(&p_send_ctx->event); in __osmv_txn_timeout_cb()
/NextBSD/contrib/ofed/management/opensm/include/vendor/
HDosm_vendor_mlx_rmpp_ctx.h155 osmv_rmpp_send_ctx_get_wl(IN const osmv_rmpp_send_ctx_t * p_send_ctx) in osmv_rmpp_send_ctx_get_wl() argument
157 CL_ASSERT(p_send_ctx); in osmv_rmpp_send_ctx_get_wl()
158 return p_send_ctx->window_last; in osmv_rmpp_send_ctx_get_wl()
186 uint32_t osmv_rmpp_send_ctx_get_num_segs(IN osmv_rmpp_send_ctx_t * p_send_ctx);
198 osmv_rmpp_send_ctx_get_seg(IN osmv_rmpp_send_ctx_t * p_send_ctx,
HDosm_vendor_mlx_sender.h116 osmv_rmpp_snd_error(IN osmv_rmpp_send_ctx_t * p_send_ctx, in osmv_rmpp_snd_error() argument
119 p_send_ctx->status = status; in osmv_rmpp_snd_error()
124 cl_event_signal(&p_send_ctx->event); in osmv_rmpp_snd_error()