Function DoraXrtHttpStreamProcess

Source/Http/XrtHttpClient.c:656–674

}

static int DoraXrtHttpStreamProcess(DoraXrtHttpStreamContext* ctx) {
	if (!DoraXrtHttpParseHeaders(ctx)) {
		DoraXrtHttpStreamCloseWith(ctx, XRT_NET_ERROR);
		return 0;
	}
	if (!ctx->headerParsed || ctx->noBody || __xnetAtomicLoad32(&ctx->closeRequested) != 0) {
		return 1;
	}
	if (ctx->bodyMode == DORA_XRT_HTTP_BODY_CHUNKED) {
		return DoraXrtHttpProcessChunkedBody(ctx);
	}
	if (ctx->bodyMode == DORA_XRT_HTTP_BODY_CONTENT_LENGTH) {
		return DoraXrtHttpProcessFixedBody(ctx);
	}
	if (ctx->bodyMode == DORA_XRT_HTTP_BODY_CLOSE_DELIMITED) {
		return DoraXrtHttpProcessCloseDelimitedBody(ctx);
	}
	return 1;
}

static void DoraXrtHttpStreamOnOpen(ptr owner, xnetstream* stream) {
	DoraXrtHttpStreamContext* ctx = (DoraXrtHttpStreamContext*)owner;