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

Make sf_buffer code more compact

Browse Source
This commit is contained in:
babic_a
2020-05-04 12:32:32 +02:00
parent 17431adf71
commit aeb998cd4d
1 changed files with 4 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
sf-buffer/src/sf_buffer.cpp
+4 -6
View File
@@ -69,24 +69,22 @@ int main (int argc, char *argv[]) {
writer.add_scalar_metadata<uint32_t>("daq_rec");
writer.add_scalar_metadata<uint16_t>("received_packets");
while (true) {
auto slot_id = queue.read();
int slot_id;
if (slot_id == -1){
while (true) {
if ((slot_id = queue.read()) == -1){
this_thread::sleep_for(chrono::milliseconds(BUFFER_QUEUE_RETRY_MS));
continue;
}
ModuleFrame* metadata = queue.get_metadata_buffer(slot_id);
char* data = queue.get_data_buffer(slot_id);
auto pulse_id = metadata->pulse_id;
writer.set_pulse_id(pulse_id);
writer.set_pulse_id(pulse_id);
writer.write_data(data);
// TODO: Combine all this into 1 struct.
writer.write_scalar_metadata<uint64_t>(
"pulse_id", &(metadata->pulse_id));