diff --git a/sf-writer/test/test_JFH5Writer.cpp b/sf-writer/test/test_JFH5Writer.cpp index 838fc05..6577f3c 100644 --- a/sf-writer/test/test_JFH5Writer.cpp +++ b/sf-writer/test/test_JFH5Writer.cpp @@ -3,6 +3,7 @@ #include "JFH5Writer.hpp" #include "gtest/gtest.h" #include "bitshuffle/bitshuffle.h" +#include "mock/data.hpp" using namespace std; using namespace buffer_config; @@ -31,44 +32,19 @@ TEST(JFH5Writer, test_writing) uint64_t stop_pulse_id = 10; auto n_images = stop_pulse_id - start_pulse_id + 1; - auto metadata = make_shared(); - metadata->block_start_pulse_id = 0; - metadata->block_stop_pulse_id = BUFFER_BLOCK_SIZE - 1; - - for (uint64_t pulse_id=start_pulse_id; - pulse_id<=stop_pulse_id; - pulse_id++) { - - metadata->pulse_id[pulse_id] = pulse_id; - metadata->frame_index[pulse_id] = pulse_id + 10; - metadata->daq_rec[pulse_id] = pulse_id + 100; - metadata->is_good_image[pulse_id] = 1; - } - - auto image_buffer = make_unique( - MODULE_N_PIXELS * n_modules * BUFFER_BLOCK_SIZE); - - for (int i_block=0; i_block<=BUFFER_BLOCK_SIZE; i_block++) { - for (int i_module=0; i_module(n_images); + auto pulse_id_dataset = reader.openDataSet("pulse_id"); + pulse_id_dataset.read(&pulse_id_data[0], H5::PredType::NATIVE_UINT64); + + auto frame_index_data = make_unique(n_images); + auto frame_index_dataset = reader.openDataSet("frame_index"); + frame_index_dataset.read(&frame_index_data[0], H5::PredType::NATIVE_UINT64); + + auto daq_rec_data = make_unique(n_images); + auto daq_rec_dataset = reader.openDataSet("daq_rec"); + daq_rec_dataset.read(&daq_rec_data[0], H5::PredType::NATIVE_UINT32); + + auto is_good_frame_data = make_unique(n_images); + auto is_good_frame_dataset = reader.openDataSet("is_good_frame"); + is_good_frame_dataset.read( + &is_good_frame_data[0], H5::PredType::NATIVE_UINT8); + + for (uint64_t pulse_id=start_pulse_id; + pulse_id<=stop_pulse_id; + pulse_id++) { + + ASSERT_EQ(pulse_id_data[pulse_id - start_pulse_id], pulse_id); + ASSERT_EQ(frame_index_data[pulse_id - start_pulse_id], pulse_id + 10); + ASSERT_EQ(daq_rec_data[pulse_id - start_pulse_id], pulse_id + 100); + ASSERT_EQ(is_good_frame_data[pulse_id - start_pulse_id], 1); + } +}