summaryrefslogtreecommitdiffstats
path: root/gst/udp/gstmultiudpsink.c
diff options
context:
space:
mode:
Diffstat (limited to 'gst/udp/gstmultiudpsink.c')
-rw-r--r--gst/udp/gstmultiudpsink.c11
1 files changed, 9 insertions, 2 deletions
diff --git a/gst/udp/gstmultiudpsink.c b/gst/udp/gstmultiudpsink.c
index 5883e529..ed9be9e1 100644
--- a/gst/udp/gstmultiudpsink.c
+++ b/gst/udp/gstmultiudpsink.c
@@ -228,6 +228,7 @@ gst_multiudpsink_render (GstBaseSink * bsink, GstBuffer * buffer)
}
} else {
client->bytes_sent += ret;
+ client->packets_sent++;
break;
}
}
@@ -465,8 +466,9 @@ gst_multiudpsink_get_stats (GstMultiUDPSink * sink, const gchar * host,
GValue value = { 0 };
- /* Result is a value array of (bytes_sent, connect_time, disconnect_time) */
- result = g_value_array_new (3);
+ /* Result is a value array of (bytes_sent, packets_sent,
+ * connect_time, disconnect_time), all as uint64 */
+ result = g_value_array_new (4);
g_value_init (&value, G_TYPE_UINT64);
g_value_set_uint64 (&value, client->bytes_sent);
@@ -474,6 +476,11 @@ gst_multiudpsink_get_stats (GstMultiUDPSink * sink, const gchar * host,
g_value_unset (&value);
g_value_init (&value, G_TYPE_UINT64);
+ g_value_set_uint64 (&value, client->packets_sent);
+ result = g_value_array_append (result, &value);
+ g_value_unset (&value);
+
+ g_value_init (&value, G_TYPE_UINT64);
g_value_set_uint64 (&value, client->connect_time);
result = g_value_array_append (result, &value);
g_value_unset (&value);