mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-04-26 04:46:13 +00:00
Code Issues 1 Projects Releases Wiki Activity

splitmuxsrc: Improve not-linked handling.

Browse source 
Don't report not-linked unless all pads have
returned not-linked.
This commit is contained in:
Jan Schmidt 2018-02-16 01:49:57 +11:00
parent fea8aadcf1
commit d61066e6b5
2 changed files with 34 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

33
gst/multifile/gstsplitmuxsrc.c
View file

@ -259,6 +259,7 @@ gst_splitmux_src_dispose (GObject * object)
gst_element_remove_pad (GST_ELEMENT (splitmux), pad); gst_element_remove_pad (GST_ELEMENT (splitmux), pad);
} }
g_list_free (splitmux->pads); g_list_free (splitmux->pads);
splitmux->n_pads = 0;
splitmux->pads = NULL; splitmux->pads = NULL;
SPLITMUX_SRC_PADS_UNLOCK (splitmux); SPLITMUX_SRC_PADS_UNLOCK (splitmux);
@ -522,6 +523,22 @@ gst_splitmux_handle_buffer (GstSplitMuxSrc * splitmux,
return ret; return ret;
} }
static guint
count_not_linked (GstSplitMuxSrc * splitmux)
{
GList *cur;
guint ret = 0;
for (cur = g_list_first (splitmux->pads);
cur != NULL; cur = g_list_next (cur)) {
SplitMuxSrcPad *splitpad = (SplitMuxSrcPad *) (cur->data);
if (GST_PAD_LAST_FLOW_RETURN (splitpad) == GST_FLOW_NOT_LINKED)
ret++;
}
return ret;
}
static void static void
gst_splitmux_pad_loop (GstPad * pad) gst_splitmux_pad_loop (GstPad * pad)
{ {
@ -562,8 +579,21 @@ gst_splitmux_pad_loop (GstPad * pad)
/* Stop immediately on error or flushing */ /* Stop immediately on error or flushing */
GST_INFO_OBJECT (splitpad, "Stopping due to pad_push() result %d", ret); GST_INFO_OBJECT (splitpad, "Stopping due to pad_push() result %d", ret);
gst_pad_pause_task (pad); gst_pad_pause_task (pad);
if (ret < GST_FLOW_EOS || ret == GST_FLOW_NOT_LINKED) { if (ret < GST_FLOW_EOS) {
GST_ELEMENT_FLOW_ERROR (splitmux, ret); GST_ELEMENT_FLOW_ERROR (splitmux, ret);
} else if (ret == GST_FLOW_NOT_LINKED) {
gboolean post_error;
guint n_notlinked;
/* Only post not-linked if all pads are not-linked */
SPLITMUX_SRC_PADS_LOCK (splitmux);
n_notlinked = count_not_linked (splitmux);
post_error = (splitmux->pads_complete
&& n_notlinked == splitmux->n_pads);
SPLITMUX_SRC_PADS_UNLOCK (splitmux);
if (post_error)
GST_ELEMENT_FLOW_ERROR (splitmux, ret);
} }
} }
} }
@ -837,6 +867,7 @@ gst_splitmux_find_output_pad (GstSplitMuxPartReader * part, GstPad * pad,
target = g_object_new (SPLITMUX_TYPE_SRC_PAD, target = g_object_new (SPLITMUX_TYPE_SRC_PAD,
"name", pad_name, "direction", GST_PAD_SRC, NULL); "name", pad_name, "direction", GST_PAD_SRC, NULL);
splitmux->pads = g_list_prepend (splitmux->pads, target); splitmux->pads = g_list_prepend (splitmux->pads, target);
splitmux->n_pads++;
gst_pad_set_active (target, TRUE); gst_pad_set_active (target, TRUE);

2
gst/multifile/gstsplitmuxsrc.h
View file

@ -55,6 +55,8 @@ struct _GstSplitMuxSrc
gboolean pads_complete; gboolean pads_complete;
GMutex pads_lock; GMutex pads_lock;
GList *pads; /* pads_lock */ GList *pads; /* pads_lock */
guint n_pads;
guint n_notlinked;
GstClockTime total_duration; GstClockTime total_duration;
GstSegment play_segment; GstSegment play_segment;