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

splitmuxsrc: Don't create part reader elements initially

Browse Source 
Only create the part reader elements internally the first time
the part is activated. Saves some startup time when preloading
a large number of fragments

Part-of: <https://gitlab.freedesktop.org/gstreamer/gstreamer/-/merge_requests/7053>
This commit is contained in:
Jan Schmidt 2024-07-12 11:09:14 +10:00
parent 8a1fab9594
commit c1a1584dde
2 changed files with 26 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

41
subprojects/gst-plugins-good/gst/multifile/gstsplitmuxpartreader.c
View File

@ -710,25 +710,11 @@ gst_splitmux_part_reader_class_init (GstSplitMuxPartReaderClass * klass)
} }
static void static void
gst_splitmux_part_reader_init (GstSplitMuxPartReader * reader) create_elements (GstSplitMuxPartReader * reader)
{ {
/* Called on the first state change to create our internal elements */
GstElement *typefind; GstElement *typefind;
reader->prep_state = PART_STATE_NULL;
reader->need_duration_measuring = TRUE;
reader->loaded = FALSE;
reader->playing = FALSE;
reader->smallest_ts_offset = GST_CLOCK_TIME_NONE;
reader->info.start_offset = GST_CLOCK_TIME_NONE;
reader->info.duration = GST_CLOCK_TIME_NONE;
g_cond_init (&reader->inactive_cond);
g_mutex_init (&reader->lock);
g_mutex_init (&reader->type_lock);
g_mutex_init (&reader->msg_lock);
/* FIXME: Create elements on a state change */
reader->src = gst_element_factory_make ("filesrc", NULL); reader->src = gst_element_factory_make ("filesrc", NULL);
if (reader->src == NULL) { if (reader->src == NULL) {
GST_ERROR_OBJECT (reader, "Failed to create filesrc element"); GST_ERROR_OBJECT (reader, "Failed to create filesrc element");
@ -756,6 +742,25 @@ gst_splitmux_part_reader_init (GstSplitMuxPartReader * reader)
reader); reader);
} }
static void
gst_splitmux_part_reader_init (GstSplitMuxPartReader * reader)
{
reader->prep_state = PART_STATE_NULL;
reader->need_duration_measuring = TRUE;
reader->created = FALSE;
reader->loaded = FALSE;
reader->playing = FALSE;
reader->smallest_ts_offset = GST_CLOCK_TIME_NONE;
reader->info.start_offset = GST_CLOCK_TIME_NONE;
reader->info.duration = GST_CLOCK_TIME_NONE;
g_cond_init (&reader->inactive_cond);
g_mutex_init (&reader->lock);
g_mutex_init (&reader->type_lock);
g_mutex_init (&reader->msg_lock);
}
static void static void
splitmux_part_reader_dispose (GObject * object) splitmux_part_reader_dispose (GObject * object)
{ {
@ -1216,6 +1221,10 @@ gst_splitmux_part_reader_change_state (GstElement * element,
} }
case GST_STATE_CHANGE_READY_TO_PAUSED:{ case GST_STATE_CHANGE_READY_TO_PAUSED:{
SPLITMUX_PART_LOCK (reader); SPLITMUX_PART_LOCK (reader);
if (!reader->created) {
create_elements (reader);
reader->created = TRUE;
}
g_object_set (reader->src, "location", reader->path, NULL); g_object_set (reader->src, "location", reader->path, NULL);
reader->prep_state = PART_STATE_PREPARING_COLLECT_STREAMS; reader->prep_state = PART_STATE_PREPARING_COLLECT_STREAMS;
gst_splitmux_part_reader_set_flushing_locked (reader, FALSE); gst_splitmux_part_reader_set_flushing_locked (reader, FALSE);

1
subprojects/gst-plugins-good/gst/multifile/gstsplitmuxpartreader.h
View File

@ -76,6 +76,7 @@ struct _GstSplitMuxPartReader
gboolean async_pending; gboolean async_pending;
gboolean created;
gboolean loaded; gboolean loaded;
gboolean playing; gboolean playing;