* 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
#include <stdlib.h>
#include <time.h>
#include <strings.h>
+#include <poll.h>
#include <tdm-client-protocol.h>
struct list_head link;
} tdm_private_client_output;
+typedef struct _tdm_private_client_voutput {
+ tdm_private_client_output base;
+ struct wl_tdm_voutput *wl_voutput;
+
+ struct
+ {
+ int count;
+ tdm_client_output_mode *modes;
+ } available_modes;
+
+ uint32_t msg;
+} tdm_private_client_voutput;
+
struct _tdm_private_client_vblank {
tdm_private_client_output *private_output;
/* LCOV_EXCL_STOP */
}
+static int
+_tdm_client_poll(struct wl_display *display, short int events, int timeout)
+{
+ int ret;
+ struct pollfd pfd[1];
+
+ pfd[0].fd = wl_display_get_fd(display);
+ pfd[0].events = events;
+ do {
+ ret = poll(pfd, 1, timeout);
+ } while (ret == -1 && errno == EINTR);
+
+ return ret;
+}
+
+static tdm_error
+_tdm_client_dispatch_timeout(tdm_private_client *private_client, int timeout)
+{
+ int ret;
+ struct wl_display *display = private_client->display;
+
+ if (wl_display_prepare_read(display) == -1) {
+ if (wl_display_dispatch_pending(display) > 0)
+ return TDM_ERROR_NONE;
+ else
+ return TDM_ERROR_OPERATION_FAILED;
+ }
+
+ while (true) {
+ ret = wl_display_flush(display);
+
+ if (ret != -1 || errno != EAGAIN)
+ break;
+
+ if (_tdm_client_poll(display, POLLOUT, -1) == -1) {
+ wl_display_cancel_read(display);
+ TDM_ERR("_tdm_client_poll failed");
+ return TDM_ERROR_OPERATION_FAILED;
+ }
+ }
+
+ /* Don't stop if flushing hits an EPIPE; continue so we can read any
+ * protocol error that may have triggered it. */
+ if (ret < 0 && errno != EPIPE) {
+ TDM_ERR("ret(%d) errno(%d)", ret, errno);
+ wl_display_cancel_read(display);
+ return TDM_ERROR_OPERATION_FAILED;
+ }
+
+ ret = _tdm_client_poll(display, POLLIN, timeout);
+ if (ret <= 0) {
+ wl_display_cancel_read(display);
+ if (ret == 0) {
+ TDM_ERR("_tdm_client_poll timeout.");
+ return TDM_ERROR_TIMEOUT;
+ } else {
+ TDM_ERR("_tdm_client_poll failed. (ret:%d)", ret);
+ return TDM_ERROR_OPERATION_FAILED;
+ }
+ }
+
+ if (wl_display_read_events(display) == -1) {
+ TDM_ERR("wl_display_read_events failed");
+ return TDM_ERROR_OPERATION_FAILED;
+ }
+
+ ret = wl_display_dispatch_pending(display);
+
+ if (ret < 0) {
+ TDM_ERR("_tdm_client_dispatch_timeout failed");
+ return TDM_ERROR_OPERATION_FAILED;
+ }
+
+ return TDM_ERROR_NONE;
+}
+
+tdm_error
+tdm_client_handle_events_timeout(tdm_client *client, int ms_timeout)
+{
+ tdm_private_client *private_client;
+ tdm_error ret;
+ TDM_RETURN_VAL_IF_FAIL(client != NULL, TDM_ERROR_INVALID_PARAMETER);
+
+ private_client = (tdm_private_client*)client;
+
+ pthread_mutex_lock(&private_client->lock);
+
+ if (CHECK_WL_PROTOCOL_ERROR(private_client)) {
+ pthread_mutex_unlock(&private_client->lock);
+ return TDM_ERROR_PROTOCOL_ERROR;
+ }
+
+ if (private_client->enable_ttrace)
+ TDM_TRACE_ASYNC_BEGIN((int)private_client->stamp, "TDM_Client_Events_Timeout:%u", (unsigned int)private_client->stamp);
+
+ ret = _tdm_client_dispatch_timeout(private_client, ms_timeout);
+
+ if (private_client->enable_ttrace)
+ TDM_TRACE_ASYNC_END((int)private_client->stamp, "TDM_Client_Events_Timeout:%u", (unsigned int)private_client->stamp);
+
+ if (CHECK_WL_PROTOCOL_ERROR(private_client)) {
+ pthread_mutex_unlock(&private_client->lock);
+ return TDM_ERROR_PROTOCOL_ERROR;
+ }
+
+ pthread_mutex_unlock(&private_client->lock);
+
+ return ret;
+}
+
typedef struct _tdm_client_vblank_temp {
tdm_client_vblank_handler2 func;
void *user_data;
{
tdm_private_client_output *private_output;
tdm_private_client *private_client;
- tdm_client_output_handler_info *h;
+ tdm_client_output_handler_info *h = NULL;
TDM_RETURN_VAL_IF_FAIL(output != NULL, TDM_ERROR_INVALID_PARAMETER);
TDM_RETURN_VAL_IF_FAIL(func != NULL, TDM_ERROR_INVALID_PARAMETER);
if (LIST_IS_EMPTY(&private_output->change_handler_list)) {
wl_tdm_output_watch_output_changes(private_output->output, 1);
+ wl_display_roundtrip_queue(private_client->display, private_client->queue);
/* TODO: this is very tricky.
* If a client adds the change_handler, we might be able to guess that
free(h);
if (LIST_IS_EMPTY(&private_output->change_handler_list)) {
- if (!CHECK_WL_PROTOCOL_ERROR(private_client))
+ private_output->watch_output_changes = 0;
+ if (!CHECK_WL_PROTOCOL_ERROR(private_client)) {
wl_tdm_output_watch_output_changes(private_output->output, 0);
+ wl_display_roundtrip_queue(private_client->display, private_client->queue);
+ }
}
pthread_mutex_unlock(&private_client->lock);
if (!private_vblank->started)
private_vblank->started = 1;
- if (private_output->watch_output_changes && !private_vblank->enable_fake) {
+ if (!private_vblank->enable_fake) {
if (private_output->connection == TDM_OUTPUT_CONN_STATUS_DISCONNECTED) {
TDM_ERR("output disconnected");
pthread_mutex_unlock(&private_client->lock);
if (!private_vblank->started)
private_vblank->started = 1;
- if (private_output->watch_output_changes && !private_vblank->enable_fake) {
+ if (!private_vblank->enable_fake) {
if (private_output->connection == TDM_OUTPUT_CONN_STATUS_DISCONNECTED) {
TDM_ERR("output disconnected");
pthread_mutex_unlock(&private_client->lock);
/* LCOV_EXCL_STOP */
}
+
+unsigned int
+tdm_client_vblank_is_waiting(tdm_client_vblank *vblank)
+{
+ tdm_private_client_vblank *private_vblank;
+
+ TDM_RETURN_VAL_IF_FAIL(vblank != NULL, 0);
+
+ private_vblank = vblank;
+
+ return (LIST_LENGTH(&private_vblank->wait_list) > 0) ? 1 : 0;
+}
+
+void
+tdm_client_voutput_cb_ack_message(void *data, struct wl_tdm_voutput *wl_voutput, uint32_t msg)
+{
+ tdm_private_client_voutput *private_voutput = data;
+
+ private_voutput->msg = msg;
+}
+
+static const struct wl_tdm_voutput_listener tdm_client_voutput_lisntener = {
+ tdm_client_voutput_cb_ack_message
+};
+
+tdm_client_voutput *
+tdm_client_create_voutput(tdm_client *client, const char *name, tdm_error *error)
+{
+ tdm_private_client *private_client;
+ tdm_private_client_output *private_output;
+ tdm_private_client_voutput *private_voutput;
+ struct wl_proxy *wrapper;
+
+ if (error)
+ *error = TDM_ERROR_NONE;
+
+ if (!client) {
+ TDM_ERR("'!client' failed");
+ if (error)
+ *error = TDM_ERROR_INVALID_PARAMETER;
+ return NULL;
+ }
+
+ if (!name) {
+ TDM_ERR("'!name' failed");
+ if (error)
+ *error = TDM_ERROR_INVALID_PARAMETER;
+ return NULL;
+ }
+
+ private_client = (tdm_private_client *)client;
+
+ pthread_mutex_lock(&private_client->lock);
+
+ if (CHECK_WL_PROTOCOL_ERROR(private_client)) {
+ if (error)
+ *error = TDM_ERROR_PROTOCOL_ERROR;
+ pthread_mutex_unlock(&private_client->lock);
+ return NULL;
+ }
+
+ LIST_FOR_EACH_ENTRY(private_output, &private_client->output_list, link) {
+ if (!strncmp(private_output->name, name, TDM_NAME_LEN)) {
+ if (error)
+ *error = TDM_ERROR_INVALID_PARAMETER; // FIXME define new error type.
+ pthread_mutex_unlock(&private_client->lock);
+ return NULL;
+ }
+ }
+
+ wrapper = wl_proxy_create_wrapper(private_client->tdm);
+ if (!wrapper) {
+ TDM_ERR("create virtual output wrapper failed");
+ if (error)
+ *error = TDM_ERROR_OUT_OF_MEMORY;
+ pthread_mutex_unlock(&private_client->lock);
+ return NULL;
+ }
+
+ wl_proxy_set_queue(wrapper, private_client->queue);
+
+ private_voutput = calloc(1, sizeof *private_voutput);
+ if (!private_voutput) {
+ /* LOCV_EXCL_START */
+ wl_proxy_wrapper_destroy(wrapper);
+ TDM_ERR("alloc failed");
+ if (error)
+ *error = TDM_ERROR_OUT_OF_MEMORY;
+ return NULL;
+ /* LOCV_EXCL_STOP */
+ }
+
+ private_voutput->base.private_client = private_client;
+
+ private_voutput->wl_voutput = wl_tdm_create_voutput((struct wl_tdm *)wrapper, private_voutput->base.name);
+ wl_proxy_wrapper_destroy(wrapper);
+ if (!private_voutput->wl_voutput) {
+ /* LCOV_EXCL_START */
+ TDM_ERR("couldn't create voutput resource");
+ free(private_voutput);
+ if (error)
+ *error = TDM_ERROR_OUT_OF_MEMORY;
+ pthread_mutex_unlock(&private_client->lock);
+ return NULL;
+ /* LCOV_EXCL_STOP */
+ }
+
+ wl_tdm_voutput_add_listener(private_voutput->wl_voutput,
+ &tdm_client_voutput_lisntener, private_voutput);
+ wl_display_roundtrip_queue(private_client->display, private_client->queue);
+
+ wl_proxy_set_queue((struct wl_proxy *)private_voutput->wl_voutput, NULL);
+
+ if (CHECK_WL_PROTOCOL_ERROR(private_client)) {
+ wl_tdm_voutput_destroy(private_voutput->wl_voutput);
+ free(private_voutput);
+ if (error)
+ *error = TDM_ERROR_PROTOCOL_ERROR;
+ pthread_mutex_unlock(&private_client->lock);
+ return NULL;
+ }
+
+ if (private_voutput->msg != WL_TDM_VOUTPUT_MESSAGE_ADDED)
+ {
+ wl_tdm_voutput_destroy(private_voutput->wl_voutput);
+ free(private_voutput);
+ if (error)
+ *error = TDM_ERROR_PROTOCOL_ERROR; // FIXME add new error type.
+ pthread_mutex_unlock(&private_client->lock);
+ return NULL;
+ }
+
+ pthread_mutex_unlock(&private_client->lock);
+
+ return (tdm_client_voutput *)private_voutput;
+}
+
+void
+tdm_client_voutput_destroy(tdm_client_voutput *voutput)
+{
+ tdm_private_client_voutput *private_voutput = (tdm_private_client_voutput *)voutput;
+
+ if (!private_voutput)
+ return;
+
+ wl_tdm_voutput_destroy(private_voutput->wl_voutput);
+
+ free(private_voutput);
+}
+
+tdm_error
+tdm_client_voutput_set_available_modes(tdm_client_voutput *voutput, const tdm_client_output_mode *modes, int count)
+{
+ tdm_private_client_voutput *private_voutput;
+
+ TDM_RETURN_VAL_IF_FAIL(voutput != NULL, TDM_ERROR_INVALID_PARAMETER);
+
+ if ((count > 0) && (modes == NULL))
+ return TDM_ERROR_INVALID_PARAMETER;
+
+ private_voutput = (tdm_private_client_voutput *)voutput;
+
+ if (private_voutput->base.connection == TDM_OUTPUT_CONN_STATUS_CONNECTED)
+ return TDM_ERROR_BAD_REQUEST;
+
+ if (private_voutput->available_modes.modes)
+ free(private_voutput->available_modes.modes);
+
+ private_voutput->available_modes.count = count;
+
+ if (count != 0)
+ {
+ private_voutput->available_modes.modes = calloc(count, sizeof(tdm_client_output_mode));
+ memcpy(private_voutput->available_modes.modes, modes, sizeof(tdm_client_output_mode) * count);
+ }
+
+ return TDM_ERROR_NONE;
+}
+
+tdm_error
+tdm_client_voutput_set_physical_size(tdm_client_voutput *voutput, int mmWidth, int mmHeight)
+{
+ TDM_RETURN_VAL_IF_FAIL(voutput != NULL, TDM_ERROR_INVALID_PARAMETER);
+ TDM_RETURN_VAL_IF_FAIL(mmWidth > 0, TDM_ERROR_INVALID_PARAMETER);
+ TDM_RETURN_VAL_IF_FAIL(mmHeight > 0, TDM_ERROR_INVALID_PARAMETER);
+
+ return TDM_ERROR_NONE;
+}
+
+tdm_client_output *
+tdm_client_voutput_get_client_output(tdm_client_voutput *voutput, tdm_error *error)
+{
+ tdm_private_client_voutput *private_voutput;
+
+ if (error)
+ *error = TDM_ERROR_NONE;
+
+ if (!voutput)
+ {
+ TDM_ERR("'!voutput' failed");
+ if (error)
+ *error = TDM_ERROR_INVALID_PARAMETER;
+ return NULL;
+ }
+
+ private_voutput = (tdm_private_client_voutput *)voutput;
+
+ return &private_voutput->base;
+}
+
+tdm_error
+tdm_client_output_set_buffer_queue(tdm_client_output *output, void *queue, void *func)
+{
+ TDM_RETURN_VAL_IF_FAIL(output != NULL, TDM_ERROR_INVALID_PARAMETER);
+ TDM_RETURN_VAL_IF_FAIL(queue != NULL, TDM_ERROR_INVALID_PARAMETER);
+ TDM_RETURN_VAL_IF_FAIL(func != NULL, TDM_ERROR_INVALID_PARAMETER);
+
+ return TDM_ERROR_NONE;
+}
+
+tdm_error
+tdm_client_output_get_available_modes(tdm_client_output *output, tdm_client_output_mode **modes, int *count)
+{
+ TDM_RETURN_VAL_IF_FAIL(output != NULL, TDM_ERROR_INVALID_PARAMETER);
+ TDM_RETURN_VAL_IF_FAIL(modes != NULL, TDM_ERROR_INVALID_PARAMETER);
+ TDM_RETURN_VAL_IF_FAIL(count != NULL, TDM_ERROR_INVALID_PARAMETER);
+
+ return TDM_ERROR_NONE;
+}
+
+tdm_error
+tdm_client_output_set_mode(tdm_client_output *output, const tdm_client_output_mode *mode)
+{
+ TDM_RETURN_VAL_IF_FAIL(output != NULL, TDM_ERROR_INVALID_PARAMETER);
+ TDM_RETURN_VAL_IF_FAIL(mode != NULL, TDM_ERROR_INVALID_PARAMETER);
+
+ return TDM_ERROR_NONE;
+}
+
+tdm_error
+tdm_client_output_connect(tdm_client_output *output)
+{
+ tdm_private_client_output *private_output;
+ tdm_private_client_voutput *private_voutput;
+ tdm_client_output_mode *modes;
+ int i;
+
+ TDM_RETURN_VAL_IF_FAIL(output != NULL, TDM_ERROR_INVALID_PARAMETER);
+
+ private_output = (tdm_private_client_output *)output;
+ private_voutput = (tdm_private_client_voutput *)output;
+
+ TDM_RETURN_VAL_IF_FAIL(private_output->connection != TDM_OUTPUT_CONN_STATUS_CONNECTED,
+ TDM_ERROR_BAD_REQUEST);
+
+ private_output->connection = TDM_OUTPUT_CONN_STATUS_CONNECTED;
+
+ modes = private_voutput->available_modes.modes;
+ for (i = 0; i < private_voutput->available_modes.count; i++)
+ {
+ wl_tdm_voutput_set_available_modes(private_voutput->wl_voutput, i,
+ modes[i].clock, modes[i].hdisplay,
+ modes[i].hsync_start, modes[i].hsync_end,
+ modes[i].htotal, modes[i].hskew,
+ modes[i].vdisplay, modes[i].vsync_start,
+ modes[i].vsync_end, modes[i].vtotal,
+ modes[i].vscan, modes[i].vrefresh,
+ modes[i].flags, modes[i].type,
+ modes[i].name);
+ }
+
+ wl_tdm_voutput_connect(private_voutput->wl_voutput);
+
+ return TDM_ERROR_NONE;
+}
+
+tdm_error
+tdm_client_output_disconnect(tdm_client_output *output)
+{
+ tdm_private_client_voutput *private_voutput;
+ tdm_private_client_output *private_output;
+
+ TDM_RETURN_VAL_IF_FAIL(output != NULL, TDM_ERROR_INVALID_PARAMETER);
+
+ private_output = (tdm_private_client_output *)output;
+ private_voutput = (tdm_private_client_voutput *)output;
+
+ TDM_RETURN_VAL_IF_FAIL(private_output->connection != TDM_OUTPUT_CONN_STATUS_DISCONNECTED,
+ TDM_ERROR_BAD_REQUEST);
+
+ private_output->connection = TDM_OUTPUT_CONN_STATUS_DISCONNECTED;
+
+ wl_tdm_voutput_disconnect(private_voutput->wl_voutput);
+
+ return TDM_ERROR_NONE;
+}
projects / platform / core / uifw / libtdm.git / blobdiff