From 4facc8c54a07f64a13a33586c9816f233dc2cc8c Mon Sep 17 00:00:00 2001 From: Andrej Babic Date: Mon, 20 Apr 2020 10:02:32 +0200 Subject: [PATCH] Add basic FastH5 test --- core-buffer/test/test_FastH5Writer.cpp | 50 ++++++++++++++++++++++++++ core-buffer/test/test_main.cpp | 1 + 2 files changed, 51 insertions(+) create mode 100644 core-buffer/test/test_FastH5Writer.cpp diff --git a/core-buffer/test/test_FastH5Writer.cpp b/core-buffer/test/test_FastH5Writer.cpp new file mode 100644 index 0000000..067ed4d --- /dev/null +++ b/core-buffer/test/test_FastH5Writer.cpp @@ -0,0 +1,50 @@ +#include "FastH5Writer.hpp" +#include "gtest/gtest.h" + +TEST(FastH5Writer, basic_interaction) +{ + auto root_folder = "."; + auto device_name = "fast_device"; + + auto buffer = make_shared(512*1024*2); + + UdpFrameMetadata metadata; + metadata.pulse_id = 1; + metadata.frame_index = 2; + metadata.daq_rec = 2; + metadata.n_recv_packets = 128; + + FastH5Writer writer( + BufferUtils::FILE_MOD, 512, 1024, device_name, root_folder); + + writer.add_scalar_metadata("pulse_id"); + writer.add_scalar_metadata("frame_id"); + writer.add_scalar_metadata("daq_rec"); + writer.add_scalar_metadata("received_packets"); + + writer.set_pulse_id(1); + + writer.write_data(buffer.get()); + + writer.write_scalar_metadata( + "pulse_id", + &(metadata.pulse_id), + sizeof(uint64_t)); + + writer.write_scalar_metadata( + "frame_id", + &(metadata.frame_index), + sizeof(uint64_t)); + + writer.write_scalar_metadata( + "daq_rec", + &(metadata.daq_rec), + sizeof(uint32_t)); + + writer.write_scalar_metadata( + "received_packets", + &(metadata.n_recv_packets), + sizeof(uint16_t)); + + +} diff --git a/core-buffer/test/test_main.cpp b/core-buffer/test/test_main.cpp index dde2225..70ac032 100644 --- a/core-buffer/test/test_main.cpp +++ b/core-buffer/test/test_main.cpp @@ -3,6 +3,7 @@ #include "test_UdpRecvModule.cpp" #include "test_BinaryWriter.cpp" #include "test_buffer_utils.cpp" +#include "test_FastH5Writer.cpp" using namespace std;