Lines Matching refs:p_ctx
49 osmv_rmpp_send_ctx_init(osmv_rmpp_send_ctx_t * p_ctx, void *p_arbt_mad,
55 CL_ASSERT(p_ctx);
61 p_ctx->is_sa_mad = TRUE;
63 p_ctx->is_sa_mad = FALSE;
65 p_ctx->mad_sz = mad_sz;
67 cl_event_construct(&p_ctx->event);
68 cl_st = cl_event_init(&p_ctx->event, FALSE);
73 st = osmv_rmpp_sar_init(&p_ctx->sar, p_arbt_mad, p_ctx->mad_sz,
74 p_ctx->is_sa_mad);
76 p_ctx->window_first = 1;
77 p_ctx->window_last = 1;
80 p_ctx->p_log = p_log;
84 void osmv_rmpp_send_ctx_done(IN osmv_rmpp_send_ctx_t * p_ctx)
86 CL_ASSERT(p_ctx);
87 cl_event_destroy(&p_ctx->event);
88 osmv_rmpp_sar_done(&p_ctx->sar);
89 free(p_ctx);
186 osmv_rmpp_recv_ctx_init(osmv_rmpp_recv_ctx_t * p_ctx, osm_log_t * p_log)
190 CL_ASSERT(p_ctx);
192 p_ctx->is_sa_mad = FALSE;
194 p_ctx->p_rbuf = malloc(sizeof(cl_qlist_t));
195 if (p_ctx->p_rbuf) {
196 memset(p_ctx->p_rbuf, 0, sizeof(cl_qlist_t));
197 cl_qlist_init(p_ctx->p_rbuf);
198 p_ctx->expected_seg = 1;
202 p_ctx->p_log = p_log;
207 void osmv_rmpp_recv_ctx_done(IN osmv_rmpp_recv_ctx_t * p_ctx)
212 CL_ASSERT(p_ctx);
215 p_list_item = cl_qlist_remove_head(p_ctx->p_rbuf);
216 while (p_list_item != cl_qlist_end(p_ctx->p_rbuf)) {
223 p_list_item = cl_qlist_remove_head(p_ctx->p_rbuf);
226 osmv_rmpp_sar_done(&p_ctx->sar);
228 free(p_ctx->p_rbuf);
229 free(p_ctx);