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

audioaggregator: Make access to the pad list thread-safe while mixing

Browse source 
When mixing every single buffer the object lock is shortly released and
acquired again. In the meantime the pad list can become invalid because
a pad was removed or added, and equally the current pad might as well
have been finalized in the meantime.

To get around that, take a snapshot of all sinkpads before mixing and
work with that list of pads.

Fixes https://gitlab.freedesktop.org/gstreamer/gstreamer/-/issues/3052

Part-of: <https://gitlab.freedesktop.org/gstreamer/gstreamer/-/merge_requests/5553>
This commit is contained in:
Sebastian Dröge 2023-10-19 19:41:27 +03:00 committed by Tim-Philipp Müller
parent 970eb963c7
commit 8419c1e6dc
1 changed files with 16 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
subprojects/gst-plugins-base/gst-libs/gst/audio/gstaudioaggregator.c
View file

@ -2224,6 +2224,8 @@ gst_audio_aggregator_aggregate (GstAggregator * agg, gboolean timeout)
GstElement *element;
GstAudioAggregator *aagg;
GList *iter;
GstPad **sinkpads;
guint n_sinkpads, i;
GstFlowReturn ret;
GstBuffer *outbuf = NULL;
gint64 next_offset;
@ -2471,9 +2473,17 @@ gst_audio_aggregator_aggregate (GstAggregator * agg, gboolean timeout)
}
GST_OBJECT_LOCK (agg);
for (iter = element->sinkpads; iter; iter = iter->next) {
GstAudioAggregatorPad *pad = (GstAudioAggregatorPad *) iter->data;
GstAggregatorPad *aggpad = (GstAggregatorPad *) iter->data;
// mix_buffer() will shortly release the object lock so we need to
// ensure that the pad list stays valid.
n_sinkpads = element->numsinkpads;
sinkpads = g_newa (GstPad *, n_sinkpads + 1);
for (i = 0, iter = element->sinkpads; iter; i++, iter = iter->next)
sinkpads[i] = gst_object_ref (iter->data);
for (i = 0; i < n_sinkpads; i++) {
GstAudioAggregatorPad *pad = (GstAudioAggregatorPad *) sinkpads[i];
GstAggregatorPad *aggpad = (GstAggregatorPad *) sinkpads[i];
if (gst_aggregator_pad_is_inactive (aggpad))
continue;
@ -2505,6 +2515,9 @@ gst_audio_aggregator_aggregate (GstAggregator * agg, gboolean timeout)
}
GST_OBJECT_UNLOCK (agg);
for (i = 0; i < n_sinkpads; i++)
gst_object_unref (sinkpads[i]);
if (dropped) {
/* We dropped a buffer, retry */
GST_LOG_OBJECT (aagg, "A pad dropped a buffer, wait for the next one");