diff --git a/java_console/io/src/main/java/com/rusefi/binaryprotocol/IncomingDataBuffer.java b/java_console/io/src/main/java/com/rusefi/binaryprotocol/IncomingDataBuffer.java index c56a3b90c7..f19597ed30 100644 --- a/java_console/io/src/main/java/com/rusefi/binaryprotocol/IncomingDataBuffer.java +++ b/java_console/io/src/main/java/com/rusefi/binaryprotocol/IncomingDataBuffer.java @@ -2,6 +2,7 @@ package com.rusefi.binaryprotocol; import com.devexperts.logging.Logging; import com.rusefi.Timeouts; +import com.rusefi.binaryprotocol.test.Bug3923; import com.rusefi.io.IoStream; import com.rusefi.io.serial.AbstractIoStream; import etch.util.CircularByteBuffer; @@ -98,7 +99,7 @@ public class IncomingDataBuffer { cbb.put(freshData); cbb.notifyAll(); } - if (log.debugEnabled()) + if (log.debugEnabled() || Bug3923.obscene) log.debug(freshData.length + " byte(s) arrived, total " + cbb.length()); } diff --git a/java_console/io/src/main/java/com/rusefi/binaryprotocol/test/Bug3923.java b/java_console/io/src/main/java/com/rusefi/binaryprotocol/test/Bug3923.java new file mode 100644 index 0000000000..0d774e1c75 --- /dev/null +++ b/java_console/io/src/main/java/com/rusefi/binaryprotocol/test/Bug3923.java @@ -0,0 +1,5 @@ +package com.rusefi.binaryprotocol.test; + +public class Bug3923 { + public static final boolean obscene = false; +} diff --git a/java_console/io/src/main/java/com/rusefi/io/serial/SerialIoStream.java b/java_console/io/src/main/java/com/rusefi/io/serial/SerialIoStream.java index ef90f77708..5e42141124 100644 --- a/java_console/io/src/main/java/com/rusefi/io/serial/SerialIoStream.java +++ b/java_console/io/src/main/java/com/rusefi/io/serial/SerialIoStream.java @@ -6,6 +6,7 @@ import com.fazecast.jSerialComm.SerialPortDataListener; import com.fazecast.jSerialComm.SerialPortEvent; import com.opensr5.io.DataListener; import com.rusefi.binaryprotocol.IncomingDataBuffer; +import com.rusefi.binaryprotocol.test.Bug3923; import com.rusefi.io.IoStream; import org.jetbrains.annotations.NotNull; @@ -76,6 +77,8 @@ public class SerialIoStream extends AbstractIoStream { @Override public void serialEvent(SerialPortEvent event) { + if (Bug3923.obscene) + System.out.println("serialEvent " + event); if (event.getEventType() != SerialPort.LISTENING_EVENT_DATA_AVAILABLE) return; if (isFirstEvent) { @@ -84,6 +87,8 @@ public class SerialIoStream extends AbstractIoStream { isFirstEvent = false; } int bytesAvailable = sp.bytesAvailable(); + if (Bug3923.obscene) + log.info("serialEvent bytesAvailable " + bytesAvailable); if (bytesAvailable <= 0) return; // sometimes negative value is returned at least on Mac byte[] newData = new byte[bytesAvailable];