virtual: fix buffer management error
[platform/core/uifw/libtdm.git] / src / tdm_server.c
index b99980b..09c6e3c 100644 (file)
@@ -37,6 +37,8 @@
 #include "config.h"
 #endif
 
+#define WL_HIDE_DEPRECATED
+
 #include <tdm-server-protocol.h>
 
 #include "tdm_private.h"
@@ -66,6 +68,12 @@ typedef struct _tdm_server_output_info {
        unsigned int watch_output_changes;
 } tdm_server_output_info;
 
+typedef struct _tdm_server_voutput_buffer {
+       struct list_head link;
+       struct wl_resource *wl_buffer;
+       tbm_surface_h buffer;
+} tdm_server_voutput_buffer;
+
 typedef struct _tdm_server_voutput_info {
        struct list_head link;
        tdm_private_server *private_server;
@@ -79,14 +87,13 @@ typedef struct _tdm_server_voutput_info {
                int count;
                tdm_output_mode *modes;
        } available_modes;
-       struct
-       {
-               int count;
-               tbm_format *formats;
-       } available_formats;
 
        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 {
@@ -708,22 +715,6 @@ _tdm_server_cb_create_output(struct wl_client *client, struct wl_resource *resou
 
 static void _tdm_voutput_cb_destroy(struct wl_client *client, struct wl_resource *resource)
 {
-       tdm_server_voutput_info *voutput_info;
-       tdm_private_server *private_server;
-       tdm_output *output;
-       tdm_error ret = TDM_ERROR_NONE;
-
-       voutput_info = wl_resource_get_user_data(resource);
-
-       private_server = voutput_info->private_server;
-       output = voutput_info->output;
-
-       if (output)
-               ret = tdm_display_destroy_output(private_server->private_loop->dpy, output);
-
-       if (ret != TDM_ERROR_NONE)
-               TDM_ERR("_tdm_voutput_cb_destroy fail");
-
        wl_resource_destroy(resource);
 }
 
@@ -754,31 +745,6 @@ _tdm_voutput_cb_set_available_modes(struct wl_client *client,
 }
 
 static void
-_tdm_voutput_cb_set_available_formats(struct wl_client *client,
-                                                                         struct wl_resource *resource,
-                                                                         struct wl_array *formats)
-{
-       tdm_server_voutput_info *voutput_info;
-       tbm_format *f;
-       int count = 0, i = 0;
-
-       voutput_info = wl_resource_get_user_data(resource);
-
-       voutput_info->available_formats.count = 0;
-       if (voutput_info->available_formats.formats)
-               free(voutput_info->available_formats.formats);
-
-       wl_array_for_each(f, formats)
-               count++;
-
-       voutput_info->available_formats.formats = malloc(count * sizeof(tbm_format));
-       voutput_info->available_formats.count = count;
-
-       wl_array_for_each(f, formats)
-               voutput_info->available_formats.formats[i++] = *f;
-}
-
-static void
 _tdm_voutput_cb_set_physical_size(struct wl_client *client, struct wl_resource *resource,
                                                                  unsigned int mmwidth, unsigned int mmheight)
 {
@@ -825,6 +791,7 @@ static void
 _tdm_voutput_cb_commit_done(struct wl_client *client, struct wl_resource *resource)
 {
        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)
@@ -832,25 +799,313 @@ _tdm_voutput_cb_commit_done(struct wl_client *client, struct wl_resource *resour
                // handle error
                return;
        }
+
+       buffer = voutput_info->attach_buffer->buffer;
+       tbm_surface_internal_unref(buffer);
+
+       voutput_info->committing = 0;
+       voutput_info->attach_buffer = NULL;
+
+       tdm_output_commit_done(voutput_info->output, buffer);
 }
 
 static const struct wl_tdm_voutput_interface tdm_voutput_implementation = {
        _tdm_voutput_cb_destroy,
        _tdm_voutput_cb_set_available_modes,
-       _tdm_voutput_cb_set_available_formats,
        _tdm_voutput_cb_set_physical_size,
        _tdm_voutput_cb_connect,
        _tdm_voutput_cb_disconnect,
        _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;
+}
+
+INTERN tdm_error
+tdm_output_send_buffer(tdm_output *output, 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->output == output) {
+                       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;
+}
+
+INTERN tdm_error
+tdm_output_commit_buffer(tdm_output *output)
+{
+       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->output == output) {
+                       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);
+
+       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;
+       tdm_private_server *private_server;
+       tdm_output *output;
+       tdm_error ret = TDM_ERROR_NONE;
 
        TDM_RETURN_IF_FAIL(voutput_info != NULL);
 
+       private_server = voutput_info->private_server;
+       output = voutput_info->output;
+
+       if (output)
+               ret = tdm_display_destroy_output(private_server->private_loop->dpy, output);
+       if (ret != TDM_ERROR_NONE)
+               TDM_ERR("_tdm_voutput_cb_destroy fail");
+
+       LIST_FOR_EACH_ENTRY(vb, &voutput_info->buffer_list, link) {
+               if (!vb) continue;
+
+               if (vb->wl_buffer)
+                       wl_resource_destroy(vb->wl_buffer);
+       }
+
        LIST_DEL(&voutput_info->link);
 
        /* Do free your own resource */
@@ -912,6 +1167,7 @@ _tdm_server_cb_create_virtual_output(struct wl_client *client, struct wl_resourc
        voutput_info->resource = voutput_resource;
        voutput_info->output = output;
        LIST_INITHEAD(&voutput_info->output_list);
+       LIST_INITHEAD(&voutput_info->buffer_list);
 
        wl_resource_set_implementation(voutput_resource,
                                                                   &tdm_voutput_implementation,
@@ -1078,7 +1334,7 @@ INTERN void
 tdm_server_deinit(tdm_private_loop *private_loop)
 {
        tdm_server_output_info *o = NULL, *oo = NULL;
-//     tdm_server_voutput_info *vo = NULL, *voo = NULL;
+       tdm_server_voutput_info *vo = NULL, *voo = NULL;
        tdm_server_wait_info *w = NULL, *ww = NULL;
        tdm_server_client_info *c = NULL, *cc = NULL;
        tdm_private_server *private_server;
@@ -1095,11 +1351,11 @@ tdm_server_deinit(tdm_private_loop *private_loop)
        LIST_FOR_EACH_ENTRY_SAFE(o, oo, &private_server->output_list, link) {
                wl_resource_destroy(o->resource);
        }
-#if 0
+
        LIST_FOR_EACH_ENTRY_SAFE(vo, voo, &private_server->voutput_list, link) {
                wl_resource_destroy(vo->resource);
        }
-#endif
+
        LIST_FOR_EACH_ENTRY_SAFE(c, cc, &client_list, link) {
                wl_resource_destroy(c->resource);
        }