hwc: remove the tdm_hwc_window_set_zpos api

[platform/core/uifw/libtdm.git] / src / tdm_thread.c

diff --git a/src/tdm_thread.c b/src/tdm_thread.c
index 8f624e1..f71f3a1 100644 (file)
--- a/src/tdm_thread.c
+++ b/src/tdm_thread.c
@@ -37,11 +37,7 @@
 #include "config.h"
 #endif
 
-#include <sys/socket.h>
-
-#include "tdm.h"
 #include "tdm_private.h"
-#include "tdm_list.h"
 
 static tdm_private_thread *keep_private_thread;
 
@@ -249,7 +245,8 @@ tdm_thread_handle_cb(tdm_private_loop *private_loop)
        tdm_private_thread *private_thread;
        tdm_thread_cb_base *base;
        char buffer[1024];
-       unsigned int len, i;
+       unsigned int i;
+       int len;
 
        /* DON'T check TDM_MUTEX_IS_LOCKED here */
 
@@ -259,16 +256,23 @@ tdm_thread_handle_cb(tdm_private_loop *private_loop)
        private_thread = private_loop->private_thread;
        private_display = private_loop->dpy;
 
-       len = read(private_thread->pipe[0], buffer, sizeof buffer);
+       do {
+               len = read(private_thread->pipe[0], buffer, sizeof buffer);
+       } while (len < 0 && errno == EINTR);
 
        if (tdm_debug_module & TDM_DEBUG_THREAD)
                TDM_INFO("fd(%d) read length(%d)", private_thread->pipe[0], len);
 
+       if (len < 0) {
+               TDM_ERR("read failed: errno(%d), len(%d) %m", errno, len);
+               return TDM_ERROR_OPERATION_FAILED;
+       }
+
        if (len == 0)
                return TDM_ERROR_NONE;
 
        if (len < sizeof * base) {
-               TDM_NEVER_GET_HERE();
+               TDM_ERR("read failed: len(%d)", len);
                return TDM_ERROR_OPERATION_FAILED;
        }
 
@@ -307,6 +311,7 @@ tdm_thread_handle_cb(tdm_private_loop *private_loop)
                        break;
                }
                case TDM_THREAD_CB_OUTPUT_STATUS: {
+                       /* LCOV_EXCL_START */
                        tdm_thread_cb_output_status *output_status = (tdm_thread_cb_output_status*)base;
                        tdm_output *output_backend =
                                tdm_display_find_output_stamp(private_loop->dpy, output_status->output_stamp);
@@ -317,8 +322,10 @@ tdm_thread_handle_cb(tdm_private_loop *private_loop)
                        tdm_output_cb_status(output_backend, output_status->status,
                                                                 output_status->user_data);
                        break;
+                       /* LCOV_EXCL_STOP */
                }
                case TDM_THREAD_CB_OUTPUT_DPMS: {
+                       /* LCOV_EXCL_START */
                        tdm_thread_cb_output_dpms *output_dpms = (tdm_thread_cb_output_dpms*)base;
                        tdm_output *output_backend =
                                tdm_display_find_output_stamp(private_loop->dpy, output_dpms->output_stamp);
@@ -328,6 +335,7 @@ tdm_thread_handle_cb(tdm_private_loop *private_loop)
                        }
                        tdm_output_cb_dpms(output_backend, output_dpms->dpms, output_dpms->user_data);
                        break;
+                       /* LCOV_EXCL_STOP */
                }
                case TDM_THREAD_CB_PP_DONE: {
                        tdm_thread_cb_pp_done *pp_done = (tdm_thread_cb_pp_done*)base;
@@ -356,6 +364,11 @@ tdm_thread_handle_cb(tdm_private_loop *private_loop)
                        tdm_vblank_cb_vblank_SW(NULL, vblank_sw->vblank_stamp);
                        break;
                }
+               case TDM_THREAD_CB_VBLANK_CREATE: {
+                       tdm_thread_cb_vblank_create *vblank_create = (tdm_thread_cb_vblank_create*)base;
+                       tdm_vblank_cb_vblank_create(NULL, vblank_create->vblank_stamp);
+                       break;
+               }
                case TDM_THREAD_CB_NEED_VALIDATE: {
                        tdm_thread_cb_need_validate *ev = (tdm_thread_cb_need_validate*)base;
                        tdm_output_cb_need_validate(ev->o);