| /packages/modules/Bluetooth/system/blueberry/tests/topshim/lib/ |
| D | gatt_client.py | 52 await self.__channel.close()
57 await self.__gatt_stub.RegisterAdvertiser(empty_proto.Empty())
64 await self.__gatt_stub.UnregisterAdvertiser(empty_proto.Empty())
69 await self.__gatt_stub.GetOwnAddress(empty_proto.Empty())
74 await self.__gatt_stub.SetParameters(empty_proto.Empty())
79 await self.__gatt_stub.SetData(empty_proto.Empty())
84 await self.__gatt_stub.AdvertisingEnable(empty_proto.Empty())
89 await self.__gatt_stub.AdvertisingDisable(empty_proto.Empty())
94 await self.__gatt_stub.SetPeriodicAdvertisingParameters(empty_proto.Empty())
99 await self.__gatt_stub.SetPeriodicAdvertisingData(empty_proto.Empty())
[all …]
|
| D | adapter_client.py | 49 await self.__channel.close()
54 e = await self.__adapter_event_stream.read()
70 await asyncio.wait_for(future, AdapterClient.DEFAULT_TIMEOUT)
77 future = await self._listen_for_event(facade_pb2.EventType.ADAPTER_STATE)
83 await self.__adapter_stub.ToggleStack(facade_pb2.ToggleStackRequest(start_stack=is_start))
84 return await self._verify_adapter_started()
88 …await self.__adapter_stub.SetDiscoveryMode(facade_pb2.SetDiscoveryModeRequest(enable_inquiry_scan=…
89 return await self._listen_for_event(facade_pb2.EventType.ADAPTER_PROPERTY)
93 …await self.__adapter_stub.SetDiscoveryMode(facade_pb2.SetDiscoveryModeRequest(enable_page_scan=Tru…
94 return await self._listen_for_event(facade_pb2.EventType.ADAPTER_PROPERTY)
[all …]
|
| D | hfp_client.py | 50 await self.__channel.close()
55 await self.__hfp_stub.StartSlc(
57 return await self._listen_for_event(facade_pb2.EventType.HFP_CONNECTION_STATE)
62 await self.__hfp_stub.StopSlc(
64 return await self._listen_for_event(facade_pb2.EventType.HFP_CONNECTION_STATE)
69 await self.__hfp_stub.ConnectAudio(
77 await self.__hfp_stub.DisconnectAudio(
83 await self.__hfp_stub.DisconnectAudio(
87 return await self._listen_for_event(facade_pb2.EventType.HFP_CONNECTION_STATE)
92 e = await self.__hfp_event_stream.read()
[all …]
|
| /packages/modules/Bluetooth/tools/rootcanal/scripts/ |
| D | controller_info.py | 47 reader, writer = await asyncio.open_connection(ip, port)
54 idc = await reader.readexactly(1)
57 header = await reader.readexactly(HCI_HEADER_SIZES[idc[0]])
60 evt = hci.Event.parse_all(header + (await reader.readexactly(header[1])))
77 await self.evt_queue_event.wait()
82 evt = await self.recv_evt()
93 await host.send_cmd(hci.ReadLocalSupportedFeatures())
94 page0 = await host.expect_evt(hci.ReadLocalSupportedFeaturesComplete)
95 await host.send_cmd(hci.ReadLocalExtendedFeatures(page_number=1))
96 page1 = await host.expect_evt(hci.ReadLocalExtendedFeaturesComplete)
[all …]
|
| /packages/modules/Bluetooth/android/pandora/test/ |
| D | asha_test.py | 89 await asyncio.gather(self.dut.reset(), self.ref_left.reset(), self.ref_right.reset())
104 await asha.Register(capability=ear, hisyncid=HISYCNID)
122 ref = await anext(
142 (dut_ref_res, ref_dut_res) = await asyncio.gather(
155 await device.aio.host.WaitDisconnection(connection=connection, timeout=timeout)
258 advertisement = await self.ref_advertise_asha(self.ref_left, ref_address_type, ear)
261 scan_result = await self.dut_scan_for_asha(dut_address_type=RANDOM, ear=ear)
281 await asha.Register(capability=Ear.LEFT, hisyncid=HISYCNID)
292 scan_result = await self.dut_scan_for_asha(dut_address_type=RANDOM, ear=Ear.LEFT)
318 advertisement = await self.ref_advertise_asha(
[all …]
|
| D | gatt_test.py | 62 await asyncio.gather(self.dut.reset(), self.ref.reset())
103 await self.dut.aio.host.ConnectLE(public=self.ref.address, own_address_type=RANDOM)
108 ref_connection_to_dut = (await anext(aiter(ref_advertisement))).connection
143 dut_connection_to_ref, ref_connection_to_dut = await self.connect_dut_to_ref()
147 … return await self.ref.aio.security.Secure(connection=ref_connection_to_dut, le=LE_LEVEL3)
152 event = await anext(dut_pairing_events)
158 …return await dut_gatt.ReadCharacteristicsFromUuid(dut_connection_to_ref, CHARACTERISTIC_UUID, 1, 0…
162 await asyncio.sleep(3)
168 event = await anext(dut_pairing_events)
172 read_response = await dut_read_task
[all …]
|
| D | sdp_test.py | 66 await asyncio.gather(self.dut.reset(), self.ref.reset())
78 ref_dut_res, dut_ref_res = await asyncio.gather(
94 await sdp_client.connect() # type: ignore
98 await sdp_client.disconnect() # type: ignore
99 await self.ref.aio.host.Disconnect(connection=ref_dut)
107 ref_dut_res, dut_ref_res = await asyncio.gather(
123 await sdp_client.connect() # type: ignore
128 …service_record_handles = await sdp_client.search_services([SDP_PUBLIC_BROWSE_ROOT]) # type: ignore
134 attributes = await sdp_client.get_attributes( # type: ignore
142 await sdp_client.disconnect() # type: ignore
[all …]
|
| /packages/modules/Bluetooth/system/rust/tests/ |
| D | gatt_callbacks_test.rs | 39 match events_rx.recv().await.unwrap() { in pull_trans_id()
58 .await in test_read_characteristic_callback()
63 callbacks_rx.recv().await.unwrap() in test_read_characteristic_callback()
81 async move { datastore.read(TCB_IDX, HANDLE_1, OFFSET, BACKING_TYPE).await }, in test_read_characteristic_response()
84 let trans_id = pull_trans_id(&mut callbacks_rx).await; in test_read_characteristic_response()
88 assert_eq!(pending_read.await.unwrap(), Ok(data.to_vec())); in test_read_characteristic_response()
104 async move { datastore.read(TCB_IDX, HANDLE_1, OFFSET, BACKING_TYPE).await }, in test_sequential_reads()
107 let trans_id = pull_trans_id(&mut callbacks_rx).await; in test_sequential_reads()
114 async move { datastore.read(TCB_IDX, HANDLE_1, OFFSET, BACKING_TYPE).await }, in test_sequential_reads()
117 let trans_id = pull_trans_id(&mut callbacks_rx).await; in test_sequential_reads()
[all …]
|
| /packages/modules/Bluetooth/system/gd/rust/topshim/facade/src/ |
| D | gatt_service.rs | 176 sink.success(Empty::default()).await.unwrap(); in register_advertiser()
184 sink.success(Empty::default()).await.unwrap(); in unregister_advertiser()
192 sink.success(Empty::default()).await.unwrap(); in get_own_address()
200 sink.success(Empty::default()).await.unwrap(); in set_parameters()
208 sink.success(Empty::default()).await.unwrap(); in set_data()
216 sink.success(Empty::default()).await.unwrap(); in advertising_enable()
224 sink.success(Empty::default()).await.unwrap(); in advertising_disable()
232 sink.success(Empty::default()).await.unwrap(); in start_advertising()
249 sink.success(Empty::default()).await.unwrap(); in start_advertising_set()
263 sink.success(Empty::default()).await.unwrap(); in set_periodic_advertising_parameters()
[all …]
|
| D | adapter_service.rs | 117 while let Some(event) = rx.lock().await.recv().await { in fetch_events()
126 sink.send((rsp, WriteFlags::default())).await.unwrap(); in fetch_events()
136 sink.send((rsp, WriteFlags::default())).await.unwrap(); in fetch_events()
165 sink.send((rsp, WriteFlags::default())).await.unwrap(); in fetch_events()
181 sink.send((rsp, WriteFlags::default())).await.unwrap(); in fetch_events()
190 sink.send((rsp, WriteFlags::default())).await.unwrap(); in fetch_events()
202 sink.send((rsp, WriteFlags::default())).await.unwrap(); in fetch_events()
215 sink.send((rsp, WriteFlags::default())).await.unwrap(); in fetch_events()
234 sink.success(ToggleStackResponse::default()).await.unwrap(); in toggle_stack()
260 sink.success(resp).await.unwrap(); in set_discovery_mode()
[all …]
|
| /packages/modules/Bluetooth/tools/rootcanal/test/LL/DDI/ADV/ |
| D | BV_09_C.py | 44 await self.expect_evt(
51 await self.expect_evt(
66 await self.expect_evt(
74 …await self.expect_evt(hci.LeSetScanResponseDataComplete(status=ErrorCode.SUCCESS, num_hci_command_…
78 …await self.expect_evt(hci.LeSetAdvertisingEnableComplete(status=ErrorCode.SUCCESS, num_hci_command…
81 await self.steps_4_14(peer_address=public_peer_address,
90 …await self.expect_evt(hci.LeSetAdvertisingEnableComplete(status=ErrorCode.SUCCESS, num_hci_command…
94 await self.steps_4_14(peer_address=random_peer_address,
109 await self.expect_evt(
114 …await self.expect_evt(hci.LeSetAdvertisingEnableComplete(status=ErrorCode.SUCCESS, num_hci_command…
[all …]
|
| D | BV_04_C.py | 46 await self.expect_evt(
55 …await self.expect_evt(hci.LeSetAdvertisingDataComplete(status=ErrorCode.SUCCESS, num_hci_command_p…
61 …await self.expect_evt(hci.LeSetAdvertisingEnableComplete(status=ErrorCode.SUCCESS, num_hci_command…
69 await self.expect_ll(ll.LeLegacyAdvertisingPdu(source_address=controller.address,
79 …await self.expect_evt(hci.LeSetAdvertisingEnableComplete(status=ErrorCode.SUCCESS, num_hci_command…
85 …await self.expect_evt(hci.LeSetAdvertisingDataComplete(status=ErrorCode.SUCCESS, num_hci_command_p…
91 …await self.expect_evt(hci.LeSetAdvertisingEnableComplete(status=ErrorCode.SUCCESS, num_hci_command…
99 await self.expect_ll(ll.LeLegacyAdvertisingPdu(source_address=controller.address,
109 …await self.expect_evt(hci.LeSetAdvertisingEnableComplete(status=ErrorCode.SUCCESS, num_hci_command…
118 …await self.expect_evt(hci.LeSetAdvertisingDataComplete(status=ErrorCode.SUCCESS, num_hci_command_p…
[all …]
|
| D | BV_16_C.py | 45 await self.expect_evt(
54 …await self.expect_evt(hci.LeSetAdvertisingDataComplete(status=ErrorCode.SUCCESS, num_hci_command_p…
60 …await self.expect_evt(hci.LeSetAdvertisingEnableComplete(status=ErrorCode.SUCCESS, num_hci_command…
68 await self.expect_ll(ll.LeLegacyAdvertisingPdu(source_address=controller.address,
78 …await self.expect_evt(hci.LeSetAdvertisingEnableComplete(status=ErrorCode.SUCCESS, num_hci_command…
84 …await self.expect_evt(hci.LeSetAdvertisingDataComplete(status=ErrorCode.SUCCESS, num_hci_command_p…
90 …await self.expect_evt(hci.LeSetAdvertisingEnableComplete(status=ErrorCode.SUCCESS, num_hci_command…
98 await self.expect_ll(ll.LeLegacyAdvertisingPdu(source_address=controller.address,
108 …await self.expect_evt(hci.LeSetAdvertisingEnableComplete(status=ErrorCode.SUCCESS, num_hci_command…
117 …await self.expect_evt(hci.LeSetAdvertisingDataComplete(status=ErrorCode.SUCCESS, num_hci_command_p…
[all …]
|
| D | BV_03_C.py | 47 await self.expect_evt(
56 …await self.expect_evt(hci.LeSetAdvertisingDataComplete(status=ErrorCode.SUCCESS, num_hci_command_p…
62 …await self.expect_evt(hci.LeSetAdvertisingEnableComplete(status=ErrorCode.SUCCESS, num_hci_command…
70 await self.expect_ll(ll.LeLegacyAdvertisingPdu(source_address=controller.address,
80 …await self.expect_evt(hci.LeSetAdvertisingEnableComplete(status=ErrorCode.SUCCESS, num_hci_command…
86 …await self.expect_evt(hci.LeSetAdvertisingDataComplete(status=ErrorCode.SUCCESS, num_hci_command_p…
92 …await self.expect_evt(hci.LeSetAdvertisingEnableComplete(status=ErrorCode.SUCCESS, num_hci_command…
100 await self.expect_ll(ll.LeLegacyAdvertisingPdu(source_address=controller.address,
110 …await self.expect_evt(hci.LeSetAdvertisingEnableComplete(status=ErrorCode.SUCCESS, num_hci_command…
120 …await self.expect_evt(hci.LeSetAdvertisingDataComplete(status=ErrorCode.SUCCESS, num_hci_command_p…
[all …]
|
| D | BV_17_C.py | 45 await self.expect_evt(
57 …await self.expect_evt(hci.LeSetScanResponseDataComplete(status=ErrorCode.SUCCESS, num_hci_command_…
61 …await self.expect_evt(hci.LeSetAdvertisingEnableComplete(status=ErrorCode.SUCCESS, num_hci_command…
69 await self.steps_4_6(peer_address=peer_address, scan_response_data=scan_response_data)
75 …await self.expect_evt(hci.LeSetScanResponseDataComplete(status=ErrorCode.SUCCESS, num_hci_command_…
79 …await self.expect_evt(hci.LeSetAdvertisingEnableComplete(status=ErrorCode.SUCCESS, num_hci_command…
82 await self.steps_4_6(peer_address=peer_address, scan_response_data=scan_response_data)
97 …await self.expect_evt(hci.LeSetScanResponseDataComplete(status=ErrorCode.SUCCESS, num_hci_command_…
101 …await self.expect_evt(hci.LeSetAdvertisingEnableComplete(status=ErrorCode.SUCCESS, num_hci_command…
104 await self.steps_4_6(peer_address=peer_address, scan_response_data=scan_response_data)
[all …]
|
| D | BV_18_C.py | 41 await self.expect_evt(
48 await self.expect_evt(
64 await self.expect_evt(
70 …await self.expect_evt(hci.LeSetScanResponseDataComplete(status=ErrorCode.SUCCESS, num_hci_command_…
74 …await self.expect_evt(hci.LeSetAdvertisingEnableComplete(status=ErrorCode.SUCCESS, num_hci_command…
77 await self.steps_3_12(peer_address=public_peer_address,
95 await self.expect_evt(
100 …await self.expect_evt(hci.LeSetAdvertisingEnableComplete(status=ErrorCode.SUCCESS, num_hci_command…
103 await self.steps_3_12(peer_address=random_peer_address,
119 await self.expect_evt(
[all …]
|
| D | BV_05_C.py | 49 await self.expect_evt(
60 …await self.expect_evt(hci.LeSetScanResponseDataComplete(status=ErrorCode.SUCCESS, num_hci_command_…
64 …await self.expect_evt(hci.LeSetAdvertisingEnableComplete(status=ErrorCode.SUCCESS, num_hci_command…
73 await self.expect_ll(
85 await self.expect_ll(
94 …await self.expect_evt(hci.LeSetAdvertisingEnableComplete(status=ErrorCode.SUCCESS, num_hci_command…
99 …await self.expect_evt(hci.LeSetScanResponseDataComplete(status=ErrorCode.SUCCESS, num_hci_command_…
103 …await self.expect_evt(hci.LeSetAdvertisingEnableComplete(status=ErrorCode.SUCCESS, num_hci_command…
107 await self.expect_ll(
119 await self.expect_ll(
[all …]
|
| D | BV_08_C.py | 41 await self.expect_evt(
48 await self.expect_evt(
64 await self.expect_evt(
72 …await self.expect_evt(hci.LeSetScanResponseDataComplete(status=ErrorCode.SUCCESS, num_hci_command_…
76 …await self.expect_evt(hci.LeSetAdvertisingEnableComplete(status=ErrorCode.SUCCESS, num_hci_command…
88 await self.expect_ll(
105 await self.expect_ll(
126 await self.expect_ll(
138 await self.expect_ll(
151 await self.expect_ll(
[all …]
|
| /packages/modules/Bluetooth/tools/rootcanal/rust/src/lmp/procedure/ |
| D | secure_simple_pairing.rs | 106 .await; in send_public_key()
115 .await; in send_public_key()
121 ctx.receive_lmp_packet::<lmp::EncapsulatedHeader>().await.get_payload_length().into(); in receive_public_key()
129 let payload = ctx.receive_lmp_packet::<lmp::EncapsulatedPayload>().await; in receive_public_key()
163 let _pairing_number = ctx.receive_lmp_packet::<lmp::SimplePairingNumber>().await; in receive_commitment()
180 .await; in receive_commitment()
196 .await; in send_commitment()
198 let _pairing_number = ctx.receive_lmp_packet::<lmp::SimplePairingNumber>().await; in send_commitment()
220 .await in user_confirmation_request()
256 .await in user_passkey_request()
[all …]
|
| /packages/modules/DnsResolver/doh/network/ |
| D | driver.rs | 83 Ok(Connection::new(info, tag_socket, config.take().await.deref_mut(), session, cause).await?) in build_connection()
98 build_connection(&info, &tag_socket, &mut config, None, Cause::Probe).await?; in new()
107 while let Some(cmd) = self.command_rx.recv().await { in drive()
110 if let Err(e) = self.probe(duration).await { in drive()
115 if let Err(e) = self.send_query(query).await { in drive()
136 .await?; in probe()
141 (self.validation)(&self.info, true).await; in probe()
144 self.force_probe(probe_timeout).await in probe()
153 match self.connection.query(dns_request, expiry).await { in force_probe()
156 if let Some(_stream) = rsp.await { in force_probe()
[all …]
|
| /packages/modules/Bluetooth/system/rust/src/gatt/server/ |
| D | att_server_bearer.rs | 133 .await in send_indication()
140 .await in send_indication()
146 indication_handler.send(handle, data, mtu, |packet| this.try_send_packet(packet)).await in send_indication()
167 let reply = request_handler.process_packet(packet.view(), mtu).await; in handle_request()
295 assert_eq!(rx.recv().await.unwrap().opcode, AttOpcode::READ_RESPONSE); in test_single_transaction()
310 assert_eq!(rx.recv().await.unwrap().opcode, AttOpcode::ERROR_RESPONSE); in test_sequential_transactions()
319 assert_eq!(rx.recv().await.unwrap().opcode, AttOpcode::READ_RESPONSE); in test_sequential_transactions()
379 ) = data_rx.recv().await.unwrap() in test_concurrent_transaction_failure()
387 let resp = rx.recv().await.unwrap(); in test_concurrent_transaction_failure()
421 assert_eq!(rx.recv().await.unwrap().opcode, AttOpcode::HANDLE_VALUE_INDICATION); in test_indication_confirmation()
[all …]
|
| D | indication_handler.rs | 90 match timeout(Duration::from_secs(30), self.pending_confirmation.recv()).await { in send()
182 .await in test_indication_sent()
186 let AttChild::AttHandleValueIndication(indication) = rx.await.unwrap() else { in test_indication_sent()
209 .await; in test_invalid_handle()
226 .await; in test_unsupported_permission()
248 .await in test_confirmation_handled()
251 rx.await.unwrap(); in test_confirmation_handled()
255 assert!(matches!(pending_result.await.unwrap(), Ok(()))); in test_confirmation_handled()
274 .await in test_unblock_on_disconnect()
278 rx.await.unwrap(); in test_unblock_on_disconnect()
[all …]
|
| /packages/modules/Bluetooth/android/pandora/test/pairing/ |
| D | smp_test.py | 56 await asyncio.gather(self.dut.reset(), self.ref.reset())
63 dut_pairing_event = await anext(dut_pairing_stream)
66 ref_pairing_event = await anext(ref_pairing_stream)
82 ref_pairing_event = await anext(ref_pairing_stream)
101 … ref = await anext((x async for x in scan if b'pause cafe' in x.data.manufacturer_specific_data))
105 (dut_ref_res, ref_dut_res) = await asyncio.gather(
115 (secure, wait_security) = await asyncio.gather(
122 await pairing
127 await asyncio.gather(
157 ref1 = await self.dut_pair(dut_address_type=RANDOM, ref_address_type=RANDOM)
[all …]
|
| /packages/modules/Bluetooth/tools/rootcanal/test/LL/SEC/ADV/ |
| D | BV_11_C.py | 72 await self.expect_evt(
77 await self.expect_evt(
91 await self.expect_evt(
96 …await self.expect_evt(hci.LeSetAdvertisingDataComplete(status=ErrorCode.SUCCESS, num_hci_command_p…
100 await self.expect_evt(
105 …await self.expect_evt(hci.LeSetAdvertisingEnableComplete(status=ErrorCode.SUCCESS, num_hci_command…
109 direct_ind = await self.expect_ll(ll.LeLegacyAdvertisingPdu(
137 await self.expect_ll(
146 connection_complete_evt = await self.expect_evt(
166 … await self.expect_evt(hci.DisconnectStatus(status=ErrorCode.SUCCESS, num_hci_command_packets=1))
[all …]
|
| /packages/modules/Bluetooth/tools/rootcanal/test/LMP/LIH/ |
| D | BV_143_C.py | 35 …await self.expect_evt(hci.WriteScanEnableComplete(status=ErrorCode.SUCCESS, num_hci_command_packet…
40 …await self.expect_evt(hci.ConnectionRequest(bd_addr=peer_address, link_type=hci.ConnectionRequestL…
45 …await self.expect_evt(hci.AcceptConnectionRequestStatus(status=ErrorCode.SUCCESS, num_hci_command_…
47 await self.expect_ll(
50 await self.expect_evt(
61 await self.expect_evt(
68 … await self.expect_evt(hci.SwitchRoleStatus(status=ErrorCode.SUCCESS, num_hci_command_packets=1))
70 …await self.expect_ll(ll.RoleSwitchRequest(source_address=controller.address, destination_address=p…
77 await self.expect_evt(
83 … await self.expect_evt(hci.SwitchRoleStatus(status=ErrorCode.SUCCESS, num_hci_command_packets=1))
[all …]
|