+ wrapper = wl_proxy_create_wrapper(private_client->tdm);
+ if (!wrapper) {
+ TDM_ERR("create 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_output = calloc(1, sizeof *private_output);
+ if (!private_output) {
+ /* LCOV_EXCL_START */
+ wl_proxy_wrapper_destroy(wrapper);
+ TDM_ERR("alloc failed");
+ if (error)
+ *error = TDM_ERROR_OUT_OF_MEMORY;
+ pthread_mutex_unlock(&private_client->lock);
+ return NULL;
+
+ /* LCOV_EXCL_STOP */
+ }
+
+ private_output->private_client = private_client;
+
+ snprintf(private_output->name, TDM_NAME_LEN, "%s", name);
+ private_output->output = wl_tdm_create_output((struct wl_tdm *)wrapper, private_output->name);
+ wl_proxy_wrapper_destroy(wrapper);
+ if (!private_output->output) {
+ /* LCOV_EXCL_START */
+
+ TDM_ERR("couldn't create output resource");
+ free(private_output);
+ if (error)
+ *error = TDM_ERROR_OUT_OF_MEMORY;
+ pthread_mutex_unlock(&private_client->lock);
+ return NULL;
+
+ /* LCOV_EXCL_STOP */
+ }
+
+ LIST_INITHEAD(&private_output->vblank_list);
+ LIST_INITHEAD(&private_output->change_handler_list);
+
+ wl_tdm_output_add_listener(private_output->output,
+ &tdm_client_output_listener, private_output);
+ wl_display_roundtrip_queue(private_client->display, private_client->queue);
+
+ wl_proxy_set_queue((struct wl_proxy *)private_output->output, NULL);
+
+ if (CHECK_WL_PROTOCOL_ERROR(private_client)) {
+ wl_tdm_output_destroy(private_output->output);
+ free(private_output);
+ if (error)
+ *error = TDM_ERROR_PROTOCOL_ERROR;
+ pthread_mutex_unlock(&private_client->lock);
+ return NULL;
+ }
+
+ LIST_ADDTAIL(&private_output->link, &private_client->output_list);
+
+ pthread_mutex_unlock(&private_client->lock);
+
+ return (tdm_client_output*)private_output;
+}
+
+tdm_error
+tdm_client_output_add_change_handler(tdm_client_output *output,
+ tdm_client_output_change_handler func,
+ void *user_data)
+{
+ tdm_private_client_output *private_output;
+ tdm_private_client *private_client;
+ 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);
+
+ private_output = (tdm_private_client_output*)output;
+ private_client = private_output->private_client;
+
+ LIST_FOR_EACH_ENTRY(h, &private_output->change_handler_list, link) {
+ if (h->func == func && h->user_data == user_data) {
+ TDM_ERR("can't add twice");
+ return TDM_ERROR_BAD_REQUEST;
+ }
+ }
+
+ h = calloc(1, sizeof *h);
+ TDM_RETURN_VAL_IF_FAIL(h != NULL, TDM_ERROR_OUT_OF_MEMORY);
+
+ pthread_mutex_lock(&private_client->lock);
+
+ if (CHECK_WL_PROTOCOL_ERROR(private_client)) {
+ free(h);
+ pthread_mutex_unlock(&private_client->lock);
+ return TDM_ERROR_PROTOCOL_ERROR;
+ }
+
+ 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
+ * the client will watch the tdm client's fd and handle tdm events in
+ * event loop. Otherwise, we CAN'T make sure if a client has event loop
+ * which handles tdm events.
+ */
+ private_output->watch_output_changes = 1;
+ }
+
+ h->private_output = private_output;
+ h->func = func;
+ h->user_data = user_data;
+ LIST_ADDTAIL(&h->link, &private_output->change_handler_list);
+ LIST_INITHEAD(&h->call_link);
+
+ pthread_mutex_unlock(&private_client->lock);
+
+ return TDM_ERROR_NONE;
+}
+
+void
+tdm_client_output_remove_change_handler(tdm_client_output *output,
+ tdm_client_output_change_handler func,
+ void *user_data)
+{
+ tdm_private_client_output *private_output;
+ tdm_private_client *private_client;
+ tdm_client_output_handler_info *h = NULL;
+
+ TDM_RETURN_IF_FAIL(output != NULL);
+ TDM_RETURN_IF_FAIL(func != NULL);
+
+ private_output = (tdm_private_client_output*)output;
+ private_client = private_output->private_client;
+
+ pthread_mutex_lock(&private_client->lock);
+
+ LIST_FOR_EACH_ENTRY(h, &private_output->change_handler_list, link) {
+ if (h->func != func || h->user_data != user_data)
+ continue;
+
+ LIST_DEL(&h->link);
+ free(h);
+
+ if (LIST_IS_EMPTY(&private_output->change_handler_list)) {
+ 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);
+
+ return;
+ }
+
+ pthread_mutex_unlock(&private_client->lock);
+}
+
+tdm_error
+tdm_client_output_get_refresh_rate(tdm_client_output *output, unsigned int *refresh)
+{
+ tdm_private_client_output *private_output;
+ tdm_private_client *private_client;
+
+ TDM_RETURN_VAL_IF_FAIL(output != NULL, TDM_ERROR_INVALID_PARAMETER);
+ TDM_RETURN_VAL_IF_FAIL(refresh != NULL, TDM_ERROR_INVALID_PARAMETER);
+
+ private_output = (tdm_private_client_output*)output;
+ private_client = private_output->private_client;
+
+ pthread_mutex_lock(&private_client->lock);
+
+ if (private_output->watch_output_changes) {
+ *refresh = private_output->refresh;
+ pthread_mutex_unlock(&private_client->lock);
+ return TDM_ERROR_NONE;
+ }
+
+ if (CHECK_WL_PROTOCOL_ERROR(private_client)) {
+ pthread_mutex_unlock(&private_client->lock);
+ return TDM_ERROR_PROTOCOL_ERROR;
+ }
+
+ wl_proxy_set_queue((struct wl_proxy *)private_output->output, private_client->queue);
+ wl_tdm_output_get_mode(private_output->output);
+ wl_display_roundtrip_queue(private_client->display, private_client->queue);
+ wl_proxy_set_queue((struct wl_proxy *)private_output->output, NULL);
+
+ if (CHECK_WL_PROTOCOL_ERROR(private_client)) {
+ pthread_mutex_unlock(&private_client->lock);
+ return TDM_ERROR_PROTOCOL_ERROR;
+ }
+
+ *refresh = private_output->refresh;
+
+ pthread_mutex_unlock(&private_client->lock);
+
+ return TDM_ERROR_NONE;
+}
+
+tdm_error
+tdm_client_output_get_conn_status(tdm_client_output *output, tdm_output_conn_status *status)
+{
+ tdm_private_client_output *private_output;
+ tdm_private_client *private_client;
+
+ TDM_RETURN_VAL_IF_FAIL(output != NULL, TDM_ERROR_INVALID_PARAMETER);
+ TDM_RETURN_VAL_IF_FAIL(status != NULL, TDM_ERROR_INVALID_PARAMETER);
+
+ private_output = (tdm_private_client_output*)output;
+ private_client = private_output->private_client;
+
+ pthread_mutex_lock(&private_client->lock);
+
+ if (private_output->watch_output_changes) {
+ *status = private_output->connection;
+ pthread_mutex_unlock(&private_client->lock);
+ return TDM_ERROR_NONE;
+ }
+
+ if (CHECK_WL_PROTOCOL_ERROR(private_client)) {
+ pthread_mutex_unlock(&private_client->lock);
+ return TDM_ERROR_PROTOCOL_ERROR;
+ }
+
+ wl_proxy_set_queue((struct wl_proxy *)private_output->output, private_client->queue);
+ wl_tdm_output_get_connection(private_output->output);
+ wl_display_roundtrip_queue(private_client->display, private_client->queue);
+ wl_proxy_set_queue((struct wl_proxy *)private_output->output, NULL);
+
+ if (CHECK_WL_PROTOCOL_ERROR(private_client)) {
+ pthread_mutex_unlock(&private_client->lock);
+ return TDM_ERROR_PROTOCOL_ERROR;
+ }
+
+ *status = private_output->connection;
+
+ pthread_mutex_unlock(&private_client->lock);
+
+ return TDM_ERROR_NONE;
+}
+
+tdm_error
+tdm_client_output_get_dpms(tdm_client_output *output, tdm_output_dpms *dpms)
+{
+ tdm_private_client_output *private_output;
+ tdm_private_client *private_client;
+
+ TDM_RETURN_VAL_IF_FAIL(output != NULL, TDM_ERROR_INVALID_PARAMETER);
+ TDM_RETURN_VAL_IF_FAIL(dpms != NULL, TDM_ERROR_INVALID_PARAMETER);
+
+ private_output = (tdm_private_client_output*)output;
+ private_client = private_output->private_client;
+
+ if (private_output->watch_output_changes) {
+ *dpms = private_output->dpms;
+ return TDM_ERROR_NONE;
+ }
+
+ pthread_mutex_lock(&private_client->lock);
+
+ if (CHECK_WL_PROTOCOL_ERROR(private_client)) {
+ pthread_mutex_unlock(&private_client->lock);
+ return TDM_ERROR_PROTOCOL_ERROR;
+ }
+
+ wl_proxy_set_queue((struct wl_proxy *)private_output->output, private_client->queue);
+ wl_tdm_output_get_dpms(private_output->output);
+ wl_display_roundtrip_queue(private_client->display, private_client->queue);
+ wl_proxy_set_queue((struct wl_proxy *)private_output->output, NULL);
+
+ if (CHECK_WL_PROTOCOL_ERROR(private_client)) {
+ pthread_mutex_unlock(&private_client->lock);
+ return TDM_ERROR_PROTOCOL_ERROR;
+ }
+
+ *dpms = private_output->dpms;
+
+ pthread_mutex_unlock(&private_client->lock);
+
+ return TDM_ERROR_NONE;
+}
+
+tdm_client_vblank*
+tdm_client_output_create_vblank(tdm_client_output *output, tdm_error *error)
+{
+ tdm_private_client *private_client;
+ tdm_private_client_output *private_output;
+ tdm_private_client_vblank *private_vblank;
+ struct wl_proxy *wrapper;
+
+ if (error)
+ *error = TDM_ERROR_NONE;
+
+ if (!output) {
+ TDM_ERR("'!output' failed");
+ if (error)
+ *error = TDM_ERROR_INVALID_PARAMETER;
+ return NULL;
+ }
+
+ private_output = (tdm_private_client_output*)output;
+ private_client = private_output->private_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;
+ }
+
+ wrapper = wl_proxy_create_wrapper(private_output->output);
+ if (!wrapper) {
+ TDM_ERR("create 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_vblank = calloc(1, sizeof *private_vblank);
+ if (!private_vblank) {
+ /* LCOV_EXCL_START */
+
+ TDM_ERR("alloc failed");
+ wl_proxy_wrapper_destroy(wrapper);
+ if (error)
+ *error = TDM_ERROR_OUT_OF_MEMORY;
+ pthread_mutex_unlock(&private_client->lock);
+ return NULL;
+
+ /* LCOV_EXCL_STOP */
+ }
+
+ private_vblank->private_output = private_output;
+
+ private_vblank->vblank = wl_tdm_output_create_vblank((struct wl_tdm_output*)wrapper);
+ wl_proxy_wrapper_destroy(wrapper);
+ if (!private_vblank->vblank) {
+ /* LCOV_EXCL_START */
+
+ TDM_ERR("couldn't create vblank resource");
+ free(private_vblank);
+ if (error)
+ *error = TDM_ERROR_OUT_OF_MEMORY;
+ pthread_mutex_unlock(&private_client->lock);
+ return NULL;
+
+ /* LCOV_EXCL_STOP */
+ }
+
+ /* initial value */
+ private_vblank->fps = private_output->refresh;
+ private_vblank->offset = 0;
+ private_vblank->enable_fake = 0;
+
+ LIST_INITHEAD(&private_vblank->wait_list);
+
+ wl_tdm_vblank_add_listener(private_vblank->vblank,
+ &tdm_client_vblank_listener, private_vblank);
+ wl_display_roundtrip_queue(private_client->display, private_client->queue);
+
+ wl_proxy_set_queue((struct wl_proxy *)private_vblank->vblank, NULL);
+
+ if (CHECK_WL_PROTOCOL_ERROR(private_client)) {
+ wl_tdm_vblank_destroy(private_vblank->vblank);
+ free(private_vblank);
+ if (error)
+ *error = TDM_ERROR_PROTOCOL_ERROR;
+ pthread_mutex_unlock(&private_client->lock);
+ return NULL;
+ }
+
+ LIST_ADDTAIL(&private_vblank->link, &private_output->vblank_list);
+
+ pthread_mutex_unlock(&private_client->lock);
+
+ return (tdm_client_vblank*)private_vblank;
+}
+
+void
+tdm_client_vblank_destroy(tdm_client_vblank *vblank)
+{
+ tdm_private_client_vblank *private_vblank;
+ tdm_private_client *private_client;
+ tdm_client_wait_info *w = NULL, *ww = NULL;
+
+ TDM_RETURN_IF_FAIL(vblank != NULL);
+
+ private_vblank = vblank;
+ private_client = private_vblank->private_output->private_client;
+
+ pthread_mutex_lock(&private_client->lock);
+
+ LIST_DEL(&private_vblank->link);
+
+ LIST_FOR_EACH_ENTRY_SAFE(w, ww, &private_vblank->wait_list, link) {
+ LIST_DEL(&w->link);
+ free(w);
+ }
+
+ wl_tdm_vblank_destroy(private_vblank->vblank);
+
+ free(private_vblank);
+
+ pthread_mutex_unlock(&private_client->lock);
+}
+
+tdm_error
+tdm_client_vblank_set_name(tdm_client_vblank *vblank, const char *name)
+{
+ tdm_private_client_vblank *private_vblank;
+ tdm_private_client *private_client;
+
+ TDM_RETURN_VAL_IF_FAIL(vblank != NULL, TDM_ERROR_INVALID_PARAMETER);
+
+ private_vblank = vblank;
+ private_client = private_vblank->private_output->private_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 (!name)
+ name = TDM_VBLANK_DEFAULT_NAME;
+
+ strncpy(private_vblank->name, name, TDM_NAME_LEN - 1);
+ private_vblank->name[TDM_NAME_LEN - 1] = '\0';
+
+ wl_tdm_vblank_set_name(private_vblank->vblank, private_vblank->name);
+
+ pthread_mutex_unlock(&private_client->lock);
+
+ return TDM_ERROR_NONE;
+}
+
+tdm_error
+tdm_client_vblank_set_sync(tdm_client_vblank *vblank, unsigned int sync)
+{
+ tdm_private_client_vblank *private_vblank;
+ tdm_private_client *private_client;
+
+ TDM_RETURN_VAL_IF_FAIL(vblank != NULL, TDM_ERROR_INVALID_PARAMETER);
+
+ private_vblank = vblank;
+ private_client = private_vblank->private_output->private_client;
+
+ pthread_mutex_lock(&private_client->lock);
+ private_vblank->sync = sync;
+ pthread_mutex_unlock(&private_client->lock);
+
+ return TDM_ERROR_NONE;
+}
+
+tdm_error
+tdm_client_vblank_set_fps(tdm_client_vblank *vblank, unsigned int fps)
+{
+ tdm_private_client_vblank *private_vblank;
+ tdm_private_client *private_client;
+
+ TDM_RETURN_VAL_IF_FAIL(vblank != NULL, TDM_ERROR_INVALID_PARAMETER);
+ TDM_RETURN_VAL_IF_FAIL(fps > 0, TDM_ERROR_INVALID_PARAMETER);
+
+ private_vblank = vblank;
+ private_client = private_vblank->private_output->private_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_vblank->fps == fps) {
+ pthread_mutex_unlock(&private_client->lock);
+ return TDM_ERROR_NONE;
+ }
+
+ private_vblank->fps = fps;
+
+ wl_tdm_vblank_set_fps(private_vblank->vblank, fps);
+
+ pthread_mutex_unlock(&private_client->lock);
+
+ return TDM_ERROR_NONE;
+}
+
+tdm_error
+tdm_client_vblank_set_offset(tdm_client_vblank *vblank, int offset_ms)
+{
+ tdm_private_client_vblank *private_vblank;
+ tdm_private_client *private_client;
+
+ TDM_RETURN_VAL_IF_FAIL(vblank != NULL, TDM_ERROR_INVALID_PARAMETER);
+
+ private_vblank = vblank;
+ TDM_RETURN_VAL_IF_FAIL(private_vblank->started == 0, TDM_ERROR_BAD_REQUEST);
+
+ private_client = private_vblank->private_output->private_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_vblank->offset == offset_ms) {
+ pthread_mutex_unlock(&private_client->lock);
+ return TDM_ERROR_NONE;
+ }
+
+ private_vblank->offset = offset_ms;
+
+ wl_tdm_vblank_set_offset(private_vblank->vblank, offset_ms);
+
+ pthread_mutex_unlock(&private_client->lock);
+
+ return TDM_ERROR_NONE;
+}
+
+tdm_error
+tdm_client_vblank_set_enable_fake(tdm_client_vblank *vblank, unsigned int enable_fake)
+{
+ tdm_private_client_vblank *private_vblank;
+ tdm_private_client *private_client;
+
+ TDM_RETURN_VAL_IF_FAIL(vblank != NULL, TDM_ERROR_INVALID_PARAMETER);
+
+ private_vblank = vblank;
+ private_client = private_vblank->private_output->private_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_vblank->enable_fake == enable_fake) {
+ pthread_mutex_unlock(&private_client->lock);
+ return TDM_ERROR_NONE;
+ }
+
+ private_vblank->enable_fake = enable_fake;
+
+ wl_tdm_vblank_set_enable_fake(private_vblank->vblank, enable_fake);
+
+ pthread_mutex_unlock(&private_client->lock);
+
+ return TDM_ERROR_NONE;
+}
+
+tdm_error
+tdm_client_vblank_wait(tdm_client_vblank *vblank, unsigned int interval, tdm_client_vblank_handler func, void *user_data)
+{
+ tdm_private_client *private_client;
+ tdm_private_client_output *private_output;
+ tdm_private_client_vblank *private_vblank;
+ tdm_client_wait_info *w;
+ struct timespec tp;
+ unsigned int req_sec, req_usec;
+ int ret = 0;
+
+ TDM_RETURN_VAL_IF_FAIL(vblank != NULL, TDM_ERROR_INVALID_PARAMETER);
+ TDM_RETURN_VAL_IF_FAIL(func != NULL, TDM_ERROR_INVALID_PARAMETER);
+ /* can't support "interval 0" and "getting current_msc" things because
+ * there is a socket communication between TDM client and server. It's impossible
+ * to return the current msc or sequence immediately.
+ */
+ TDM_RETURN_VAL_IF_FAIL(interval > 0, TDM_ERROR_INVALID_PARAMETER);
+
+ private_vblank = vblank;
+ private_output = private_vblank->private_output;
+ private_client = private_output->private_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_vblank->started)
+ private_vblank->started = 1;
+
+ if (!private_vblank->enable_fake) {
+ if (private_output->connection == TDM_OUTPUT_CONN_STATUS_DISCONNECTED) {
+ TDM_ERR("output disconnected");
+ pthread_mutex_unlock(&private_client->lock);
+ return TDM_ERROR_OUTPUT_DISCONNECTED;
+ }
+ if (TDM_OUTPUT_DPMS_VSYNC_IS_OFF(private_output->dpms)) {
+ TDM_ERR("dpms %s", tdm_dpms_str(private_output->dpms));
+ pthread_mutex_unlock(&private_client->lock);
+ return TDM_ERROR_DPMS_OFF;
+ }
+ }
+
+ w = calloc(1, sizeof *w);
+ if (!w) {
+ /* LCOV_EXCL_START */
+
+ TDM_ERR("alloc failed");
+ pthread_mutex_unlock(&private_client->lock);
+ return TDM_ERROR_OUT_OF_MEMORY;
+
+ /* LCOV_EXCL_STOP */
+ }
+
+ w->private_vblank = private_vblank;
+ w->func = func;
+ w->user_data = user_data;
+
+ LIST_ADDTAIL(&w->link, &private_vblank->wait_list);
+ LIST_INITHEAD(&w->call_link);
+
+ clock_gettime(CLOCK_MONOTONIC, &tp);
+ req_sec = (unsigned int)tp.tv_sec;
+ req_usec = (unsigned int)(tp.tv_nsec / 1000);
+
+ w->req_id = ++private_output->req_id;
+ w->req_time = TDM_TIME(req_sec, req_usec);
+ w->need_free = (private_vblank->sync) ? 0 : 1;
+
+ wl_tdm_vblank_wait_vblank(private_vblank->vblank, interval, w->req_id, req_sec, req_usec);
+
+ if (private_vblank->enable_ttrace)
+ TDM_TRACE_ASYNC_BEGIN((int)w->req_time, "TDM_Client_Vblank:%u", private_vblank->stamp);
+
+ TDM_DBG("vblank(%p) interval(%u) req_id(%d) req(%.6f)",
+ vblank, interval, w->req_id, w->req_time);
+
+ private_vblank->req_time = w->req_time;
+
+ if (private_vblank->last_time >= w->req_time)
+ TDM_ERR("'last(%.6f) < req(%.6f)' failed", private_vblank->last_time, w->req_time);
+
+ if (!private_vblank->sync) {
+ wl_display_flush(private_client->display);
+ pthread_mutex_unlock(&private_client->lock);
+ return TDM_ERROR_NONE;
+ }
+
+ /* LCOV_EXCL_START */
+
+ while (ret != -1 && !w->need_free)
+ ret = wl_display_dispatch(private_client->display);
+
+ clock_gettime(CLOCK_MONOTONIC, &tp);
+ TDM_DBG("block during %d us",
+ ((unsigned int)(tp.tv_sec * 1000000) + (unsigned int)(tp.tv_nsec / 1000))
+ - (req_sec * 1000000 + req_usec));
+
+ LIST_DEL(&w->link);
+ free(w);
+
+ 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 TDM_ERROR_NONE;
+
+ /* LCOV_EXCL_STOP */
+}
+
+tdm_error
+tdm_client_vblank_wait_seq(tdm_client_vblank *vblank, unsigned int sequence,
+ tdm_client_vblank_handler func, void *user_data)
+{
+ tdm_private_client *private_client;
+ tdm_private_client_output *private_output;
+ tdm_private_client_vblank *private_vblank;
+ tdm_client_wait_info *w;
+ struct timespec tp;
+ unsigned int req_sec, req_usec;
+ int ret = 0;
+
+ TDM_RETURN_VAL_IF_FAIL(vblank != NULL, TDM_ERROR_INVALID_PARAMETER);
+ TDM_RETURN_VAL_IF_FAIL(func != NULL, TDM_ERROR_INVALID_PARAMETER);
+
+ private_vblank = vblank;
+ private_output = private_vblank->private_output;
+ private_client = private_output->private_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_vblank->started)
+ private_vblank->started = 1;
+
+ if (!private_vblank->enable_fake) {
+ if (private_output->connection == TDM_OUTPUT_CONN_STATUS_DISCONNECTED) {
+ TDM_ERR("output disconnected");
+ pthread_mutex_unlock(&private_client->lock);
+ return TDM_ERROR_OUTPUT_DISCONNECTED;
+ }
+ if (TDM_OUTPUT_DPMS_VSYNC_IS_OFF(private_output->dpms)) {
+ TDM_ERR("dpms %s", tdm_dpms_str(private_output->dpms));
+ pthread_mutex_unlock(&private_client->lock);
+ return TDM_ERROR_DPMS_OFF;
+ }
+ }
+
+ w = calloc(1, sizeof *w);
+ if (!w) {
+ /* LCOV_EXCL_START */
+
+ TDM_ERR("alloc failed");
+ pthread_mutex_unlock(&private_client->lock);
+ return TDM_ERROR_OUT_OF_MEMORY;
+
+ /* LCOV_EXCL_STOP */
+ }
+
+ w->private_vblank = private_vblank;
+ w->func = func;
+ w->user_data = user_data;
+
+ LIST_ADDTAIL(&w->link, &private_vblank->wait_list);
+ LIST_INITHEAD(&w->call_link);
+
+ clock_gettime(CLOCK_MONOTONIC, &tp);
+ req_sec = (unsigned int)tp.tv_sec;
+ req_usec = (unsigned int)(tp.tv_nsec / 1000);
+
+ w->req_id = ++private_output->req_id;
+ w->req_time = TDM_TIME(req_sec, req_usec);
+ w->need_free = (private_vblank->sync) ? 0 : 1;
+
+ wl_tdm_vblank_wait_vblank_seq(private_vblank->vblank, sequence, w->req_id, req_sec, req_usec);
+
+ if (private_vblank->enable_ttrace)
+ TDM_TRACE_ASYNC_BEGIN((int)w->req_time, "TDM_Client_Vblank:%u", private_vblank->stamp);
+
+ TDM_DBG("vblank(%p) sequence(%u) req_id(%d) req(%.6f)",
+ vblank, sequence, w->req_id, w->req_time);
+
+ private_vblank->req_time = w->req_time;
+
+ if (private_vblank->last_time >= w->req_time)
+ TDM_ERR("'last(%.6f) < req(%.6f)' failed", private_vblank->last_time, w->req_time);
+
+ if (!private_vblank->sync) {
+ wl_display_flush(private_client->display);
+ pthread_mutex_unlock(&private_client->lock);
+ return TDM_ERROR_NONE;
+ }
+
+ /* LCOV_EXCL_START */
+
+ while (ret != -1 && !w->need_free)
+ ret = wl_display_dispatch(private_client->display);
+
+ clock_gettime(CLOCK_MONOTONIC, &tp);
+ TDM_DBG("block during %d us",
+ ((unsigned int)(tp.tv_sec * 1000000) + (unsigned int)(tp.tv_nsec / 1000))
+ - (req_sec * 1000000 + req_usec));
+
+ LIST_DEL(&w->link);
+ free(w);
+
+ 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 TDM_ERROR_NONE;
+
+ /* 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_commit(void *data, struct wl_tdm_voutput *wl_voutput)
+{
+ tdm_private_client_voutput *private_voutput;
+ tdm_private_client *private_client;
+ tdm_client_voutput_commit_handler_info *h = NULL, *hh = NULL;
+ struct list_head call_list;
+
+ private_voutput = (tdm_private_client_voutput *)data;
+ TDM_RETURN_IF_FAIL(private_voutput != NULL);
+
+ private_client = private_voutput->base.private_client;
+
+ LIST_INITHEAD(&call_list);
+
+ LIST_FOR_EACH_ENTRY(h, &private_voutput->commit_handler_list, link) {
+ LIST_ADDTAIL(&h->call_link, &call_list);
+ }
+
+ pthread_mutex_unlock(&private_client->lock);
+ LIST_FOR_EACH_ENTRY_SAFE(h, hh, &call_list, call_link) {
+ if (h->func)
+ h->func(private_voutput, h->user_data);
+ }
+ pthread_mutex_lock(&private_client->lock);
+}
+
+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_commit,
+ 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 */
+ }
+
+ LIST_INITHEAD(&private_voutput->commit_handler_list);
+
+ 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;
+ tdm_client_voutput_commit_handler_info *h = NULL, *hh = NULL;
+
+ if (!private_voutput)
+ return;
+
+ if (private_voutput->available_modes.modes)
+ free(private_voutput->available_modes.modes);
+
+ LIST_FOR_EACH_ENTRY_SAFE(h, hh, &private_voutput->commit_handler_list, link) {
+ LIST_DEL(&h->link);
+ free(h);
+ }
+
+ 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, unsigned int mmWidth, unsigned int mmHeight)
+{
+ tdm_private_client_voutput *private_voutput;
+
+ 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);
+
+ private_voutput = (tdm_private_client_voutput *)voutput;
+
+ if (private_voutput->base.connection == TDM_OUTPUT_CONN_STATUS_CONNECTED)
+ return TDM_ERROR_BAD_REQUEST;
+
+ private_voutput->mmwidth = mmWidth;
+ private_voutput->mmheight = mmHeight;
+
+ return TDM_ERROR_NONE;
+}
+
+tdm_error
+tdm_client_voutput_add_commit_handler(tdm_client_voutput *voutput,
+ tdm_client_voutput_commit_handler func,
+ void *user_data)
+{
+ tdm_private_client_voutput *private_voutput;
+ tdm_private_client *private_client;
+ tdm_client_voutput_commit_handler_info *h = NULL;
+
+ TDM_RETURN_VAL_IF_FAIL(voutput != NULL, TDM_ERROR_INVALID_PARAMETER);
+ TDM_RETURN_VAL_IF_FAIL(func != NULL, TDM_ERROR_INVALID_PARAMETER);
+
+ private_voutput = (tdm_private_client_voutput *)voutput;
+ private_client = private_voutput->base.private_client;
+
+ LIST_FOR_EACH_ENTRY(h, &private_voutput->commit_handler_list, link) {
+ if (h->func == func && h->user_data == user_data) {
+ TDM_ERR("can't add twice");
+ return TDM_ERROR_BAD_REQUEST;
+ }
+ }
+
+ h = calloc(1, sizeof *h);
+ TDM_RETURN_VAL_IF_FAIL(h != NULL, TDM_ERROR_OUT_OF_MEMORY);
+
+ pthread_mutex_lock(&private_client->lock);
+
+ if (CHECK_WL_PROTOCOL_ERROR(private_client)) {
+ free(h);
+ pthread_mutex_unlock(&private_client->lock);
+ return TDM_ERROR_PROTOCOL_ERROR;
+ }
+
+ h->private_voutput = private_voutput;
+ h->func = func;
+ h->user_data = user_data;
+ LIST_ADDTAIL(&h->link, &private_voutput->commit_handler_list);
+ LIST_INITHEAD(&h->call_link);
+
+ pthread_mutex_unlock(&private_client->lock);
+
+ return TDM_ERROR_NONE;
+}
+
+void
+tdm_client_voutput_remove_commit_handler(tdm_client_voutput *voutput,
+ tdm_client_voutput_commit_handler func,
+ void *user_data)
+{
+ tdm_private_client_voutput *private_voutput;
+ tdm_private_client *private_client;
+ tdm_client_voutput_commit_handler_info *h = NULL;
+
+ TDM_RETURN_IF_FAIL(voutput != NULL);
+ TDM_RETURN_IF_FAIL(func != NULL);
+
+ private_voutput = (tdm_private_client_voutput *)voutput;
+ private_client = private_voutput->base.private_client;
+
+ pthread_mutex_lock(&private_client->lock);
+
+ LIST_FOR_EACH_ENTRY(h, &private_voutput->commit_handler_list, link) {
+ if (h->func != func || h->user_data != user_data)
+ continue;
+
+ LIST_DEL(&h->link);
+ free(h);
+
+ pthread_mutex_unlock(&private_client->lock);
+ }
+
+ pthread_mutex_unlock(&private_client->lock);
+}
+
+tdm_error
+tdm_client_voutput_commit_done(tdm_client_voutput *voutput)
+{
+ tdm_private_client_voutput *private_voutput;
+
+ TDM_RETURN_VAL_IF_FAIL(voutput != NULL, TDM_ERROR_INVALID_PARAMETER);
+
+ private_voutput = (tdm_private_client_voutput *)voutput;
+ wl_tdm_voutput_commit_done(private_voutput->wl_voutput);
+
+ 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_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;
+}
+
+void
+_tdm_client_voutput_send_available_modes(tdm_private_client_voutput *private_voutput)
+{
+ tdm_client_output_mode *modes, *mode;
+ struct wl_array array;
+ int i, size;
+
+ modes = private_voutput->available_modes.modes;
+ size = sizeof(tdm_client_output_mode);
+
+ wl_array_init(&array);
+ for (i = 0; i < private_voutput->available_modes.count; i++) {
+ mode = wl_array_add(&array, size);
+ memcpy(mode, &modes[i], size);
+ }
+ wl_tdm_voutput_set_available_modes(private_voutput->wl_voutput, &array);
+ wl_array_release(&array);
+}
+
+tdm_error
+tdm_client_output_connect(tdm_client_output *output)
+{
+ tdm_private_client_output *private_output;
+ tdm_private_client_voutput *private_voutput;
+
+ 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;
+
+ _tdm_client_voutput_send_available_modes(private_voutput);
+
+ wl_tdm_voutput_set_physical_size(private_voutput->wl_voutput, private_voutput->mmwidth, private_voutput->mmheight);
+
+ 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;