mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-06-06 23:48:53 +00:00
Code Issues 1 Projects Releases Wiki Activity

mssdemux: adds mininum error handling

Browse source 
This should care for basic scenarios of errors and EOS to allow
the pipeline to stop correctly
This commit is contained in:
Thiago Santos 2012-11-22 12:28:56 -03:00
parent 96522f474c
commit b4f994d47c
1 changed files with 35 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

36
ext/smoothstreaming/gstmssdemux.c
View file

@ -411,6 +411,12 @@ gst_mss_demux_stream_loop (GstMssDemuxStream * stream)
GST_DEBUG_OBJECT (mssdemux, "Getting url for stream %p", stream); GST_DEBUG_OBJECT (mssdemux, "Getting url for stream %p", stream);
ret = gst_mss_stream_get_fragment_url (stream->manifest_stream, &path); ret = gst_mss_stream_get_fragment_url (stream->manifest_stream, &path);
switch (ret) { switch (ret) {
case GST_FLOW_OK:
break; /* all is good, let's go */
case GST_FLOW_UNEXPECTED: /* EOS */
goto eos;
case GST_FLOW_ERROR:
goto error;
default: default:
break; break;
} }
@ -428,6 +434,34 @@ gst_mss_demux_stream_loop (GstMssDemuxStream * stream)
buflist = gst_fragment_get_buffer_list (fragment); buflist = gst_fragment_get_buffer_list (fragment);
ret = gst_pad_push_list (stream->pad, buflist); /* TODO check return */ ret = gst_pad_push_list (stream->pad, buflist); /* TODO check return */
switch (ret) {
case GST_FLOW_UNEXPECTED:
goto eos; /* EOS ? */
case GST_FLOW_ERROR:
goto error;
case GST_FLOW_NOT_LINKED:
break; /* TODO what to do here? pause the task or just keep pushing? */
case GST_FLOW_OK:
default:
break;
}
ret = gst_mss_stream_advance_fragment (stream->manifest_stream); gst_mss_stream_advance_fragment (stream->manifest_stream);
return;
eos:
{
GstEvent *eos = gst_event_new_eos ();
GST_DEBUG_OBJECT (mssdemux, "Pushing EOS on pad %s:%s",
GST_DEBUG_PAD_NAME (stream->pad));
gst_pad_push_event (stream->pad, eos);
gst_task_stop (stream->stream_task);
return;
}
error:
{
GST_WARNING_OBJECT (mssdemux, "Error while pushing fragment");
gst_task_stop (stream->stream_task);
return;
}
} }