docs timestamp

rusefi · Sep 23, 2024 · 430ec5c · 430ec5c
1 parent 5c89e92
commit 430ec5c
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/reader/src/main/java/com/rusefi/mlv/LoggingContext.java b/reader/src/main/java/com/rusefi/mlv/LoggingContext.java
@@ -12,7 +12,7 @@
 
 public class LoggingContext {
     public Map<String, Double> currentSnapshot = new HashMap<>();
-    AtomicReference<Long> currentTime = new AtomicReference<>();
+    private final AtomicReference<Long> currentTimeUs = new AtomicReference<>();
 
     public BinarySensorLog<BinaryLogEntry> getBinaryLogEntryBinarySensorLog(Collection<BinaryLogEntry> entries, String outputFileName) {
         return new BinarySensorLog<>(o -> {
@@ -25,7 +25,7 @@ public BinarySensorLog<BinaryLogEntry> getBinaryLogEntryBinarySensorLog(Collecti
 
     public void writeLogContent(List<CANPacket> packets, BinarySensorLog<BinaryLogEntry> log, LoggingStrategy.PacketLogger logger) {
         for (CANPacket packetContent : packets) {
-            currentTime.set((long) (packetContent.getTimeStamp() * 1000));
+            currentTimeUs.set((long) (packetContent.getTimeStamp() * 1000));
             boolean needLine = logger.takeValues(packetContent);
             if (needLine)
                 log.writeSensorLogLine();
@@ -34,6 +34,6 @@ public void writeLogContent(List<CANPacket> packets, BinarySensorLog<BinaryLogEn
     }
 
     public BinarySensorLog.TimeProvider getTimeProvider() {
-        return () -> this.currentTime.get();
+        return () -> this.currentTimeUs.get();
     }
 }
diff --git a/reader/src/main/java/com/rusefi/sensor_logs/BinarySensorLog.java b/reader/src/main/java/com/rusefi/sensor_logs/BinarySensorLog.java
@@ -30,7 +30,7 @@ public BinarySensorLog(Function<T, Double> valueProvider, Collection<T> sensors,
     }
 
     public interface TimeProvider {
-        long currentTimestamp();
+        long currentTimestampUs();
     }
 
     @Override
@@ -56,7 +56,7 @@ public void writeSensorLogLine() {
             try {
                 stream.write(0);
                 stream.write(lineCounter++);
-                stream.writeShort((int) (timeProvider.currentTimestamp() * 100));
+                stream.writeShort((int) (timeProvider.currentTimestampUs() * 100));
 
                 ByteArrayOutputStream baos = new ByteArrayOutputStream();
                 DataOutputStream dos = new DataOutputStream(baos);