correct email address
[platform/core/uifw/libtdm.git] / src / tdm_output.c
index 03dcd45..a8b5065 100644 (file)
@@ -9,7 +9,7 @@
  *          Taeheon Kim <th908.kim@samsung.com>,
  *          YoungJun Cho <yj44.cho@samsung.com>,
  *          SooChan Lim <sc1.lim@samsung.com>,
- *          Boram Park <sc1.lim@samsung.com>
+ *          Boram Park <boram1288.park@samsung.com>
  *
  * Permission is hereby granted, free of charge, to any person obtaining a
  * copy of this software and associated documentation files (the
@@ -146,7 +146,9 @@ tdm_output_init(tdm_private_display *private_display)
 {
        tdm_thread_cb_set_find_func(TDM_THREAD_CB_OUTPUT_COMMIT, tdm_display_find_output_stamp);
        tdm_thread_cb_set_find_func(TDM_THREAD_CB_OUTPUT_VBLANK, tdm_display_find_output_stamp);
-       tdm_thread_cb_set_find_func(TDM_THREAD_CB_OUTPUT_CHANGE, tdm_display_find_output_stamp);
+       tdm_thread_cb_set_find_func(TDM_THREAD_CB_OUTPUT_STATUS, tdm_display_find_output_stamp);
+       tdm_thread_cb_set_find_func(TDM_THREAD_CB_OUTPUT_DPMS, tdm_display_find_output_stamp);
+
 
        return TDM_ERROR_NONE;
 }
@@ -226,34 +228,68 @@ INTERN void
 tdm_output_thread_cb_change(tdm_private_display *private_display, void *object, tdm_thread_cb_base *cb_base, void *user_data)
 {
        tdm_private_output *private_output = object;
-       tdm_thread_cb_output_change *output_change = (tdm_thread_cb_output_change *)cb_base;
        tdm_private_output_change_handler *change_handler = user_data;
+       tdm_output_change_type type = TDM_OUTPUT_CHANGE_CONNECTION;
+       tdm_value value = {.u32 = 0 };
 
        TDM_RETURN_IF_FAIL(TDM_MUTEX_IS_LOCKED());
 
        assert(change_handler->owner_tid == syscall(SYS_gettid));
 
+       if (cb_base->type == TDM_THREAD_CB_OUTPUT_STATUS) {
+               tdm_thread_cb_output_status *output_status = (tdm_thread_cb_output_status *)cb_base;
+               type = TDM_OUTPUT_CHANGE_CONNECTION;
+               value.u32 = output_status->status;
+       } else if (cb_base->type == TDM_THREAD_CB_OUTPUT_DPMS) {
+               tdm_thread_cb_output_dpms *output_dpms = (tdm_thread_cb_output_dpms *)cb_base;
+               type = TDM_OUTPUT_CHANGE_DPMS;
+               value.u32 = output_dpms->dpms;
+       } else {
+               TDM_NEVER_GET_HERE();
+               return;
+       }
+
        _pthread_mutex_unlock(&private_display->lock);
-       change_handler->func(private_output, output_change->type, output_change->value, change_handler->user_data);
+       change_handler->func(private_output, type, value, change_handler->user_data);
        _pthread_mutex_lock(&private_display->lock);
+
+}
+
+static tdm_error
+_tdm_output_call_thread_cb_status(tdm_private_output *private_output, tdm_output_conn_status status)
+{
+       tdm_thread_cb_output_status output_status;
+       tdm_error ret;
+
+       memset(&output_status, 0, sizeof output_status);
+       output_status.base.type = TDM_THREAD_CB_OUTPUT_STATUS;
+       output_status.base.length = sizeof output_status;
+       output_status.base.object_stamp = private_output->stamp;
+       output_status.base.data = NULL;
+       output_status.base.sync = 1;
+       output_status.status = status;
+
+       ret = tdm_thread_cb_call(private_output, &output_status.base, 1);
+       TDM_WARNING_IF_FAIL(ret == TDM_ERROR_NONE);
+
+       return TDM_ERROR_NONE;
 }
 
 static tdm_error
-_tdm_output_call_thread_cb_change(tdm_private_output *private_output, tdm_output_change_type type, tdm_value value)
+_tdm_output_call_thread_cb_dpms(tdm_private_output *private_output, tdm_output_dpms dpms)
 {
-       tdm_thread_cb_output_change output_change;
+       tdm_thread_cb_output_dpms output_dpms;
        tdm_error ret;
 
-       memset(&output_change, 0, sizeof output_change);
-       output_change.base.type = TDM_THREAD_CB_OUTPUT_CHANGE;
-       output_change.base.length = sizeof output_change;
-       output_change.base.object_stamp = private_output->stamp;
-       output_change.base.data = NULL;
-       output_change.base.sync = 1;
-       output_change.type = type;
-       output_change.value = value;
+       memset(&output_dpms, 0, sizeof output_dpms);
+       output_dpms.base.type = TDM_THREAD_CB_OUTPUT_DPMS;
+       output_dpms.base.length = sizeof output_dpms;
+       output_dpms.base.object_stamp = private_output->stamp;
+       output_dpms.base.data = NULL;
+       output_dpms.base.sync = 0;
+       output_dpms.dpms = dpms;
 
-       ret = tdm_thread_cb_call(private_output, &output_change.base);
+       ret = tdm_thread_cb_call(private_output, &output_dpms.base, 1);
        TDM_WARNING_IF_FAIL(ret == TDM_ERROR_NONE);
 
        return TDM_ERROR_NONE;
@@ -263,7 +299,6 @@ INTERN void
 tdm_output_cb_status(tdm_output *output_backend, tdm_output_conn_status status, void *user_data)
 {
        tdm_private_output *private_output = user_data;
-       tdm_value value;
        tdm_error ret;
 
        TDM_RETURN_IF_FAIL(private_output);
@@ -278,9 +313,7 @@ tdm_output_cb_status(tdm_output *output_backend, tdm_output_conn_status status,
                private_output->caps.status = status;
        }
 
-       value.u32 = status;
-
-       ret = _tdm_output_call_thread_cb_change(private_output, TDM_OUTPUT_CHANGE_CONNECTION, value);
+       ret = _tdm_output_call_thread_cb_status(private_output, status);
        TDM_WARNING_IF_FAIL(ret == TDM_ERROR_NONE);
 }
 
@@ -288,7 +321,6 @@ INTERN void
 tdm_output_cb_dpms(tdm_output *output_backend, tdm_output_dpms dpms, void *user_data)
 {
        tdm_private_output *private_output = user_data;
-       tdm_value value;
        tdm_error ret;
 
        TDM_INFO("output(%d) %s", private_output->pipe, tdm_status_str(dpms));
@@ -297,9 +329,7 @@ tdm_output_cb_dpms(tdm_output *output_backend, tdm_output_dpms dpms, void *user_
        private_output->waiting_dpms_change = 0;
        TDM_INFO("output(%d) dpms async '%s' done", private_output->pipe, tdm_dpms_str(dpms));
 
-       value.u32 = dpms;
-
-       ret = _tdm_output_call_thread_cb_change(private_output, TDM_OUTPUT_CHANGE_DPMS, value);
+       ret = _tdm_output_call_thread_cb_dpms(private_output, dpms);
        TDM_WARNING_IF_FAIL(ret == TDM_ERROR_NONE);
 }
 
@@ -332,10 +362,21 @@ tdm_output_add_change_handler(tdm_output *output,
                /* LCOV_EXCL_STOP */
        }
 
-       ret = tdm_thread_cb_add(private_output, TDM_THREAD_CB_OUTPUT_CHANGE, NULL, tdm_output_thread_cb_change, change_handler);
+       ret = tdm_thread_cb_add(private_output, TDM_THREAD_CB_OUTPUT_DPMS, NULL, tdm_output_thread_cb_change, change_handler);
+       if (ret != TDM_ERROR_NONE) {
+               /* LCOV_EXCL_START */
+               TDM_ERR("tdm_thread_cb_add failed");
+               free(change_handler);
+               _pthread_mutex_unlock(&private_display->lock);
+               return TDM_ERROR_OPERATION_FAILED;
+               /* LCOV_EXCL_STOP */
+       }
+
+       ret = tdm_thread_cb_add(private_output, TDM_THREAD_CB_OUTPUT_STATUS, NULL, tdm_output_thread_cb_change, change_handler);
        if (ret != TDM_ERROR_NONE) {
                /* LCOV_EXCL_START */
                TDM_ERR("tdm_thread_cb_add failed");
+               tdm_thread_cb_remove(private_output, TDM_THREAD_CB_OUTPUT_DPMS, NULL, tdm_output_thread_cb_change, change_handler);
                free(change_handler);
                _pthread_mutex_unlock(&private_display->lock);
                return TDM_ERROR_OPERATION_FAILED;
@@ -375,7 +416,8 @@ tdm_output_remove_change_handler(tdm_output *output,
                if (change_handler->func != func || change_handler->user_data != user_data)
                        continue;
 
-               tdm_thread_cb_remove(private_output, TDM_THREAD_CB_OUTPUT_CHANGE, NULL, tdm_output_thread_cb_change, change_handler);
+               tdm_thread_cb_remove(private_output, TDM_THREAD_CB_OUTPUT_DPMS, NULL, tdm_output_thread_cb_change, change_handler);
+               tdm_thread_cb_remove(private_output, TDM_THREAD_CB_OUTPUT_STATUS, NULL, tdm_output_thread_cb_change, change_handler);
 
                LIST_DEL(&change_handler->link);
                free(change_handler);
@@ -766,7 +808,10 @@ _tdm_output_cb_vblank(tdm_output *output_backend, unsigned int sequence,
 
        vblank_handler->sent_to_frontend = 1;
 
-       ret = tdm_thread_cb_call(vblank_handler->private_output, &output_vblank.base);
+       if (tdm_debug_module & TDM_DEBUG_COMMIT)
+               TDM_INFO("output(%d) wait_vblank: handler(%p)", vblank_handler->private_output->pipe, vblank_handler);
+
+       ret = tdm_thread_cb_call(vblank_handler->private_output, &output_vblank.base, 1);
        TDM_WARNING_IF_FAIL(ret == TDM_ERROR_NONE);
 }
 
@@ -842,7 +887,7 @@ _tdm_output_cb_commit(tdm_output *output_backend, unsigned int sequence,
        output_commit.tv_sec = tv_sec;
        output_commit.tv_usec = tv_usec;
 
-       ret = tdm_thread_cb_call(private_output, &output_commit.base);
+       ret = tdm_thread_cb_call(private_output, &output_commit.base, 1);
        TDM_WARNING_IF_FAIL(ret == TDM_ERROR_NONE);
 }
 
@@ -1084,39 +1129,47 @@ tdm_output_commit_internal(tdm_output *output, int sync, tdm_output_commit_handl
        TDM_RETURN_VAL_IF_FAIL(ret == TDM_ERROR_NONE, ret);
 
        if (!TDM_OUTPUT_DPMS_VSYNC_IS_OFF(dpms_value)) {
-               if (func) {
-                       if (!private_output->regist_commit_cb) {
-                               private_output->regist_commit_cb = 1;
-                               ret = func_output->output_set_commit_handler(private_output->output_backend, _tdm_output_cb_commit);
-                               TDM_GOTO_IF_FAIL(ret == TDM_ERROR_NONE, commit_failed);
-                       }
-
-                       output_commit_handler = calloc(1, sizeof(tdm_private_output_commit_handler));
-                       if (!output_commit_handler) {
-                               /* LCOV_EXCL_START */
-                               TDM_ERR("failed: alloc memory");
-                               return TDM_ERROR_OUT_OF_MEMORY;
-                               /* LCOV_EXCL_STOP */
-                       }
+               if (!private_output->regist_commit_cb) {
+                       private_output->regist_commit_cb = 1;
+                       ret = func_output->output_set_commit_handler(private_output->output_backend, _tdm_output_cb_commit);
+                       TDM_GOTO_IF_FAIL(ret == TDM_ERROR_NONE, commit_failed);
+               }
 
-                       ret = tdm_thread_cb_add(private_output, TDM_THREAD_CB_OUTPUT_COMMIT, output_commit_handler, _tdm_output_thread_cb_commit, NULL);
-                       if (ret != TDM_ERROR_NONE) {
-                               TDM_ERR("tdm_thread_cb_add failed");
-                               free(output_commit_handler);
-                               return ret;
-                       }
+               output_commit_handler = calloc(1, sizeof(tdm_private_output_commit_handler));
+               if (!output_commit_handler) {
+                       /* LCOV_EXCL_START */
+                       TDM_ERR("failed: alloc memory");
+                       return TDM_ERROR_OUT_OF_MEMORY;
+                       /* LCOV_EXCL_STOP */
+               }
 
-                       LIST_ADDTAIL(&output_commit_handler->link, &private_output->output_commit_handler_list);
-                       output_commit_handler->private_output = private_output;
-                       output_commit_handler->func = func;
-                       output_commit_handler->user_data = user_data;
-                       output_commit_handler->owner_tid = syscall(SYS_gettid);
+               ret = tdm_thread_cb_add(private_output, TDM_THREAD_CB_OUTPUT_COMMIT, output_commit_handler, _tdm_output_thread_cb_commit, NULL);
+               if (ret != TDM_ERROR_NONE) {
+                       TDM_ERR("tdm_thread_cb_add failed");
+                       free(output_commit_handler);
+                       return ret;
                }
 
+               LIST_ADDTAIL(&output_commit_handler->link, &private_output->output_commit_handler_list);
+               output_commit_handler->private_output = private_output;
+               output_commit_handler->func = func;
+               output_commit_handler->user_data = user_data;
+               output_commit_handler->owner_tid = syscall(SYS_gettid);
+
                ret = func_output->output_commit(private_output->output_backend, sync,
                                output_commit_handler);
                TDM_GOTO_IF_FAIL(ret == TDM_ERROR_NONE, commit_failed);
 
+               if (ret == TDM_ERROR_NONE) {
+                       if (private_output->current_mode &&
+                               private_output->caps.status != TDM_OUTPUT_CONN_STATUS_MODE_SETTED) {
+                               TDM_WRN("backend doesn't change the output connection status");
+                               tdm_output_cb_status(private_output->output_backend,
+                                                                        TDM_OUTPUT_CONN_STATUS_MODE_SETTED,
+                                                                        private_output);
+                       }
+               }
+
                if (tdm_debug_module & TDM_DEBUG_COMMIT)
                        TDM_INFO("output(%d) backend commit: handle(%p) func(%p) user_data(%p)",
                                        private_output->pipe, output_commit_handler, func, user_data);
@@ -1129,8 +1182,14 @@ tdm_output_commit_internal(tdm_output *output, int sync, tdm_output_commit_handl
                if (!private_layer->waiting_buffer)
                        continue;
 
-               if (private_layer->committed_buffer)
+               if (private_layer->committed_buffer) {
                        tdm_layer_free_buffer(private_layer, private_layer->committed_buffer);
+                       private_layer->committed_buffer = NULL;
+                       if (tdm_debug_module & TDM_DEBUG_BUFFER)
+                               TDM_INFO("layer(%p) waiting_buffer(%p) committed_buffer(%p)",
+                                                private_layer, private_layer->waiting_buffer->buffer,
+                                                private_layer->committed_buffer);
+               }
 
                private_layer->committed_buffer = private_layer->waiting_buffer;
                private_layer->waiting_buffer = NULL;
@@ -1301,12 +1360,10 @@ tdm_output_set_dpms(tdm_output *output, tdm_output_dpms dpms_value)
 done:
        if (ret == TDM_ERROR_NONE) {
                if (private_output->current_dpms_value != dpms_value) {
-                       tdm_value value;
                        private_output->current_dpms_value = dpms_value;
-                       value.u32 = dpms_value;
-                       _tdm_output_call_thread_cb_change(private_output, TDM_OUTPUT_CHANGE_DPMS, value);
-                       TDM_INFO("output(%d) dpms '%s' done", private_output->pipe, tdm_dpms_str(dpms_value));
+                       _tdm_output_call_thread_cb_dpms(private_output, dpms_value);
                }
+               TDM_INFO("output(%d) dpms '%s' done", private_output->pipe, tdm_dpms_str(dpms_value));
        } else {
                tdm_output_dpms temp = TDM_OUTPUT_DPMS_OFF;
 
@@ -1445,13 +1502,11 @@ tdm_output_get_dpms_internal(tdm_output *output, tdm_output_dpms *dpms_value)
 
        /* checking with backend's value */
        if (*dpms_value != private_output->current_dpms_value) {
-               tdm_value value;
                TDM_ERR("output(%d) dpms changed suddenly: %s -> %s",
                                private_output->pipe, tdm_dpms_str(private_output->current_dpms_value),
                                tdm_dpms_str(*dpms_value));
                private_output->current_dpms_value = *dpms_value;
-               value.u32 = *dpms_value;
-               _tdm_output_call_thread_cb_change(private_output, TDM_OUTPUT_CHANGE_DPMS, value);
+               _tdm_output_call_thread_cb_dpms(private_output, *dpms_value);
        }
 
        return ret;
@@ -1473,6 +1528,31 @@ tdm_output_get_dpms(tdm_output *output, tdm_output_dpms *dpms_value)
        return ret;
 }
 
+EXTERN tdm_error
+tdm_output_has_capture_capability(tdm_output *output, unsigned int *has_capability)
+{
+       tdm_private_module *private_module;
+
+       OUTPUT_FUNC_ENTRY();
+
+       TDM_RETURN_VAL_IF_FAIL(has_capability != NULL, TDM_ERROR_INVALID_PARAMETER);
+
+       _pthread_mutex_lock(&private_display->lock);
+
+       private_module = private_output->private_module;
+
+       if (!(private_module->capabilities & TDM_DISPLAY_CAPABILITY_CAPTURE))
+               *has_capability = 0;
+       else if (!(private_module->caps_capture.capabilities & TDM_CAPTURE_CAPABILITY_OUTPUT))
+               *has_capability = 0;
+       else
+               *has_capability = 1;
+
+       _pthread_mutex_unlock(&private_display->lock);
+
+       return ret;
+}
+
 EXTERN tdm_capture *
 tdm_output_create_capture(tdm_output *output, tdm_error *error)
 {
@@ -2100,7 +2180,7 @@ _need_validate_handler(int fd, tdm_event_loop_mask mask, void *user_data)
        ev.base.data = NULL;
        ev.base.sync = 0;
 
-       ret = tdm_thread_cb_call(private_output, &ev.base);
+       ret = tdm_thread_cb_call(private_output, &ev.base, 1);
        TDM_WARNING_IF_FAIL(ret == TDM_ERROR_NONE);
 
        TDM_INFO("tdm-thread: get a 'need to revalidate' event for the ouptut:%p.", private_output);