gpio: enhance the interrupted callback thread safty

Change-Id: Ib9374b0a62bdf7d8d71604365637d0dfacab69b6
Signed-off-by: Segwon <segwon.han@samsung.com>

diff --git a/include/peripheral_handle.h b/include/peripheral_handle.h
index e07c4f13c4e17daf32816377946f9db420f7c7a2..18f260dbc2f46a79410bec5c932c3e1b2b2fee3f 100644 (file)
--- a/include/peripheral_handle.h
+++ b/include/peripheral_handle.h
@@ -24,7 +24,7 @@ typedef struct _peripheral_gpio_interrupted_cb_info_s {
        peripheral_gpio_interrupted_cb cb;
        peripheral_error_e error;
        void *user_data;
-       int status;
+       gint status;
 } interrupted_cb_info_s;
 
 /**

diff --git a/src/interface/peripheral_interface_gpio.c b/src/interface/peripheral_interface_gpio.c
index 2695a86d98ea00b2e02477c09ed3639b898d75e2..90c2a21c83bf636ce65b22245ee34348feb8bbfa 100644 (file)
--- a/src/interface/peripheral_interface_gpio.c
+++ b/src/interface/peripheral_interface_gpio.c
@@ -204,7 +204,7 @@ static gpointer __peripheral_interface_gpio_poll(void *data)
 
        uint32_t value;
 
-       while (gpio->cb_info.status == GPIO_INTERRUPTED_CALLBACK_SET) {
+       while (g_atomic_int_get(&gpio->cb_info.status) == GPIO_INTERRUPTED_CALLBACK_SET) {
 
                poll_state = poll(&poll_fd, 1, 3000);
 
@@ -250,7 +250,7 @@ int peripheral_interface_gpio_set_interrupted_cb(peripheral_gpio_h gpio, periphe
 
        gpio->cb_info.cb = callback;
        gpio->cb_info.user_data = user_data;
-       gpio->cb_info.status = GPIO_INTERRUPTED_CALLBACK_SET;
+       g_atomic_int_set(&gpio->cb_info.status, GPIO_INTERRUPTED_CALLBACK_SET);
        gpio->cb_info.thread = g_thread_new(NULL, __peripheral_interface_gpio_poll, gpio);
 
        return PERIPHERAL_ERROR_NONE;
@@ -258,7 +258,7 @@ int peripheral_interface_gpio_set_interrupted_cb(peripheral_gpio_h gpio, periphe
 
 int peripheral_interface_gpio_unset_interrupted_cb(peripheral_gpio_h gpio)
 {
-       gpio->cb_info.status = GPIO_INTERRUPTED_CALLBACK_UNSET;
+       g_atomic_int_set(&gpio->cb_info.status, GPIO_INTERRUPTED_CALLBACK_UNSET);
 
        if (gpio->cb_info.thread != NULL) {
                g_thread_join(gpio->cb_info.thread);