mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-02-22 05:56:31 +00:00
Code Issues 1 Projects Releases Wiki Activity

videomixer: Drop custom latency querying logic

Browse source 
This is now implemented in the default latency query handler.
This commit is contained in:
Arun Raghavan 2015-02-27 00:40:05 +05:30
parent d331d931db
commit dbc142afec
1 changed files with 0 additions and 88 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

88
gst/videomixer/videomixer2.c
View file

@ -1433,91 +1433,6 @@ gst_videomixer2_query_duration (GstVideoMixer2 * mix, GstQuery * query)
return res; return res;
} }
static gboolean
gst_videomixer2_query_latency (GstVideoMixer2 * mix, GstQuery * query)
{
GstClockTime min, max;
gboolean live;
gboolean res;
GstIterator *it;
gboolean done;
GValue item = { 0 };
res = TRUE;
done = FALSE;
live = FALSE;
min = 0;
max = GST_CLOCK_TIME_NONE;
/* Take maximum of all latency values */
it = gst_element_iterate_sink_pads (GST_ELEMENT_CAST (mix));
while (!done) {
switch (gst_iterator_next (it, &item)) {
case GST_ITERATOR_DONE:
done = TRUE;
break;
case GST_ITERATOR_OK:
{
GstPad *pad = g_value_get_object (&item);
GstQuery *peerquery;
GstClockTime min_cur, max_cur;
gboolean live_cur;
peerquery = gst_query_new_latency ();
/* Ask peer for latency */
res &= gst_pad_peer_query (pad, peerquery);
/* take max from all valid return values */
if (res) {
gst_query_parse_latency (peerquery, &live_cur, &min_cur, &max_cur);
if (live_cur) {
if (min_cur > min)
min = min_cur;
if (max == GST_CLOCK_TIME_NONE)
max = max_cur;
else if (max_cur < max)
max = max_cur;
live = TRUE;
}
}
gst_query_unref (peerquery);
g_value_reset (&item);
break;
}
case GST_ITERATOR_RESYNC:
live = FALSE;
min = 0;
max = GST_CLOCK_TIME_NONE;
res = TRUE;
gst_iterator_resync (it);
break;
default:
res = FALSE;
done = TRUE;
break;
}
}
g_value_unset (&item);
gst_iterator_free (it);
mix->live = live;
if (res) {
/* store the results */
GST_DEBUG_OBJECT (mix, "Calculated total latency: live %s, min %"
GST_TIME_FORMAT ", max %" GST_TIME_FORMAT,
(live ? "yes" : "no"), GST_TIME_ARGS (min), GST_TIME_ARGS (max));
gst_query_set_latency (query, live, min, max);
}
return res;
}
static gboolean static gboolean
gst_videomixer2_src_query (GstPad * pad, GstObject * parent, GstQuery * query) gst_videomixer2_src_query (GstPad * pad, GstObject * parent, GstQuery * query)
{ {
@ -1546,9 +1461,6 @@ gst_videomixer2_src_query (GstPad * pad, GstObject * parent, GstQuery * query)
case GST_QUERY_DURATION: case GST_QUERY_DURATION:
res = gst_videomixer2_query_duration (mix, query); res = gst_videomixer2_query_duration (mix, query);
break; break;
case GST_QUERY_LATENCY:
res = gst_videomixer2_query_latency (mix, query);
break;
case GST_QUERY_CAPS: case GST_QUERY_CAPS:
res = gst_pad_query_default (pad, parent, query); res = gst_pad_query_default (pad, parent, query);
break; break;