rusefi
/
custom-board-bundle-sample-fork-of-rusefi
mirror of https://github.com/rusefi/custom-board-bundle-sample-fork-of-rusefi.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

proxy progress 

one more go? it makes no sense :(
This commit is contained in:
rusefi 2020-07-08 20:41:35 -04:00
parent 972c56f629
commit 71f38012a4
2 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
java_console/io/src/main/java/com/rusefi/io/LinkManager.java
View File

@ -188,11 +188,7 @@ public class LinkManager {
int portPart = TcpConnector.getTcpPort(port); int portPart = TcpConnector.getTcpPort(port);
String hostname = TcpConnector.getHostname(port); String hostname = TcpConnector.getHostname(port);
socket = new Socket(hostname, portPart); socket = new Socket(hostname, portPart);
TcpIoStream tcpIoStream = new TcpIoStream(logger, socket); return new TcpIoStream(logger, socket);
IncomingDataBuffer dataBuffer = IncomingDataBuffer.createDataBuffer(tcpIoStream, logger);
tcpIoStream.setDataBuffer(dataBuffer);
return tcpIoStream;
} catch (Throwable e) { } catch (Throwable e) {
stateListener.onConnectionFailed(); stateListener.onConnectionFailed();
return null; return null;

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

@ -35,6 +35,8 @@ public class TcpIoStream implements IoStream {
throw new NullPointerException("output"); throw new NullPointerException("output");
this.output = output; this.output = output;
this.input = input; this.input = input;
IncomingDataBuffer dataBuffer = IncomingDataBuffer.createDataBuffer(this, logger);
setDataBuffer(dataBuffer);
} }
@Override @Override