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

Iteration over the specified modules instead of all

Browse Source 
Left over from the development process where we used always
the 16M.
This commit is contained in:
babic_a
2020-06-18 13:48:49 +02:00
parent 68e2193beb
commit ed23b58332
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
sf-stream/src/ZmqLiveReceiver.cpp
+6 -2
View File
@@ -98,7 +98,9 @@ uint64_t ZmqLiveReceiver::align_modules(ModuleFrameBuffer *meta, char *data)
uint64_t min_pulse_id = numeric_limits<uint64_t>::max();
// First pass - determine current min and max pulse_id.
for (auto& module_meta : meta->module) {
for (size_t i_module = 0; i_module < n_modules_; i_module++) {
auto& module_meta = meta->module[i_module];
min_pulse_id = min(min_pulse_id, module_meta.pulse_id);
max_pulse_id = max(max_pulse_id, module_meta.pulse_id);
}
@@ -111,7 +113,9 @@ uint64_t ZmqLiveReceiver::align_modules(ModuleFrameBuffer *meta, char *data)
err_msg << " PULSE_OFFSET_LIMIT exceeded.";
err_msg << " Modules out of sync for " << max_diff << " pulses.";
for (auto& module_meta : meta->module) {
for (size_t i_module = 0; i_module < n_modules_; i_module++) {
auto& module_meta = meta->module[i_module];
err_msg << " (" << module_meta.module_id << ", ";
err_msg << module_meta.pulse_id << "),";
}