Searched refs:p_recv_ctx (Results 1 – 3 of 3) sorted by relevance
233 osmv_rmpp_recv_ctx_store_mad_seg(IN osmv_rmpp_recv_ctx_t * p_recv_ctx, in osmv_rmpp_recv_ctx_store_mad_seg() argument239 OSM_LOG_ENTER(p_recv_ctx->p_log); in osmv_rmpp_recv_ctx_store_mad_seg()241 CL_ASSERT(p_recv_ctx); in osmv_rmpp_recv_ctx_store_mad_seg()257 cl_qlist_insert_tail(p_recv_ctx->p_rbuf, &p_obj->list_item); in osmv_rmpp_recv_ctx_store_mad_seg()260 p_recv_ctx->is_sa_mad = TRUE; in osmv_rmpp_recv_ctx_store_mad_seg()268 osmv_rmpp_recv_ctx_get_cur_byte_num(IN osmv_rmpp_recv_ctx_t * p_recv_ctx) in osmv_rmpp_recv_ctx_get_cur_byte_num() argument272 num_segs = cl_qlist_count(p_recv_ctx->p_rbuf); in osmv_rmpp_recv_ctx_get_cur_byte_num()273 if (p_recv_ctx->is_sa_mad) in osmv_rmpp_recv_ctx_get_cur_byte_num()280 osmv_rmpp_recv_ctx_get_byte_num_from_first(IN osmv_rmpp_recv_ctx_t * p_recv_ctx) in osmv_rmpp_recv_ctx_get_byte_num_from_first() argument287 p_item = cl_qlist_head(p_recv_ctx->p_rbuf); in osmv_rmpp_recv_ctx_get_byte_num_from_first()[all …]
490 osmv_rmpp_recv_ctx_t *p_recv_ctx = osmv_txn_get_rmpp_recv_ctx(p_txn); in __osmv_dispatch_rmpp_rcv() local529 size = osmv_rmpp_recv_ctx_get_byte_num_from_first(p_recv_ctx); in __osmv_dispatch_rmpp_rcv()532 (osmv_rmpp_recv_ctx_get_cur_byte_num(p_recv_ctx) >= in __osmv_dispatch_rmpp_rcv()577 size = osmv_rmpp_recv_ctx_get_byte_num_from_last(p_recv_ctx); in __osmv_dispatch_rmpp_rcv()605 status = osmv_rmpp_recv_ctx_reassemble_arbt_mad(p_recv_ctx, size, in __osmv_dispatch_rmpp_rcv()652 osmv_rmpp_recv_ctx_t *p_recv_ctx = osmv_txn_get_rmpp_recv_ctx(p_txn); in __osmv_dispatch_accept_seg() local658 if (seg_num != p_recv_ctx->expected_seg) { in __osmv_dispatch_accept_seg()668 ret = osmv_rmpp_recv_ctx_store_mad_seg(p_recv_ctx, (uint8_t *) p_mad); in __osmv_dispatch_accept_seg()675 p_recv_ctx->expected_seg = seg_num + 1; in __osmv_dispatch_accept_seg()697 osmv_rmpp_recv_ctx_t *p_recv_ctx = osmv_txn_get_rmpp_recv_ctx(p_txn); in __osmv_dispatch_send_ack() local[all …]
234 osmv_rmpp_recv_ctx_get_es(IN const osmv_rmpp_recv_ctx_t * p_recv_ctx) in osmv_rmpp_recv_ctx_get_es() argument236 CL_ASSERT(p_recv_ctx); in osmv_rmpp_recv_ctx_get_es()237 return p_recv_ctx->expected_seg; in osmv_rmpp_recv_ctx_get_es()249 osmv_rmpp_recv_ctx_set_es(IN osmv_rmpp_recv_ctx_t * p_recv_ctx, IN uint32_t val) in osmv_rmpp_recv_ctx_set_es() argument251 CL_ASSERT(p_recv_ctx); in osmv_rmpp_recv_ctx_set_es()252 p_recv_ctx->expected_seg = val; in osmv_rmpp_recv_ctx_set_es()264 osmv_rmpp_recv_ctx_store_mad_seg(IN osmv_rmpp_recv_ctx_t * p_recv_ctx,268 osmv_rmpp_recv_ctx_get_cur_byte_num(IN osmv_rmpp_recv_ctx_t * p_recv_ctx);272 p_recv_ctx);275 osmv_rmpp_recv_ctx_get_byte_num_from_last(IN osmv_rmpp_recv_ctx_t * p_recv_ctx);[all …]