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

Adjust to new interface to write metadata

Browse Source
This commit is contained in:
babic_a
2020-04-19 23:37:23 +02:00
parent 9f4175bc9d
commit 8805c6a923
1 changed files with 21 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
sf-buffer/src/sf_buffer.cpp
+21 -6
View File
@@ -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);