|
|
|
@ -83,16 +83,15 @@ class IsoTpParallelQuery: |
|
|
|
|
self.bus, sub_addr=sub_addr, debug=self.debug) |
|
|
|
|
|
|
|
|
|
msg = IsoTpMessage(can_client, timeout=0, max_len=max_len, debug=self.debug) |
|
|
|
|
msgs[tx_addr] = msg |
|
|
|
|
request_counter[tx_addr] = 0 |
|
|
|
|
request_done[tx_addr] = False |
|
|
|
|
|
|
|
|
|
# Don't query functional addresses multiple times |
|
|
|
|
# Send first query to each tx addr once |
|
|
|
|
if tx_addr not in tx_addrs_sent: |
|
|
|
|
msg.send(self.request[0]) |
|
|
|
|
tx_addrs_sent.append(tx_addr) |
|
|
|
|
|
|
|
|
|
msgs[tx_addr] = msg |
|
|
|
|
request_counter[tx_addr] = 0 |
|
|
|
|
request_done[tx_addr] = False |
|
|
|
|
|
|
|
|
|
results = {} |
|
|
|
|
start_time = time.monotonic() |
|
|
|
|
response_timeouts = {tx_addr: start_time + timeout for tx_addr in self.msg_addrs} |
|
|
|
|