mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-10-03 17:22:29 +00:00
Code Issues 1 Projects Releases Wiki Activity

nlesource: Use gst_element_call_async as appropriate

Browse source
This commit is contained in:
Thibault Saunier 2019-03-15 18:31:30 -03:00
parent dabcc3b459
commit f255ae72d9
1 changed files with 6 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
plugins/nle/nlesource.c
View file

@ -431,10 +431,10 @@ nle_source_send_event (GstElement * element, GstEvent * event)
return res; return res;
} }
static gpointer static void
ghost_seek_pad (NleSource * source) ghost_seek_pad (GstElement * source, gpointer user_data)
{ {
NleSourcePrivate *priv = source->priv; NleSourcePrivate *priv = NLE_SOURCE (source)->priv;
g_mutex_lock (&priv->seek_lock); g_mutex_lock (&priv->seek_lock);
if (priv->seek_event) { if (priv->seek_event) {
@ -455,22 +455,18 @@ ghost_seek_pad (NleSource * source)
priv->probeid = 0; priv->probeid = 0;
} }
GST_OBJECT_UNLOCK (source); GST_OBJECT_UNLOCK (source);
return NULL;
} }
static GstPadProbeReturn static GstPadProbeReturn
pad_blocked_cb (GstPad * pad, GstPadProbeInfo * info, NleSource * source) pad_blocked_cb (GstPad * pad, GstPadProbeInfo * info, NleSource * source)
{ {
GThread *lthread; GST_OBJECT_LOCK (source);
if (!source->priv->areblocked) { if (!source->priv->areblocked) {
GST_INFO_OBJECT (pad, "Blocked now, launching seek"); GST_INFO_OBJECT (pad, "Blocked now, launching seek");
gst_element_call_async (GST_ELEMENT (source), ghost_seek_pad, NULL, NULL);
source->priv->areblocked = TRUE; source->priv->areblocked = TRUE;
lthread =
g_thread_new ("gnlsourceseek", (GThreadFunc) ghost_seek_pad, source);
g_thread_unref (lthread);
} }
GST_OBJECT_UNLOCK (source);
return GST_PAD_PROBE_OK; return GST_PAD_PROBE_OK;
} }