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

Show cams in TS trigger logger #2496

This commit is contained in:
rusefillc 2022-11-16 22:47:40 -05:00
parent 56b79da839
commit 29017946ca
1 changed files with 18 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
java_console/io/src/test/java/com/rusefi/binaryprotocol/test/TcpServerSandbox.java
View File

@ -1,9 +1,11 @@
package com.rusefi.binaryprotocol.test; package com.rusefi.binaryprotocol.test;
import com.macfaq.io.LittleEndianOutputStream;
import com.rusefi.CompatibleFunction; import com.rusefi.CompatibleFunction;
import com.rusefi.Listener; import com.rusefi.Listener;
import com.rusefi.binaryprotocol.BinaryProtocol; import com.rusefi.binaryprotocol.BinaryProtocol;
import com.rusefi.binaryprotocol.IncomingDataBuffer; import com.rusefi.binaryprotocol.IncomingDataBuffer;
import com.rusefi.binaryprotocol.IoHelper;
import com.rusefi.config.generated.Fields; import com.rusefi.config.generated.Fields;
import com.rusefi.config.generated.TsOutputs; import com.rusefi.config.generated.TsOutputs;
import com.rusefi.io.IoStream; import com.rusefi.io.IoStream;
@ -13,6 +15,7 @@ import com.rusefi.io.tcp.TcpIoStream;
import com.rusefi.ui.StatusConsumer; import com.rusefi.ui.StatusConsumer;
import java.io.ByteArrayInputStream; import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.IOException; import java.io.IOException;
import java.net.Socket; import java.net.Socket;
@ -99,7 +102,22 @@ public class TcpServerSandbox {
} else if (command == Fields.TS_CRC_CHECK_COMMAND) { } else if (command == Fields.TS_CRC_CHECK_COMMAND) {
stream.sendPacket(BinaryProtocolServer.createCrcResponse(TOTALLY_EMPTY_CONFIGURATION)); stream.sendPacket(BinaryProtocolServer.createCrcResponse(TOTALLY_EMPTY_CONFIGURATION));
} else if (command == Fields.TS_SET_LOGGER_SWITCH) { } else if (command == Fields.TS_SET_LOGGER_SWITCH) {
stream.sendPacket(TS_OK.getBytes());
} else if (command == Fields.TS_GET_LOGGER_GET_BUFFER) { } else if (command == Fields.TS_GET_LOGGER_GET_BUFFER) {
ByteArrayOutputStream baos = new ByteArrayOutputStream();
baos.write(TS_OK.charAt(0));
LittleEndianOutputStream dout = new LittleEndianOutputStream(baos);
int count = 256;
dout.writeShort(count * 5);
for (int i = 0; i < count; i++) {
baos.write(i);
baos.write(0);
baos.write(0);
baos.write(0);
baos.write(100);
}
stream.sendPacket(baos.toByteArray());
} else if (command == Fields.TS_OUTPUT_COMMAND) { } else if (command == Fields.TS_OUTPUT_COMMAND) {
byte[] response = getOutputCommandResponse(payload, ecuState.outputs); byte[] response = getOutputCommandResponse(payload, ecuState.outputs);
stream.sendPacket(response); stream.sendPacket(response);