From da3a2835935173173da8843ecc4800961856ca44 Mon Sep 17 00:00:00 2001
From: jaseg <git@jaseg.net>
Date: Thu, 30 Jan 2020 16:45:11 +0100
Subject: Fixup protocol reset problem

---
 gm_platform/fw/serial.c   |   2 +-
 gm_platform/fw/tw_test.py | 104 +++++++++++++++++++++++-----------------------
 2 files changed, 53 insertions(+), 53 deletions(-)

(limited to 'gm_platform/fw')

diff --git a/gm_platform/fw/serial.c b/gm_platform/fw/serial.c
index 25b86fc..2c80674 100644
--- a/gm_platform/fw/serial.c
+++ b/gm_platform/fw/serial.c
@@ -50,7 +50,7 @@ void usart_dma_reset() {
     usart_tx_buf.wr_idx = 0;
     usart_tx_buf.xfr_next = 0;
     usart_tx_buf.wraparound = false;
-    usart_tx_buf.ack = false;
+    usart_tx_buf.ack = true;
 
     for (size_t i=0; i<ARRAY_LEN(usart_tx_buf.packet_end); i++)
         usart_tx_buf.packet_end[i] = -1;
diff --git a/gm_platform/fw/tw_test.py b/gm_platform/fw/tw_test.py
index a05a44b..cde59f0 100644
--- a/gm_platform/fw/tw_test.py
+++ b/gm_platform/fw/tw_test.py
@@ -74,56 +74,56 @@ if __name__ == '__main__':
     while True:
         #ser.write(cobs.encode(b'\x01\xff') + b'\0')
         data = ser.read_until(b'\0')
-        if not data or data[-1] != 0x00:
-            #print(f'{time():>7.3f} Timeout: resetting')
-            #ser.write(cobs.encode(b'\x01\xff') + b'\0') # reset
-            continue
-
-        try:
-            if len(data) <= 1: # delimiting zero for retransmission
-                cur.execute('INSERT INTO errors(run_id, rx_ts, type) VALUES (?, ?, "retransmission")',
-                        (run_id, int(time()*1000)))
-                continue
-            crc32, payload = unpack_head('I', cobs.decode(data[:-1]))
-            pid, seq, data = unpack_head('xBH', payload)
-            ts = time()
-
-            # Calculate byte-wise CRC32
-            our_crc = zlib.crc32(bytes(b for x in payload for b in (0, 0, 0, x)))
-            #log.append((time(), seq, crc32, our_crc, pid, data))
-            print(f'{ts:>7.3f} {seq:05d} {crc32:08x} {our_crc:08x} {pid} {hexlify(data).decode()}', end='')
-
-            error = False
-            suppress_ack = False
-            if crc32 != our_crc:
-                print(' CRC ERROR', end='')
-                suppress_ack = True
-                error = True
-
-            if last_pid is not None and pid != (last_pid+1)%8:
-                print(' PID ERROR', end='')
-                error = True
-            else:
-                last_pid = pid
-
-            if not suppress_ack:
-                ser.write(ctrl_ack(pid))
-                ser.flushOutput()
-
-            if not error:
-                cur.execute('INSERT INTO measurements VALUES (?, ?, ?, ?)', (run_id, int(ts*1000), seq, data))
-            else:
-                cur.execute('INSERT INTO errors VALUES (?, ?, "pid", ?, ?, ?, ?, ?, ?)',
-                        (run_id, int(ts*1000), seq, pid, (last_pid+1)%8, crc32, our_crc, data))
-
-            print()
-            lines_written += 1
-            if lines_written == 80:
-                lines_written = 0
-                print('\033[2J\033[H', end='')
-                db.commit()
-
-        except Exception as e:
-            print(e, len(data))
-            ser.write(ctrl_ack(0)) # FIXME delet this
+        for data in data.split(b'\0')[:-1]: # data always ends on \0 due to read_until, so split off the trailing empty bytes()
+            try:
+                if not data:
+                    #print(f'{time():>7.3f} Timeout: resetting')
+                    #ser.write(cobs.encode(b'\x01\xff') + b'\0') # reset
+                    ser.write(ctrl_ack(0)) # FIXME delet this
+                    cur.execute('INSERT INTO errors(run_id, rx_ts, type) VALUES (?, ?, "retransmission")',
+                            (run_id, int(time()*1000)))
+                    continue
+
+                crc32, payload = unpack_head('I', cobs.decode(data))
+                pid, seq, data = unpack_head('xBH', payload)
+                ts = time()
+
+                # Calculate byte-wise CRC32
+                our_crc = zlib.crc32(bytes(b for x in payload for b in (0, 0, 0, x)))
+                #log.append((time(), seq, crc32, our_crc, pid, data))
+                print(f'{ts:>7.3f} {seq:05d} {crc32:08x} {our_crc:08x} {pid} {hexlify(data).decode()}', end='')
+
+                error = False
+                suppress_ack = False
+                if crc32 != our_crc:
+                    print(' CRC ERROR', end='')
+                    suppress_ack = True
+                    error = True
+
+                if last_pid is not None and pid != (last_pid+1)%8:
+                    print(' PID ERROR', end='')
+                    error = True
+                else:
+                    last_pid = pid
+
+                if not suppress_ack:
+                    ser.write(ctrl_ack(pid))
+                    ser.flushOutput()
+
+                if not suppress_ack:
+                    cur.execute('INSERT INTO measurements VALUES (?, ?, ?, ?)', (run_id, int(ts*1000), seq, data))
+                if error:
+                    cur.execute('INSERT INTO errors VALUES (?, ?, "pid", ?, ?, ?, ?, ?, ?)',
+                            (run_id, int(ts*1000), seq, pid, (last_pid+1)%8, crc32, our_crc, data))
+
+                print()
+                lines_written += 1
+                if lines_written == 80:
+                    lines_written = 0
+                    print('\033[2J\033[H', end='')
+                    db.commit()
+
+            except Exception as e:
+                print(e, len(data))
+                ser.write(ctrl_ack(0)) # FIXME delet this
 
-- 
cgit