From 8805c6a923fa4b4015cc09152455db8035c4b073 Mon Sep 17 00:00:00 2001 From: Andrej Babic Date: Sun, 19 Apr 2020 23:37:23 +0200 Subject: [PATCH] Adjust to new interface to write metadata --- sf-buffer/src/sf_buffer.cpp | 27 +++++++++++++++++++++------ 1 file changed, 21 insertions(+), 6 deletions(-) diff --git a/sf-buffer/src/sf_buffer.cpp b/sf-buffer/src/sf_buffer.cpp index 659bbfe..98ba917 100644 --- a/sf-buffer/src/sf_buffer.cpp +++ b/sf-buffer/src/sf_buffer.cpp @@ -58,14 +58,29 @@ int main (int argc, char *argv[]) { } auto pulse_id = data.first->pulse_id; - writer.set_pulse_id(pulse_id); + writer.write_data(data.second); - writer.write_metadata("pulse_id", data.first->pulse_id); - writer.write_metadata("frame_id", data.first->frame_index); - writer.write_metadata("daq_rec", data.first->daq_rec); - writer.write_metadata( - "received_packets", data.first->n_recv_packets); + + writer.write_scalar_metadata( + "pulse_id", + &(data.first->pulse_id), + sizeof(uint64_t)); + + writer.write_scalar_metadata( + "frame_id", + &(data.first->frame_index), + sizeof(uint64_t)); + + writer.write_scalar_metadata( + "daq_rec", + &(data.first->daq_rec), + sizeof(uint32_t)); + + writer.write_scalar_metadata( + "received_packets", + &(data.first->n_recv_packets), + sizeof(uint16_t)); ring_buffer.release(data.first->buffer_slot_index);