From 8761129677ba0dbb474f9959d3cc657a3879c58e Mon Sep 17 00:00:00 2001 From: pstrueb <62699315+pstrueb@users.noreply.github.com> Date: Sun, 16 Feb 2025 14:38:05 +0100 Subject: [PATCH 1/5] Add setup_data_path for iso queues --- apps/auracast.py | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/apps/auracast.py b/apps/auracast.py index 77e58ed..9ef87da 100644 --- a/apps/auracast.py +++ b/apps/auracast.py @@ -965,6 +965,11 @@ async def run_transmit( bumble.device.IsoPacketStream(big.bis_links[1], 64), ] + for queue in iso_queues: + await queue.iso_link.setup_data_path( + direction=queue.iso_link.Direction.HOST_TO_CONTROLLER + ) + def on_flow(): data_packet_queue = iso_queues[0].data_packet_queue print( From f526f549eed5a7954c75efad246d013b3a9bbc25 Mon Sep 17 00:00:00 2001 From: pstrueb <62699315+pstrueb@users.noreply.github.com> Date: Mon, 17 Feb 2025 08:51:28 +0100 Subject: [PATCH 2/5] refractoring --- apps/auracast.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/apps/auracast.py b/apps/auracast.py index 9ef87da..e0ff8c4 100644 --- a/apps/auracast.py +++ b/apps/auracast.py @@ -965,9 +965,9 @@ async def run_transmit( bumble.device.IsoPacketStream(big.bis_links[1], 64), ] - for queue in iso_queues: - await queue.iso_link.setup_data_path( - direction=queue.iso_link.Direction.HOST_TO_CONTROLLER + for bis_link in big.bis_links: + await bis_link.setup_data_path( + direction=bis_link.Direction.HOST_TO_CONTROLLER ) def on_flow(): From 4b66a38fe64ae7747592464ec9c007de56554838 Mon Sep 17 00:00:00 2001 From: pstrueb <62699315+pstrueb@users.noreply.github.com> Date: Mon, 17 Feb 2025 09:49:09 +0100 Subject: [PATCH 3/5] Refractoring again --- apps/auracast.py | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) diff --git a/apps/auracast.py b/apps/auracast.py index e0ff8c4..6adc351 100644 --- a/apps/auracast.py +++ b/apps/auracast.py @@ -692,7 +692,7 @@ async def run_receive( def on_new_broadcast(broadcast: BroadcastScanner.Broadcast) -> None: if scan_result.done(): return - if broadcast_id is None or broadcast.broadcast_id == broadcast_id: + if broadcast_id is None or broadcast.broadcast_:id == broadcast_id: scan_result.set_result(broadcast) scanner.on('new_broadcast', on_new_broadcast) @@ -959,17 +959,16 @@ async def run_transmit( ), ), ) + for bis_link in big.bis_links: + await bis_link.setup_data_path( + direction=bis_link.Direction.HOST_TO_CONTROLLER + ) iso_queues = [ bumble.device.IsoPacketStream(big.bis_links[0], 64), bumble.device.IsoPacketStream(big.bis_links[1], 64), ] - for bis_link in big.bis_links: - await bis_link.setup_data_path( - direction=bis_link.Direction.HOST_TO_CONTROLLER - ) - def on_flow(): data_packet_queue = iso_queues[0].data_packet_queue print( From ae5f9cf6904b935dff2ad6d042c48f868f12d1fd Mon Sep 17 00:00:00 2001 From: pstrueb <62699315+pstrueb@users.noreply.github.com> Date: Mon, 17 Feb 2025 18:21:16 +0100 Subject: [PATCH 4/5] Remove little accident --- apps/auracast.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/apps/auracast.py b/apps/auracast.py index 6adc351..30e059a 100644 --- a/apps/auracast.py +++ b/apps/auracast.py @@ -692,7 +692,7 @@ async def run_receive( def on_new_broadcast(broadcast: BroadcastScanner.Broadcast) -> None: if scan_result.done(): return - if broadcast_id is None or broadcast.broadcast_:id == broadcast_id: + if broadcast_id is None or broadcast.broadcast_id == broadcast_id: scan_result.set_result(broadcast) scanner.on('new_broadcast', on_new_broadcast) From 185d5fd5773361ac816c7639ea6693d97f04bfb7 Mon Sep 17 00:00:00 2001 From: pstruebi Date: Mon, 17 Feb 2025 20:11:17 +0100 Subject: [PATCH 5/5] reformatting --- apps/auracast.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/apps/auracast.py b/apps/auracast.py index 30e059a..7c567d3 100644 --- a/apps/auracast.py +++ b/apps/auracast.py @@ -962,7 +962,7 @@ async def run_transmit( for bis_link in big.bis_links: await bis_link.setup_data_path( direction=bis_link.Direction.HOST_TO_CONTROLLER - ) + ) iso_queues = [ bumble.device.IsoPacketStream(big.bis_links[0], 64),