mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-02-17 03:35:21 +00:00
Code Issues 1 Projects Releases Wiki Activity

multiqueue: Simplify gst_multi_queue_iterate_internal_links

Browse source 
We don't need to obtain the mutex to ensure that `sq` is non-NULL. `sq`
is assigned immediately after the pads are created and not destroyed
until the pads are finalized.

Use the pad direction to determine which internal peer we need.

Part-of: <https://gitlab.freedesktop.org/gstreamer/gstreamer/-/merge_requests/888>
This commit is contained in:
Jan Alexander Steffens (heftig) 2021-05-06 14:07:35 +02:00 committed by GStreamer Marge Bot
parent 53c145a158
commit cd827e790a
1 changed files with 18 additions and 29 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

47
subprojects/gstreamer/plugins/elements/gstmultiqueue.c
View file

@ -1147,42 +1147,31 @@ gst_multi_queue_get_property (GObject * object, guint prop_id,
static GstIterator *
gst_multi_queue_iterate_internal_links (GstPad * pad, GstObject * parent)
{
GstSingleQueue *sq = GST_MULTIQUEUE_PAD (pad)->sq;
GstIterator *it = NULL;
GstPad *opad, *sinkpad, *srcpad;
GstSingleQueue *squeue;
GstMultiQueue *mq = GST_MULTI_QUEUE (parent);
GValue val = { 0, };
GstPad *opad;
GST_MULTI_QUEUE_MUTEX_LOCK (mq);
squeue = GST_MULTIQUEUE_PAD (pad)->sq;
if (!squeue)
goto out;
switch (GST_PAD_DIRECTION (pad)) {
case GST_PAD_SRC:
opad = g_weak_ref_get (&sq->sinkpad);
break;
srcpad = g_weak_ref_get (&squeue->srcpad);
sinkpad = g_weak_ref_get (&squeue->sinkpad);
if (sinkpad == pad && srcpad) {
opad = srcpad;
gst_clear_object (&sinkpad);
case GST_PAD_SINK:
opad = g_weak_ref_get (&sq->srcpad);
break;
} else if (srcpad == pad && sinkpad) {
opad = sinkpad;
gst_clear_object (&srcpad);
} else {
gst_clear_object (&srcpad);
gst_clear_object (&sinkpad);
goto out;
default:
g_return_val_if_reached (NULL);
}
g_value_init (&val, GST_TYPE_PAD);
g_value_set_object (&val, opad);
it = gst_iterator_new_single (GST_TYPE_PAD, &val);
g_value_unset (&val);
if (opad) {
GValue val = G_VALUE_INIT;
gst_object_unref (opad);
out:
GST_MULTI_QUEUE_MUTEX_UNLOCK (mq);
g_value_init (&val, GST_TYPE_PAD);
g_value_take_object (&val, opad);
it = gst_iterator_new_single (GST_TYPE_PAD, &val);
g_value_unset (&val);
}
return it;
}