forked from auracaster/bumble_mirror
Merge pull request #790 from markusjellitsch/task/fix-cis-reconnect
Fix - Allow re-creation of CIS link when not successfull
This commit is contained in:
@@ -4727,7 +4727,7 @@ class Device(utils.CompositeEventEmitter):
|
|||||||
self, cis_acl_pairs: Sequence[tuple[int, Connection]]
|
self, cis_acl_pairs: Sequence[tuple[int, Connection]]
|
||||||
) -> list[CisLink]:
|
) -> list[CisLink]:
|
||||||
for cis_handle, acl_connection in cis_acl_pairs:
|
for cis_handle, acl_connection in cis_acl_pairs:
|
||||||
cis_id, cig_id = self._pending_cis.pop(cis_handle)
|
cis_id, cig_id = self._pending_cis[cis_handle]
|
||||||
self.cis_links[cis_handle] = CisLink(
|
self.cis_links[cis_handle] = CisLink(
|
||||||
device=self,
|
device=self,
|
||||||
acl_connection=acl_connection,
|
acl_connection=acl_connection,
|
||||||
@@ -4743,6 +4743,7 @@ class Device(utils.CompositeEventEmitter):
|
|||||||
}
|
}
|
||||||
|
|
||||||
def on_cis_establishment(cis_link: CisLink) -> None:
|
def on_cis_establishment(cis_link: CisLink) -> None:
|
||||||
|
self._pending_cis.pop(cis_link.handle)
|
||||||
if pending_future := pending_cis_establishments.get(cis_link.handle):
|
if pending_future := pending_cis_establishments.get(cis_link.handle):
|
||||||
pending_future.set_result(cis_link)
|
pending_future.set_result(cis_link)
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user