diff --git a/core-buffer/src/UdpRecvModule.cpp b/core-buffer/src/UdpRecvModule.cpp index 5a6a6ba..49a77fc 100644 --- a/core-buffer/src/UdpRecvModule.cpp +++ b/core-buffer/src/UdpRecvModule.cpp @@ -106,8 +106,6 @@ void UdpRecvModule::receive_thread( if (frame_metadata->pulse_id == 0) { frame_metadata->frame_index = packet_buffer.framenum; frame_metadata->pulse_id = packet_buffer.bunchid; - frame_metadata->recv_packets_1 = ~(uint64_t)0; - frame_metadata->recv_packets_2 = ~(uint64_t)0; frame_metadata->daq_rec = packet_buffer.debug; // Packet from new frame, while we lost the last packet of // previous frame. @@ -124,8 +122,6 @@ void UdpRecvModule::receive_thread( frame_metadata->frame_index = packet_buffer.framenum; frame_metadata->pulse_id = packet_buffer.bunchid; - frame_metadata->recv_packets_1 = ~(uint64_t)0; - frame_metadata->recv_packets_2 = ~(uint64_t)0; frame_metadata->daq_rec = packet_buffer.debug; } @@ -139,14 +135,6 @@ void UdpRecvModule::receive_thread( frame_metadata->n_recv_packets++; - if (packet_buffer.packetnum < 64) { - frame_metadata->recv_packets_1 ^= - (uint64_t)1 << packet_buffer.packetnum; - } else { - frame_metadata->recv_packets_2 ^= - (uint64_t)1 << (packet_buffer.packetnum - 64); - } - // Frame finished with last packet. if (packet_buffer.packetnum == JUNGFRAU_N_PACKETS_PER_FRAME-1) { diff --git a/core-writer/include/RingBuffer.hpp b/core-writer/include/RingBuffer.hpp index eb50abc..38c9442 100644 --- a/core-writer/include/RingBuffer.hpp +++ b/core-writer/include/RingBuffer.hpp @@ -36,12 +36,7 @@ struct UdpFrameMetadata uint64_t pulse_id; uint64_t frame_index; - - uint64_t recv_packets_1; - uint64_t recv_packets_2; - uint32_t daq_rec; - uint16_t n_recv_packets; };