From 0eb30d478d079c381d73ed0b3c063526c7a3427b Mon Sep 17 00:00:00 2001 From: Jeffy Chen Date: Fri, 26 Nov 2021 17:41:47 +0800 Subject: [PATCH 8/9] playbin2: Fix deadlock when hooking about-to-finish signal The playbin2 will deactivate old group in drain_cb() for that, which would cause deadlock when other thread tries to notify pad-change at the same time. Signed-off-by: Jeffy Chen --- gst/playback/gstplaybin2.c | 20 ++++++++++++++++++++ 1 file changed, 20 insertions(+) diff --git a/gst/playback/gstplaybin2.c b/gst/playback/gstplaybin2.c index f1ddef0..f07fd75 100644 --- a/gst/playback/gstplaybin2.c +++ b/gst/playback/gstplaybin2.c @@ -385,6 +385,11 @@ G_STMT_START { \ #define GST_PLAY_BIN_SHUTDOWN_UNLOCK(bin) \ GST_PLAY_BIN_DYN_UNLOCK (bin); \ +/* lock to protect drain callbacks */ +#define GST_PLAY_BIN_DRAIN_LOCK(bin) g_mutex_lock (&(bin)->drain_lock) +#define GST_PLAY_BIN_DRAIN_TRYLOCK(bin) g_mutex_trylock (&(bin)->drain_lock) +#define GST_PLAY_BIN_DRAIN_UNLOCK(bin) g_mutex_unlock (&(bin)->drain_lock) + /** * GstPlayBin: * @@ -427,6 +432,9 @@ struct _GstPlayBin gint shutdown; gboolean async_pending; /* async-start has been emitted */ + /* lock protecting draining */ + GMutex drain_lock; + GMutex elements_lock; guint32 elements_cookie; GList *elements; /* factories we can use for selecting elements */ @@ -1552,6 +1560,7 @@ gst_play_bin_init (GstPlayBin * playbin) { g_rec_mutex_init (&playbin->lock); g_mutex_init (&playbin->dyn_lock); + g_mutex_init (&playbin->drain_lock); /* assume we can create an input-selector */ playbin->have_selector = TRUE; @@ -1651,6 +1660,7 @@ gst_play_bin_finalize (GObject * object) g_list_free_full (playbin->contexts, (GDestroyNotify) gst_context_unref); g_rec_mutex_clear (&playbin->lock); + g_mutex_clear (&playbin->drain_lock); g_mutex_clear (&playbin->dyn_lock); g_mutex_clear (&playbin->elements_lock); @@ -3150,7 +3160,14 @@ combiner_active_pad_changed (GObject * combiner, GParamSpec * pspec, GstSourceCombine *combine = NULL; int i; + /* We got a pad-change after draining; no need to notify */ + if (!GST_PLAY_BIN_DRAIN_TRYLOCK (playbin)) + return; + GST_PLAY_BIN_LOCK (playbin); + + GST_PLAY_BIN_DRAIN_UNLOCK (playbin); + group = get_group (playbin); for (i = 0; i < PLAYBIN_STREAM_LAST; i++) { @@ -3960,7 +3977,10 @@ drained_cb (GstElement * decodebin, GstSourceGroup * group) /* now activate the next group. If the app did not set a uri, this will * fail and we can do EOS */ + + GST_PLAY_BIN_DRAIN_LOCK (playbin); setup_next_source (playbin, GST_STATE_PAUSED); + GST_PLAY_BIN_DRAIN_UNLOCK (playbin); } /* Like gst_element_factory_can_sink_any_caps() but doesn't -- 2.20.1