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

splitmuxsrc: Post messages when a fragment is started

Browse source 
This allows the application to keep track which fragment is currently active.

Part-of: <https://gitlab.freedesktop.org/gstreamer/gstreamer/-/merge_requests/8184>
This commit is contained in:
Sebastian Dröge 2024-12-19 17:01:28 +02:00 committed by GStreamer Marge Bot
parent 2c9a642b66
commit 10fc594847
1 changed files with 31 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

31
subprojects/gst-plugins-good/gst/multifile/gstsplitmuxsrc.c
View file

@ -1051,13 +1051,27 @@ static gboolean
gst_splitmux_src_activate_part (GstSplitMuxSrc * splitmux, guint part, gst_splitmux_src_activate_part (GstSplitMuxSrc * splitmux, guint part,
GstSeekFlags extra_flags) GstSeekFlags extra_flags)
{ {
GstMessage *msg;
GST_DEBUG_OBJECT (splitmux, "Activating part %d", part); GST_DEBUG_OBJECT (splitmux, "Activating part %d", part);
GstSplitMuxPartReader *reader = gst_object_ref (splitmux->parts[part]); GstSplitMuxPartReader *reader = gst_object_ref (splitmux->parts[part]);
splitmux->cur_part = part; splitmux->cur_part = part;
add_to_active_readers (splitmux, reader, FALSE); add_to_active_readers (splitmux, reader, FALSE);
msg = gst_message_new_element (GST_OBJECT (splitmux),
gst_structure_new ("splitmuxsrc-fragment-started",
"fragment-id", G_TYPE_UINT, part,
"location", G_TYPE_STRING, reader->path,
"fragment-offset", GST_TYPE_CLOCK_TIME,
gst_splitmux_part_reader_get_start_offset (reader),
"fragment-duration", GST_TYPE_CLOCK_TIME,
gst_splitmux_part_reader_get_duration (reader), NULL));
SPLITMUX_SRC_UNLOCK (splitmux); SPLITMUX_SRC_UNLOCK (splitmux);
gst_element_post_message (GST_ELEMENT_CAST (splitmux), msg);
/* Drop lock around calling activate, as it might call back /* Drop lock around calling activate, as it might call back
* into the splitmuxsrc when exposing pads */ * into the splitmuxsrc when exposing pads */
if (!gst_splitmux_part_reader_activate (reader, if (!gst_splitmux_part_reader_activate (reader,
@ -1487,6 +1501,7 @@ gst_splitmux_push_flush_stop (GstSplitMuxSrc * splitmux, guint32 seqnum)
static gboolean static gboolean
gst_splitmux_end_of_part (GstSplitMuxSrc * splitmux, SplitMuxSrcPad * splitpad) gst_splitmux_end_of_part (GstSplitMuxSrc * splitmux, SplitMuxSrcPad * splitpad)
{ {
GstMessage *msg = NULL;
gint next_part = -1; gint next_part = -1;
gint cur_part = splitpad->cur_part; gint cur_part = splitpad->cur_part;
gboolean res = FALSE; gboolean res = FALSE;
@ -1562,6 +1577,16 @@ gst_splitmux_end_of_part (GstSplitMuxSrc * splitmux, SplitMuxSrcPad * splitpad)
GST_SEGMENT_FORMAT, next_part, &tmp); GST_SEGMENT_FORMAT, next_part, &tmp);
add_to_active_readers (splitmux, splitpad->reader, FALSE); add_to_active_readers (splitmux, splitpad->reader, FALSE);
msg = gst_message_new_element (GST_OBJECT (splitmux),
gst_structure_new ("splitmuxsrc-fragment-started",
"fragment-id", G_TYPE_UINT, next_part,
"location", G_TYPE_STRING, splitpad->reader->path,
"fragment-offset", GST_TYPE_CLOCK_TIME,
gst_splitmux_part_reader_get_start_offset (splitpad->reader),
"fragment-duration", GST_TYPE_CLOCK_TIME,
gst_splitmux_part_reader_get_duration (splitpad->reader),
NULL));
if (!gst_splitmux_part_reader_activate (splitpad->reader, &tmp, if (!gst_splitmux_part_reader_activate (splitpad->reader, &tmp,
GST_SEEK_FLAG_NONE)) { GST_SEEK_FLAG_NONE)) {
goto error; goto error;
@ -1581,9 +1606,15 @@ gst_splitmux_end_of_part (GstSplitMuxSrc * splitmux, SplitMuxSrcPad * splitpad)
} }
SPLITMUX_SRC_UNLOCK (splitmux); SPLITMUX_SRC_UNLOCK (splitmux);
if (msg)
gst_element_post_message (GST_ELEMENT_CAST (splitmux),
g_steal_pointer (&msg));
return res; return res;
error: error:
SPLITMUX_SRC_UNLOCK (splitmux); SPLITMUX_SRC_UNLOCK (splitmux);
gst_clear_message (&msg);
GST_ELEMENT_ERROR (splitmux, RESOURCE, READ, (NULL), GST_ELEMENT_ERROR (splitmux, RESOURCE, READ, (NULL),
("Failed to activate part %d", splitmux->cur_part)); ("Failed to activate part %d", splitmux->cur_part));
return FALSE; return FALSE;