tools/pyboard.py: Avoid initial blocking read in read_until().

This applies the mpremote commit 0d46e45a1f
to pyboard.py.

If the target does not return any data then `read_until()` will block
indefinitely.  Fix this by making the initial read part of the general read
look, which always checks `inWaiting() > 0` before reading from the serial
device.

Also added the UART timeout to the constructor.  This is not currently used
but may be used as an additional safeguard.

Signed-off-by: Damien George <damien@micropython.org>
This commit is contained in:
Damien George
2025-05-20 16:48:38 +10:00
parent f5d10c322e
commit aaedd59b7c

View File

@@ -267,7 +267,14 @@ class ProcessPtyToTerminal:
class Pyboard: class Pyboard:
def __init__( def __init__(
self, device, baudrate=115200, user="micro", password="python", wait=0, exclusive=True self,
device,
baudrate=115200,
user="micro",
password="python",
wait=0,
exclusive=True,
timeout=None,
): ):
self.in_raw_repl = False self.in_raw_repl = False
self.use_raw_paste = True self.use_raw_paste = True
@@ -283,7 +290,11 @@ class Pyboard:
import serial.tools.list_ports import serial.tools.list_ports
# Set options, and exclusive if pyserial supports it # Set options, and exclusive if pyserial supports it
serial_kwargs = {"baudrate": baudrate, "interCharTimeout": 1} serial_kwargs = {
"baudrate": baudrate,
"timeout": timeout,
"interCharTimeout": 1,
}
if serial.__version__ >= "3.3": if serial.__version__ >= "3.3":
serial_kwargs["exclusive"] = exclusive serial_kwargs["exclusive"] = exclusive
@@ -324,13 +335,20 @@ class Pyboard:
self.serial.close() self.serial.close()
def read_until(self, min_num_bytes, ending, timeout=10, data_consumer=None): def read_until(self, min_num_bytes, ending, timeout=10, data_consumer=None):
# if data_consumer is used then data is not accumulated and the ending must be 1 byte long """
assert data_consumer is None or len(ending) == 1 min_num_bytes: Obsolete.
ending: Return if 'ending' matches.
timeout [s]: Return if timeout between characters. None: Infinite timeout.
data_consumer: Use callback for incoming characters.
If data_consumer is used then data is not accumulated and the ending must be 1 byte long
data = self.serial.read(min_num_bytes) It is not visible to the caller why the function returned. It could be ending or timeout.
if data_consumer: """
data_consumer(data) assert data_consumer is None or len(ending) == 1
timeout_count = 0 assert isinstance(timeout, (type(None), int, float))
data = b""
begin_char_s = time.monotonic()
while True: while True:
if data.endswith(ending): if data.endswith(ending):
break break
@@ -341,10 +359,9 @@ class Pyboard:
data = new_data data = new_data
else: else:
data = data + new_data data = data + new_data
timeout_count = 0 begin_char_s = time.monotonic()
else: else:
timeout_count += 1 if timeout is not None and time.monotonic() >= begin_char_s + timeout:
if timeout is not None and timeout_count >= 100 * timeout:
break break
time.sleep(0.01) time.sleep(0.01)
return data return data