Lines Matching refs:frag_ctx

534 		flags = ctx->frag_ctx.flags;  in spoe_prepare_hanotify_frame()
585 stream_id = SPOE_APPCTX(appctx)->frag_ctx.cursid; in spoe_prepare_hafrag_frame()
586 frame_id = SPOE_APPCTX(appctx)->frag_ctx.curfid; in spoe_prepare_hafrag_frame()
589 flags = ctx->frag_ctx.flags; in spoe_prepare_hafrag_frame()
987 if (SPOE_APPCTX(appctx)->frag_ctx.ctx && in spoe_handle_agentack_frame()
988 SPOE_APPCTX(appctx)->frag_ctx.cursid == (unsigned int)stream_id && in spoe_handle_agentack_frame()
989 SPOE_APPCTX(appctx)->frag_ctx.curfid == (unsigned int)frame_id) { in spoe_handle_agentack_frame()
993 *ctx = SPOE_APPCTX(appctx)->frag_ctx.ctx; in spoe_handle_agentack_frame()
1020 SPOE_APPCTX(appctx)->frag_ctx.ctx) in spoe_handle_agentack_frame()
1275 if (spoe_appctx->frag_ctx.ctx) { in spoe_release_appctx()
1276 ctx = spoe_appctx->frag_ctx.ctx; in spoe_release_appctx()
1485 ctx = SPOE_APPCTX(appctx)->frag_ctx.ctx; in spoe_handle_sending_frame_appctx()
1540 (ctx->frag_ctx.flags & SPOE_FRM_FL_FIN)) in spoe_handle_sending_frame_appctx()
1550 SPOE_APPCTX(appctx)->frag_ctx.ctx = ctx; in spoe_handle_sending_frame_appctx()
1551 SPOE_APPCTX(appctx)->frag_ctx.cursid = ctx->stream_id; in spoe_handle_sending_frame_appctx()
1552 SPOE_APPCTX(appctx)->frag_ctx.curfid = ctx->frame_id; in spoe_handle_sending_frame_appctx()
1573 SPOE_APPCTX(appctx)->frag_ctx.ctx = NULL; in spoe_handle_sending_frame_appctx()
1574 SPOE_APPCTX(appctx)->frag_ctx.cursid = 0; in spoe_handle_sending_frame_appctx()
1575 SPOE_APPCTX(appctx)->frag_ctx.curfid = 0; in spoe_handle_sending_frame_appctx()
1583 SPOE_APPCTX(appctx)->frag_ctx.ctx = NULL; in spoe_handle_sending_frame_appctx()
1584 SPOE_APPCTX(appctx)->frag_ctx.cursid = 0; in spoe_handle_sending_frame_appctx()
1585 SPOE_APPCTX(appctx)->frag_ctx.curfid = 0; in spoe_handle_sending_frame_appctx()
1635 ctx == SPOE_APPCTX(appctx)->frag_ctx.ctx) { in spoe_handle_receiving_frame_appctx()
1637 SPOE_APPCTX(appctx)->frag_ctx.ctx = NULL; in spoe_handle_receiving_frame_appctx()
1638 SPOE_APPCTX(appctx)->frag_ctx.cursid = 0; in spoe_handle_receiving_frame_appctx()
1639 SPOE_APPCTX(appctx)->frag_ctx.curfid = 0; in spoe_handle_receiving_frame_appctx()
2183 if (ctx->frag_ctx.curarg != NULL) { in spoe_encode_message()
2184 arg = ctx->frag_ctx.curarg; in spoe_encode_message()
2188 if (ctx->frag_ctx.curoff != UINT_MAX) in spoe_encode_message()
2205 ctx->frag_ctx.curoff = 0; in spoe_encode_message()
2210 ctx->frag_ctx.curarg = arg; in spoe_encode_message()
2211 ctx->frag_ctx.curoff = UINT_MAX; in spoe_encode_message()
2212 ctx->frag_ctx.curlen = 0; in spoe_encode_message()
2215 if (ctx->frag_ctx.curoff != UINT_MAX) in spoe_encode_message()
2222 ctx->frag_ctx.curoff = 0; in spoe_encode_message()
2228 smp->ctx.a[0] = &ctx->frag_ctx.curlen; in spoe_encode_message()
2229 smp->ctx.a[1] = &ctx->frag_ctx.curoff; in spoe_encode_message()
2232 if (ret == -1 || ctx->frag_ctx.curoff) in spoe_encode_message()
2261 if (ctx->frag_ctx.curmsg != NULL) { in spoe_encode_messages()
2262 msg = ctx->frag_ctx.curmsg; in spoe_encode_messages()
2267 ctx->frag_ctx.curmsg = msg; in spoe_encode_messages()
2268 ctx->frag_ctx.curarg = NULL; in spoe_encode_messages()
2269 ctx->frag_ctx.curoff = UINT_MAX; in spoe_encode_messages()
2278 if (ctx->frag_ctx.curmsg != NULL) { in spoe_encode_messages()
2279 msg = ctx->frag_ctx.curmsg; in spoe_encode_messages()
2284 ctx->frag_ctx.curmsg = msg; in spoe_encode_messages()
2285 ctx->frag_ctx.curarg = NULL; in spoe_encode_messages()
2286 ctx->frag_ctx.curoff = UINT_MAX; in spoe_encode_messages()
2311 ctx->frag_ctx.curmsg = NULL; in spoe_encode_messages()
2312 ctx->frag_ctx.curarg = NULL; in spoe_encode_messages()
2313 ctx->frag_ctx.curoff = 0; in spoe_encode_messages()
2314 ctx->frag_ctx.flags = SPOE_FRM_FL_FIN; in spoe_encode_messages()
2332 ctx->frag_ctx.curmsg, ctx->frag_ctx.curarg, ctx->frag_ctx.curoff, in spoe_encode_messages()
2337 ctx->frag_ctx.flags &= ~SPOE_FRM_FL_FIN; in spoe_encode_messages()
2625 if (sa->frag_ctx.ctx == ctx) { in spoe_stop_processing()
2626 sa->frag_ctx.ctx = NULL; in spoe_stop_processing()
2643 ctx->frag_ctx.curmsg = NULL; in spoe_stop_processing()
2644 ctx->frag_ctx.curarg = NULL; in spoe_stop_processing()
2645 ctx->frag_ctx.curoff = 0; in spoe_stop_processing()
2646 ctx->frag_ctx.flags = 0; in spoe_stop_processing()