FaSTTUBe/GST-Tensordecoder-ov_ep
37
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fpsdisplaysink: get rendered and dropped stats from QOS messages

Browse Source 
Use QOS messages to update rendered and dropped frame stats. This is
the only accurate method. The old method didn't take max-lateness and
latency into account.
This commit is contained in:
Alessandro Decina 2015-06-18 12:59:18 +07:00
parent 7823e6d606
commit bdcaf8f5ee
1 changed files with 40 additions and 38 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

60
gst/debugutils/fpsdisplaysink.c
View File

@ -101,6 +101,8 @@ static void fps_display_sink_set_property (GObject * object, guint prop_id,
static void fps_display_sink_get_property (GObject * object, guint prop_id, static void fps_display_sink_get_property (GObject * object, guint prop_id,
GValue * value, GParamSpec * pspec); GValue * value, GParamSpec * pspec);
static void fps_display_sink_dispose (GObject * object); static void fps_display_sink_dispose (GObject * object);
static void fps_display_sink_handle_message (GstBin * bin,
GstMessage * message);
static gboolean display_current_fps (gpointer data); static gboolean display_current_fps (gpointer data);
@ -113,6 +115,7 @@ fps_display_sink_class_init (GstFPSDisplaySinkClass * klass)
{ {
GObjectClass *gobject_klass = G_OBJECT_CLASS (klass); GObjectClass *gobject_klass = G_OBJECT_CLASS (klass);
GstElementClass *gstelement_klass = GST_ELEMENT_CLASS (klass); GstElementClass *gstelement_klass = GST_ELEMENT_CLASS (klass);
GstBinClass *bin_class = GST_BIN_CLASS (klass);
parent_class = g_type_class_peek_parent (klass); parent_class = g_type_class_peek_parent (klass);
@ -120,6 +123,8 @@ fps_display_sink_class_init (GstFPSDisplaySinkClass * klass)
gobject_klass->get_property = fps_display_sink_get_property; gobject_klass->get_property = fps_display_sink_get_property;
gobject_klass->dispose = fps_display_sink_dispose; gobject_klass->dispose = fps_display_sink_dispose;
bin_class->handle_message = fps_display_sink_handle_message;
g_object_class_install_property (gobject_klass, PROP_SYNC, g_object_class_install_property (gobject_klass, PROP_SYNC,
g_param_spec_boolean ("sync", g_param_spec_boolean ("sync",
"Sync", "Sync on the clock (if the internally used sink doesn't " "Sync", "Sync on the clock (if the internally used sink doesn't "
@ -220,38 +225,13 @@ on_video_sink_data_flow (GstPad * pad, GstPadProbeInfo * info,
GstMiniObject *mini_obj = GST_PAD_PROBE_INFO_DATA (info); GstMiniObject *mini_obj = GST_PAD_PROBE_INFO_DATA (info);
GstFPSDisplaySink *self = GST_FPS_DISPLAY_SINK (user_data); GstFPSDisplaySink *self = GST_FPS_DISPLAY_SINK (user_data);
#if 0
if (GST_IS_BUFFER (mini_obj)) { if (GST_IS_BUFFER (mini_obj)) {
GstBuffer *buf = GST_BUFFER_CAST (mini_obj);
if (GST_CLOCK_TIME_IS_VALID (self->next_ts)) {
if (GST_BUFFER_TIMESTAMP (buf) <= self->next_ts) {
self->frames_rendered++;
} else {
GST_WARNING_OBJECT (self, "dropping frame : ts %" GST_TIME_FORMAT
" < expected_ts %" GST_TIME_FORMAT,
GST_TIME_ARGS (GST_BUFFER_TIMESTAMP (buf)),
GST_TIME_ARGS (self->next_ts));
self->frames_dropped++;
}
} else {
self->frames_rendered++;
}
} else
#endif
if (GST_IS_EVENT (mini_obj)) {
GstEvent *ev = GST_EVENT_CAST (mini_obj);
if (GST_EVENT_TYPE (ev) == GST_EVENT_QOS) {
GstClockTimeDiff diff;
GstClockTime ts; GstClockTime ts;
gst_event_parse_qos (ev, NULL, NULL, &diff, &ts); /* assume the frame is going to be rendered. If it isnt', we'll get a qos
if (diff <= 0.0) { * message and reset ->frames_rendered from there.
*/
g_atomic_int_inc (&self->frames_rendered); g_atomic_int_inc (&self->frames_rendered);
} else {
g_atomic_int_inc (&self->frames_dropped);
}
ts = gst_util_get_timestamp (); ts = gst_util_get_timestamp ();
if (G_UNLIKELY (!GST_CLOCK_TIME_IS_VALID (self->start_ts))) { if (G_UNLIKELY (!GST_CLOCK_TIME_IS_VALID (self->start_ts))) {
@ -262,7 +242,7 @@ on_video_sink_data_flow (GstPad * pad, GstPadProbeInfo * info,
self->interval_ts = ts; self->interval_ts = ts;
} }
} }
}
return GST_PAD_PROBE_OK; return GST_PAD_PROBE_OK;
} }
@ -698,6 +678,28 @@ fps_display_sink_change_state (GstElement * element, GstStateChange transition)
return ret; return ret;
} }
static void
fps_display_sink_handle_message (GstBin * bin, GstMessage * message)
{
GstFPSDisplaySink *self = (GstFPSDisplaySink *) bin;
if (GST_MESSAGE_TYPE (message) == GST_MESSAGE_QOS) {
GstFormat format;
guint64 rendered, dropped;
gst_message_parse_qos_stats (message, &format, &rendered, &dropped);
if (format != GST_FORMAT_UNDEFINED) {
if (rendered != -1)
g_atomic_int_set (&self->frames_rendered, rendered);
if (dropped != -1)
g_atomic_int_set (&self->frames_dropped, dropped);
}
}
GST_BIN_CLASS (parent_class)->handle_message (bin, message);
}
GType GType
fps_display_sink_get_type (void) fps_display_sink_get_type (void)
{ {