From d1d0cbdb94ba58beb3e2b4180a59d0a62c7171fc Mon Sep 17 00:00:00 2001
From: Andrej Babic <andrej.babic@psi.ch>
Date: Mon, 4 May 2020 14:12:01 +0200
Subject: [PATCH] Add n_corrupted_frames to sf_buffer metric

---
 sf-buffer/src/sf_buffer.cpp | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/sf-buffer/src/sf_buffer.cpp b/sf-buffer/src/sf_buffer.cpp
index 284ed50..96ca3f2 100644
--- a/sf-buffer/src/sf_buffer.cpp
+++ b/sf-buffer/src/sf_buffer.cpp
@@ -58,6 +58,7 @@ int main (int argc, char *argv[]) {
     uint64_t stats_counter(0);
     uint64_t n_missed_packets = 0;
     uint64_t n_missed_frames = 0;
+    uint64_t n_corrupted_frames = 0;
     uint64_t last_pulse_id = 0;
 
     BufferH5Writer writer(device_name, root_folder);
@@ -92,6 +93,7 @@ int main (int argc, char *argv[]) {
         if (metadata->n_received_packets < JUNGFRAU_N_PACKETS_PER_FRAME) {
             n_missed_packets +=
                     JUNGFRAU_N_PACKETS_PER_FRAME - metadata->n_received_packets;
+            n_corrupted_frames++;
         }
 
         if (last_pulse_id>0) {
@@ -104,10 +106,12 @@ int main (int argc, char *argv[]) {
             cout << " sf_buffer:pulse_id " << pulse_id;
             cout << " sf_buffer:n_missed_frames " << n_missed_frames;
             cout << " sf_buffer:n_missed_packets " << n_missed_packets;
+            cout << " sf_buffer:n_corrupted_frames " << n_corrupted_frames;
             cout << endl;
 
             stats_counter = 0;
             n_missed_packets = 0;
+            n_corrupted_frames = 0;
             n_missed_frames = 0;
         }
     }