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

Recv uses correct form of buffer

Browse Source
This commit is contained in:
babic_a
2020-04-29 15:08:19 +02:00
parent bf595870d6
commit e1ab75fec4
1 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
sf-buffer/src/sf_writer.cpp
+7 -5
View File
@@ -9,6 +9,8 @@
#include "SFWriter.hpp"
#include <config.hpp>
#include <FastQueue.hpp>
#include <cstring>
#include "date.h"
using namespace std;
using namespace core_buffer;
@@ -78,17 +80,17 @@ void receive_replay(
// Initialize buffers in first iteration for each pulse_id.
if (i_module == 0) {
frame_meta_buffer->pulse_id =
frame_meta_buffer->pulse_id[i_buffer] =
module_meta_buffer->pulse_id;
frame_meta_buffer->frame_index =
frame_meta_buffer->frame_index[i_buffer] =
module_meta_buffer->frame_index;
frame_meta_buffer->daq_rec =
frame_meta_buffer->daq_rec[i_buffer] =
module_meta_buffer->daq_rec;
frame_meta_buffer->n_received_packets =
frame_meta_buffer->n_received_packets[i_buffer] =
module_meta_buffer->n_received_packets;
}
if (frame_meta_buffer->pulse_id !=
if (frame_meta_buffer->pulse_id[i_buffer] !=
module_meta_buffer->pulse_id) {
throw runtime_error("Unexpected pulse_id received.");
}