From 1761f362df86af2bcd5e8000d39d649b78558a46 Mon Sep 17 00:00:00 2001
From: Andrej Babic <andrej.babic@psi.ch>
Date: Wed, 15 Apr 2020 15:28:31 +0200
Subject: [PATCH] Add daq_rec value

---
 core-writer/include/RingBuffer.hpp       | 2 ++
 core-writer/src/module/UdpRecvModule.cpp | 5 +++--
 2 files changed, 5 insertions(+), 2 deletions(-)

diff --git a/core-writer/include/RingBuffer.hpp b/core-writer/include/RingBuffer.hpp
index b002fe5..34557f6 100644
--- a/core-writer/include/RingBuffer.hpp
+++ b/core-writer/include/RingBuffer.hpp
@@ -39,6 +39,8 @@ struct UdpFrameMetadata
 
     uint64_t recv_packets_1;
     uint64_t recv_packets_2;
+
+    uint32_t daq_rec;
 };
 
 template <class T>
diff --git a/core-writer/src/module/UdpRecvModule.cpp b/core-writer/src/module/UdpRecvModule.cpp
index 0c33ead..1f2769f 100644
--- a/core-writer/src/module/UdpRecvModule.cpp
+++ b/core-writer/src/module/UdpRecvModule.cpp
@@ -108,8 +108,9 @@ void UdpRecvModule::receive_thread(
                 current_metadata->frame_index = packet_buffer.framenum;
                 current_metadata->pulse_id = packet_buffer.bunchid;
                 current_metadata->frame_bytes_size = JUNGFRAU_DATA_BYTES_PER_FRAME;
-                current_metadata->recv_packets_1 = 0;
-                current_metadata->recv_packets_2 = 0;
+                current_metadata->recv_packets_1 = ~(uint64_t)0;
+                current_metadata->recv_packets_2 = ~(uint64_t)0;
+                current_metadata->daq_rec = packet_buffer.debug;
 
                 frame_buffer = ring_buffer_.reserve(metadata);
                 memset(frame_buffer, 0, JUNGFRAU_DATA_BYTES_PER_FRAME);