X-Git-Url: https://git.sesse.net/?a=blobdiff_plain;f=futatabi%2Fmain.cpp;h=73df3aa032f39598f497daeaa8eab7b17d33f8d4;hb=20ea8ae661b78d88f360b8f582d2576c9c1def4d;hp=486bcfff213654bf409691ac4212bd4acdaaa44c;hpb=e0d676aec4f44252170da8e1c8824421ac6976ff;p=nageru

diff --git a/futatabi/main.cpp b/futatabi/main.cpp
index 486bcff..73df3aa 100644
--- a/futatabi/main.cpp
+++ b/futatabi/main.cpp
@@ -71,6 +71,7 @@ vector<FrameOnDisk> frames[MAX_STREAMS];  // Under frame_mu.
 vector<string> frame_filenames;  // Under frame_mu.
 
 atomic<int64_t> metric_received_frames[MAX_STREAMS]{{0}};
+Summary metric_received_frame_size_bytes;
 
 namespace {
 
@@ -211,6 +212,7 @@ int main(int argc, char **argv)
 	}
 
 	avformat_network_init();
+	global_metrics.set_prefix("futatabi");
 	global_httpd = new HTTPD;
 
 	QCoreApplication::setAttribute(Qt::AA_ShareOpenGLContexts, true);
@@ -459,6 +461,7 @@ void record_thread_func()
 	for (unsigned i = 0; i < MAX_STREAMS; ++i) {
 		global_metrics.add("received_frames", {{ "stream", to_string(i) }}, &metric_received_frames[i]);
 	}
+	global_metrics.add("received_frame_size_bytes", &metric_received_frame_size_bytes);
 
 	if (global_flags.stream_source.empty() || global_flags.stream_source == "/dev/null") {
 		// Save the user from some repetitive messages.
@@ -498,6 +501,7 @@ void record_thread_func()
 			}
 
 			++metric_received_frames[pkt.stream_index];
+			metric_received_frame_size_bytes.count_event(pkt.size);
 
 			// Convert pts to our own timebase.
 			AVRational stream_timebase = format_ctx->streams[pkt.stream_index]->time_base;