Function DoraXrtHttpStreamOnRecv

Source/Http/XrtHttpClient.c:686–716

}

static void DoraXrtHttpStreamOnRecv(ptr owner, xnetstream* stream, xnetchain* chain) {
	DoraXrtHttpStreamContext* ctx = (DoraXrtHttpStreamContext*)owner;
	size_t len;
	char* data;
	(void)stream;
	if (!ctx || !chain || __xnetAtomicLoad32(&ctx->closeRequested) != 0) {
		return;
	}
	len = xrtNetChainBytes(chain);
	if (len == 0u) {
		return;
	}
	data = (char*)malloc(len);
	if (!data) {
		DoraXrtHttpStreamCloseWith(ctx, XRT_NET_ERROR);
		return;
	}
	if (xrtNetChainPeek(chain, data, len) != len) {
		free(data);
		DoraXrtHttpStreamCloseWith(ctx, XRT_NET_ERROR);
		return;
	}
	xrtNetChainConsume(chain, len);
	if (!DoraXrtHttpStreamAppend(ctx, data, len)) {
		free(data);
		DoraXrtHttpStreamCloseWith(ctx, XRT_NET_ERROR);
		return;
	}
	free(data);
	(void)DoraXrtHttpStreamProcess(ctx);
}

static void DoraXrtHttpStreamOnClose(ptr owner, xnetstream* stream, xnet_result reason) {
	DoraXrtHttpStreamContext* ctx = (DoraXrtHttpStreamContext*)owner;