Change the socket to non-blocking mode.

[platform/core/appfw/message-port.git] / src / message_port.c

diff --git a/src/message_port.c b/src/message_port.c
old mode 100644 (file)
new mode 100755 (executable)
index d6d50f3..2629c35
--- a/src/message_port.c
+++ b/src/message_port.c
@@ -30,7 +30,7 @@ typedef struct message_port_callback_item_s {
 
 static GHashTable *__listeners;
 static GHashTable *__trusted_listeners;
-static pthread_mutex_t __mutex = PTHREAD_MUTEX_INITIALIZER;
+pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
 
 static void do_callback(message_port_message_cb callback, int local_port_id, const char *remote_app_id, const char *remote_port, bool trusted_remote_port, bundle *message, void *user_data)
 {
@@ -75,13 +75,13 @@ int message_port_register_local_port(const char *local_port, message_port_messag
                if (__listeners == NULL)
                        __listeners = g_hash_table_new_full(g_direct_hash, g_direct_equal, NULL, g_free);
 
-               pthread_mutex_lock(&__mutex);
+               pthread_mutex_lock(&mutex);
                message_port_callback_item *item =
                        (message_port_callback_item *)g_hash_table_lookup(__listeners, GINT_TO_POINTER(local_port_id));
                if (item == NULL) {
                        item = (message_port_callback_item *)calloc(1, sizeof(message_port_callback_item));
                        if (item == NULL) {
-                               pthread_mutex_unlock(&__mutex);
+                               pthread_mutex_unlock(&mutex);
                                return MESSAGE_PORT_ERROR_OUT_OF_MEMORY;
                        }
 
@@ -90,7 +90,7 @@ int message_port_register_local_port(const char *local_port, message_port_messag
 
                item->callback = callback;
                item->user_data = user_data;
-               pthread_mutex_unlock(&__mutex);
+               pthread_mutex_unlock(&mutex);
 
        } else {
                _SECURE_LOGI("Register local port fail (%d).", local_port_id);
@@ -113,13 +113,13 @@ int message_port_register_trusted_local_port(const char *local_port, message_por
                if (__trusted_listeners == NULL)
                        __trusted_listeners = g_hash_table_new_full(g_direct_hash, g_direct_equal, NULL, g_free);
 
-               pthread_mutex_lock(&__mutex);
+               pthread_mutex_lock(&mutex);
                message_port_callback_item *item =
                        (message_port_callback_item *)g_hash_table_lookup(__trusted_listeners, GINT_TO_POINTER(trusted_local_port_id));
                if (item == NULL) {
                        item = (message_port_callback_item *)calloc(1, sizeof(message_port_callback_item));
                        if (item == NULL) {
-                               pthread_mutex_unlock(&__mutex);
+                               pthread_mutex_unlock(&mutex);
                                return MESSAGE_PORT_ERROR_OUT_OF_MEMORY;
                        }
 
@@ -128,7 +128,7 @@ int message_port_register_trusted_local_port(const char *local_port, message_por
 
                item->callback = callback;
                item->user_data = user_data;
-               pthread_mutex_unlock(&__mutex);
+               pthread_mutex_unlock(&mutex);
        } else {
                _SECURE_LOGI("Register trusted local port fail (%d).", trusted_local_port_id);
        }
@@ -193,9 +193,9 @@ int message_port_send_message(const char *remote_app_id, const char *remote_port
        }
 
        _SECURE_LOGI("Send a message to (%s):(%s).", remote_app_id, remote_port);
-       pthread_mutex_lock(&__mutex);
+       pthread_mutex_lock(&mutex);
        ret = messageport_send_message(remote_app_id, remote_port, message);
-       pthread_mutex_unlock(&__mutex);
+       pthread_mutex_unlock(&mutex);
 
        return convert_to_tizen_error((messageport_error_e)ret);
 }
@@ -209,9 +209,9 @@ int message_port_send_trusted_message(const char *remote_app_id, const char *rem
        }
        _SECURE_LOGI("Send a trusted message to (%s):(%s).", remote_app_id, remote_port);
 
-       pthread_mutex_lock(&__mutex);
+       pthread_mutex_lock(&mutex);
        ret = messageport_send_trusted_message(remote_app_id, remote_port, message);
-       pthread_mutex_unlock(&__mutex);
+       pthread_mutex_unlock(&mutex);
 
        return convert_to_tizen_error((messageport_error_e)ret);
 }
@@ -244,9 +244,9 @@ int message_port_send_message_with_local_port(const char *remote_app_id, const c
        }
 
        _SECURE_LOGI("Send a message to (%s):(%s) and listen at the local port ID (%d).", remote_app_id, remote_port, local_port_id);
-       pthread_mutex_lock(&__mutex);
+       pthread_mutex_lock(&mutex);
        ret = messageport_send_bidirectional_message(local_port_id, remote_app_id, remote_port, message);
-       pthread_mutex_unlock(&__mutex);
+       pthread_mutex_unlock(&mutex);
 
        return convert_to_tizen_error((messageport_error_e)ret);
 }
@@ -277,9 +277,9 @@ int message_port_send_trusted_message_with_local_port(const char *remote_app_id,
        }
 
        _SECURE_LOGI("Send a trusted message to (%s):(%s) and listen at the local port ID (%d).", remote_app_id, remote_port, local_port_id);
-       pthread_mutex_lock(&__mutex);
+       pthread_mutex_lock(&mutex);
        ret = messageport_send_bidirectional_trusted_message(local_port_id, remote_app_id, remote_port, message);
-       pthread_mutex_unlock(&__mutex);
+       pthread_mutex_unlock(&mutex);
 
        return convert_to_tizen_error((messageport_error_e)ret);
 }