Function DoraXrtHttpExecuteStreamOnce

Source/Http/XrtHttpClient.c:768–902

}

static xnet_result DoraXrtHttpExecuteStreamOnce(
	const char* method,
	const char* url,
	const char* const* headerNames,
	const char* const* headerValues,
	size_t headerCount,
	const void* body,
	size_t bodyLen,
	unsigned int timeoutMs,
	int verifyPeer,
	DoraXrtHttpShouldCancel shouldCancel,
	void* cancelUserData,
	DoraXrtHttpStreamHandler onChunk,
	void* streamUserData,
	int* statusCode,
	char* redirectLocation,
	size_t redirectLocationCap) {
	xhttprequest request;
	xnetengine* engine;
	xnetconnectconfig connectConfig;
	xtlsconfig tlsConfig;
	DoraXrtHttpStreamContext ctx;
	xnet_result status = XRT_NET_ERROR;
	double startTime = xrtTimer();

	if (statusCode) {
		*statusCode = 0;
	}
	if (redirectLocation && redirectLocationCap > 0u) {
		redirectLocation[0] = '\0';
	}
	if (!method || !url) {
		return XRT_NET_ERROR;
	}

	memset(&ctx, 0, sizeof(ctx));
	ctx.finalStatus = XRT_NET_AGAIN;
	ctx.onChunk = onChunk;
	ctx.streamUserData = streamUserData;
	ctx.future = xrtNetFutureCreate();
	if (!ctx.future) {
		return XRT_NET_ERROR;
	}

	xrtHttpRequestInit(&request);
	if (!xrtHttpRequestSetMethod(&request, method) ||
		!xrtHttpRequestSetURL(&request, url)) {
		xrtHttpRequestUnit(&request);
		xrtNetFutureDestroy(ctx.future);
		return XRT_NET_ERROR;
	}
	for (size_t i = 0; i < headerCount; ++i) {
		if (headerNames && headerValues && headerNames[i] && headerValues[i]) {
			(void)xrtHttpRequestSetHeader(&request, headerNames[i], headerValues[i]);
		}
	}
	if (!DoraXrtHttpHasHeader(headerNames, headerCount, "User-Agent")) {
		(void)xrtHttpRequestSetHeader(&request, "User-Agent", DORA_XRT_HTTP_USER_AGENT);