diff --git a/java_tools/proxy_server/src/main/java/com/rusefi/proxy/BaseBroadcastingThread.java b/java_tools/proxy_server/src/main/java/com/rusefi/proxy/BaseBroadcastingThread.java index 4af83c8aca..faa4f270b8 100644 --- a/java_tools/proxy_server/src/main/java/com/rusefi/proxy/BaseBroadcastingThread.java +++ b/java_tools/proxy_server/src/main/java/com/rusefi/proxy/BaseBroadcastingThread.java @@ -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); } }); } diff --git a/java_tools/proxy_server/src/main/java/com/rusefi/proxy/NetworkConnector.java b/java_tools/proxy_server/src/main/java/com/rusefi/proxy/NetworkConnector.java index f104f7152b..947d4bff13 100644 --- a/java_tools/proxy_server/src/main/java/com/rusefi/proxy/NetworkConnector.java +++ b/java_tools/proxy_server/src/main/java/com/rusefi/proxy/NetworkConnector.java @@ -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); } };