sf-daq/sf_daq_buffer
0
0
Fork 0
mirror of https://github.com/paulscherrerinstitute/sf_daq_buffer.git synced 2026-05-04 16:44:12 +02:00
Code Issues Packages Projects Releases Wiki Activity

Fixed InfluxDB statistics on jf-buffer-writer

Browse Source
This commit is contained in:
babic_a
2020-10-01 10:02:58 +02:00
parent d776e78ab0
commit 2399b8d59e
3 changed files with 26 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
jf-buffer-writer/src/BufferStats.cpp
+19 -6
View File
@@ -4,9 +4,13 @@
using namespace std;
using namespace chrono;
BufferStats::BufferStats(const string& source_name, const size_t stats_modulo) :
source_name_(source_name),
stats_modulo_(stats_modulo)
BufferStats::BufferStats(
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();
}
@@ -43,8 +47,17 @@ void BufferStats::print_stats()
{
float avg_buffer_write_us = total_buffer_write_us_ / frames_counter_;
cout << "sf_buffer:device_name " << source_name_;
cout << " sf_buffer:avg_buffer_write_us " << avg_buffer_write_us;
cout << " sf_buffer:max_buffer_write_us " << max_buffer_write_us_;
uint64_t timestamp = time_point_cast<nanoseconds>(
system_clock::now()).time_since_epoch().count();
// 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 << ",max_buffer_write_us=" << max_buffer_write_us_ << "i";
cout << " ";
cout << timestamp;
cout << endl;
}