| 642 | } |
| 643 | |
| 644 | static int DoraXrtHttpProcessCloseDelimitedBody(DoraXrtHttpStreamContext* ctx) { |
| 645 | if (ctx->pendingLen == 0u) { |
| 646 | return 1; |
| 647 | } |
| 648 | ctx->received += ctx->pendingLen; |
| 649 | if (!DoraXrtHttpDeliverChunk(ctx, ctx->pending, ctx->pendingLen, 0u)) { |
| 650 | return 0; |
| 651 | } |
| 652 | DoraXrtHttpStreamConsume(ctx, ctx->pendingLen); |
| 653 | return 1; |
| 654 | } |
| 655 | |
| 656 | static int DoraXrtHttpStreamProcess(DoraXrtHttpStreamContext* ctx) { |
| 657 | if (!DoraXrtHttpParseHeaders(ctx)) { |
no test coverage detected