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 - application side UI

This commit is contained in:
rusefi 2020-07-22 00:03:03 -04:00
parent 4896ab3c4d
commit c0791090e6
2 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
java_tools/proxy_server/src/main/java/com/rusefi/proxy/BaseBroadcastingThread.java
View File

@ -1,6 +1,7 @@
package com.rusefi.proxy;
import com.opensr5.Logger;
import com.rusefi.binaryprotocol.BinaryProtocol;
import com.rusefi.binaryprotocol.IncomingDataBuffer;
import com.rusefi.config.generated.Fields;
import com.rusefi.io.commands.HelloCommand;
@ -34,13 +35,14 @@ public class BaseBroadcastingThread {
if (command == Fields.TS_HELLO_COMMAND) {
// respond on hello request with information about session
logger.info("Sending out " + sessionDetails);
new HelloCommand(logger, sessionDetails.toJson()).handle(stream);
} else {
handleCommand(packet, stream);
}
}
} catch (IOException e) {
e.printStackTrace();
logger.error("exiting thread " + e);
}
});
}

3
java_tools/proxy_server/src/main/java/com/rusefi/proxy/NetworkConnector.java
View File

@ -2,6 +2,7 @@ package com.rusefi.proxy;
import com.opensr5.ConfigurationImage;
import com.opensr5.Logger;
import com.rusefi.binaryprotocol.BinaryProtocol;
import com.rusefi.config.generated.Fields;
import com.rusefi.io.ConnectionStateListener;
import com.rusefi.io.IoStream;
@ -71,9 +72,11 @@ public class NetworkConnector {
@Override
protected void handleCommand(BinaryProtocolServer.Packet packet, TcpIoStream stream) throws IOException {
super.handleCommand(packet, stream);
logger.info("Relaying request to controller " + BinaryProtocol.findCommand(packet.getPacket()[0]));
targetEcuSocket.sendPacket(packet);
BinaryProtocolServer.Packet response = targetEcuSocket.readPacket();
logger.info("Relaying response to proxy size=" + response.getPacket().length);
stream.sendPacket(response);
}
};