Andrew Leech 2025-05-12 05:54:36 +00:00 zatwierdzone przez GitHub
commit dd2819ab87
Nie znaleziono w bazie danych klucza dla tego podpisu
ID klucza GPG: B5690EEEBB952194
1 zmienionych plików z 31 dodań i 20 usunięć

Wyświetl plik

@ -6,7 +6,7 @@ from micropython import const
import asyncio
from .core import ble, log_error, register_irq_handler
from .device import DeviceConnection
from .device import DeviceConnection, DeviceDisconnectedError
_IRQ_L2CAP_ACCEPT = const(22)
@ -180,6 +180,7 @@ class L2CAPChannel:
# Use connection.l2cap_accept() instead of calling this directly.
async def accept(connection, psm, mtu, timeout_ms):
global _listening
try:
channel = L2CAPChannel(connection)
@ -192,6 +193,10 @@ async def accept(connection, psm, mtu, timeout_ms):
with connection.timeout(timeout_ms):
await channel._event.wait()
return channel
except ValueError as ex:
if ex.value == 'Not connected':
raise DeviceDisconnectedError()
raise
# Use connection.l2cap_connect() instead of calling this directly.
@ -199,6 +204,7 @@ async def connect(connection, psm, mtu, timeout_ms):
if _listening:
raise ValueError("Can't connect while listening")
try:
channel = L2CAPChannel(connection)
with connection.timeout(timeout_ms):
@ -212,3 +218,8 @@ async def connect(connection, psm, mtu, timeout_ms):
return channel
else:
raise L2CAPConnectionError(channel._status)
except ValueError as ex:
if ex.value == 'Not connected':
raise DeviceDisconnectedError()
raise