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

matroskademux: Mark streams as being EOS at the right time.

Browse source 
This allows us to stop streaming only when all streams have gone past the
segment.stop and not before.

Fixes #611501
This commit is contained in:
Edward Hervey 2010-03-02 14:09:14 +01:00
parent ad71d43f52
commit be186bd089
2 changed files with 16 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
gst/matroska/matroska-demux.c
View file

@ -2278,6 +2278,7 @@ gst_matroska_demux_handle_seek_event (GstMatroskaDemux * demux,
context->pos = entry->time; context->pos = entry->time;
context->set_discont = TRUE; context->set_discont = TRUE;
context->last_flow = GST_FLOW_OK; context->last_flow = GST_FLOW_OK;
context->eos = FALSE;
} }
demux->segment.last_stop = entry->time; demux->segment.last_stop = entry->time;
demux->seek_block = entry->block; demux->seek_block = entry->block;
@ -4381,7 +4382,8 @@ gst_matroska_demux_parse_blockgroup_or_simpleblock (GstMatroskaDemux * demux,
GST_DEBUG_OBJECT (demux, GST_DEBUG_OBJECT (demux,
"Stream %d after segment stop %" GST_TIME_FORMAT, stream->index, "Stream %d after segment stop %" GST_TIME_FORMAT, stream->index,
GST_TIME_ARGS (demux->segment.stop)); GST_TIME_ARGS (demux->segment.stop));
ret = GST_FLOW_UNEXPECTED; stream->eos = TRUE;
ret = GST_FLOW_OK;
/* combine flows */ /* combine flows */
ret = gst_matroska_demux_combine_flows (demux, stream, ret); ret = gst_matroska_demux_combine_flows (demux, stream, ret);
goto done; goto done;
@ -5163,22 +5165,24 @@ gst_matroska_demux_loop (GstPad * pad)
goto pause; goto pause;
/* check if we're at the end of a configured segment */ /* check if we're at the end of a configured segment */
if (G_LIKELY (GST_CLOCK_TIME_IS_VALID (demux->segment.stop))) { if (G_LIKELY (demux->src->len)) {
guint i; guint i;
g_assert (demux->num_streams == demux->src->len); g_assert (demux->num_streams == demux->src->len);
for (i = 0; i < demux->src->len; i++) { for (i = 0; i < demux->src->len; i++) {
GstMatroskaTrackContext *context = g_ptr_array_index (demux->src, i); GstMatroskaTrackContext *context = g_ptr_array_index (demux->src, i);
if (context->pos >= demux->segment.stop) { GST_DEBUG_OBJECT (context->pad, "pos %" GST_TIME_FORMAT,
GST_INFO_OBJECT (demux, "Reached end of segment (%" G_GUINT64_FORMAT GST_TIME_ARGS (context->pos));
"-%" G_GUINT64_FORMAT ") on pad %s:%s", demux->segment.start, if (context->eos == FALSE)
demux->segment.stop, GST_DEBUG_PAD_NAME (context->pad)); goto next;
ret = GST_FLOW_UNEXPECTED;
goto pause;
}
} }
GST_INFO_OBJECT (demux, "All streams are EOS");
ret = GST_FLOW_UNEXPECTED;
goto pause;
} }
next:
if (G_UNLIKELY (ebml->offset == gst_ebml_read_get_length (ebml))) { if (G_UNLIKELY (ebml->offset == gst_ebml_read_get_length (ebml))) {
GST_LOG_OBJECT (demux, "Reached end of stream, sending EOS"); GST_LOG_OBJECT (demux, "Reached end of stream, sending EOS");
ret = GST_FLOW_UNEXPECTED; ret = GST_FLOW_UNEXPECTED;

3
gst/matroska/matroska-ids.h
View file

@ -521,6 +521,9 @@ struct _GstMatroskaTrackContext {
/* A GArray of GstMatroskaTrackEncoding structures which contain the /* A GArray of GstMatroskaTrackEncoding structures which contain the
* encoding (compression/encryption) settings for this track, if any */ * encoding (compression/encryption) settings for this track, if any */
GArray *encodings; GArray *encodings;
/* Whether the stream is EOS */
gboolean eos;
}; };
typedef struct _GstMatroskaTrackVideoContext { typedef struct _GstMatroskaTrackVideoContext {