From 2c14d4d0dd1f40da55a3557561198aff9bfbe64b Mon Sep 17 00:00:00 2001
From: Jeonghoon Park <jh1979.park@samsung.com>
Date: Thu, 3 May 2018 14:55:24 +0900
Subject: [PATCH] adds openssl callbacks to use https protocol in multithread

Change-Id: I3b96faf4f301c85631869480c271aeb3b7e276e0
---
 daemon/CMakeLists.txt              |  1 +
 daemon/src/ttd-http.c              | 68 ++++++++++++++++++++++++++++++++++++++
 packaging/tizen-things-daemon.spec |  1 +
 3 files changed, 70 insertions(+)

diff --git a/daemon/CMakeLists.txt b/daemon/CMakeLists.txt
index 4d738af..d4db090 100644
--- a/daemon/CMakeLists.txt
+++ b/daemon/CMakeLists.txt
@@ -10,6 +10,7 @@ pkg_check_modules(DAEMON_PKGS REQUIRED
 	json-c
 	libtzplatform-config
 	gio-unix-2.0
+	openssl
 )
 
 FOREACH (flag ${DAEMON_PKGS_CFLAGS})
diff --git a/daemon/src/ttd-http.c b/daemon/src/ttd-http.c
index ed3f78d..fabbf86 100644
--- a/daemon/src/ttd-http.c
+++ b/daemon/src/ttd-http.c
@@ -15,20 +15,86 @@
  */
 
 #include <curl/curl.h>
+#include <openssl/crypto.h>
 #include <glib.h>
 #include "ttd-log.h"
 
 #define CERT_FILE_PATH "/opt/share/cert-svc/ca-certificate.crt"
 
+static GMutex *mutex_a = NULL;
+static int http_initialized = 0;
+
+static void __locking_function(int mode, int n, const char *file, int line)
+{
+	if(mode & CRYPTO_LOCK)
+		g_mutex_lock(&mutex_a[n]);
+	else
+		g_mutex_unlock(&mutex_a[n]);
+}
+
+static unsigned long __id_function(void)
+{
+	return ((unsigned long)g_thread_self());
+}
+
+int __ssl_thread_mutex_setup(void)
+{
+	int i;
+
+	mutex_a = g_malloc(CRYPTO_num_locks() * sizeof(GMutex));
+	if(!mutex_a)
+		return -1;
+
+	for(i = 0; i < CRYPTO_num_locks(); i++)
+		g_mutex_init(&mutex_a[i]);
+
+	CRYPTO_set_id_callback(__id_function);
+	CRYPTO_set_locking_callback(__locking_function);
+
+	return 0;
+}
+
+static int __ssl_thread_mutex_cleanup(void)
+{
+	int i;
+
+	if(!mutex_a)
+		return -1;
+
+	CRYPTO_set_id_callback(NULL);
+	CRYPTO_set_locking_callback(NULL);
+
+	for(i = 0; i < CRYPTO_num_locks(); i++)
+		g_mutex_clear(&mutex_a[i]);
+
+	g_free(mutex_a);
+	mutex_a = NULL;
+
+	return 0;
+}
+
+
 int ttd_http_init(void)
 {
+	int ret = 0;
 	curl_global_init(CURL_GLOBAL_DEFAULT);
+	ret = __ssl_thread_mutex_setup();
+	if (ret) {
+		_E("failed to setup ssl thread mutex");
+		return -1;
+	}
+
+	http_initialized = 1;
+
 	return 0;
 }
 
 int ttd_http_fini(void)
 {
+	__ssl_thread_mutex_cleanup();
 	curl_global_cleanup();
+	http_initialized = 0;
+
 	return 0;
 }
 
@@ -62,6 +128,7 @@ int ttd_http_get_cloud_cmd(const char *url, char **cmd_json)
 	CURL *curl = NULL;
 	CURLcode res = CURLE_OK;
 
+	retvm_if(!http_initialized, -1, "http is not initialized yet");
 	retvm_if(!url, -1, "url is null");
 	retvm_if(!cmd_json, -1, "cmd_json is null");
 
@@ -94,6 +161,7 @@ int ttd_http_post_cmd_result(const char *url, const char *result_json)
 	CURLcode res = CURLE_OK;
 	struct curl_slist *headers = NULL;
 
+	retvm_if(!http_initialized, -1, "http is not initialized yet");
 	retvm_if(!url, -1, "url is null");
 	retvm_if(!result_json, -1, "result_json is null");
 
diff --git a/packaging/tizen-things-daemon.spec b/packaging/tizen-things-daemon.spec
index 62ab253..bf5a0fb 100644
--- a/packaging/tizen-things-daemon.spec
+++ b/packaging/tizen-things-daemon.spec
@@ -17,6 +17,7 @@ BuildRequires:  pkgconfig(capi-network-connection)
 BuildRequires:  pkgconfig(libcurl)
 BuildRequires:  pkgconfig(json-c)
 BuildRequires:  pkgconfig(libtzplatform-config)
+BuildRequires:  pkgconfig(openssl)
 
 %description
 Tizen Things daemon
-- 
2.7.4