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

Remove individual packet tracking

Browse Source
This commit is contained in:
babic_a
2020-04-17 14:57:33 +02:00
parent ced9435d6e
commit cb6075560d
2 changed files with 0 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files
core-buffer/src/UdpRecvModule.cpp
-12
View File
@@ -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)
{
core-writer/include/RingBuffer.hpp
-5
View File
@@ -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;
};