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

audiolatency: Forward latency query and event upstream

Browse source 
Make sure the pipeline still configures the latency that it would configure
if audiolatency was not in the pipeline.

Part-of: <https://gitlab.freedesktop.org/gstreamer/gstreamer/-/merge_requests/5146>
This commit is contained in:
Jan Schmidt 2023-08-04 17:25:26 +10:00 committed by GStreamer Marge Bot
parent 8a7614e814
commit fd95f5682e
1 changed files with 39 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

41
subprojects/gst-plugins-bad/gst/audiolatency/gstaudiolatency.c
View file

@ -227,7 +227,9 @@ gst_audiolatency_init (GstAudioLatency * self)
templ = gst_static_pad_template_get (&src_template);
srcpad = gst_element_get_static_pad (self->audiosrc, "src");
gst_pad_add_probe (srcpad, GST_PAD_PROBE_TYPE_BUFFER,
gst_pad_add_probe (srcpad,
GST_PAD_PROBE_TYPE_BUFFER | GST_PAD_PROBE_TYPE_QUERY_UPSTREAM |
GST_PAD_PROBE_TYPE_EVENT_UPSTREAM,
(GstPadProbeCallback) gst_audiolatency_src_probe, self, NULL);
self->srcpad = gst_ghost_pad_new_from_template ("src", srcpad, templ);
@ -383,7 +385,7 @@ buffer_has_wave (GstBuffer * buffer, GstPad * pad)
}
static GstPadProbeReturn
gst_audiolatency_src_probe (GstPad * pad, GstPadProbeInfo * info,
gst_audiolatency_src_probe_buffer (GstPad * pad, GstPadProbeInfo * info,
gpointer user_data)
{
GstAudioLatency *self = user_data;
@ -425,6 +427,41 @@ out:
return GST_PAD_PROBE_OK;
}
static GstPadProbeReturn
gst_audiolatency_src_probe (GstPad * pad, GstPadProbeInfo * info,
gpointer user_data)
{
GstAudioLatency *self = user_data;
if (info->type & GST_PAD_PROBE_TYPE_BUFFER) {
return gst_audiolatency_src_probe_buffer (pad, info, user_data);
} else if (info->type & GST_PAD_PROBE_TYPE_QUERY_UPSTREAM) {
GstQuery *query = gst_pad_probe_info_get_query (info);
/* Forward latency query to the upstream sinkpad */
if (GST_QUERY_TYPE (query) == GST_QUERY_LATENCY) {
gboolean res = gst_pad_peer_query (self->sinkpad, query);
GST_LOG_OBJECT (self,
"Forwarded latency query to sinkpad. Result %d %" GST_PTR_FORMAT, res,
query);
return res ? GST_PAD_PROBE_HANDLED : GST_PAD_PROBE_DROP;
}
} else if (info->type & GST_PAD_PROBE_TYPE_EVENT_UPSTREAM) {
GstEvent *event = gst_pad_probe_info_get_event (info);
if (GST_EVENT_TYPE (event) == GST_EVENT_LATENCY) {
gboolean res = gst_pad_push_event (self->sinkpad, event);
GST_LOG_OBJECT (self,
"Forwarded latency event to sinkpad. Result %d %" GST_PTR_FORMAT, res,
event);
return res ? GST_PAD_PROBE_HANDLED : GST_PAD_PROBE_DROP;
}
}
return GST_PAD_PROBE_OK;
}
static GstFlowReturn
gst_audiolatency_sink_chain (GstPad * pad, GstObject * parent,
GstBuffer * buffer)