include/media_codec_queue.h

   1 /*
   2 * Copyright (c) 2011 Samsung Electronics Co., Ltd All Rights Reserved
   3 *
   4 * Licensed under the Apache License, Version 2.0 (the "License");
   5 * you may not use this file except in compliance with the License.
   6 * You may obtain a copy of the License at
   7 *
   8 * http://www.apache.org/licenses/LICENSE-2.0
   9 *
  10 * Unless required by applicable law or agreed to in writing, software
  11 * distributed under the License is distributed on an "AS IS" BASIS,
  12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13 * See the License for the specific language governing permissions and
  14 * limitations under the License.
  15 */
  16
  17 #ifndef __TIZEN_MEDIA_CODEC_QUEUE_H__
  18 #define __TIZEN_MEDIA_CODEC_QUEUE_H__
  19
  20 #include <glib.h>
  21
  22 #ifdef __cplusplus
  23 extern "C" {
  24 #endif
  25
  26 typedef struct _async_queue {
  27     GMutex mutex;
  28     GCond condition;
  29     GList *head;
  30     GList *tail;
  31     guint length;
  32     gboolean enabled;
  33 } async_queue_t;
  34
  35 typedef struct _mc_aqueue {
  36     GThread *thread;
  37     gint running;
  38     async_queue_t *input;
  39     async_queue_t *output;
  40 } mc_aqueue_t;
  41
  42 async_queue_t *mc_async_queue_new();
  43
  44 void mc_async_queue_free(async_queue_t *async_queue);
  45
  46 void mc_async_queue_push(async_queue_t *async_queue, gpointer data);
  47
  48 gpointer mc_async_queue_pop_forced (async_queue_t * async_queue);
  49
  50 gpointer mc_async_queue_pop(async_queue_t *async_queue);
  51
  52 void mc_async_queue_disable (async_queue_t *async_queue);
  53
  54 void mc_async_queue_enable (async_queue_t *async_queue);
  55
  56 void mc_async_queue_flush(async_queue_t *async_queue);
  57
  58 gboolean mc_async_queue_is_empty(async_queue_t *async_queue);
  59
  60 #ifdef __cplusplus
  61 }
  62 #endif
  63
  64 #endif /* __TIZEN_MEDIA_CODEC_QUEUE_H__ */