mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-11-28 20:51:13 +00:00
Code Issues 1 Projects Releases Wiki Activity

multiqueue: Add stats property

Browse source 
The returned "stats" structure contains, for now, one array called
"queues" with one GstStructure per internal queue, containing said
queue's current level of bytes, buffers, and time.
This commit is contained in:
Vivia Nikolaidou 2020-04-09 13:12:22 +03:00
parent c18f9d4ad4
commit 74938f07c2
1 changed files with 61 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

61
plugins/elements/gstmultiqueue.c
View file

@ -273,6 +273,7 @@ enum
PROP_USE_INTERLEAVE,
PROP_UNLINKED_CACHE_TIME,
PROP_MINIMUM_INTERLEAVE,
PROP_STATS,
PROP_LAST
};
@ -657,6 +658,25 @@ gst_multi_queue_class_init (GstMultiQueueClass * klass)
G_PARAM_READWRITE | GST_PARAM_MUTABLE_PLAYING |
G_PARAM_STATIC_STRINGS));
/**
* GstMultiQueue:stats:
*
* Various #GstMultiQueue statistics. This property returns a #GstStructure
* with name "application/x-gst-multi-queue-stats" with the following fields:
*
* - "queues" GST_TYPE_ARRAY Contains one GstStructure named "queue_%d"
* (where %d is the queue's ID) per internal queue:
* - "buffers" G_TYPE_UINT The queue's current level of buffers
* - "bytes" G_TYPE_UINT The queue's current level of bytes
* - "time" G_TYPE_UINT64 The queue's current level of time
*
* Since: 1.18
*/
g_object_class_install_property (gobject_class, PROP_STATS,
g_param_spec_boxed ("stats", "Stats",
"Multiqueue Statistics",
GST_TYPE_STRUCTURE, G_PARAM_READABLE | G_PARAM_STATIC_STRINGS));
gobject_class->finalize = gst_multi_queue_finalize;
gst_element_class_set_static_metadata (gstelement_class,
@ -850,6 +870,44 @@ gst_multi_queue_set_property (GObject * object, guint prop_id,
}
}
/* Called with mutex held */
static GstStructure *
gst_multi_queue_get_stats (GstMultiQueue * mq)
{
GstStructure *ret =
gst_structure_new_empty ("application/x-gst-multi-queue-stats");
GList *tmp;
GstSingleQueue *sq;
if (mq->queues != NULL) {
GValue queues = G_VALUE_INIT;
GValue v = G_VALUE_INIT;
g_value_init (&queues, GST_TYPE_ARRAY);
for (tmp = mq->queues; tmp; tmp = g_list_next (tmp)) {
GstDataQueueSize level;
GstStructure *s;
gchar *id;
g_value_init (&v, GST_TYPE_STRUCTURE);
sq = (GstSingleQueue *) tmp->data;
gst_data_queue_get_level (sq->queue, &level);
id = g_strdup_printf ("queue_%d", sq->id);
s = gst_structure_new (id,
"buffers", G_TYPE_UINT, level.visible,
"bytes", G_TYPE_UINT, level.bytes,
"time", G_TYPE_UINT64, sq->cur_time, NULL);
g_value_take_boxed (&v, s);
gst_value_array_append_and_take_value (&queues, &v);
g_free (id);
}
gst_structure_take_value (ret, "queues", &queues);
}
return ret;
}
static void
gst_multi_queue_get_property (GObject * object, guint prop_id,
GValue * value, GParamSpec * pspec)
@ -906,6 +964,9 @@ gst_multi_queue_get_property (GObject * object, guint prop_id,
case PROP_MINIMUM_INTERLEAVE:
g_value_set_uint64 (value, mq->min_interleave_time);
break;
case PROP_STATS:
g_value_take_boxed (value, gst_multi_queue_get_stats (mq));
break;
default:
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
break;