detectors/slsDetectorPackage
25
0
Fork 0
mirror of https://github.com/slsdetectorgroup/slsDetectorPackage.git synced 2025-06-17 07:17:13 +02:00
Code Issues Actions Packages Releases Activity

updated i3gbe to lll

Browse Source
This commit is contained in:
maliakal_d
2021-08-06 16:08:07 +02:00
parent bc5d6a0309
commit 2c53a134cd
17 changed files with 121 additions and 121 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
slsDetectorSoftware/src/Detector.cpp
View File

@ -1565,34 +1565,34 @@ void Detector::setVeto(bool enable, Positions pos) {
pimpl->Parallel(&Module::setVeto, pos, enable);
}
Result<defs::ethernetInterface> Detector::getVetoStream(Positions pos) const {
Result<defs::streamingInterface> Detector::getVetoStream(Positions pos) const {
// 3gbe
auto r3 = pimpl->Parallel(&Module::getVetoStream, pos);
// 10gbe (debugging interface) opens 2nd udp interface in receiver
auto r10 = getNumberofUDPInterfaces_(pos);
Result<defs::ethernetInterface> res(r3.size());
Result<defs::streamingInterface> res(r3.size());
for (unsigned int i = 0; i < res.size(); ++i) {
res[i] = (r3[i] ? defs::ethernetInterface::I3GBE
: defs::ethernetInterface::NONE);
res[i] = (r3[i] ? defs::streamingInterface::LOW_LATENCY_LINK
: defs::streamingInterface::NONE);
if (r10[i] == 2) {
res[i] = res[i] | defs::ethernetInterface::I10GBE;
res[i] = res[i] | defs::streamingInterface::ETHERNET_10GB;
}
}
return res;
}
void Detector::setVetoStream(defs::ethernetInterface interface, Positions pos) {
void Detector::setVetoStream(defs::streamingInterface interface, Positions pos) {
// 3gbe
bool i3gbe = (interface & defs::ethernetInterface::I3GBE) ==
defs::ethernetInterface::I3GBE;
pimpl->Parallel(&Module::setVetoStream, pos, i3gbe);
bool LOW_LATENCY_LINK = (interface & defs::streamingInterface::LOW_LATENCY_LINK) ==
defs::streamingInterface::LOW_LATENCY_LINK;
pimpl->Parallel(&Module::setVetoStream, pos, LOW_LATENCY_LINK);
// 10gbe (debugging interface) opens 2nd udp interface in receiver
int old_numinterfaces = getNumberofUDPInterfaces_(pos).tsquash(
"retrieved inconsistent number of udp interfaces");
int numinterfaces = ((interface & defs::ethernetInterface::I10GBE) ==
defs::ethernetInterface::I10GBE)
int numinterfaces = ((interface & defs::streamingInterface::ETHERNET_10GB) ==
defs::streamingInterface::ETHERNET_10GB)
? 2
: 1;
if (numinterfaces != old_numinterfaces) {
@ -1601,13 +1601,13 @@ void Detector::setVetoStream(defs::ethernetInterface interface, Positions pos) {
}
Result<defs::vetoAlgorithm>
Detector::getVetoAlgorithm(const defs::ethernetInterface interface,
Detector::getVetoAlgorithm(const defs::streamingInterface interface,
Positions pos) const {
return pimpl->Parallel(&Module::getVetoAlgorithm, pos, interface);
}
void Detector::setVetoAlgorithm(const defs::vetoAlgorithm alg,
defs::ethernetInterface interface,
defs::streamingInterface interface,
Positions pos) {
pimpl->Parallel(&Module::setVetoAlgorithm, pos, alg, interface);
}