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

helping Android

This commit is contained in:
rusefi 2020-07-19 00:14:59 -04:00
parent 158e5d1876
commit 75fc3a270d
3 changed files with 10 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
android/app/src/main/java/com/rusefi/app/AndroidSerial.java
View File

@ -34,7 +34,12 @@ public class AndroidSerial implements IoStream {
public AndroidSerial(UsbSerialPort usbSerialPort, Logger logger) {
this.usbSerialPort = usbSerialPort;
dataBuffer = IncomingDataBuffer.createDataBuffer(this, logger);
dataBuffer = IncomingDataBuffer.createDataBuffer("", this, logger);
}
@Override
public String getLoggingPrefix() {
return "";
}
@Override
@ -45,7 +50,7 @@ public class AndroidSerial implements IoStream {
@Override
public void setInputListener(DataListener listener) {
ByteReader reader = buffer -> usbSerialPort.read(buffer, 5000);
ByteReader.runReaderLoop(listener, reader, Logger.CONSOLE);
ByteReader.runReaderLoop("", listener, reader, Logger.CONSOLE);
}
@Override

4
java_console/io/src/main/java/com/rusefi/io/ByteReader.java
View File

@ -9,7 +9,7 @@ import java.util.concurrent.Executor;
import java.util.concurrent.Executors;
public interface ByteReader {
static void runReaderLoop(DataListener listener, ByteReader reader, Logger logger) {
static void runReaderLoop(String loggingPrefix, DataListener listener, ByteReader reader, Logger logger) {
/**
* Threading of the whole input/output does not look healthy at all!
*
@ -24,7 +24,7 @@ public interface ByteReader {
threadExecutor.execute(() -> {
Thread.currentThread().setName("TCP connector loop");
logger.info("Running TCP connection loop");
logger.info(loggingPrefix + "Running TCP connection loop");
byte inputBuffer[] = new byte[256];
while (true) {

2
java_console/io/src/main/java/com/rusefi/io/tcp/TcpIoStream.java
View File

@ -66,7 +66,7 @@ public class TcpIoStream implements IoStream {
@Override
public void setInputListener(final DataListener listener) {
ByteReader.runReaderLoop(listener, input::read, logger);
ByteReader.runReaderLoop(loggingPrefix, listener, input::read, logger);
}
@Override