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

add number of received packets to metadata

Browse Source
This commit is contained in:
babic_a
2020-04-16 12:32:55 +02:00
parent 75c28dfdd8
commit b7999b2cd1
2 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
core-writer/include/RingBuffer.hpp
+2
View File
@@ -41,6 +41,8 @@ struct UdpFrameMetadata
uint64_t recv_packets_2;
uint32_t daq_rec;
uint16_t n_recv_packets;
};
template <class T>
core-writer/src/module/UdpRecvModule.cpp
+5
View File
@@ -84,6 +84,7 @@ void UdpRecvModule::receive_thread(
auto metadata = make_shared<UdpFrameMetadata>();
metadata->frame_bytes_size = JUNGFRAU_DATA_BYTES_PER_FRAME;
metadata->pulse_id = 0;
metadata->n_recv_packets = 0;
char* frame_buffer = ring_buffer_.reserve(metadata);
@@ -116,6 +117,7 @@ void UdpRecvModule::receive_thread(
metadata = make_shared<UdpFrameMetadata>();
metadata->frame_bytes_size = JUNGFRAU_DATA_BYTES_PER_FRAME;
metadata->pulse_id = 0;
metadata->n_recv_packets = 0;
frame_buffer = ring_buffer_.reserve(metadata);
memset(frame_buffer, 0, JUNGFRAU_DATA_BYTES_PER_FRAME);
@@ -135,6 +137,8 @@ void UdpRecvModule::receive_thread(
packet_buffer.data,
JUNGFRAU_DATA_BYTES_PER_PACKET);
frame_metadata->n_recv_packets++;
if (packet_buffer.packetnum < 64) {
frame_metadata->recv_packets_1 ^=
(uint64_t)1 << packet_buffer.packetnum;
@@ -151,6 +155,7 @@ void UdpRecvModule::receive_thread(
metadata = make_shared<UdpFrameMetadata>();
metadata->frame_bytes_size = JUNGFRAU_DATA_BYTES_PER_FRAME;
metadata->pulse_id = 0;
metadata->n_recv_packets = 0;
frame_buffer = ring_buffer_.reserve(metadata);
memset(frame_buffer, 0, JUNGFRAU_DATA_BYTES_PER_FRAME);