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

version 1.0.0-rc.24

Browse Source
This commit is contained in:
leonarski_f
2024-11-17 14:55:09 +01:00
parent aeeae33ad9
commit adc13ff33e
361 changed files with 12513 additions and 3314 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tests/JFJochReceiverProcessingTest.cpp
+11 -1
View File
@@ -312,7 +312,7 @@ TEST_CASE("JFJochIntegrationTest_ZMQPreview", "[JFJochReceiver]") {
JFJochReceiverService service(aq_devices, logger, pusher);
service.NumThreads(nthreads);
service.PreviewSocket("ipc://*");
service.PreviewSocketSettings({.period = std::chrono::seconds(0)}); // Send all images to preview
service.PreviewSocketSettings({.period = std::chrono::seconds(0), .send_start_message = true}); // Send all images to preview
ZMQSocket sub_socket(ZMQSocketType::Sub);
sub_socket.ReceiveWaterMark(10);
@@ -330,6 +330,16 @@ TEST_CASE("JFJochIntegrationTest_ZMQPreview", "[JFJochReceiver]") {
ZMQMessage msg1;
REQUIRE(sub_socket.Receive(msg1, true));
auto out = CBORStream2Deserialize(msg1.data(), msg1.size());
REQUIRE(out != nullptr);
CHECK(out->msg_type == CBORImageType::START);
REQUIRE(sub_socket.Receive(msg1, true));
out = CBORStream2Deserialize(msg1.data(), msg1.size());
REQUIRE(out != nullptr);
CHECK(out->msg_type == CBORImageType::IMAGE);
REQUIRE(sub_socket.Receive(msg1, true));
REQUIRE(sub_socket.Receive(msg1, true));
REQUIRE(sub_socket.Receive(msg1, true));