mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-12-26 02:00:33 +00:00
Code Issues 1 Projects Releases Wiki Activity

gesdemux: Detect recursively loading the same project file

Browse source 
And error out when it is the case.
This commit is contained in:
Thibault Saunier 2019-07-03 12:10:24 -04:00
parent e9e24a23ba
commit 902b8ad98e
1 changed files with 21 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

21
plugins/ges/gesdemux.c
View file

@ -210,6 +210,7 @@ ges_demux_create_timeline (GESDemux * self, gchar * uri, GError ** error)
G_GNUC_UNUSED void *unused; G_GNUC_UNUSED void *unused;
TimelineConstructionData data = { 0, }; TimelineConstructionData data = { 0, };
GMainContext *ctx = g_main_context_new (); GMainContext *ctx = g_main_context_new ();
GstQuery *query;
g_main_context_push_thread_default (ctx); g_main_context_push_thread_default (ctx);
data.ml = g_main_loop_new (ctx, TRUE); data.ml = g_main_loop_new (ctx, TRUE);
@ -231,6 +232,26 @@ ges_demux_create_timeline (GESDemux * self, gchar * uri, GError ** error)
g_main_loop_run (data.ml); g_main_loop_run (data.ml);
g_main_loop_unref (data.ml); g_main_loop_unref (data.ml);
query = gst_query_new_uri ();
if (gst_pad_peer_query (self->sinkpad, query)) {
gchar *upstream_uri = NULL;
GList *assets, *tmp;
gst_query_parse_uri (query, &upstream_uri);
assets = ges_project_list_assets (project, GES_TYPE_URI_CLIP);
for (tmp = assets; tmp; tmp = tmp->next) {
const gchar *id = ges_asset_get_id (tmp->data);
if (!g_strcmp0 (id, upstream_uri)) {
g_set_error (error, GST_STREAM_ERROR, GST_STREAM_ERROR_DEMUX,
"Recursively loading uri: %s", upstream_uri);
break;
}
}
g_list_free_full (assets, g_object_unref);
}
done: done:
if (data.loaded_sigid) if (data.loaded_sigid)
g_signal_handler_disconnect (project, data.loaded_sigid); g_signal_handler_disconnect (project, data.loaded_sigid);