From d7e3f9f3cddf314478c1ecd4d9cfebde79f3e945 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=EA=A6=8C=EA=A6=AB=EA=A6=B6=EA=A6=8F=EA=A7=80=EA=A6=A6?=
 =?UTF-8?q?=EA=A6=BF=EA=A6=A7=EA=A6=AE=EA=A6=91=EA=A6=A9=EA=A6=AD=EA=A7=80?=
 <erik@darapsa.co.id>
Date: Sat, 19 Jun 2021 23:23:31 +0800
Subject: C11 threads applied to libcurl related request

---
 request.c | 59 ++++++++++++++++++++++++++++++++++++++++++++---------------
 1 file changed, 44 insertions(+), 15 deletions(-)

diff --git a/request.c b/request.c
index 3e0b857..8668f4b 100644
--- a/request.c
+++ b/request.c
@@ -6,13 +6,26 @@
 #include <stdarg.h>
 #include <string.h>
 #include "request.h"
+
 #ifdef __EMSCRIPTEN__
+
 extern emscripten_fetch_attr_t attr;
+
 #else
+
 #include <threads.h>
 #include <curl/curl.h>
+
 extern char *sampleurl;
 extern CURL *curl;
+
+struct container {
+	CURL *curl;
+	struct curl_httppost *post;
+	void (*handler)(icclient_response *);
+	icclient_response *response;
+};
+
 static size_t append(char *data, size_t size, size_t nmemb, icclient_response *response)
 {
 	size_t realsize = size * nmemb;
@@ -22,6 +35,30 @@ static size_t append(char *data, size_t size, size_t nmemb, icclient_response *r
 	response->data[response->numBytes] = '\0';
 	return realsize;
 }
+
+static int async(void *arg)
+{
+	int ret = thrd_success;
+	struct container *container = (struct container *)arg;
+	CURLcode res = curl_easy_perform(container->curl);
+	if (container->post)
+		curl_formfree(container->post);
+	if (res == CURLE_OK && container->handler)
+		container->handler(container->response);
+	else {
+		ret = thrd_error;
+#ifdef DEBUG
+		const char *error = curl_easy_strerror(res);
+#ifdef __ANDROID__
+		__android_log_print(ANDROID_LOG_ERROR, "libicclient.so", "%s", error);
+#else
+		fprintf(stderr, "%s\n", error);
+#endif
+#endif
+	}
+	free(container);
+	return ret;
+}
 #endif
 
 void request(void (*handler)(icclient_response *), void (*callback)(void *), struct body *body, char *fmt, ...)
@@ -131,20 +168,12 @@ void request(void (*handler)(icclient_response *), void (*callback)(void *), str
 		curl_easy_setopt(curl, CURLOPT_HTTPPOST, post);
 	} else
 		curl_easy_setopt(curl, CURLOPT_HTTPGET, 1L);
-	CURLcode res = curl_easy_perform(curl);
-	if (post)
-		curl_formfree(post);
-	if (res == CURLE_OK && handler)
-		handler(response);
-#ifdef DEBUG
-	else {
-		const char *error = curl_easy_strerror(res);
-#ifdef __ANDROID__
-		__android_log_print(ANDROID_LOG_ERROR, "libicclient.so", "%s", error);
-#else
-		fprintf(stderr, "%s\n", error);
-#endif
-	}
-#endif
+	struct container *container = malloc(sizeof(struct container));
+	container->curl = curl;
+	container->post = post;
+	container->handler = handler;
+	container->response = response;
+	thrd_t thread;
+	thrd_create(&thread, async, container);
 #endif
 }
-- 
cgit v1.2.3