summaryrefslogtreecommitdiff
path: root/plugins
diff options
context:
space:
mode:
authorEdward Hervey <bilboed@bilboed.com>2007-01-22 16:00:39 +0000
committerEdward Hervey <bilboed@bilboed.com>2007-01-22 16:00:39 +0000
commitbc3baaa7c442eb2e8b5f2d1e70b7d440c3fbbe89 (patch)
treebde83f2743f9f1a88582ffec18e7985da7caca81 /plugins
parent7c4dc118f694e52f9fbb6e08cd3dddff7635b148 (diff)
downloadgstreamer-bc3baaa7c442eb2e8b5f2d1e70b7d440c3fbbe89.tar.gz
plugins/elements/gstmultiqueue.c: Remove previous hack of unsetting the flushing flag for the source pad instead of a...
Original commit message from CVS: * plugins/elements/gstmultiqueue.c: (gst_multi_queue_src_activate_push), (gst_single_queue_new): Remove previous hack of unsetting the flushing flag for the source pad instead of activating it. Instead, fix the source pad activate function so that it no longer depends on having a parent set or not.
Diffstat (limited to 'plugins')
-rw-r--r--plugins/elements/gstmultiqueue.c10
1 files changed, 3 insertions, 7 deletions
diff --git a/plugins/elements/gstmultiqueue.c b/plugins/elements/gstmultiqueue.c
index dda0574009..a7987d6c3a 100644
--- a/plugins/elements/gstmultiqueue.c
+++ b/plugins/elements/gstmultiqueue.c
@@ -767,7 +767,7 @@ gst_multi_queue_src_activate_push (GstPad * pad, gboolean active)
gboolean result = FALSE;
sq = (GstSingleQueue *) gst_pad_get_element_private (pad);
- mq = (GstMultiQueue *) gst_pad_get_parent (pad);
+ mq = sq->mqueue;
GST_LOG ("SingleQueue %d", sq->id);
@@ -793,7 +793,6 @@ gst_multi_queue_src_activate_push (GstPad * pad, gboolean active)
gst_data_queue_set_flushing (sq->queue, FALSE);
}
- gst_object_unref (mq);
return result;
}
@@ -1032,14 +1031,11 @@ gst_single_queue_new (GstMultiQueue * mqueue)
gst_pad_set_element_private (sq->sinkpad, (gpointer) sq);
gst_pad_set_element_private (sq->srcpad, (gpointer) sq);
- gst_pad_set_active (sq->sinkpad, TRUE);
- gst_element_add_pad (GST_ELEMENT (mqueue), sq->sinkpad);
-
- GST_OBJECT_FLAG_UNSET (sq->srcpad, GST_PAD_FLUSHING);
+ gst_pad_set_active (sq->srcpad, TRUE);
gst_element_add_pad (GST_ELEMENT (mqueue), sq->srcpad);
- gst_pad_set_active (sq->srcpad, TRUE);
gst_pad_set_active (sq->sinkpad, TRUE);
+ gst_element_add_pad (GST_ELEMENT (mqueue), sq->sinkpad);
GST_DEBUG_OBJECT (mqueue, "GstSingleQueue [%d] created and pads added",
sq->id);