X-Git-Url: https://git.sesse.net/?a=blobdiff_plain;f=futatabi%2Fmain.cpp;h=3b6f8e3044b804d637bff98f026b1795db9aaace;hb=94a228f7473325130704e96c82937b690703615b;hp=52cdb80664379e5014fb0f5ea673234e087f14b8;hpb=ed041ec8c0fa1dd31fd3c3ac053da13519c524c3;p=nageru diff --git a/futatabi/main.cpp b/futatabi/main.cpp index 52cdb80..3b6f8e3 100644 --- a/futatabi/main.cpp +++ b/futatabi/main.cpp @@ -71,6 +71,7 @@ vector frames[MAX_STREAMS]; // Under frame_mu. vector frame_filenames; // Under frame_mu. atomic metric_received_frames[MAX_STREAMS]{{0}}; +Summary metric_received_frame_size_bytes; namespace { @@ -213,6 +214,7 @@ int main(int argc, char **argv) avformat_network_init(); global_metrics.set_prefix("futatabi"); global_httpd = new HTTPD; + global_metrics.remove("num_connected_multicam_clients"); QCoreApplication::setAttribute(Qt::AA_ShareOpenGLContexts, true); @@ -460,6 +462,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. @@ -499,6 +502,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;