mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-05-17 16:02:49 +00:00
Code Issues Projects Releases Wiki Activity

decodebin3: minor refactoring to identify selected stream

Browse source
This commit is contained in:
Edward Hervey 2024-04-08 09:34:22 +02:00
parent 6194fdbe76
commit 0a10443432
1 changed files with 12 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
subprojects/gst-plugins-base/gst/playback/gstdecodebin3.c
View file

@ -2291,6 +2291,12 @@ stream_is_active (GstDecodebin3 * dbin, const gchar * stream_id)
return FALSE;
}
/* Called with SELECTION_LOCK */
static gboolean
stream_is_requested (GstDecodebin3 * dbin, const gchar * stream_id)
{
return stream_in_list (dbin->requested_selection, stream_id) != NULL;
}
static void
update_requested_selection (GstDecodebin3 * dbin)
{
@ -2328,8 +2334,7 @@ update_requested_selection (GstDecodebin3 * dbin)
if (request == -1)
all_user_selected = FALSE;
if (request == 1 || (request == -1
&& (stream_in_list (dbin->requested_selection, sid)
if (request == 1 || (request == -1 && (stream_is_requested (dbin, sid)
|| stream_is_active (dbin, sid)))) {
GstStreamType curtype = gst_stream_get_stream_type (stream);
if (request == 1)
@ -2827,8 +2832,7 @@ find_free_compatible_output (GstDecodebin3 * dbin, GstStream * stream)
for (tmp = dbin->output_streams; tmp; tmp = tmp->next) {
DecodebinOutputStream *output = (DecodebinOutputStream *) tmp->data;
if (output->type == stype && output->slot && output->slot->active_stream) {
if (!stream_in_list (dbin->requested_selection,
(gchar *) output->slot->active_stream_id)) {
if (!stream_is_requested (dbin, output->slot->active_stream_id)) {
return output;
}
}
@ -2944,7 +2948,9 @@ mq_slot_get_or_create_output (MultiQueueSlot * slot)
/* 3. In default mode check if we should expose */
id_in_list = (gchar *) stream_in_list (dbin->requested_selection, stream_id);
if (!id_in_list && !dbin->upstream_handles_selection) {
/* If the stream is not requested, bail out */
if (!stream_is_requested (dbin, stream_id)
&& !dbin->upstream_handles_selection) {
GST_DEBUG_OBJECT (slot->src_pad, "Not selected, not creating any output");
return NULL;
}
@ -3927,11 +3933,10 @@ mq_slot_reassign (MultiQueueSlot * slot)
return;
}
sid = slot->active_stream_id;
GST_DEBUG_OBJECT (slot->src_pad, "stream: %s", slot->active_stream_id);
/* Recheck whether this stream is still in the list of streams to deactivate */
if (stream_in_list (dbin->requested_selection, sid)) {
if (stream_is_requested (dbin, slot->active_stream_id)) {
/* Stream is in the list of requested streams, don't remove */
SELECTION_UNLOCK (dbin);
GST_DEBUG_OBJECT (slot->src_pad,