| 108 | |
| 109 | |
| 110 | class RXThread(threading.Thread): |
| 111 | def __init__(self): |
| 112 | threading.Thread.__init__(self) |
| 113 | |
| 114 | def run(self): |
| 115 | print("Starting ") |
| 116 | i = 0 |
| 117 | while True: |
| 118 | msg = vpe_api_read() |
| 119 | if msg: |
| 120 | # print msg |
| 121 | id = unpack(">H", msg[0:2]) |
| 122 | size = unpack(">H", msg[2:4]) |
| 123 | print(f"Received {id} of size {size}") |
| 124 | i += 1 |
| 125 | # del msg |
| 126 | continue |
| 127 | |
| 128 | # time.sleep(0.001) |
| 129 | return |
| 130 | |
| 131 | |
| 132 | # Create RX thread |