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

Fix streamer sync attempts for loop

Browse Source
This commit is contained in:
babic_a
2021-01-13 16:18:47 +01:00
parent cb9ddb3693
commit e9bb30eac8
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
sf-stream/src/ZmqPulseSyncReceiver.cpp
+2 -2
View File
@@ -55,7 +55,7 @@ uint64_t ZmqPulseSyncReceiver::get_next_pulse_id() const
return pulses[0];
}
for (int i_sync; i_sync < SYNC_RETRY_LIMIT; i_sync++) {
for (int i_sync=0; i_sync < SYNC_RETRY_LIMIT; i_sync++) {
cout << "Sync attempt " << i_sync << endl;
uint64_t min_pulse_id = 0;
@@ -69,7 +69,7 @@ uint64_t ZmqPulseSyncReceiver::get_next_pulse_id() const
auto max_diff = max_pulse_id - min_pulse_id;
if (max_diff > PULSE_OFFSET_LIMIT) {
stringstream err_msg;
err_msg << "[ZmqLiveReceiver::get_next_pulse_id]";
err_msg << "[ZmqPulseSyncReceiver::get_next_pulse_id]";
err_msg << " PULSE_OFFSET_LIMIT exceeded.";
err_msg << " max_diff=" << max_diff << " pulses.";