FaSTTUBe/GST-Tensordecoder-ov_ep
61
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

tsdemux: Support segment seeking

Browse Source 
Add support for segment seeks and posting segment-done for
seamless non-flushing looping

Part-of: <https://gitlab.freedesktop.org/gstreamer/gstreamer/-/merge_requests/6023>
This commit is contained in:
Jan Schmidt 2024-01-25 03:02:59 +11:00 committed by GStreamer Marge Bot
parent df0be57d38
commit 61aefda664
2 changed files with 28 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
subprojects/gst-plugins-bad/gst/mpegtsdemux/mpegtsbase.c
View File

@ -1750,11 +1750,30 @@ error:
{ {
GST_DEBUG_OBJECT (base, "Pausing task, reason %s", gst_flow_get_name (ret)); GST_DEBUG_OBJECT (base, "Pausing task, reason %s", gst_flow_get_name (ret));
if (ret == GST_FLOW_EOS) { if (ret == GST_FLOW_EOS) {
if (!GST_MPEGTS_BASE_GET_CLASS (base)->push_event (base, GstEvent *e;
gst_event_new_eos ())) if (base->out_segment.flags & GST_SEEK_FLAG_SEGMENT) {
gint64 stop;
if ((stop = base->out_segment.stop) == -1) {
stop = base->out_segment.position;
}
e = gst_event_new_segment_done (GST_FORMAT_TIME, stop);
GstMessage *msg = gst_message_new_segment_done (GST_OBJECT (base),
GST_FORMAT_TIME, stop);
if (base->last_seek_seqnum != GST_SEQNUM_INVALID) {
gst_message_set_seqnum (msg, base->last_seek_seqnum);
}
gst_element_post_message (GST_ELEMENT (base), msg);
} else {
e = gst_event_new_eos ();
}
GST_DEBUG_OBJECT (base, "Pushing event %" GST_PTR_FORMAT, e);
if (!GST_MPEGTS_BASE_GET_CLASS (base)->push_event (base, e)) {
GST_ELEMENT_ERROR (base, STREAM, FAILED, GST_ELEMENT_ERROR (base, STREAM, FAILED,
(_("Internal data stream error.")), (_("Internal data stream error.")),
("No program activated before EOS")); ("No program activated before EOS"));
}
} else if (ret == GST_FLOW_NOT_LINKED || ret < GST_FLOW_EOS) { } else if (ret == GST_FLOW_NOT_LINKED || ret < GST_FLOW_EOS) {
GST_ELEMENT_FLOW_ERROR (base, ret); GST_ELEMENT_FLOW_ERROR (base, ret);
GST_MPEGTS_BASE_GET_CLASS (base)->push_event (base, gst_event_new_eos ()); GST_MPEGTS_BASE_GET_CLASS (base)->push_event (base, gst_event_new_eos ());
@ -1887,17 +1906,12 @@ mpegts_base_handle_seek_event (MpegTSBase * base, GstPad * pad,
/* ref for it to be reused later */ /* ref for it to be reused later */
gst_pad_push_event (base->sinkpad, gst_event_ref (flush_event)); gst_pad_push_event (base->sinkpad, gst_event_ref (flush_event));
}
/* And actually flush our pending data but allow to preserve some info /* And actually flush our pending data but allow to preserve some info
* to perform the seek */ * to perform the seek */
mpegts_base_flush (base, FALSE); mpegts_base_flush (base, FALSE);
mpegts_packetizer_flush (base->packetizer, FALSE); mpegts_packetizer_flush (base->packetizer, FALSE);
}
if (flags & (GST_SEEK_FLAG_SEGMENT)) {
GST_WARNING ("seek flags 0x%x are not supported", (int) flags);
goto done;
}
/* If the subclass can seek, do that */ /* If the subclass can seek, do that */
ret = klass->seek (base, event); ret = klass->seek (base, event);
@ -1912,7 +1926,7 @@ mpegts_base_handle_seek_event (MpegTSBase * base, GstPad * pad,
GST_MPEGTS_BASE_GET_CLASS (base)->push_event (base, flush_event); GST_MPEGTS_BASE_GET_CLASS (base)->push_event (base, flush_event);
flush_event = NULL; flush_event = NULL;
} }
done:
if (flush_event) if (flush_event)
gst_event_unref (flush_event); gst_event_unref (flush_event);
gst_pad_start_task (base->sinkpad, (GstTaskFunction) mpegts_base_loop, base, gst_pad_start_task (base->sinkpad, (GstTaskFunction) mpegts_base_loop, base,

8
subprojects/gst-plugins-bad/gst/mpegtsdemux/tsdemux.c
View File

@ -943,12 +943,6 @@ gst_ts_demux_do_seek (MpegTSBase * base, GstEvent * event)
goto done; goto done;
} }
if (flags & (GST_SEEK_FLAG_SEGMENT)) {
GST_WARNING_OBJECT (demux, "seek flags 0x%x are not supported",
(int) flags);
goto done;
}
/* configure the segment with the seek variables */ /* configure the segment with the seek variables */
memcpy (&seeksegment, &base->out_segment, sizeof (GstSegment)); memcpy (&seeksegment, &base->out_segment, sizeof (GstSegment));
GST_LOG_OBJECT (demux, "Before seek, output segment %" GST_SEGMENT_FORMAT, GST_LOG_OBJECT (demux, "Before seek, output segment %" GST_SEGMENT_FORMAT,
@ -1020,6 +1014,8 @@ gst_ts_demux_do_seek (MpegTSBase * base, GstEvent * event)
/* Commit the new segment */ /* Commit the new segment */
memcpy (&base->out_segment, &seeksegment, sizeof (GstSegment)); memcpy (&base->out_segment, &seeksegment, sizeof (GstSegment));
/* And prepare to restart */
gst_flow_combiner_reset (demux->flowcombiner);
res = GST_FLOW_OK; res = GST_FLOW_OK;
done: done: