src/tdm_capture.c

   1 /**************************************************************************
   2  *
   3  * libtdm
   4  *
   5  * Copyright 2015 Samsung Electronics co., Ltd. All Rights Reserved.
   6  *
   7  * Contact: Eunchul Kim <chulspro.kim@samsung.com>,
   8  *          JinYoung Jeon <jy0.jeon@samsung.com>,
   9  *          Taeheon Kim <th908.kim@samsung.com>,
  10  *          YoungJun Cho <yj44.cho@samsung.com>,
  11  *          SooChan Lim <sc1.lim@samsung.com>,
  12  *          Boram Park <sc1.lim@samsung.com>
  13  *
  14  * Permission is hereby granted, free of charge, to any person obtaining a
  15  * copy of this software and associated documentation files (the
  16  * "Software"), to deal in the Software without restriction, including
  17  * without limitation the rights to use, copy, modify, merge, publish,
  18  * distribute, sub license, and/or sell copies of the Software, and to
  19  * permit persons to whom the Software is furnished to do so, subject to
  20  * the following conditions:
  21  *
  22  * The above copyright notice and this permission notice (including the
  23  * next paragraph) shall be included in all copies or substantial portions
  24  * of the Software.
  25  *
  26  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
  27  * OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
  28  * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NON-INFRINGEMENT.
  29  * IN NO EVENT SHALL PRECISION INSIGHT AND/OR ITS SUPPLIERS BE LIABLE FOR
  30  * ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT,
  31  * TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE
  32  * SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
  33  *
  34 **************************************************************************/
  35
  36 #ifdef HAVE_CONFIG_H
  37 #include "config.h"
  38 #endif
  39
  40 #include "tdm_private.h"
  41
  42 #define CAPTURE_FUNC_ENTRY() \
  43         tdm_func_capture *func_capture; \
  44         tdm_private_display *private_display; \
  45         tdm_private_capture *private_capture; \
  46         tdm_error ret = TDM_ERROR_NONE; \
  47         TDM_RETURN_VAL_IF_FAIL(capture != NULL, TDM_ERROR_INVALID_PARAMETER); \
  48         private_capture = (tdm_private_capture*)capture; \
  49         private_display = private_capture->private_display; \
  50         func_capture = &private_display->func_capture
  51
  52 static void
  53 _tdm_capture_print_list(struct list_head *list)
  54 {
  55         tdm_capture_private_buffer *b = NULL;
  56         char str[512], *p;
  57         int len = sizeof(str);
  58
  59         TDM_RETURN_IF_FAIL(list != NULL);
  60
  61         p = str;
  62         LIST_FOR_EACH_ENTRY(b, list, link) {
  63                 if (len > 0) {
  64                         int l = snprintf(p, len, " (%p)", b->buffer);
  65                         p += l;
  66                         len -= l;
  67                 } else
  68                         break;
  69         }
  70
  71         TDM_INFO("\t %s", str);
  72 }
  73
  74 static tdm_capture_private_buffer *
  75 _tdm_capture_find_tbm_buffer(struct list_head *list, tbm_surface_h buffer)
  76 {
  77         tdm_capture_private_buffer *b = NULL, *bb = NULL;
  78
  79         LIST_FOR_EACH_ENTRY_SAFE(b, bb, list, link) {
  80                 if (b->buffer == buffer)
  81                         return b;
  82         }
  83
  84         return NULL;
  85 }
  86
  87 static tdm_capture_private_buffer *
  88 _tdm_capture_find_buffer(struct list_head *list, tdm_capture_private_buffer *capture_buffer)
  89 {
  90         tdm_capture_private_buffer *b = NULL, *bb = NULL;
  91
  92         LIST_FOR_EACH_ENTRY_SAFE(b, bb, list, link) {
  93                 if (b == capture_buffer)
  94                         return b;
  95         }
  96
  97         return NULL;
  98 }
  99
 100 static void
 101 _tdm_capture_thread_cb_done(tdm_private_display *private_display, void *object, tdm_thread_cb_base *cb_base, void *user_data)
 102 {
 103         tdm_thread_cb_capture_done *capture_done = (tdm_thread_cb_capture_done *)cb_base;
 104         tdm_private_capture *private_capture = object;
 105         tdm_capture_private_buffer *capture_buffer = NULL, *first_entry = NULL;
 106         tbm_surface_h buffer;
 107
 108         TDM_RETURN_IF_FAIL(TDM_MUTEX_IS_LOCKED());
 109
 110         assert(private_capture->owner_tid == syscall(SYS_gettid));
 111
 112         buffer = capture_done->buffer;
 113
 114         if (tdm_debug_dump & TDM_DUMP_FLAG_CAPTURE) {
 115                 /* LCOV_EXCL_START */
 116                 char str[TDM_PATH_LEN];
 117                 static int i;
 118                 snprintf(str, TDM_PATH_LEN, "capture_%03d", i++);
 119                 tdm_helper_dump_buffer_str(buffer, tdm_debug_dump_dir, str);
 120                 /* LCOV_EXCL_STOP */
 121         }
 122
 123         if (tdm_debug_module & TDM_DEBUG_BUFFER)
 124                 TDM_INFO("capture(%p) done: %p", private_capture, buffer);
 125
 126         if (tdm_ttrace_module & TDM_TTRACE_CAPTURE) {
 127                 tbm_bo bo = tbm_surface_internal_get_bo(buffer, 0);
 128                 TDM_TRACE_ASYNC_END((intptr_t)private_capture, "[CAPTURE] %d", tbm_bo_export(bo));
 129         }
 130
 131         if (!LIST_IS_EMPTY(&private_capture->buffer_list)) {
 132                 first_entry = container_of((&private_capture->buffer_list)->next, capture_buffer, link);
 133                 if (first_entry->buffer != buffer)
 134                         TDM_ERR("buffer(%p) is skipped", first_entry->buffer);
 135         } else {
 136                 TDM_NEVER_GET_HERE();
 137         }
 138
 139         if ((capture_buffer = _tdm_capture_find_tbm_buffer(&private_capture->buffer_list, buffer))) {
 140                 LIST_DEL(&capture_buffer->link);
 141                 LIST_DELINIT(&capture_buffer->commit_link);
 142
 143                 _pthread_mutex_unlock(&private_display->lock);
 144                 if (private_capture->done_func)
 145                         private_capture->done_func(capture_buffer, buffer, private_capture->done_user_data);
 146                 tdm_buffer_unref_backend(buffer);
 147                 _pthread_mutex_lock(&private_display->lock);
 148
 149                 free(capture_buffer);
 150         }
 151 }
 152
 153 static void
 154 _tdm_capture_cb_done(tdm_capture *capture_backend, tbm_surface_h buffer, void *user_data)
 155 {
 156         tdm_private_capture *private_capture = user_data;
 157         tdm_thread_cb_capture_done capture_done;
 158         tdm_error ret;
 159
 160         TDM_RETURN_IF_FAIL(TDM_MUTEX_IS_LOCKED());
 161
 162         memset(&capture_done, 0, sizeof capture_done);
 163         capture_done.base.type = TDM_THREAD_CB_CAPTURE_DONE;
 164         capture_done.base.length = sizeof capture_done;
 165         capture_done.base.object_stamp = private_capture->stamp;
 166         capture_done.base.data = NULL;
 167         capture_done.base.sync = 0;
 168         capture_done.buffer = buffer;
 169
 170         ret = tdm_thread_cb_call(private_capture, &capture_done.base);
 171         TDM_WARNING_IF_FAIL(ret == TDM_ERROR_NONE);
 172 }
 173
 174 static void *
 175 _tdm_capture_find_object(tdm_private_display *private_display, double stamp)
 176 {
 177         tdm_private_capture *private_capture = NULL;
 178
 179         TDM_RETURN_VAL_IF_FAIL(TDM_MUTEX_IS_LOCKED(), NULL);
 180
 181         LIST_FOR_EACH_ENTRY(private_capture, &private_display->capture_list, display_link) {
 182                 if (private_capture->stamp == stamp)
 183                         return private_capture;
 184         }
 185
 186         return NULL;
 187 }
 188
 189 INTERN tdm_error
 190 tdm_capture_init(tdm_private_display *private_display)
 191 {
 192         tdm_thread_cb_set_find_func(TDM_THREAD_CB_CAPTURE_DONE, _tdm_capture_find_object);
 193
 194         return TDM_ERROR_NONE;
 195 }
 196
 197 INTERN tdm_private_capture *
 198 tdm_capture_create_output_internal(tdm_private_output *private_output,
 199                                                                    tdm_error *error)
 200 {
 201         tdm_private_display *private_display = private_output->private_display;
 202         tdm_func_output *func_output = &private_display->func_output;
 203         tdm_func_capture *func_capture = &private_display->func_capture;
 204         tdm_private_capture *private_capture = NULL;
 205         tdm_capture *capture_backend = NULL;
 206         tdm_error ret = TDM_ERROR_NONE;
 207
 208         TDM_RETURN_VAL_IF_FAIL(TDM_MUTEX_IS_LOCKED(), NULL);
 209
 210         if (!(private_display->capabilities & TDM_DISPLAY_CAPABILITY_CAPTURE)) {
 211                 /* LCOV_EXCL_START */
 212                 TDM_ERR("no capture capability");
 213                 if (error)
 214                         *error = TDM_ERROR_NO_CAPABILITY;
 215                 return NULL;
 216                 /* LCOV_EXCL_STOP */
 217         }
 218
 219         if (!(private_display->caps_capture.capabilities & TDM_CAPTURE_CAPABILITY_OUTPUT)) {
 220                 /* LCOV_EXCL_START */
 221                 TDM_ERR("no output capture capability");
 222                 if (error)
 223                         *error = TDM_ERROR_NO_CAPABILITY;
 224                 return NULL;
 225                 /* LCOV_EXCL_STOP */
 226         }
 227
 228         capture_backend = func_output->output_create_capture(
 229                                                   private_output->output_backend, &ret);
 230         if (ret != TDM_ERROR_NONE) {
 231                 /* LCOV_EXCL_START */
 232                 if (error)
 233                         *error = ret;
 234                 return NULL;
 235                 /* LCOV_EXCL_STOP */
 236         }
 237
 238         private_capture = calloc(1, sizeof(tdm_private_capture));
 239         if (!private_capture) {
 240                 /* LCOV_EXCL_START */
 241                 TDM_ERR("failed: alloc memory");
 242                 func_capture->capture_destroy(capture_backend);
 243                 if (error)
 244                         *error = TDM_ERROR_OUT_OF_MEMORY;
 245                 return NULL;
 246                 /* LCOV_EXCL_STOP */
 247         }
 248
 249         ret = tdm_thread_cb_add(private_capture, TDM_THREAD_CB_CAPTURE_DONE, NULL, _tdm_capture_thread_cb_done, NULL);
 250         if (ret != TDM_ERROR_NONE) {
 251                 TDM_ERR("capture tdm_thread_cb_add failed");
 252                 func_capture->capture_destroy(capture_backend);
 253                 free(private_capture);
 254                 if (error)
 255                         *error = ret;
 256                 return NULL;
 257         }
 258
 259         ret = func_capture->capture_set_done_handler(capture_backend, _tdm_capture_cb_done, private_capture);
 260         if (ret != TDM_ERROR_NONE) {
 261                 /* LCOV_EXCL_START */
 262                 TDM_ERR("capture(%p) set capture_done_handler failed", private_capture);
 263                 func_capture->capture_destroy(capture_backend);
 264                 free(private_capture);
 265                 if (error)
 266                         *error = ret;
 267                 return NULL;
 268                 /* LCOV_EXCL_STOP */
 269         }
 270
 271         private_capture->stamp = tdm_helper_get_time();
 272         while (_tdm_capture_find_object(private_display, private_capture->stamp))
 273                 private_capture->stamp++;
 274
 275         LIST_ADD(&private_capture->link, &private_output->capture_list);
 276         LIST_ADD(&private_capture->display_link, &private_display->capture_list);
 277
 278         private_capture->target = TDM_CAPTURE_TARGET_OUTPUT;
 279         private_capture->private_display = private_display;
 280         private_capture->private_output = private_output;
 281         private_capture->private_layer = NULL;
 282         private_capture->capture_backend = capture_backend;
 283         private_capture->owner_tid = syscall(SYS_gettid);
 284
 285         LIST_INITHEAD(&private_capture->pending_buffer_list);
 286         LIST_INITHEAD(&private_capture->buffer_list);
 287
 288         TDM_DBG("capture(%p) create", private_capture);
 289
 290         if (error)
 291                 *error = TDM_ERROR_NONE;
 292
 293         return private_capture;
 294 }
 295
 296 /* LCOV_EXCL_START */
 297 INTERN tdm_private_capture *
 298 tdm_capture_create_layer_internal(tdm_private_layer *private_layer,
 299                                                                   tdm_error *error)
 300 {
 301         tdm_private_output *private_output = private_layer->private_output;
 302         tdm_private_display *private_display = private_output->private_display;
 303         tdm_func_layer *func_layer = &private_display->func_layer;
 304         tdm_func_capture *func_capture = &private_display->func_capture;
 305         tdm_private_capture *private_capture = NULL;
 306         tdm_capture *capture_backend = NULL;
 307         tdm_error ret = TDM_ERROR_NONE;
 308
 309         TDM_RETURN_VAL_IF_FAIL(TDM_MUTEX_IS_LOCKED(), NULL);
 310
 311         if (!(private_display->capabilities & TDM_DISPLAY_CAPABILITY_CAPTURE)) {
 312                 TDM_ERR("no capture capability");
 313                 if (error)
 314                         *error = TDM_ERROR_NO_CAPABILITY;
 315                 return NULL;
 316         }
 317
 318         if (!(private_display->caps_capture.capabilities & TDM_CAPTURE_CAPABILITY_LAYER)) {
 319                 TDM_ERR("no layer capture capability");
 320                 if (error)
 321                         *error = TDM_ERROR_NO_CAPABILITY;
 322                 return NULL;
 323         }
 324
 325         capture_backend = func_layer->layer_create_capture(private_layer->layer_backend,
 326                                           &ret);
 327         if (ret != TDM_ERROR_NONE)
 328                 return NULL;
 329
 330         private_capture = calloc(1, sizeof(tdm_private_capture));
 331         if (!private_capture) {
 332                 TDM_ERR("failed: alloc memory");
 333                 func_capture->capture_destroy(capture_backend);
 334                 if (error)
 335                         *error = TDM_ERROR_OUT_OF_MEMORY;
 336                 return NULL;
 337         }
 338
 339         private_capture->stamp = tdm_helper_get_time();
 340         while (_tdm_capture_find_object(private_display, private_capture->stamp))
 341                 private_capture->stamp++;
 342
 343         LIST_ADD(&private_capture->link, &private_layer->capture_list);
 344         LIST_ADD(&private_capture->display_link, &private_display->capture_list);
 345
 346         private_capture->target = TDM_CAPTURE_TARGET_LAYER;
 347         private_capture->private_display = private_display;
 348         private_capture->private_output = private_output;
 349         private_capture->private_layer = private_layer;
 350         private_capture->capture_backend = capture_backend;
 351         private_capture->owner_tid = syscall(SYS_gettid);
 352
 353         LIST_INITHEAD(&private_capture->pending_buffer_list);
 354         LIST_INITHEAD(&private_capture->buffer_list);
 355
 356         TDM_DBG("capture(%p) create", private_capture);
 357
 358         if (error)
 359                 *error = TDM_ERROR_NONE;
 360
 361         return private_capture;
 362 }
 363 /* LCOV_EXCL_STOP */
 364
 365 INTERN void
 366 tdm_capture_destroy_internal(tdm_private_capture *private_capture)
 367 {
 368         tdm_private_display *private_display;
 369         tdm_func_capture *func_capture;
 370         tdm_capture_private_buffer *b = NULL, *bb = NULL;
 371         struct list_head clone_list;
 372
 373         TDM_RETURN_IF_FAIL(TDM_MUTEX_IS_LOCKED());
 374
 375         if (!private_capture)
 376                 return;
 377
 378         private_display = private_capture->private_display;
 379
 380         tdm_thread_cb_remove(private_capture, TDM_THREAD_CB_CAPTURE_DONE, NULL, _tdm_capture_thread_cb_done, NULL);
 381
 382         LIST_DEL(&private_capture->link);
 383         LIST_DEL(&private_capture->display_link);
 384
 385         func_capture = &private_capture->private_display->func_capture;
 386         func_capture->capture_destroy(private_capture->capture_backend);
 387
 388         if (!LIST_IS_EMPTY(&private_capture->pending_buffer_list)) {
 389                 TDM_WRN("capture(%p) not finished:", private_capture);
 390                 _tdm_capture_print_list(&private_capture->pending_buffer_list);
 391
 392                 LIST_INITHEAD(&clone_list);
 393                 LIST_FOR_EACH_ENTRY_SAFE(b, bb, &private_capture->pending_buffer_list, link) {
 394                         LIST_DEL(&b->link);
 395                         LIST_ADDTAIL(&b->link, &clone_list);
 396                 }
 397
 398                 _pthread_mutex_unlock(&private_display->lock);
 399                 LIST_FOR_EACH_ENTRY_SAFE(b, bb, &clone_list, link) {
 400                         LIST_DEL(&b->link);
 401
 402                         if (tdm_ttrace_module & TDM_TTRACE_CAPTURE) {
 403                                 tbm_bo bo = tbm_surface_internal_get_bo(b->buffer, 0);
 404                                 TDM_TRACE_ASYNC_END((intptr_t)private_capture, "[CAPTURE] %d", tbm_bo_export(bo));
 405                         }
 406
 407                         tdm_buffer_unref_backend(b->buffer);
 408                         free(b);
 409                 }
 410                 _pthread_mutex_lock(&private_display->lock);
 411         }
 412
 413         if (!LIST_IS_EMPTY(&private_capture->buffer_list)) {
 414                 TDM_WRN("capture(%p) not finished:", private_capture);
 415                 _tdm_capture_print_list(&private_capture->buffer_list);
 416
 417                 LIST_INITHEAD(&clone_list);
 418                 LIST_FOR_EACH_ENTRY_SAFE(b, bb, &private_capture->buffer_list, link) {
 419                         LIST_DEL(&b->link);
 420                         LIST_ADDTAIL(&b->link, &clone_list);
 421                 }
 422
 423                 _pthread_mutex_unlock(&private_display->lock);
 424                 LIST_FOR_EACH_ENTRY_SAFE(b, bb, &clone_list, link) {
 425                         LIST_DEL(&b->link);
 426
 427                         if (tdm_ttrace_module & TDM_TTRACE_CAPTURE) {
 428                                 tbm_bo bo = tbm_surface_internal_get_bo(b->buffer, 0);
 429                                 TDM_TRACE_ASYNC_END((intptr_t)private_capture, "[CAPTURE] %d", tbm_bo_export(bo));
 430                         }
 431
 432                         tdm_buffer_unref_backend(b->buffer);
 433                         free(b);
 434                 }
 435                 _pthread_mutex_lock(&private_display->lock);
 436         }
 437
 438         private_capture->stamp = 0;
 439         free(private_capture);
 440 }
 441
 442 EXTERN void
 443 tdm_capture_destroy(tdm_capture *capture)
 444 {
 445         tdm_private_capture *private_capture = capture;
 446         tdm_private_display *private_display;
 447
 448         if (!private_capture)
 449                 return;
 450
 451         TDM_DBG("capture(%p) destroy", private_capture);
 452
 453         private_display = private_capture->private_display;
 454
 455         _pthread_mutex_lock(&private_display->lock);
 456         tdm_capture_destroy_internal(private_capture);
 457         _pthread_mutex_unlock(&private_display->lock);
 458 }
 459
 460 EXTERN tdm_error
 461 tdm_capture_set_info(tdm_capture *capture, tdm_info_capture *info)
 462 {
 463         CAPTURE_FUNC_ENTRY();
 464
 465         TDM_RETURN_VAL_IF_FAIL(info != NULL, TDM_ERROR_INVALID_PARAMETER);
 466         TDM_RETURN_VAL_IF_FAIL(info->type != 0, TDM_ERROR_INVALID_PARAMETER);
 467
 468         _pthread_mutex_lock(&private_display->lock);
 469
 470         if (!func_capture->capture_set_info) {
 471                 /* LCOV_EXCL_START */
 472                 _pthread_mutex_unlock(&private_display->lock);
 473                 TDM_DBG("failed: not implemented!!");
 474                 return TDM_ERROR_NOT_IMPLEMENTED;
 475                 /* LCOV_EXCL_STOP */
 476         }
 477
 478         if (info->type == TDM_CAPTURE_TYPE_STREAM && info->frequency == 0) {
 479                 tdm_private_output *private_output = private_capture->private_output;
 480                 info->frequency = private_output->current_mode->vrefresh;
 481         }
 482
 483         TDM_INFO("capture(%p) info: dst(%ux%u %u,%u %ux%u %c%c%c%c) trans(%d) type(%d) freq(%d) flags(%x)",
 484                          private_capture,
 485                          info->dst_config.size.h, info->dst_config.size.v,
 486                          info->dst_config.pos.x, info->dst_config.pos.y,
 487                          info->dst_config.pos.w, info->dst_config.pos.h,
 488                          FOURCC_STR(info->dst_config.format),
 489                          info->transform, info->type, info->frequency, info->flags);
 490
 491         ret = func_capture->capture_set_info(private_capture->capture_backend, info);
 492         TDM_WARNING_IF_FAIL(ret == TDM_ERROR_NONE);
 493
 494         private_capture->info = *info;
 495
 496         _pthread_mutex_unlock(&private_display->lock);
 497
 498         return ret;
 499 }
 500
 501 EXTERN tdm_error
 502 tdm_capture_set_done_handler(tdm_capture *capture, tdm_capture_done_handler func, void *user_data)
 503 {
 504         tdm_private_display *private_display;
 505         tdm_private_capture *private_capture;
 506         tdm_error ret = TDM_ERROR_NONE;
 507
 508         TDM_RETURN_VAL_IF_FAIL(capture != NULL, TDM_ERROR_INVALID_PARAMETER);
 509
 510         private_capture = (tdm_private_capture*)capture;
 511         private_display = private_capture->private_display;
 512
 513         TDM_RETURN_VAL_IF_FAIL(func != NULL, TDM_ERROR_INVALID_PARAMETER);
 514
 515         _pthread_mutex_lock(&private_display->lock);
 516
 517         private_capture->done_func = func;
 518         private_capture->done_user_data = user_data;
 519
 520         _pthread_mutex_unlock(&private_display->lock);
 521
 522         return ret;
 523 }
 524
 525 EXTERN tdm_error
 526 tdm_capture_attach(tdm_capture *capture, tbm_surface_h buffer)
 527 {
 528         tdm_capture_private_buffer *capture_buffer;
 529
 530         CAPTURE_FUNC_ENTRY();
 531
 532         TDM_RETURN_VAL_IF_FAIL(buffer != NULL, TDM_ERROR_INVALID_PARAMETER);
 533
 534         _pthread_mutex_lock(&private_display->lock);
 535
 536         if (!func_capture->capture_attach) {
 537                 /* LCOV_EXCL_START */
 538                 _pthread_mutex_unlock(&private_display->lock);
 539                 TDM_DBG("failed: not implemented!!");
 540                 return TDM_ERROR_NOT_IMPLEMENTED;
 541                 /* LCOV_EXCL_STOP */
 542         }
 543
 544         if (tdm_display_check_module_abi(private_display, 1, 2) &&
 545                 private_display->caps_capture.max_attach_count > 0) {
 546                 /* LCOV_EXCL_START */
 547                 int length = LIST_LENGTH(&private_capture->pending_buffer_list) +
 548                                          LIST_LENGTH(&private_capture->buffer_list);
 549                 if (length >= private_display->caps_capture.max_attach_count) {
 550                         _pthread_mutex_unlock(&private_display->lock);
 551                         TDM_DBG("failed: too many attached!! max_attach_count(%d)",
 552                                         private_display->caps_capture.max_attach_count);
 553                         return TDM_ERROR_BAD_REQUEST;
 554                 }
 555                 /* LCOV_EXCL_STOP */
 556         }
 557
 558         capture_buffer = calloc(1, sizeof * capture_buffer);
 559         if (!capture_buffer) {
 560                 /* LCOV_EXCL_START */
 561                 _pthread_mutex_unlock(&private_display->lock);
 562                 TDM_ERR("alloc failed");
 563                 return TDM_ERROR_OUT_OF_MEMORY;
 564                 /* LCOV_EXCL_STOP */
 565         }
 566
 567         ret = func_capture->capture_attach(private_capture->capture_backend, buffer);
 568         TDM_WARNING_IF_FAIL(ret == TDM_ERROR_NONE);
 569
 570         if (ret != TDM_ERROR_NONE) {
 571                 /* LCOV_EXCL_START */
 572                 free(capture_buffer);
 573                 _pthread_mutex_unlock(&private_display->lock);
 574                 TDM_ERR("attach failed");
 575                 return ret;
 576                 /* LCOV_EXCL_STOP */
 577         }
 578
 579         LIST_ADDTAIL(&capture_buffer->link, &private_capture->pending_buffer_list);
 580         capture_buffer->buffer = tdm_buffer_ref_backend(buffer);
 581
 582         if (tdm_debug_module & TDM_DEBUG_BUFFER) {
 583                 TDM_INFO("capture(%p) attached:", private_capture);
 584                 _tdm_capture_print_list(&private_capture->buffer_list);
 585         }
 586
 587         if (tdm_ttrace_module & TDM_TTRACE_CAPTURE) {
 588                 tbm_bo bo = tbm_surface_internal_get_bo(buffer, 0);
 589                 TDM_TRACE_ASYNC_BEGIN((intptr_t)capture, "[CAPTURE] %d", tbm_bo_export(bo));
 590         }
 591
 592         _pthread_mutex_unlock(&private_display->lock);
 593
 594         return ret;
 595 }
 596
 597 EXTERN tdm_error
 598 tdm_capture_commit(tdm_capture *capture)
 599 {
 600         tdm_capture_private_buffer *b = NULL, *bb = NULL;
 601         tdm_private_output *private_output;
 602         struct list_head commit_buffer_list;
 603
 604         CAPTURE_FUNC_ENTRY();
 605
 606         _pthread_mutex_lock(&private_display->lock);
 607
 608         private_output = private_capture->private_output;
 609
 610         /* TODO: possible when standby mode? can't decide it yet. no scenario. */
 611         if (TDM_OUTPUT_DPMS_VSYNC_IS_OFF(private_output->current_dpms_value)) {
 612                 TDM_ERR("output(%d) dpms: %s", private_output->pipe,
 613                                 tdm_dpms_str(private_output->current_dpms_value));
 614                 _pthread_mutex_unlock(&private_display->lock);
 615                 return TDM_ERROR_BAD_REQUEST;
 616         }
 617
 618         if (!func_capture->capture_commit) {
 619                 /* LCOV_EXCL_START */
 620                 _pthread_mutex_unlock(&private_display->lock);
 621                 TDM_DBG("failed: not implemented!!");
 622                 return TDM_ERROR_NOT_IMPLEMENTED;
 623                 /* LCOV_EXCL_STOP */
 624         }
 625
 626         LIST_INITHEAD(&commit_buffer_list);
 627
 628         LIST_FOR_EACH_ENTRY_SAFE(b, bb, &private_capture->pending_buffer_list, link) {
 629                 LIST_DEL(&b->link);
 630                 LIST_ADDTAIL(&b->link, &private_capture->buffer_list);
 631                 LIST_ADDTAIL(&b->commit_link, &commit_buffer_list);
 632         }
 633
 634         ret = func_capture->capture_commit(private_capture->capture_backend);
 635         TDM_WARNING_IF_FAIL(ret == TDM_ERROR_NONE);
 636
 637         LIST_FOR_EACH_ENTRY_SAFE(b, bb, &commit_buffer_list, commit_link) {
 638                 LIST_DELINIT(&b->commit_link);
 639
 640                 if (!_tdm_capture_find_buffer(&private_capture->buffer_list, b))
 641                         continue;
 642
 643                 if (ret != TDM_ERROR_NONE) {
 644                         /* LCOV_EXCL_START */
 645                         /* Not to call the user release handler when failed.
 646                          * Do we have to call this function here really?
 647                          * User better use set_done_handler to know when pp is done. Using
 648                          * buffer_release_handler is not good.
 649                          */
 650                         tdm_buffer_remove_release_handler_internal(b->buffer);
 651
 652                         _pthread_mutex_unlock(&private_display->lock);
 653                         tdm_buffer_unref_backend(b->buffer);
 654                         _pthread_mutex_lock(&private_display->lock);
 655                         LIST_DEL(&b->link);
 656
 657                         free(b);
 658                         /* LCOV_EXCL_STOP */
 659                 }
 660         }
 661
 662         _pthread_mutex_unlock(&private_display->lock);
 663
 664         return ret;
 665 }