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

Made the loop a bit more bearable

Browse Source
This commit is contained in:
babic_a
2020-04-23 12:51:43 +02:00
parent 81077c395a
commit 926a36a4f8
1 changed files with 13 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
sf-writer/sf_h5_writer.cpp
+13 -9
View File
@@ -160,16 +160,19 @@ int main (int argc, char *argv[])
{
auto start_time = chrono::steady_clock::now();
auto received_data = ring_buffer.read();
pair<shared_ptr<DetectorFrame>, char *> received_data;
// .first is nullptr if ringbuffer is empty.
if(received_data.first == nullptr) {
this_thread::sleep_for(chrono::milliseconds(
config::ring_buffer_read_retry_interval));
while (true)
{
received_data = ring_buffer.read();
// TODO: Very ugly hack. Make it nicer.
current_pulse_id--;
continue;
// .first is nullptr if ringbuffer is empty.
if(received_data.first == nullptr) {
this_thread::sleep_for(chrono::milliseconds(
config::ring_buffer_read_retry_interval));
continue;
}
break;
}
auto metadata = received_data.first;
@@ -178,7 +181,8 @@ int main (int argc, char *argv[])
cout << "Received pulse_id " << metadata->pulse_id << endl;
if (metadata->pulse_id != current_pulse_id) {
cout << "ERROR expecting " << current_pulse_id << endl;
cout << "ERROR expecting " << current_pulse_id;
cout << " diff " << current_pulse_id - metadata->pulse_id << endl;
}
// TODO: Write to H5