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

Remove tests that are not relevant anymore due to refactoring

Browse Source
This commit is contained in:
babic_a
2020-04-06 16:24:02 +02:00
parent de01a75cab
commit d375a65043
3 changed files with 18 additions and 96 deletions
Download Patch File Download Diff File Expand all files Collapse all files
core-writer/test/test_BufferedWriter.cpp
+1 -67
View File
@@ -2,73 +2,7 @@
#include "BufferedWriter.hpp"
using namespace std;
TEST(BufferedWriter, get_buffered_writer)
TEST(BufferedWriter, basic_interaction)
{
auto header_values = shared_ptr<unordered_map<string, HeaderDataType>>(new unordered_map<string, HeaderDataType> {
{"frame", HeaderDataType("uint64")},
{"module_number", HeaderDataType("uint64", 2)}
});
auto metadata_buffer1 = unique_ptr<MetadataBuffer>(new MetadataBuffer(1, header_values));
auto dummy_writer = get_buffered_writer("/dev/null", 10, move(metadata_buffer1));
EXPECT_TRUE(dynamic_cast<DummyBufferedWriter*>(dummy_writer.get()));
auto metadata_buffer2 = unique_ptr<MetadataBuffer>(new MetadataBuffer(1, header_values));
auto real_writer = get_buffered_writer("real_file.h5", 10, move(metadata_buffer2));
EXPECT_FALSE(dynamic_cast<DummyBufferedWriter*>(real_writer.get()));
}
TEST(BufferedWriter, DummyBufferedWriter)
{
DummyBufferedWriter dummy_writer;
EXPECT_FALSE(dummy_writer.is_file_open());
EXPECT_TRUE(dummy_writer.is_data_for_current_file(12345678));
EXPECT_NO_THROW(dummy_writer.cache_metadata("test", 10, nullptr));
EXPECT_NO_THROW(dummy_writer.write_metadata_to_file());
EXPECT_NO_THROW(dummy_writer.close_file());
EXPECT_THROW(dummy_writer.get_h5_file(), runtime_error);
unique_ptr<char> buffer(new char[1]);
vector<size_t> shape = {1};
EXPECT_NO_THROW(dummy_writer.write_data("does not matter", 0, buffer.get(), shape, 0, "nop", "nop"));
}
TEST(BufferedWriter, process_manager_workflow)
{
auto header_values = shared_ptr<unordered_map<string, HeaderDataType>>(new unordered_map<string, HeaderDataType> {
{"frame", HeaderDataType("uint64")},
{"module_number", HeaderDataType("uint64", 2)}
});
auto metadata_buffer = unique_ptr<MetadataBuffer>(new MetadataBuffer(1, header_values));
auto writer = get_buffered_writer("/dev/null", 10, move(metadata_buffer));
ASSERT_NO_THROW(writer->create_file());
EXPECT_TRUE(writer->is_data_for_current_file(0));
EXPECT_TRUE(writer->is_data_for_current_file(123456));
// This 2 should not happen, because is_data_for_current_file should always return true.
ASSERT_NO_THROW(writer->write_metadata_to_file());
ASSERT_THROW(writer->get_h5_file(), runtime_error);
unique_ptr<char> buffer(new char[1]);
vector<size_t> shape = {1};
EXPECT_NO_THROW(writer->write_data("does not matter", 0, buffer.get(), shape, 0, "nop", "nop"));
EXPECT_NO_THROW(writer->cache_metadata("test", 10, nullptr));
// This is important to prevent get_h5_file from being called.
EXPECT_FALSE(writer->is_file_open());
EXPECT_NO_THROW(writer->close_file());
}
core-writer/test/test_H5Writer.cpp
+1 -21
View File
@@ -2,27 +2,7 @@
#include "H5Writer.hpp"
using namespace std;
TEST(H5Writer, get_h5_writer)
TEST(H5Writer, basic_interaction)
{
auto dummy_writer = get_h5_writer("/dev/null");
EXPECT_TRUE(dynamic_cast<DummyH5Writer*>(dummy_writer.get()));
auto real_writer = get_h5_writer("real_file.h5");
EXPECT_FALSE(dynamic_cast<DummyH5Writer*>(real_writer.get()));
}
TEST(H5Writer, DummyH5Writer)
{
DummyH5Writer dummy_writer;
EXPECT_FALSE(dummy_writer.is_file_open());
EXPECT_NO_THROW(dummy_writer.close_file());
EXPECT_THROW(dummy_writer.get_h5_file(), runtime_error);
unique_ptr<char> buffer(new char[1]);
vector<size_t> shape = {1};
EXPECT_NO_THROW(dummy_writer.write_data("does not matter", 0, buffer.get(), shape, 0, "nop", "nop"));
}
core-writer/test/test_MetadataBuffer.cpp
+16 -8
View File
@@ -8,12 +8,14 @@ TEST(MetadataBuffer, basic_operations)
int n_frames = 10;
int n_modules = 3;
auto header_values = shared_ptr<unordered_map<string, HeaderDataType>>(new unordered_map<string, HeaderDataType> {
unordered_map<string, HeaderDataType> header_values {
{"frame", HeaderDataType("uint64")},
{"module_number", HeaderDataType("uint64", n_modules)}
});
};
MetadataBuffer metadata_buffer(n_frames, header_values);
MetadataBuffer metadata_buffer(
static_cast<const uint64_t>(n_frames),
header_values);
uint64_t base_frame_data = 12345678;
uint64_t base_module_number = 0;
@@ -49,10 +51,10 @@ TEST(MetadataBuffer, missing_keys)
int n_frames = 10;
int n_modules = 3;
auto header_values = shared_ptr<unordered_map<string, HeaderDataType>>(new unordered_map<string, HeaderDataType> {
unordered_map<string, HeaderDataType> header_values = {
{"frame", HeaderDataType("uint64")},
{"module_number", HeaderDataType("uint64", n_modules)}
});
};
MetadataBuffer metadata_buffer(n_frames, header_values);
@@ -61,7 +63,13 @@ TEST(MetadataBuffer, missing_keys)
metadata_buffer.add_metadata_to_buffer("frame", 0, (char*)&data);
metadata_buffer.get_metadata_values("frame");
EXPECT_THROW(metadata_buffer.get_metadata_values("non_existant"), runtime_error);
EXPECT_THROW(metadata_buffer.add_metadata_to_buffer("non_existant", 0, nullptr), runtime_error);
EXPECT_THROW(metadata_buffer.add_metadata_to_buffer("frame", n_frames, nullptr), runtime_error);
EXPECT_THROW(
metadata_buffer.get_metadata_values("non_existant"),
runtime_error);
EXPECT_THROW(
metadata_buffer.add_metadata_to_buffer("non_existant", 0, nullptr),
runtime_error);
EXPECT_THROW(
metadata_buffer.add_metadata_to_buffer("frame", n_frames, nullptr),
runtime_error);
}