if (full) {
dec->priv->active = FALSE;
+ GST_OBJECT_LOCK (dec);
dec->priv->bytes_in = 0;
dec->priv->samples_out = 0;
+ GST_OBJECT_UNLOCK (dec);
dec->priv->agg = -1;
dec->priv->error_count = 0;
gst_audio_decoder_clear_queues (dec);
if (dec->priv->ctx.allocator)
gst_object_unref (dec->priv->ctx.allocator);
+ GST_OBJECT_LOCK (dec);
gst_caps_replace (&dec->priv->ctx.input_caps, NULL);
gst_caps_replace (&dec->priv->ctx.allocation_caps, NULL);
memset (&dec->priv->ctx, 0, sizeof (dec->priv->ctx));
gst_audio_info_init (&dec->priv->ctx.info);
+ GST_OBJECT_UNLOCK (dec);
dec->priv->ctx.max_errors = GST_AUDIO_DECODER_MAX_ERRORS;
dec->priv->ctx.had_output_data = FALSE;
dec->priv->ctx.had_input_data = FALSE;
}
/* copy the GstAudioInfo */
+ GST_OBJECT_LOCK (dec);
dec->priv->ctx.info = *info;
+ GST_OBJECT_UNLOCK (dec);
dec->priv->ctx.output_format_changed = TRUE;
done:
}
}
+ GST_OBJECT_LOCK (dec);
priv->samples += samples;
priv->samples_out += samples;
+ GST_OBJECT_UNLOCK (dec);
/* we got data, so note things are looking up */
if (G_UNLIKELY (dec->priv->error_count))
GST_TIME_ARGS (GST_BUFFER_TIMESTAMP (buffer)));
g_queue_push_tail (&dec->priv->frames, buffer);
dec->priv->ctx.delay = dec->priv->frames.length;
+ GST_OBJECT_LOCK (dec);
dec->priv->bytes_in += size;
+ GST_OBJECT_UNLOCK (dec);
} else {
GST_LOG_OBJECT (dec, "providing subclass with NULL frame");
}
static inline gboolean
gst_audio_decoder_do_byte (GstAudioDecoder * dec)
{
- return dec->priv->ctx.do_estimate_rate && dec->priv->ctx.info.bpf &&
+ gboolean ret;
+
+ GST_OBJECT_LOCK (dec);
+ ret = dec->priv->ctx.do_estimate_rate && dec->priv->ctx.info.bpf &&
dec->priv->ctx.info.rate <= dec->priv->samples_out;
+ GST_OBJECT_UNLOCK (dec);
+
+ return ret;
}
/* Must be called holding the GST_AUDIO_DECODER_STREAM_LOCK */
guint64 channel_mask = 0;
gint caps_size;
GstStructure *structure;
+ GstAudioInfo info;
templcaps = gst_pad_get_pad_template_caps (dec->srcpad);
caps = gst_pad_peer_query_caps (dec->srcpad, templcaps);
}
}
- if (!caps || !gst_audio_info_from_caps (&dec->priv->ctx.info, caps))
+ if (!caps || !gst_audio_info_from_caps (&info, caps))
goto caps_error;
+ GST_OBJECT_LOCK (dec);
+ dec->priv->ctx.info = info;
+ GST_OBJECT_UNLOCK (dec);
+
GST_INFO_OBJECT (dec,
"Chose default caps %" GST_PTR_FORMAT " for initial gap", caps);
gst_caps_unref (caps);
gint64 src_val, dest_val;
gst_query_parse_convert (query, &src_fmt, &src_val, &dest_fmt, &dest_val);
- if (!(res = __gst_audio_encoded_audio_convert (&dec->priv->ctx.info,
- dec->priv->bytes_in, dec->priv->samples_out,
- src_fmt, src_val, &dest_fmt, &dest_val)))
+ GST_OBJECT_LOCK (dec);
+ res = __gst_audio_encoded_audio_convert (&dec->priv->ctx.info,
+ dec->priv->bytes_in, dec->priv->samples_out,
+ src_fmt, src_val, &dest_fmt, &dest_val);
+ GST_OBJECT_UNLOCK (dec);
+ if (!res)
goto error;
gst_query_set_convert (query, src_fmt, src_val, dest_fmt, dest_val);
break;
gint64 src_val, dest_val;
gst_query_parse_convert (query, &src_fmt, &src_val, &dest_fmt, &dest_val);
- if (!(res = gst_audio_info_convert (&dec->priv->ctx.info,
- src_fmt, src_val, dest_fmt, &dest_val)))
+ GST_OBJECT_LOCK (dec);
+ res = gst_audio_info_convert (&dec->priv->ctx.info,
+ src_fmt, src_val, dest_fmt, &dest_val);
+ GST_OBJECT_UNLOCK (dec);
+ if (!res)
break;
gst_query_set_convert (query, src_fmt, src_val, dest_fmt, dest_val);
break;