baresip 0.4.10

1 files changed, 79 insertions, 0 deletions

diff --git a/src/metric.c b/src/metric.c
new file mode 100644
index 0000000..8cc0b18
--- /dev/null
+++ b/src/metric.c
@@ -0,0 +1,79 @@
+/**
+ * @file metric.c  Metrics for media transmit/receive
+ *
+ * Copyright (C) 2010 Creytiv.com
+ */
+#include <re.h>
+#include <baresip.h>
+#include "core.h"
+
+
+enum {TMR_INTERVAL = 3};
+static void tmr_handler(void *arg)
+{
+	struct metric *metric = arg;
+	const uint64_t now = tmr_jiffies();
+	uint32_t diff;
+
+	tmr_start(&metric->tmr, TMR_INTERVAL * 1000, tmr_handler, metric);
+
+ 	if (now <= metric->ts_last)
+		return;
+
+	if (metric->ts_last) {
+		uint32_t bytes = metric->n_bytes - metric->n_bytes_last;
+		diff = (uint32_t)(now - metric->ts_last);
+		metric->cur_bitrate = 1000 * 8 * bytes / diff;
+	}
+
+	/* Update counters */
+	metric->ts_last = now;
+	metric->n_bytes_last = metric->n_bytes;
+}
+
+
+static void metric_start(struct metric *metric)
+{
+	if (metric->started)
+		return;
+
+	metric->ts_start = tmr_jiffies();
+	tmr_start(&metric->tmr, 1, tmr_handler, metric);
+
+	metric->started = true;
+}
+
+
+void metric_reset(struct metric *metric)
+{
+	if (!metric)
+		return;
+
+	tmr_cancel(&metric->tmr);
+}
+
+
+void metric_add_packet(struct metric *metric, size_t packetsize)
+{
+	if (!metric)
+		return;
+
+	if (!metric->started)
+		metric_start(metric);
+
+	metric->n_bytes += (uint32_t)packetsize;
+	metric->n_packets++;
+}
+
+
+uint32_t metric_avg_bitrate(const struct metric *metric)
+{
+	int diff;
+
+	if (!metric || !metric->ts_start)
+		return 0;
+
+	diff = (int)(tmr_jiffies() - metric->ts_start);
+
+	return 1000 * 8 * metric->n_bytes / diff;
+}