Add mutex encapsulation

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

diff --git a/src/message_port_local.c b/src/message_port_local.c
index 27b3739..a4d83cb 100755 (executable)
--- a/src/message_port_local.c
+++ b/src/message_port_local.c
@@ -114,8 +114,6 @@ typedef struct delay_message {
        bundle_raw *data;
 } delay_message_info_s;
 
-extern pthread_mutex_t mutex;
-
 /* LCOV_EXCL_START */
 static void __free_delay_message_info(delay_message_info_s *message)
 {
@@ -383,9 +381,9 @@ static gboolean __socket_disconnect_handler(GIOChannel *gio,
                gpointer data)
 {
        _LOGI("__socket_disconnect_handler %d", cond);
-       pthread_mutex_lock(&mutex);
+       message_port_lock_mutex();
        __free_port_info_by_key((port_key_info_s *)data);
-       pthread_mutex_unlock(&mutex);
+       message_port_unlock_mutex();
 
        return FALSE;
 }
@@ -744,28 +742,28 @@ static gboolean __process_delayed_message(gint fd, GIOCondition cond, gpointer d
        if (port_info == NULL)
                return G_SOURCE_REMOVE;
 
-       pthread_mutex_lock(&mutex);
+       message_port_lock_mutex();
 
        if (__validate_delay_port_info(delay_info) == false) {
-               pthread_mutex_unlock(&mutex);
+               message_port_unlock_mutex();
                return G_SOURCE_REMOVE;
        }
 
        if (port_info->delayed_message_list == NULL) {
                port_info->delayed_message_size = 0;
                port_info->delay_src_id = 0;
-               pthread_mutex_unlock(&mutex);
+               message_port_unlock_mutex();
                return G_SOURCE_REMOVE;
        } else {
                message = g_list_nth_data(port_info->delayed_message_list, 0);
                ret = __send_delayed_message(port_info->send_sock_fd, message);
 
                if (ret == MESSAGE_PORT_ERROR_RESOURCE_UNAVAILABLE) {
-                       pthread_mutex_unlock(&mutex);
+                       message_port_unlock_mutex();
                        return G_SOURCE_CONTINUE;
                } else if (ret == MESSAGE_PORT_ERROR_IO_ERROR) {
                        port_info->delay_src_id = 0;
-                       pthread_mutex_unlock(&mutex);
+                       message_port_unlock_mutex();
                        return G_SOURCE_REMOVE;
                }
 
@@ -775,7 +773,7 @@ static gboolean __process_delayed_message(gint fd, GIOCondition cond, gpointer d
                __free_delay_message_info(message);
        }
 
-       pthread_mutex_unlock(&mutex);
+       message_port_unlock_mutex();
 
        return G_SOURCE_CONTINUE;
 }