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

just refactoring

This commit is contained in:
rusefillc 2022-02-10 22:44:21 -05:00
parent 08774c4149
commit 46d87f549f
4 changed files with 6 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
java_console/io/src/main/java/com/rusefi/io/can/Elm327IoStream.java
View File

@ -40,7 +40,7 @@ public class Elm327IoStream extends AbstractIoStream {
private Elm327IoStream(Elm327Connector con, String loggingPrefix, DisconnectListener disconnectListener) { private Elm327IoStream(Elm327Connector con, String loggingPrefix, DisconnectListener disconnectListener) {
this.con = con; this.con = con;
this.disconnectListener = disconnectListener; this.disconnectListener = disconnectListener;
this.dataBuffer = this.createDataBuffer(loggingPrefix); dataBuffer = createDataBuffer(loggingPrefix);
// ByteBuffer inBuf = ByteBuffer.allocate(OUT_BUFFER_SIZE); // ByteBuffer inBuf = ByteBuffer.allocate(OUT_BUFFER_SIZE);
outBuf = ByteBuffer.allocate(OUT_BUFFER_SIZE); outBuf = ByteBuffer.allocate(OUT_BUFFER_SIZE);

2
java_console/io/src/main/java/com/rusefi/io/serial/BufferedSerialIoStream.java
View File

@ -22,7 +22,7 @@ public class BufferedSerialIoStream extends SerialIoStream {
*/ */
private BufferedSerialIoStream(SerialPort sp, String port) { private BufferedSerialIoStream(SerialPort sp, String port) {
super(sp, port); super(sp, port);
this.dataBuffer = this.createDataBuffer("[serial] "); dataBuffer = createDataBuffer("[serial] ");
} }
@Override @Override

2
java_console/io/src/main/java/com/rusefi/io/stream/PCanIoStream.java
View File

@ -79,7 +79,7 @@ public class PCanIoStream extends AbstractIoStream {
public PCanIoStream(PCANBasic can) { public PCanIoStream(PCANBasic can) {
this.can = can; this.can = can;
this.dataBuffer = this.createDataBuffer(""); dataBuffer = createDataBuffer("");
} }
@Override @Override

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

@ -33,10 +33,9 @@ public class TcpIoStream extends AbstractIoStream {
if (socket == null) if (socket == null)
throw new NullPointerException("socket"); throw new NullPointerException("socket");
this.socket = socket; this.socket = socket;
InputStream input = new BufferedInputStream(socket.getInputStream()); input = new BufferedInputStream(socket.getInputStream());
this.output = new BufferedOutputStream(socket.getOutputStream()); output = new BufferedOutputStream(socket.getOutputStream());
this.input = input; dataBuffer = createDataBuffer(loggingPrefix);
this.dataBuffer = this.createDataBuffer(loggingPrefix);
} }
@NotNull @NotNull