mirror
/
micropython-lib
kopia lustrzana https://github.com/micropython/micropython-lib
1
0
Forkuj 0
Kod Zgłoszenia Projekty Wydania Wiki Aktywność

aioble: Add l2cap channel disconnected(). 

Allows `await channel.disconnected()`.

This also fixes a bug where connection._l2cap_channel wasn't being set to
None on disconnect.

Signed-off-by: Jim Mussared <jim.mussared@gmail.com>
pull/426/head
Jim Mussared 2021-10-29 13:58:15 +11:00 zatwierdzone przez Damien George
rodzic dd9b783568
commit 3ea74867f3
1 zmienionych plików z 5 dodań i 1 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

6
micropython/bluetooth/aioble/aioble/l2cap.py
Wyświetl plik

@ -44,6 +44,7 @@ def _l2cap_irq(event, data):
_, _, psm, status = data _, _, psm, status = data
channel._status = status channel._status = status
channel._cid = None channel._cid = None
connection._l2cap_channel = None
elif event == _IRQ_L2CAP_RECV: elif event == _IRQ_L2CAP_RECV:
channel._data_ready = True channel._data_ready = True
elif event == _IRQ_L2CAP_SEND_READY: elif event == _IRQ_L2CAP_SEND_READY:
@ -155,8 +156,11 @@ class L2CAPChannel:
return return
# Wait for the cid to be cleared by the disconnect IRQ. # Wait for the cid to be cleared by the disconnect IRQ.
ble.l2cap_disconnect(self._connection._conn_handle, self._cid)
await self.disconnected(timeout_ms)
async def disconnected(self, timeout_ms=1000):
with self._connection.timeout(timeout_ms): with self._connection.timeout(timeout_ms):
ble.l2cap_disconnect(self._connection._conn_handle, self._cid)
while self._cid is not None: while self._cid is not None:
await self._event.wait() await self._event.wait()