From e0d0a13deff45af7431f388f2eff7897b46ccaee Mon Sep 17 00:00:00 2001 From: Alice Date: Wed, 4 Nov 2026 19:57:28 +0100 Subject: [PATCH] reset udp streaming for all modules --- .../tests/Caller/test-Caller-rx.cpp | 16 ++++++++++++---- 1 file changed, 12 insertions(+), 4 deletions(-) diff --git a/slsDetectorSoftware/tests/Caller/test-Caller-rx.cpp b/slsDetectorSoftware/tests/Caller/test-Caller-rx.cpp index 8a87dfc7c..65c57f1a5 100644 --- a/slsDetectorSoftware/tests/Caller/test-Caller-rx.cpp +++ b/slsDetectorSoftware/tests/Caller/test-Caller-rx.cpp @@ -868,8 +868,10 @@ TEST_CASE("rx_roi_port_disabled", "[.detectorintegration]") { if (two_ports) { auto prev_roi = det.getRxROI(); auto ports = det.getPortPositionList(); - auto prev_port0 = det.getUDPDataStream(ports[0], {0})[0]; - auto prev_port1 = det.getUDPDataStream(ports[1], {0})[0]; + + auto prev_port0 = det.getUDPDataStream(ports[0]); + auto prev_port1 = det.getUDPDataStream(ports[1]); + bool prev_tengiga = false; if (det_type == defs::EIGER) { prev_tengiga = det.getTenGiga().squash(false); @@ -935,8 +937,14 @@ TEST_CASE("rx_roi_port_disabled", "[.detectorintegration]") { det.clearRxROI(); else det.setRxROI(prev_roi); - det.setUDPDataStream(ports[0], prev_port0, {0}); - det.setUDPDataStream(ports[1], prev_port1, {0}); + + for (size_t i = 0; i != prev_port0.size(); ++i) { + det.setUDPDataStream(ports[0], prev_port0[i], + {static_cast(i)}); + det.setUDPDataStream(ports[1], prev_port1[i], + {static_cast(i)}); + } + if (det_type == defs::EIGER) { det.setTenGiga(prev_tengiga); }