Changeset 147

Timestamp:

09/20/2008 09:34:08 PM (5 years ago)

Author:

kascade

Message:

add j2534 support

Location:

trunk/src/com/romraider/io/j2534

Files:

• api/J2534.java (modified) (1 diff)
• op20/J2534OpenPort20.java (modified) (2 diffs)

trunk/src/com/romraider/io/j2534/api/J2534.java

@@ -18 +18 @@
     void writeMsg(int channelId, byte[] data);
 
-    byte[] readMsg(int channelId);
+    byte[] readMsg(int channelId, long timeout);
 
     void stopMsgFilter(int channelId, int msgId);

trunk/src/com/romraider/io/j2534/op20/J2534OpenPort20.java

@@ -20 +20 @@
 import static com.romraider.io.j2534.op20.OpenPort20.PassThruWriteMsgs;
 import static com.romraider.io.j2534.op20.OpenPort20.STATUS_NOERROR;
+import static com.romraider.util.HexUtil.asHex;
+import static java.lang.System.currentTimeMillis;
 
 public final class J2534OpenPort20 implements J2534 {
@@ -90 +92 @@
 
     // FIX - Needs to check msg type and retry until msg received
-    public byte[] readMsg(int channelId) {
+    public byte[] readMsg(int channelId, long timeout) {
+        long end = currentTimeMillis() + timeout;
+        do {
+            PassThruMessage msg = doReadMsg(channelId);
+            System.out.println("Response: [ProtocolID=" + msg.ProtocolID + "|RxStatus=" + msg.RxStatus + "|TxFlags=" + msg.TxFlags + "|Timestamp=" + msg.Timestamp + "|DataSize=" + msg.DataSize + "|Data=" + asHex(msg.Data) + "]");
+            if (isResponse(msg)) return data(msg);
+        } while (currentTimeMillis() <= end);
+        throw new J2534Exception("Read timeout.");
+    }
+
+    private boolean isResponse(PassThruMessage msg) {
+        // FIX - Complete!
+        return false;
+    }
+
+    private PassThruMessage doReadMsg(int channelId) {
         PassThruMessage msg = passThruMessage();
         int[] pNumMsgs = {1};
         int status = PassThruReadMsgs(channelId, msg, pNumMsgs, 0);
         if (status != STATUS_NOERROR) handleError(status);
-        return data(msg);
+        return msg;
     }