diff --git a/jf-live-writer/include/BufferStats.hpp b/jf-live-writer/include/WriterStats.hpp similarity index 75% rename from jf-live-writer/include/BufferStats.hpp rename to jf-live-writer/include/WriterStats.hpp index 3aff6cb..cb023a7 100644 --- a/jf-live-writer/include/BufferStats.hpp +++ b/jf-live-writer/include/WriterStats.hpp @@ -6,12 +6,11 @@ #define SF_DAQ_BUFFER_FRAMESTATS_HPP -class BufferStats { +class WriterStats { const std::string detector_name_; - const int module_id_; size_t stats_modulo_; - int frames_counter_; + int image_counter_; uint32_t total_buffer_write_us_; uint32_t max_buffer_write_us_; std::chrono::time_point stats_interval_start_; @@ -20,12 +19,11 @@ class BufferStats { void print_stats(); public: - BufferStats( + WriterStats( const std::string &detector_name, - const int module_id, const size_t stats_modulo); - void start_frame_write(); - void end_frame_write(); + void start_image_write(); + void end_image_write(); }; diff --git a/jf-live-writer/src/BufferStats.cpp b/jf-live-writer/src/WriterStats.cpp similarity index 66% rename from jf-live-writer/src/BufferStats.cpp rename to jf-live-writer/src/WriterStats.cpp index 173a35c..1d67947 100644 --- a/jf-live-writer/src/BufferStats.cpp +++ b/jf-live-writer/src/WriterStats.cpp @@ -1,35 +1,33 @@ #include -#include "BufferStats.hpp" +#include "WriterStats.hpp" using namespace std; using namespace chrono; -BufferStats::BufferStats( +WriterStats::WriterStats( const string& detector_name, - const int module_id, const size_t stats_modulo) : detector_name_(detector_name), - module_id_(module_id), stats_modulo_(stats_modulo) { reset_counters(); } -void BufferStats::reset_counters() +void WriterStats::reset_counters() { - frames_counter_ = 0; + image_counter_ = 0; total_buffer_write_us_ = 0; max_buffer_write_us_ = 0; } -void BufferStats::start_frame_write() +void WriterStats::start_image_write() { stats_interval_start_ = steady_clock::now(); } -void BufferStats::end_frame_write() +void WriterStats::end_image_write() { - frames_counter_++; + image_counter_++; uint32_t write_us_duration = duration_cast( steady_clock::now()-stats_interval_start_).count(); @@ -37,15 +35,15 @@ void BufferStats::end_frame_write() total_buffer_write_us_ += write_us_duration; max_buffer_write_us_ = max(max_buffer_write_us_, write_us_duration); - if (frames_counter_ == stats_modulo_) { + if (image_counter_ == stats_modulo_) { print_stats(); reset_counters(); } } -void BufferStats::print_stats() +void WriterStats::print_stats() { - float avg_buffer_write_us = total_buffer_write_us_ / frames_counter_; + float avg_buffer_write_us = total_buffer_write_us_ / image_counter_; uint64_t timestamp = time_point_cast( system_clock::now()).time_since_epoch().count(); @@ -53,9 +51,9 @@ void BufferStats::print_stats() // Output in InfluxDB line protocol cout << "jf_buffer_writer"; cout << ",detector_name=" << detector_name_; - cout << ",module_name=M" << module_id_; cout << " "; - cout << "avg_buffer_write_us=" << avg_buffer_write_us; + cout << "n_written_images=" << image_counter_ << "i"; + cout << " ,avg_buffer_write_us=" << avg_buffer_write_us; cout << ",max_buffer_write_us=" << max_buffer_write_us_ << "i"; cout << " "; cout << timestamp;