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

Add n_recv_packets to hdf5

Browse Source
This commit is contained in:
babic_a
2020-04-16 12:37:07 +02:00
parent b7999b2cd1
commit 935f79ba0e
1 changed files with 11 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
sf-buffer/src/sf_buffer.cpp
+11 -1
View File
@@ -65,6 +65,9 @@ int main (int argc, char *argv[]) {
auto* buffer_recv_packets_2 = new uint64_t[FILE_MOD];
memset((char*) buffer_recv_packets_2, 0, FILE_MOD * 8);
auto* buffer_recv_packets = new uint16_t[FILE_MOD];
memset((char*) buffer_recv_packets, 0, FILE_MOD * 2);
while (true) {
auto data = ring_buffer.read();
@@ -90,7 +93,7 @@ int main (int argc, char *argv[]) {
{1}, 8*FILE_MOD, "uint64", "little");
writer.write_data("daq_rec", 0, (char*) buffer_daq_rec,
{1}, 8*FILE_MOD, "uint32", "little");
{1}, 4*FILE_MOD, "uint32", "little");
writer.write_data("recv_packets_1", 0, (char*) buffer_recv_packets_1,
{1}, 8*FILE_MOD, "uint64", "little");
@@ -98,6 +101,9 @@ int main (int argc, char *argv[]) {
writer.write_data("recv_packets_2", 0, (char*) buffer_recv_packets_2,
{1}, 8*FILE_MOD, "uint64", "little");
writer.write_data("received_packets", 0, (char*) buffer_recv_packets,
{1}, 2*FILE_MOD, "uint16", "little");
// TODO: Ugly hack from above, part 2.
stringstream latest_command;
latest_command << "echo " << current_file;
@@ -116,6 +122,7 @@ int main (int argc, char *argv[]) {
memset((char*) buffer_daq_rec, 0, FILE_MOD * 4);
memset((char*) buffer_recv_packets_1, 0, FILE_MOD * 8);
memset((char*) buffer_recv_packets_2, 0, FILE_MOD * 8);
memset((char*) buffer_recv_packets, 0, FILE_MOD * 2);
WriterUtils::create_destination_folder(current_file);
writer.create_file(current_file);
@@ -143,6 +150,9 @@ int main (int argc, char *argv[]) {
memcpy((void*) (buffer_recv_packets_2 + file_frame_index),
(void*) (&data.first->recv_packets_2), 8);
memcpy((void*) (buffer_recv_packets + file_frame_index),
(void*) (&data.first->n_recv_packets), 2);
ring_buffer.release(data.first->buffer_slot_index);
// TODO: Make real statistics, please.