unsigned int mmwidth;
unsigned int mmheight;
+
+ struct list_head buffer_list;
+ tdm_server_voutput_buffer *attach_buffer;
+ int committing;
} tdm_server_voutput_info;
typedef struct _tdm_server_vblank_info {
tdm_vblank *vblank;
unsigned int stamp;
+
+ /* for timeout */
+ tdm_event_loop_source *vblank_timeout_timer;
} tdm_server_vblank_info;
typedef struct _tdm_server_wait_info {
unsigned int req_id;
double req_time;
+
+ unsigned int timeout;
} tdm_server_wait_info;
typedef struct _tdm_server_client_info {
static struct list_head client_list;
static void destroy_wait(tdm_server_wait_info *wait_info);
+static void _tdm_server_vblank_timeout_update(tdm_server_vblank_info *vblank_info, int ms_delay);
static void
_tdm_server_get_process_name(pid_t pid, char *name, unsigned int size)
{
tdm_server_wait_info *found;
tdm_server_vblank_info *vblank_info;
+ tdm_server_output_info *output_info;
+ tdm_private_server *private_server;
+ tdm_private_loop *private_loop;
TDM_RETURN_IF_FAIL(keep_private_server != NULL);
TDM_DBG("req_id(%d) done", wait_info->req_id);
vblank_info = wait_info->vblank_info;
+ output_info = vblank_info->output_info;
+ private_server = output_info->private_server;
+ private_loop = private_server->private_loop;
+
+ tdm_display_lock(private_loop->dpy);
+ _tdm_server_vblank_timeout_update(vblank_info, 0);
+ tdm_display_unlock(private_loop->dpy);
if (tdm_ttrace_module & TDM_TTRACE_SERVER_VBLANK)
TDM_TRACE_ASYNC_END((int)wait_info->req_time, "TDM_Server_Vblank:%u", vblank_info->stamp);
- wl_tdm_vblank_send_done(vblank_info->resource, wait_info->req_id,
- sequence, tv_sec, tv_usec, error);
+ if (!wait_info->timeout)
+ wl_tdm_vblank_send_done(vblank_info->resource, wait_info->req_id,
+ sequence, tv_sec, tv_usec, error);
destroy_wait(wait_info);
}
/* LCOV_EXCL_STOP */
/* LCOV_EXCL_START */
+static tdm_error
+_tdm_server_timeout_timer_cb(void *user_data)
+{
+ tdm_server_vblank_info *vblank_info = user_data;
+ tdm_server_wait_info *wait_info = NULL;
+ double curr;
+ unsigned int tv_sec;
+ unsigned int tv_usec;
+
+ TDM_RETURN_VAL_IF_FAIL(vblank_info != NULL, TDM_ERROR_OPERATION_FAILED);
+ TDM_RETURN_VAL_IF_FAIL(keep_private_server != NULL, TDM_ERROR_OPERATION_FAILED);
+
+ curr = tdm_helper_get_time();
+ tv_sec = TDM_TIME_SEC(curr);
+ tv_usec = TDM_TIME_USEC(curr);
+
+ LIST_FOR_EACH_ENTRY(wait_info, &keep_private_server->wait_list, link) {
+ if (wait_info->timeout) continue;
+ if (vblank_info != wait_info->vblank_info) continue;
+
+ wl_tdm_vblank_send_done(vblank_info->resource, wait_info->req_id,
+ 0, tv_sec, tv_usec, TDM_ERROR_TIMEOUT);
+ TDM_ERR("tdm_server_vblank(%p) req_id(%d) timeout force send vblank", vblank_info, wait_info->req_id);
+ wait_info->timeout = 1;
+ }
+
+ return TDM_ERROR_NONE;
+}
+
+static void
+_tdm_server_vblank_timeout_update(tdm_server_vblank_info *vblank_info, int ms_delay)
+{
+ tdm_server_output_info *output_info = vblank_info->output_info;
+ tdm_private_server *private_server = output_info->private_server;
+ tdm_private_loop *private_loop = private_server->private_loop;
+ tdm_error ret;
+
+ if (!vblank_info->vblank_timeout_timer) {
+ vblank_info->vblank_timeout_timer =
+ tdm_event_loop_add_timer_handler(private_loop->dpy,
+ _tdm_server_timeout_timer_cb,
+ vblank_info,
+ &ret);
+ if (!vblank_info->vblank_timeout_timer) {
+ TDM_ERR("tdm_server_vblank(%p) couldn't add timer", vblank_info);
+ return;
+ }
+
+ if (tdm_debug_module & TDM_DEBUG_VBLANK)
+ TDM_INFO("tdm_server_vblank(%p) create vblank timeout timer", vblank_info);
+ }
+
+ ret = tdm_event_loop_source_timer_update(vblank_info->vblank_timeout_timer, ms_delay);
+ if (ret != TDM_ERROR_NONE) {
+ TDM_ERR("tdm_server_vblank(%p) couldn't update timer", vblank_info);
+ return;
+ }
+}
+
static void
_tdm_server_cb_vblank(tdm_vblank *vblank, tdm_error error, unsigned int sequence,
unsigned int tv_sec, unsigned int tv_usec, void *user_data)
destroy_vblank_callback(struct wl_resource *resource)
{
tdm_server_vblank_info *vblank_info = wl_resource_get_user_data(resource);
+ tdm_server_output_info *output_info = vblank_info->output_info;
+ tdm_private_server *private_server = output_info->private_server;
+ tdm_private_loop *private_loop = private_server->private_loop;
tdm_server_wait_info *w = NULL, *ww = NULL;
TDM_RETURN_IF_FAIL(vblank_info != NULL);
+ if (vblank_info->vblank_timeout_timer) {
+ tdm_display_lock(private_loop->dpy);
+ tdm_event_loop_source_remove(vblank_info->vblank_timeout_timer);
+ tdm_display_unlock(private_loop->dpy);
+ }
+
LIST_DEL(&vblank_info->link);
if (vblank_info->vblank)
tdm_server_vblank_info *vblank_info = wl_resource_get_user_data(resource);
tdm_server_output_info *output_info = vblank_info->output_info;
tdm_private_server *private_server = output_info->private_server;
+ tdm_private_loop *private_loop = private_server->private_loop;
tdm_server_wait_info *wait_info;
unsigned int enable_fake = 0;
tdm_error ret;
TDM_GOTO_IF_FAIL(ret == TDM_ERROR_NONE, wait_failed);
+ tdm_display_lock(private_loop->dpy);
+ _tdm_server_vblank_timeout_update(vblank_info, 1000);
+ tdm_display_unlock(private_loop->dpy);
+
return;
wait_failed:
/* LCOV_EXCL_START */
voutput_info->mmwidth = 0;
voutput_info->mmheight = 0;
+ if (voutput_info->attach_buffer) {
+ tbm_surface_h buffer = voutput_info->attach_buffer->buffer;
+ tbm_surface_internal_unref(buffer);
+ voutput_info->committing = 0;
+ voutput_info->attach_buffer = NULL;
+ }
+
tdm_voutput_disconnect(voutput_info->voutput);
}
static void
_tdm_voutput_cb_commit_done(struct wl_client *client, struct wl_resource *resource)
{
- /* TODO */
+ tdm_server_voutput_info *voutput_info;
+ tbm_surface_h buffer;
+
+ voutput_info = wl_resource_get_user_data(resource);
+ if (voutput_info->status != TDM_OUTPUT_CONN_STATUS_CONNECTED) {
+ TDM_DBG("not connected.");
+ return;
+ }
+
+ buffer = voutput_info->attach_buffer->buffer;
+ tbm_surface_internal_unref(buffer);
+ voutput_info->committing = 0;
+ voutput_info->attach_buffer = NULL;
+
+ tdm_voutput_commit_done(voutput_info->voutput);
}
static const struct wl_tdm_voutput_interface tdm_voutput_implementation = {
_tdm_voutput_cb_commit_done
};
+static void
+_tdm_voutput_wl_buffer_destroy(struct wl_client *client, struct wl_resource *wl_buffer)
+{
+ wl_resource_destroy(wl_buffer);
+}
+
+static const struct wl_buffer_interface _tdm_voutput_buffer_impementation = {
+ _tdm_voutput_wl_buffer_destroy
+};
+
+static void
+_tdm_voutput_buffer_destory(struct wl_resource *wl_buffer)
+{
+ tdm_server_voutput_info *voutput_info = NULL;
+ tdm_server_voutput_buffer *vb = NULL, *vbb = NULL;
+
+ voutput_info = (tdm_server_voutput_info *)wl_resource_get_user_data(wl_buffer);
+ TDM_RETURN_IF_FAIL(voutput_info != NULL);
+
+ LIST_FOR_EACH_ENTRY_SAFE(vb, vbb, &voutput_info->buffer_list, link) {
+ if (vb->wl_buffer == wl_buffer) {
+ tbm_surface_internal_unref(vb->buffer);
+ wl_resource_set_user_data(wl_buffer, NULL);
+ LIST_DEL(&vb->link);
+ free(vb);
+ }
+ }
+}
+
+struct wl_resource *
+_tdm_voutput_create_wl_buffer(tdm_server_voutput_info *voutput_info)
+{
+ struct wl_client *wl_client;
+ struct wl_resource *wl_buffer = NULL;
+
+ wl_client = wl_resource_get_client(voutput_info->resource);
+
+ /* create a wl_buffer resource */
+ wl_buffer = wl_resource_create(wl_client, &wl_buffer_interface, 1, 0);
+ TDM_RETURN_VAL_IF_FAIL(wl_buffer != NULL, NULL);
+
+ wl_resource_set_implementation(wl_buffer,
+ (void (**)(void)) &_tdm_voutput_buffer_impementation,
+ voutput_info, _tdm_voutput_buffer_destory);
+
+ return wl_buffer;
+}
+
+struct wl_resource *
+_tdm_voutput_export_buffer(tdm_server_voutput_info *voutput_info,
+ tbm_surface_h buffer)
+{
+ int bufs[TBM_SURF_PLANE_MAX] = { -1, -1, -1, -1};
+ struct wl_resource *wl_buffer = NULL;
+ int num_buf, is_fd = -1, i;
+ tbm_surface_info_s info;
+ uint32_t flags = 0;
+ struct wl_array plane_buf_idx, plane_offset, plane_stride, plane_size;
+ int *p;
+
+ TDM_RETURN_VAL_IF_FAIL(voutput_info != NULL, NULL);
+ TDM_RETURN_VAL_IF_FAIL(buffer != NULL, NULL);
+
+ if (tbm_surface_get_info(buffer, &info) != TBM_SURFACE_ERROR_NONE) {
+ TDM_ERR("Failed to create buffer from surface");
+ return NULL;
+ }
+
+ if (info.num_planes > 3) {
+ TDM_ERR("invalid num_planes(%d)", info.num_planes);
+ return NULL;
+ }
+
+ num_buf = tbm_surface_internal_get_num_bos(buffer);
+ if (num_buf == 0) {
+ TDM_ERR("surface doesn't have any bo.");
+ return NULL;
+ }
+
+ for (i = 0; i < num_buf; i++) {
+ tbm_bo bo = tbm_surface_internal_get_bo(buffer, i);
+ if (bo == NULL) {
+ TDM_ERR("Failed to get bo from surface");
+ goto err;
+ }
+
+ /* try to get fd first */
+ if (is_fd == -1 || is_fd == 1) {
+ bufs[i] = tbm_bo_export_fd(bo);
+ if (is_fd == -1 && bufs[i] >= 0)
+ is_fd = 1;
+ }
+
+ /* if fail to get fd, try to get name second */
+ if (is_fd == -1 || is_fd == 0) {
+ bufs[i] = tbm_bo_export(bo);
+ if (is_fd == -1 && bufs[i] > 0)
+ is_fd = 0;
+ }
+
+ if (is_fd == -1 ||
+ (is_fd == 1 && bufs[i] < 0) ||
+ (is_fd == 0 && bufs[i] <= 0)) {
+ TDM_ERR("Failed to export(is_fd:%d, bufs:%d)", is_fd, bufs[i]);
+ goto err;
+ }
+ }
+
+ wl_buffer = _tdm_voutput_create_wl_buffer(voutput_info);
+ if (!wl_buffer) {
+ TDM_ERR("Failed to create wl_buffer");
+ goto err;
+ }
+
+ wl_array_init(&plane_buf_idx);
+ wl_array_init(&plane_offset);
+ wl_array_init(&plane_stride);
+ wl_array_init(&plane_size);
+
+ for (i = 0; i < 3; i++) {
+ p = wl_array_add(&plane_buf_idx, sizeof(int));
+ *p = tbm_surface_internal_get_plane_bo_idx(buffer, i);
+ p = wl_array_add(&plane_offset, sizeof(int));
+ *p = info.planes[i].offset;
+ p = wl_array_add(&plane_stride, sizeof(int));
+ *p = info.planes[i].stride;
+ p = wl_array_add(&plane_size, sizeof(int));
+ *p = info.planes[i].size;
+ }
+
+ if (is_fd == 1)
+ wl_tdm_voutput_send_buffer_set_with_fd(voutput_info->resource,
+ wl_buffer,
+ info.width, info.height, info.format, info.bpp, info.size, info.num_planes,
+ &plane_buf_idx, &plane_offset, &plane_stride, &plane_size,
+ flags, num_buf, bufs[0],
+ (bufs[1] == -1) ? bufs[0] : bufs[1],
+ (bufs[2] == -1) ? bufs[0] : bufs[2]);
+ else
+ wl_tdm_voutput_send_buffer_set_with_id(voutput_info->resource,
+ wl_buffer,
+ info.width, info.height, info.format, info.bpp, info.size, info.num_planes,
+ &plane_buf_idx, &plane_offset, &plane_stride, &plane_size,
+ flags,
+ num_buf, bufs[0], bufs[1], bufs[2]);
+
+ wl_array_release(&plane_buf_idx);
+ wl_array_release(&plane_offset);
+ wl_array_release(&plane_stride);
+ wl_array_release(&plane_size);
+
+ for (i = 0; i < TBM_SURF_PLANE_MAX; i++) {
+ if (is_fd == 1 && (bufs[i] >= 0))
+ close(bufs[i]);
+ }
+
+ return wl_buffer;
+
+err:
+ for (i = 0; i < TBM_SURF_PLANE_MAX; i++) {
+ if (is_fd == 1 && (bufs[i] >= 0))
+ close(bufs[i]);
+ }
+
+ return NULL;
+}
+
+tdm_server_voutput_buffer *
+_tdm_output_get_voutput_buffer(tdm_server_voutput_info *voutput_info, tbm_surface_h buffer)
+{
+ tdm_server_voutput_buffer *voutput_buffer = NULL, *vb = NULL;
+
+ LIST_FOR_EACH_ENTRY(vb, &voutput_info->buffer_list, link) {
+ if (vb && vb->buffer == buffer) {
+ tbm_surface_internal_ref(vb->buffer);
+ return vb;
+ }
+ }
+
+ tbm_surface_internal_ref(buffer);
+ voutput_buffer = calloc(1, sizeof *voutput_buffer);
+ if (!voutput_buffer) {
+ /* LCOV_EXCL_START */
+
+ TDM_ERR("fail calloc");
+ tbm_surface_internal_unref(buffer);
+ return NULL;
+
+ /* LCOV_EXCL_STOP */
+ }
+
+ voutput_buffer->wl_buffer = _tdm_voutput_export_buffer(voutput_info, buffer);
+ if (!voutput_buffer->wl_buffer) {
+ /* LCOV_EXCL_START */
+
+ TDM_ERR("fail export buffer");
+ free(voutput_buffer);
+ tbm_surface_internal_unref(buffer);
+ return NULL;
+
+ /* LCOV_EXCL_STOP */
+ }
+
+ voutput_buffer->buffer = buffer;
+ LIST_ADDTAIL(&voutput_buffer->link, &voutput_info->buffer_list);
+
+ return voutput_buffer;
+}
+
+tdm_error
+tdm_voutput_attach_buffer(tdm_voutput *voutput, tbm_surface_h buffer)
+{
+ tdm_private_server *private_server = keep_private_server;
+ tdm_server_voutput_info *voutput_info = NULL, *vo = NULL;
+ tdm_server_voutput_buffer *voutput_buffer = NULL;
+
+ TDM_RETURN_VAL_IF_FAIL(keep_private_server != NULL, TDM_ERROR_OPERATION_FAILED);
+
+ LIST_FOR_EACH_ENTRY(vo, &private_server->voutput_list, link) {
+ if (vo && vo->voutput == voutput) {
+ voutput_info = vo;
+ break;
+ }
+ }
+ TDM_RETURN_VAL_IF_FAIL(voutput_info != NULL, TDM_ERROR_INVALID_PARAMETER);
+ TDM_RETURN_VAL_IF_FAIL(voutput_info->attach_buffer == NULL, TDM_ERROR_OPERATION_FAILED);
+
+ voutput_buffer = _tdm_output_get_voutput_buffer(voutput_info, buffer);
+ TDM_RETURN_VAL_IF_FAIL(voutput_buffer != NULL, TDM_ERROR_OUT_OF_MEMORY);
+
+ voutput_info->attach_buffer = voutput_buffer;
+
+ wl_tdm_voutput_send_attach_buffer(voutput_info->resource, voutput_buffer->wl_buffer);
+
+ return TDM_ERROR_NONE;
+}
+
+tdm_error
+tdm_voutput_commit_buffer(tdm_voutput *voutput)
+{
+ tdm_private_server *private_server = keep_private_server;
+ tdm_server_voutput_info *voutput_info = NULL, *vo = NULL;
+
+ TDM_RETURN_VAL_IF_FAIL(keep_private_server != NULL, TDM_ERROR_OPERATION_FAILED);
+
+ LIST_FOR_EACH_ENTRY(vo, &private_server->voutput_list, link) {
+ if (vo && vo->voutput == voutput) {
+ voutput_info = vo;
+ break;
+ }
+ }
+ TDM_RETURN_VAL_IF_FAIL(voutput_info != NULL, TDM_ERROR_INVALID_PARAMETER);
+ TDM_RETURN_VAL_IF_FAIL(voutput_info->attach_buffer != NULL, TDM_ERROR_OPERATION_FAILED);
+ TDM_RETURN_VAL_IF_FAIL(voutput_info->committing == 0, TDM_ERROR_OPERATION_FAILED);
+
+ tbm_surface_internal_ref(voutput_info->attach_buffer->buffer);
+ voutput_info->committing = 1;
+
+ wl_tdm_voutput_send_commit(voutput_info->resource);
+
+ return TDM_ERROR_NONE;
+}
+
void
tdm_voutput_cb_resource_destroy(struct wl_resource *resource)
{
tdm_server_voutput_info *voutput_info = wl_resource_get_user_data(resource);
+ tdm_server_voutput_buffer *vb = NULL;
tdm_voutput *voutput;
tdm_error ret = TDM_ERROR_NONE;
if (ret != TDM_ERROR_NONE)
TDM_ERR("_tdm_voutput_cb_destroy fail");
+ if (voutput_info->attach_buffer) {
+ tbm_surface_h buffer = voutput_info->attach_buffer->buffer;
+ tbm_surface_internal_unref(buffer);
+ voutput_info->committing = 0;
+ voutput_info->attach_buffer = NULL;
+ }
+
+ LIST_FOR_EACH_ENTRY(vb, &voutput_info->buffer_list, link) {
+ if (vb->wl_buffer)
+ wl_resource_destroy(vb->wl_buffer);
+ }
+
LIST_DEL(&voutput_info->link);
/* Do free your own resource */
voutput_info->resource = voutput_resource;
voutput_info->voutput = voutput;
voutput_info->output = output;
+ LIST_INITHEAD(&voutput_info->buffer_list);
wl_resource_set_implementation(voutput_resource,
&tdm_voutput_implementation,
projects / platform / core / uifw / libtdm.git / blobdiff