detectors/slsDetectorPackage
24
1
Fork 0
mirror of https://github.com/slsdetectorgroup/slsDetectorPackage.git synced 2026-07-09 21:40:50 +02:00
Code Issues Actions Packages Releases Activity

wip, imple=> save only disabled ports with port index, 1 interface, is empty
Run Simulator Tests on local RHEL9 / build (push) Failing after 35s
Details
Build on RHEL8 docker image / build (push) Failing after 1m29s
Details
Build on RHEL9 docker image / build (push) Failing after 1m28s
Details
Run Simulator Tests on local RHEL8 / build (push) Failing after 1m48s
Details

Browse Source
This commit is contained in:
maliakal_d
2026-05-12 17:38:02 +02:00
parent c9793129db
commit 794c9f506a
8 changed files with 62 additions and 71 deletions
Download Patch File Download Diff File Expand all files Collapse all files
slsDetectorSoftware/src/Module.cpp
+8 -23
View File
@@ -1434,35 +1434,20 @@ void Module::setDataStream(const portPosition port, const bool enable) {
}
}
void Module::updateRxUDPDatastreamMetadata(
const std::array<std::vector<bool>, 2> &res) {
void Module::updateRxUDPPortDisableMetadata(const std::vector<int> &disable) {
if (!shm()->useReceiverFlag) {
return;
}
LOG(logDEBUG) << "Updating UDP data stream enable in receiver (metadata)";
LOG(logDEBUG) << "Updating UDP port disable metadata in Receiver 0";
auto client = ReceiverSocket(shm()->rxHostname, shm()->rxTCPPort);
client.Send(F_RECEIVER_UDP_DATASTREAM_METADATA);
client.setFnum(F_RECEIVER_UDP_DATASTREAM_METADATA);
// ensure both port list size match
if (res[0].size() != res[1].size()) {
throw RuntimeError(
"Size Mismatch of udp datastream enable list for ports");
}
// send udp data stream enable of all ports in all modules
auto nports = static_cast<int>(res.size());
auto nmods = static_cast<int>(res[0].size());
client.Send(F_RECEIVER_UDP_PORT_DISABLE_META);
client.setFnum(F_RECEIVER_UDP_PORT_DISABLE_META);
auto nports = static_cast<int>(disable.size());
client.Send(nports);
client.Send(nmods);
for (const auto &r : res) {
// convert vector of bool to vector of int to send
std::vector<int> tmp;
tmp.reserve(r.size());
for (bool b : r) {
tmp.push_back(static_cast<int>(b));
}
client.Send(tmp);
if (nports > 0) {
client.Send(disable);
}
if (client.Receive<int>() == FAIL) {
throw ReceiverError("Receiver " + std::to_string(moduleIndex) +