aioble/multitests: Fix existing multitests.

Signed-off-by: Jim Mussared <jim.mussared@gmail.com>
pull/437/head
Jim Mussared 2021-11-04 16:31:26 +11:00 zatwierdzone przez Damien George
rodzic 5a86aa5866
commit 23b3c7fe2d
3 zmienionych plików z 10 dodań i 9 usunięć

Wyświetl plik

@ -66,7 +66,8 @@ async def instance0_task():
print("written", characteristic.read()) print("written", characteristic.read())
print("write") print("write")
characteristic.write("periph3") characteristic.write("periph3")
print("indicate", await characteristic.indicate(connection, timeout_ms=TIMEOUT_MS)) print("indicate")
await characteristic.indicate(connection, timeout_ms=TIMEOUT_MS)
# Wait for the central to disconnect. # Wait for the central to disconnect.
await connection.disconnected(timeout_ms=TIMEOUT_MS) await connection.disconnected(timeout_ms=TIMEOUT_MS)
@ -77,7 +78,7 @@ def instance0():
try: try:
asyncio.run(instance0_task()) asyncio.run(instance0_task())
finally: finally:
aioble.ble.active(0) aioble.stop()
# Acting in central role. # Acting in central role.
@ -132,4 +133,4 @@ def instance1():
try: try:
asyncio.run(instance1_task()) asyncio.run(instance1_task())
finally: finally:
aioble.ble.active(0) aioble.stop()

Wyświetl plik

@ -8,7 +8,7 @@ written b'central1'
notify notify
written b'central2' written b'central2'
write write
indicate 0 indicate
disconnected disconnected
--- instance1 --- --- instance1 ---
connect connect

Wyświetl plik

@ -29,7 +29,7 @@ def register_server():
return server_characteristic return server_characteristic
async def discover_server(): async def discover_server(connection):
client_service = await connection.service(SERVICE_UUID) client_service = await connection.service(SERVICE_UUID)
return await client_service.characteristic(CHAR_UUID) return await client_service.characteristic(CHAR_UUID)
@ -45,7 +45,7 @@ async def instance0_task():
20_000, adv_data=b"\x02\x01\x06\x04\xffMPY", timeout_ms=TIMEOUT_MS 20_000, adv_data=b"\x02\x01\x06\x04\xffMPY", timeout_ms=TIMEOUT_MS
) )
client_characteristic = await discover_server() client_characteristic = await discover_server(connection)
# Give the central enough time to discover chars. # Give the central enough time to discover chars.
await asyncio.sleep_ms(500) await asyncio.sleep_ms(500)
@ -73,7 +73,7 @@ def instance0():
try: try:
asyncio.run(instance0_task()) asyncio.run(instance0_task())
finally: finally:
aioble.ble.active(0) aioble.stop()
# Acting in central role. # Acting in central role.
@ -85,7 +85,7 @@ async def instance1_task():
device = aioble.Device(*BDADDR) device = aioble.Device(*BDADDR)
connection = await device.connect(timeout_ms=TIMEOUT_MS) connection = await device.connect(timeout_ms=TIMEOUT_MS)
client_characteristic = await discover_server() client_characteristic = await discover_server(connection)
for i in range(_NUM_NOTIFICATIONS): for i in range(_NUM_NOTIFICATIONS):
# Wait for notification and send response. # Wait for notification and send response.
@ -100,4 +100,4 @@ def instance1():
try: try:
asyncio.run(instance1_task()) asyncio.run(instance1_task())
finally: finally:
aioble.ble.active(0) aioble.stop()