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

visual: post QoS messages when dropping frames due to QoS

Browse source 
https://bugzilla.gnome.org/show_bug.cgi?id=742875
This commit is contained in:
Luis de Bethencourt 2015-01-21 14:46:15 +00:00
parent 2bd4ea6e8e
commit 684e5e0c87
1 changed files with 30 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

36
ext/libvisual/gstaudiovisualizer.c
View file

@ -500,6 +500,9 @@ struct _GstAudioVisualizerPrivate
GstAllocator *allocator; GstAllocator *allocator;
GstAllocationParams params; GstAllocationParams params;
GstQuery *query; GstQuery *query;
guint dropped; /* frames dropped / not dropped */
guint processed;
}; };
GType GType
@ -686,6 +689,8 @@ gst_audio_visualizer_reset (GstAudioVisualizer * scope)
GST_OBJECT_LOCK (scope); GST_OBJECT_LOCK (scope);
scope->proportion = 1.0; scope->proportion = 1.0;
scope->earliest_time = -1; scope->earliest_time = -1;
scope->priv->dropped = 0;
scope->priv->processed = 0;
GST_OBJECT_UNLOCK (scope); GST_OBJECT_UNLOCK (scope);
} }
@ -1093,27 +1098,46 @@ gst_audio_visualizer_chain (GstPad * pad, GstObject * parent,
ts += gst_util_uint64_scale_int (dist, GST_SECOND, rate); ts += gst_util_uint64_scale_int (dist, GST_SECOND, rate);
} }
/* check for QoS, don't compute buffers that are known to be late */
if (GST_CLOCK_TIME_IS_VALID (ts)) { if (GST_CLOCK_TIME_IS_VALID (ts)) {
GstClockTime earliest_time;
gdouble proportion;
gint64 qostime; gint64 qostime;
gboolean need_skip;
qostime = qostime =
gst_segment_to_running_time (&scope->segment, GST_FORMAT_TIME, ts) + gst_segment_to_running_time (&scope->segment, GST_FORMAT_TIME, ts) +
scope->frame_duration; scope->frame_duration;
GST_OBJECT_LOCK (scope); GST_OBJECT_LOCK (scope);
/* check for QoS, don't compute buffers that are known to be late */ earliest_time = scope->earliest_time;
need_skip = scope->earliest_time != -1 && qostime <= scope->earliest_time; proportion = scope->proportion;
GST_OBJECT_UNLOCK (scope); GST_OBJECT_UNLOCK (scope);
if (need_skip) { if (GST_CLOCK_TIME_IS_VALID (earliest_time) && qostime <= earliest_time) {
GST_WARNING_OBJECT (scope, GstClockTime stream_time, jitter;
GstMessage *qos_msg;
GST_DEBUG_OBJECT (scope,
"QoS: skip ts: %" GST_TIME_FORMAT ", earliest: %" GST_TIME_FORMAT, "QoS: skip ts: %" GST_TIME_FORMAT ", earliest: %" GST_TIME_FORMAT,
GST_TIME_ARGS (qostime), GST_TIME_ARGS (scope->earliest_time)); GST_TIME_ARGS (qostime), GST_TIME_ARGS (earliest_time));
++scope->priv->dropped;
stream_time = gst_segment_to_stream_time (&scope->segment,
GST_FORMAT_TIME, ts);
jitter = GST_CLOCK_DIFF (qostime, earliest_time);
qos_msg = gst_message_new_qos (GST_OBJECT (scope), FALSE, qostime,
stream_time, ts, GST_BUFFER_DURATION (buffer));
gst_message_set_qos_values (qos_msg, jitter, proportion, 1000000);
gst_message_set_qos_stats (qos_msg, GST_FORMAT_BUFFERS,
scope->priv->processed, scope->priv->dropped);
gst_element_post_message (GST_ELEMENT (scope), qos_msg);
goto skip; goto skip;
} }
} }
++scope->priv->processed;
g_mutex_unlock (&scope->config_lock); g_mutex_unlock (&scope->config_lock);
ret = default_prepare_output_buffer (scope, &outbuf); ret = default_prepare_output_buffer (scope, &outbuf);
g_mutex_lock (&scope->config_lock); g_mutex_lock (&scope->config_lock);