mx/Jungfraujoch
1
1
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases 43 Wiki Activity

jfjoch_writer improvement

Browse Source
This commit is contained in:
leonarski_f
2024-01-30 20:34:30 +01:00
parent 34dd74d8ae
commit 52519fb45c
22 changed files with 369 additions and 590 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
tests/StreamWriterTest.cpp
View File

@@ -33,13 +33,16 @@ TEST_CASE("StreamWriterTest_ZMQ","[JFJochWriter]") {
auto pusher_addr = pusher.GetAddress();
REQUIRE(pusher_addr.size() == 1);
REQUIRE_NOTHROW(writer = std::make_unique<StreamWriter>(context, logger, pusher_addr[0]));
CHECK (writer->GetStatistics().state == StreamWriterState::Idle);
REQUIRE_NOTHROW(fpga_receiver_service.Start(x, nullptr));
REQUIRE_NOTHROW(writer->Run());
REQUIRE_NOTHROW(receiver_output = fpga_receiver_service.Stop());
CHECK(receiver_output.status.images_sent == 5);
CHECK(writer->GetStatistics().state == StreamWriterState::Idle);
CHECK(writer->GetStatistics().processed_images == 5);
CHECK(writer->GetStatistics().file_prefix == x.GetFilePrefix());
// HDF5 file can be opened
std::unique_ptr<HDF5ReadOnlyFile> file;