andreika-git
/
rusefi
mirror of https://github.com/andreika-git/rusefi.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

List<JavaSensorsConsumer>

This commit is contained in:
Andrey 2024-03-30 01:18:58 -04:00 committed by rusefillc
parent 7192b3a7af
commit 13cc0a6bb1
1 changed files with 13 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
java_tools/configuration_definition_base/src/main/java/com/rusefi/ldmp/LiveDataProcessor.java
View File

@ -124,11 +124,16 @@ public class LiveDataProcessor {
dataLogConsumer.outputNames = outputNames;
gaugeConsumer.outputNames = outputNames;
JavaSensorsConsumer javaSensorsConsumer = new JavaSensorsConsumer(startingPosition.get());
List<JavaSensorsConsumer> javaSensorsConsumers = new ArrayList<>();
for (int i = 0; i < tempLimit(outputNames); i++) {
JavaSensorsConsumer javaSensorsConsumer = new JavaSensorsConsumer(startingPosition.get());
state.addDestination(javaSensorsConsumer);
javaSensorsConsumers.add(javaSensorsConsumer);
}
state.addDestination(javaSensorsConsumer,
outputsSections,
dataLogConsumer
state.addDestination(
outputsSections,
dataLogConsumer
);
List<FragmentDialogConsumer> fragmentConsumers = new ArrayList<>();
@ -182,8 +187,10 @@ public class LiveDataProcessor {
fancyNewMenu.append(fragmentDialogConsumer.menuLine());
}
totalSensors.append(javaSensorsConsumer.getContent());
startingPosition.set(javaSensorsConsumer.getSensorTsPosition());
for (JavaSensorsConsumer javaSensorsConsumer : javaSensorsConsumers)
totalSensors.append(javaSensorsConsumer.getContent());
startingPosition.set(javaSensorsConsumers.get(javaSensorsConsumers.size() - 1).getSensorTsPosition());
log.info("Done with " + name + " at " + startingPosition);
}