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

Add primitive statistics

Browse Source
This commit is contained in:
babic_a
2020-04-15 17:30:26 +02:00
parent 020c6a46b0
commit a6300035d9
1 changed files with 23 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
sf-buffer/src/sf_buffer.cpp
+23
View File
@@ -38,6 +38,11 @@ int main (int argc, char *argv[]) {
string current_file;
H5Writer writer("");
uint64_t n_stat_out(0);
uint64_t n_frames_with_missing_packets = 0;
uint64_t n_missed_frames = 0;
uint64_t last_pulse_id = 0;
while (true) {
auto data = ring_buffer.read();
@@ -95,5 +100,23 @@ int main (int argc, char *argv[]) {
"uint64", "little");
ring_buffer.release(data.first->buffer_slot_index);
// TODO: Make real statistics, please.
n_stat_out++;
if (data.first->recv_packets_2 > 0 || data.first->recv_packets_1 > 0) {
n_frames_with_missing_packets++;
}
n_missed_frames += (pulse_id - last_pulse_id) - 1;
if (n_stat_out == 500) {
cout << "frames_with_missing_packets " << n_frames_with_missing_packets;
cout << " n_missed_frames " << n_missed_frames;
n_stat_out = 0;
n_frames_with_missing_packets = 0;
n_missed_frames = 0;
}
}
}