2 * Copyright (C) 2006 Edward Hervey <edward@fluendo.com>
6 * This library is free software; you can redistribute it and/or
7 * modify it under the terms of the GNU Library General Public
8 * License as published by the Free Software Foundation; either
9 * version 2 of the License, or (at your option) any later version.
11 * This library is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14 * Library General Public License for more details.
16 * You should have received a copy of the GNU Library General Public
17 * License along with this library; if not, write to the
18 * Free Software Foundation, Inc., 51 Franklin St, Fifth Floor,
19 * Boston, MA 02110-1301, USA.
23 #ifndef __GST_DATA_QUEUE_H__
24 #define __GST_DATA_QUEUE_H__
27 #include <gst/base/base-prelude.h>
30 #define GST_TYPE_DATA_QUEUE \
31 (gst_data_queue_get_type())
32 #define GST_DATA_QUEUE(obj) \
33 (G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_DATA_QUEUE,GstDataQueue))
34 #define GST_DATA_QUEUE_CLASS(klass) \
35 (G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_DATA_QUEUE,GstDataQueueClass))
36 #define GST_IS_DATA_QUEUE(obj) \
37 (G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_DATA_QUEUE))
38 #define GST_IS_DATA_QUEUE_CLASS(klass) \
39 (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_DATA_QUEUE))
41 typedef struct _GstDataQueue GstDataQueue;
42 typedef struct _GstDataQueueClass GstDataQueueClass;
43 typedef struct _GstDataQueueSize GstDataQueueSize;
44 typedef struct _GstDataQueueItem GstDataQueueItem;
45 typedef struct _GstDataQueuePrivate GstDataQueuePrivate;
48 * GstDataQueueItem: (skip)
49 * @object: the #GstMiniObject to queue.
50 * @size: the size in bytes of the miniobject.
51 * @duration: the duration in #GstClockTime of the miniobject. Can not be
52 * %GST_CLOCK_TIME_NONE.
53 * @visible: %TRUE if @object should be considered as a visible object.
54 * @destroy: The #GDestroyNotify function to use to free the #GstDataQueueItem.
55 * This function should also drop the reference to @object the owner of the
56 * #GstDataQueueItem is assumed to hold.
58 * Structure used by #GstDataQueue. You can supply a different structure, as
59 * long as the top of the structure is identical to this structure.
62 struct _GstDataQueueItem
64 GstMiniObject *object;
69 /* user supplied destroy function */
70 GDestroyNotify destroy;
73 gpointer _gst_reserved[GST_PADDING];
77 * GstDataQueueSize: (skip)
78 * @visible: number of buffers
79 * @bytes: number of bytes
80 * @time: amount of time
82 * Structure describing the size of a queue.
84 struct _GstDataQueueSize
92 * GstDataQueueCheckFullFunction: (skip)
93 * @queue: a #GstDataQueue.
94 * @visible: The number of visible items currently in the queue.
95 * @bytes: The amount of bytes currently in the queue.
96 * @time: The accumulated duration of the items currently in the queue.
97 * @checkdata: The #gpointer registered when the #GstDataQueue was created.
99 * The prototype of the function used to inform the queue that it should be
100 * considered as full.
102 * Returns: %TRUE if the queue should be considered full.
104 typedef gboolean (*GstDataQueueCheckFullFunction) (GstDataQueue * queue,
105 guint visible, guint bytes, guint64 time, gpointer checkdata);
107 typedef void (*GstDataQueueFullCallback) (GstDataQueue * queue, gpointer checkdata);
108 typedef void (*GstDataQueueEmptyCallback) (GstDataQueue * queue, gpointer checkdata);
112 * @object: the parent structure
114 * Opaque #GstDataQueue structure.
121 GstDataQueuePrivate *priv;
122 gpointer _gst_reserved[GST_PADDING];
128 struct _GstDataQueueClass
130 GObjectClass parent_class;
133 void (*empty) (GstDataQueue * queue);
134 void (*full) (GstDataQueue * queue);
136 gpointer _gst_reserved[GST_PADDING];
140 GType gst_data_queue_get_type (void);
143 GstDataQueue * gst_data_queue_new (GstDataQueueCheckFullFunction checkfull,
144 GstDataQueueFullCallback fullcallback,
145 GstDataQueueEmptyCallback emptycallback,
146 gpointer checkdata) G_GNUC_MALLOC;
148 gboolean gst_data_queue_push (GstDataQueue * queue, GstDataQueueItem * item);
151 gboolean gst_data_queue_push_force (GstDataQueue * queue, GstDataQueueItem * item);
154 gboolean gst_data_queue_pop (GstDataQueue * queue, GstDataQueueItem ** item);
157 gboolean gst_data_queue_peek (GstDataQueue * queue, GstDataQueueItem ** item);
160 void gst_data_queue_flush (GstDataQueue * queue);
163 void gst_data_queue_set_flushing (GstDataQueue * queue, gboolean flushing);
166 gboolean gst_data_queue_drop_head (GstDataQueue * queue, GType type);
169 gboolean gst_data_queue_is_full (GstDataQueue * queue);
172 gboolean gst_data_queue_is_empty (GstDataQueue * queue);
175 void gst_data_queue_get_level (GstDataQueue * queue, GstDataQueueSize *level);
178 void gst_data_queue_limits_changed (GstDataQueue * queue);
180 #ifdef G_DEFINE_AUTOPTR_CLEANUP_FUNC
181 G_DEFINE_AUTOPTR_CLEANUP_FUNC(GstDataQueue, gst_object_unref)
186 #endif /* __GST_DATA_QUEUE_H__ */