diff --git a/playback/src/main/java/com/rusefi/io/can/CanSender.java b/playback/src/main/java/com/rusefi/io/can/CanSender.java new file mode 100644 index 0000000..bc8d52d --- /dev/null +++ b/playback/src/main/java/com/rusefi/io/can/CanSender.java @@ -0,0 +1,5 @@ +package com.rusefi.io.can; + +public interface CanSender { + void send(int id, byte[] payload); +} diff --git a/playback/src/main/java/com/rusefi/io/can/PCanHelper.java b/playback/src/main/java/com/rusefi/io/can/PCanHelper.java index 22d8adb..ca43363 100644 --- a/playback/src/main/java/com/rusefi/io/can/PCanHelper.java +++ b/playback/src/main/java/com/rusefi/io/can/PCanHelper.java @@ -9,7 +9,7 @@ public class PCanHelper { public static final TPCANHandle CHANNEL = TPCANHandle.PCAN_USBBUS1; // @NotNull - public static PCANBasic create() { + public static PCANBasic createPCAN() { PCANBasic can = new PCANBasic(); can.initializeAPI(); return can; @@ -27,7 +27,7 @@ public class PCanHelper { } public static PCANBasic createAndInit() { - PCANBasic pcan = create(); + PCANBasic pcan = createPCAN(); TPCANStatus initStatus = init(pcan); if (initStatus != TPCANStatus.PCAN_ERROR_OK) { System.out.println("TPCANStatus " + initStatus); @@ -35,4 +35,14 @@ public class PCanHelper { } return pcan; } + + public static CanSender create() { + PCANBasic pcan = createAndInit(); + return new CanSender() { + @Override + public void send(int id, byte[] payload) { + PCanHelper.send(pcan, id, payload); + } + }; + } } diff --git a/playback/src/main/java/com/rusefi/io/can/SocketCANHelper.java b/playback/src/main/java/com/rusefi/io/can/SocketCANHelper.java index 24bc32c..ef9d878 100644 --- a/playback/src/main/java/com/rusefi/io/can/SocketCANHelper.java +++ b/playback/src/main/java/com/rusefi/io/can/SocketCANHelper.java @@ -36,4 +36,14 @@ public class SocketCANHelper { throw new IllegalStateException(e); } } + + public static CanSender create() { + RawCanChannel canChannel = createSocket(); + return new CanSender() { + @Override + public void send(int id, byte[] payload) { + SocketCANHelper.send(id, payload, canChannel); + } + }; + } }