Lines Matching refs:parser_remaining
811 ctx->parser_remaining = 4; in websocket_parse()
814 ctx->parser_remaining = ctx->message_len; in websocket_parse()
816 (ctx->parser_remaining == 0) in websocket_parse()
822 ctx->parser_remaining = (len < 127) ? 2 : 8; in websocket_parse()
827 ctx->parser_remaining--; in websocket_parse()
828 ctx->message_len |= ((uint64_t)data << (ctx->parser_remaining * 8)); in websocket_parse()
829 if (ctx->parser_remaining == 0) { in websocket_parse()
832 ctx->parser_remaining = 4; in websocket_parse()
835 ctx->parser_remaining = ctx->message_len; in websocket_parse()
841 ctx->parser_remaining--; in websocket_parse()
842 ctx->masking_value |= (data << (ctx->parser_remaining * 8)); in websocket_parse()
843 if (ctx->parser_remaining == 0) { in websocket_parse()
845 ctx->parser_remaining = 0; in websocket_parse()
848 ctx->parser_remaining = ctx->message_len; in websocket_parse()
870 MIN(remaining_in_recv_buf, ctx->parser_remaining); in websocket_parse()
882 ctx->parser_remaining -= ready_to_copy; in websocket_parse()
883 if (ctx->parser_remaining == 0) { in websocket_parse()
884 ctx->parser_remaining = 0; in websocket_parse()
1032 *remaining = ctx->parser_remaining; in websocket_recv_msg()
1054 size_t data_buf_offset = ctx->message_len - ctx->parser_remaining - payload.count; in websocket_recv_msg()