From aeb998cd4df917222b0716e61b1345399ebc786a Mon Sep 17 00:00:00 2001 From: Andrej Babic Date: Mon, 4 May 2020 12:32:32 +0200 Subject: [PATCH] Make sf_buffer code more compact --- sf-buffer/src/sf_buffer.cpp | 10 ++++------ 1 file changed, 4 insertions(+), 6 deletions(-) diff --git a/sf-buffer/src/sf_buffer.cpp b/sf-buffer/src/sf_buffer.cpp index 04da883..400166f 100644 --- a/sf-buffer/src/sf_buffer.cpp +++ b/sf-buffer/src/sf_buffer.cpp @@ -69,24 +69,22 @@ int main (int argc, char *argv[]) { writer.add_scalar_metadata("daq_rec"); writer.add_scalar_metadata("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( "pulse_id", &(metadata->pulse_id));