summary | shortlog | log | commit | commitdiff | tree
raw | patch | inline | side by side (parent: 2a4fca2)
raw | patch | inline | side by side (parent: 2a4fca2)
author | Tim-Philipp Müller <tim.muller@collabora.co.uk> | |
Thu, 3 Nov 2011 22:58:50 +0000 (22:58 +0000) | ||
committer | Tim-Philipp Müller <tim.muller@collabora.co.uk> | |
Thu, 3 Nov 2011 22:58:50 +0000 (22:58 +0000) |
Because we can.
gst/gstbin.c | patch | blob | history |
diff --git a/gst/gstbin.c b/gst/gstbin.c
index bdf01a7b4fe1f386bef88b1966b9bc457545783c..6a59354b011639a967910de15d0f2948e36e7053 100644 (file)
--- a/gst/gstbin.c
+++ b/gst/gstbin.c
typedef struct _GstBinSortIterator
{
GstIterator it;
- GQueue *queue; /* elements queued for state change */
+ GQueue queue; /* elements queued for state change */
GstBin *bin; /* bin we iterate */
gint mode; /* adding or removing dependency */
GstElement *best; /* next element with least dependencies */
GST_DEBUG_OBJECT (bit->bin, "adding '%s' to queue",
GST_ELEMENT_NAME (element));
gst_object_ref (element);
- g_queue_push_tail (bit->queue, element);
+ g_queue_push_tail (&bit->queue, element);
HASH_SET_DEGREE (bit, element, -1);
}
{
GList *find;
- if ((find = g_queue_find (bit->queue, element))) {
+ if ((find = g_queue_find (&bit->queue, element))) {
GST_DEBUG_OBJECT (bit->bin, "removing '%s' from queue",
GST_ELEMENT_NAME (element));
- g_queue_delete_link (bit->queue, find);
+ g_queue_delete_link (&bit->queue, find);
gst_object_unref (element);
} else {
GST_DEBUG_OBJECT (bit->bin, "unable to remove '%s' from queue",
GstBin *bin = bit->bin;
/* empty queue, we have to find a next best element */
- if (g_queue_is_empty (bit->queue)) {
+ if (g_queue_is_empty (&bit->queue)) {
GstElement *best;
bit->best = NULL;
}
} else {
/* everything added to the queue got reffed */
- *result = g_queue_pop_head (bit->queue);
+ *result = g_queue_pop_head (&bit->queue);
}
GST_DEBUG_OBJECT (bin, "queue head gives %s", GST_ELEMENT_NAME (*result));
GST_DEBUG_OBJECT (bin, "resync");
bit->dirty = FALSE;
- clear_queue (bit->queue);
+ clear_queue (&bit->queue);
/* reset degrees */
g_list_foreach (bin->children, (GFunc) reset_degree, bit);
/* calc degrees, incrementing */
GstBin *bin = bit->bin;
GST_DEBUG_OBJECT (bin, "free");
- clear_queue (bit->queue);
- g_queue_free (bit->queue);
+ clear_queue (&bit->queue);
g_hash_table_destroy (bit->hash);
gst_object_unref (bin);
g_free (bit);
(GstIteratorItemFunction) NULL,
(GstIteratorResyncFunction) gst_bin_sort_iterator_resync,
(GstIteratorFreeFunction) gst_bin_sort_iterator_free);
- result->queue = g_queue_new ();
+ g_queue_init (&result->queue);
result->hash = g_hash_table_new (NULL, NULL);
gst_object_ref (bin);
result->bin = bin;