mirror of
https://github.com/paulscherrerinstitute/sf_daq_buffer.git
synced 2026-05-03 03:44:13 +02:00
Add basic FastH5 test
This commit is contained in:
@@ -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<char[]>(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<uint64_t>("pulse_id");
|
||||
writer.add_scalar_metadata<uint64_t>("frame_id");
|
||||
writer.add_scalar_metadata<uint32_t>("daq_rec");
|
||||
writer.add_scalar_metadata<uint16_t>("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));
|
||||
|
||||
|
||||
}
|
||||
Reference in New Issue
Block a user