#define DEBUG 0
#if DEBUG
-#define TBM_TRACE() TBM_LOG("[TRACE] %s:%d surface:%p\n", __func__, __LINE__, surface_queue)
+#define TBM_QUEUE_TRACE() TBM_LOG("[QUEUE_TRACE] %s:%d surface_queue:%p\n", __func__, __LINE__, surface_queue)
#define TBM_LOCK() TBM_LOG("[LOCK] %s:%d surface:%p\n", __func__, __LINE__, surface_queue)
#define TBM_UNLOCK() TBM_LOG("[UNLOCK] %s:%d surface:%p\n", __func__, __LINE__, surface_queue)
#else
-#define TBM_TRACE()
+#define TBM_QUEUE_TRACE()
#define TBM_LOCK()
#define TBM_UNLOCK()
#endif
pthread_mutex_lock(&surface_queue->lock);
+ TBM_QUEUE_TRACE();
+
surface_queue->destroy_cb = destroy_cb;
surface_queue->destroy_cb_data = data;
pthread_mutex_lock(&surface_queue->lock);
+ TBM_QUEUE_TRACE();
+
_notify_add(&surface_queue->destory_noti, destroy_cb, data);
pthread_mutex_unlock(&surface_queue->lock);
pthread_mutex_lock(&surface_queue->lock);
+ TBM_QUEUE_TRACE();
+
_notify_remove(&surface_queue->destory_noti, destroy_cb, data);
pthread_mutex_unlock(&surface_queue->lock);
pthread_mutex_lock(&surface_queue->lock);
+ TBM_QUEUE_TRACE();
+
surface_queue->dequeuable_cb = dequeuable_cb;
surface_queue->dequeuable_cb_data = data;
pthread_mutex_lock(&surface_queue->lock);
+ TBM_QUEUE_TRACE();
+
_notify_add(&surface_queue->dequeuable_noti, dequeuable_cb, data);
pthread_mutex_unlock(&surface_queue->lock);
pthread_mutex_lock(&surface_queue->lock);
+ TBM_QUEUE_TRACE();
+
_notify_remove(&surface_queue->dequeuable_noti, dequeuable_cb, data);
pthread_mutex_unlock(&surface_queue->lock);
pthread_mutex_lock(&surface_queue->lock);
+ TBM_QUEUE_TRACE();
+
surface_queue->acquirable_cb = acquirable_cb;
surface_queue->acquirable_cb_data = data;
pthread_mutex_lock(&surface_queue->lock);
+ TBM_QUEUE_TRACE();
+
_notify_add(&surface_queue->acquirable_noti, acquirable_cb, data);
pthread_mutex_unlock(&surface_queue->lock);
pthread_mutex_lock(&surface_queue->lock);
+ TBM_QUEUE_TRACE();
+
_notify_remove(&surface_queue->acquirable_noti, acquirable_cb, data);
pthread_mutex_unlock(&surface_queue->lock);
pthread_mutex_lock(&surface_queue->lock);
+ TBM_QUEUE_TRACE();
+
surface_queue->alloc_cb = alloc_cb;
surface_queue->free_cb = free_cb;
surface_queue->alloc_cb_data = data;
{
TBM_RETURN_VAL_IF_FAIL(surface_queue != NULL, 0);
+ TBM_QUEUE_TRACE();
+
+ TBM_RETURN_VAL_IF_FAIL(surface_queue != NULL, 0);
+
return surface_queue->width;
}
int
tbm_surface_queue_get_height(tbm_surface_queue_h surface_queue)
{
+ TBM_RETURN_VAL_IF_FAIL(surface_queue != NULL, 0);
+
+ TBM_QUEUE_TRACE();
+
return surface_queue->height;
}
int
tbm_surface_queue_get_format(tbm_surface_queue_h surface_queue)
{
+ TBM_RETURN_VAL_IF_FAIL(surface_queue != NULL, 0);
+
+ TBM_QUEUE_TRACE();
+
return surface_queue->format;
}
int
tbm_surface_queue_get_size(tbm_surface_queue_h surface_queue)
{
+ TBM_RETURN_VAL_IF_FAIL(surface_queue != NULL, 0);
+
+ TBM_QUEUE_TRACE();
+
return surface_queue->queue_size;
}
pthread_mutex_lock(&surface_queue->lock);
+ TBM_QUEUE_TRACE();
+
surface_queue->reset_cb = reset_cb;
surface_queue->reset_cb_data = data;
pthread_mutex_lock(&surface_queue->lock);
+ TBM_QUEUE_TRACE();
+
_notify_add(&surface_queue->acquirable_noti, reset_cb, data);
pthread_mutex_unlock(&surface_queue->lock);
pthread_mutex_lock(&surface_queue->lock);
+ TBM_QUEUE_TRACE();
+
_notify_remove(&surface_queue->acquirable_noti, reset_cb, data);
pthread_mutex_unlock(&surface_queue->lock);
pthread_mutex_lock(&surface_queue->lock);
+ TBM_QUEUE_TRACE();
+
node = _queue_get_node(surface_queue, 0, surface, &queue_type);
if (node == NULL || queue_type != NODE_LIST) {
TBM_LOG("tbm_surface_queue_enqueue::Surface exist in free_queue or dirty_queue node:%p, queue:%d\n",
pthread_mutex_lock(&surface_queue->lock);
+ TBM_QUEUE_TRACE();
+
if (surface_queue->impl && surface_queue->impl->dequeue)
node = surface_queue->impl->dequeue(surface_queue);
else
pthread_mutex_lock(&surface_queue->lock);
+ TBM_QUEUE_TRACE();
+
if (_queue_is_empty(&surface_queue->free_queue)) {
if (surface_queue->impl && surface_queue->impl->need_attach)
surface_queue->impl->need_attach(surface_queue);
pthread_mutex_lock(&surface_queue->lock);
+ TBM_QUEUE_TRACE();
+
node = _queue_get_node(surface_queue, 0, surface, &queue_type);
if (node == NULL || queue_type != NODE_LIST) {
TBM_LOG("tbm_surface_queue_release::Surface exist in free_queue or dirty_queue node:%p, queue:%d\n",
pthread_mutex_lock(&surface_queue->lock);
+ TBM_QUEUE_TRACE();
+
if (surface_queue->impl && surface_queue->impl->acquire)
node = surface_queue->impl->acquire(surface_queue);
else
pthread_mutex_lock(&surface_queue->lock);
+ TBM_QUEUE_TRACE();
+
if (_queue_is_empty(&surface_queue->dirty_queue)) {
if (wait) {
pthread_cond_wait(&surface_queue->dirty_cond, &surface_queue->lock);
TBM_RETURN_IF_FAIL(surface_queue != NULL);
+ TBM_QUEUE_TRACE();
+
if (surface_queue->destroy_cb)
surface_queue->destroy_cb(surface_queue, surface_queue->destroy_cb_data);
TBM_RETURN_VAL_IF_FAIL(surface_queue != NULL,
TBM_SURFACE_QUEUE_ERROR_INVALID_QUEUE);
+ TBM_QUEUE_TRACE();
+
queue_node *node = NULL, *tmp = NULL;
if (width == surface_queue->width && height == surface_queue->height &&
pthread_mutex_lock(&surface_queue->lock);
+ TBM_QUEUE_TRACE();
+
/* Destory surface and Push to free_queue */
LIST_FOR_EACH_ENTRY_SAFE(node, tmp, &surface_queue->list, link) {
_queue_delete_node(surface_queue, node);
sizeof(struct _tbm_surface_queue));
TBM_RETURN_VAL_IF_FAIL(surface_queue != NULL, NULL);
+ TBM_QUEUE_TRACE();
+
tbm_queue_default *data = (tbm_queue_default *) calloc(1,
sizeof(tbm_queue_default));
if (data == NULL) {
sizeof(struct _tbm_surface_queue));
TBM_RETURN_VAL_IF_FAIL(surface_queue != NULL, NULL);
+ TBM_QUEUE_TRACE();
+
tbm_queue_sequence *data = (tbm_queue_sequence *) calloc(1,
sizeof(tbm_queue_sequence));
if (data == NULL) {